Solana public RPC finder

readme.md

Solana public RPC finder

Prerequisites

Ensure you have the following installed:

• Node

Running the Script

Execute the script using Node:

node ./main.js

main.js

const https = require("https");
const http = require("http");
const fs = require("fs/promises");

const MAINNET = "https://api.mainnet-beta.solana.com";
const CSV_FILE_NAME = "rpc-nodes.csv";

// Helper function for making POST requests
function postRequest(url, data) {
  return new Promise((resolve, reject) => {
    const urlObj = new URL(url);
    const module = urlObj.protocol === "https:" ? https : http;

    const options = {
      method: "POST",
      headers: {
        "Content-Type": "application/json",
        "Content-Length": Buffer.byteLength(data),
      },
      hostname: urlObj.hostname,
      port: urlObj.port || (urlObj.protocol === "https:" ? 443 : 80),
      path: urlObj.pathname,
    };

    const req = module.request(options, (res) => {
      let body = "";
      res.on("data", (chunk) => {
        body += chunk;
      });
      res.on("end", () => {
        try {
          const json = JSON.parse(body);
          resolve(json);
        } catch (error) {
          reject(error);
        }
      });
    });

    req.on("error", (error) => {
      reject(error);
    });

    req.write(data);
    req.end();
  });
}

// Function to get the list of cluster nodes
async function getClusterNodes() {
  const data = JSON.stringify({
    jsonrpc: "2.0",
    id: 1,
    method: "getClusterNodes",
  });
  const response = await postRequest(MAINNET, data);
  return response.result;
}

// Function to check the health of a node
async function checkHealth(rpcUrl) {
  try {
    const data = JSON.stringify({
      jsonrpc: "2.0",
      id: 1,
      method: "getHealth",
    });
    const response = await postRequest(rpcUrl, data);
    return response.result || response.error?.message || "unknown";
  } catch (e) {
    console.error("> Error:", e.message, "|", rpcUrl);
    return undefined;
  }
}

// Main program logic
(async () => {
  // Get the list of cluster nodes
  const clusterNodes = await getClusterNodes();

  // Filter nodes with RPC and add the main node
  const nodesWithRpc = clusterNodes.filter((node) => !!node.rpc);
  nodesWithRpc.push({ rpc: MAINNET });

  console.log("> Total nodes:", clusterNodes.length);
  console.log("> Found", nodesWithRpc.length, "nodes with RPC");

  // Check the health of each node
  const data = [];
  await Promise.all(
    nodesWithRpc.map(async (node, i) => {
      console.log(`> Connecting to node ${i + 1}/${nodesWithRpc.length}`);
      let rpcUrl = node.rpc;
      if (!rpcUrl.startsWith("http")) {
        rpcUrl = `http://${rpcUrl}`;
      }
      const healthStatus = await checkHealth(rpcUrl);
      if (healthStatus) {
        data.push([rpcUrl, healthStatus]);
      }
    })
  );

  console.log("> Active nodes with RPC:", data.length);

  // Prepare data for CSV
  const CSV_HEADERS = ["rpc_url", "health_status"];
  const CSV_DATA = [
    CSV_HEADERS.join(","),
    ...data
      .sort((a, b) => b[1].localeCompare(a[1]))
      .map((row) => row.join(",")),
  ];

  // Write data to CSV file
  await fs.writeFile(CSV_FILE_NAME, CSV_DATA.join("\n"));
  console.log(`> Saved to ${CSV_FILE_NAME}`);
})();

rpc-nodes.csv