@ethersproject/web - npm Package Compare versions

Comparing version 5.6.0 to 6.0.0-beta.1

lib/_version.d.ts

@@ -1,2 +0,2 @@
-export declare const version = "web/5.6.0";
+export declare const version = "@ethersproject/web@6.0.0-beta.1";
 //# sourceMappingURL=_version.d.ts.map

lib/_version.js

@@ -1,5 +0,2 @@
-"use strict";
-Object.defineProperty(exports, "__esModule", { value: true });
-exports.version = void 0;
-exports.version = "web/5.6.0";
+export const version = "@ethersproject/web@6.0.0-beta.1";
 //# sourceMappingURL=_version.js.map

lib/index.d.ts

@@ -1,41 +0,5 @@
-export declare type ConnectionInfo = {
-    url: string;
-    headers?: {
-        [key: string]: string | number;
-    };
-    user?: string;
-    password?: string;
-    allowInsecureAuthentication?: boolean;
-    allowGzip?: boolean;
-    throttleLimit?: number;
-    throttleSlotInterval?: number;
-    throttleCallback?: (attempt: number, url: string) => Promise<boolean>;
-    skipFetchSetup?: boolean;
-    errorPassThrough?: boolean;
-    timeout?: number;
-};
-export interface OnceBlockable {
-    once(eventName: "block", handler: () => void): void;
-}
-export interface OncePollable {
-    once(eventName: "poll", handler: () => void): void;
-}
-export declare type PollOptions = {
-    timeout?: number;
-    floor?: number;
-    ceiling?: number;
-    interval?: number;
-    retryLimit?: number;
-    onceBlock?: OnceBlockable;
-    oncePoll?: OncePollable;
-};
-export declare type FetchJsonResponse = {
-    statusCode: number;
-    headers: {
-        [header: string]: string;
-    };
-};
-export declare function _fetchData<T = Uint8Array>(connection: string | ConnectionInfo, body?: Uint8Array, processFunc?: (value: Uint8Array, response: FetchJsonResponse) => T): Promise<T>;
-export declare function fetchJson(connection: string | ConnectionInfo, json?: string, processFunc?: (value: any, response: FetchJsonResponse) => any): Promise<any>;
-export declare function poll<T>(func: () => Promise<T>, options?: PollOptions): Promise<T>;
+export { fetchData } from "./fetch-data.js";
+export { FetchRequest } from "./request.js";
+export { FetchResponse } from "./response.js";
+export type { ConnectionInfo, PreflightRequestFunc, ProcessResponseFunc, ThrottleRetryFunc } from "./fetch-data.js";
 //# sourceMappingURL=index.d.ts.map

lib/index.js

@@ -1,455 +0,4 @@
-"use strict";
-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 };
-    }
-};
-Object.defineProperty(exports, "__esModule", { value: true });
-exports.poll = exports.fetchJson = exports._fetchData = void 0;
-var base64_1 = require("@ethersproject/base64");
-var bytes_1 = require("@ethersproject/bytes");
-var properties_1 = require("@ethersproject/properties");
-var strings_1 = require("@ethersproject/strings");
-var logger_1 = require("@ethersproject/logger");
-var _version_1 = require("./_version");
-var logger = new logger_1.Logger(_version_1.version);
-var geturl_1 = require("./geturl");
-function staller(duration) {
-    return new Promise(function (resolve) {
-        setTimeout(resolve, duration);
-    });
-}
-function bodyify(value, type) {
-    if (value == null) {
-        return null;
-    }
-    if (typeof (value) === "string") {
-        return value;
-    }
-    if ((0, bytes_1.isBytesLike)(value)) {
-        if (type && (type.split("/")[0] === "text" || type.split(";")[0].trim() === "application/json")) {
-            try {
-                return (0, strings_1.toUtf8String)(value);
-            }
-            catch (error) { }
-            ;
-        }
-        return (0, bytes_1.hexlify)(value);
-    }
-    return value;
-}
-// This API is still a work in progress; the future changes will likely be:
-// - ConnectionInfo => FetchDataRequest<T = any>
-// - FetchDataRequest.body? = string | Uint8Array | { contentType: string, data: string | Uint8Array }
-//   - If string => text/plain, Uint8Array => application/octet-stream (if content-type unspecified)
-// - FetchDataRequest.processFunc = (body: Uint8Array, response: FetchDataResponse) => T
-// For this reason, it should be considered internal until the API is finalized
-function _fetchData(connection, body, processFunc) {
-    // How many times to retry in the event of a throttle
-    var attemptLimit = (typeof (connection) === "object" && connection.throttleLimit != null) ? connection.throttleLimit : 12;
-    logger.assertArgument((attemptLimit > 0 && (attemptLimit % 1) === 0), "invalid connection throttle limit", "connection.throttleLimit", attemptLimit);
-    var throttleCallback = ((typeof (connection) === "object") ? connection.throttleCallback : null);
-    var throttleSlotInterval = ((typeof (connection) === "object" && typeof (connection.throttleSlotInterval) === "number") ? connection.throttleSlotInterval : 100);
-    logger.assertArgument((throttleSlotInterval > 0 && (throttleSlotInterval % 1) === 0), "invalid connection throttle slot interval", "connection.throttleSlotInterval", throttleSlotInterval);
-    var errorPassThrough = ((typeof (connection) === "object") ? !!(connection.errorPassThrough) : false);
-    var headers = {};
-    var url = null;
-    // @TODO: Allow ConnectionInfo to override some of these values
-    var options = {
-        method: "GET",
-    };
-    var allow304 = false;
-    var timeout = 2 * 60 * 1000;
-    if (typeof (connection) === "string") {
-        url = connection;
-    }
-    else if (typeof (connection) === "object") {
-        if (connection == null || connection.url == null) {
-            logger.throwArgumentError("missing URL", "connection.url", connection);
-        }
-        url = connection.url;
-        if (typeof (connection.timeout) === "number" && connection.timeout > 0) {
-            timeout = connection.timeout;
-        }
-        if (connection.headers) {
-            for (var key in connection.headers) {
-                headers[key.toLowerCase()] = { key: key, value: String(connection.headers[key]) };
-                if (["if-none-match", "if-modified-since"].indexOf(key.toLowerCase()) >= 0) {
-                    allow304 = true;
-                }
-            }
-        }
-        options.allowGzip = !!connection.allowGzip;
-        if (connection.user != null && connection.password != null) {
-            if (url.substring(0, 6) !== "https:" && connection.allowInsecureAuthentication !== true) {
-                logger.throwError("basic authentication requires a secure https url", logger_1.Logger.errors.INVALID_ARGUMENT, { argument: "url", url: url, user: connection.user, password: "[REDACTED]" });
-            }
-            var authorization = connection.user + ":" + connection.password;
-            headers["authorization"] = {
-                key: "Authorization",
-                value: "Basic " + (0, base64_1.encode)((0, strings_1.toUtf8Bytes)(authorization))
-            };
-        }
-        if (connection.skipFetchSetup != null) {
-            options.skipFetchSetup = !!connection.skipFetchSetup;
-        }
-    }
-    var reData = new RegExp("^data:([a-z0-9-]+/[a-z0-9-]+);base64,(.*)$", "i");
-    var dataMatch = ((url) ? url.match(reData) : null);
-    if (dataMatch) {
-        try {
-            var response = {
-                statusCode: 200,
-                statusMessage: "OK",
-                headers: { "content-type": dataMatch[1] },
-                body: (0, base64_1.decode)(dataMatch[2])
-            };
-            var result = response.body;
-            if (processFunc) {
-                result = processFunc(response.body, response);
-            }
-            return Promise.resolve(result);
-        }
-        catch (error) {
-            logger.throwError("processing response error", logger_1.Logger.errors.SERVER_ERROR, {
-                body: bodyify(dataMatch[1], dataMatch[2]),
-                error: error,
-                requestBody: null,
-                requestMethod: "GET",
-                url: url
-            });
-        }
-    }
-    if (body) {
-        options.method = "POST";
-        options.body = body;
-        if (headers["content-type"] == null) {
-            headers["content-type"] = { key: "Content-Type", value: "application/octet-stream" };
-        }
-        if (headers["content-length"] == null) {
-            headers["content-length"] = { key: "Content-Length", value: String(body.length) };
-        }
-    }
-    var flatHeaders = {};
-    Object.keys(headers).forEach(function (key) {
-        var header = headers[key];
-        flatHeaders[header.key] = header.value;
-    });
-    options.headers = flatHeaders;
-    var runningTimeout = (function () {
-        var timer = null;
-        var promise = new Promise(function (resolve, reject) {
-            if (timeout) {
-                timer = setTimeout(function () {
-                    if (timer == null) {
-                        return;
-                    }
-                    timer = null;
-                    reject(logger.makeError("timeout", logger_1.Logger.errors.TIMEOUT, {
-                        requestBody: bodyify(options.body, flatHeaders["content-type"]),
-                        requestMethod: options.method,
-                        timeout: timeout,
-                        url: url
-                    }));
-                }, timeout);
-            }
-        });
-        var cancel = function () {
-            if (timer == null) {
-                return;
-            }
-            clearTimeout(timer);
-            timer = null;
-        };
-        return { promise: promise, cancel: cancel };
-    })();
-    var runningFetch = (function () {
-        return __awaiter(this, void 0, void 0, function () {
-            var attempt, response, location_1, tryAgain, stall, retryAfter, error_1, body_1, result, error_2, tryAgain, timeout_1;
-            return __generator(this, function (_a) {
-                switch (_a.label) {
-                    case 0:
-                        attempt = 0;
-                        _a.label = 1;
-                    case 1:
-                        if (!(attempt < attemptLimit)) return [3 /*break*/, 20];
-                        response = null;
-                        _a.label = 2;
-                    case 2:
-                        _a.trys.push([2, 9, , 10]);
-                        return [4 /*yield*/, (0, geturl_1.getUrl)(url, options)];
-                    case 3:
-                        response = _a.sent();
-                        if (!(attempt < attemptLimit)) return [3 /*break*/, 8];
-                        if (!(response.statusCode === 301 || response.statusCode === 302)) return [3 /*break*/, 4];
-                        location_1 = response.headers.location || "";
-                        if (options.method === "GET" && location_1.match(/^https:/)) {
-                            url = response.headers.location;
-                            return [3 /*break*/, 19];
-                        }
-                        return [3 /*break*/, 8];
-                    case 4:
-                        if (!(response.statusCode === 429)) return [3 /*break*/, 8];
-                        tryAgain = true;
-                        if (!throttleCallback) return [3 /*break*/, 6];
-                        return [4 /*yield*/, throttleCallback(attempt, url)];
-                    case 5:
-                        tryAgain = _a.sent();
-                        _a.label = 6;
-                    case 6:
-                        if (!tryAgain) return [3 /*break*/, 8];
-                        stall = 0;
-                        retryAfter = response.headers["retry-after"];
-                        if (typeof (retryAfter) === "string" && retryAfter.match(/^[1-9][0-9]*$/)) {
-                            stall = parseInt(retryAfter) * 1000;
-                        }
-                        else {
-                            stall = throttleSlotInterval * parseInt(String(Math.random() * Math.pow(2, attempt)));
-                        }
-                        //console.log("Stalling 429");
-                        return [4 /*yield*/, staller(stall)];
-                    case 7:
-                        //console.log("Stalling 429");
-                        _a.sent();
-                        return [3 /*break*/, 19];
-                    case 8: return [3 /*break*/, 10];
-                    case 9:
-                        error_1 = _a.sent();
-                        response = error_1.response;
-                        if (response == null) {
-                            runningTimeout.cancel();
-                            logger.throwError("missing response", logger_1.Logger.errors.SERVER_ERROR, {
-                                requestBody: bodyify(options.body, flatHeaders["content-type"]),
-                                requestMethod: options.method,
-                                serverError: error_1,
-                                url: url
-                            });
-                        }
-                        return [3 /*break*/, 10];
-                    case 10:
-                        body_1 = response.body;
-                        if (allow304 && response.statusCode === 304) {
-                            body_1 = null;
-                        }
-                        else if (!errorPassThrough && (response.statusCode < 200 || response.statusCode >= 300)) {
-                            runningTimeout.cancel();
-                            logger.throwError("bad response", logger_1.Logger.errors.SERVER_ERROR, {
-                                status: response.statusCode,
-                                headers: response.headers,
-                                body: bodyify(body_1, ((response.headers) ? response.headers["content-type"] : null)),
-                                requestBody: bodyify(options.body, flatHeaders["content-type"]),
-                                requestMethod: options.method,
-                                url: url
-                            });
-                        }
-                        if (!processFunc) return [3 /*break*/, 18];
-                        _a.label = 11;
-                    case 11:
-                        _a.trys.push([11, 13, , 18]);
-                        return [4 /*yield*/, processFunc(body_1, response)];
-                    case 12:
-                        result = _a.sent();
-                        runningTimeout.cancel();
-                        return [2 /*return*/, result];
-                    case 13:
-                        error_2 = _a.sent();
-                        if (!(error_2.throttleRetry && attempt < attemptLimit)) return [3 /*break*/, 17];
-                        tryAgain = true;
-                        if (!throttleCallback) return [3 /*break*/, 15];
-                        return [4 /*yield*/, throttleCallback(attempt, url)];
-                    case 14:
-                        tryAgain = _a.sent();
-                        _a.label = 15;
-                    case 15:
-                        if (!tryAgain) return [3 /*break*/, 17];
-                        timeout_1 = throttleSlotInterval * parseInt(String(Math.random() * Math.pow(2, attempt)));
-                        //console.log("Stalling callback");
-                        return [4 /*yield*/, staller(timeout_1)];
-                    case 16:
-                        //console.log("Stalling callback");
-                        _a.sent();
-                        return [3 /*break*/, 19];
-                    case 17:
-                        runningTimeout.cancel();
-                        logger.throwError("processing response error", logger_1.Logger.errors.SERVER_ERROR, {
-                            body: bodyify(body_1, ((response.headers) ? response.headers["content-type"] : null)),
-                            error: error_2,
-                            requestBody: bodyify(options.body, flatHeaders["content-type"]),
-                            requestMethod: options.method,
-                            url: url
-                        });
-                        return [3 /*break*/, 18];
-                    case 18:
-                        runningTimeout.cancel();
-                        // If we had a processFunc, it either returned a T or threw above.
-                        // The "body" is now a Uint8Array.
-                        return [2 /*return*/, body_1];
-                    case 19:
-                        attempt++;
-                        return [3 /*break*/, 1];
-                    case 20: return [2 /*return*/, logger.throwError("failed response", logger_1.Logger.errors.SERVER_ERROR, {
-                            requestBody: bodyify(options.body, flatHeaders["content-type"]),
-                            requestMethod: options.method,
-                            url: url
-                        })];
-                }
-            });
-        });
-    })();
-    return Promise.race([runningTimeout.promise, runningFetch]);
-}
-exports._fetchData = _fetchData;
-function fetchJson(connection, json, processFunc) {
-    var processJsonFunc = function (value, response) {
-        var result = null;
-        if (value != null) {
-            try {
-                result = JSON.parse((0, strings_1.toUtf8String)(value));
-            }
-            catch (error) {
-                logger.throwError("invalid JSON", logger_1.Logger.errors.SERVER_ERROR, {
-                    body: value,
-                    error: error
-                });
-            }
-        }
-        if (processFunc) {
-            result = processFunc(result, response);
-        }
-        return result;
-    };
-    // If we have json to send, we must
-    // - add content-type of application/json (unless already overridden)
-    // - convert the json to bytes
-    var body = null;
-    if (json != null) {
-        body = (0, strings_1.toUtf8Bytes)(json);
-        // Create a connection with the content-type set for JSON
-        var updated = (typeof (connection) === "string") ? ({ url: connection }) : (0, properties_1.shallowCopy)(connection);
-        if (updated.headers) {
-            var hasContentType = (Object.keys(updated.headers).filter(function (k) { return (k.toLowerCase() === "content-type"); }).length) !== 0;
-            if (!hasContentType) {
-                updated.headers = (0, properties_1.shallowCopy)(updated.headers);
-                updated.headers["content-type"] = "application/json";
-            }
-        }
-        else {
-            updated.headers = { "content-type": "application/json" };
-        }
-        connection = updated;
-    }
-    return _fetchData(connection, body, processJsonFunc);
-}
-exports.fetchJson = fetchJson;
-function poll(func, options) {
-    if (!options) {
-        options = {};
-    }
-    options = (0, properties_1.shallowCopy)(options);
-    if (options.floor == null) {
-        options.floor = 0;
-    }
-    if (options.ceiling == null) {
-        options.ceiling = 10000;
-    }
-    if (options.interval == null) {
-        options.interval = 250;
-    }
-    return new Promise(function (resolve, reject) {
-        var timer = null;
-        var done = false;
-        // Returns true if cancel was successful. Unsuccessful cancel means we're already done.
-        var cancel = function () {
-            if (done) {
-                return false;
-            }
-            done = true;
-            if (timer) {
-                clearTimeout(timer);
-            }
-            return true;
-        };
-        if (options.timeout) {
-            timer = setTimeout(function () {
-                if (cancel()) {
-                    reject(new Error("timeout"));
-                }
-            }, options.timeout);
-        }
-        var retryLimit = options.retryLimit;
-        var attempt = 0;
-        function check() {
-            return func().then(function (result) {
-                // If we have a result, or are allowed null then we're done
-                if (result !== undefined) {
-                    if (cancel()) {
-                        resolve(result);
-                    }
-                }
-                else if (options.oncePoll) {
-                    options.oncePoll.once("poll", check);
-                }
-                else if (options.onceBlock) {
-                    options.onceBlock.once("block", check);
-                    // Otherwise, exponential back-off (up to 10s) our next request
-                }
-                else if (!done) {
-                    attempt++;
-                    if (attempt > retryLimit) {
-                        if (cancel()) {
-                            reject(new Error("retry limit reached"));
-                        }
-                        return;
-                    }
-                    var timeout = options.interval * parseInt(String(Math.random() * Math.pow(2, attempt)));
-                    if (timeout < options.floor) {
-                        timeout = options.floor;
-                    }
-                    if (timeout > options.ceiling) {
-                        timeout = options.ceiling;
-                    }
-                    setTimeout(check, timeout);
-                }
-                return null;
-            }, function (error) {
-                if (cancel()) {
-                    reject(error);
-                }
-            });
-        }
-        check();
-    });
-}
-exports.poll = poll;
+export { fetchData } from "./fetch-data.js";
+export { FetchRequest } from "./request.js";
+export { FetchResponse } from "./response.js";
 //# sourceMappingURL=index.js.map

LICENSE.md

 MIT License
 
-Copyright (c) 2019 Richard Moore
+Copyright (c) 2022 Richard Moore
 
@@ -5,0 +5,0 @@ Permission is hereby granted, free of charge, to any person obtaining a copy

package.json

 {
-  "_ethers.alias": {
-    "geturl.js": "browser-geturl.js"
-  },
   "author": "Richard Moore <[e-mail]>",
-  "browser": {
-    "./lib/geturl": "./lib/browser-geturl.js"
-  },
   "dependencies": {
-    "@ethersproject/base64": "^5.6.0",
-    "@ethersproject/bytes": "^5.6.0",
-    "@ethersproject/logger": "^5.6.0",
-    "@ethersproject/properties": "^5.6.0",
-    "@ethersproject/strings": "^5.6.0"
+    "@ethersproject/bytes": "^6.0.0-beta.1",
+    "@ethersproject/logger": "^6.0.0-beta.1",
+    "@ethersproject/properties": "^6.0.0-beta.1",
+    "@ethersproject/strings": "^6.0.0-beta.1"
   },
-  "description": "Utility fucntions for managing web requests for ethers.",
+  "description": "Web fetching Utilities for ethers.",
+  "engines": {
+    "node": ">=12.17.0"
+  },
   "ethereum": "donations.ethers.eth",
-  "funding": [
-    {
-      "type": "individual",
-      "url": "https://gitcoin.co/grants/13/ethersjs-complete-simple-and-tiny-2"
-    },
-    {
-      "type": "individual",
-      "url": "https://www.buymeacoffee.com/ricmoo"
-    }
-  ],
-  "gitHead": "b8cda5dffdcb688e38d7c6a0aec4c7b8b59c1af5",
+  "gitHead": "77f691b3bc3a6387a5184ec9b1779faab4bcb30d",
   "keywords": [
@@ -35,6 +21,6 @@ "Ethereum",
   "main": "./lib/index.js",
-  "module": "./lib.esm/index.js",
   "name": "@ethersproject/web",
   "publishConfig": {
-    "access": "public"
+    "access": "public",
+    "tag": "beta"
   },
@@ -50,5 +36,6 @@ "repository": {
   "sideEffects": false,
-  "tarballHash": "0x7e94c77f934aa62ce0bd58546dd163a8a3f821ad64198ca8101ce6876800ed01",
+  "tarballHash": "0xb070fa728f5d56de6ffad75e51cca1c380df75eddedd8b4bdd0246d4d44b89a2",
+  "type": "module",
   "types": "./lib/index.d.ts",
-  "version": "5.6.0"
+  "version": "6.0.0-beta.1"
 }

src.ts/_version.ts

@@ -1,1 +0,1 @@
-export const version = "web/5.6.0";
+export const version = "@ethersproject/web@6.0.0-beta.1";

src.ts/index.ts

@@ -1,466 +0,11 @@
-"use strict";
 
-import { decode as base64Decode, encode as base64Encode } from "@ethersproject/base64";
-import { hexlify, isBytesLike } from "@ethersproject/bytes";
-import { shallowCopy } from "@ethersproject/properties";
-import { toUtf8Bytes, toUtf8String } from "@ethersproject/strings";
+export { fetchData } from "./fetch-data.js";
+export { FetchRequest } from "./request.js";
+export { FetchResponse } from "./response.js";
 
-import { Logger } from "@ethersproject/logger";
-import { version } from "./_version";
-const logger = new Logger(version);
+export type {
+    ConnectionInfo,
+    PreflightRequestFunc, ProcessResponseFunc,
+    ThrottleRetryFunc
+} from "./fetch-data.js";
 
-import { getUrl, GetUrlResponse, Options } from "./geturl";
-
-function staller(duration: number): Promise<void> {
-    return new Promise((resolve) => {
-        setTimeout(resolve, duration);
-    });
-}
-
-function bodyify(value: any, type: string): string {
-    if (value == null) { return null; }
-
-    if (typeof(value) === "string") { return value; }
-
-    if (isBytesLike(value)) {
-        if (type && (type.split("/")[0] === "text" || type.split(";")[0].trim() === "application/json")) {
-            try {
-                return toUtf8String(value);
-            } catch (error) { };
-        }
-        return hexlify(value);
-    }
-
-    return value;
-}
-
-// Exported Types
-export type ConnectionInfo = {
-    url: string,
-    headers?: { [key: string]: string | number }
-
-    user?: string,
-    password?: string,
-
-    allowInsecureAuthentication?: boolean,
-    allowGzip?: boolean,
-
-    throttleLimit?: number,
-    throttleSlotInterval?: number;
-    throttleCallback?: (attempt: number, url: string) => Promise<boolean>,
-
-    skipFetchSetup?: boolean;
-    errorPassThrough?: boolean;
-
-    timeout?: number,
-};
-
-export interface OnceBlockable {
-    once(eventName: "block", handler: () => void): void;
-}
-
-export interface OncePollable {
-    once(eventName: "poll", handler: () => void): void;
-}
-
-export type PollOptions = {
-    timeout?: number,
-    floor?: number,
-    ceiling?: number,
-    interval?: number,
-    retryLimit?: number,
-    onceBlock?: OnceBlockable
-    oncePoll?: OncePollable
-};
-
-export type FetchJsonResponse = {
-    statusCode: number;
-    headers: { [ header: string ]: string };
-};
-
-
-type Header = { key: string, value: string };
-
-// This API is still a work in progress; the future changes will likely be:
-// - ConnectionInfo => FetchDataRequest<T = any>
-// - FetchDataRequest.body? = string | Uint8Array | { contentType: string, data: string | Uint8Array }
-//   - If string => text/plain, Uint8Array => application/octet-stream (if content-type unspecified)
-// - FetchDataRequest.processFunc = (body: Uint8Array, response: FetchDataResponse) => T
-// For this reason, it should be considered internal until the API is finalized
-export function _fetchData<T = Uint8Array>(connection: string | ConnectionInfo, body?: Uint8Array, processFunc?: (value: Uint8Array, response: FetchJsonResponse) => T): Promise<T> {
-
-    // How many times to retry in the event of a throttle
-    const attemptLimit = (typeof(connection) === "object" && connection.throttleLimit != null) ? connection.throttleLimit: 12;
-    logger.assertArgument((attemptLimit > 0 && (attemptLimit % 1) === 0),
-        "invalid connection throttle limit", "connection.throttleLimit", attemptLimit);
-
-    const throttleCallback = ((typeof(connection) === "object") ? connection.throttleCallback: null);
-    const throttleSlotInterval = ((typeof(connection) === "object" && typeof(connection.throttleSlotInterval) === "number") ? connection.throttleSlotInterval: 100);
-    logger.assertArgument((throttleSlotInterval > 0 && (throttleSlotInterval % 1) === 0),
-        "invalid connection throttle slot interval", "connection.throttleSlotInterval", throttleSlotInterval);
-
-    const errorPassThrough = ((typeof(connection) === "object") ? !!(connection.errorPassThrough): false);
-
-    const headers: { [key: string]: Header } = { };
-
-    let url: string = null;
-
-    // @TODO: Allow ConnectionInfo to override some of these values
-    const options: Options = {
-        method: "GET",
-    };
-
-    let allow304 = false;
-
-    let timeout = 2 * 60 * 1000;
-
-    if (typeof(connection) === "string") {
-        url = connection;
-
-    } else if (typeof(connection) === "object") {
-        if (connection == null || connection.url == null) {
-            logger.throwArgumentError("missing URL", "connection.url", connection);
-        }
-
-        url = connection.url;
-
-        if (typeof(connection.timeout) === "number" && connection.timeout > 0) {
-            timeout = connection.timeout;
-        }
-
-        if (connection.headers) {
-            for (const key in connection.headers) {
-                headers[key.toLowerCase()] = { key: key, value: String(connection.headers[key]) };
-                if (["if-none-match", "if-modified-since"].indexOf(key.toLowerCase()) >= 0) {
-                    allow304 = true;
-                }
-            }
-        }
-
-        options.allowGzip = !!connection.allowGzip;
-
-        if (connection.user != null && connection.password != null) {
-            if (url.substring(0, 6) !== "https:" && connection.allowInsecureAuthentication !== true) {
-                logger.throwError(
-                    "basic authentication requires a secure https url",
-                    Logger.errors.INVALID_ARGUMENT,
-                    { argument: "url", url: url, user: connection.user, password: "[REDACTED]" }
-                );
-            }
-
-            const authorization = connection.user + ":" + connection.password;
-            headers["authorization"] = {
-                key: "Authorization",
-                value: "Basic " + base64Encode(toUtf8Bytes(authorization))
-            };
-        }
-
-        if (connection.skipFetchSetup != null) {
-            options.skipFetchSetup = !!connection.skipFetchSetup;
-        }
-    }
-    const reData = new RegExp("^data:([a-z0-9-]+/[a-z0-9-]+);base64,(.*)$", "i");
-    const dataMatch = ((url) ? url.match(reData): null);
-    if (dataMatch) {
-        try {
-            const response = {
-                statusCode: 200,
-                statusMessage: "OK",
-                headers: { "content-type": dataMatch[1] },
-                body: base64Decode(dataMatch[2])
-            };
-
-            let result: T = <T><unknown>response.body;
-            if (processFunc) {
-                result = processFunc(response.body, response);
-            }
-            return Promise.resolve(<T><unknown>result);
-
-        } catch (error) {
-            logger.throwError("processing response error", Logger.errors.SERVER_ERROR, {
-                body: bodyify(dataMatch[1], dataMatch[2]),
-                error: error,
-                requestBody: null,
-                requestMethod: "GET",
-                url: url
-            });
-        }
-    }
-
-    if (body) {
-        options.method = "POST";
-        options.body = body;
-        if (headers["content-type"] == null) {
-            headers["content-type"] = { key: "Content-Type", value: "application/octet-stream" };
-        }
-        if (headers["content-length"] == null) {
-            headers["content-length"] = { key: "Content-Length", value: String(body.length) };
-        }
-    }
-
-    const flatHeaders: { [ key: string ]: string } = { };
-    Object.keys(headers).forEach((key) => {
-        const header = headers[key];
-        flatHeaders[header.key] = header.value;
-    });
-    options.headers = flatHeaders;
-
-    const runningTimeout = (function() {
-        let timer: NodeJS.Timer = null;
-        const promise: Promise<never> = new Promise(function(resolve, reject) {
-            if (timeout) {
-                timer = setTimeout(() => {
-                    if (timer == null) { return; }
-                    timer = null;
-
-                    reject(logger.makeError("timeout", Logger.errors.TIMEOUT, {
-                        requestBody: bodyify(options.body, flatHeaders["content-type"]),
-                        requestMethod: options.method,
-                        timeout: timeout,
-                        url: url
-                    }));
-                }, timeout);
-            }
-        });
-
-        const cancel = function() {
-            if (timer == null) { return; }
-            clearTimeout(timer);
-            timer = null;
-        }
-
-        return { promise, cancel };
-    })();
-
-    const runningFetch = (async function() {
-
-        for (let attempt = 0; attempt < attemptLimit; attempt++) {
-            let response: GetUrlResponse = null;
-
-            try {
-                response = await getUrl(url, options);
-
-                if (attempt < attemptLimit) {
-                    if (response.statusCode === 301 || response.statusCode === 302) {
-                        // Redirection; for now we only support absolute locataions
-                        const location = response.headers.location || "";
-                        if (options.method === "GET" && location.match(/^https:/)) {
-                            url = response.headers.location;
-                            continue;
-                        }
-
-                    } else if (response.statusCode === 429) {
-                        // Exponential back-off throttling
-                        let tryAgain = true;
-                        if (throttleCallback) {
-                            tryAgain = await throttleCallback(attempt, url);
-                        }
-
-                        if (tryAgain) {
-                            let stall = 0;
-
-                            const retryAfter = response.headers["retry-after"];
-                            if (typeof(retryAfter) === "string" && retryAfter.match(/^[1-9][0-9]*$/)) {
-                                stall = parseInt(retryAfter) * 1000;
-                            } else {
-                                stall = throttleSlotInterval * parseInt(String(Math.random() * Math.pow(2, attempt)));
-                            }
-
-                            //console.log("Stalling 429");
-                            await staller(stall);
-                            continue;
-                        }
-                    }
-                }
-
-            } catch (error) {
-                response = (<any>error).response;
-                if (response == null) {
-                    runningTimeout.cancel();
-                    logger.throwError("missing response", Logger.errors.SERVER_ERROR, {
-                        requestBody: bodyify(options.body, flatHeaders["content-type"]),
-                        requestMethod: options.method,
-                        serverError: error,
-                        url: url
-                    });
-                }
-            }
-
-
-            let body = response.body;
-
-            if (allow304 && response.statusCode === 304) {
-                body = null;
-            } else if (!errorPassThrough && (response.statusCode < 200 || response.statusCode >= 300)) {
-                runningTimeout.cancel();
-                logger.throwError("bad response", Logger.errors.SERVER_ERROR, {
-                    status: response.statusCode,
-                    headers: response.headers,
-                    body: bodyify(body, ((response.headers) ? response.headers["content-type"]: null)),
-                    requestBody: bodyify(options.body, flatHeaders["content-type"]),
-                    requestMethod: options.method,
-                    url: url
-                });
-            }
-
-            if (processFunc) {
-                try {
-                    const result = await processFunc(body, response);
-                    runningTimeout.cancel();
-                    return result;
-
-                } catch (error) {
-                    // Allow the processFunc to trigger a throttle
-                    if (error.throttleRetry && attempt < attemptLimit) {
-                        let tryAgain = true;
-                        if (throttleCallback) {
-                            tryAgain = await throttleCallback(attempt, url);
-                        }
-
-                        if (tryAgain) {
-                            const timeout = throttleSlotInterval * parseInt(String(Math.random() * Math.pow(2, attempt)));
-                            //console.log("Stalling callback");
-                            await staller(timeout);
-                            continue;
-                        }
-                    }
-
-                    runningTimeout.cancel();
-                    logger.throwError("processing response error", Logger.errors.SERVER_ERROR, {
-                        body: bodyify(body, ((response.headers) ? response.headers["content-type"]: null)),
-                        error: error,
-                        requestBody: bodyify(options.body, flatHeaders["content-type"]),
-                        requestMethod: options.method,
-                        url: url
-                    });
-                }
-            }
-
-            runningTimeout.cancel();
-
-            // If we had a processFunc, it either returned a T or threw above.
-            // The "body" is now a Uint8Array.
-            return <T>(<unknown>body);
-        }
-
-        return logger.throwError("failed response", Logger.errors.SERVER_ERROR, {
-            requestBody: bodyify(options.body, flatHeaders["content-type"]),
-            requestMethod: options.method,
-            url: url
-        });
-    })();
-
-    return Promise.race([ runningTimeout.promise, runningFetch ]);
-}
-
-export function fetchJson(connection: string | ConnectionInfo, json?: string, processFunc?: (value: any, response: FetchJsonResponse) => any): Promise<any> {
-    let processJsonFunc = (value: Uint8Array, response: FetchJsonResponse) => {
-        let result: any = null;
-        if (value != null) {
-            try {
-                result = JSON.parse(toUtf8String(value));
-            } catch (error) {
-                logger.throwError("invalid JSON", Logger.errors.SERVER_ERROR, {
-                    body: value,
-                    error: error
-                });
-            }
-        }
-
-        if (processFunc) {
-            result = processFunc(result, response);
-        }
-
-        return result;
-    }
-
-    // If we have json to send, we must
-    // - add content-type of application/json (unless already overridden)
-    // - convert the json to bytes
-    let body: Uint8Array = null;
-    if (json != null) {
-        body = toUtf8Bytes(json);
-
-        // Create a connection with the content-type set for JSON
-        const updated: ConnectionInfo = (typeof(connection) === "string") ? ({ url: connection }): shallowCopy(connection);
-        if (updated.headers) {
-            const hasContentType = (Object.keys(updated.headers).filter((k) => (k.toLowerCase() === "content-type")).length) !== 0;
-            if (!hasContentType) {
-                updated.headers = shallowCopy(updated.headers);
-                updated.headers["content-type"] = "application/json";
-            }
-        } else {
-            updated.headers = { "content-type": "application/json" };
-        }
-        connection = updated;
-    }
-
-    return _fetchData<any>(connection, body, processJsonFunc);
-}
-
-export function poll<T>(func: () => Promise<T>, options?: PollOptions): Promise<T> {
-    if (!options) { options = {}; }
-    options = shallowCopy(options);
-    if (options.floor == null) { options.floor = 0; }
-    if (options.ceiling == null) { options.ceiling = 10000; }
-    if (options.interval == null) { options.interval = 250; }
-
-    return new Promise(function(resolve, reject) {
-
-        let timer: NodeJS.Timer = null;
-        let done: boolean = false;
-
-        // Returns true if cancel was successful. Unsuccessful cancel means we're already done.
-        const cancel = (): boolean => {
-            if (done) { return false; }
-            done = true;
-            if (timer) { clearTimeout(timer); }
-            return true;
-        };
-
-        if (options.timeout) {
-            timer = setTimeout(() => {
-                if (cancel()) { reject(new Error("timeout")); }
-            }, options.timeout)
-        }
-
-        const retryLimit = options.retryLimit;
-
-        let attempt = 0;
-        function check() {
-            return func().then(function(result) {
-
-                // If we have a result, or are allowed null then we're done
-                if (result !== undefined) {
-                    if (cancel()) { resolve(result); }
-
-                } else if (options.oncePoll) {
-                    options.oncePoll.once("poll", check);
-
-                } else if (options.onceBlock) {
-                    options.onceBlock.once("block", check);
-
-                // Otherwise, exponential back-off (up to 10s) our next request
-                } else if (!done) {
-                    attempt++;
-                    if (attempt > retryLimit) {
-                        if (cancel()) { reject(new Error("retry limit reached")); }
-                        return;
-                    }
-
-                    let timeout = options.interval * parseInt(String(Math.random() * Math.pow(2, attempt)));
-                    if (timeout < options.floor) { timeout = options.floor; }
-                    if (timeout > options.ceiling) { timeout = options.ceiling; }
-
-                    setTimeout(check, timeout);
-                }
-
-                return null;
-            }, function(error) {
-                if (cancel()) { reject(error); }
-            });
-        }
-        check();
-    });
-}
-

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

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

No README

Quality

Package does not have a README. This may indicate a failed publish or a low quality package.

Found 1 instance in 1 package

No v1

Quality

Package is not semver >=1. This means it is not stable and does not support ^ ranges.

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

Improved metrics

Dependency count

4

decreased by-20%

Is type module

Yes

Worsened metrics

Total package byte prevSize

93283

decreased by-23.87%

Number of package files

43

decreased by-4.44%

Lines of code

1388

decreased by-22.85%

Number of low quality alerts

3

increased by50%

Number of medium quality alerts

1

increased byInfinity%

Number of lines in readme file

0

decreased by-100%

Dependency changes

• + Added@ethersproject/bytes@6.0.0-beta.3(transitive)

• + Added@ethersproject/logger@6.0.0-beta.7(transitive)

• + Added@ethersproject/properties@6.0.0-beta.6(transitive)

• + Added@ethersproject/strings@6.0.0-beta.2(transitive)

• - Removed@ethersproject/base64@^5.6.0

• - Removed@ethersproject/base64@5.7.0(transitive)

• - Removed@ethersproject/bignumber@5.7.0(transitive)

• - Removed@ethersproject/bytes@5.7.0(transitive)

• - Removed@ethersproject/constants@5.7.0(transitive)

• - Removed@ethersproject/logger@5.7.0(transitive)

• - Removed@ethersproject/properties@5.7.0(transitive)

• - Removed@ethersproject/strings@5.7.0(transitive)

• - Removedbn.js@5.2.1(transitive)

• Updated@ethersproject/bytes@^6.0.0-beta.1

• Updated@ethersproject/logger@^6.0.0-beta.1

• Updated@ethersproject/properties@^6.0.0-beta.1

• Updated@ethersproject/strings@^6.0.0-beta.1