added product_name

Author: sanderegg

services/web/server/src/simcore_service_webserver/projects/_controller/projects_states_rest.py

@@ -165,6 +165,7 @@ async def open_project(request: web.Request) -> web.Response:
             user_id=req_ctx.user_id,
             project=project,
             app=request.app,
+            product_name=req_ctx.product_name,
         )
         await _projects_service.notify_project_state_update(request.app, project)
 

services/web/server/src/simcore_service_webserver/projects/_crud_api_create.py

@@ -433,6 +433,7 @@ async def create_project(  # pylint: disable=too-many-arguments,too-many-branche
             user_id=user_id,
             project=new_project,
             app=request.app,
+            product_name=product_name,
         )
         await progress.update()
 

services/web/server/src/simcore_service_webserver/projects/_crud_api_read.py

@@ -10,6 +10,7 @@
 
 from aiohttp import web
 from models_library.folders import FolderID, FolderQuery, FolderScope
+from models_library.products import ProductName
 from models_library.projects import ProjectTemplateType
 from models_library.rest_ordering import OrderBy
 from models_library.users import UserID
@@ -51,6 +52,7 @@ async def _aggregate_data_to_projects_from_other_sources(
     *,
     db_projects: list[ProjectDict],
     user_id: UserID,
+    product_name: ProductName,
 ) -> list[ProjectDict]:
     """
     Aggregates data to each project from other sources, first as a batch-update and then as a parallel-update.
@@ -73,9 +75,7 @@ async def _aggregate_data_to_projects_from_other_sources(
     # udpating `project.state`
     update_state_per_project = [
         _projects_service.add_project_states_for_user(
-            user_id=user_id,
-            project=prj,
-            app=app,
+            user_id=user_id, project=prj, app=app, product_name=product_name
         )
         for prj in db_projects
     ]
@@ -188,7 +188,7 @@ async def list_projects(  # pylint: disable=too-many-arguments
     )
 
     final_projects = await _aggregate_data_to_projects_from_other_sources(
-        app, db_projects=api_projects, user_id=user_id
+        app, db_projects=api_projects, user_id=user_id, product_name=product_name
     )
 
     return final_projects, total_number_projects
@@ -235,7 +235,7 @@ async def list_projects_full_depth(  # pylint: disable=too-many-arguments
     )
 
     final_projects = await _aggregate_data_to_projects_from_other_sources(
-        app, db_projects=api_projects, user_id=user_id
+        app, db_projects=api_projects, user_id=user_id, product_name=product_name
     )
 
     return final_projects, total_number_projects

services/web/server/src/simcore_service_webserver/projects/_projects_service.py

@@ -281,6 +281,7 @@ async def get_project_for_user(
             user_id=user_id,
             project=project,
             app=app,
+            product_name=product_name,
         )
 
     # adds `trashed_by_primary_gid`
@@ -1265,7 +1266,7 @@ async def patch_project_node(
         )
 
     updated_project = await add_project_states_for_user(
-        user_id=user_id, project=updated_project, app=app
+        user_id=user_id, project=updated_project, app=app, product_name=product_name
     )
     # 5. if inputs/outputs have been changed all depending nodes shall be notified
     if {"inputs", "outputs"} & _node_patch_exclude_unset.keys():
@@ -1335,7 +1336,7 @@ async def update_project_node_outputs(
         pformat(changed_entries),
     )
     updated_project = await add_project_states_for_user(
-        user_id=user_id, project=updated_project, app=app
+        user_id=user_id, project=updated_project, app=app, product_name=product_name
     )
 
     # changed entries come in the form of {node_uuid: {outputs: {changed_key1: value1, changed_key2: value2}}}
@@ -1910,6 +1911,7 @@ async def add_project_states_for_user(
     user_id: int,
     project: ProjectDict,
     app: web.Application,
+    product_name: ProductName,
 ) -> ProjectDict:
     _logger.debug(
         "adding project states for %s with project %s",
@@ -1945,6 +1947,7 @@ async def add_project_states_for_user(
                 user_id=user_id,
                 project_uuid=project["uuid"],
                 node_id=NodeID(node_uuid),
+                product_name=product_name,
             )
         if NodeID(node_uuid) in computational_node_states:
             node_state = computational_node_states[NodeID(node_uuid)].model_copy(