test(NODE-7254): migrate node-specific/operation_examples tests (#4743)

Author: tadjik1

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

@@ -1,12 +1,7 @@
 import { expect } from 'chai';
 
-import {
-  Code,
-  enumToString,
-  type MongoClient,
-  ProfilingLevel,
-  ReturnDocument
-} from '../../mongodb';
+import { Code, type MongoClient, ProfilingLevel, ReturnDocument } from '../../../src';
+import { enumToString } from '../../../src/utils';
 import { sleep as delay } from '../../tools/utils';
 import { setupDatabase } from '../shared';
 
@@ -3989,77 +3984,47 @@ describe('Operations', function () {
   });
 
   /**
-   * A simple example showing the listening to a capped collection using a Promise.
+   * A simple example showing the listening to a capped collection.
    *
    * example-class Db
    * example-method createCollection
    */
-  it('Should correctly add capped collection options to cursor With Promises', {
-    metadata: { requires: { topology: ['single'] } },
-
-    test: function (done) {
-      const configuration = this.configuration;
-      const client = configuration.newClient(configuration.writeConcernMax(), {
-        maxPoolSize: 1
-      });
-
-      client.connect().then(function (client) {
-        const db = client.db(configuration.db);
-        // LINE var MongoClient = require('mongodb').MongoClient,
-        // LINE   test = require('assert');
-        // LINE const client = new MongoClient('mongodb://localhost:27017/test');
-        // LINE client.connect().then(() => {
-        // LINE   var db = client.db('test);
-        // REPLACE configuration.writeConcernMax() WITH {w:1}
-        // REMOVE-LINE done();
-        // BEGIN
-        // Create a capped collection with a maximum of 1000 documents
-        let collection;
-
-        db.createCollection('a_simple_collection_2_with_promise', {
-          capped: true,
-          size: 100000,
-          max: 1000,
-          writeConcern: { w: 1 }
-        })
-          .then(function (_collection) {
-            collection = _collection;
-
-            const docs: Array<{ a: number }> = [];
-            for (let i = 0; i < 1000; i++) docs.push({ a: i });
+  it('Should correctly add capped collection options to cursor', async function () {
+    const configuration = this.configuration;
+    const client = configuration.newClient(configuration.writeConcernMax(), {
+      maxPoolSize: 1
+    });
 
-            // Insert a document in the capped collection
-            return collection.insertMany(docs, configuration.writeConcernMax());
-          })
-          .then(function (result) {
-            expect(result).to.exist;
+    await client.connect();
+    const db = client.db(configuration.db);
 
-            let total = 0;
+    const collection = await db.createCollection('a_simple_collection_2_with_promise', {
+      capped: true,
+      size: 100000,
+      max: 1000,
+      writeConcern: { w: 1 }
+    });
+    const docs: Array<{ a: number }> = [];
+    for (let i = 0; i < 10000; i++) docs.push({ a: i });
 
-            // Get the cursor
-            const cursor = collection
-              .find({ a: { $gte: 0 } })
-              .addCursorFlag('tailable', true)
-              .addCursorFlag('awaitData', true);
+    // Insert a document in the capped collection
+    await collection.insertMany(docs, configuration.writeConcernMax());
+    let total = 0;
 
-            const stream = cursor.stream();
-            stream.on('data', function (d) {
-              expect(d).to.exist;
-              total = total + 1;
+    // Get the cursor
+    const cursor = collection
+      .find({ a: { $gte: 0 } })
+      .addCursorFlag('tailable', true)
+      .addCursorFlag('awaitData', true);
 
-              if (total === 1000) {
-                cursor.close();
-              }
-            });
+    const stream = cursor.stream();
 
-            cursor.on('close', function () {
-              // TODO: forced because the cursor is still open/active
-              client.close(true, done);
-            });
-          });
-      });
-      // END
+    for await (const d of stream) {
+      expect(d).to.have.property('_id');
+      total = total + 1;
+      if (total === 1000) await cursor.close();
     }
+    await client.close();
   });
 
   describe('Transaction Examples', function () {