reth.js

const pty = require("node-pty");
const fs = require("fs");
const path = require("path");
const os = require("os");

const installDir = process.env.INSTALL_DIR || os.homedir();

const jwtPath = path.join(os.homedir(), "bgnode", "jwt", "jwt.hex");

let rethCommand;
const platform = os.platform();
if (["darwin", "linux"].includes(platform)) {
  rethCommand = path.join(os.homedir(), "bgnode", "reth", "reth");
} else if (platform === "win32") {
  rethCommand = path.join(os.homedir(), "bgnode", "reth", "reth.exe");
}

const logFilePath = path.join(
  os.homedir(),
  "bgnode",
  "reth",
  "logs",
  `reth_${getFormattedDateTime()}.log`
);

const logStream = fs.createWriteStream(logFilePath, { flags: "a" });

function stripAnsiCodes(input) {
  return input.replace(
    /[\u001b\u009b][[()#;?]*(?:(?:[a-zA-Z\d]*(?:;[a-zA-Z\d]*)*)?\u0007|(?:\d{1,4}(?:;\d{0,4})*)?[0-9A-ORZcf-nq-uy=><~])/g,
    ""
  );
}

const execution = pty.spawn(
  `${rethCommand}`,
  [
    "node",
    "--http",
    "--http.addr",
    "0.0.0.0",
    "--http.api",
    // "trace,web3,eth,debug",
    // "trace,web3,eth,debug,net",
    "debug,eth,net,trace,txpool,web3,rpc",
    "--ws",
    "--ws.api",
    "trace,web3,eth,debug",
    "--authrpc.addr",
    "127.0.0.1",
    "--authrpc.port",
    "8551",
    "--datadir",
    path.join(os.homedir(), "bgnode", "reth", "database"),
    "--authrpc.jwtsecret",
    `${jwtPath}`,
  ],
  {
    name: "xterm-color",
    cols: 80,
    rows: 30,
    cwd: process.env.HOME,
    env: { ...process.env, INSTALL_DIR: installDir },
  }
);

// Pipe stdout and stderr to the log file and to the parent process
execution.on("data", (data) => {
  logStream.write(stripAnsiCodes(data));
  if (process.send) {
    process.send({ log: data });
  }
  process.stdout.write(data); // Also log to console for real-time feedback
});

execution.on("exit", (code) => {
  const exitMessage = `geth process exited with code ${code}`;
  logStream.write(exitMessage);
  logStream.end();
});

execution.on("error", (err) => {
  const errorMessage = `Error: ${err.message}`;
  logStream.write(errorMessage);
  if (process.send) {
    process.send({ log: errorMessage }); // Send error message to parent process
  }
  console.error(errorMessage); // Log error message to console
});

function getFormattedDateTime() {
  const now = new Date();
  return now.toISOString().replace(/T/, "_").replace(/\..+/, "");
}

process.on("SIGINT", () => {
  execution.kill("SIGINT");
});