Documentation Index
Fetch the complete documentation index at: https://www.helius.dev/docs/llms.txt
Use this file to discover all available pages before exploring further.
使用 LaserStream SDK 实时流传每一个 Pump.fun 账户更新和交易。本页面提供一个完整的 TypeScript 脚本，您可以从头到尾运行：它在每笔交易到达时打印信息，每分钟报告滚动统计（吞吐量、唯一费用支付者、Sol 中的总费用），并在重连时自动保持连接。
这是对任何需要持续 Pump.fun 可见性项目的有用起点——交易机器人、分析仪表板、警报管道，或者只是探索数据形态以便您在其基础上构建更专业的东西。
创建一个新项目，安装 SDK + bs58（用于解码交易签名），并设置您的 API 密钥：
mkdir pump-monitor && cd pump-monitor
npm init -y
npm install helius-laserstream bs58
npm install --save-dev typescript ts-node @types/node
npx tsc --init
export HELIUS_API_KEY=your-key-here
将其另存为 index.ts，然后运行 npx ts-node index.ts：
import { subscribe, CommitmentLevel, LaserstreamConfig, SubscribeRequest } from 'helius-laserstream';
import bs58 from 'bs58';
const PUMP_PROGRAM_ID = '6EF8rrecthR5Dkzon8Nwu78hRvfCKubJ14M5uBEwF6P';
// Rolling stats across the session.
const stats = {
startedAt: Date.now(),
transactions: 0,
successes: 0,
failures: 0,
uniquePayers: new Set<string>(),
totalFeesLamports: 0,
accountUpdates: 0,
};
async function handleUpdate(data: any) {
if (data.transaction) {
const tx = data.transaction.transaction;
if (!tx) return;
stats.transactions++;
const failed = !!tx.meta?.err;
failed ? stats.failures++ : stats.successes++;
// tx.meta.fee is a u64 string — coerce before adding.
stats.totalFeesLamports += Number(tx.meta?.fee ?? 0);
// Fee payer is the first account in the message.
const firstKey = tx.transaction?.message?.accountKeys?.[0];
if (firstKey) {
const payer = typeof firstKey === 'string' ? firstKey : bs58.encode(firstKey);
stats.uniquePayers.add(payer);
}
// tx.signature is a Buffer in the SDK.
const sig = bs58.encode(tx.signature);
const slot = data.transaction.slot;
const flag = failed ? '❌' : '✅';
console.log(`${flag} ${sig.slice(0, 12)}… slot ${slot} fee ${tx.meta?.fee} lamports`);
}
if (data.account) {
stats.accountUpdates++;
const acct = data.account.account;
const pubkey = typeof acct.pubkey === 'string' ? acct.pubkey : bs58.encode(acct.pubkey);
console.log(`📋 account ${pubkey} ${acct.data?.length ?? 0} bytes`);
}
}
function printReport() {
const minutes = (Date.now() - stats.startedAt) / 60_000;
console.log('\n📊 Pump.fun activity report');
console.log(` Runtime: ${minutes.toFixed(1)} min`);
console.log(` Transactions: ${stats.transactions} (${stats.successes} ok, ${stats.failures} failed)`);
console.log(` Throughput: ${(stats.transactions / Math.max(minutes, 0.0001)).toFixed(1)} tx/min`);
console.log(` Unique fee payers: ${stats.uniquePayers.size}`);
console.log(` Total fees: ${(stats.totalFeesLamports / 1e9).toFixed(4)} SOL`);
console.log(` Account updates: ${stats.accountUpdates}\n`);
}
async function main() {
const config: LaserstreamConfig = {
apiKey: process.env.HELIUS_API_KEY ?? 'YOUR_API_KEY',
endpoint: 'https://laserstream-mainnet-ewr.helius-rpc.com', // pick the region closest to you
};
const subscriptionRequest: SubscribeRequest = {
accounts: {
'pump-accounts': {
account: [],
owner: [PUMP_PROGRAM_ID],
filters: [],
},
},
transactions: {
'pump-transactions': {
accountInclude: [PUMP_PROGRAM_ID],
accountExclude: [],
accountRequired: [],
vote: false,
failed: false,
},
},
commitment: CommitmentLevel.CONFIRMED,
slots: {},
transactionsStatus: {},
blocks: {},
blocksMeta: {},
entry: {},
accountsDataSlice: [],
};
console.log('🚀 Streaming Pump.fun activity. Press Ctrl+C to stop.\n');
const reportTimer = setInterval(printReport, 60_000);
process.on('SIGINT', () => {
clearInterval(reportTimer);
printReport();
process.exit(0);
});
await subscribe(config, subscriptionRequest, handleUpdate, async (error) => {
console.error('Stream error:', error);
});
}
main().catch(console.error);
脚本的功能
一个订阅，两个过滤块
一个 subscribe(...) 调用包含两个命名的过滤组：
accounts 过滤接收每当数据变化时 Pump.fun 程序拥有的每个账户（债券曲线、铸造状态等）。transactions 过滤接收每个与 Pump.fun 程序交互的交易。 vote: false, failed: false 标记在到达您的处理程序之前删除投票和失败的交易。
两者通过单个 gRPC 流到达，因此 SDK 只需管理一个连接。如果连接断开，SDK 会自动重新连接，您将继续从两个过滤器接收更新。
读取原始字段
负载中的几个值需要进行小的转换，以便于使用：
tx.signature 是一个 Buffer。通过 bs58.encode(...) 运行它，以获得在资源管理器或 getTransaction 响应中看到的 base58 签名。tx.meta.fee 是一个以字符串存储的 u64，以确保在 JavaScript 中不会丢失 Number.MAX_SAFE_INTEGER 以上的精度。在进行算术运算之前，将其包裹在 Number(...) 中。同样的 u64 字符串约定也适用于多个区块级字段 — 请参阅 Slot & Block Monitoring 以了解完整的数据结构。
滚动统计
setInterval 每 60 秒打印一次快照：总交易数、成功与失败、吞吐量、唯一费用支付者和 SOL 中的总费用。在脚本退出之前按下 Ctrl+C 可获得最后一次快照。
扩展脚本
一些进一步发展的方向：
后续步骤
解码交易数据
将二进制交易负载解析为可读的Solana交易。
历史重放
从起始槽重放过去最多24小时的Pump.fun活动。
