boilerplate execution

Author: aditi-khare-mongoDB

no_resource_leak_connect_close.cjs

@@ -0,0 +1,55 @@
+'use strict';
+
+/* eslint-disable no-undef */
+
+const driverPath = "/Users/aditi.khare/Desktop/node-mongodb-native/lib";
+const func = (async function run({ MongoClient, uri }) {
+                    const mongoClient = new MongoClient(uri, { minPoolSize: 100 });
+                    await mongoClient.connect();
+                    // Any operations will reproduce the issue found in v5.0.0/v4.13.0
+                    // it would seem the MessageStream has to be used?
+                    await mongoClient.db().command({ ping: 1 });
+                    await mongoClient.close();
+                });
+const name = "no_resource_leak_connect_close";
+const uri = "mongodb://bob:pwd123@localhost:31000/integration_tests?replicaSet=rs&authSource=admin";
+const iterations = 100;
+
+const { MongoClient } = require(driverPath);
+const process = require('node:process');
+const v8 = require('node:v8');
+const util = require('node:util');
+const timers = require('node:timers');
+
+const sleep = util.promisify(timers.setTimeout);
+
+const run = func;
+
+const MB = (2 ** 10) ** 2;
+
+async function main() {
+  const startingMemoryUsed = process.memoryUsage().heapUsed / MB;
+  process.send({ startingMemoryUsed });
+
+  for (let iteration = 0; iteration < iterations; iteration++) {
+    await run({ MongoClient, uri, iteration });
+    global.gc();
+  }
+
+  global.gc();
+  // Sleep b/c maybe gc will run
+  await sleep(100);
+  global.gc();
+
+  const endingMemoryUsed = process.memoryUsage().heapUsed / MB;
+  process.send({ endingMemoryUsed });
+  v8.writeHeapSnapshot(`${name}.heapsnapshot.json`);
+}
+
+main()
+  .then(() => {
+    process.exit(0);
+  })
+  .catch(() => {
+    process.exit(1);
+  });

test/integration/node-specific/client_close.test.ts

@@ -1,7 +1,8 @@
+import { expect } from 'chai';
 import { TestConfiguration } from '../../tools/runner/config';
 import { runScriptAndReturnResourceInfo } from './resource_tracking_script_builder';
 
-describe.only('client.close() Integration', () => {
+describe.skip('client.close() Integration', () => {
   let config: TestConfiguration;
   beforeEach(function () {
     config = this.configuration;
@@ -21,44 +22,41 @@ describe.only('client.close() Integration', () => {
   });
 
   describe('MongoClientAuthProviders', () => {
-    describe('when MongoClientAuthProviders is instantiated', () => {
-        it('the token cache is cleaned up by client.close', () => {
+    describe('when MongoClientAuthProviders is instantiated and token file read hangs', () => {
+        it('the file read is interrupted by client.close', () => {
         });
     });
   });
 
   describe('Topology', () => {
-    describe('after a Topology is explicitly created', () => {
-        it('timers are cleaned up by client.close()', () => {
-
-        });
-    });
     describe('after a Topology is created through client.connect()', () => {
-        it('timers are cleaned up by client.close()', () => {
-
+        it('server selection timers are cleaned up by client.close()', async () => {
+            await runScriptAndReturnResourceInfo(
+                'topology-clean-up', 
+                config,
+                async function run({ MongoClient, uri }) {
+                    const client = new MongoClient(uri);
+                    await client.connect();
+                    await client.close();
+                }
+            );
         });
     });
   });
 
   describe('SRVPoller', () => {
-    describe('after SRVPoller is explicitly created', () => {
-        it('timers are cleaned up by client.close()', () => {
-
-        });
-    });
-
     // SRVPoller is implicitly created after an SRV string's topology transitions to sharded
-    describe('after SRVPoller is implicitly created', () => {
+    describe('after SRVPoller is created', () => {
         it('timers are cleaned up by client.close()', () => {
 
         });
     });
   });
 
   describe('ClientSession', () => {
-    describe('after a clientSession is created', () => {
+    describe('after a clientSession is created and used', () => {
         it('the server-side ServerSession and transaction are cleaned up by client.close()', () => {
-
+            // must send a command to the server
         });
     });
   });
@@ -67,9 +65,6 @@ describe.only('client.close() Integration', () => {
     describe('when FLE is enabled and the client has made a KMS request', () => {
         it('no sockets remain after client.close', () => {
 
-        });
-        it('no server-side connection threads remain after client.close', () => {
-
         });
         describe('when the TLS file read hangs', () => {
             it('the file read is interrupted by client.close', () => {
@@ -79,6 +74,10 @@ describe.only('client.close() Integration', () => {
     });
   });
 
+  describe('Server', () => {
+
+  });
+
   describe('ConnectionPool', () => {
     describe('after new connection pool is created', () => {
         it('minPoolSize timer is cleaned up by client.close()', () => {
@@ -95,22 +94,23 @@ describe.only('client.close() Integration', () => {
     });
 
     describe('after a heartbeat fails', () => {
-        it('monitor interval timer is cleaned up by client.close()', () => {
+        it('the new monitor interval timer is cleaned up by client.close()', () => {
 
         });
     });
   });
 
   describe('RTTPinger', () => {
-    describe('after helloReply has a topologyVersion defined fails', () => {
-        it('rtt pinger timer is cleaned up by client.close()', () => {
-
+    describe('after entering monitor streaming mode ', () => {
+        it('the rtt pinger timer is cleaned up by client.close()', () => {
+            // helloReply has a topologyVersion defined
         });
     });
   });
 
   describe('Connection', () => {
     describe('when connection monitoring is turned on', () => {
+        // connection monitoring is by default turned on - with the exception of load-balanced mode
         it('no sockets remain after client.close', () => {
 
         });

test/integration/node-specific/resource_tracking_script_builder.ts

@@ -117,12 +117,12 @@ export async function runScriptAndReturnResourceInfo(
   func: ResourceTestFunction
 ) {
 
-  const scriptName = `scripts/${name}.cjs`;
+  const scriptName = `${name}.cjs`;
   const scriptContent = await testScriptFactory(name, config.url(), REPORT_RESOURCE_SCRIPT_PATH, func);
   await writeFile(scriptName, scriptContent, { encoding: 'utf8' });
 
   const processDiedController = new AbortController();
-  const script = fork(name);
+  const script = fork(scriptName);
 
   // Interrupt our awaiting of messages if the process crashed
   script.once('close', exitCode => {
@@ -133,11 +133,19 @@ export async function runScriptAndReturnResourceInfo(
 
   const willClose = once(script, 'close');
 
+  const messages = on(script, 'message', { signal: processDiedController.signal });
+  const report = await messages.next();
+  let { finalReport, originalReport } = report.value[0];
+
+ // const beforeExit = await messages.next();
+
   // make sure the process ended
   const [exitCode] = await willClose;
+
+  // assertions about exit status
   expect(exitCode, 'process should have exited with zero').to.equal(0);
 
-  const messages = on(script, 'message', { signal: processDiedController.signal });
-  const report = await messages.next();
-  return report;
+  // assertions about clean-up
+  expect(originalReport.length).to.equal(finalReport.length);
+  // expect(beforeExitEventHappened).to.be.true; 
 }

test/tools/fixtures/close_resource_script.in.js

@@ -6,7 +6,6 @@ const driverPath = DRIVER_SOURCE_PATH;
 const func = FUNCTION_STRING;
 const name = NAME_STRING;
 const uri = URI_STRING;
-const iterations = ITERATIONS_STRING;
 
 const { MongoClient } = require(driverPath);
 const process = require('node:process');
@@ -18,11 +17,12 @@ const run = func;
 
 async function main() {
   process.on('beforeExit', (code) => {
-    process.send({beforeExit: true});
+    console.log('Process beforeExit event with code: ', code);
   });
-  await run({ MongoClient, uri, iteration });
-  const report = process.report.getReport();
-  process.send({ report });
+  const originalReport = process.report.getReport().libuv;
+  await run({ MongoClient, uri });
+  const finalReport = process.report.getReport().libuv;
+  process.send({originalReport, finalReport});
 }
 
 main()

topology-clean-up.cjs

@@ -0,0 +1,38 @@
+'use strict';
+
+/* eslint-disable no-undef */
+
+const driverPath = "/Users/aditi.khare/Desktop/node-mongodb-native/lib";
+const func = (async function run({ MongoClient, uri }) {
+                    const client = new MongoClient(uri);
+                    await client.connect();
+                    await client.close();
+                });
+const name = "topology-clean-up";
+const uri = "mongodb://bob:pwd123@localhost:31000/integration_tests?replicaSet=rs&authSource=admin";
+
+const { MongoClient } = require(driverPath);
+const process = require('node:process');
+const v8 = require('node:v8');
+const util = require('node:util');
+const timers = require('node:timers');
+
+const run = func;
+
+async function main() {
+  process.on('beforeExit', (code) => {
+    console.log('Process beforeExit event with code: ', code);
+  });
+  const originalReport = process.report.getReport().libuv;
+  await run({ MongoClient, uri });
+  const finalReport = process.report.getReport().libuv;
+  process.send({originalReport, finalReport});
+}
+
+main()
+  .then(() => {
+    process.exit(0);
+  })
+  .catch(() => {
+    process.exit(1);
+  });

topology.cjs

@@ -0,0 +1,37 @@
+'use strict';
+
+/* eslint-disable no-undef */
+
+const driverPath = "/Users/aditi.khare/Desktop/node-mongodb-native/lib";
+const func = (async function run({ MongoClient, uri }) {
+                    const mongoClient = new MongoClient(uri);
+                    await mongoClient.connect();
+                });
+const name = "topology";
+const uri = "mongodb://bob:pwd123@localhost:31000/integration_tests?replicaSet=rs&authSource=admin";
+const iterations = ITERATIONS_STRING;
+
+const { MongoClient } = require(driverPath);
+const process = require('node:process');
+const v8 = require('node:v8');
+const util = require('node:util');
+const timers = require('node:timers');
+
+const run = func;
+
+async function main() {
+  process.on('beforeExit', (code) => {
+    process.send({beforeExit: true});
+  });
+  await run({ MongoClient, uri, iteration });
+  const report = process.report.getReport();
+  process.send({ report });
+}
+
+main()
+  .then(() => {
+    process.exit(0);
+  })
+  .catch(() => {
+    process.exit(1);
+  });