ethers.js/packages/providers/lib/json-rpc-provider.js

670 lines
29 KiB
JavaScript
Raw Normal View History

2019-05-15 01:48:48 +03:00
"use strict";
var __extends = (this && this.__extends) || (function () {
var extendStatics = function (d, b) {
extendStatics = Object.setPrototypeOf ||
({ __proto__: [] } instanceof Array && function (d, b) { d.__proto__ = b; }) ||
2021-03-08 02:24:04 +03:00
function (d, b) { for (var p in b) if (Object.prototype.hasOwnProperty.call(b, p)) d[p] = b[p]; };
2019-05-15 01:48:48 +03:00
return extendStatics(d, b);
};
return function (d, b) {
2021-03-08 02:24:04 +03:00
if (typeof b !== "function" && b !== null)
throw new TypeError("Class extends value " + String(b) + " is not a constructor or null");
2019-05-15 01:48:48 +03:00
extendStatics(d, b);
function __() { this.constructor = d; }
d.prototype = b === null ? Object.create(b) : (__.prototype = b.prototype, new __());
};
})();
2019-11-20 12:57:38 +03:00
var __awaiter = (this && this.__awaiter) || function (thisArg, _arguments, P, generator) {
function adopt(value) { return value instanceof P ? value : new P(function (resolve) { resolve(value); }); }
return new (P || (P = Promise))(function (resolve, reject) {
function fulfilled(value) { try { step(generator.next(value)); } catch (e) { reject(e); } }
function rejected(value) { try { step(generator["throw"](value)); } catch (e) { reject(e); } }
function step(result) { result.done ? resolve(result.value) : adopt(result.value).then(fulfilled, rejected); }
step((generator = generator.apply(thisArg, _arguments || [])).next());
});
};
var __generator = (this && this.__generator) || function (thisArg, body) {
var _ = { label: 0, sent: function() { if (t[0] & 1) throw t[1]; return t[1]; }, trys: [], ops: [] }, f, y, t, g;
return g = { next: verb(0), "throw": verb(1), "return": verb(2) }, typeof Symbol === "function" && (g[Symbol.iterator] = function() { return this; }), g;
function verb(n) { return function (v) { return step([n, v]); }; }
function step(op) {
if (f) throw new TypeError("Generator is already executing.");
while (_) try {
if (f = 1, y && (t = op[0] & 2 ? y["return"] : op[0] ? y["throw"] || ((t = y["return"]) && t.call(y), 0) : y.next) && !(t = t.call(y, op[1])).done) return t;
if (y = 0, t) op = [op[0] & 2, t.value];
switch (op[0]) {
case 0: case 1: t = op; break;
case 4: _.label++; return { value: op[1], done: false };
case 5: _.label++; y = op[1]; op = [0]; continue;
case 7: op = _.ops.pop(); _.trys.pop(); continue;
default:
if (!(t = _.trys, t = t.length > 0 && t[t.length - 1]) && (op[0] === 6 || op[0] === 2)) { _ = 0; continue; }
if (op[0] === 3 && (!t || (op[1] > t[0] && op[1] < t[3]))) { _.label = op[1]; break; }
if (op[0] === 6 && _.label < t[1]) { _.label = t[1]; t = op; break; }
if (t && _.label < t[2]) { _.label = t[2]; _.ops.push(op); break; }
if (t[2]) _.ops.pop();
_.trys.pop(); continue;
}
op = body.call(thisArg, _);
} catch (e) { op = [6, e]; y = 0; } finally { f = t = 0; }
if (op[0] & 5) throw op[1]; return { value: op[0] ? op[1] : void 0, done: true };
}
};
2019-05-15 01:48:48 +03:00
Object.defineProperty(exports, "__esModule", { value: true });
2021-03-08 02:24:04 +03:00
exports.JsonRpcProvider = exports.JsonRpcSigner = void 0;
2019-05-15 01:48:48 +03:00
var abstract_signer_1 = require("@ethersproject/abstract-signer");
var bignumber_1 = require("@ethersproject/bignumber");
var bytes_1 = require("@ethersproject/bytes");
2020-10-19 06:19:16 +03:00
var hash_1 = require("@ethersproject/hash");
2019-05-15 01:48:48 +03:00
var properties_1 = require("@ethersproject/properties");
var strings_1 = require("@ethersproject/strings");
2021-03-30 22:22:45 +03:00
var transactions_1 = require("@ethersproject/transactions");
2019-05-15 01:48:48 +03:00
var web_1 = require("@ethersproject/web");
2019-08-02 09:10:58 +03:00
var logger_1 = require("@ethersproject/logger");
var _version_1 = require("./_version");
var logger = new logger_1.Logger(_version_1.version);
2019-05-15 01:48:48 +03:00
var base_provider_1 = require("./base-provider");
2020-09-16 10:08:36 +03:00
var errorGas = ["call", "estimateGas"];
function checkError(method, error, params) {
2020-11-23 06:44:33 +03:00
// Undo the "convenience" some nodes are attempting to prevent backwards
// incompatibility; maybe for v6 consider forwarding reverts as errors
if (method === "call" && error.code === logger_1.Logger.errors.SERVER_ERROR) {
var e = error.error;
if (e && e.message.match("reverted") && bytes_1.isHexString(e.data)) {
return e.data;
}
}
2020-09-11 09:10:58 +03:00
var message = error.message;
if (error.code === logger_1.Logger.errors.SERVER_ERROR && error.error && typeof (error.error.message) === "string") {
message = error.error.message;
}
2020-09-16 10:08:36 +03:00
else if (typeof (error.body) === "string") {
message = error.body;
}
2020-09-11 09:10:58 +03:00
else if (typeof (error.responseText) === "string") {
message = error.responseText;
}
2020-09-16 10:08:36 +03:00
message = (message || "").toLowerCase();
var transaction = params.transaction || params.signedTransaction;
// "insufficient funds for gas * price + value + cost(data)"
if (message.match(/insufficient funds/)) {
logger.throwError("insufficient funds for intrinsic transaction cost", logger_1.Logger.errors.INSUFFICIENT_FUNDS, {
error: error, method: method, transaction: transaction
});
}
// "nonce too low"
if (message.match(/nonce too low/)) {
logger.throwError("nonce has already been used", logger_1.Logger.errors.NONCE_EXPIRED, {
error: error, method: method, transaction: transaction
});
}
// "replacement transaction underpriced"
if (message.match(/replacement transaction underpriced/)) {
logger.throwError("replacement fee too low", logger_1.Logger.errors.REPLACEMENT_UNDERPRICED, {
error: error, method: method, transaction: transaction
});
}
2021-04-18 05:41:09 +03:00
// "replacement transaction underpriced"
if (message.match(/only replay-protected/)) {
logger.throwError("legacy pre-eip-155 transactions not supported", logger_1.Logger.errors.UNSUPPORTED_OPERATION, {
error: error, method: method, transaction: transaction
});
}
2020-09-16 10:08:36 +03:00
if (errorGas.indexOf(method) >= 0 && message.match(/gas required exceeds allowance|always failing transaction|execution reverted/)) {
logger.throwError("cannot estimate gas; transaction may fail or may require manual gas limit", logger_1.Logger.errors.UNPREDICTABLE_GAS_LIMIT, {
error: error, method: method, transaction: transaction
});
}
throw error;
2020-09-11 09:10:58 +03:00
}
2019-05-15 01:48:48 +03:00
function timer(timeout) {
return new Promise(function (resolve) {
2020-05-04 00:53:58 +03:00
setTimeout(resolve, timeout);
2019-05-15 01:48:48 +03:00
});
}
function getResult(payload) {
if (payload.error) {
// @TODO: not any
var error = new Error(payload.error.message);
error.code = payload.error.code;
error.data = payload.error.data;
throw error;
}
return payload.result;
}
function getLowerCase(value) {
if (value) {
return value.toLowerCase();
}
return value;
}
var _constructorGuard = {};
var JsonRpcSigner = /** @class */ (function (_super) {
__extends(JsonRpcSigner, _super);
function JsonRpcSigner(constructorGuard, provider, addressOrIndex) {
var _newTarget = this.constructor;
var _this = this;
2019-08-02 09:10:58 +03:00
logger.checkNew(_newTarget, JsonRpcSigner);
2019-05-15 01:48:48 +03:00
_this = _super.call(this) || this;
if (constructorGuard !== _constructorGuard) {
throw new Error("do not call the JsonRpcSigner constructor directly; use provider.getSigner");
}
properties_1.defineReadOnly(_this, "provider", provider);
if (addressOrIndex == null) {
addressOrIndex = 0;
}
2019-06-01 21:19:43 +03:00
if (typeof (addressOrIndex) === "string") {
properties_1.defineReadOnly(_this, "_address", _this.provider.formatter.address(addressOrIndex));
properties_1.defineReadOnly(_this, "_index", null);
}
else if (typeof (addressOrIndex) === "number") {
properties_1.defineReadOnly(_this, "_index", addressOrIndex);
properties_1.defineReadOnly(_this, "_address", null);
}
else {
2019-08-02 09:10:58 +03:00
logger.throwArgumentError("invalid address or index", "addressOrIndex", addressOrIndex);
2019-05-15 01:48:48 +03:00
}
return _this;
}
JsonRpcSigner.prototype.connect = function (provider) {
2019-08-02 09:10:58 +03:00
return logger.throwError("cannot alter JSON-RPC Signer connection", logger_1.Logger.errors.UNSUPPORTED_OPERATION, {
2019-05-15 01:48:48 +03:00
operation: "connect"
});
};
JsonRpcSigner.prototype.connectUnchecked = function () {
return new UncheckedJsonRpcSigner(_constructorGuard, this.provider, this._address || this._index);
};
JsonRpcSigner.prototype.getAddress = function () {
var _this = this;
if (this._address) {
return Promise.resolve(this._address);
}
return this.provider.send("eth_accounts", []).then(function (accounts) {
if (accounts.length <= _this._index) {
2019-08-02 09:10:58 +03:00
logger.throwError("unknown account #" + _this._index, logger_1.Logger.errors.UNSUPPORTED_OPERATION, {
operation: "getAddress"
});
2019-05-15 01:48:48 +03:00
}
return _this.provider.formatter.address(accounts[_this._index]);
});
};
JsonRpcSigner.prototype.sendUncheckedTransaction = function (transaction) {
var _this = this;
transaction = properties_1.shallowCopy(transaction);
var fromAddress = this.getAddress().then(function (address) {
if (address) {
address = address.toLowerCase();
}
return address;
});
// The JSON-RPC for eth_sendTransaction uses 90000 gas; if the user
// wishes to use this, it is easy to specify explicitly, otherwise
// we look it up for them.
if (transaction.gasLimit == null) {
var estimate = properties_1.shallowCopy(transaction);
estimate.from = fromAddress;
transaction.gasLimit = this.provider.estimateGas(estimate);
}
2020-06-03 10:47:17 +03:00
return properties_1.resolveProperties({
tx: properties_1.resolveProperties(transaction),
sender: fromAddress
}).then(function (_a) {
var tx = _a.tx, sender = _a.sender;
if (tx.from != null) {
if (tx.from.toLowerCase() !== sender) {
logger.throwArgumentError("from address mismatch", "transaction", transaction);
}
}
else {
tx.from = sender;
}
var hexTx = _this.provider.constructor.hexlifyTransaction(tx, { from: true });
2019-05-15 01:48:48 +03:00
return _this.provider.send("eth_sendTransaction", [hexTx]).then(function (hash) {
return hash;
}, function (error) {
2020-09-16 10:08:36 +03:00
return checkError("sendTransaction", error, hexTx);
2019-05-15 01:48:48 +03:00
});
});
};
JsonRpcSigner.prototype.signTransaction = function (transaction) {
2019-08-02 09:10:58 +03:00
return logger.throwError("signing transactions is unsupported", logger_1.Logger.errors.UNSUPPORTED_OPERATION, {
2019-05-15 01:48:48 +03:00
operation: "signTransaction"
});
};
JsonRpcSigner.prototype.sendTransaction = function (transaction) {
var _this = this;
return this.sendUncheckedTransaction(transaction).then(function (hash) {
return web_1.poll(function () {
return _this.provider.getTransaction(hash).then(function (tx) {
if (tx === null) {
return undefined;
}
return _this.provider._wrapTransaction(tx, hash);
});
}, { onceBlock: _this.provider }).catch(function (error) {
error.transactionHash = hash;
throw error;
});
});
};
JsonRpcSigner.prototype.signMessage = function (message) {
2020-10-19 06:19:16 +03:00
return __awaiter(this, void 0, void 0, function () {
var data, address;
return __generator(this, function (_a) {
switch (_a.label) {
case 0:
data = ((typeof (message) === "string") ? strings_1.toUtf8Bytes(message) : message);
return [4 /*yield*/, this.getAddress()];
case 1:
address = _a.sent();
return [4 /*yield*/, this.provider.send("eth_sign", [address.toLowerCase(), bytes_1.hexlify(data)])];
case 2:
// https://github.com/ethereum/wiki/wiki/JSON-RPC#eth_sign
return [2 /*return*/, _a.sent()];
}
});
});
};
JsonRpcSigner.prototype._signTypedData = function (domain, types, value) {
return __awaiter(this, void 0, void 0, function () {
2020-10-19 08:27:15 +03:00
var populated, address;
2020-10-19 06:19:16 +03:00
var _this = this;
return __generator(this, function (_a) {
switch (_a.label) {
case 0: return [4 /*yield*/, hash_1._TypedDataEncoder.resolveNames(domain, types, value, function (name) {
return _this.provider.resolveName(name);
})];
case 1:
populated = _a.sent();
2020-10-19 08:27:15 +03:00
return [4 /*yield*/, this.getAddress()];
case 2:
address = _a.sent();
2020-10-19 06:19:16 +03:00
return [4 /*yield*/, this.provider.send("eth_signTypedData_v4", [
2020-10-19 08:27:15 +03:00
address.toLowerCase(),
JSON.stringify(hash_1._TypedDataEncoder.getPayload(populated.domain, types, populated.value))
2020-10-19 06:19:16 +03:00
])];
2020-10-19 08:27:15 +03:00
case 3: return [2 /*return*/, _a.sent()];
2020-10-19 06:19:16 +03:00
}
});
2019-05-15 01:48:48 +03:00
});
};
JsonRpcSigner.prototype.unlock = function (password) {
2020-10-19 08:27:15 +03:00
return __awaiter(this, void 0, void 0, function () {
var provider, address;
return __generator(this, function (_a) {
switch (_a.label) {
case 0:
provider = this.provider;
return [4 /*yield*/, this.getAddress()];
case 1:
address = _a.sent();
return [2 /*return*/, provider.send("personal_unlockAccount", [address.toLowerCase(), password, null])];
}
});
2019-05-15 01:48:48 +03:00
});
};
return JsonRpcSigner;
}(abstract_signer_1.Signer));
exports.JsonRpcSigner = JsonRpcSigner;
var UncheckedJsonRpcSigner = /** @class */ (function (_super) {
__extends(UncheckedJsonRpcSigner, _super);
function UncheckedJsonRpcSigner() {
return _super !== null && _super.apply(this, arguments) || this;
}
UncheckedJsonRpcSigner.prototype.sendTransaction = function (transaction) {
var _this = this;
return this.sendUncheckedTransaction(transaction).then(function (hash) {
return {
hash: hash,
nonce: null,
gasLimit: null,
gasPrice: null,
data: null,
value: null,
chainId: null,
confirmations: 0,
from: null,
wait: function (confirmations) { return _this.provider.waitForTransaction(hash, confirmations); }
};
});
};
return UncheckedJsonRpcSigner;
}(JsonRpcSigner));
var allowedTransactionKeys = {
2021-03-30 22:22:45 +03:00
chainId: true, data: true, gasLimit: true, gasPrice: true, nonce: true, to: true, value: true,
type: true, accessList: true
2019-05-15 01:48:48 +03:00
};
var JsonRpcProvider = /** @class */ (function (_super) {
__extends(JsonRpcProvider, _super);
function JsonRpcProvider(url, network) {
var _newTarget = this.constructor;
var _this = this;
2019-08-02 09:10:58 +03:00
logger.checkNew(_newTarget, JsonRpcProvider);
var networkOrReady = network;
// The network is unknown, query the JSON-RPC for it
if (networkOrReady == null) {
networkOrReady = new Promise(function (resolve, reject) {
setTimeout(function () {
_this.detectNetwork().then(function (network) {
resolve(network);
}, function (error) {
reject(error);
});
}, 0);
});
2019-05-15 01:48:48 +03:00
}
_this = _super.call(this, networkOrReady) || this;
2019-05-15 01:48:48 +03:00
// Default URL
if (!url) {
2020-03-12 21:14:50 +03:00
url = properties_1.getStatic(_this.constructor, "defaultUrl")();
2019-05-15 01:48:48 +03:00
}
if (typeof (url) === "string") {
properties_1.defineReadOnly(_this, "connection", Object.freeze({
2019-05-15 01:48:48 +03:00
url: url
}));
2019-05-15 01:48:48 +03:00
}
else {
properties_1.defineReadOnly(_this, "connection", Object.freeze(properties_1.shallowCopy(url)));
2019-05-15 01:48:48 +03:00
}
2019-05-25 01:15:42 +03:00
_this._nextId = 42;
2019-05-15 01:48:48 +03:00
return _this;
}
2021-04-20 04:30:28 +03:00
Object.defineProperty(JsonRpcProvider.prototype, "_cache", {
get: function () {
if (this._eventLoopCache == null) {
this._eventLoopCache = {};
}
return this._eventLoopCache;
},
enumerable: false,
configurable: true
});
2020-03-12 21:14:50 +03:00
JsonRpcProvider.defaultUrl = function () {
2020-04-27 13:31:43 +03:00
return "http:/\/localhost:8545";
2020-03-12 21:14:50 +03:00
};
2020-05-04 00:53:58 +03:00
JsonRpcProvider.prototype.detectNetwork = function () {
2021-04-18 05:41:09 +03:00
var _this = this;
2021-04-20 04:30:28 +03:00
if (!this._cache["detectNetwork"]) {
this._cache["detectNetwork"] = this._uncachedDetectNetwork();
2021-04-18 05:41:09 +03:00
// Clear this cache at the beginning of the next event loop
setTimeout(function () {
2021-04-20 04:30:28 +03:00
_this._cache["detectNetwork"] = null;
2021-04-18 05:41:09 +03:00
}, 0);
}
2021-04-20 04:30:28 +03:00
return this._cache["detectNetwork"];
2021-04-18 05:41:09 +03:00
};
JsonRpcProvider.prototype._uncachedDetectNetwork = function () {
2020-05-04 00:53:58 +03:00
return __awaiter(this, void 0, void 0, function () {
var chainId, error_1, error_2, getNetwork;
return __generator(this, function (_a) {
switch (_a.label) {
case 0: return [4 /*yield*/, timer(0)];
case 1:
_a.sent();
chainId = null;
_a.label = 2;
case 2:
_a.trys.push([2, 4, , 9]);
return [4 /*yield*/, this.send("eth_chainId", [])];
case 3:
chainId = _a.sent();
return [3 /*break*/, 9];
case 4:
error_1 = _a.sent();
_a.label = 5;
case 5:
_a.trys.push([5, 7, , 8]);
return [4 /*yield*/, this.send("net_version", [])];
case 6:
chainId = _a.sent();
return [3 /*break*/, 8];
case 7:
error_2 = _a.sent();
return [3 /*break*/, 8];
case 8: return [3 /*break*/, 9];
case 9:
if (chainId != null) {
getNetwork = properties_1.getStatic(this.constructor, "getNetwork");
try {
return [2 /*return*/, getNetwork(bignumber_1.BigNumber.from(chainId).toNumber())];
}
catch (error) {
return [2 /*return*/, logger.throwError("could not detect network", logger_1.Logger.errors.NETWORK_ERROR, {
chainId: chainId,
2020-06-14 04:39:36 +03:00
event: "invalidNetwork",
2020-05-04 00:53:58 +03:00
serverError: error
})];
}
}
2020-06-14 04:39:36 +03:00
return [2 /*return*/, logger.throwError("could not detect network", logger_1.Logger.errors.NETWORK_ERROR, {
event: "noNetwork"
})];
2020-05-04 00:53:58 +03:00
}
});
});
};
2019-05-15 01:48:48 +03:00
JsonRpcProvider.prototype.getSigner = function (addressOrIndex) {
return new JsonRpcSigner(_constructorGuard, this, addressOrIndex);
};
JsonRpcProvider.prototype.getUncheckedSigner = function (addressOrIndex) {
return this.getSigner(addressOrIndex).connectUnchecked();
};
JsonRpcProvider.prototype.listAccounts = function () {
var _this = this;
return this.send("eth_accounts", []).then(function (accounts) {
return accounts.map(function (a) { return _this.formatter.address(a); });
});
};
JsonRpcProvider.prototype.send = function (method, params) {
var _this = this;
var request = {
method: method,
params: params,
2019-05-25 01:15:42 +03:00
id: (this._nextId++),
2019-05-15 01:48:48 +03:00
jsonrpc: "2.0"
};
2019-08-02 09:10:58 +03:00
this.emit("debug", {
action: "request",
request: properties_1.deepCopy(request),
provider: this
});
2021-04-18 05:41:09 +03:00
// We can expand this in the future to any call, but for now these
// are the biggest wins and do not require any serializing parameters.
var cache = (["eth_chainId", "eth_blockNumber"].indexOf(method) >= 0);
2021-04-20 04:30:28 +03:00
if (cache && this._cache[method]) {
return this._cache[method];
2021-04-18 05:41:09 +03:00
}
var result = web_1.fetchJson(this.connection, JSON.stringify(request), getResult).then(function (result) {
2019-05-15 01:48:48 +03:00
_this.emit("debug", {
2019-08-02 09:10:58 +03:00
action: "response",
2019-05-15 01:48:48 +03:00
request: request,
response: result,
provider: _this
});
return result;
2020-02-26 13:06:48 +03:00
}, function (error) {
_this.emit("debug", {
action: "response",
error: error,
request: request,
provider: _this
});
throw error;
2019-05-15 01:48:48 +03:00
});
2021-04-18 05:41:09 +03:00
// Cache the fetch, but clear it on the next event loop
if (cache) {
2021-04-20 04:30:28 +03:00
this._cache[method] = result;
2021-04-18 05:41:09 +03:00
setTimeout(function () {
2021-04-20 04:30:28 +03:00
_this._cache[method] = null;
2021-04-18 05:41:09 +03:00
}, 0);
}
return result;
2019-05-15 01:48:48 +03:00
};
2020-03-21 19:48:22 +03:00
JsonRpcProvider.prototype.prepareRequest = function (method, params) {
2019-05-15 01:48:48 +03:00
switch (method) {
case "getBlockNumber":
2020-03-21 19:48:22 +03:00
return ["eth_blockNumber", []];
2019-05-15 01:48:48 +03:00
case "getGasPrice":
2020-03-21 19:48:22 +03:00
return ["eth_gasPrice", []];
2019-05-15 01:48:48 +03:00
case "getBalance":
2020-03-21 19:48:22 +03:00
return ["eth_getBalance", [getLowerCase(params.address), params.blockTag]];
2019-05-15 01:48:48 +03:00
case "getTransactionCount":
2020-03-21 19:48:22 +03:00
return ["eth_getTransactionCount", [getLowerCase(params.address), params.blockTag]];
2019-05-15 01:48:48 +03:00
case "getCode":
2020-03-21 19:48:22 +03:00
return ["eth_getCode", [getLowerCase(params.address), params.blockTag]];
2019-05-15 01:48:48 +03:00
case "getStorageAt":
2020-03-21 19:48:22 +03:00
return ["eth_getStorageAt", [getLowerCase(params.address), params.position, params.blockTag]];
2019-05-15 01:48:48 +03:00
case "sendTransaction":
2020-03-21 19:48:22 +03:00
return ["eth_sendRawTransaction", [params.signedTransaction]];
2019-05-15 01:48:48 +03:00
case "getBlock":
if (params.blockTag) {
2020-03-21 19:48:22 +03:00
return ["eth_getBlockByNumber", [params.blockTag, !!params.includeTransactions]];
2019-05-15 01:48:48 +03:00
}
else if (params.blockHash) {
2020-03-21 19:48:22 +03:00
return ["eth_getBlockByHash", [params.blockHash, !!params.includeTransactions]];
2019-05-15 01:48:48 +03:00
}
2020-03-21 19:48:22 +03:00
return null;
2019-05-15 01:48:48 +03:00
case "getTransaction":
2020-03-21 19:48:22 +03:00
return ["eth_getTransactionByHash", [params.transactionHash]];
2019-05-15 01:48:48 +03:00
case "getTransactionReceipt":
2020-03-21 19:48:22 +03:00
return ["eth_getTransactionReceipt", [params.transactionHash]];
2019-11-20 12:57:38 +03:00
case "call": {
var hexlifyTransaction = properties_1.getStatic(this.constructor, "hexlifyTransaction");
2020-03-21 19:48:22 +03:00
return ["eth_call", [hexlifyTransaction(params.transaction, { from: true }), params.blockTag]];
2019-11-20 12:57:38 +03:00
}
case "estimateGas": {
var hexlifyTransaction = properties_1.getStatic(this.constructor, "hexlifyTransaction");
2020-03-21 19:48:22 +03:00
return ["eth_estimateGas", [hexlifyTransaction(params.transaction, { from: true })]];
2019-11-20 12:57:38 +03:00
}
2019-05-15 01:48:48 +03:00
case "getLogs":
if (params.filter && params.filter.address != null) {
params.filter.address = getLowerCase(params.filter.address);
}
2020-03-21 19:48:22 +03:00
return ["eth_getLogs", [params.filter]];
2019-05-15 01:48:48 +03:00
default:
break;
}
2020-03-21 19:48:22 +03:00
return null;
};
JsonRpcProvider.prototype.perform = function (method, params) {
2020-09-11 09:10:58 +03:00
return __awaiter(this, void 0, void 0, function () {
2020-09-16 10:08:36 +03:00
var args, error_3;
2020-09-11 09:10:58 +03:00
return __generator(this, function (_a) {
switch (_a.label) {
case 0:
args = this.prepareRequest(method, params);
if (args == null) {
logger.throwError(method + " not implemented", logger_1.Logger.errors.NOT_IMPLEMENTED, { operation: method });
}
_a.label = 1;
case 1:
_a.trys.push([1, 3, , 4]);
return [4 /*yield*/, this.send(args[0], args[1])];
case 2: return [2 /*return*/, _a.sent()];
case 3:
error_3 = _a.sent();
2020-09-16 10:08:36 +03:00
return [2 /*return*/, checkError(method, error_3, params)];
case 4: return [2 /*return*/];
2020-03-21 19:48:22 +03:00
}
});
2020-09-11 09:10:58 +03:00
});
2019-05-15 01:48:48 +03:00
};
2020-03-12 21:14:50 +03:00
JsonRpcProvider.prototype._startEvent = function (event) {
if (event.tag === "pending") {
this._startPending();
}
_super.prototype._startEvent.call(this, event);
};
2019-05-15 01:48:48 +03:00
JsonRpcProvider.prototype._startPending = function () {
if (this._pendingFilter != null) {
return;
}
var self = this;
var pendingFilter = this.send("eth_newPendingTransactionFilter", []);
this._pendingFilter = pendingFilter;
pendingFilter.then(function (filterId) {
function poll() {
self.send("eth_getFilterChanges", [filterId]).then(function (hashes) {
if (self._pendingFilter != pendingFilter) {
return null;
}
var seq = Promise.resolve();
hashes.forEach(function (hash) {
// @TODO: This should be garbage collected at some point... How? When?
self._emitted["t:" + hash.toLowerCase()] = "pending";
seq = seq.then(function () {
return self.getTransaction(hash).then(function (tx) {
self.emit("pending", tx);
return null;
});
});
});
return seq.then(function () {
return timer(1000);
});
}).then(function () {
if (self._pendingFilter != pendingFilter) {
self.send("eth_uninstallFilter", [filterId]);
return;
}
setTimeout(function () { poll(); }, 0);
return null;
}).catch(function (error) { });
}
poll();
return filterId;
}).catch(function (error) { });
};
2020-03-12 21:14:50 +03:00
JsonRpcProvider.prototype._stopEvent = function (event) {
if (event.tag === "pending" && this.listenerCount("pending") === 0) {
this._pendingFilter = null;
}
_super.prototype._stopEvent.call(this, event);
2019-05-15 01:48:48 +03:00
};
// Convert an ethers.js transaction into a JSON-RPC transaction
// - gasLimit => gas
// - All values hexlified
// - All numeric values zero-striped
2020-03-21 19:48:22 +03:00
// - All addresses are lowercased
2019-05-15 01:48:48 +03:00
// NOTE: This allows a TransactionRequest, but all values should be resolved
// before this is called
2020-03-21 19:48:22 +03:00
// @TODO: This will likely be removed in future versions and prepareRequest
// will be the preferred method for this.
2019-05-15 01:48:48 +03:00
JsonRpcProvider.hexlifyTransaction = function (transaction, allowExtra) {
// Check only allowed properties are given
var allowed = properties_1.shallowCopy(allowedTransactionKeys);
if (allowExtra) {
for (var key in allowExtra) {
if (allowExtra[key]) {
allowed[key] = true;
}
}
}
properties_1.checkProperties(transaction, allowed);
var result = {};
// Some nodes (INFURA ropsten; INFURA mainnet is fine) do not like leading zeros.
2021-03-30 22:22:45 +03:00
["gasLimit", "gasPrice", "type", "nonce", "value"].forEach(function (key) {
2019-05-15 01:48:48 +03:00
if (transaction[key] == null) {
return;
}
var value = bytes_1.hexValue(transaction[key]);
if (key === "gasLimit") {
key = "gas";
}
result[key] = value;
});
["from", "to", "data"].forEach(function (key) {
if (transaction[key] == null) {
return;
}
result[key] = bytes_1.hexlify(transaction[key]);
});
2021-03-30 22:22:45 +03:00
if (transaction.accessList) {
result["accessList"] = transactions_1.accessListify(transaction.accessList);
}
2019-05-15 01:48:48 +03:00
return result;
};
return JsonRpcProvider;
}(base_provider_1.BaseProvider));
exports.JsonRpcProvider = JsonRpcProvider;
2020-07-13 15:03:56 +03:00
//# sourceMappingURL=json-rpc-provider.js.map