notify clients on deleted document model

src/controllers/documents.ts

@@ -92,8 +92,22 @@ export const all: RequestHandler = async (req, res, next) => {
 
 export const destroy: RequestHandler<{ id: string }> = async (req, res, next) => {
     try {
-        const document = await Document.deleteModel(req.user!, req.params.id);
-        res.json(document);
+        const model = await Document.deleteModel(req.user!, req.params.id);
+
+        const groupIds = model.documentRoot.rootGroupPermissions
+            .filter((p) => !NoneAccess.has(p.access))
+            .map((p) => p.studentGroupId);
+        const userIds = model.documentRoot.rootUserPermissions
+            .filter((p) => !NoneAccess.has(p.access))
+            .map((p) => p.userId);
+        res.notifications = [
+            {
+                event: IoEvent.DELETED_RECORD,
+                message: { type: RecordType.Document, id: model.id },
+                to: [...groupIds, ...userIds, IoRoom.ADMIN, req.user!.id] // overlappings are handled by socket.io: https://socket.io/docs/v3/rooms/#joining-and-leaving
+            }
+        ];
+        res.status(204).send();
     } catch (error) {
         next(error);
     }

src/models/Document.ts

@@ -207,7 +207,7 @@ function Document(db: PrismaClient['document']) {
             return model;
         },
 
-        async deleteModel(actor: User, id: string): Promise<DbDocument> {
+        async deleteModel(actor: User, id: string) {
             const record = await this.findModel(actor, id);
             if (!record) {
                 throw new HTTP404Error('Document not found');
@@ -216,13 +216,30 @@ function Document(db: PrismaClient['document']) {
                 throw new HTTP403Error('Not authorized');
             }
 
-            // TODO: Notify connected clients.
-
-            return db.delete({
+            const model = (await db.delete({
                 where: {
                     id: id
+                },
+                include: {
+                    documentRoot: {
+                        include: {
+                            rootGroupPermissions: {
+                                select: {
+                                    access: true,
+                                    studentGroupId: true
+                                }
+                            },
+                            rootUserPermissions: {
+                                select: {
+                                    access: true,
+                                    userId: true
+                                }
+                            }
+                        }
+                    }
                 }
-            });
+            })) satisfies DbDocument;
+            return model;
         },
 
         async all(actor: User): Promise<DbDocument[]> {