uniformize

Author: sanderegg

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

@@ -889,7 +889,7 @@ async def update_project_node_data(
             extra=get_log_record_extra(user_id=user_id),
         ):
             partial_workbench_data: dict[NodeIDStr, Any] = {
-                NodeIDStr(f"{node_id}"): new_node_data,
+                f"{node_id}": new_node_data,
             }
             return await self._update_project_workbench_with_lock_and_notify(
                 partial_workbench_data,

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

@@ -1149,8 +1149,8 @@ async def update_project_node_state(
         user_id,
     )
 
-    db: ProjectDBAPI = app[APP_PROJECT_DBAPI]
-    product_name = await db.get_project_product(project_id)
+    _projects_repository = ProjectDBAPI.get_from_app_context(app)
+    product_name = await _projects_repository.get_project_product(project_id)
     await check_user_project_permission(
         app,
         project_id=project_id,
@@ -1161,7 +1161,7 @@ async def update_project_node_state(
 
     # Delete this once workbench is removed from the projects table
     # See: https://github.com/ITISFoundation/osparc-simcore/issues/7046
-    await db.update_project_node_data(
+    await _projects_repository.update_project_node_data(
         user_id=user_id,
         project_uuid=project_id,
         node_id=node_id,
@@ -1297,8 +1297,8 @@ async def update_project_node_outputs(
     )
     new_outputs = new_outputs or {}
 
-    db: ProjectDBAPI = app[APP_PROJECT_DBAPI]
-    product_name = await db.get_project_product(project_id)
+    _projects_repository = ProjectDBAPI.get_from_app_context(app)
+    product_name = await _projects_repository.get_project_product(project_id)
     await check_user_project_permission(
         app,
         project_id=project_id,
@@ -1307,7 +1307,10 @@ async def update_project_node_outputs(
         permission="write",  # NOTE: MD: before only read was sufficient, double check this
     )
 
-    updated_project, changed_entries = await db.update_project_node_data(
+    (
+        updated_project,
+        changed_entries,
+    ) = await _projects_repository.update_project_node_data(
         user_id=user_id,
         project_uuid=project_id,
         node_id=node_id,