@bitski/provider-engine
Advanced tools
Comparing version 0.2.0-beta.3 to 0.2.0-beta.4
@@ -11,7 +11,7 @@ 'use strict'; | ||
var _eachSeries2 = _interopRequireDefault(_eachSeries); | ||
var eachSeries = _interopRequireWildcard(_eachSeries); | ||
var _map = require('async/map'); | ||
var _map2 = _interopRequireDefault(_map); | ||
var map = _interopRequireWildcard(_map); | ||
@@ -32,6 +32,6 @@ var _ethBlockTracker = require('eth-block-tracker'); | ||
function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { default: obj }; } | ||
function _interopRequireWildcard(obj) { if (obj && obj.__esModule) { return obj; } else { var newObj = {}; if (obj != null) { for (var key in obj) { if (Object.prototype.hasOwnProperty.call(obj, key)) newObj[key] = obj[key]; } } newObj.default = obj; return newObj; } } | ||
function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { default: obj }; } | ||
function _classCallCheck(instance, Constructor) { if (!(instance instanceof Constructor)) { throw new TypeError("Cannot call a class as a function"); } } | ||
@@ -116,3 +116,3 @@ | ||
// handle batch | ||
(0, _map2.default)(payload, _this3._handleAsync.bind(_this3), cb); | ||
map(payload, _this3._handleAsync.bind(_this3), cb); | ||
} else { | ||
@@ -156,3 +156,3 @@ // handle single | ||
result = _result; | ||
(0, _eachSeries2.default)(stack, function (fn, callback) { | ||
eachSeries(stack, function (fn, callback) { | ||
if (fn) { | ||
@@ -159,0 +159,0 @@ fn(error, result, callback); |
@@ -11,11 +11,11 @@ 'use strict'; | ||
var _asyncify2 = _interopRequireDefault(_asyncify); | ||
var asyncify = _interopRequireWildcard(_asyncify); | ||
var _retry = require('async/retry'); | ||
var _retry2 = _interopRequireDefault(_retry); | ||
var retry = _interopRequireWildcard(_retry); | ||
var _waterfall = require('async/waterfall'); | ||
var _waterfall2 = _interopRequireDefault(_waterfall); | ||
var waterfall = _interopRequireWildcard(_waterfall); | ||
@@ -40,6 +40,6 @@ var _crossFetch = require('cross-fetch'); | ||
function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { default: obj }; } | ||
function _interopRequireWildcard(obj) { if (obj && obj.__esModule) { return obj; } else { var newObj = {}; if (obj != null) { for (var key in obj) { if (Object.prototype.hasOwnProperty.call(obj, key)) newObj[key] = obj[key]; } } newObj.default = obj; return newObj; } } | ||
function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { default: obj }; } | ||
function _classCallCheck(instance, Constructor) { if (!(instance instanceof Constructor)) { throw new TypeError("Cannot call a class as a function"); } } | ||
@@ -92,3 +92,3 @@ | ||
} | ||
(0, _retry2.default)({ | ||
retry({ | ||
times: 5, | ||
@@ -119,3 +119,3 @@ interval: 1000, | ||
// continue parsing result | ||
(0, _waterfall2.default)([checkForHttpErrors, | ||
waterfall([checkForHttpErrors, | ||
// buffer body | ||
@@ -126,3 +126,3 @@ function (cb) { | ||
// parse body | ||
(0, _asyncify2.default)(function (rawBody) { | ||
asyncify(function (rawBody) { | ||
return JSON.parse(rawBody); | ||
@@ -129,0 +129,0 @@ }), parseResponse], done); |
@@ -11,3 +11,3 @@ 'use strict'; | ||
var _parallel2 = _interopRequireDefault(_parallel); | ||
var parallel = _interopRequireWildcard(_parallel); | ||
@@ -38,2 +38,4 @@ var _ethUtil = require('../util/eth-util'); | ||
function _interopRequireWildcard(obj) { if (obj && obj.__esModule) { return obj; } else { var newObj = {}; if (obj != null) { for (var key in obj) { if (Object.prototype.hasOwnProperty.call(obj, key)) newObj[key] = obj[key]; } } newObj.default = obj; return newObj; } } | ||
function _classCallCheck(instance, Constructor) { if (!(instance instanceof Constructor)) { throw new TypeError("Cannot call a class as a function"); } } | ||
@@ -82,3 +84,3 @@ | ||
}); | ||
(0, _parallel2.default)(updaters, function (err) { | ||
parallel(updaters, function (err) { | ||
// tslint:disable-next-line: no-console | ||
@@ -301,3 +303,3 @@ if (err) { | ||
}); | ||
(0, _parallel2.default)(updaters, cb); | ||
parallel(updaters, cb); | ||
} | ||
@@ -304,0 +306,0 @@ }, { |
@@ -11,3 +11,3 @@ 'use strict'; | ||
var _map2 = _interopRequireDefault(_map); | ||
var map = _interopRequireWildcard(_map); | ||
@@ -20,2 +20,4 @@ var _subprovider = require('./subprovider'); | ||
function _interopRequireWildcard(obj) { if (obj && obj.__esModule) { return obj; } else { var newObj = {}; if (obj != null) { for (var key in obj) { if (Object.prototype.hasOwnProperty.call(obj, key)) newObj[key] = obj[key]; } } newObj.default = obj; return newObj; } } | ||
function _classCallCheck(instance, Constructor) { if (!(instance instanceof Constructor)) { throw new TypeError("Cannot call a class as a function"); } } | ||
@@ -102,3 +104,3 @@ | ||
}; | ||
(0, _map2.default)(blockNumbers, getBlock, calcPrice); | ||
map(blockNumbers, getBlock, calcPrice); | ||
}); | ||
@@ -105,0 +107,0 @@ } |
@@ -1,3 +0,3 @@ | ||
import eachSeries from 'async/eachSeries'; | ||
import map from 'async/map'; | ||
import * as eachSeries from 'async/eachSeries'; | ||
import * as map from 'async/map'; | ||
import * as PollingBlockTracker from 'eth-block-tracker'; | ||
@@ -4,0 +4,0 @@ import { EventEmitter } from 'events'; |
@@ -1,4 +0,4 @@ | ||
import asyncify from 'async/asyncify'; | ||
import retry from 'async/retry'; | ||
import waterfall from 'async/waterfall'; | ||
import * as asyncify from 'async/asyncify'; | ||
import * as retry from 'async/retry'; | ||
import * as waterfall from 'async/waterfall'; | ||
import fetch from 'cross-fetch'; | ||
@@ -5,0 +5,0 @@ import * as JsonRpcError from 'json-rpc-error'; |
@@ -1,2 +0,2 @@ | ||
import parallel from 'async/parallel'; | ||
import * as parallel from 'async/parallel'; | ||
import { intToHex, stripHexPrefix } from '../util/eth-util'; | ||
@@ -3,0 +3,0 @@ import Stoplight from '../util/stoplight'; |
@@ -9,3 +9,3 @@ /* | ||
*/ | ||
import map from 'async/map'; | ||
import * as map from 'async/map'; | ||
import Subprovider from './subprovider'; | ||
@@ -12,0 +12,0 @@ export default class GaspriceProvider extends Subprovider { |
{ | ||
"name": "@bitski/provider-engine", | ||
"version": "0.2.0-beta.3", | ||
"version": "0.2.0-beta.4", | ||
"description": "", | ||
@@ -15,3 +15,3 @@ "repository": "https://github.com/BitskiCo/provider-engine", | ||
"dependencies": { | ||
"async": "^2.5.0", | ||
"async": "^3.0.0", | ||
"bn.js": "^4.11.8", | ||
@@ -18,0 +18,0 @@ "clone": "^2.0.0", |
@@ -1,3 +0,3 @@ | ||
import eachSeries from 'async/eachSeries'; | ||
import map from 'async/map'; | ||
import * as eachSeries from 'async/eachSeries'; | ||
import * as map from 'async/map'; | ||
import * as PollingBlockTracker from 'eth-block-tracker'; | ||
@@ -4,0 +4,0 @@ import { EventEmitter } from 'events'; |
@@ -1,4 +0,4 @@ | ||
import asyncify from 'async/asyncify'; | ||
import retry from 'async/retry'; | ||
import waterfall from 'async/waterfall'; | ||
import * as asyncify from 'async/asyncify'; | ||
import * as retry from 'async/retry'; | ||
import * as waterfall from 'async/waterfall'; | ||
import fetch from 'cross-fetch'; | ||
@@ -5,0 +5,0 @@ import * as JsonRpcError from 'json-rpc-error'; |
@@ -1,2 +0,2 @@ | ||
import parallel from 'async/parallel'; | ||
import * as parallel from 'async/parallel'; | ||
import { intToHex, stripHexPrefix } from '../util/eth-util'; | ||
@@ -3,0 +3,0 @@ import Stoplight from '../util/stoplight'; |
@@ -10,3 +10,3 @@ /* | ||
import map from 'async/map'; | ||
import * as map from 'async/map'; | ||
import Subprovider from './subprovider'; | ||
@@ -13,0 +13,0 @@ |
@@ -1,2 +0,2 @@ | ||
import asyncParallel = require('async/parallel'); | ||
import * as asyncParallel from 'async/parallel'; | ||
import test = require('tape'); | ||
@@ -3,0 +3,0 @@ import ProviderEngine from '../src/index'; |
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
687534
18576
+ Addedasync@3.2.6(transitive)
- Removedasync@2.6.4(transitive)
- Removedlodash@4.17.21(transitive)
Updatedasync@^3.0.0