|
@@ -4,7 +4,7 @@ from pathlib import Path
|
|
|
from dataclasses import asdict
|
|
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, JobOffer
|
|
|
from job_search.messages import (
|
|
from job_search.messages import (
|
|
|
VisitedLinkedInJobPageMessage,
|
|
VisitedLinkedInJobPageMessage,
|
|
|
AddJobMessage,
|
|
AddJobMessage,
|
|
@@ -15,6 +15,7 @@ from job_search.messages import (
|
|
|
LogMessage,
|
|
LogMessage,
|
|
|
Message,
|
|
Message,
|
|
|
JobAddedMessage,
|
|
JobAddedMessage,
|
|
|
|
|
+ JobAddedNewMessage,
|
|
|
JobAlreadyExistsMessage,
|
|
JobAlreadyExistsMessage,
|
|
|
)
|
|
)
|
|
|
|
|
|
|
@@ -38,6 +39,7 @@ class Application:
|
|
|
case AddJobMessage():
|
|
case AddJobMessage():
|
|
|
try:
|
|
try:
|
|
|
self.job_storage.insert_record("job_offer", asdict(message))
|
|
self.job_storage.insert_record("job_offer", asdict(message))
|
|
|
|
|
+ self.read_writer.send_message(JobAddedNewMessage(message.id))
|
|
|
except FileExistsError as e:
|
|
except FileExistsError as e:
|
|
|
self.read_writer.send_message(JobAlreadyExistsMessage(message.id))
|
|
self.read_writer.send_message(JobAlreadyExistsMessage(message.id))
|
|
|
|
|
|