From bedc2d2be082ee46fbf1640ebeef27ba9f185874 Mon Sep 17 00:00:00 2001
From: Dan Aprahamian <dan.aprahamian@gmail.com>
Date: Mon, 14 Jan 2019 16:55:12 -0500
Subject: [PATCH] fix(bulk): make sure that any error in bulk write is
 propagated

* fix(bulk): make sure that any error in bulk write is propagaged

Previously, errors that were not the last returned during
a bulk write would be swallowed. Now, we return them.

Fixes NODE-1702

* updating test name

* fixing typo
---
 lib/bulk/unordered.js         |  9 +++++
 test/unit/bulk_write_tests.js | 65 +++++++++++++++++++++++++++++++++++
 2 files changed, 74 insertions(+)
 create mode 100644 test/unit/bulk_write_tests.js

diff --git a/lib/bulk/unordered.js b/lib/bulk/unordered.js
index d33f7006b2..6ec27b9081 100644
--- a/lib/bulk/unordered.js
+++ b/lib/bulk/unordered.js
@@ -172,9 +172,18 @@ function executeBatch(bulkOperation, batch, options, callback) {
  */
 function executeBatches(bulkOperation, options, callback) {
   let numberOfCommandsToExecute = bulkOperation.s.batches.length;
+  let hasErrored = false;
   // Execute over all the batches
   for (let i = 0; i < bulkOperation.s.batches.length; i++) {
     executeBatch(bulkOperation, bulkOperation.s.batches[i], options, function(err) {
+      if (hasErrored) {
+        return;
+      }
+
+      if (err) {
+        hasErrored = true;
+        return handleCallback(callback, err);
+      }
       // Count down the number of commands left to execute
       numberOfCommandsToExecute = numberOfCommandsToExecute - 1;
 
diff --git a/test/unit/bulk_write_tests.js b/test/unit/bulk_write_tests.js
new file mode 100644
index 0000000000..69ea7fba14
--- /dev/null
+++ b/test/unit/bulk_write_tests.js
@@ -0,0 +1,65 @@
+'use strict';
+
+const expect = require('chai').expect;
+const mock = require('mongodb-mock-server');
+
+describe('Bulk Writes', function() {
+  const test = {};
+
+  let documents;
+  before(() => {
+    documents = new Array(20000).fill('').map(() => ({
+      arr: new Array(19).fill('aaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaa')
+    }));
+  });
+
+  beforeEach(() => {
+    return mock.createServer().then(server => {
+      test.server = server;
+    });
+  });
+  afterEach(() => mock.cleanup());
+
+  it('should propagate errors', function(done) {
+    const client = this.configuration.newClient(`mongodb://${test.server.uri()}/test`);
+
+    let close = e => {
+      close = () => {};
+      client.close(() => done(e));
+    };
+
+    let hasErrored = false;
+
+    test.server.setMessageHandler(request => {
+      const doc = request.document;
+      if (doc.ismaster) {
+        request.reply(Object.assign({}, mock.DEFAULT_ISMASTER));
+      } else if (doc.endSessions) {
+        request.reply({ ok: 1 });
+      } else if (doc.insert) {
+        if (hasErrored) {
+          return request.reply({ ok: 1 });
+        }
+        hasErrored = true;
+        return request.reply({ ok: 0 });
+      } else {
+        close(`Received unknown command ${doc}`);
+      }
+    });
+
+    client.connect(function(err) {
+      expect(err).to.be.null;
+
+      const coll = client.db('foo').collection('bar');
+
+      coll.insert(documents, { ordered: false }, function(err) {
+        try {
+          expect(err).to.be.an.instanceOf(Error);
+          done();
+        } catch (e) {
+          done(e);
+        }
+      });
+    });
+  });
+});