feat(mongo): support user and password connection options

Closes #31, #32

lib/connections/MongoConnection.ts

@@ -1,5 +1,5 @@
-import { Collection, Db, MongoClient, ObjectID } from 'mongodb';
-import { Connection, QueryResult } from './Connection';
+import { Collection, Db, MongoClient, MongoClientOptions, ObjectID } from 'mongodb';
+import { Connection, ConnectionConfig, QueryResult } from './Connection';
 import { Utils } from '../utils';
 import { QueryOrder } from '../query';
 import { FilterQuery } from '..';
@@ -10,7 +10,7 @@ export class MongoConnection extends Connection {
   protected db: Db;
 
   async connect(): Promise<void> {
-    this.client = await MongoClient.connect(this.config.getClientUrl(), { useNewUrlParser: true });
+    this.client = await MongoClient.connect(this.config.getClientUrl(), this.getConnectionOptions());
     this.db = this.client.db(this.config.get('dbName'));
   }
 
@@ -30,6 +30,18 @@ export class MongoConnection extends Connection {
     return 'mongodb://localhost:27017';
   }
 
+  getConnectionOptions(): MongoClientOptions & ConnectionConfig {
+    const ret: MongoClientOptions = { useNewUrlParser: true };
+    const user = this.config.get('user');
+    const password = this.config.get('password');
+
+    if (user && password) {
+      ret.auth = { user, password };
+    }
+
+    return ret;
+  }
+
   async execute(query: string): Promise<any> {
     throw new Error(`${this.constructor.name} does not support generic execute method`);
   }

tests/EntityManager.mongo.test.ts

@@ -1,10 +1,11 @@
 import { ObjectID } from 'mongodb';
-import { Collection, EntityManager, MikroORM, QueryOrder } from '../lib';
+import { Collection, Configuration, EntityManager, MikroORM, QueryOrder } from '../lib';
 import { EntityProperty } from '../lib/decorators';
 import { Author, Book, BookTag, Publisher, PublisherType, Test } from './entities';
 import { AuthorRepository } from './repositories/AuthorRepository';
 import { initORM, wipeDatabase } from './bootstrap';
 import { MongoDriver } from '../lib/drivers/MongoDriver';
+import { MongoConnection } from '../lib/connections/MongoConnection';
 import { Logger } from '../lib/utils';
 
 /**
@@ -307,6 +308,15 @@ describe('EntityManagerMongo', () => {
     await expect(driver.getConnection().execute('')).rejects.toThrowError('MongoConnection does not support generic execute method');
   });
 
+  test('should use user and password as connection options', async () => {
+    const config = new Configuration({ user: 'usr', password: 'pw' } as any, false);
+    const connection = new MongoConnection(config);
+    await expect(connection.getConnectionOptions()).toEqual({
+      useNewUrlParser: true,
+      auth: { user: 'usr', password: 'pw' },
+    });
+  });
+
   test('findOne by id', async () => {
     const authorRepository = orm.em.getRepository(Author);
     const jon = new Author('Jon Snow', '[email protected]');