event-streaming

Use this skill any time you're building or debugging realtime event flows in PumpKit — WebSocket subscriptions to pump.fun events, SSE fan-out to clients, decoder pipelines, reconnect-with-replay, multi-provider quorum streams. Triggers on "logsSubscribe", "programSubscribe", "accountSubscribe", "SSE", "event monitor", "websocket dropped events", "channel bot feed". Skip for one-shot reads (use [inspect-curve](../../commands/inspect-curve.md) or `getAccountInfo` directly).

Ir para a instalação

Repositório: nirholas/pumpkit
Última atividade na origem: 21 de maio de 2026 às 08:50
Idioma detectado do SKILL.md: inglês
Estrelas: 19
Forks: 2

Opções de instalação

Por padrão, está selecionado o prompt que primeiro revisa a origem. Você pode mudar para um comando direto ou baixar uma cópia local.

Instalar com Codex ou Claude Copie este prompt, cole no Codex, Claude ou outro assistente e deixe que ele revise a página da skill e instale para você.

Um comando direto ignora o prompt de revisão. Verifique a origem antes de executá-lo.

npx skills add https://github.com/nirholas/pumpkit --skill event-streaming

O comando permanece em uma só linha. Role horizontalmente para revisá-lo antes de copiar.

Prefere uma cópia local? Baixe os arquivos disponíveis atualmente no SkillsMP.

Revise os arquivos de origem

Leia o SKILL.md e os arquivos complementares exibidos pelo SkillsMP antes de decidir se vai instalar.

SKILL.md

Instruções da origem · Visualização somente leitura

Voltar à pesquisa Voltar à instalação

Event streaming for PumpKit

This skill is the project-specific reference for ingesting pump.fun events in realtime and reliably fanning them out to downstream consumers (channel bot, dashboard, claim tracker, analytics).

The shape of a streaming pipeline

┌──────────────┐ ┌────────────────┐ ┌───────────┐ ┌──────────┐ │ Solana RPC │ WS │ Resilient WS │ │ Typed │ │ Fan-out │ │ (streamer ├─────▶│ adapter ├─────▶│ decoder ├─────▶│ (SSE / │ │ pool) │ │ - heartbeat │ │ (SDK) │ │ bot / │ │ │ │ - reconnect │ │ │ │ store) │ └──────────────┘ │ - replay │ └───────────┘ └──────────┘ └────────────────┘

Each box has a distinct failure mode and a distinct test surface. Conflate them and you get bugs that only surface in prod.

Subscription types

Subscription

Use for

Trade-off

logsSubscribe(programId)

Every event from a program (firehose)

Highest volume; need to filter downstream

programSubscribe(programId, filters)

Account-change stream filtered server-side

Cheaper, but less flexible than logs

accountSubscribe(pda)

One account's state changes

Event streaming for PumpKit

This skill is the project-specific reference for ingesting pump.fun events in realtime and reliably fanning them out to downstream consumers (channel bot, dashboard, claim tracker, analytics).

The shape of a streaming pipeline

Each box has a distinct failure mode and a distinct test surface. Conflate them and you get bugs that only surface in prod.

Subscription types

Subscription

Use for

Trade-off

logsSubscribe(programId)

Every event from a program (firehose)

Highest volume; need to filter downstream

programSubscribe(programId, filters)

Account-change stream filtered server-side

Cheaper, but less flexible than logs

accountSubscribe(pda)

One account's state changes

export class ResilientLogStream { private lastSlot = 0; private seen = new Set<string>(); // recent signatures, capped LRU private ws?: WebSocket; private subId?: number; private hbTimer?: NodeJS.Timeout; constructor( private urls: string[], private programId: PublicKey, private onLog: (l: { signature: string; slot: number; logs: string[] }) => void, ) {} start() { this.connect(this.urls[0]); } private connect(url: string) { const ws = new WebSocket(url); this.ws = ws; ws.onopen = () => { ws.send(JSON.stringify({ jsonrpc: '2.0', id: 1, method: 'logsSubscribe', params: [{ mentions: [this.programId.toBase58()] }, { commitment: 'confirmed' }], })); this.hbTimer = setInterval(() => this.heartbeat(), 20_000); }; ws.onmessage = (m) => this.handle(JSON.parse(m.data as string)); ws.onclose = () => { clearInterval(this.hbTimer!); const next = this.urls[(this.urls.indexOf(url) + 1) % this.urls.length]; this.replayMissed().catch(() => {}); setTimeout(() => this.connect(next), 1_000); }; ws.onerror = () => ws.close(); } private heartbeat() { this.ws?.send(JSON.stringify({ jsonrpc: '2.0', id: 99, method: 'getHealth' })); } private handle(msg: { method?: string; params?: { result?: { value?: { signature?: string; slot?: number; logs?: string[] } } } }) { if (msg.method !== 'logsNotification') return; const v = msg.params?.result?.value; if (!v?.signature || v.slot === undefined || !v.logs) return; if (this.seen.has(v.signature)) return; this.seen.add(v.signature); if (this.seen.size > 5000) { // Trim oldest — Set preserves insertion order const drop = [...this.seen].slice(0, 1000); drop.forEach(s => this.seen.delete(s)); } this.lastSlot = Math.max(this.lastSlot, v.slot); this.onLog({ signature: v.signature, slot: v.slot, logs: v.logs }); } private async replayMissed() { if (!this.lastSlot) return; const conn = new Connection(this.urls[0], 'confirmed'); const sigs = await conn.getSignaturesForAddress(this.programId, { limit: 200 }); for (const { signature, slot } of sigs.reverse()) { if (slot && slot <= this.lastSlot) continue; const tx = await conn.getTransaction(signature, { commitment: 'confirmed', maxSupportedTransactionVersion: 0 }); if (!tx || !tx.meta?.logMessages) continue; if (this.seen.has(signature)) continue; this.seen.add(signature); this.onLog({ signature, slot: slot!, logs: tx.meta.logMessages }); } } }

event-streaming

Opções de instalação

Revise os arquivos de origem

Event streaming for PumpKit

The shape of a streaming pipeline

Subscription types

Event streaming for PumpKit

The shape of a streaming pipeline

Subscription types

Resilient WebSocket pattern

Decoder pipeline

SSE fan-out

Quorum streaming (for critical feeds)

Observability

Common pitfalls

See also

event-streaming

Informações da origem

Opções de instalação

Revise os arquivos de origem

Mais deste repositório

Mais deste repositório

Event streaming for PumpKit

The shape of a streaming pipeline

Subscription types

Event streaming for PumpKit

The shape of a streaming pipeline

Subscription types

Resilient WebSocket pattern

Decoder pipeline

SSE fan-out

Quorum streaming (for critical feeds)

Observability

Common pitfalls

See also