fix: reject promise if deserializeMessage throws (#413)

denodrivers · May 19, 2024 · 1ade65f · 1ade65f
1 parent d917442
commit 1ade65f
Showing 1 changed file with 6 additions and 2 deletions.
diff --git a/src/protocol/protocol.ts b/src/protocol/protocol.ts
@@ -120,10 +120,14 @@ export class WireProtocol {
       if (!bodyBuffer) {
         throw new MongoDriverError("Invalid response body");
       }
-      const reply = deserializeMessage(header, bodyBuffer);
       const pendingMessage = this.#pendingResponses.get(header.responseTo);
       this.#pendingResponses.delete(header.responseTo);
-      pendingMessage?.resolve(reply);
+      try {
+        const reply = deserializeMessage(header, bodyBuffer);
+        pendingMessage?.resolve(reply);
+      } catch (e) {
+        pendingMessage?.reject(e);
+      }
     }
     this.#isPendingResponse = false;
   }