feat: refactor models

Author: giancarloromeo

services/notifications/src/simcore_service_notifications/models/schemas.py

@@ -15,6 +15,5 @@ class EmailRecipient(BaseModel):
 
 
 class NotificationMessage(BaseModel):
-    recipients: list[Recipient]
     event: str
     context: dict[str, Any] | None = None

services/notifications/src/simcore_service_notifications/modules/celery/_email_tasks.py

@@ -0,0 +1,7 @@
+from ...models.schemas import EmailRecipient, NotificationMessage
+
+
+async def send_email_notification(
+    message: NotificationMessage, recipient: EmailRecipient
+) -> None:
+    pass

services/notifications/src/simcore_service_notifications/modules/celery/worker_main.py

@@ -26,7 +26,7 @@
 
 
 assert _settings.NOTIFICATIONS_CELERY  # nosec
-app = create_celery_app(_settings.NOTIFICATIONS_CELERY)
+the_celery_app = create_celery_app(_settings.NOTIFICATIONS_CELERY)
 
 app_server = FastAPIAppServer(app=create_app())
 
@@ -41,4 +41,4 @@ def worker_init_wrapper(sender, **_kwargs):
 worker_init.connect(worker_init_wrapper)
 worker_shutdown.connect(on_worker_shutdown)
 
-setup_worker_tasks(app)
+setup_worker_tasks(the_celery_app)

services/notifications/src/simcore_service_notifications/services/notifications_service.py

@@ -1,4 +1,6 @@
-from ..models.schemas import NotificationMessage
+from ..models.schemas import NotificationMessage, Recipient
 
 
-async def send_notification_message(message: NotificationMessage) -> None: ...
+async def send_notification(
+    message: NotificationMessage, *recipients: list[Recipient]
+) -> None: ...