nothinkdb - npm Package Compare versions

Comparing version 0.5.31 to 0.5.32

lib/Environment.js

@@ -31,7 +31,10 @@ 'use strict';
 
+var _promiseMapSeries = require('promise-map-series');
+
+var _promiseMapSeries2 = _interopRequireDefault(_promiseMapSeries);
+
 function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { default: obj }; }
 
-/* eslint no-shadow: 0 */
+var debug = require('debug')('nothinkdb:Environment'); /* eslint no-shadow: 0 */
 
-var debug = require('debug')('nothinkdb:Environment');
 
@@ -89,61 +92,49 @@ var Environment = function () {
     value: function () {
-      var ref = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee3(connection) {
+      var ref = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee2(connection) {
         var _this = this;
 
-        return _regenerator2.default.wrap(function _callee3$(_context3) {
+        return _regenerator2.default.wrap(function _callee2$(_context2) {
           while (1) {
-            switch (_context3.prev = _context3.next) {
+            switch (_context2.prev = _context2.next) {
               case 0:
-                _context3.next = 2;
-                return Promise.all(_lodash2.default.map(this.tables, function () {
-                  var ref = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee2(table) {
-                    return _regenerator2.default.wrap(function _callee2$(_context2) {
+                _context2.next = 2;
+                return (0, _promiseMapSeries2.default)(_lodash2.default.values(this.tables), function () {
+                  var ref = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee(table) {
+                    var _connection;
+
+                    return _regenerator2.default.wrap(function _callee$(_context) {
                       while (1) {
-                        switch (_context2.prev = _context2.next) {
+                        switch (_context.prev = _context.next) {
                           case 0:
                             if (!_lodash2.default.isFunction(connection)) {
-                              _context2.next = 5;
+                              _context.next = 10;
                               break;
                             }
 
-                            _context2.next = 3;
-                            return connection().then(function () {
-                              var ref = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee(connection) {
-                                return _regenerator2.default.wrap(function _callee$(_context) {
-                                  while (1) {
-                                    switch (_context.prev = _context.next) {
-                                      case 0:
-                                        _context.next = 2;
-                                        return table.sync(connection);
+                            _context.next = 3;
+                            return _connection();
 
-                                      case 2:
-                                        _context.next = 4;
-                                        return connection.close();
+                          case 3:
+                            _connection = _context.sent;
+                            _context.next = 6;
+                            return table.sync(_connection);
 
-                                      case 4:
-                                      case 'end':
-                                        return _context.stop();
-                                    }
-                                  }
-                                }, _callee, _this);
-                              }));
-                              return function (_x4) {
-                                return ref.apply(this, arguments);
-                              };
-                            }());
+                          case 6:
+                            _context.next = 8;
+                            return _connection.close();
 
-                          case 3:
-                            _context2.next = 7;
+                          case 8:
+                            _context.next = 12;
                             break;
 
-                          case 5:
-                            _context2.next = 7;
+                          case 10:
+                            _context.next = 12;
                             return table.sync(connection);
 
-                          case 7:
+                          case 12:
                           case 'end':
-                            return _context2.stop();
+                            return _context.stop();
                         }
                       }
-                    }, _callee2, _this);
+                    }, _callee, _this);
                   }));
@@ -153,10 +144,10 @@ return function (_x3) {
                   };
-                }()));
+                }());
 
               case 2:
               case 'end':
-                return _context3.stop();
+                return _context2.stop();
             }
           }
-        }, _callee3, this);
+        }, _callee2, this);
       }));
@@ -163,0 +154,0 @@

package.json

 {
   "name": "nothinkdb",
-  "version": "0.5.31",
+  "version": "0.5.32",
   "description": "Functional toolkit for rethinkdb",
@@ -54,8 +54,8 @@ "main": "lib",
     "babel-runtime": "^6.9.0",
-    "core-decorators": "^0.12.2",
     "debug": "^2.2.0",
     "joi": "^7.2.3",
     "lodash": "^4.5.1",
-    "node-uuid": "^1.4.7"
+    "node-uuid": "^1.4.7",
+    "promise-map-series": "^0.2.2"
   }
 }

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

Major refactor

Supply chain risk

Package has recently undergone a major refactor. It may be unstable or indicate significant internal changes. Use caution when updating to versions that include significant changes.

Found 1 instance in 1 package

Improved metrics

Number of medium supply chain risk alerts

0

decreased by-100%

Worsened metrics

Total package byte prevSize

42668

decreased by-1.63%

Lines of code

993

decreased by-1.19%

Dependency changes

• + Addedpromise-map-series@^0.2.2

• + Addedpromise-map-series@0.2.3(transitive)

• + Addedrsvp@3.6.2(transitive)

• - Removedcore-decorators@^0.12.2

• - Removedcore-decorators@0.12.3(transitive)