add test for matching output endpoints

Author: bisgaard-itis

services/web/server/tests/unit/with_dbs/01/test_catalog_handlers__services.py

@@ -30,7 +30,7 @@
 from pytest_simcore.helpers.typing_env import EnvVarsDict
 from pytest_simcore.helpers.webserver_login import UserInfoDict
 from servicelib.aiohttp import status
-from simcore_service_webserver.catalog._models import ServiceInputGet
+from simcore_service_webserver.catalog._models import ServiceInputGet, ServiceOutputGet
 from simcore_service_webserver.db.models import UserRole
 
 
@@ -188,6 +188,65 @@ async def test_list_inputs(
     TypeAdapter(list[ServiceInputGet]).validate_python(data)
 
 
+@pytest.mark.parametrize(
+    "user_role",
+    [UserRole.USER],
+)
+async def test_list_outputs(
+    client: TestClient, logged_user: UserInfoDict, aioresponses_mocker: AioResponsesMock
+):
+
+    url_pattern = re.compile(r"http://catalog:8000/v0/services/.*")
+    service_payload = ServiceGetV2.model_json_schema()["examples"][0]
+    aioresponses_mocker.get(
+        url_pattern,
+        status=status.HTTP_200_OK,
+        payload=service_payload,
+    )
+
+    service_key = "simcore/services/comp/itis/sleeper"
+    service_version = "0.1.0"
+    assert client.app and client.app.router
+    url = client.app.router["list_service_outputs"].url_for(
+        service_key=urllib.parse.quote(service_key, safe=""),
+        service_version=service_version,
+    )
+
+    response = await client.get(f"{url}")
+    data, _ = await assert_status(response, status.HTTP_200_OK)
+    TypeAdapter(list[ServiceOutputGet]).validate_python(data)
+
+
+@pytest.mark.parametrize(
+    "user_role",
+    [UserRole.USER],
+)
+async def test_get_outputs(
+    client: TestClient, logged_user: UserInfoDict, aioresponses_mocker: AioResponsesMock
+):
+
+    url_pattern = re.compile(r"http://catalog:8000/v0/services/.*")
+    service_payload = ServiceGetV2.model_json_schema()["examples"][0]
+    aioresponses_mocker.get(
+        url_pattern,
+        status=status.HTTP_200_OK,
+        payload=service_payload,
+    )
+
+    service_key = "simcore/services/comp/itis/sleeper"
+    service_version = "0.1.0"
+    assert client.app and client.app.router
+    url = client.app.router["get_service_output"].url_for(
+        service_key=urllib.parse.quote(service_key, safe=""),
+        service_version=service_version,
+        output_key=next(iter(service_payload["outputs"].keys())),
+    )
+
+    response = await client.get(f"{url}")
+    data, _ = await assert_status(response, status.HTTP_200_OK)
+    ServiceOutputGet.model_validate(data)
+
+
 @pytest.mark.parametrize(
     "user_role",
     [UserRole.USER],
@@ -253,6 +312,43 @@ async def test_get_compatible_inputs_given_source_outputs(
     _, _ = await assert_status(response, status.HTTP_200_OK)
 
 
+@pytest.mark.parametrize(
+    "user_role",
+    [UserRole.USER],
+)
+async def test_get_compatible_outputs_given_target_inptuts(
+    client: TestClient, logged_user: UserInfoDict, aioresponses_mocker: AioResponsesMock
+):
+    url_pattern = re.compile(r"http://catalog:8000/v0/services/.*")
+    service_payload = ServiceGetV2.model_json_schema()["examples"][0]
+    for _ in range(2):
+        aioresponses_mocker.get(
+            url_pattern,
+            status=status.HTTP_200_OK,
+            payload=service_payload,
+        )
+
+    service_key = "simcore/services/comp/itis/sleeper"
+    service_version = "0.1.0"
+    assert client.app and client.app.router
+    url = (
+        client.app.router["get_compatible_outputs_given_target_input"]
+        .url_for(
+            service_key=urllib.parse.quote(service_key, safe=""),
+            service_version=service_version,
+        )
+        .with_query(
+            {
+                "toService": "simcore/services/comp/itis/sleeper",
+                "toVersion": "0.1.0",
+                "toInput": "input_1",
+            }
+        )
+    )
+    response = await client.get(f"{url}")
+    _, _ = await assert_status(response, status.HTTP_200_OK)
+
+
 @pytest.mark.parametrize(
     "user_role",
     [UserRole.USER],