Function runTestSuiteTest

test/tools/spec-runner/index.js:345–419

(configuration, spec, context)

const CMAP_EVENTS = new Set(SOURCE_CMAP_EVENTS);

function runTestSuiteTest(configuration, spec, context) {
  context.commandEvents = [];
  const clientOptions = translateClientOptions({
    heartbeatFrequencyMS: 100,
    minHeartbeatFrequencyMS: 100,
    monitorCommands: true,
    ...spec.clientOptions,
    __skipPingOnConnect: true
  });

  if (context.requiresCSFLE) {
    clientOptions.promoteValues = false;
    clientOptions.promoteLongs = false;
  }

  const url = resolveConnectionString(configuration, spec, context);
  const client = configuration.newClient(url, clientOptions);
  CMAP_EVENTS.forEach(eventName => client.on(eventName, event => context.cmapEvents.push(event)));
  SDAM_EVENTS.forEach(eventName => client.on(eventName, event => context.sdamEvents.push(event)));

  client.on('commandStarted', event => {
    if (!IGNORED_COMMANDS.has(event.commandName)) {
      context.commandEvents.push(event);
    }
  });

  return client.connect().then(client => {
    context.testClient = client;
    const sessionOptions = Object.assign({}, spec.transactionOptions);

    spec.sessionOptions = spec.sessionOptions || {};
    const database = client.db(context.dbName);

    let session0, session1;
    let savedSessionData;

    if (context.useSessions) {
      try {
        session0 = client.startSession(
          Object.assign({}, sessionOptions, parseSessionOptions(spec.sessionOptions.session0))
        );
        session1 = client.startSession(
          Object.assign({}, sessionOptions, parseSessionOptions(spec.sessionOptions.session1))
        );

        savedSessionData = {
          session0: JSON.parse(EJSON.stringify(session0.id)),
          session1: JSON.parse(EJSON.stringify(session1.id))
        };
      } catch {
        // ignore
      }
    }

    const operationContext = {
      client,
      database,
      collectionName: context.collectionName,