feat: add rabbitmq call

Author: giancarloromeo

packages/service-library/src/servicelib/rabbitmq/rpc_interfaces/notifications/messages.py

@@ -1,2 +1,25 @@
-async def send_notification_message():
-    pass
+from typing import Final
+
+from models_library.api_schemas_notifications import NOTIFICATIONS_RPC_NAMESPACE
+from models_library.rabbitmq_basic_types import RPCMethodName
+from models_library.rpc.notifications.messages import NotificationMessage, Recipient
+from pydantic import NonNegativeInt, TypeAdapter
+
+from ... import RabbitMQRPCClient
+
+_DEFAULT_TIMEOUT_S: Final[NonNegativeInt] = 30
+
+
+async def send_notification_message(
+    rabbitmq_rpc_client: RabbitMQRPCClient,
+    *,
+    message: NotificationMessage,
+    recipients: list[Recipient],
+) -> None:
+    await rabbitmq_rpc_client.request(
+        NOTIFICATIONS_RPC_NAMESPACE,
+        TypeAdapter(RPCMethodName).validate_python("send_notification_message"),
+        timeout_s=_DEFAULT_TIMEOUT_S,
+        message=message,
+        recipients=recipients,
+    )

services/notifications/tests/conftest.py

@@ -24,9 +24,7 @@
 from simcore_service_notifications.core.application import create_app
 from simcore_service_notifications.core.settings import ApplicationSettings
 from simcore_service_notifications.modules.celery.tasks import (
-    TaskQueue,  # type: ignore[import-untyped]
-)
-from simcore_service_notifications.modules.celery.tasks import (
+    TaskQueue,
     setup_worker_tasks,
 )
 

services/notifications/tests/unit/test_tasks.py

@@ -0,0 +1,9 @@
+from celery.contrib.testing.worker import TestWorkController
+from servicelib.rabbitmq import RabbitMQRPCClient
+
+
+async def test_send_email(
+    notifications_rabbitmq_rpc_client: RabbitMQRPCClient,
+    with_celery_worker: TestWorkController,
+):
+    pass