add tests for get_project_marked_as_job

Author: bisgaard-itis

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

@@ -86,3 +86,25 @@ async def list_projects_marked_as_jobs(
             limit=limit,
             offset=offset,
         )
+
+    @validate_call(config={"arbitrary_types_allowed": True})
+    async def get_project_marked_as_job(
+        self,
+        rpc_client: RabbitMQRPCClient | MockType,
+        *,
+        product_name: ProductName,
+        user_id: UserID,
+        project_uuid: ProjectID,
+        job_parent_resource_name: str,
+    ) -> ProjectJobRpcGet:
+        assert rpc_client
+        assert product_name
+        assert user_id
+        assert project_uuid
+        assert job_parent_resource_name
+
+        # Return a valid example from the schema
+        example = ProjectJobRpcGet.model_json_schema()["examples"][0]
+        example["uuid"] = str(project_uuid)
+        example["job_parent_resource_name"] = job_parent_resource_name
+        return ProjectJobRpcGet.model_validate(example)

services/api-server/tests/unit/service/test_service_solvers.py

@@ -5,6 +5,8 @@
 
 import pytest
 from models_library.products import ProductName
+from models_library.projects import ProjectID
+from models_library.rpc.webserver.projects import ProjectJobRpcGet
 from models_library.users import UserID
 from pytest_mock import MockType
 from simcore_service_api_server._service_jobs import JobService
@@ -14,6 +16,10 @@
 )
 from simcore_service_api_server.models.schemas.solvers import Solver
 from simcore_service_api_server.services_rpc.catalog import CatalogService
+from simcore_service_api_server.services_rpc.wb_api_server import (
+    ProjectForbiddenRpcError,
+    ProjectNotFoundRpcError,
+)
 
 
 async def test_get_solver(
@@ -73,3 +79,48 @@ async def test_solver_service_init_raises_configuration_error(
         )
     # Verify the RPC call was made to check consistency
     assert not mocked_rpc_client.request.called
+
+
+async def test_job_service_get_job_success(
+    mocked_rpc_client: MockType,
+    job_service: JobService,
+):
+    job_parent_resource_name = "solver-resource"
+    job_id = ProjectID("123e4567-e89b-12d3-a456-426614174000")
+
+    # Act
+    result = await job_service.get_job(job_parent_resource_name, job_id)
+
+    # Assert
+    assert isinstance(result, ProjectJobRpcGet)
+    assert result.job_parent_resource_name.startswith(job_parent_resource_name)
+    assert mocked_rpc_client.request.called
+    assert mocked_rpc_client.request.call_args.args == (
+        "webserver",
+        "get_project_marked_as_job",
+    )
+    assert (
+        mocked_rpc_client.request.call_args.kwargs["job_parent_resource_name"]
+        == job_parent_resource_name
+    )
+    assert mocked_rpc_client.request.call_args.kwargs["project_uuid"] == job_id
+
+
+@pytest.mark.parametrize(
+    "exception_type",
+    [ProjectForbiddenRpcError, ProjectNotFoundRpcError],
+)
+async def test_job_service_get_job_exceptions(
+    mocker, job_service: JobService, exception_type
+):
+    job_parent_resource_name = "solver-resource"
+    job_id = ProjectID("123e4567-e89b-12d3-a456-426614174000")
+    mocker.patch.object(
+        job_service._web_rpc_client,
+        "get_project_marked_as_job",
+        side_effect=exception_type("error"),
+    )
+
+    with pytest.raises(exception_type):
+        await job_service.get_job(job_parent_resource_name, job_id)
+        await job_service.get_job(job_parent_resource_name, job_id)