Function test

test/integration/crud/bulk.test.ts:1616–1656

()

  it(class="st">'should apply hint via FindOperators', {
    metadata: { requires: { mongodb: class="st">'>= 4.4' } },
    async test() {
      const bulk = client.db().collection(class="st">'coll').initializeOrderedBulkOp();

      const events = [];
      client.on(class="st">'commandStarted', event => {
        if ([class="st">'update', class="st">'delete'].includes(event.commandName)) {
          events.push(event);
        }
      });

      class="cm">// updates
      bulk
        .find({ b: 1 })
        .hint({ b: 1 })
        .updateOne({ $set: { b: 2 } });
      bulk
        .find({ b: 2 })
        .hint({ b: 1 })
        .update({ $set: { b: 3 } });
      bulk.find({ b: 3 }).hint({ b: 1 }).replaceOne({ b: 2 });

      class="cm">// deletes
      bulk.find({ b: 2 }).hint({ b: 1 }).deleteOne();
      bulk.find({ b: 1 }).hint({ b: 1 }).delete();

      await bulk.execute();

      expect(events).to.be.an(class="st">'array').with.length.at.least(1);
      expect(events[0]).property(class="st">'commandName').to.equal(class="st">'update');
      const updateCommand = events[0].command;
      expect(updateCommand).property(class="st">'updates').to.be.an(class="st">'array').with.length(3);
      updateCommand.updates.forEach(statement => {
        expect(statement).property(class="st">'hint').to.eql({ b: 1 });
      });
      expect(events[1]).property(class="st">'commandName').to.equal(class="st">'delete');
      const deleteCommand = events[1].command;
      expect(deleteCommand).property(class="st">'deletes').to.be.an(class="st">'array').with.length(2);
      deleteCommand.deletes.forEach(statement => {
        expect(statement).property(class="st">'hint').to.eql({ b: 1 });
      });
    }
  });

  it(class="st">'should apply arrayFilters to bulk updates via FindOperators', async function () {