extens projects_service

Author: pcrespov

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

@@ -78,7 +78,7 @@ async def delete_project(
     app: web.Application,
     project_uuid: ProjectID,
     user_id: UserID,
-    simcore_user_agent,
+    simcore_user_agent: str,
     remove_project_dynamic_services: RemoveProjectServicesCallable,
 ) -> None:
     """Stops dynamic services, deletes data and finally deletes project

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

@@ -486,9 +486,9 @@ async def delete_project(request: web.Request):
 
         await projects_service.submit_delete_project_task(
             request.app,
-            path_params.project_id,
-            req_ctx.user_id,
-            request.headers.get(
+            project_uuid=path_params.project_id,
+            user_id=req_ctx.user_id,
+            simcore_user_agent=request.headers.get(
                 X_SIMCORE_USER_AGENT, UNDEFINED_DEFAULT_SIMCORE_USER_AGENT_VALUE
             ),
         )

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

@@ -318,6 +318,33 @@ async def patch_project(
 #
 
 
+async def delete_project_by_user(
+    app: web.Application,
+    *,
+    project_uuid: ProjectID,
+    user_id: UserID,
+    simcore_user_agent: str = UNDEFINED_DEFAULT_SIMCORE_USER_AGENT_VALUE,
+    wait_until_completed: bool = True,
+) -> None:
+    task = await submit_delete_project_task(
+        app,
+        project_uuid=project_uuid,
+        user_id=user_id,
+        simcore_user_agent=simcore_user_agent,
+    )
+    if wait_until_completed:
+        await task
+
+
+def get_delete_project_task(
+    project_uuid: ProjectID, user_id: UserID
+) -> asyncio.Task | None:
+    if tasks := _crud_api_delete.get_scheduled_tasks(project_uuid, user_id):
+        assert len(tasks) == 1, f"{tasks=}"  # nosec
+        return tasks[0]
+    return None
+
+
 async def submit_delete_project_task(
     app: web.Application,
     project_uuid: ProjectID,
@@ -353,15 +380,6 @@ async def submit_delete_project_task(
     return task
 
 
-def get_delete_project_task(
-    project_uuid: ProjectID, user_id: UserID
-) -> asyncio.Task | None:
-    if tasks := _crud_api_delete.get_scheduled_tasks(project_uuid, user_id):
-        assert len(tasks) == 1, f"{tasks=}"  # nosec
-        return tasks[0]
-    return None
-
-
 #
 # PROJECT NODES -----------------------------------------------------
 #