feat: global fetch and websocket in config, globalThis for auto-detect fetch

Author: tabaktoni

src/channel/rpc_0_7.ts

@@ -36,6 +36,7 @@ import { Block, getDefaultNodeUrl, isV3Tx, wait } from '../utils/provider';
 import { decompressProgram, signatureToHexArray } from '../utils/stark';
 import { getVersionsByType } from '../utils/transaction';
 import { logger } from '../global/logger';
+import { config } from '../global/config';
 
 const defaultOptions = {
   headers: { 'Content-Type': 'application/json' },
@@ -88,7 +89,7 @@ export class RpcChannel {
     } else {
       this.nodeUrl = getDefaultNodeUrl(undefined, optionsOrProvider?.default, '0.7');
     }
-    this.baseFetch = baseFetch ?? fetch;
+    this.baseFetch = baseFetch || config.get('fetch') || fetch;
     this.blockIdentifier = blockIdentifier ?? defaultOptions.blockIdentifier;
     this.chainId = chainId;
     this.headers = { ...defaultOptions.headers, ...headers };

src/channel/rpc_0_8.ts

@@ -42,6 +42,7 @@ import { decompressProgram, signatureToHexArray } from '../utils/stark';
 import { getVersionsByType } from '../utils/transaction';
 import { logger } from '../global/logger';
 import { isRPC08_ResourceBounds } from '../provider/types/spec.type';
+import { config } from '../global/config';
 // TODO: check if we can filet type before entering to this method, as so to specify here only RPC 0.8 types
 
 const defaultOptions = {
@@ -95,7 +96,7 @@ export class RpcChannel {
     } else {
       this.nodeUrl = getDefaultNodeUrl(undefined, optionsOrProvider?.default, '0.8');
     }
-    this.baseFetch = baseFetch ?? fetch;
+    this.baseFetch = baseFetch || config.get('fetch') || fetch;
     this.blockIdentifier = blockIdentifier ?? defaultOptions.blockIdentifier;
     this.chainId = chainId;
     this.headers = { ...defaultOptions.headers, ...headers };

src/channel/ws_0_8.ts

@@ -16,6 +16,7 @@ import WebSocket from '../utils/connect/ws';
 import { stringify } from '../utils/json';
 import { bigNumberishArrayToHexadecimalStringArray, toHex } from '../utils/num';
 import { Block } from '../utils/provider';
+import { config } from '../global/config';
 
 export const WSSubscriptions = {
   NEW_HEADS: 'newHeads',
@@ -184,7 +185,7 @@ export class WebSocketChannel {
     // provided existing websocket
     const nodeUrl = options.nodeUrl || 'http://localhost:3000 '; // TODO: implement getDefaultNodeUrl default node when defined by providers?
     this.nodeUrl = options.websocket ? options.websocket.url : nodeUrl;
-    this.websocket = options.websocket ? options.websocket : new WebSocket(nodeUrl);
+    this.websocket = options.websocket || config.get('websocket') || new WebSocket(nodeUrl);
 
     this.websocket.addEventListener('open', this.onOpen.bind(this));
     this.websocket.addEventListener('close', this.onCloseProxy.bind(this));

src/global/constants.ts

@@ -107,6 +107,8 @@ export const DEFAULT_GLOBAL_CONFIG: {
   rpcVersion: _SupportedRpcVersion;
   transactionVersion: SupportedTransactionVersion;
   feeMarginPercentage: FeeMarginPercentage;
+  fetch: any;
+  websocket: any;
 } = {
   legacyMode: false,
   rpcVersion: '0.8',
@@ -129,6 +131,8 @@ export const DEFAULT_GLOBAL_CONFIG: {
     },
     maxFee: 50,
   },
+  fetch: undefined,
+  websocket: undefined,
 };
 
 export const RPC_DEFAULT_NODES = {

src/utils/connect/fetch.ts

@@ -1,7 +1,8 @@
 import { LibraryError } from '../errors';
 
 export default (typeof fetch !== 'undefined' && fetch) ||
-  (typeof window !== 'undefined' && window.fetch) ||
+  (typeof globalThis !== 'undefined' && globalThis.fetch) ||
+  (typeof window !== 'undefined' && window.fetch.bind(window)) ||
   (typeof global !== 'undefined' && global.fetch) ||
   ((() => {
     throw new LibraryError(

src/utils/connect/ws.ts

@@ -1,7 +1,8 @@
 import { LibraryError } from '../errors';
 
 export default (typeof WebSocket !== 'undefined' && WebSocket) ||
-  (typeof window !== 'undefined' && window.WebSocket) ||
+  (typeof globalThis !== 'undefined' && globalThis.WebSocket) ||
+  (typeof window !== 'undefined' && window.WebSocket.bind(window)) ||
   (typeof global !== 'undefined' && global.WebSocket) ||
   (class {
     constructor() {