Make your dApp more reliable with Chainstack

VIRGINIA_RPC="YOUR_VIRGNIA_CHAINSTACK_ENDPOINT"
LONDON_RPC="YOUR_LONDON_CHAINSTACK_ENDPOINT"
SINGAPORE_RPC="YOUR_SINGAPORE_CHAINSTACK_ENDPOINT"

const {Web3} = require("web3");
require("dotenv").config();

// Initialize RPCs from environment variables
const RPC_NODES = {
  web3Virginia: process.env.VIRGINIA_RPC,
  web3London: process.env.LONDON_RPC,
  web3Singapore: process.env.SINGAPORE_RPC,
};

// Create Web3 instances for each RPC
const web3Instances = {};
for (const [key, url] of Object.entries(RPC_NODES)) {
  web3Instances[key] = new Web3(url);
}

// Array of keys to cycle through
const keys = Object.keys(web3Instances);

// Counter to keep track of the current Web3 instance
let counter = 0;

async function getBlock(blockNumber) {
  // Select the current Web3 instance
  const key = keys[counter];
  const web3 = web3Instances[key];

  console.log(`Using ${key} RPC`);

  // Start the timer
  console.time("getBlock");

  try {
    // Try to get the latest block
    const block = await web3.eth.getBlock(blockNumber, false);

    // Extract some fields to keep the response cleaner
    const blockSummary = {
      blockNumber: block.number,
      blockHash: block.hash,
      parentHash: block.parentHash,
      size: block.size,
    };

    console.log(blockSummary);
  } catch (error) {
    // Log the error
    console.error(`Error fetching block: ${error.message}`);

    // Increment the counter and reset it if it's larger than the array length
    counter = (counter + 1) % keys.length;

    // Retry the request on the next Web3 instance
    console.log("Retrying request on next RPC...");
    return getBlock(blockNumber);
  }

  // End the timer and log the time
  console.timeEnd("getBlock");

  // Increment the counter and reset it if it's larger than the array length
  counter = (counter + 1) % keys.length;
}

// Call getBlock every 10 seconds
console.log("Running load balanced script...");
setInterval(() => getBlock("latest"), 10000);

const ethers = require('ethers');
require('dotenv').config();

// Initialize RPC nodes from environment variables
const RPC_NODES = {
  ethersVirginia: process.env.VIRGINIA_RPC,
  ethersLondon: process.env.LONDON_RPC,
  ethersSingapore: process.env.SINGAPORE_RPC,
};

// Create ethers providers for each RPC URL
const providers = {};
for (const [key, url] of Object.entries(RPC_NODES)) {
  providers[key] = new ethers.JsonRpcProvider(url);
}

// Keys to cycle through providers
const keys = Object.keys(providers);
let counter = 0; // Counter to keep track of the current provider

// Function to get the latest block using the current provider
const getBlock = async () => {
  const key = keys[counter];
  const provider = providers[key];
  console.log(`Using ${key} RPC`);

  console.time("getBlock"); // Start timing the operation
  try {
    // Fetch the latest block information
    const blockByNumber = await provider.send("eth_getBlockByNumber", ["latest", false]);
        // Extract some fields to keep the response cleaner
        const blockSummary = {
          blockNumber: blockByNumber.number,
          blockHash: blockByNumber.hash,
          parentHash: blockByNumber.parentHash,
          size: blockByNumber.size,
        };
    console.log(blockSummary);
  } catch (error) {
    // If there's an error, log it and move to the next provider
    console.error(`Error fetching block: ${error.message}`);
    counter = (counter + 1) % keys.length; // Increment and wrap the counter if necessary
    console.log("Retrying request on next RPC...");
    return getBlock(); // Retry with the next provider
  }
  console.timeEnd("getBlock"); // End timing the operation

  counter = (counter + 1) % keys.length; // Move to the next provider for the next call
};

// Start the process and call getBlock every 10 seconds
console.log("Running load-balanced script with ethers.js...");
setInterval(getBlock, 2000);

// Initialize RPCs from environment variables
const RPC_NODES = {
  web3Virginia: process.env.VIRGINIA_RPC,
  web3London: process.env.LONDON_RPC,
  web3Singapore: process.env.SINGAPORE_RPC,
};

// Create Web3 instances for each RPC
const web3Instances = {};
for (const [key, url] of Object.entries(RPC_NODES)) {
  web3Instances[key] = new Web3(url);
}

// Array of keys to cycle through
const keys = Object.keys(web3Instances);

// Counter to keep track of the current Web3 instance
let counter = 0;

async function getBlock(blockNumber) {
  // Select the current Web3 instance
  const key = keys[counter];
  const web3 = web3Instances[key];

  console.log(`Using ${key} RPC`);

  // Start the timer
  console.time("getBlock");

  try {
    // Try to get the latest block
    const block = await web3.eth.getBlock(blockNumber, false);

    // Extract some fields to keep the response cleaner
    const blockSummary = {
      blockNumber: block.number,
      blockHash: block.hash,
      parentHash: block.parentHash,
      size: block.size,
    };

    console.log(blockSummary);
  } catch (error) {
    // Log the error
    console.error(`Error fetching block: ${error.message}`);

    // Increment the counter and reset it if it's larger than the array length
    counter = (counter + 1) % keys.length;

    // Retry the request on the next Web3 instance
    console.log("Retrying request on next RPC...");
    return getBlock(blockNumber);
  }

  // End the timer and log the time
  console.timeEnd("getBlock");

  // Increment the counter and reset it if it's larger than the array length
  counter = (counter + 1) % keys.length;
}

// Call getBlock every 10 seconds
console.log("Running load balanced script...");
setInterval(() => getBlock("latest"), 10000);