🐛 Fixes broken anonymous user opening templates (#6149)

Co-authored-by: Andrei Neagu <[email protected]>

Author: GitHK

services/director-v2/src/simcore_service_director_v2/core/application.py

@@ -39,6 +39,7 @@
     ClusterAccessForbiddenError,
     ClusterNotFoundError,
     PipelineNotFoundError,
+    ProjectNetworkNotFoundError,
     ProjectNotFoundError,
 )
 from .events import on_shutdown, on_startup
@@ -57,6 +58,12 @@ def _set_exception_handlers(app: FastAPI):
             status.HTTP_404_NOT_FOUND, ProjectNotFoundError
         ),
     )
+    app.add_exception_handler(
+        ProjectNetworkNotFoundError,
+        make_http_error_handler_for_exception(
+            status.HTTP_404_NOT_FOUND, ProjectNetworkNotFoundError
+        ),
+    )
     app.add_exception_handler(
         PipelineNotFoundError,
         make_http_error_handler_for_exception(

services/director-v2/src/simcore_service_director_v2/core/errors.py

@@ -92,6 +92,14 @@ def __init__(self, project_id: ProjectID):
         self.project_id = project_id
 
 
+class ProjectNetworkNotFoundError(DirectorError):
+    """Project not found error"""
+
+    def __init__(self, project_id: ProjectID):
+        super().__init__(f"no networks forund for project {project_id}")
+        self.project_id = project_id
+
+
 class PricingPlanUnitNotFoundError(DirectorError):
     """Pricing plan unit not found error"""
 

services/director-v2/src/simcore_service_director_v2/modules/db/repositories/projects_networks.py

@@ -6,7 +6,7 @@
 from models_library.projects_networks import NetworksWithAliases, ProjectsNetworks
 from sqlalchemy.dialects.postgresql import insert as pg_insert
 
-from ....core.errors import ProjectNotFoundError
+from ....core.errors import ProjectNetworkNotFoundError
 from ..tables import projects_networks
 from ._base import BaseRepository
 
@@ -22,7 +22,7 @@ async def get_projects_networks(self, project_id: ProjectID) -> ProjectsNetworks
                 )
             ).first()
         if not row:
-            raise ProjectNotFoundError(project_id)
+            raise ProjectNetworkNotFoundError(project_id)
         return ProjectsNetworks.from_orm(row)
 
     async def upsert_projects_networks(

services/director-v2/src/simcore_service_director_v2/modules/projects_networks.py

@@ -21,7 +21,7 @@
 from servicelib.rabbitmq import RabbitMQClient
 from servicelib.utils import logged_gather
 
-from ..core.errors import ProjectNotFoundError
+from ..core.errors import ProjectNetworkNotFoundError
 from ..modules.db.repositories.projects import ProjectsRepository
 from ..modules.db.repositories.projects_networks import ProjectsNetworksRepository
 from ..modules.director_v0 import DirectorV0Client
@@ -247,9 +247,9 @@ async def update_from_workbench(
                 project_id=project_id
             )
         )
-    except ProjectNotFoundError:
+    except ProjectNetworkNotFoundError:
         existing_projects_networks = ProjectsNetworks.parse_obj(
-            dict(project_uuid=project_id, networks_with_aliases={})
+            {"project_uuid": project_id, "networks_with_aliases": {}}
         )
 
     existing_networks_with_aliases = existing_projects_networks.networks_with_aliases

services/web/server/src/simcore_service_webserver/studies_dispatcher/_studies_access.py

@@ -12,6 +12,7 @@
 NOTE: Some of the code below is duplicated in the studies_dispatcher!
 SEE refactoring plan in https://github.com/ITISFoundation/osparc-simcore/issues/3977
 """
+
 import functools
 import logging
 from functools import lru_cache
@@ -26,6 +27,9 @@
 
 from .._constants import INDEX_RESOURCE_NAME
 from ..director_v2._core_computations import create_or_update_pipeline
+from ..director_v2._core_dynamic_services import (
+    update_dynamic_service_networks_in_project,
+)
 from ..products.api import get_current_product, get_product_name
 from ..projects.db import ANY_USER, ProjectDBAPI
 from ..projects.exceptions import ProjectInvalidRightsError, ProjectNotFoundError
@@ -184,6 +188,7 @@ async def copy_study_to_account(
         await create_or_update_pipeline(
             request.app, user["id"], project["uuid"], product_name
         )
+        await update_dynamic_service_networks_in_project(request.app, project["uuid"])
 
     return project_uuid