|
@@ -1,11 +1,13 @@
|
|
|
import sys
|
|
import sys
|
|
|
import traceback
|
|
import traceback
|
|
|
from pathlib import Path
|
|
from pathlib import Path
|
|
|
|
|
+from dataclasses import asdict
|
|
|
|
|
|
|
|
from job_search.read_write import ReadWriter
|
|
from job_search.read_write import ReadWriter
|
|
|
from job_search.job_storage import JobStorage
|
|
from job_search.job_storage import JobStorage
|
|
|
from job_search.messages import (
|
|
from job_search.messages import (
|
|
|
VisitedLinkedInJobPageMessage,
|
|
VisitedLinkedInJobPageMessage,
|
|
|
|
|
+ AddJobMessage,
|
|
|
InitialConfigurationMessage,
|
|
InitialConfigurationMessage,
|
|
|
JobOfferListMessage,
|
|
JobOfferListMessage,
|
|
|
LogMessage,
|
|
LogMessage,
|
|
@@ -31,6 +33,12 @@ class Application:
|
|
|
except FileExistsError as e:
|
|
except FileExistsError as e:
|
|
|
self.read_writer.send_message(JobAlreadyExistsMessage(offer.id))
|
|
self.read_writer.send_message(JobAlreadyExistsMessage(offer.id))
|
|
|
|
|
|
|
|
|
|
+ case AddJobMessage():
|
|
|
|
|
+ try:
|
|
|
|
|
+ self.job_storage.insert_record("job_offer", asdict(message))
|
|
|
|
|
+ except FileExistsError as e:
|
|
|
|
|
+ self.read_writer.send_message(JobAlreadyExistsMessage(message.id))
|
|
|
|
|
+
|
|
|
case InitialConfigurationMessage(jobs_path):
|
|
case InitialConfigurationMessage(jobs_path):
|
|
|
self.job_storage = JobStorage(base_dir=Path(jobs_path))
|
|
self.job_storage = JobStorage(base_dir=Path(jobs_path))
|
|
|
|
|
|