core: add domain delete

packages/hydrooj/package.json

@@ -1,6 +1,6 @@
 {
     "name": "hydrooj",
-    "version": "2.27.2",
+    "version": "2.27.3",
     "bin": "bin/hydrooj.js",
     "main": "dist/loader.js",
     "typings": "dist/loader.d.ts",

packages/hydrooj/src/model/document.ts

@@ -428,6 +428,11 @@ async function ensureIndexes() {
 }
 
 bus.once('app/started', ensureIndexes);
+bus.on('domain/delete', (domainId) => Promise.all([
+    coll.deleteMany({ domainId }),
+    collStatus.deleteMany({ domainId }),
+]));
+
 global.Hydro.model.document = {
     coll,
     collStatus,

packages/hydrooj/src/model/domain.ts

@@ -249,6 +249,13 @@ class DomainModel {
         }).limit(limit).toArray();
         return ddocs;
     }
+
+    @ArgMethod
+    static async del(domainId: string) {
+        await coll.deleteOne({ _id: domainId });
+        await collUser.deleteMany({ domainId });
+        await bus.parallel('domain/delete', domainId);
+    }
 }
 
 export default DomainModel;

packages/hydrooj/src/model/record.ts

@@ -208,5 +208,7 @@ class RecordModel {
 }
 
 bus.on('problem/delete', (domainId, docId) => RecordModel.coll.deleteMany({ domainId, pid: docId }));
+bus.on('domain/delete', (domainId) => RecordModel.coll.deleteMany({ domainId }));
+
 export default RecordModel;
 global.Hydro.model.record = RecordModel;

packages/hydrooj/src/model/storage.ts

@@ -97,6 +97,10 @@ bus.once('app/started', async () => {
         });
     }
 });
+bus.on('domain/delete', async (domainId) => {
+    const files = await StorageModel.list(`problem/${domainId}`);
+    await StorageModel.del(files.map((i) => i.path));
+});
 
 global.Hydro.model.storage = StorageModel;
 export default StorageModel;

packages/hydrooj/src/model/task.ts

@@ -127,5 +127,7 @@ class TaskModel {
     static Worker = Worker;
 }
 
+bus.on('domain/delete', (domainId) => coll.deleteMany({ domainId }));
+
 export default TaskModel;
 global.Hydro.model.task = TaskModel;

packages/hydrooj/src/service/bus.ts

@@ -55,6 +55,7 @@ export interface EventMap extends Record<string, any> {
     'domain/get': (ddoc: DomainDoc) => VoidReturn
     'domain/before-update': (domainId: string, $set: Partial<DomainDoc>) => VoidReturn
     'domain/update': (domainId: string, $set: Partial<DomainDoc>, ddoc: DomainDoc) => VoidReturn
+    'domain/delete': (domainId: string) => VoidReturn
 
     'document/add': (doc: any) => VoidReturn
     'document/set': <T extends keyof DocType>(

packages/ui-default/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@hydrooj/ui-default",
-  "version": "4.9.1",
+  "version": "4.9.2",
   "author": "undefined <i@undefined.moe>",
   "license": "AGPL-3.0",
   "main": "hydro.js",