refactor

Author: EspressoTrip-v2

src/mongoPatch.ts

@@ -14,7 +14,7 @@ interface Config {
  *  @param config - The configuration for the proxy
  */
 export function useProxyForMongo(config: Config) {
-  const sockets: tls.TLSSocket[] = [];
+  let sockets: tls.TLSSocket[] = [];
   socks.SocksClient.createConnection = async (options, callback) => {
     const socket = await new HttpsProxySocket(`https://${config.proxy}`, { auth: config.auth }).connect({
       host: options.destination.host,
@@ -31,31 +31,21 @@ export function useProxyForMongo(config: Config) {
   };
   return {
     close: async () => {
-      let count = 0;
       await Promise.all(
         sockets.map(
           (socket) =>
             new Promise<void>((resolve) => {
               socket.once('close', () => {
-                count++;
+                console.log(
+                  `Socket state: destroyed=${socket.destroyed}, readable=${socket.readable}, writable=${socket.writable}, closed=${socket.closed}`,
+                );
                 resolve();
               });
               socket.destroySoon();
             }),
         ),
       );
-      // if (count === sockets.length) {
-      //   console.log(`Closed ${sockets.length} MongoDB connection sockets`);
-      // }
-      for (const socket of sockets) {
-        console.log('---------------------------------------------');
-        console.log('Socket destroyed', socket.destroyed);
-        console.log('Socket readable', socket.readable);
-        console.log('Socket writable', socket.writable);
-        console.log('Socket closed', socket.closed);
-        console.log('---------------------------------------------');
-      }
-      sockets.length = 0;
+      sockets = [];
     },
   };
 }