处理 Yellowstone gRPC 重连与流量

import { setTimeout as delay } from "node:timers/promises";
import { subscribe } from "./stream.mts";

let retry = 0;
while (retry < 8) {
  try {
    for await (const update of subscribe({ blocksMeta: { blocks: {} } })) {
      if (update.blockMeta) console.log(update.blockMeta.slot);
    }
    console.error("Stream ended");
  } catch (error) {
    console.error("Stream failed", error);
  }
  retry += 1;
  const waitMs = Math.min(30_000, 500 * 2 ** retry) + Math.random() * 500;
  await delay(waitMs);
}
throw new Error("Reconnect budget exhausted");