fix dupe key error

Author: nbbeeken

test/integration/enumerate_indexes.test.ts

@@ -2,11 +2,6 @@ import { TestBuilder, UnifiedTestSuiteBuilder } from '../tools/utils';
 
 new UnifiedTestSuiteBuilder('listIndexes with comment option')
   .createEntities(UnifiedTestSuiteBuilder.defaultEntities)
-  .initialData({
-    collectionName: 'collection0',
-    databaseName: 'database0',
-    documents: [{ _id: 1, x: 11 }]
-  })
   .test(
     new TestBuilder('listIndexes should not send comment for server versions < 4.4')
       .runOnRequirement({ maxServerVersion: '4.3.99' })

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

@@ -62,7 +62,7 @@ new UnifiedTestSuiteBuilder('Comment with Falsy Values')
   .createEntities(UnifiedTestSuiteBuilder.defaultEntities)
   .initialData({
     collectionName: 'collection0',
-    databaseName: '',
+    databaseName: 'database0',
     documents: [
       { _id: 1, x: 11 },
       { _id: 2, toBeDeleted: true } // This should only be used by the delete test

test/tools/unified-spec-runner/entities.ts

@@ -324,22 +324,6 @@ export class EntitiesMap<E = Entity> extends Map<string, E> {
       await session.endSession({ force: true });
     }
 
-    trace('drop namespaces');
-    for (const [, db] of this.mapOf('db')) {
-      if (['admin', 'local', 'config'].includes(db.databaseName)) {
-        continue;
-      }
-      expect(await db.dropDatabase()).to.be.true;
-    }
-
-    trace('drop namespaces');
-    for (const [, db] of this.mapOf('db')) {
-      if (['admin', 'local', 'config'].includes(db.databaseName)) {
-        continue;
-      }
-      expect(await db.dropDatabase()).to.be.true;
-    }
-
     trace('closeClient');
     for (const [, client] of this.mapOf('client')) {
       await client.close();
@@ -380,20 +364,10 @@ export class EntitiesMap<E = Entity> extends Map<string, E> {
         map.set(entity.database.id, db);
       } else if ('collection' in entity) {
         const db = map.getEntity('db', entity.collection.database);
-        const collection = await db
-          .createCollection(
-            entity.collection.collectionName,
-            patchCollectionOptions(entity.collection.collectionOptions)
-          )
-          .catch(error => {
-            if (/already exists/.test(error.message)) {
-              return db.collection(
-                entity.collection.collectionName,
-                patchCollectionOptions(entity.collection.collectionOptions)
-              );
-            }
-            throw error;
-          });
+        const collection = db.collection(
+          entity.collection.collectionName,
+          patchCollectionOptions(entity.collection.collectionOptions)
+        );
         map.set(entity.collection.id, collection);
       } else if ('session' in entity) {
         const client = map.getEntity('client', entity.session.client);
@@ -453,13 +427,6 @@ export class EntitiesMap<E = Entity> extends Map<string, E> {
         throw new Error(`Unsupported Entity ${JSON.stringify(entity)}`);
       }
     }
-
-    // startup events are never part of testing
-    for (const [, client] of map.mapOf('client')) {
-      client.commandEvents = [];
-      // client.cmapEvents = []; TODO connect optional PR
-    }
-
     return map;
   }
 }