🎨 Require parent info headers when running function (#7900)

Author: bisgaard-itis

services/api-server/openapi.json

@@ -7604,6 +7604,42 @@
               "format": "uuid",
               "title": "Function Id"
             }
+          },
+          {
+            "name": "x-simcore-parent-project-uuid",
+            "in": "header",
+            "required": true,
+            "schema": {
+              "anyOf": [
+                {
+                  "type": "string",
+                  "format": "uuid"
+                },
+                {
+                  "const": "null",
+                  "type": "string"
+                }
+              ],
+              "title": "X-Simcore-Parent-Project-Uuid"
+            }
+          },
+          {
+            "name": "x-simcore-parent-node-id",
+            "in": "header",
+            "required": true,
+            "schema": {
+              "anyOf": [
+                {
+                  "type": "string",
+                  "format": "uuid"
+                },
+                {
+                  "const": "null",
+                  "type": "string"
+                }
+              ],
+              "title": "X-Simcore-Parent-Node-Id"
+            }
           }
         ],
         "requestBody": {
@@ -7700,6 +7736,42 @@
               "format": "uuid",
               "title": "Function Id"
             }
+          },
+          {
+            "name": "x-simcore-parent-project-uuid",
+            "in": "header",
+            "required": true,
+            "schema": {
+              "anyOf": [
+                {
+                  "type": "string",
+                  "format": "uuid"
+                },
+                {
+                  "const": "null",
+                  "type": "string"
+                }
+              ],
+              "title": "X-Simcore-Parent-Project-Uuid"
+            }
+          },
+          {
+            "name": "x-simcore-parent-node-id",
+            "in": "header",
+            "required": true,
+            "schema": {
+              "anyOf": [
+                {
+                  "type": "string",
+                  "format": "uuid"
+                },
+                {
+                  "const": "null",
+                  "type": "string"
+                }
+              ],
+              "title": "X-Simcore-Parent-Node-Id"
+            }
           }
         ],
         "requestBody": {

services/api-server/src/simcore_service_api_server/api/routes/functions_routes.py

@@ -1,8 +1,9 @@
+# pylint: disable=too-many-positional-arguments
 from collections.abc import Callable
-from typing import Annotated, Final
+from typing import Annotated, Final, Literal
 
 import jsonschema
-from fastapi import APIRouter, Depends, Request, status
+from fastapi import APIRouter, Depends, Header, Request, status
 from fastapi_pagination.api import create_page
 from jsonschema import ValidationError
 from models_library.api_schemas_api_server.functions import (
@@ -29,6 +30,8 @@
     UnsupportedFunctionClassError,
 )
 from models_library.products import ProductName
+from models_library.projects import ProjectID
+from models_library.projects_nodes_io import NodeID
 from models_library.projects_state import RunningState
 from models_library.users import UserID
 from servicelib.fastapi.dependencies import get_reverse_url_mapper
@@ -372,8 +375,21 @@ async def run_function(  # noqa: PLR0913
     product_name: Annotated[str, Depends(get_product_name)],
     solver_service: Annotated[SolverService, Depends(get_solver_service)],
     job_service: Annotated[JobService, Depends(get_job_service)],
+    x_simcore_parent_project_uuid: Annotated[ProjectID | Literal["null"], Header()],
+    x_simcore_parent_node_id: Annotated[NodeID | Literal["null"], Header()],
 ) -> RegisteredFunctionJob:
 
+    parent_project_uuid = (
+        x_simcore_parent_project_uuid
+        if isinstance(x_simcore_parent_project_uuid, ProjectID)
+        else None
+    )
+    parent_node_id = (
+        x_simcore_parent_node_id
+        if isinstance(x_simcore_parent_node_id, NodeID)
+        else None
+    )
+
     # Make sure the user is allowed to execute any function
     # (read/write right is checked in the other endpoint called in this method)
     user_api_access_rights = await wb_api_rpc.get_functions_user_api_access_rights(
@@ -443,8 +459,8 @@ async def run_function(  # noqa: PLR0913
             webserver_api=webserver_api,
             wb_api_rpc=wb_api_rpc,
             url_for=url_for,
-            x_simcore_parent_project_uuid=None,
-            x_simcore_parent_node_id=None,
+            x_simcore_parent_project_uuid=parent_project_uuid,
+            x_simcore_parent_node_id=parent_node_id,
             user_id=user_id,
             product_name=product_name,
         )
@@ -478,8 +494,8 @@ async def run_function(  # noqa: PLR0913
             solver_service=solver_service,
             job_service=job_service,
             url_for=url_for,
-            x_simcore_parent_project_uuid=None,
-            x_simcore_parent_node_id=None,
+            x_simcore_parent_project_uuid=parent_project_uuid,
+            x_simcore_parent_node_id=parent_node_id,
         )
         await solvers_jobs.start_job(
             request=request,
@@ -558,6 +574,8 @@ async def map_function(  # noqa: PLR0913
     product_name: Annotated[str, Depends(get_product_name)],
     solver_service: Annotated[SolverService, Depends(get_solver_service)],
     job_service: Annotated[JobService, Depends(get_job_service)],
+    x_simcore_parent_project_uuid: Annotated[ProjectID | Literal["null"], Header()],
+    x_simcore_parent_node_id: Annotated[NodeID | Literal["null"], Header()],
 ) -> RegisteredFunctionJobCollection:
     function_jobs = []
     function_jobs = [
@@ -573,6 +591,8 @@ async def map_function(  # noqa: PLR0913
             request=request,
             solver_service=solver_service,
             job_service=job_service,
+            x_simcore_parent_project_uuid=x_simcore_parent_project_uuid,
+            x_simcore_parent_node_id=x_simcore_parent_node_id,
         )
         for function_inputs in function_inputs_list
     ]