setup rpc

Author: pcrespov

services/web/server/src/simcore_service_webserver/products/_controller/rpc.py

@@ -5,7 +5,8 @@
 from models_library.products import CreditResultGet, ProductName
 from servicelib.rabbitmq import RPCRouter
 
-from ...rabbitmq import get_rabbitmq_rpc_server
+from ...constants import APP_SETTINGS_KEY
+from ...rabbitmq import get_rabbitmq_rpc_server, setup_rabbitmq
 from .. import _service
 
 router = RPCRouter()
@@ -24,6 +25,12 @@ async def get_credit_amount(
     return credit_result_get
 
 
-async def register_rpc_routes_on_startup(app: web.Application):
+async def _register_rpc_routes_on_startup(app: web.Application):
     rpc_server = get_rabbitmq_rpc_server(app)
     await rpc_server.register_router(router, WEBSERVER_RPC_NAMESPACE, app)
+
+
+def setup_rpc(app: web.Application):
+    setup_rabbitmq(app)
+    if app[APP_SETTINGS_KEY].WEBSERVER_RABBITMQ:
+        app.on_startup.append(_register_rpc_routes_on_startup)

services/web/server/src/simcore_service_webserver/products/plugin.py

@@ -29,22 +29,15 @@ def setup_products(app: web.Application):
     # specially if this plugin is not set up to be loaded
     #
     from ..constants import APP_SETTINGS_KEY
-    from ..rabbitmq import setup_rabbitmq
     from . import _web_events, _web_middlewares
     from ._controller import rest, rpc
 
     assert app[APP_SETTINGS_KEY].WEBSERVER_PRODUCTS is True  # nosec
 
-    # set middlewares
     app.middlewares.append(_web_middlewares.discover_product_middleware)
 
-    # setup rest
     app.router.add_routes(rest.routes)
 
-    # setup rpc
-    setup_rabbitmq(app)
-    if app[APP_SETTINGS_KEY].WEBSERVER_RABBITMQ:
-        app.on_startup.append(rpc.register_rpc_routes_on_startup)
+    rpc.setup_rpc(app)
 
-    # setup events
     _web_events.setup_web_events(app)