fix: Fix to catch error (#82) (#86)

approvers · Mar 22, 2022 · d60a93b · d60a93b
1 parent 8c466fc
commit d60a93b
Show file tree

Hide file tree

Showing 4 changed files with 28 additions and 7 deletions.
diff --git a/src/runner/message.ts b/src/runner/message.ts
@@ -50,7 +50,11 @@ export class MessageResponseRunner<
   }
 
   private async triggerEvent(event: MessageEvent, message: M): Promise<void> {
-    await Promise.all(this.responders.map((res) => res.on(event, message)));
+    try {
+      await Promise.all(this.responders.map((res) => res.on(event, message)));
+    } catch (e) {
+      console.error(e);
+    }
   }
 
   private responders: R[] = [];
@@ -109,9 +113,13 @@ export class MessageUpdateResponseRunner<M> {
   }
 
   private async triggerEvent([before, after]: [M, M]): Promise<void> {
-    await Promise.all(
-      this.responders.map((res) => res.on('UPDATE', before, after))
-    );
+    try {
+      await Promise.all(
+        this.responders.map((res) => res.on('UPDATE', before, after))
+      );
+    } catch (e) {
+      console.error(e);
+    }
   }
 
   private responders: MessageUpdateEventResponder<M>[] = [];

diff --git a/src/runner/role.ts b/src/runner/role.ts
@@ -14,7 +14,11 @@ export const composeRoleEventResponders = <R>(
 
 export class RoleResponseRunner<R> {
   async triggerEvent(event: RoleEvent, role: R): Promise<void> {
-    await Promise.all(this.responder.map((res) => res.on(event, role)));
+    try {
+      await Promise.all(this.responder.map((res) => res.on(event, role)));
+    } catch (e) {
+      console.error(e);
+    }
   }
 
   private responder: RoleEventResponder<R>[] = [];

diff --git a/src/runner/schedule.ts b/src/runner/schedule.ts
@@ -69,7 +69,10 @@ export class ScheduleRunner {
     }
     const id = setTimeout(() => {
       void (async () => {
-        const newTimeout = await task();
+        const newTimeout = await task().catch((e) => {
+          console.error(e);
+          return null;
+        });
         this.onDidRun(key, task, newTimeout);
       })();
     }, differenceInMilliseconds(timeout, this.clock.now()));

diff --git a/src/runner/voice-room.ts b/src/runner/voice-room.ts
@@ -54,7 +54,13 @@ export class VoiceRoomResponseRunner<V> {
     event: VoiceRoomEvent,
     voiceState: V
   ): Promise<void> {
-    await Promise.all(this.responders.map((res) => res.on(event, voiceState)));
+    try {
+      await Promise.all(
+        this.responders.map((res) => res.on(event, voiceState))
+      );
+    } catch (e) {
+      console.error(e);
+    }
   }
 
   private responders: VoiceRoomEventResponder<V>[] = [];