"use strict"; Object.defineProperty(exports, "__esModule", { value: true }); exports.FallbackProvider = void 0; /** * Explain all the nitty-gritty about the **FallbackProvider**. * * @_section: api/providers/fallback-provider:Fallback Provider [about-fallback-provider] */ const index_js_1 = require("../utils/index.js"); const abstract_provider_js_1 = require("./abstract-provider.js"); const network_js_1 = require("./network.js"); const BN_1 = BigInt("1"); const BN_2 = BigInt("2"); function shuffle(array) { for (let i = array.length - 1; i > 0; i--) { const j = Math.floor(Math.random() * (i + 1)); const tmp = array[i]; array[i] = array[j]; array[j] = tmp; } } function stall(duration) { return new Promise((resolve) => { setTimeout(resolve, duration); }); } function getTime() { return (new Date()).getTime(); } function stringify(value) { return JSON.stringify(value, (key, value) => { if (typeof (value) === "bigint") { return { type: "bigint", value: value.toString() }; } return value; }); } ; const defaultConfig = { stallTimeout: 400, priority: 1, weight: 1 }; const defaultState = { blockNumber: -2, requests: 0, lateResponses: 0, errorResponses: 0, outOfSync: -1, unsupportedEvents: 0, rollingDuration: 0, score: 0, _network: null, _updateNumber: null, _totalTime: 0 }; async function waitForSync(config, blockNumber) { while (config.blockNumber < 0 || config.blockNumber < blockNumber) { if (!config._updateNumber) { config._updateNumber = (async () => { const blockNumber = await config.provider.getBlockNumber(); if (blockNumber > config.blockNumber) { config.blockNumber = blockNumber; } config._updateNumber = null; })(); } await config._updateNumber; config.outOfSync++; } } function _normalize(value) { if (value == null) { return "null"; } if (Array.isArray(value)) { return "[" + (value.map(_normalize)).join(",") + "]"; } if (typeof (value) === "object" && typeof (value.toJSON) === "function") { return _normalize(value.toJSON()); } switch (typeof (value)) { case "boolean": case "symbol": return value.toString(); case "bigint": case "number": return BigInt(value).toString(); case "string": return JSON.stringify(value); case "object": { const keys = Object.keys(value); keys.sort(); return "{" + keys.map((k) => `${JSON.stringify(k)}:${_normalize(value[k])}`).join(",") + "}"; } } console.log("Could not serialize", value); throw new Error("Hmm..."); } function normalizeResult(value) { if ("error" in value) { const error = value.error; return { tag: _normalize(error), value: error }; } const result = value.result; return { tag: _normalize(result), value: result }; } // This strategy picks the highest weight result, as long as the weight is // equal to or greater than quorum function checkQuorum(quorum, results) { const tally = new Map(); for (const { value, tag, weight } of results) { const t = tally.get(tag) || { value, weight: 0 }; t.weight += weight; tally.set(tag, t); } let best = null; for (const r of tally.values()) { if (r.weight >= quorum && (!best || r.weight > best.weight)) { best = r; } } if (best) { return best.value; } return undefined; } function getMedian(quorum, results) { let resultWeight = 0; const errorMap = new Map(); let bestError = null; const values = []; for (const { value, tag, weight } of results) { if (value instanceof Error) { const e = errorMap.get(tag) || { value, weight: 0 }; e.weight += weight; errorMap.set(tag, e); if (bestError == null || e.weight > bestError.weight) { bestError = e; } } else { values.push(BigInt(value)); resultWeight += weight; } } if (resultWeight < quorum) { // We have quorum for an error if (bestError && bestError.weight >= quorum) { return bestError.value; } // We do not have quorum for a result return undefined; } // Get the sorted values values.sort((a, b) => ((a < b) ? -1 : (b > a) ? 1 : 0)); const mid = values.length / 2; // Odd-length; take the middle value if (values.length % 2) { return values[mid]; } // Even length; take the ceiling of the mean of the center two values return (values[mid - 1] + values[mid] + BN_1) / BN_2; } function getAnyResult(quorum, results) { // If any value or error meets quorum, that is our preferred result const result = checkQuorum(quorum, results); if (result !== undefined) { return result; } // Otherwise, do we have any result? for (const r of results) { if (r.value) { return r.value; } } // Nope! return undefined; } function getFuzzyMode(quorum, results) { if (quorum === 1) { return (0, index_js_1.getNumber)(getMedian(quorum, results), "%internal"); } const tally = new Map(); const add = (result, weight) => { const t = tally.get(result) || { result, weight: 0 }; t.weight += weight; tally.set(result, t); }; for (const { weight, value } of results) { const r = (0, index_js_1.getNumber)(value); add(r - 1, weight); add(r, weight); add(r + 1, weight); } let bestWeight = 0; let bestResult = undefined; for (const { weight, result } of tally.values()) { // Use this result, if this result meets quorum and has either: // - a better weight // - or equal weight, but the result is larger if (weight >= quorum && (weight > bestWeight || (bestResult != null && weight === bestWeight && result > bestResult))) { bestWeight = weight; bestResult = result; } } return bestResult; } /** * A Fallback Provider. * */ class FallbackProvider extends abstract_provider_js_1.AbstractProvider { quorum; eventQuorum; eventWorkers; #configs; #height; #initialSyncPromise; constructor(providers, network) { super(network); this.#configs = providers.map((p) => { if (p instanceof abstract_provider_js_1.AbstractProvider) { return Object.assign({ provider: p }, defaultConfig, defaultState); } else { return Object.assign({}, defaultConfig, p, defaultState); } }); this.#height = -2; this.#initialSyncPromise = null; this.quorum = 2; //Math.ceil(providers.length / 2); this.eventQuorum = 1; this.eventWorkers = 1; (0, index_js_1.assertArgument)(this.quorum <= this.#configs.reduce((a, c) => (a + c.weight), 0), "quorum exceed provider wieght", "quorum", this.quorum); } get providerConfigs() { return this.#configs.map((c) => { const result = Object.assign({}, c); for (const key in result) { if (key[0] === "_") { delete result[key]; } } return result; }); } async _detectNetwork() { return network_js_1.Network.from((0, index_js_1.getBigInt)(await this._perform({ method: "chainId" }))); } // @TODO: Add support to select providers to be the event subscriber //_getSubscriber(sub: Subscription): Subscriber { // throw new Error("@TODO"); //} async _translatePerform(provider, req) { switch (req.method) { case "broadcastTransaction": return await provider.broadcastTransaction(req.signedTransaction); case "call": return await provider.call(Object.assign({}, req.transaction, { blockTag: req.blockTag })); case "chainId": return (await provider.getNetwork()).chainId; case "estimateGas": return await provider.estimateGas(req.transaction); case "getBalance": return await provider.getBalance(req.address, req.blockTag); case "getBlock": { const block = ("blockHash" in req) ? req.blockHash : req.blockTag; return await provider.getBlock(block, req.includeTransactions); } case "getBlockNumber": return await provider.getBlockNumber(); case "getCode": return await provider.getCode(req.address, req.blockTag); case "getGasPrice": return (await provider.getFeeData()).gasPrice; case "getLogs": return await provider.getLogs(req.filter); case "getStorage": return await provider.getStorage(req.address, req.position, req.blockTag); case "getTransaction": return await provider.getTransaction(req.hash); case "getTransactionCount": return await provider.getTransactionCount(req.address, req.blockTag); case "getTransactionReceipt": return await provider.getTransactionReceipt(req.hash); case "getTransactionResult": return await provider.getTransactionResult(req.hash); } } // Grab the next (random) config that is not already part of // the running set #getNextConfig(running) { // @TODO: Maybe do a check here to favour (heavily) providers that // do not require waitForSync and disfavour providers that // seem down-ish or are behaving slowly const configs = Array.from(running).map((r) => r.config); // Shuffle the states, sorted by priority const allConfigs = this.#configs.slice(); shuffle(allConfigs); allConfigs.sort((a, b) => (b.priority - a.priority)); for (const config of allConfigs) { if (configs.indexOf(config) === -1) { return config; } } return null; } // Adds a new runner (if available) to running. #addRunner(running, req) { const config = this.#getNextConfig(running); // No runners available if (config == null) { return null; } // Create a new runner const runner = { config, result: null, didBump: false, perform: null, staller: null }; const now = getTime(); // Start performing this operation runner.perform = (async () => { try { config.requests++; const result = await this._translatePerform(config.provider, req); runner.result = { result }; } catch (error) { config.errorResponses++; runner.result = { error }; } const dt = (getTime() - now); config._totalTime += dt; config.rollingDuration = 0.95 * config.rollingDuration + 0.05 * dt; runner.perform = null; })(); // Start a staller; when this times out, it's time to force // kicking off another runner because we are taking too long runner.staller = (async () => { await stall(config.stallTimeout); runner.staller = null; })(); running.add(runner); return runner; } // Initializes the blockNumber and network for each runner and // blocks until initialized async #initialSync() { let initialSync = this.#initialSyncPromise; if (!initialSync) { const promises = []; this.#configs.forEach((config) => { promises.push(waitForSync(config, 0)); promises.push((async () => { config._network = await config.provider.getNetwork(); })()); }); this.#initialSyncPromise = initialSync = (async () => { // Wait for all providers to have a block number and network await Promise.all(promises); // Check all the networks match let chainId = null; for (const config of this.#configs) { const network = (config._network); if (chainId == null) { chainId = network.chainId; } else if (network.chainId !== chainId) { (0, index_js_1.assert)(false, "cannot mix providers on different networks", "UNSUPPORTED_OPERATION", { operation: "new FallbackProvider" }); } } })(); } await initialSync; } async #checkQuorum(running, req) { // Get all the result objects const results = []; for (const runner of running) { if (runner.result != null) { const { tag, value } = normalizeResult(runner.result); results.push({ tag, value, weight: runner.config.weight }); } } // Are there enough results to event meet quorum? if (results.reduce((a, r) => (a + r.weight), 0) < this.quorum) { return undefined; } switch (req.method) { case "getBlockNumber": { // We need to get the bootstrap block height if (this.#height === -2) { this.#height = Math.ceil((0, index_js_1.getNumber)(getMedian(this.quorum, this.#configs.map((c) => ({ value: c.blockNumber, tag: (0, index_js_1.getNumber)(c.blockNumber).toString(), weight: c.weight }))))); } // Find the mode across all the providers, allowing for // a little drift between block heights const mode = getFuzzyMode(this.quorum, results); if (mode === undefined) { return undefined; } if (mode > this.#height) { this.#height = mode; } return this.#height; } case "getGasPrice": case "estimateGas": return getMedian(this.quorum, results); case "getBlock": // Pending blocks are in the mempool and already // quite untrustworthy; just grab anything if ("blockTag" in req && req.blockTag === "pending") { return getAnyResult(this.quorum, results); } return checkQuorum(this.quorum, results); case "call": case "chainId": case "getBalance": case "getTransactionCount": case "getCode": case "getStorage": case "getTransaction": case "getTransactionReceipt": case "getLogs": return checkQuorum(this.quorum, results); case "broadcastTransaction": throw new Error("TODO"); } (0, index_js_1.assert)(false, "unsupported method", "UNSUPPORTED_OPERATION", { operation: `_perform(${stringify(req.method)})` }); } async #waitForQuorum(running, req) { if (running.size === 0) { throw new Error("no runners?!"); } // Any promises that are interesting to watch for; an expired stall // or a successful perform const interesting = []; let newRunners = 0; for (const runner of running) { // No responses, yet; keep an eye on it if (runner.perform) { interesting.push(runner.perform); } // Still stalling... if (runner.staller) { interesting.push(runner.staller); continue; } // This runner has already triggered another runner if (runner.didBump) { continue; } // Got a response (result or error) or stalled; kick off another runner runner.didBump = true; newRunners++; } // Check if we have reached quorum on a result (or error) const value = await this.#checkQuorum(running, req); if (value !== undefined) { if (value instanceof Error) { throw value; } return value; } // Add any new runners, because a staller timed out or a result // or error response came in. for (let i = 0; i < newRunners; i++) { this.#addRunner(running, req); } // All providers have returned, and we have no result (0, index_js_1.assert)(interesting.length > 0, "quorum not met", "SERVER_ERROR", { request: "%sub-requests", info: { request: req, results: Array.from(running).map((r) => stringify(r.result)) } }); // Wait for someone to either complete its perform or stall out await Promise.race(interesting); // This is recursive, but at worst case the depth is 2x the // number of providers (each has a perform and a staller) return await this.#waitForQuorum(running, req); } async _perform(req) { // Broadcasting a transaction is rare (ish) and already incurs // a cost on the user, so spamming is safe-ish. Just send it to // every backend. if (req.method === "broadcastTransaction") { const results = await Promise.all(this.#configs.map(async ({ provider, weight }) => { try { const result = await provider._perform(req); return Object.assign(normalizeResult({ result }), { weight }); } catch (error) { return Object.assign(normalizeResult({ error }), { weight }); } })); const result = getAnyResult(this.quorum, results); (0, index_js_1.assert)(result !== undefined, "problem multi-broadcasting", "SERVER_ERROR", { request: "%sub-requests", info: { request: req, results: results.map(stringify) } }); return result; } await this.#initialSync(); // Bootstrap enough runners to meet quorum const running = new Set(); for (let i = 0; i < this.quorum; i++) { this.#addRunner(running, req); } const result = await this.#waitForQuorum(running, req); // Track requests sent to a provider that are still // outstanding after quorum has been otherwise found for (const runner of running) { if (runner.perform && runner.result == null) { runner.config.lateResponses++; } } return result; } } exports.FallbackProvider = FallbackProvider; //# sourceMappingURL=provider-fallback.js.map