JsonRpcProvider: Basic access authentication support

README.md

@@ -27,6 +27,10 @@ import {
 } from "./config.js";
 
 // Instantiate a provider for querying information on the chain!
+//
+// MAINNET_RPC_URL and an element of DISPATCHERS is a string representing an
+// endpoint URL to the Pocket Network which may or may not contains basic
+// authentication credentials e.g. "https://scott:[email protected]".
 export const provider = new JsonRpcProvider({
   rpcUrl: MAINNET_RPC_URL,
   // If you'll Instantiate a relayer, you need to add dispatchers as well

packages/provider/package.json

@@ -35,6 +35,7 @@
   "dependencies": {
     "@pokt-foundation/pocketjs-abstract-provider": "workspace:*",
     "abort-controller": "^3.0.0",
+    "buffer": "^6.0.3",
     "debug": "^4.3.3",
     "undici": "^5.26.2"
   }

packages/provider/src/json-rpc-provider.ts

@@ -1,5 +1,6 @@
 import AbortController from 'abort-controller'
 import debug from 'debug'
+import { Buffer } from 'buffer'
 import { fetch, Response } from 'undici'
 import {
   Account,
@@ -93,14 +94,25 @@ export class JsonRpcProvider implements AbstractProvider {
         ]
       : this.rpcUrl
 
-    const routedRpcUrl = `${finalRpcUrl}${route}`
+    const headers = {
+      'Content-Type': 'application/json',
+    };
+
+    const url = new URL(route, finalRpcUrl);
+    if (url.username || url.password) {
+      const credential =
+        Buffer.from(`${url.username}:${url.password}`).toString('base64');
+      headers['Authorization'] = `Basic ${credential}`;
+      url.username = '';
+      url.password = '';
+    }
+
+    const routedRpcUrl = url.toString();
 
     const rpcResponse = await fetch(routedRpcUrl, {
       method: 'POST',
       signal: controller.signal as AbortSignal,
-      headers: {
-        'Content-Type': 'application/json',
-      },
+      headers: headers,
       body: JSON.stringify(body),
     }).catch((error) => {
       debug(`${routedRpcUrl} attempt ${retriesPerformed + 1} failure`)