api: asset: delete assets

packages/api/src/schema/api-schema.yaml

@@ -883,6 +883,8 @@ components:
                 - processing
                 - ready
                 - failed
+                - deleting
+                - deleted
             updatedAt:
               type: number
               description:
@@ -1408,6 +1410,7 @@ components:
             - upload
             - export
             - export-data
+            - delete
             - transcode-file
             - clip
         createdAt:
@@ -1473,6 +1476,16 @@ components:
                 id:
                   type: string
                   description: Optional ID of the content
+            delete:
+              type: object
+              additionalProperties: false
+              description: Parameters for the delete asset task
+              required:
+                - assetId
+              properties:
+                assetId:
+                  type: string
+                  description: ID of the asset to delete
             transcode-file:
               type: object
               additionalProperties: false

packages/api/src/task/scheduler.ts

@@ -198,6 +198,18 @@ export class TaskScheduler {
           });
         }
         break;
+      case "delete":
+        const deletingAsset = await db.asset.get(task.inputAssetId);
+        if (task.params.delete.assetId === deletingAsset.id) {
+          await this.updateAsset(deletingAsset, {
+            deletedAt: Date.now(),
+            deleted: true,
+            status: {
+              phase: "deleted",
+              updatedAt: Date.now(),
+            },
+          });
+        }
     }
     await this.updateTask(task, {
       status: {
@@ -526,10 +538,20 @@ export class TaskScheduler {
     if (typeof asset === "string") {
       asset = await db.asset.get(asset);
     }
+    const task = await taskScheduler.createAndScheduleTask(
+      "delete",
+      {
+        delete: {
+          assetId: asset.id,
+        },
+      },
+      asset
+    );
     await this.updateAsset(asset, {
-      deleted: true,
-      deletedAt: Date.now(),
-      status: asset.status, // prevent updatedAt from being bumped
+      status: {
+        phase: "deleting",
+        updatedAt: Date.now(),
+      },
     });
   }