elastic-bulk-stream - npm Package Compare versions

Comparing version 1.0.1 to 2.0.0

index.js

@@ -77,3 +77,17 @@ /* global require */
     index: this.index
-  }, function(err) {
+  })
+  .then(function(data) {
+    if (!data.errors) return callback()
+    const error = new Error('Bulk Error')
+    error.items = data.items
+      .filter((item) =>
+      (item.create && item.create.error) ||
+      (item.index && item.index.error) ||
+      (item.update && item.update.error) ||
+      (item.delete && item.delete.error)
+    )
+
+    callback(error)
+  })
+  .catch(function (err) {
     callback(err)
@@ -80,0 +94,0 @@ })

package.json

 {
   "name": "elastic-bulk-stream",
-  "version": "1.0.1",
+  "version": "2.0.0",
   "description": "transform stream to transfer data to elasticsearch",
@@ -27,3 +27,6 @@ "main": "index.js",
     "eslint": "^1.1.0"
+  },
+  "engines": {
+    "node": ">= 0.12.0"
   }
 }

No alert changes

Improved metrics

Total package byte prevSize

4519

increased by10.17%

Lines of code

86

increased by17.81%

No dependency changes