feat: implement get_service_ports method in CatalogService and add corresponding tests

Author: pcrespov

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

@@ -3,6 +3,7 @@
 
 from fastapi import Depends
 from models_library.api_schemas_catalog.services import LatestServiceGet, ServiceGetV2
+from models_library.api_schemas_catalog.services_ports import ServicePortGet
 from models_library.products import ProductName
 from models_library.rest_pagination import (
     DEFAULT_NUMBER_OF_ITEMS_PER_PAGE,
@@ -113,3 +114,33 @@ async def get(
             service_key=name,
             service_version=version,
         )
+
+    @_exception_mapper(
+        rpc_exception_map={
+            CatalogItemNotFoundError: ProgramOrSolverOrStudyNotFoundError,
+            CatalogForbiddenError: ServiceForbiddenAccessError,
+            ValidationError: InvalidInputError,
+        }
+    )
+    async def get_service_ports(
+        self,
+        *,
+        product_name: ProductName,
+        user_id: UserID,
+        service_key: ServiceKey,
+        service_version: ServiceVersion,
+    ) -> list[ServicePortGet]:
+        """Gets service ports (inputs and outputs) for a specific service version
+
+        Raises:
+            ProgramOrSolverOrStudyNotFoundError: service not found in catalog
+            ServiceForbiddenAccessError: no access rights to read this service
+            InvalidInputError: invalid input parameters
+        """
+        return await catalog_rpc.get_service_ports(
+            self._client,
+            product_name=product_name,
+            user_id=user_id,
+            service_key=service_key,
+            service_version=service_version,
+        )

services/api-server/tests/unit/conftest.py

@@ -96,6 +96,12 @@ def get_mock_rabbitmq_rpc_client():
             autospec=True,
             side_effect=side_effects.list_my_service_history_paginated,
         ),
+        "get_service_ports": mocker.patch.object(
+            catalog_rpc,
+            "get_service_ports",
+            autospec=True,
+            side_effect=side_effects.get_service_ports,
+        ),
     }
     app.dependency_overrides.pop(get_rabbitmq_rpc_client)
 

services/api-server/tests/unit/test_services_catalog.py

@@ -76,9 +76,23 @@ async def test_catalog_service_read_solvers(
     assert solver.id == selected_solver.id
     assert solver.version == oldest_release.version
 
+    # Step 4: Get service ports for the solver
+    ports = await catalog_service.get_service_ports(
+        product_name=product_name,
+        user_id=user_id,
+        service_key=selected_solver.id,
+        service_version=oldest_release.version,
+    )
+
+    # Verify ports are returned and contain both inputs and outputs
+    assert ports, "Service ports should not be empty"
+    assert any(port.kind == "input" for port in ports), "Should contain input ports"
+    assert any(port.kind == "output" for port in ports), "Should contain output ports"
+
     # checks calls to rpc
     mocked_rpc_catalog_service_api["list_services_paginated"].assert_called_once()
     mocked_rpc_catalog_service_api[
         "list_my_service_history_paginated"
     ].assert_called_once()
     mocked_rpc_catalog_service_api["get_service"].assert_called_once()
+    mocked_rpc_catalog_service_api["get_service_ports"].assert_called_once()