Check if collection exists in database

Author: rsaladocid

src/Contexts/Shared/infrastructure/persistence/mongo/MongoClientFactory.ts

@@ -25,7 +25,6 @@ export class MongoClientFactory {
     const client = new MongoClient(config.get('mongo.url'), { useUnifiedTopology: true });
 
     await client.connect();
-    client.db(config.get('mongo.name'));
 
     return client;
   }

src/apps/mooc_backend/config/config.ts

@@ -12,11 +12,6 @@ const convictConfig = convict({
       doc: 'The Mongo connection URL',
       format: String,
       env: 'MONGO_URL'
-    },
-    name: {
-      doc: 'The Mongo database name',
-      format: String,
-      env: 'MONGO_DB_NAME'
     }
   }
 });

src/apps/mooc_backend/config/test.json

@@ -1,3 +1,3 @@
 {
-  "mongo": { "url": "mongodb://localhost:27017", "name": "test" }
+  "mongo": { "url": "mongodb://localhost:27017/test" }
 }

tests/Contexts/Shared/infrastructure/arranger/MongoEnvironmentArranger.ts

@@ -7,7 +7,19 @@ export class MongoEnvironmentArranger extends EnvironmentArranger {
   }
 
   protected async clean(name: string): Promise<void> {
-    await (await this.client()).db().dropCollection(name);
+    const hasCollection = await this.hasCollection(name);
+
+    if (hasCollection) {
+      await (await this.client()).db().dropCollection(name);
+    }
+  }
+
+  private async hasCollection(name: string): Promise<boolean> {
+    const client = await this.client();
+    return await client
+      .db()
+      .listCollections({ name }, { nameOnly: true })
+      .hasNext();
   }
 
   protected client(): Promise<MongoClient> {