fix: avoid crash when an unexpected message arrives (#1019)

Signed-off-by: Pavel Zarecky <[email protected]>
openwallet-foundation · Sep 9, 2022 · 2cfadd9 · 2cfadd9
1 parent 543437c
commit 2cfadd9
Showing 1 changed file with 7 additions and 1 deletion.
diff --git a/packages/core/src/agent/Agent.ts b/packages/core/src/agent/Agent.ts
@@ -137,7 +137,13 @@ export class Agent {
       .observable<AgentMessageReceivedEvent>(AgentEventTypes.AgentMessageReceived)
       .pipe(
         takeUntil(this.agentConfig.stop$),
-        concatMap((e) => this.messageReceiver.receiveMessage(e.payload.message, { connection: e.payload.connection }))
+        concatMap((e) =>
+          this.messageReceiver
+            .receiveMessage(e.payload.message, { connection: e.payload.connection })
+            .catch((error) => {
+              this.logger.error('Failed to process message', { error })
+            })
+        )
       )
       .subscribe()
   }