adds examples and adapts rpc tests

Author: pcrespov

packages/models-library/src/models_library/api_schemas_catalog/services.py

@@ -427,6 +427,39 @@ class MyServicesRpcBatchGet(
 ):
     """Result for batch get user services operations"""
 
+    @staticmethod
+    def _update_json_schema_extra(schema: JsonDict) -> None:
+        missing: Any = [("simcore/services/comp/itis/sleeper", "100.2.3")]
+        schema.update(
+            {
+                "examples": [
+                    {
+                        "found_items": [
+                            {
+                                "key": "simcore/services/comp/itis/sleeper",
+                                "release": {
+                                    "version": "2.2.1",
+                                    "version_display": "Summer Release",
+                                    "released": "2024-07-21T15:00:00",
+                                },
+                                "owner": 42,
+                                "my_access_rights": {
+                                    "execute": True,
+                                    "write": False,
+                                },
+                            }
+                        ],
+                        "missing_identifiers": missing,
+                    }
+                ]
+            }
+        )
+
+    model_config = ConfigDict(
+        extra="forbid",
+        json_schema_extra=_update_json_schema_extra,
+    )
+
 
 class ServiceListFilters(Filters):
     service_type: Annotated[

packages/service-library/src/servicelib/rabbitmq/rpc_interfaces/catalog/errors.py

@@ -19,3 +19,7 @@ class CatalogForbiddenError(CatalogApiBaseError):
 
 class CatalogNotAvailableError(CatalogApiBaseError):
     msg_template = "Catalog service failed unexpectedly"
+
+
+class CatalogBadRequestError(CatalogApiBaseError):
+    msg_template = "Bad request on {name}: {reason}"

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

@@ -608,13 +608,16 @@ async def test_rpc_batch_get_my_services(
         (other_service_key, other_service_version),
     ]
 
-    my_services = await catalog_rpc.batch_get_my_services(
+    batch_got = await catalog_rpc.batch_get_my_services(
         rpc_client,
         product_name=product_name,
         user_id=user_id,
         ids=ids,
     )
 
+    my_services = batch_got.found_items
+    assert batch_got.missing_identifiers == []
+
     assert len(my_services) == 2
 
     # Check access rights to all of them