add mock of director v2 endpoint

Author: bisgaard-itis

packages/models-library/src/models_library/api_schemas_directorv2/computations.py

@@ -130,6 +130,25 @@ class TaskLogFileIdGet(BaseModel):
     task_id: NodeID
     file_id: SimcoreS3FileID | None
 
+    model_config = ConfigDict(
+        json_schema_extra={
+            "examples": [
+                {
+                    "task_id": "3fa85f64-5717-4562-b3fc-2c963f66afa6",
+                    "file_id": "1c46752c-b096-11ea-a3c4-02420a00392e/3fa85f64-5717-4562-b3fc-2c963f66afa6/logs/task_logs.txt",
+                },
+                {
+                    "task_id": "6ba7b810-9dad-11d1-80b4-00c04fd430c8",
+                    "file_id": "1c46752c-b096-11ea-a3c4-02420a00392e/6ba7b810-9dad-11d1-80b4-00c04fd430c8/logs/debug.log",
+                },
+                {
+                    "task_id": "6ba7b811-9dad-11d1-80b4-00c04fd430c8",
+                    "file_id": None,
+                },
+            ]
+        }
+    )
+
 
 class TasksSelection(BaseModel):
     nodes_ids: list[NodeID]

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

@@ -0,0 +1,30 @@
+# pylint: disable=no-self-use
+# pylint: disable=not-context-manager
+# pylint: disable=protected-access
+# pylint: disable=redefined-outer-name
+# pylint: disable=unused-argument
+# pylint: disable=unused-variable
+
+
+from models_library.api_schemas_directorv2.computations import TaskLogFileIdGet
+from models_library.projects import ProjectID
+from pydantic import TypeAdapter, validate_call
+from pytest_mock import MockType
+from servicelib.rabbitmq._client_rpc import RabbitMQRPCClient
+
+
+class DirectorV2SideEffects:
+    # pylint: disable=no-self-use
+    @validate_call(config={"arbitrary_types_allowed": True})
+    async def get_computation_task_log_file_ids(
+        self,
+        rpc_client: RabbitMQRPCClient | MockType,
+        *,
+        project_id: ProjectID,
+    ) -> list[TaskLogFileIdGet]:
+        assert rpc_client
+        assert project_id
+
+        return TypeAdapter(list[TaskLogFileIdGet]).validate_python(
+            TaskLogFileIdGet.model_json_schema()["examples"],
+        )

services/api-server/tests/unit/api_functions/test_api_routers_functions.py

@@ -889,7 +889,14 @@ async def test_export_logs(
     auth: httpx.BasicAuth,
     user_id: UserID,
 ):
+    mock_handler_in_functions_rpc_interface(
+        "get_function", mock_registered_project_function
+    )
+    mock_handler_in_functions_rpc_interface(
+        "get_function_job", mock_registered_function_job
+    )
+
     response = await client.post(
-        f"{API_VTAG}/functions/{mock_registered_project_function.uid}/export_logs",
+        f"{API_VTAG}/functions/{mock_registered_project_function.uid}/logs",
         auth=auth,
     )