fix: avoid crash when an unexpected message arrives (openwallet-found…

…ation#1019) Signed-off-by: Pavel Zarecky <[email protected]>
2060-io · Sep 16, 2022 · 9b0c1f1 · 9b0c1f1
1 parent 8130d14
commit 9b0c1f1
Show file tree

Hide file tree

Showing 2 changed files with 9 additions and 5 deletions.
diff --git a/packages/core/src/agent/Agent.ts b/packages/core/src/agent/Agent.ts
@@ -106,10 +106,14 @@ export class Agent<AgentModules extends AgentModulesInput = ModulesMap> extends
       .pipe(
         takeUntil(stop$),
         concatMap((e) =>
-          this.messageReceiver.receiveMessage(e.payload.message, {
-            connection: e.payload.connection,
-            contextCorrelationId: e.payload.contextCorrelationId,
-          })
+          this.messageReceiver
+            .receiveMessage(e.payload.message, {
+              connection: e.payload.connection,
+              contextCorrelationId: e.payload.contextCorrelationId,
+            })
+            .catch((error) => {
+              this.logger.error('Failed to process message', { error })
+            })
         )
       )
       .subscribe()

diff --git a/packages/core/src/modules/didcomm/services/DidCommDocumentService.ts b/packages/core/src/modules/didcomm/services/DidCommDocumentService.ts
@@ -69,4 +69,4 @@ export class DidCommDocumentService {
 
     return didCommServices
   }
-}
+}