> ## 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. # Отслеживание выпуска токенов Pump.fun с помощью Parsed Streams > Подпишитесь на инструкции create Pump.fun с помощью Helius Parsed Streams и создайте устойчивый к переподключениям слушатель Solana, который регистрирует каждый новый минт токена и его создателя. В этом руководстве мы создадим постоянно работающий слушатель для **каждого нового токена Pump.fun**. Он фильтрует две инструкции, которые Pump.fun использует для запуска токена, и сохраняет подключение при тайм-аутах из-за бездействия и развертываниях. Pump.fun запускает токены с помощью одной из двух инструкций в зависимости от версии: `create` и `create_v2`. Прежде чем фильтровать по ним, подтвердите точные имена и роли аккаунтов с помощью [`describeProgram`](/docs/ru/parsed-streams/quickstart#обнаружение). Сейчас это доступно только в `wss://fs-beta.helius-rpc.com/?api-key=`: ```json Request theme={"system"} { "jsonrpc": "2.0", "id": 1, "method": "describeProgram", "params": [{ "program": "6EF8rrecthR5Dkzon8Nwu78hRvfCKubJ14M5uBEwF6P" }] } ``` Проверьте список `instructions` в ответе на наличие `create` и `create_v2`, а список `roles` — на наличие нужного аккаунта. Обычно это новый адрес **минта**, а также либо роль аккаунта `creator`, либо поле `creator` в `args`. Структуры двух версий инструкции могут различаться, поэтому приведенный ниже код проверяет как аргумент, так и несколько имен ролей, а не полагается только на один вариант. Настройте фильтрацию по программе и обоим именам инструкций. Оставьте `includeCpi` включенным: инструкции `create`/`create_v2` в Pump.fun обычно находятся на верхнем уровне, но такая дополнительная проверка почти ничего не стоит. Также исключите неуспешные транзакции, поскольку неудачное развертывание не создает активный минт: ```json theme={"system"} { "programs": ["6EF8rrecthR5Dkzon8Nwu78hRvfCKubJ14M5uBEwF6P"], "instructionNames": ["create", "create_v2"], "includeFailed": false, "includeCpi": true } ``` Трекер развертываний — это постоянно работающий процесс, поэтому считайте отключения штатной ситуацией, а не исключением: контролируйте первоначальное установление соединения, поддерживайте подключение при отсутствии событий по фильтру и автоматически переподключайтесь после закрытия соединения. ```javascript pumpfun-deploys.js theme={"system"} const API_KEY = process.env.HELIUS_API_KEY; if (!API_KEY) { console.error("Missing HELIUS_API_KEY."); process.exit(1); } const URL = `wss://beta.helius-rpc.com/?api-key=${API_KEY}`; const PUMP_PROGRAM = "6EF8rrecthR5Dkzon8Nwu78hRvfCKubJ14M5uBEwF6P"; const SUBSCRIBE_ID = 1; const SUBSCRIBE_REQUEST = { jsonrpc: "2.0", id: SUBSCRIBE_ID, method: "parsedTransactionSubscribe", params: [ { programs: [PUMP_PROGRAM], instructionNames: ["create", "create_v2"], includeFailed: false, includeCpi: true, }, ], }; const CONNECT_TIMEOUT_MS = 10_000; const ts = () => new Date().toISOString(); function connect() { console.log(`[${ts()}] connecting…`); const ws = new WebSocket(URL); // Watchdog: if the handshake never completes, force-close so we retry // instead of hanging silently in CONNECTING. const connectTimer = setTimeout(() => { if (ws.readyState === WebSocket.CONNECTING) { console.error(`[${ts()}] handshake stalled after ${CONNECT_TIMEOUT_MS}ms — closing`); ws.close(); } }, CONNECT_TIMEOUT_MS); ws.addEventListener("open", () => { clearTimeout(connectTimer); console.log(`[${ts()}] connected, subscribing to pump create/create_v2`); ws.send(JSON.stringify(SUBSCRIBE_REQUEST)); }); ws.addEventListener("message", (event) => handleMessage(event.data)); ws.addEventListener("error", (err) => { console.error(`[${ts()}] socket error:`, err.message || err); }); ws.addEventListener("close", (event) => { clearTimeout(connectTimer); console.log(`[${ts()}] closed (code=${event.code}, reason="${event.reason}"). reconnecting in 3s…`); setTimeout(connect, 3000); }); } connect(); ``` Для простоты здесь используется фиксированная задержка переподключения в 3 секунды. В рабочем слушателе вместо этого применяйте экспоненциальную задержку — см. [Обработка переподключений](/docs/ru/parsed-streams/guides/handling-reconnects). Распределяйте входящие сообщения по `id` (ваши собственные запросы) или `method` (уведомления, отправленные сервером), а затем извлекайте минт, создателя и метаданные из декодированной инструкции: ```javascript theme={"system"} // Pull an account pubkey out of a decoded instruction by its role name. function accountByRole(decoded, role) { return decoded?.accounts?.find((a) => a.name === role)?.pubkey ?? null; } let deployCount = 0; function handleDeploy(tx, ix) { deployCount += 1; const args = ix.decoded?.args ?? {}; const mint = accountByRole(ix.decoded, "mint"); const creator = args.creator ?? accountByRole(ix.decoded, "creator") ?? accountByRole(ix.decoded, "user"); console.log(`[${ts()}] pump deploy #${deployCount} (${ix.instructionName})`); console.log(` mint: ${mint}`); console.log(` creator: ${creator}`); console.log(` name: ${args.name ?? "?"}`); console.log(` symbol: ${args.symbol ?? "?"}`); console.log(` uri: ${args.uri ?? "?"}`); console.log(` slot=${tx.slot} sig=${tx.signature}`); } function handleMessage(raw) { let msg; try { msg = JSON.parse(raw); } catch { console.log(`[${ts()}] non-JSON message:`, raw); return; } if (msg.error) { console.error(`[${ts()}] error (code=${msg.error.code}): ${msg.error.message}`); return; } if (msg.id === SUBSCRIBE_ID && typeof msg.result === "number") { console.log(`[${ts()}] subscribed (subscription id=${msg.result})`); return; } if (msg.method === "parsedTransactionNotification") { const { value } = msg.params.result; // Default details is "full", so value.instructions is the whole // transaction; matchedIndexes points at just the create/create_v2 // instructions this filter hit. for (const i of value.matchedIndexes) handleDeploy(value.transaction, value.instructions[i]); return; } console.log(`[${ts()}] message:`, JSON.stringify(msg, null, 2)); } ``` Поскольку `includeFailed` имеет значение `false`, каждое регистрируемое уведомление соответствует действительно развернутому токену. Прежде чем доверять `args` и `accounts`, убедитесь, что присутствует `ix.decoded`. Нераспознанная сборка программы Pump.fun поступит с `decoded: null` и иначе отобразится как `mint: null`. ## Следующие шаги Более подробное описание процесса describeProgram → создание фильтра → подписка. Экспоненциальная задержка и заполнение пропусков слотов для постоянно работающих слушателей. Исторический вариант: постранично просматривайте прошлые развертывания создателя с помощью Parsed Events. This documentation is built and hosted on [Mintlify](https://mintlify.com), a developer documentation platform.