4/5 tests complted

Author: aditi-khare-mongoDB

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

@@ -1,8 +1,10 @@
 /* eslint-disable @typescript-eslint/no-empty-function */
+import { expect } from 'chai';
+import { MongoClient } from '../../mongodb';
 import { type TestConfiguration } from '../../tools/runner/config';
 import { runScriptAndGetProcessInfo } from './resource_tracking_script_builder';
 
-describe.skip('MongoClient.close() Integration', () => {
+describe.only('MongoClient.close() Integration', () => {
   // note: these tests are set-up in accordance of the resource ownership tree
 
   let config: TestConfiguration;
@@ -500,29 +502,85 @@ describe.skip('MongoClient.close() Integration', () => {
   });
 
   describe('ClientSession (Implicit)', () => {
+    let idleSessionsBeforeClose;
+    let idleSessionsAfterClose;
+
+    beforeEach(async function() {
+      const client = this.configuration.newClient();
+      await client.connect();
+      const session = client.startSession({ explicit: false });
+      session.startTransaction();
+      await client.db('db').collection('collection').insertOne({ x: 1 }, { session });
+
+      const opBefore = await client.db().admin().command({ currentOp: 1 });
+      idleSessionsBeforeClose = opBefore.inprog.filter(s => s.type === 'idleSession');
+
+      await client.close();
+      await client.connect();
+
+      const opAfter = await client.db().admin().command({ currentOp: 1 });
+      idleSessionsAfterClose = opAfter.inprog.filter(s => s.type === 'idleSession');
+
+      await client.close();
+    });
+  
     describe('Server resource: LSID/ServerSession', () => {
       describe('after a clientSession is implicitly created and used', () => {
-        it.skip('the server-side ServerSession is cleaned up by client.close()', async function () {});
+        it('the server-side ServerSession is cleaned up by client.close()', async function () {
+          expect(idleSessionsBeforeClose).to.not.be.empty;
+          expect(idleSessionsAfterClose).to.be.empty;
+        });
       });
     });
 
     describe('Server resource: Transactions', () => {
       describe('after a clientSession is implicitly created and used', () => {
-        it.skip('the server-side transaction is cleaned up by client.close()', async function () {});
+        it('the server-side transaction is cleaned up by client.close()', async function () {
+          expect(idleSessionsBeforeClose[0].transaction.txnNumber).to.not.null;
+          expect(idleSessionsAfterClose).to.be.empty;
+        });
       });
     });
   });
 
   describe('ClientSession (Explicit)', () => {
+    let idleSessionsBeforeClose;
+    let idleSessionsAfterClose;
+
+    beforeEach(async function() {
+      const client = this.configuration.newClient();
+      await client.connect();
+      const session = client.startSession();
+      session.startTransaction();
+      await client.db('db').collection('collection').insertOne({ x: 1 }, { session });
+
+      const opBefore = await client.db().admin().command({ currentOp: 1 });
+      idleSessionsBeforeClose = opBefore.inprog.filter(s => s.type === 'idleSession');
+
+      await client.close();
+      await client.connect();
+
+      const opAfter = await client.db().admin().command({ currentOp: 1 });
+      idleSessionsAfterClose = opAfter.inprog.filter(s => s.type === 'idleSession');
+
+      await client.close();
+    });
+
     describe('Server resource: LSID/ServerSession', () => {
       describe('after a clientSession is created and used', () => {
-        it.skip('the server-side ServerSession is cleaned up by client.close()', async function () {});
+        it('the server-side ServerSession is cleaned up by client.close()', async function () {
+          expect(idleSessionsBeforeClose).to.not.be.empty;
+          expect(idleSessionsAfterClose).to.be.empty;
+        });
       });
     });
 
     describe('Server resource: Transactions', () => {
       describe('after a clientSession is created and used', () => {
-        it.skip('the server-side transaction is cleaned up by client.close()', async function () {});
+        it('the server-side transaction is cleaned up by client.close()', async function () {
+          expect(idleSessionsBeforeClose[0].transaction.txnNumber).to.not.null;
+          expect(idleSessionsAfterClose).to.be.empty;
+        });
       });
     });
   });
@@ -632,7 +690,32 @@ describe.skip('MongoClient.close() Integration', () => {
 
   describe('Server resource: Cursor', () => {
     describe('after cursors are created', () => {
-      it.skip('all active server-side cursors are closed by client.close()', async function () {});
+      let client;
+      let cursor;
+
+      afterEach(async function () {
+        await client?.close();
+        await cursor?.close();
+      });
+
+      it.only('all active server-side cursors are closed by client.close()', async function () {
+        client = this.configuration.newClient();
+        const coll = client.db('db').collection('coll');
+        await coll.insertMany([{ a: 1 }, { b: 1 }]);
+        cursor = await coll.find();
+        await cursor.next();
+
+        const before = await client.db().admin().command({ aggregate: 1, cursor: {}, pipeline: [ { $currentOp: { idleCursors: true,  } }] });
+        const beforeOp = await before.cursor.toArray();
+        //const cursorsBefore = opBefore.inprog.filter(r => r.type === 'idleCursor');
+        //expect(cursorsBefore).to.not.be.empty;
+
+        await client.close();
+        await client.connect();
+
+        const opAfter = await client.db().admin().command({ aggregate: 1, cursor: {}, pipeline: [ { $currentOp: { idleCursors: true } }] });
+        //expect(cursorsAfter).to.be.empty;
+      });
     });
   });
 });