implements batch_delete_trashed_projects_as_admin

Author: pcrespov

services/web/server/src/simcore_service_webserver/folders/_trash_service.py

@@ -292,6 +292,7 @@ async def batch_delete_trashed_folders_as_admin(
         FolderBatchDeleteError: if error and fail_fast=False
         Exception: any other exception during delete_recursively
     """
+    errors: list[tuple[FolderID, Exception]] = []
 
     for page_params in iter_pagination_params(limit=MAXIMUM_NUMBER_OF_ITEMS_PER_PAGE):
         (
@@ -306,8 +307,7 @@ async def batch_delete_trashed_folders_as_admin(
             order_by=OrderBy(field=IDStr("trashed"), direction=OrderDirection.ASC),
         )
 
-        # batch delete
-        errors: list[tuple[FolderID, Exception]] = []
+        # BATCH delete
         for folder in expired_trashed_folders:
             try:
                 await _folders_repository.delete_recursively(
@@ -318,7 +318,7 @@ async def batch_delete_trashed_folders_as_admin(
                     raise
                 errors.append((folder.folder_id, err))
 
-        if errors:
-            raise FolderBatchDeleteError(
-                errors=errors, trashed_before=trashed_before, product_name=product_name
-            )
+    if errors:
+        raise FolderBatchDeleteError(
+            errors=errors, trashed_before=trashed_before, product_name=product_name
+        )

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

@@ -17,12 +17,16 @@
 
 from ..director_v2 import api as director_v2_api
 from ..dynamic_scheduler import api as dynamic_scheduler_api
-from . import _crud_api_read, projects_service
+from . import _crud_api_read
+from . import _projects_db as _projects_repository
+from . import projects_service
 from ._access_rights_api import check_user_project_permission
+from ._projects_db import _OLDEST_TRASHED_FIRST
 from .exceptions import (
     ProjectNotFoundError,
     ProjectNotTrashedError,
     ProjectRunningConflictError,
+    ProjectsBatchDeleteError,
 )
 from .models import ProjectDict, ProjectPatchInternalExtended
 
@@ -241,10 +245,52 @@ async def delete_explicitly_trashed_project(
 
 async def batch_delete_trashed_projects_as_admin(
     app: web.Application,
-    trashed_before: datetime,
     *,
     product_name: ProductName,
+    trashed_before: datetime,
     fail_fast: bool,
-) -> None:
+) -> list[ProjectID]:
+
+    deleted_project_ids: list[ProjectID] = []
+    errors: list[tuple[ProjectID, Exception]] = []
+
+    for page_params in iter_pagination_params(limit=MAXIMUM_NUMBER_OF_ITEMS_PER_PAGE):
+        (
+            page_params.total_number_of_items,
+            expired_trashed_projects,
+        ) = await _projects_repository.list_trashed_projects(
+            app,
+            trashed_explicitly=True,
+            trashed_before=trashed_before,
+            offset=page_params.offset,
+            limit=page_params.limit,
+            order_by=_OLDEST_TRASHED_FIRST,
+        )
+        # BATCH delete
+        for project in expired_trashed_projects:
+
+            assert project.trashed  # nosec
+            assert project.trashed_explicitly  # nosec
+
+            try:
+                _logger.debug(
+                    # TODO: _projects_service_delete.delete_project_as_admin
+                    "await _projects_service_delete.delete_project_as_admin(app, project_id=%s, product_name=%s)",
+                    project.uuid,
+                    product_name,
+                )
+                deleted_project_ids.append(project.uuid)
+            except Exception as err:  # pylint: disable=broad-exception-caught
+                if fail_fast:
+                    raise
+                errors.append((project.uuid, err))
+
+    if errors:
+        raise ProjectsBatchDeleteError(
+            errors=errors,
+            trashed_before=trashed_before,
+            product_name=product_name,
+            deleted_project_ids=deleted_project_ids,
+        )
 
-    raise NotImplementedError
+    return deleted_project_ids

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

@@ -79,6 +79,10 @@ def __init__(self, *, project_uuid, reason, **ctx):
         self.reason = reason
 
 
+class ProjectsBatchDeleteError(BaseProjectError):
+    msg_template = "One or more projects could not be deleted in the batch: {errors}"
+
+
 class ProjectTrashError(BaseProjectError):
     ...