drafts trash section

Author: pcrespov

services/web/server/src/simcore_service_webserver/workspaces/_trash_api.py

@@ -0,0 +1,69 @@
+import logging
+
+import arrow
+from aiohttp import web
+from models_library.products import ProductName
+from models_library.projects import ProjectID
+from models_library.users import UserID
+from models_library.workspaces import WorkspaceID
+
+from ..projects._trash_api import trash_project, untrash_project
+
+_logger = logging.getLogger(__name__)
+
+
+async def trash_workspace(
+    app: web.Application,
+    *,
+    product_name: ProductName,
+    user_id: UserID,
+    workspace_id: WorkspaceID,
+    force_stop_first: bool,
+):
+    # TODO: Check
+
+    # Trash
+    trashed_at = arrow.utcnow().datetime
+
+    _logger.debug(
+        "TODO: Unit of work for all workspaces and projects and fails if force_stop_first=%s  is False",
+        force_stop_first,
+    )
+
+    # 1. TODO: Trash workspace
+
+    # 2. Trash all child folders
+
+    # 2. Trash all child projects that I am an owner
+    child_projects: list[ProjectID] = []
+
+    for project_id in child_projects:
+        await trash_project(
+            app,
+            product_name=product_name,
+            user_id=user_id,
+            project_id=project_id,
+            force_stop_first=force_stop_first,
+            explicit=False,
+        )
+
+
+async def untrash_workspace(
+    app: web.Application,
+    *,
+    product_name: ProductName,
+    user_id: UserID,
+    workspace_id: WorkspaceID,
+):
+    # TODO: Check
+
+    # 3. UNtrash
+
+    # 3.1 UNtrash workspace and children
+
+    # 3.2 UNtrash all child projects that I am an owner
+    child_projects: list[ProjectID] = []
+    for project_id in child_projects:
+        await untrash_project(
+            app, product_name=product_name, user_id=user_id, project_id=project_id
+        )

services/web/server/src/simcore_service_webserver/workspaces/_trash_handlers.py

@@ -0,0 +1,66 @@
+import logging
+
+from aiohttp import web
+from servicelib.aiohttp import status
+from servicelib.aiohttp.requests_validation import (
+    parse_request_path_parameters_as,
+    parse_request_query_parameters_as,
+)
+
+from .._meta import API_VTAG as VTAG
+from ..application_settings_utils import requires_dev_feature_enabled
+from ..login.decorators import get_user_id, login_required
+from ..products.api import get_product_name
+from ..security.decorators import permission_required
+from . import _trash_api
+from ._exceptions_handlers import handle_plugin_requests_exceptions
+from ._models import RemoveQueryParams, WorkspacesPathParams
+
+_logger = logging.getLogger(__name__)
+
+
+routes = web.RouteTableDef()
+
+
+@routes.post(f"/{VTAG}/workspaces/{{workspace_id}}:trash", name="trash_workspace")
+@requires_dev_feature_enabled
+@login_required
+@permission_required("workspace.delete")
+@handle_plugin_requests_exceptions
+async def trash_workspace(request: web.Request):
+    user_id = get_user_id(request)
+    product_name = get_product_name(request)
+    path_params = parse_request_path_parameters_as(WorkspacesPathParams, request)
+    query_params: RemoveQueryParams = parse_request_query_parameters_as(
+        RemoveQueryParams, request
+    )
+
+    await _trash_api.trash_workspace(
+        request.app,
+        product_name=product_name,
+        user_id=user_id,
+        workspace_id=path_params.workspace_id,
+        force_stop_first=query_params.force,
+    )
+
+    return web.json_response(status=status.HTTP_204_NO_CONTENT)
+
+
+@routes.post(f"/{VTAG}/workspaces/{{workspace_id}}:untrash", name="untrash_workspace")
+@requires_dev_feature_enabled
+@login_required
+@permission_required("workspace.delete")
+@handle_plugin_requests_exceptions
+async def untrash_workspace(request: web.Request):
+    user_id = get_user_id(request)
+    product_name = get_product_name(request)
+    path_params = parse_request_path_parameters_as(WorkspacesPathParams, request)
+
+    await _trash_api.untrash_workspace(
+        request.app,
+        product_name=product_name,
+        user_id=user_id,
+        workspace_id=path_params.workspace_id,
+    )
+
+    return web.json_response(status=status.HTTP_204_NO_CONTENT)