mongodb - npm Package Compare versions

Comparing version 6.14.1 to 6.14.2

lib/client-side-encryption/state_machine.js

@@ -202,3 +202,3 @@ "use strict";
         const buffer = new utils_1.BufferPool();
-        const netSocket = new net.Socket();
+        let netSocket;
         let socket;
@@ -235,10 +235,11 @@ function destroySockets() {
         }
-        const { promise: willConnect, reject: rejectOnNetSocketError, resolve: resolveOnNetSocketConnect } = (0, utils_1.promiseWithResolvers)();
-        netSocket
-            .once('error', err => rejectOnNetSocketError(onerror(err)))
-            .once('close', () => rejectOnNetSocketError(onclose()))
-            .once('connect', () => resolveOnNetSocketConnect());
         let abortListener;
         try {
             if (this.options.proxyOptions && this.options.proxyOptions.proxyHost) {
+                netSocket = new net.Socket();
+                const { promise: willConnect, reject: rejectOnNetSocketError, resolve: resolveOnNetSocketConnect } = (0, utils_1.promiseWithResolvers)();
+                netSocket
+                    .once('error', err => rejectOnNetSocketError(onerror(err)))
+                    .once('close', () => rejectOnNetSocketError(onclose()))
+                    .once('connect', () => resolveOnNetSocketConnect());
                 const netSocketOptions = {
@@ -245,0 +246,0 @@ ...socketOptions,

package.json

 {
   "name": "mongodb",
-  "version": "6.14.1",
+  "version": "6.14.2",
   "description": "The official MongoDB driver for Node.js",
@@ -5,0 +5,0 @@ "main": "lib/index.js",

src/client-side-encryption/state_machine.ts

@@ -355,3 +355,3 @@ import * as fs from 'fs/promises';
 
-    const netSocket: net.Socket = new net.Socket();
+    let netSocket: net.Socket;
     let socket: tls.TLSSocket;
@@ -392,12 +392,2 @@
 
-    const {
-      promise: willConnect,
-      reject: rejectOnNetSocketError,
-      resolve: resolveOnNetSocketConnect
-    } = promiseWithResolvers<void>();
-    netSocket
-      .once('error', err => rejectOnNetSocketError(onerror(err)))
-      .once('close', () => rejectOnNetSocketError(onclose()))
-      .once('connect', () => resolveOnNetSocketConnect());
-
     let abortListener;
@@ -407,2 +397,15 @@
       if (this.options.proxyOptions && this.options.proxyOptions.proxyHost) {
+        netSocket = new net.Socket();
+
+        const {
+          promise: willConnect,
+          reject: rejectOnNetSocketError,
+          resolve: resolveOnNetSocketConnect
+        } = promiseWithResolvers<void>();
+
+        netSocket
+          .once('error', err => rejectOnNetSocketError(onerror(err)))
+          .once('close', () => rejectOnNetSocketError(onclose()))
+          .once('connect', () => resolveOnNetSocketConnect());
+
         const netSocketOptions = {
@@ -413,3 +416,5 @@ ...socketOptions,
         };
+
         netSocket.connect(netSocketOptions);
+
         await willConnect;
@@ -416,0 +421,0 @@

No alert changes

Improved metrics

Total package byte prevSize

3772109

Lines of code

78625

Published versions last months

21

increased by5%

Published versions last two months

37

increased by2.78%

Published versions last week

6

increased by20%

No dependency changes