Method run

test/unit/assorted/write_concern.test.js:52–94

(resultKey, testFn)

  }

  async run(resultKey, testFn) {
    const self = this;
    let primaryServer = await mock.createServer(32000, 'localhost');
    let firstSecondaryServer = await mock.createServer(32001, 'localhost');
    let arbiterServer = await mock.createServer(32002, 'localhost');

    primaryServer.setMessageHandler(request => {
      const doc = request.document;
      if (isHello(doc)) {
        request.reply(self.serverStates.primary[0]);
      } else if (doc[resultKey]) {
        self.commandResult = doc;
        request.reply(Object.assign({ ok: 1 }, self.responseDecoration));
      } else if (doc.endSessions) {
        request.reply({ ok: 1 });
      }
    });

    firstSecondaryServer.setMessageHandler(request => {
      const doc = request.document;
      if (isHello(doc)) {
        request.reply(self.serverStates.firstSecondary[0]);
      } else if (doc.endSessions) {
        request.reply({ ok: 1 });
      }
    });

    arbiterServer.setMessageHandler(request => {
      const doc = request.document;
      if (isHello(doc)) {
        request.reply(self.serverStates.arbiter[0]);
      } else if (doc.endSessions) {
        request.reply({ ok: 1 });
      }
    });

    const client = new MongoClient(
      'mongodb://localhost:32000,localhost:32001,localhost:32002/test?replicaSet=rs'
    );

    await client.connect();
    await testFn(client, client.db('write_concern_db'));
  }
}

function writeConcernTest(command, testFn) {