adds first tests

Author: pcrespov

packages/models-library/src/models_library/rpc/webserver/projects.py

@@ -43,12 +43,30 @@ def _update_json_schema_extra(schema: JsonDict) -> None:
                 "examples": [
                     {
                         "uuid": "12345678-1234-5678-1234-123456789012",
-                        "name": "My project",
-                        "description": "My project description",
+                        "name": "A solver job",
+                        "description": "A description of a solver job with a single node",
                         "workbench": {f"{uuid4()}": n for n in nodes_examples[2:3]},
                         "created_at": "2023-01-01T00:00:00Z",
                         "modified_at": "2023-01-01T00:00:00Z",
-                        "job_parent_resource_name": "solvers/slv_123/release/1.2.3",
+                        "job_parent_resource_name": "solvers/simcore%2Fservices%2Fcomp%2Fitis%2Fsleeper/releases/2.0.2",
+                    },
+                    {
+                        "uuid": "00000000-1234-5678-1234-123456789012",
+                        "name": "A study job",
+                        "description": "A description of a study job with many node",
+                        "workbench": {f"{uuid4()}": n for n in nodes_examples},
+                        "created_at": "2023-02-01T00:00:00Z",
+                        "modified_at": "2023-02-01T00:00:00Z",
+                        "job_parent_resource_name": "studies/96642f2a-a72c-11ef-8776-02420a00087d",
+                    },
+                    {
+                        "uuid": "00000000-0000-5678-1234-123456789012",
+                        "name": "A program job",
+                        "description": "A program of a solver job with a single node",
+                        "workbench": {f"{uuid4()}": n for n in nodes_examples[2:3]},
+                        "created_at": "2023-03-01T00:00:00Z",
+                        "modified_at": "2023-03-01T00:00:00Z",
+                        "job_parent_resource_name": "program/simcore%2Fservices%2Fdynamic%2Fjupyter/releases/5.0.2",
                     },
                 ]
             }

packages/pytest-simcore/src/pytest_simcore/helpers/webserver_rpc_server.py

@@ -68,7 +68,14 @@ async def list_projects_marked_as_jobs(
             assert not job_parent_resource_name_prefix.endswith("%")
             assert not job_parent_resource_name_prefix.startswith("%")
 
-        items = ProjectJobRpcGet.model_json_schema()["examples"]
+        items = [
+            item
+            for item in ProjectJobRpcGet.model_json_schema()["examples"]
+            if job_parent_resource_name_prefix is None
+            or item.get("job_parent_resource_name").startswith(
+                job_parent_resource_name_prefix
+            )
+        ]
 
         return PageRpcProjectJobRpcGet.create(
             items[offset : offset + limit],

services/api-server/tests/unit/api_solvers/test_api_routers_solvers_jobs_read.py

@@ -12,7 +12,6 @@
 from pytest_simcore.helpers.httpx_calls_capture_models import HttpApiCallCaptureModel
 from respx import MockRouter
 from simcore_service_api_server._meta import API_VTAG
-from simcore_service_api_server.api.dependencies import webserver_rpc
 from simcore_service_api_server.models.pagination import Page
 from simcore_service_api_server.models.schemas.jobs import Job
 from starlette import status
@@ -111,20 +110,17 @@ async def test_list_all_solvers_jobs(
 
     # Basic assertions on the response structure
     assert isinstance(jobs_page.items, list)
-    assert hasattr(jobs_page, "meta")
-    assert hasattr(jobs_page.meta, "total")
+    assert jobs_page.total > 0
+    assert jobs_page.limit == 10
+    assert jobs_page.offset == 0
+    assert jobs_page.total <= len(jobs_page.items)
 
     # Each job should have the expected structure
     for job in jobs_page.items:
-        assert isinstance(job.id, str)
-        assert isinstance(job.name, str)
-        assert hasattr(job, "url")
-
-    # Verify interactions with backend services
-    # These will need to be adjusted based on how the endpoint is implemented
-    # For now, we can assume it might use the solver_service's list_jobs method
-
-    # Additional tests could include:
-    # - Testing pagination by retrieving different pages
-    # - Testing with different limit/offset parameters
-    # - Checking that jobs from different solvers are included
+        assert job.id
+        assert job.name
+        assert job.url is not None
+        assert job.runner_url is not None
+        assert job.outputs_url is not None
+
+    assert mocked_backend.webserver_rpc["list_projects_marked_as_jobs"].called

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

@@ -50,6 +50,7 @@
 from simcore_service_api_server.core.settings import ApplicationSettings
 from simcore_service_api_server.repository.api_keys import UserAndProductTuple
 from simcore_service_api_server.services_http.solver_job_outputs import ResultsTypes
+from simcore_service_api_server.services_rpc.wb_api_server import WbApiRpcClient
 
 
 @pytest.fixture
@@ -245,7 +246,7 @@ def _get_rabbitmq_rpc_client_override():
         return mocker.MagicMock()
 
     async def _get_wb_api_rpc_client_override():
-        return mocker.AsyncMock()
+        return WbApiRpcClient(_client=mocker.MagicMock())
 
     app.dependency_overrides[get_rabbitmq_rpc_client] = (
         _get_rabbitmq_rpc_client_override