fix(MongoMemoryReplSet): getConnectionString() now returns uri with ?replicaSet= option.

BREAKING CHANGE: `getConnectionString()` now returns uri with `?replicaSet=` option.

Author: nodkz

packages/mongodb-memory-server-core/src/MongoMemoryReplSet.ts

@@ -156,7 +156,7 @@ export default class MongoMemoryReplSet extends EventEmitter {
     }
     const ports = await Promise.all(this.servers.map((s) => s.getPort()));
     const hosts = ports.map((port) => `127.0.0.1:${port}`).join(',');
-    return `mongodb://${hosts}/${dbName}`;
+    return `mongodb://${hosts}/${dbName}?replicaSet=${this.opts.replSet.name}`;
   }
 
   /**

packages/mongodb-memory-server-core/src/__tests__/replset-single-test.ts

@@ -19,7 +19,8 @@ describe('single server replset', () => {
     const uri = await replSet.getUri('other');
     const str = await replSet.getConnectionString('other');
     expect(uri.split(',').length).toEqual(1);
-    expect(uri.endsWith('/other')).toBeTruthy();
+    expect(uri.includes('/other')).toBeTruthy();
+    expect(uri.includes('replicaSet=testset')).toBeTruthy();
     expect(str).toEqual(uri);
 
     await replSet.stop();

packages/mongodb-memory-server-core/src/__tests__/replset-test.ts

@@ -4,7 +4,7 @@ import { MongoClient } from 'mongodb';
 jasmine.DEFAULT_TIMEOUT_INTERVAL = 600000;
 
 describe('multi-member replica set', () => {
-  it.only('should enter running state', async () => {
+  it('should enter running state', async () => {
     const opts: any = { replSet: { count: 3 } };
     const replSet = new MongoMemoryReplSet(opts);
     await replSet.waitUntilRunning();
@@ -21,11 +21,17 @@ describe('multi-member replica set', () => {
     await replSet.waitUntilRunning();
     const uri = await replSet.getUri();
 
-    await MongoClient.connect(`${uri}?replicaSet=testset`, {
+    const conn = await MongoClient.connect(uri, {
       useNewUrlParser: true,
       useUnifiedTopology: true,
     });
 
+    const db = await conn.db(await replSet.getDbName());
+    const admin = db.admin();
+    const status = await admin.replSetGetStatus();
+    expect(status.members.filter((m: any) => m.stateStr === 'PRIMARY')).toHaveLength(1);
+    expect(status.members.filter((m: any) => m.stateStr === 'SECONDARY')).toHaveLength(2);
+
     await replSet.stop();
   });
 });