Socket
Socket
Sign inDemoInstall

@bitski/provider-engine

Package Overview
Dependencies
Maintainers
3
Versions
29
Alerts
File Explorer

Advanced tools

License
Socket logo

Install Socket

Detect and block malicious and high-risk dependencies

Install

@bitski/provider-engine - npm Package Compare versions

Comparing version 0.6.0 to 0.6.1

dist/errors/block-tracker-error.d.ts
dist/errors/block-tracker-error.js
dist/errors/gas-price-error.d.ts
dist/errors/gas-price-error.js
dist/errors/provider-engine-error.d.ts
dist/errors/provider-engine-error.js
dist/errors/subscription-error.d.ts
dist/errors/subscription-error.js
src/errors/block-tracker-error.ts
src/errors/gas-price-error.ts
src/errors/provider-engine-error.ts
src/errors/subscription-error.ts

5

dist/base-provider.js

@@ -17,2 +17,3 @@ "use strict";

var events_1 = require("events");
var provider_engine_error_1 = require("./errors/provider-engine-error");
var create_payload_1 = require("./util/create-payload");

@@ -48,3 +49,3 @@ // The base class which ProviderEngine will extend from that provides the basic Web3 Provider interface

// Override this with subscription implementation
return Promise.reject(new Error('Subscriptions are not supported'));
return Promise.reject(new provider_engine_error_1.ProviderEngineError('Subscriptions are not supported', provider_engine_error_1.ProviderEngineErrorCode.UnsupportedFeature));
};

@@ -54,3 +55,3 @@ // Method to unsubscribe

// Override this with unsubscribe implementation
return Promise.reject(new Error('Subscriptions are not supported'));
return Promise.reject(new provider_engine_error_1.ProviderEngineError('Subscriptions are not supported', provider_engine_error_1.ProviderEngineErrorCode.UnsupportedFeature));
};

@@ -57,0 +58,0 @@ return BaseProvider;

4

dist/index.d.ts

@@ -6,2 +6,6 @@ import { JSONRPCRequest, JSONRPCResponse, JSONRPCResponseHandler } from './base-provider';

export { JSONRPCRequest, JSONRPCResponse, JSONRPCResponseHandler, Subprovider, NextHandler, CompletionHandler, SubproviderNextCallback, };
export { BlockTrackerError, BlockTrackerErrorCode } from './errors/block-tracker-error';
export { GasPriceError, GasPriceErrorCode } from './errors/gas-price-error';
export { ProviderEngineError, ProviderEngineErrorCode } from './errors/provider-engine-error';
export { SubscriptionError, SubscriptionErrorCode } from './errors/subscription-error';
export * from './subproviders/index';

13

dist/index.js

@@ -13,2 +13,15 @@ "use strict";

exports.default = provider_engine_1.default;
// Errors
var block_tracker_error_1 = require("./errors/block-tracker-error");
exports.BlockTrackerError = block_tracker_error_1.BlockTrackerError;
exports.BlockTrackerErrorCode = block_tracker_error_1.BlockTrackerErrorCode;
var gas_price_error_1 = require("./errors/gas-price-error");
exports.GasPriceError = gas_price_error_1.GasPriceError;
exports.GasPriceErrorCode = gas_price_error_1.GasPriceErrorCode;
var provider_engine_error_1 = require("./errors/provider-engine-error");
exports.ProviderEngineError = provider_engine_error_1.ProviderEngineError;
exports.ProviderEngineErrorCode = provider_engine_error_1.ProviderEngineErrorCode;
var subscription_error_1 = require("./errors/subscription-error");
exports.SubscriptionError = subscription_error_1.SubscriptionError;
exports.SubscriptionErrorCode = subscription_error_1.SubscriptionErrorCode;
__export(require("./subproviders/index"));

5

dist/provider-engine.js

@@ -21,2 +21,3 @@ "use strict";

var base_provider_1 = __importDefault(require("./base-provider"));
var provider_engine_error_1 = require("./errors/provider-engine-error");
var block_tracker_1 = __importDefault(require("./util/block-tracker"));

@@ -124,4 +125,4 @@ var stoplight_1 = __importDefault(require("./util/stoplight"));

// tslint:disable-next-line: max-line-length
var msg = "Request for method \"" + payload.method + "\" not handled by any subprovider. Please check your subprovider configuration to ensure this method is handled.";
end(new Error(msg));
var msg = "Request for method \"" + payload.method + "\" not handled by any subprovider.";
end(new provider_engine_error_1.ProviderEngineError(msg, provider_engine_error_1.ProviderEngineErrorCode.UnhandledRequest));
return;

@@ -128,0 +129,0 @@ }

3

dist/subproviders/gasprice.js

@@ -28,2 +28,3 @@ "use strict";

var map_1 = __importDefault(require("async/map"));
var gas_price_error_1 = require("../errors/gas-price-error");
var subprovider_1 = __importDefault(require("../subprovider"));

@@ -61,3 +62,3 @@ var GaspriceProvider = /** @class */ (function (_super) {

if (!blockRes.result) {
return cb(new Error("GaspriceProvider - No block for \"" + item + "\""));
return cb(gas_price_error_1.GasPriceError.BlockNotFound(item));
}

@@ -64,0 +65,0 @@ cb(null, blockRes.result.transactions);

3

dist/subproviders/provider.js

@@ -19,2 +19,3 @@ "use strict";

Object.defineProperty(exports, "__esModule", { value: true });
var json_rpc_error_1 = __importDefault(require("json-rpc-error"));
var subprovider_1 = __importDefault(require("../subprovider"));

@@ -35,3 +36,3 @@ // wraps a provider in a subprovider interface

if (response.error) {
return end(new Error(response.error.message));
return end(new json_rpc_error_1.default.InternalError(response.error));
}

@@ -38,0 +39,0 @@ end(null, response.result);

5

dist/subproviders/subscriptions.js

@@ -19,2 +19,3 @@ "use strict";

Object.defineProperty(exports, "__esModule", { value: true });
var subscription_error_1 = require("../errors/subscription-error");
var eth_util_1 = require("../util/eth-util");

@@ -76,3 +77,3 @@ var rpc_hex_encoding_1 = require("../util/rpc-hex-encoding");

default:
cb(new Error('unsupported subscription type'));
cb(subscription_error_1.SubscriptionError.UnsupportedType(subscriptionType));
return;

@@ -86,3 +87,3 @@ }

if (!this.subscriptions[id]) {
cb(new Error("Subscription ID " + hexId + " not found."));
cb(subscription_error_1.SubscriptionError.NotFound(hexId));
}

@@ -89,0 +90,0 @@ else {

3

dist/util/block-tracker.js

@@ -32,2 +32,3 @@ "use strict";

var events_1 = require("events");
var block_tracker_error_1 = require("../errors/block-tracker-error");
var create_payload_1 = require("./create-payload");

@@ -90,3 +91,3 @@ var eth_util_1 = require("./eth-util");

else {
throw new Error("Could not load block " + blockNumber + " after 3 tries");
throw block_tracker_error_1.BlockTrackerError.BlockNotFound(blockNumber);
}

@@ -93,0 +94,0 @@ }).catch(function (err) {

4

dist/util/eth-util.js

@@ -24,3 +24,3 @@ "use strict";

else {
throw new Error(
throw new TypeError(
// tslint:disable-next-line: max-line-length

@@ -44,3 +44,3 @@ "Cannot convert string to buffer. toBuffer only supports 0x-prefixed hex strings and this string was given: " + v);

else {
throw new Error('invalid type');
throw new TypeError("invalid type: " + v);
}

@@ -47,0 +47,0 @@ }

2

package.json
{
"name": "@bitski/provider-engine",
"version": "0.6.0",
"version": "0.6.1",
"description": "",

@@ -5,0 +5,0 @@ "repository": "https://github.com/BitskiCo/provider-engine",

9

src/base-provider.ts
import { EventEmitter } from 'events';
import { ProviderEngineError, ProviderEngineErrorCode } from './errors/provider-engine-error';
import { createPayload } from './util/create-payload';

@@ -51,3 +52,5 @@

// Override this with subscription implementation
return Promise.reject(new Error('Subscriptions are not supported'));
return Promise.reject(
new ProviderEngineError('Subscriptions are not supported', ProviderEngineErrorCode.UnsupportedFeature),
);
}

@@ -58,3 +61,5 @@

// Override this with unsubscribe implementation
return Promise.reject(new Error('Subscriptions are not supported'));
return Promise.reject(
new ProviderEngineError('Subscriptions are not supported', ProviderEngineErrorCode.UnsupportedFeature),
);
}

@@ -61,0 +66,0 @@

7

src/index.ts

@@ -17,2 +17,9 @@ import { JSONRPCRequest, JSONRPCResponse, JSONRPCResponseHandler } from './base-provider';

};
// Errors
export { BlockTrackerError, BlockTrackerErrorCode } from './errors/block-tracker-error';
export { GasPriceError, GasPriceErrorCode } from './errors/gas-price-error';
export { ProviderEngineError, ProviderEngineErrorCode } from './errors/provider-engine-error';
export { SubscriptionError, SubscriptionErrorCode } from './errors/subscription-error';
export * from './subproviders/index';

5

src/provider-engine.ts
import eachSeries from 'async/eachSeries';
import BaseProvider, { JSONRPCRequest, JSONRPCResponse, JSONRPCResponseHandler } from './base-provider';
import { ProviderEngineError, ProviderEngineErrorCode } from './errors/provider-engine-error';
import { default as Subprovider, SubproviderNextCallback } from './subprovider';

@@ -134,4 +135,4 @@ import BlockTracker, { BufferBlock } from './util/block-tracker';

// tslint:disable-next-line: max-line-length
const msg = `Request for method "${payload.method}" not handled by any subprovider. Please check your subprovider configuration to ensure this method is handled.`;
end(new Error(msg));
const msg = `Request for method "${payload.method}" not handled by any subprovider.`;
end(new ProviderEngineError(msg, ProviderEngineErrorCode.UnhandledRequest));
return;

@@ -138,0 +139,0 @@ }

3

src/subproviders/gasprice.ts

@@ -12,2 +12,3 @@ /*

import { JSONRPCRequest } from '../base-provider';
import { GasPriceError } from '../errors/gas-price-error';
import Subprovider, { CompletionHandler, NextHandler } from '../subprovider';

@@ -49,3 +50,3 @@

if (err) { return cb(err); }
if (!blockRes.result) { return cb(new Error(`GaspriceProvider - No block for "${item}"`)); }
if (!blockRes.result) { return cb(GasPriceError.BlockNotFound(item)); }
cb(null, blockRes.result.transactions);

@@ -52,0 +53,0 @@ });

3

src/subproviders/provider.ts

@@ -0,1 +1,2 @@

import JsonRpcError from 'json-rpc-error';
import { JSONRPCRequest } from '../base-provider';

@@ -21,3 +22,3 @@ import Subprovider, { CompletionHandler, NextHandler } from '../subprovider';

if (err) { return end(err); }
if (response.error) { return end(new Error(response.error.message)); }
if (response.error) { return end(new JsonRpcError.InternalError(response.error)); }
end(null, response.result);

@@ -24,0 +25,0 @@ });

5

src/subproviders/subscriptions.ts
import { JSONRPCRequest } from '../base-provider';
import { SubscriptionError } from '../errors/subscription-error';
import { CompletionHandler, NextHandler } from '../subprovider';

@@ -65,3 +66,3 @@ import { bufferToHex } from '../util/eth-util';

default:
cb(new Error('unsupported subscription type'));
cb(SubscriptionError.UnsupportedType(subscriptionType));
return;

@@ -75,3 +76,3 @@ }

if (!this.subscriptions[id]) {
cb(new Error(`Subscription ID ${hexId} not found.`));
cb(SubscriptionError.NotFound(hexId));
} else {

@@ -78,0 +79,0 @@ this.uninstallFilter(hexId, (err, result) => {

3

src/util/block-tracker.ts
import PollingBlockTracker from 'eth-block-tracker';
import { EventEmitter } from 'events';
import { JSONRPCResponse } from '../base-provider';
import { BlockTrackerError } from '../errors/block-tracker-error';
import { createPayload } from './create-payload';

@@ -132,3 +133,3 @@ import { toBuffer } from './eth-util';

} else {
throw new Error(`Could not load block ${blockNumber} after 3 tries`);
throw BlockTrackerError.BlockNotFound(blockNumber);
}

@@ -135,0 +136,0 @@ }).catch((err) => {

4

src/util/eth-util.ts

@@ -19,3 +19,3 @@ import BN from 'bn.js';

} else {
throw new Error(
throw new TypeError(
// tslint:disable-next-line: max-line-length

@@ -35,3 +35,3 @@ `Cannot convert string to buffer. toBuffer only supports 0x-prefixed hex strings and this string was given: ${v}`,

} else {
throw new Error('invalid type');
throw new TypeError(`invalid type: ${v}`);
}

@@ -38,0 +38,0 @@ }

SocketSocket SOC 2 Logo

Product

  • Package Alerts
  • Integrations
  • Docs
  • Pricing
  • FAQ
  • Roadmap
  • Changelog

About

Packages

npm

Go

Maven

PyPI

Rubygems

Stay in touch

Get open source security insights delivered straight into your inbox.

  • Terms
  • Privacy
  • Security

Made with ⚡️ by Socket Inc