feat: add skeletons and schemas

Author: giancarloromeo

services/notifications/src/simcore_service_notifications/api/rpc/_notifications.py

@@ -0,0 +1,16 @@
+from fastapi import FastAPI
+from servicelib.rabbitmq import RPCRouter
+
+from ...models.schemas import NotificationMessage
+from ...services import notifications_service
+
+router = RPCRouter()
+
+
+@router.expose(reraise_if_error_type=())
+async def send_notification_message(
+    app: FastAPI,
+    *,
+    message: NotificationMessage,
+) -> None:
+    await notifications_service.send_notification_message(message=message)

services/notifications/src/simcore_service_notifications/api/rpc/routes.py

@@ -6,10 +6,9 @@
 from servicelib.rabbitmq import RPCRouter
 
 from ...clients.rabbitmq import get_rabbitmq_rpc_server
+from . import _notifications
 
-ROUTERS: list[RPCRouter] = [
-    # import and use all routers here
-]
+ROUTERS: list[RPCRouter] = [_notifications.router]
 
 
 async def rpc_api_routes_lifespan(app: FastAPI) -> AsyncIterator[State]:

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

@@ -0,0 +1,20 @@
+from typing import Any, TypeAlias
+
+from pydantic import BaseModel
+
+
+class SMSRecipient(BaseModel):
+    phone_number: str
+
+
+class EmailRecipient(BaseModel):
+    email: str
+
+
+Recipient: TypeAlias = SMSRecipient | EmailRecipient
+
+
+class NotificationMessage(BaseModel):
+    recipients: list[Recipient]
+    event: str
+    context: dict[str, Any] | None = None

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

@@ -0,0 +1,4 @@
+from ..models.schemas import NotificationMessage
+
+
+async def send_notification_message(message: NotificationMessage) -> None: ...