fix: reject promise if deserializeMessage throws

denodrivers · May 16, 2024 · e0b4b7d · e0b4b7d
1 parent eff419f
commit e0b4b7d
Showing 1 changed file with 6 additions and 2 deletions.
diff --git a/src/protocol/protocol.ts b/src/protocol/protocol.ts
@@ -116,10 +116,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;
   }