web3-providers-http: Migrate from xhr2-cookies to cross-fetch

CHANGELOG.md

@@ -565,10 +565,14 @@ Released with 1.0.0-beta.37 code base.
 
 ## [1.7.5]
 
+### Changed
+-  Replace xhr2-cookies deps to cross-fetch for web3-providers-http (#5085)
+
 ### Added
 - Documentation details about `maxFeePerGas` and `maxPriorityFeePerGas` (#5121)
 
 ### Fixed
 -  Fix typos in web3-eth-accounts.rst & TESTING.md (#5047)
 -  Improve README.md & Fix typos (#4848)
 
+

packages/web3-providers-http/package.json

@@ -14,8 +14,10 @@
     "types": "types/index.d.ts",
     "main": "lib/index.js",
     "dependencies": {
-        "web3-core-helpers": "1.7.4",
-        "xhr2-cookies": "1.1.0"
+        "abortcontroller-polyfill": "^1.7.3",
+        "cross-fetch": "^3.1.4",
+        "es6-promise": "^4.2.8",
+        "web3-core-helpers": "1.7.4"
     },
     "devDependencies": {
         "dtslint": "^3.4.1",

packages/web3-providers-http/src/index.js

@@ -19,29 +19,33 @@
  *   Marek Kotewicz <marek@parity.io>
  *   Marian Oancea
  *   Fabian Vogelsteller <fabian@ethereum.org>
+ *   AyanamiTech <ayanami0330@protonmail.com>
  * @date 2015
  */
 
 var errors = require('web3-core-helpers').errors;
-var XHR2 = require('xhr2-cookies').XMLHttpRequest; // jshint ignore: line
+var fetch = require('cross-fetch');
 var http = require('http');
 var https = require('https');
 
+// Apply missing polyfill for IE
+require('es6-promise').polyfill();
+require('abortcontroller-polyfill/dist/polyfill-patch-fetch');
 
 /**
  * HttpProvider should be used to send rpc calls over http
  */
 var HttpProvider = function HttpProvider(host, options) {
     options = options || {};
 
-    this.withCredentials = options.withCredentials || false;
+    this.withCredentials = options.withCredentials;
     this.timeout = options.timeout || 0;
     this.headers = options.headers;
     this.agent = options.agent;
     this.connected = false;
 
     // keepAlive is true unless explicitly set to false
-    const keepAlive = options.keepAlive !== false;
+    var keepAlive = options.keepAlive !== false;
     this.host = host || 'http://localhost:8545';
     if (!this.agent) {
         if (this.host.substring(0,5) === "https") {
@@ -52,77 +56,109 @@ var HttpProvider = function HttpProvider(host, options) {
     }
 };
 
-HttpProvider.prototype._prepareRequest = function(){
-    var request;
-
-    // the current runtime is a browser
-    if (typeof XMLHttpRequest !== 'undefined') {
-        request = new XMLHttpRequest();
+/**
+ * Should be used to make async request
+ *
+ * @method send
+ * @param {Object} payload
+ * @param {Function} callback triggered on end with (err, result)
+ */
+HttpProvider.prototype.send = function (payload, callback) {
+    var options = {
+      method: 'POST',
+      body: JSON.stringify(payload)
+    };
+    var headers = {};
+    var controller;
+
+    if (typeof AbortController !== 'undefined') {
+        controller = new AbortController();
+    } else if (typeof AbortController === 'undefined' && typeof window !== 'undefined' && typeof window.AbortController !== 'undefined') {
+        // Some chrome version doesn't recognize new AbortController(); so we are using it from window instead
+        // https://stackoverflow.com/questions/55718778/why-abortcontroller-is-not-defined
+        controller = new window.AbortController();
     } else {
-        request = new XHR2();
-        var agents = {httpsAgent: this.httpsAgent, httpAgent: this.httpAgent, baseUrl: this.baseUrl};
+        // Disable user defined timeout
+        this.timeout = 0;
+    }
+
+    // the current runtime is node
+    if (typeof XMLHttpRequest === 'undefined') {
+        // https://github.com/node-fetch/node-fetch#custom-agent
+        var agents = {httpsAgent: this.httpsAgent, httpAgent: this.httpAgent};
 
         if (this.agent) {
             agents.httpsAgent = this.agent.https;
             agents.httpAgent = this.agent.http;
-            agents.baseUrl = this.agent.baseUrl;
         }
 
-        request.nodejsSet(agents);
+        if (this.host.substring(0,5) === "https") {
+            options.agent = agents.httpsAgent;
+        } else {
+            options.agent = agents.httpAgent;
+        }
     }
 
-    request.open('POST', this.host, true);
-    request.setRequestHeader('Content-Type','application/json');
-    request.timeout = this.timeout;
-    request.withCredentials = this.withCredentials;
-
     if(this.headers) {
         this.headers.forEach(function(header) {
-            request.setRequestHeader(header.name, header.value);
+            headers[header.name] = header.value;
         });
     }
 
-    return request;
-};
+    // Default headers
+    if (!headers['Content-Type']) {
+        headers['Content-Type'] = 'application/json';
+    }
 
-/**
- * Should be used to make async request
- *
- * @method send
- * @param {Object} payload
- * @param {Function} callback triggered on end with (err, result)
- */
-HttpProvider.prototype.send = function (payload, callback) {
-    var _this = this;
-    var request = this._prepareRequest();
+    options.credentials = this.withCredentials;
+    options.headers = headers;
 
-    request.onreadystatechange = function() {
-        if (request.readyState === 4 && request.timeout !== 1) {
-            var result = request.responseText;
-            var error = null;
+    if (this.timeout > 0) {
+        this.timeoutId = setTimeout(function() {
+            controller.abort();
+        }, this.timeout);
+    }
 
-            try {
-                result = JSON.parse(result);
-            } catch(e) {
-                error = errors.InvalidResponse(request.responseText);
-            }
+    // Prevent global leak of connected
+    var _this = this;
 
-            _this.connected = true;
-            callback(error, result);
+    var success = function(response) {
+        if (this.timeoutId !== undefined) {
+            clearTimeout(this.timeoutId);
+        }
+        var result = response;
+        var error = null;
+
+        try {
+            // Response is a stream data so should be awaited for json response
+            result.json().then(function(data) {
+                result = data;
+                _this.connected = true;
+                callback(error, result);
+            });
+        } catch (e) {
+            _this.connected = false;
+            callback(errors.InvalidResponse(result));
         }
     };
 
-    request.ontimeout = function() {
-        _this.connected = false;
-        callback(errors.ConnectionTimeout(this.timeout));
-    };
+    var failed = function(error) {
+        if (this.timeoutId !== undefined) {
+            clearTimeout(this.timeoutId);
+        }
 
-    try {
-        request.send(JSON.stringify(payload));
-    } catch(error) {
-        this.connected = false;
+        if (error.name === 'AbortError') {
+            _this.connected = false;
+            callback(errors.ConnectionTimeout(this.timeout));
+        }
+
+        _this.connected = false;
         callback(errors.InvalidConnection(this.host));
     }
+
+    fetch(this.host, options)
+        .then(success.bind(this))
+        .catch(failed.bind(this));
 };
 
 HttpProvider.prototype.disconnect = function () {

packages/web3-providers-http/types/index.d.ts

@@ -19,8 +19,8 @@
  * @author Josh Stevens <joshstevens19@hotmail.co.uk>
  * @date 2018
  */
-import * as http from 'http';
-import * as https from 'https';
+import type { Agent as HTTPAgent } from 'http';
+import type { Agent as HTTPSAgent } from 'https';
 
 import { HttpProviderBase, JsonRpcResponse } from 'web3-core-helpers';
 
@@ -30,9 +30,8 @@ export interface HttpHeader {
 }
 
 export interface HttpProviderAgent {
-    baseUrl?: string;
-    http?: http.Agent;
-    https?: https.Agent;
+    http?: HTTPAgent;
+    https?: HTTPSAgent;
 }
 
 export interface HttpProviderOptions {
@@ -46,7 +45,7 @@ export interface HttpProviderOptions {
 export class HttpProvider extends HttpProviderBase {
     host: string;
 
-    withCredentials: boolean;
+    withCredentials?: string;
     timeout: number;
     headers?: HttpHeader[];
     agent?: HttpProviderAgent;

packages/web3-providers-http/types/tests/web3-provider-http-tests.ts

@@ -35,7 +35,6 @@ const httpProvider = new HttpProvider('http://localhost:8545', {
     ],
     withCredentials: false,
     agent: {
-        baseUrl: 'base',
         http: new http.Agent({}),
         https: new https.Agent({})
     }