feat: catch and log error while initializing drive

powerhouse-inc · Apr 23, 2024 · 6e5462a · 6e5462a
1 parent bf3aef0
commit 6e5462a
Show file tree

Hide file tree

Showing 3 changed files with 21 additions and 22 deletions.
diff --git a/api/package.json b/api/package.json
@@ -23,7 +23,7 @@
     "body-parser": "^1.20.2",
     "cookie-parser": "^1.4.6",
     "cors": "^2.8.5",
-    "document-drive": "1.0.0-alpha.44",
+    "document-drive": "1.0.0-alpha.46",
     "document-model": "^1.0.51",
     "document-model-libs": "^1.36.0",
     "dotenv": "^16.4.5",

diff --git a/api/pnpm-lock.yaml b/api/pnpm-lock.yaml
diff --git a/api/src/modules/document/listenerManager.ts b/api/src/modules/document/listenerManager.ts
@@ -58,19 +58,23 @@ export async function init(driveServer: DocumentDriveServer, prisma: Prisma.Tran
         }
 
         for (const driveId of drives) {
-            const drive = await driveServer.getDrive(driveId);
-            if (!isListenerRegistered(drive, listener)) {
-                await registerListener(driveServer, driveId, listener);
-            }
+            try {
+                const drive = await driveServer.getDrive(driveId);
+                if (!isListenerRegistered(drive, listener)) {
+                    await registerListener(driveServer, driveId, listener);
+                }
 
-            const transmitter = (await driveServer.getTransmitter(driveId, listener.listenerId));
-            if (transmitter instanceof InternalTransmitter) {
-                logger.info(`Setting receiver for ${listener.listenerId}`);
-                transmitter.setReceiver({
-                    transmit: async (strands: InternalTransmitterUpdate<Document, OperationScope>[]) => {
-                        transmit(strands, prisma)
-                    }
-                })
+                const transmitter = (await driveServer.getTransmitter(driveId, listener.listenerId));
+                if (transmitter instanceof InternalTransmitter) {
+                    logger.info(`Setting receiver for ${listener.listenerId}`);
+                    transmitter.setReceiver({
+                        transmit: async (strands: InternalTransmitterUpdate<Document, OperationScope>[]) => {
+                            transmit(strands, prisma)
+                        }
+                    })
+                }
+            } catch (e) {
+                logger.error(`Error while initializing listener ${listener.listenerId} for drive ${driveId}`, e);
             }
         }
     }