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

订阅 Pump.fun 曲线账户写入，解码储备与完成标志。先将快速入门中的辅助代码保存为同一目录的 stream.mts。以下示例使用相同的环境变量与依赖。

安装解码器与 IDL

npm install @coral-xyz/anchor @solana/web3.js
curl -L https://docs.solanatracker.io/idl/pump.json -o pump.json

此示例使用配套 Pump.fun IDL，从中读取程序地址、判别符与字段名称。更新 IDL 时需检查兼容性。

解码更新

pump-accounts.mts

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);
  }
}

npx tsx pump-accounts.mts

读取储备并保留精度

示例将原始储备整数输出为字符串。显示金额需要代币与报价 mint 的精度。原始储备比率不是 SOL/代币价格，quote_mint 也不一定为 SOL。格式化价格前先查询 mint 数据。

处理布局变化

判别符筛选无需假设账户总大小。解码错误会记录输出，不会静默丢弃更新。曲线完成并不包含迁移后完整池状态；新池数据请使用 PumpSwap 参考或 Data API。

相关指南

Pump.fun 交易

可靠性与性能