connecting new rpc client

Author: pcrespov

services/api-server/src/simcore_service_api_server/services_rpc/wb_api_server.py

@@ -85,10 +85,13 @@
 from servicelib.rabbitmq.rpc_interfaces.webserver.licenses.licensed_items import (
     release_licensed_item_for_wallet as _release_licensed_item_for_wallet,
 )
+from servicelib.rabbitmq.rpc_interfaces.webserver.v1 import WebServerRpcClient
 from simcore_service_api_server.models.basic_types import NameValueTuple
 
+from ..core.settings import WebServerSettings
 from ..exceptions.backend_errors import (
     CanNotCheckoutServiceIsNotRunningError,
+    ConfigurationError,
     InsufficientNumberOfSeatsError,
     JobForbiddenAccessError,
     JobNotFoundError,
@@ -138,6 +141,7 @@ def _create_licensed_items_get_page(
 class WbApiRpcClient(SingletonInAppStateMixin):
     app_state_name = "wb_api_rpc_client"
     _client: RabbitMQRPCClient
+    _rpc_client: WebServerRpcClient
 
     @_exception_mapper(rpc_exception_map={})
     async def get_licensed_items(
@@ -253,8 +257,7 @@ async def mark_project_as_job(
         job_parent_resource_name: RelativeResourceName,
         storage_assets_deleted: bool,  # noqa: FBT001
     ):
-        await projects_rpc.mark_project_as_job(
-            rpc_client=self._client,
+        await self._rpc_client.projects.mark_project_as_job(
             product_name=product_name,
             user_id=user_id,
             project_uuid=project_uuid,
@@ -702,5 +705,14 @@ async def get_functions_user_api_access_rights(
 
 
 def setup(app: FastAPI, rabbitmq_rmp_client: RabbitMQRPCClient):
-    wb_api_rpc_client = WbApiRpcClient(_client=rabbitmq_rmp_client)
+    webserver_settings: WebServerSettings = app.state.settings.API_SERVER_WEBSERVER
+    if not webserver_settings:
+        raise ConfigurationError(tip="Webserver settings are not configured")
+
+    wb_api_rpc_client = WbApiRpcClient(
+        _client=rabbitmq_rmp_client,
+        _rpc_client=WebServerRpcClient(
+            rabbitmq_rmp_client, webserver_settings.WEBSERVER_RPC_NAMESPACE
+        ),
+    )
     wb_api_rpc_client.set_to_app_state(app=app)