Function testBulkWrite

test/unit/collection.test.ts:110–140

(config)

  context('#bulkWrite', () => {
    async function testBulkWrite(config) {
      const client = new MongoClient(`mongodb://${server.uri()}/test`);

      server.setMessageHandler(request => {
        const doc = request.document;
        if (doc.insert) {
          expect(doc.bypassDocumentValidation).equal(config.expected);
          request.reply({
            ok: 1
          });
        }

        if (isHello(doc)) {
          request.reply(Object.assign({}, HELLO));
        } else if (doc.endSessions) {
          request.reply({ ok: 1 });
        }
      });

      await client.connect();
      const db = client.db('test');
      const collection = db.collection('test_c');

      const options = {
        bypassDocumentValidation: config.actual,
        ordered: config.ordered
      };

      await collection.bulkWrite([{ insertOne: { document: { a: 1 } } }], options);
      await client.close();
    }

    // ordered bulk write, testing change in ordered.js
    it('should only set bypass document validation if strictly true in ordered bulkWrite', async function () {