通过 Yellowstone gRPC 解码 Pump.fun 曲线账户

import { readFileSync } from "node:fs";
import { BorshAccountsCoder, type Idl } from "@coral-xyz/anchor";
import bs58 from "bs58";
import { subscribe } from "./stream.mts";

const idl = JSON.parse(readFileSync("pump.json", "utf8")) as Idl;
const coder = new BorshAccountsCoder(idl);
const definition = idl.accounts?.find(account => account.name === "BondingCurve");
if (!definition) throw new Error("BondingCurve is missing from the IDL");
const discriminator = Buffer.from(definition.discriminator);

for await (const update of subscribe({
  accounts: {
    curves: {
      account: [], owner: [idl.address],
      filters: [{ memcmp: { offset: "0", bytes: discriminator } }],
    },
  },
})) {
  const account = update.account?.account;
  if (!account) continue;
  try {
    const curve = coder.decode("BondingCurve", Buffer.from(account.data));
    console.log({
      address: bs58.encode(account.pubkey),
      slot: update.account!.slot,
      complete: curve.complete,
      quoteMint: curve.quote_mint.toString(),
      virtualTokenReserves: curve.virtual_token_reserves.toString(),
      virtualQuoteReserves: curve.virtual_quote_reserves.toString(),
    });
  } catch (error) {
    console.error("Bonding curve decode failed; check IDL compatibility", error);
  }
}