marsdb - npm Package Compare versions

Comparing version 0.3.13 to 0.3.14

dist/Cursor.js

@@ -9,3 +9,3 @@ 'use strict';
 
-var _get = function get(_x2, _x3, _x4) { var _again = true; _function: while (_again) { var object = _x2, property = _x3, receiver = _x4; desc = parent = getter = undefined; _again = false; if (object === null) object = Function.prototype; var desc = Object.getOwnPropertyDescriptor(object, property); if (desc === undefined) { var parent = Object.getPrototypeOf(object); if (parent === null) { return undefined; } else { _x2 = parent; _x3 = property; _x4 = receiver; _again = true; continue _function; } } else if ('value' in desc) { return desc.value; } else { var getter = desc.get; if (getter === undefined) { return undefined; } return getter.call(receiver); } } };
+var _get = function get(_x4, _x5, _x6) { var _again = true; _function: while (_again) { var object = _x4, property = _x5, receiver = _x6; desc = parent = getter = undefined; _again = false; if (object === null) object = Function.prototype; var desc = Object.getOwnPropertyDescriptor(object, property); if (desc === undefined) { var parent = Object.getPrototypeOf(object); if (parent === null) { return undefined; } else { _x4 = parent; _x5 = property; _x6 = receiver; _again = true; continue _function; } } else if ('value' in desc) { return desc.value; } else { var getter = desc.get; if (getter === undefined) { return undefined; } return getter.call(receiver); } } };
 
@@ -96,9 +96,14 @@ var _PIPELINE_PROCESSORS;
 }), _defineProperty(_PIPELINE_PROCESSORS, PIPELINE_TYPE.JoinEach, function (docs, pipeObj, cursor) {
-  return Promise.all(((0, _lodashLangIsArray2['default'])(docs) ? docs : [docs]).map(function (x) {
-    return PIPELINE_PROCESSORS[PIPELINE_TYPE.JoinAll](x, pipeObj, cursor);
+  docs = (0, _lodashLangIsArray2['default'])(docs) ? docs : [docs];
+  var docsLength = docs.length;
+  return Promise.all(docs.map(function (x, i) {
+    return PIPELINE_PROCESSORS[PIPELINE_TYPE.JoinAll](x, pipeObj, cursor, i, docsLength);
   }));
 }), _defineProperty(_PIPELINE_PROCESSORS, PIPELINE_TYPE.JoinAll, function (docs, pipeObj, cursor) {
+  var i = arguments.length <= 3 || arguments[3] === undefined ? 0 : arguments[3];
+  var len = arguments.length <= 4 || arguments[4] === undefined ? 1 : arguments[4];
+
   var updatedFn = cursor._propagateUpdate ? cursor._propagateUpdate.bind(cursor) : function () {};
 
-  var res = pipeObj.value(docs, updatedFn);
+  var res = pipeObj.value(docs, updatedFn, i, len);
   res = (0, _lodashLangIsArray2['default'])(res) ? res : [res];
@@ -105,0 +110,0 @@ res.forEach(function (observeStopper) {

lib/Cursor.js

@@ -53,7 +53,10 @@ import _each from 'lodash/collection/each';
   [PIPELINE_TYPE.JoinEach]: (docs, pipeObj, cursor) => {
-    return Promise.all((_isArray(docs) ? docs : [docs]).map((x) => (
-      PIPELINE_PROCESSORS[PIPELINE_TYPE.JoinAll](x, pipeObj, cursor)
+    docs = _isArray(docs) ? docs : [docs];
+    const docsLength = docs.length;
+    return Promise.all(docs.map((x, i) => (
+      PIPELINE_PROCESSORS[PIPELINE_TYPE.JoinAll](x, pipeObj, cursor,
+        i, docsLength)
     )));
   },
-  [PIPELINE_TYPE.JoinAll]: (docs, pipeObj, cursor) => {
+  [PIPELINE_TYPE.JoinAll]: (docs, pipeObj, cursor, i = 0, len = 1) => {
     const updatedFn = (cursor._propagateUpdate)
@@ -63,3 +66,3 @@ ? cursor._propagateUpdate.bind(cursor)
 
-    let res = pipeObj.value(docs, updatedFn);
+    let res = pipeObj.value(docs, updatedFn, i, len);
     res = _isArray(res) ? res : [res];
@@ -66,0 +69,0 @@ res.forEach(observeStopper => {

package.json

 {
   "name": "marsdb",
-  "version": "0.3.13",
+  "version": "0.3.14",
   "author": {
@@ -5,0 +5,0 @@ "name": "Artem Artemev",

New alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Fixed alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

1083884

increased by0.07%

Lines of code

25300

increased by0.05%

No dependency changes