feat: queue add and remove listener operations

powerhouse-inc · Jun 12, 2024 · 5702eb8 · 5702eb8
1 parent 1c08db8
commit 5702eb8
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/api/src/modules/document/model.ts b/api/src/modules/document/model.ts
@@ -206,7 +206,7 @@ export function getDocumentDriveCRUD(prisma: Prisma.TransactionClient) {
                 system: false,
             };
 
-            const result = await driveServer.addDriveAction(driveId, actions.addListener({ listener }));
+            const result = await driveServer.queueDriveAction(driveId, actions.addListener({ listener }));
             if (result.status !== "SUCCESS") {
                 result.error && logger.error(result.error);
                 throw new Error(`Listener couldn't be registered: ${result.error || result.status}`);
@@ -219,7 +219,7 @@ export function getDocumentDriveCRUD(prisma: Prisma.TransactionClient) {
             driveId: string,
             listenerId: string,
         ) => {
-            const result = await driveServer.addDriveAction(driveId, actions.removeListener({ listenerId }));
+            const result = await driveServer.queueDriveAction(driveId, actions.removeListener({ listenerId }));
             if (result.status !== "SUCCESS") {
                 result.error && logger.error(result.error);
                 throw new Error(`Listener couldn't be deleted: ${result.error || result.status}`);