test(NODE-4264): part 1 of removing connect from tests

Author: nbbeeken

global.d.ts

@@ -12,7 +12,7 @@ declare global {
       topology?: TopologyTypeRequirement;
       mongodb?: string;
       os?: NodeJS.Platform | `!${NodeJS.Platform}`;
-      apiVersion?: '1';
+      apiVersion?: '1' | boolean;
       clientSideEncryption?: boolean;
       serverless?: 'forbid' | 'allow' | 'require';
       auth?: 'enabled' | 'disabled';

test/integration/auth/mongodb_aws.test.js

@@ -4,7 +4,7 @@ const { removeAuthFromConnectionString } = require('../../tools/utils');
 const sinon = require('sinon');
 const http = require('http');
 const { performance } = require('perf_hooks');
-const { MongoAWSError } = require('../../../src');
+const { MongoAWSError, MongoError } = require('../../../src');
 
 describe('MONGODB-AWS', function () {
   beforeEach(function () {
@@ -15,37 +15,28 @@ describe('MONGODB-AWS', function () {
     }
   });
 
-  it('should not authorize when not authenticated', function (done) {
-    const config = this.configuration;
-    const url = removeAuthFromConnectionString(config.url());
-    const client = config.newClient(url); // strip provided URI of credentials
-    client.connect(err => {
-      expect(err).to.not.exist;
-      this.defer(() => client.close());
+  it('should not authorize when not authenticated', async function () {
+    const url = removeAuthFromConnectionString(this.configuration.url());
+    const client = this.configuration.newClient(url); // strip provided URI of credentials
 
-      client.db('aws').command({ count: 'test' }, (err, count) => {
-        expect(err).to.exist;
-        expect(count).to.not.exist;
+    const error = await client
+      .db('aws')
+      .command({ ping: 1 })
+      .catch(error => error);
 
-        done();
-      });
-    });
+    expect(error).to.be.instanceOf(MongoAWSError);
   });
 
-  it('should authorize when successfully authenticated', function (done) {
-    const config = this.configuration;
-    const client = config.newClient(process.env.MONGODB_URI); // use the URI built by the test environment
-    client.connect(err => {
-      expect(err).to.not.exist;
-      this.defer(() => client.close());
+  it('should authorize when successfully authenticated', async function () {
+    const client = this.configuration.newClient(process.env.MONGODB_URI); // use the URI built by the test environment
 
-      client.db('aws').command({ count: 'test' }, (err, count) => {
-        expect(err).to.not.exist;
-        expect(count).to.exist;
+    const result = await client
+      .db('aws')
+      .command({ ping: 1 })
+      .catch(error => error);
 
-        done();
-      });
-    });
+    expect(result).to.not.be.instanceOf(MongoAWSError);
+    expect(result).to.have.property('ok', 1);
   });
 
   it('should allow empty string in authMechanismProperties.AWS_SESSION_TOKEN to override AWS_SESSION_TOKEN environment variable', function () {
@@ -84,10 +75,10 @@ describe('MONGODB-AWS', function () {
       client = config.newClient(process.env.MONGODB_URI, { authMechanism: 'MONGODB-AWS' }); // use the URI built by the test environment
       const startTime = performance.now();
 
-      let caughtError = null;
-      await client.connect().catch(err => {
-        caughtError = err;
-      });
+      const caughtError = await client
+        .db()
+        .command({ ping: 1 })
+        .catch(error => error);
 
       const endTime = performance.now();
       const timeTaken = endTime - startTime;

test/integration/auth/scram_sha_1.test.js

@@ -0,0 +1,29 @@
+import { expect } from 'chai';
+
+import type { MongoClient } from '../../../src';
+
+describe('SCRAM-SHA-1', function () {
+  let client: MongoClient;
+
+  beforeEach(async function () {
+    const onlyScram1AuthMech =
+      this.configuration.parameters?.authenticationMechanisms.length === 1 &&
+      this.configuration.parameters?.authenticationMechanisms[0] === 'SCRAM-SHA-1';
+
+    if (!onlyScram1AuthMech) {
+      this.currentTest.skipReason = `MongoDB auth mechanism must only be SCRAM-SHA-1, got ${this.configuration.parameters?.authenticationMechanisms}`;
+      return this.skip();
+    }
+
+    client = this.configuration.newClient();
+  });
+
+  afterEach(async () => {
+    await client.close();
+  });
+
+  it('successfuly authenticates', async () => {
+    const result = await client.db().admin().command({ ping: 1 });
+    expect(result).to.have.property('ok', 1);
+  });
+});

test/integration/auth/scram_sha_1.test.ts

@@ -9,43 +9,30 @@ describe('Decimal128', function () {
     return setupDatabase(this.configuration);
   });
 
-  it('should correctly insert decimal128 value', {
-    // Add a tag that our runner can trigger on
-    // in this case we are setting that node needs to be higher than 0.10.X to run
-    metadata: {
-      requires: {
-        mongodb: '>=3.3.6',
-        topology: ['single']
-      }
-    },
+  it('should correctly insert decimal128 value', function (done) {
+    var configuration = this.configuration;
+    var client = configuration.newClient(configuration.writeConcernMax(), { maxPoolSize: 1 });
+    var db = client.db(configuration.db);
+    var object = {
+      id: 1,
+      value: Decimal128.fromString('1.28')
+    };
 
-    test: function (done) {
-      var configuration = this.configuration;
-      var client = configuration.newClient(configuration.writeConcernMax(), { maxPoolSize: 1 });
-      client.connect(function (err, client) {
-        var db = client.db(configuration.db);
-        var object = {
-          id: 1,
-          value: Decimal128.fromString('1')
-        };
+    db.collection('decimal128').insertOne(object, function (err) {
+      expect(err).to.not.exist;
 
-        db.collection('decimal128').insertOne(object, function (err) {
+      db.collection('decimal128').findOne(
+        {
+          id: 1
+        },
+        function (err, doc) {
           expect(err).to.not.exist;
+          test.ok(doc.value instanceof Decimal128);
+          test.equal('1.28', doc.value.toString());
 
-          db.collection('decimal128').findOne(
-            {
-              id: 1
-            },
-            function (err, doc) {
-              expect(err).to.not.exist;
-              test.ok(doc.value instanceof Decimal128);
-              test.equal('1', doc.value.toString());
-
-              client.close(done);
-            }
-          );
-        });
-      });
-    }
+          client.close(done);
+        }
+      );
+    });
   });
 });

test/integration/bson-decimal128/decimal128.test.js

@@ -37,8 +37,6 @@ describe('Causal Consistency - prose tests', function () {
     test.client.on('commandSucceeded', event => {
       if (ignoredCommands.indexOf(event.commandName) === -1) test.commands.succeeded.push(event);
     });
-
-    return test.client.connect();
   });
 
   afterEach(() => {