sync tests

Author: emadum

test/functional/crud_spec.test.js

@@ -10,6 +10,9 @@ const TestRunnerContext = require('./spec-runner').TestRunnerContext;
 const gatherTestSuites = require('./spec-runner').gatherTestSuites;
 const generateTopologyTests = require('./spec-runner').generateTopologyTests;
 
+const { loadSpecTests } = require('../spec/index');
+const { runUnifiedTest } = require('./unified-spec-runner/runner');
+
 function enforceServerVersionLimits(requires, scenario) {
   const versionLimits = [];
   if (scenario.minServerVersion) {
@@ -433,3 +436,29 @@ describe('CRUD v2', function () {
 
   generateTopologyTests(testSuites, testContext);
 });
+
+describe('CRUD unified', function () {
+  for (const crudSpecTest of loadSpecTests('crud/unified')) {
+    expect(crudSpecTest).to.exist;
+    context(String(crudSpecTest.description), function () {
+      for (const test of crudSpecTest.tests) {
+        it(String(test.description), {
+          metadata: { sessions: { skipLeakTests: true } },
+          test: async function () {
+            try {
+              await runUnifiedTest(this, crudSpecTest, test);
+            } catch (error) {
+              if (error.message.includes('not implemented.')) {
+                console.log(`${test.description}: was skipped due to missing functionality`);
+                console.log(error.stack);
+                this.skip();
+              } else {
+                throw error;
+              }
+            }
+          }
+        });
+      }
+    });
+  }
+});

test/functional/cursor.test.js

@@ -3600,7 +3600,7 @@ describe('Cursor', function () {
     }
   });
 
-  it('Correctly decorate the collection cursor count command with skip, limit, hint, readConcern', {
+  it.skip('Correctly decorate the collection count command with skip, limit, hint, readConcern', {
     // 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: {

test/functional/retryable_reads.test.js

@@ -24,7 +24,7 @@ describe('Retryable Reads', function () {
       spec.description.match(/listCollections/i) ||
       spec.description.match(/listCollectionNames/i) ||
       spec.description.match(/estimatedDocumentCount/i) ||
-      spec.description.match(/count/i) ||
+      // spec.description.match(/count/i) ||
       spec.description.match(/find/i)
     );
   });

test/functional/unified-spec-runner/operations.ts

@@ -6,7 +6,7 @@ import { ReadPreference } from '../../../src/read_preference';
 import { WriteConcern } from '../../../src/write_concern';
 import { Document, InsertOneOptions } from '../../../src';
 import { EventCollector } from '../../tools/utils';
-import { EntitiesMap, UnifiedMongoClient } from './entities';
+import { EntitiesMap } from './entities';
 import { expectErrorCheck, resultCheck } from './match';
 import type { OperationDescription } from './schema';
 import { CommandStartedEvent } from '../../../src/cmap/events';
@@ -384,7 +384,7 @@ operations.set('distinct', async ({ entities, operation }) => {
 
 operations.set('estimatedDocumentCount', async ({ entities, operation }) => {
   const collection = entities.getEntity('collection', operation.object);
-  return collection.estimatedDocumentCount();
+  return collection.estimatedDocumentCount(operation.arguments);
 });
 
 operations.set('findOneAndDelete', async ({ entities, operation }) => {