connect to rpc

Author: pcrespov

services/catalog/src/simcore_service_catalog/api/rpc/_services.py

@@ -21,6 +21,7 @@
     CatalogForbiddenError,
     CatalogItemNotFoundError,
 )
+from simcore_service_catalog.db.repositories.groups import GroupsRepository
 
 from ...db.repositories.services import ServicesRepository
 from ...services import services_api
@@ -182,5 +183,17 @@ async def batch_get_my_services(
         ]
     ],
 ) -> list[MyServiceGet]:
+    assert app.state.engine  # nosec
+
+    # TODO: id not found?
+    services = await services_api.batch_get_my_services(
+        repo=ServicesRepository(app.state.engine),
+        groups_repo=GroupsRepository(app.state.engine),
+        product_name=product_name,
+        user_id=user_id,
+        ids=ids,
+    )
+
+    assert [(sv.key, sv.release.version) for sv in services] == ids  # nosec
 
-    raise NotImplementedError
+    return services

services/catalog/tests/unit/with_dbs/test_services_services_api.py

@@ -256,3 +256,7 @@ async def test_batch_get_my_services(
             },
         ]
     )
+
+    # TODO: test user has no access to one and needs to ask owner (NOTE: owner can be a group? )
+    # TODO: test user has no access to entire history
+    #