add initial rpc route

Author: bisgaard-itis

packages/models-library/src/models_library/api_schemas_storage/__init__.py

@@ -0,0 +1,9 @@
+from typing import Final
+
+from pydantic import TypeAdapter
+
+from ..rabbitmq_basic_types import RPCNamespace
+
+STORAGE_RPC_NAMESPACE: Final[RPCNamespace] = TypeAdapter(RPCNamespace).validate_python(
+    "storage"
+)

services/storage/src/simcore_service_storage/api/rabbitmq_rpc/_zipping.py

@@ -0,0 +1,8 @@
+from servicelib.rabbitmq import RPCRouter
+
+router = RPCRouter()
+
+
+@router.expose()
+async def start_zipping(paths: list[str]) -> str:
+    return f"Started zipping [ { ','.join(paths) } ]"

services/storage/src/simcore_service_storage/api/rabbitmq_rpc/routes.py

@@ -0,0 +1,28 @@
+import logging
+
+from fastapi import FastAPI
+from models_library.api_schemas_storage import STORAGE_RPC_NAMESPACE
+from servicelib.logging_utils import log_context
+from servicelib.rabbitmq import RPCRouter
+
+from ...modules.rabbitmq import get_rabbitmq_rpc_server
+from . import _zipping
+
+_logger = logging.getLogger(__name__)
+
+
+ROUTERS: list[RPCRouter] = [_zipping.router]
+
+
+def setup_rpc_api_routes(app: FastAPI) -> None:
+    async def startup() -> None:
+        with log_context(
+            _logger,
+            logging.INFO,
+            msg="RUT startup RPC API Routes",
+        ):
+            rpc_server = get_rabbitmq_rpc_server(app)
+            for router in ROUTERS:
+                await rpc_server.register_router(router, STORAGE_RPC_NAMESPACE, app)
+
+    app.add_event_handler("startup", startup)