filter by ns

Author: aditi-khare-mongoDB

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

@@ -5,7 +5,7 @@ import { type Collection, type FindCursor, type MongoClient } from '../../mongod
 import { type TestConfiguration } from '../../tools/runner/config';
 import { runScriptAndGetProcessInfo } from './resource_tracking_script_builder';
 
-describe('MongoClient.close() Integration', () => {
+describe.only('MongoClient.close() Integration', () => {
   // note: these tests are set-up in accordance of the resource ownership tree
 
   let config: TestConfiguration;
@@ -716,13 +716,13 @@ describe('MongoClient.close() Integration', () => {
         utilClient = this.configuration.newClient();
         await client.connect();
         await client
-          .db('db')
-          .collection('coll')
+          .db('close')
+          .collection('cursorCleanUp')
           ?.drop()
           .catch(() => null);
         coll = await client
-          .db('db')
-          .createCollection('coll', { capped: true, size: 1_000, max: 4 });
+          .db('close')
+          .createCollection('cursorCleanUp', { capped: true, size: 1_000, max: 4 });
         await coll.insertMany([{ a: 1 }, { b: 2 }, { c: 3 }]);
       });
 
@@ -745,9 +745,8 @@ describe('MongoClient.close() Integration', () => {
                 cursor: {},
                 pipeline: [{ $currentOp: { idleCursors: true } }]
               });
-            return res.cursor.firstBatch.filter(
-              r => r.type === 'idleCursor' || (r.type === 'op' && r.desc === 'getMore')
-            );
+            const isCursor = (r) => ((r.type === 'idleCursor') || (r.type === 'op' && r.desc === 'getMore'));
+            return res.cursor.firstBatch.filter(r => isCursor(r) && r.ns === 'close.cursorCleanUp');
           };
 
           cursor = coll.find(