fix: move project_exists

Author: giancarloromeo

packages/postgres-database/src/simcore_postgres_database/utils_projects.py

@@ -7,7 +7,7 @@
 from sqlalchemy.ext.asyncio import AsyncConnection
 
 from .models.projects import projects
-from .utils_repos import transaction_context
+from .utils_repos import pass_or_acquire_connection, transaction_context
 
 
 class DBBaseProjectError(OsparcErrorMixin, Exception):
@@ -22,6 +22,23 @@ class ProjectsRepo:
     def __init__(self, engine):
         self.engine = engine
 
+    async def exists(
+        self,
+        project_uuid: uuid.UUID,
+        *,
+        connection: AsyncConnection | None = None,
+    ) -> bool:
+        async with pass_or_acquire_connection(self.engine, connection) as conn:
+            return (
+                await conn.scalar(
+                    sa.select(1)
+                    .select_from(projects)
+                    .where(projects.c.uuid == project_uuid)
+                    .limit(1)
+                )
+                is not None
+            )
+
     async def get_project_last_change_date(
         self,
         project_uuid: uuid.UUID,

services/storage/src/simcore_service_storage/modules/db/projects.py

@@ -33,22 +33,6 @@ async def list_valid_projects_in(
                 with suppress(ValidationError):
                     yield ProjectAtDB.model_validate(row)
 
-    async def project_exists(
-        self,
-        *,
-        connection: AsyncConnection | None = None,
-        project_uuid: ProjectID,
-    ) -> bool:
-        async with pass_or_acquire_connection(self.db_engine, connection) as conn:
-            return bool(
-                await conn.scalar(
-                    sa.select(sa.func.count())
-                    .select_from(projects)
-                    .where(projects.c.uuid == f"{project_uuid}")
-                )
-                == 1
-            )
-
     async def get_project_id_and_node_id_to_names_map(
         self,
         *,

services/storage/src/simcore_service_storage/simcore_s3_dsm.py

@@ -41,6 +41,7 @@
 from servicelib.logging_utils import log_context
 from servicelib.progress_bar import ProgressBarData
 from servicelib.utils import ensure_ends_with, limited_gather
+from simcore_postgres_database.utils_projects import ProjectsRepo
 from simcore_postgres_database.utils_repos import transaction_context
 from sqlalchemy.ext.asyncio import AsyncEngine
 
@@ -792,9 +793,9 @@ async def deep_copy_project_simcore_s3(
             task_progress.description = "Checking study access rights..."
 
             for prj_uuid in [src_project_uuid, dst_project_uuid]:
-                if not await ProjectRepository.instance(
-                    get_db_engine(self.app)
-                ).project_exists(project_uuid=prj_uuid):
+                if not await ProjectsRepo(get_db_engine(self.app)).exists(
+                    project_uuid=prj_uuid
+                ):
                     raise ProjectNotFoundError(project_id=prj_uuid)
             source_access_rights = await AccessLayerRepository.instance(
                 get_db_engine(self.app)