Мониторинг транзакций

Мониторинг транзакций позволяет в реальном времени отслеживать выполнение транзакций, их успешное или неуспешное завершение, взаимодействия с программами и изменения балансов токенов в Solana. В этом руководстве рассматриваются стратегии фильтрации и практические реализации с использованием SDK helius-laserstream.

Предварительные требования: в этом руководстве предполагается, что вы выполнили инструкции из краткого руководства по LaserStream gRPC и получили ключ API.

Параметры фильтрации транзакций

LaserStream использует ту же структуру фильтров, что и Yellowstone gRPC, включая фильтр tokenAccounts (расширение ATA). Внутри transactions.<label> можно задать следующие поля:

accountInclude — совпадение, если присутствует любой из этих аккаунтов (логическое ИЛИ)
accountRequired — совпадение, только если присутствуют все эти аккаунты (логическое И)
accountExclude — исключение, если присутствует любой из этих аккаунтов
vote / failed — логические флаги для транзакций голосования и неуспешных транзакций
tokenAccounts — необязательное расширение связанного токен-аккаунта (ATA) ("balanceChanged", "all" или "none"), благодаря которому кошелек в accountInclude также соответствует транзакциям, где он владеет балансом SPL-токена. См. раздел Фильтрация токен-аккаунтов (ATA) и вкладку Watching a Wallet ниже.
matchMints — необязательный флаг, который также сопоставляет списки аккаунтов с минтами в балансах токенов до и после транзакции. Благодаря этому минт в accountInclude позволяет отследить каждый перевод, обмен, выпуск и сжигание этого токена. См. раздел Фильтрация по минту токена и вкладку Watching a Token ниже.

Program Filtering
Account-Specific
Advanced Filtering
Watching a Wallet
Watching a Token

Отслеживайте транзакции с участием определенных программОтслеживайте все транзакции, затрагивающие интересующие вас программы:

import { subscribe, CommitmentLevel, LaserstreamConfig, SubscribeRequest } from 'helius-laserstream';

const subscriptionRequest: SubscribeRequest = {
  transactions: {
    "program-filter": {
      accountInclude: [
        "TokenkegQfeZyiNwAJbNbGKPFXCWuBvf9Ss623VQ5DA", // Token Program
        "11111111111111111111111111111111",              // System Program
        "675kPX9MHTjS2zt1qfr1NYHuzeLXfQM9H24wFSUt1Mp8"  // Your program
      ],
      accountExclude: [],
      accountRequired: [],
      vote: false,
      failed: false
    }
  },
  commitment: CommitmentLevel.CONFIRMED,
  accounts: {},
  slots: {},
  transactionsStatus: {},
  blocks: {},
  blocksMeta: {},
  entry: {},
  accountsDataSlice: [],
};

Лучше всего подходит для: мониторинга конкретных программ, отслеживания протоколов DeFi и взаимодействий со смарт-контрактами.

Отслеживайте транзакции, затрагивающие определенные аккаунты

const subscriptionRequest: SubscribeRequest = {
  transactions: {
    "wallet-filter": {
      accountInclude: [
        "EPjFWdd5AufqSSqeM2qN1xzybapC8G4wEGGkZwyTDt1v", // USDC mint
        "YourWalletAddress"                                // Your wallet
      ],
      accountExclude: [],
      accountRequired: [],
      vote: false,
      failed: true // Include failures to track errors
    }
  },
  commitment: CommitmentLevel.CONFIRMED,
  accounts: {}, slots: {}, transactionsStatus: {},
  blocks: {}, blocksMeta: {}, entry: {}, accountsDataSlice: [],
};

Сценарий использования: мониторинг кошельков, отслеживание минтов токенов и панели активности аккаунтов.

Объединяйте несколько критериев фильтрации

const subscriptionRequest: SubscribeRequest = {
  transactions: {
    "advanced-filter": {
      accountInclude: ["TokenkegQfeZyiNwAJbNbGKPFXCWuBvf9Ss623VQ5DA"],
      accountRequired: ["YourProgramId"], // Must include this program
      accountExclude: ["VoteProgram"],     // Exclude vote-related txs
      vote: false,
      failed: false
    }
  },
  commitment: CommitmentLevel.CONFIRMED,
  accounts: {}, slots: {}, transactionsStatus: {},
  blocks: {}, blocksMeta: {}, entry: {}, accountsDataSlice: [],
};

Логика фильтра: accountInclude (ИЛИ) И accountRequired (И) И НЕ accountExclude.

Отслеживайте входящие переводы токенов, а не только прямую активностьaccountInclude соответствует только транзакциям, в которых кошелек непосредственно указан среди ключей аккаунтов. Когда кто-либо отправляет на кошелек SPL-токен, перевод затрагивает связанный токен-аккаунт (ATA) кошелька, а не публичный ключ кошелька, поэтому обычный accountInclude: [wallet] его не обнаруживает.Задайте tokenAccounts, чтобы сопоставление также охватывало транзакции, в которых кошелек владеет балансом токена. Поле принимает строку:

"balanceChanged" — совпадение, когда изменился баланс принадлежащего кошельку токена или был закрыт его токен-аккаунт. Лучше всего подходит для сценария «сообщить, когда средства действительно переместились»: более узкий фильтр, меньший объем данных и рекомендуемый вариант по умолчанию.
"all" — совпадение с любой транзакцией, которая ссылается на баланс принадлежащего кошельку токена, даже если он не изменился. Объем данных значительно выше.
"none" — без расширения (то же самое, что не указывать поле).

const subscriptionRequest: SubscribeRequest = {
  transactions: {
    "wallet-with-tokens": {
      accountInclude: ["YourWalletAddress"],
      accountExclude: [],
      accountRequired: [],
      vote: false,
      failed: false,
      tokenAccounts: "balanceChanged" // also match the wallet's ATAs
    }
  },
  commitment: CommitmentLevel.CONFIRMED,
  accounts: {}, slots: {}, transactionsStatus: {},
  blocks: {}, blocksMeta: {}, entry: {}, accountsDataSlice: [],
};

Сопоставление выполняется по владельцу: оно охватывает любой принадлежащий кошельку токен-аккаунт, включая неканонические, а не только производный адрес ATA. SDK автоматически преобразует строку в перечисление TokenAccountExpansionControlFlag уровня протокола.

Отслеживайте каждую транзакцию для минта, а не только транзакции, где он указан явноОбычный accountInclude: [mint] соответствует только транзакциям, в ключах аккаунтов которых присутствует минт, например MintTo, Burn или TransferChecked. Классический SPL Transfer никогда не ссылается на минт, поэтому большинство переводов токена пропускается.Задайте matchMints: true, чтобы списки аккаунтов также сопоставлялись с минтами в preTokenBalances и postTokenBalances транзакции:

const USDC = 'EPjFWdd5AufqSSqeM2qN1xzybapC8G4wEGGkZwyTDt1v';

const subscriptionRequest: SubscribeRequest = {
  transactions: {
    "usdc-activity": {
      accountInclude: [USDC],
      accountExclude: [],
      accountRequired: [],
      vote: false,
      failed: false,
      matchMints: true // also match via pre/post token-balance mints
    }
  },
  commitment: CommitmentLevel.CONFIRMED,
  accounts: {}, slots: {}, transactionsStatus: {},
  blocks: {}, blocksMeta: {}, entry: {}, accountsDataSlice: [],
};

Объедините этот параметр с tokenAccounts, чтобы отслеживать один токен для одного кошелька: поместите кошелек в accountInclude с tokenAccounts: "balanceChanged", а минт — в accountRequired с matchMints: true. Требуется helius-laserstream 0.8.5+ (JS), 0.6.4+ (Rust) или go/v0.3.0+ (Go). Полное описание семантики см. в разделе Фильтрация по минту токена.

Практические примеры

Пример 1. Мониторинг транзакций DEX

Отслеживайте транзакции, затрагивающие популярные программы DEX:

import { subscribe, CommitmentLevel, LaserstreamConfig, SubscribeRequest } from 'helius-laserstream';
import bs58 from 'bs58';

async function monitorDEXTransactions() {
  const subscriptionRequest: SubscribeRequest = {
    transactions: {
      "dex-filter": {
        accountInclude: [
          "675kPX9MHTjS2zt1qfr1NYHuzeLXfQM9H24wFSUt1Mp8", // Raydium
          "CAMMCzo5YL8w4VFF8KVHrK22GGUsp5VTaW7grrKgrWqK", // Raydium CLMM
          "JUP6LkbZbjS1jKKwapdHNy74zcZ3tLUZoi5QNyVTaV4"   // Jupiter
        ],
        accountExclude: [],
        accountRequired: [],
        vote: false,
        failed: false
      }
    },
    commitment: CommitmentLevel.CONFIRMED,
    accounts: {}, slots: {}, transactionsStatus: {},
    blocks: {}, blocksMeta: {}, entry: {}, accountsDataSlice: [],
  };

  const config: LaserstreamConfig = {
    apiKey: 'YOUR_API_KEY',
    endpoint: 'https://laserstream-mainnet-ewr.helius-rpc.com', // Choose your closest region
  };

  await subscribe(config, subscriptionRequest, async (data) => {
    if (!data.transaction?.transaction) return;
    const tx = data.transaction.transaction;
    console.log(`\n🔄 DEX Transaction:`);
    console.log(`  Signature: ${bs58.encode(tx.signature)}`);
    console.log(`  Slot: ${data.transaction.slot}`);
    console.log(`  Status: ${tx.meta?.err ? 'Failed' : 'Success'}`);
    console.log(`  Fee: ${tx.meta?.fee || 0} lamports`);
    console.log(`  Compute Units: ${tx.meta?.computeUnitsConsumed || 0}`);

    // Token balance changes
    if (tx.meta?.preTokenBalances?.length > 0) {
      console.log(`  Token Balance Changes:`);
      tx.meta.preTokenBalances.forEach((preBalance: any, index: number) => {
        const postBalance = tx.meta.postTokenBalances[index];
        if (preBalance && postBalance) {
          const change = postBalance.uiTokenAmount.uiAmount - preBalance.uiTokenAmount.uiAmount;
          if (change !== 0) {
            console.log(`    ${preBalance.mint}: ${change > 0 ? '+' : ''}${change}`);
          }
        }
      });
    }
  }, async (error) => {
    console.error('Stream error:', error);
  });
}

monitorDEXTransactions().catch(console.error);

Пример 2. Мониторинг неуспешных транзакций

Отслеживайте неуспешные транзакции, чтобы выявлять проблемы в приложении:

async function monitorFailedTransactions() {
  const subscriptionRequest: SubscribeRequest = {
    transactions: {
      "failures": {
        accountInclude: ["YourProgramId"],
        accountExclude: [],
        accountRequired: [],
        vote: false,
        failed: true // Only failed transactions
      }
    },
    commitment: CommitmentLevel.CONFIRMED,
    accounts: {}, slots: {}, transactionsStatus: {},
    blocks: {}, blocksMeta: {}, entry: {}, accountsDataSlice: [],
  };

  const config: LaserstreamConfig = {
    apiKey: 'YOUR_API_KEY',
    endpoint: 'https://laserstream-mainnet-ewr.helius-rpc.com',
  };

  await subscribe(config, subscriptionRequest, async (data) => {
    if (!data.transaction?.transaction?.meta?.err) return;
    const tx = data.transaction.transaction;
    console.log(`\n❌ Failed Transaction:`);
    console.log(`  Signature: ${bs58.encode(tx.signature)}`);
    console.log(`  Slot: ${data.transaction.slot}`);
    console.log(`  Error: ${JSON.stringify(tx.meta.err)}`);
    console.log(`  Fee: ${tx.meta.fee} lamports`);
    console.log(`  Compute Units: ${tx.meta.computeUnitsConsumed || 0}`);
  }, async (error) => {
    console.error('Stream error:', error);
  });
}

Пример 3. Мониторинг крупных транзакций

Отслеживайте транзакции со значительными переводами SOL:

async function monitorHighValueTransactions() {
  const subscriptionRequest: SubscribeRequest = {
    transactions: {
      "system-program": {
        accountInclude: ["11111111111111111111111111111111"],
        accountExclude: [],
        accountRequired: [],
        vote: false,
        failed: false
      }
    },
    commitment: CommitmentLevel.CONFIRMED,
    accounts: {}, slots: {}, transactionsStatus: {},
    blocks: {}, blocksMeta: {}, entry: {}, accountsDataSlice: [],
  };

  const config: LaserstreamConfig = {
    apiKey: 'YOUR_API_KEY',
    endpoint: 'https://laserstream-mainnet-ewr.helius-rpc.com',
  };

  await subscribe(config, subscriptionRequest, async (data) => {
    if (!data.transaction?.transaction?.meta) return;
    const tx = data.transaction.transaction;
    const preBalances = tx.meta.preBalances || [];
    const postBalances = tx.meta.postBalances || [];

    let maxChange = 0;
    preBalances.forEach((preBalance: number, index: number) => {
      const postBalance = postBalances[index] || 0;
      maxChange = Math.max(maxChange, Math.abs(postBalance - preBalance));
    });

    const changeInSOL = maxChange / 1e9;
    if (changeInSOL > 10) {
      console.log(`\n💰 High-Value Transaction:`);
      console.log(`  Signature: ${bs58.encode(tx.signature)}`);
      console.log(`  Slot: ${data.transaction.slot}`);
      console.log(`  Max SOL Transfer: ${changeInSOL.toFixed(2)} SOL`);
      console.log(`  Fee: ${tx.meta.fee / 1e9} SOL`);
    }
  }, async (error) => {
    console.error('Stream error:', error);
  });
}

Пример 4. Отслеживание кошелька, включая переводы токенов

Отслеживайте все перемещения средств для кошелька, включая входящие переводы SPL-токенов, затрагивающие его ATA. Для этого добавьте tokenAccounts в обычный фильтр accountInclude:

import { subscribe, CommitmentLevel, LaserstreamConfig, SubscribeRequest } from 'helius-laserstream';
import bs58 from 'bs58';

async function watchWallet(wallet: string) {
  const subscriptionRequest: SubscribeRequest = {
    transactions: {
      "wallet-activity": {
        accountInclude: [wallet],
        accountExclude: [],
        accountRequired: [],
        vote: false,
        failed: false,
        // Also match txs touching token accounts this wallet owns.
        // "balanceChanged" = only when an owned token balance actually moved.
        tokenAccounts: "balanceChanged"
      }
    },
    commitment: CommitmentLevel.CONFIRMED,
    accounts: {}, slots: {}, transactionsStatus: {},
    blocks: {}, blocksMeta: {}, entry: {}, accountsDataSlice: [],
  };

  const config: LaserstreamConfig = {
    apiKey: 'YOUR_API_KEY',
    endpoint: 'https://laserstream-mainnet-ewr.helius-rpc.com',
  };

  await subscribe(config, subscriptionRequest, async (data) => {
    if (!data.transaction?.transaction) return;
    const tx = data.transaction.transaction;
    console.log(`\n👛 Wallet activity:`);
    console.log(`  Signature: ${bs58.encode(tx.signature)}`);
    console.log(`  Slot: ${data.transaction.slot}`);

    // Surface token balances this wallet owns that changed in the tx
    const owned = (tx.meta?.postTokenBalances || []).filter((b: any) => b.owner === wallet);
    owned.forEach((post: any) => {
      const pre = (tx.meta.preTokenBalances || []).find(
        (b: any) => b.accountIndex === post.accountIndex
      );
      const before = pre?.uiTokenAmount?.uiAmount || 0;
      const after = post.uiTokenAmount?.uiAmount || 0;
      if (after !== before) {
        console.log(`  ${post.mint}: ${after - before > 0 ? '+' : ''}${after - before}`);
      }
    });
  }, async (error) => {
    console.error('Stream error:', error);
  });
}

Структура данных транзакции

Transaction Message Structure

{
  signature: string;
  isVote: boolean;
  transaction: {
    message: {
      accountKeys: string[];        // All accounts involved
      instructions: Instruction[];  // Program instructions
      recentBlockhash: string;
    };
    signatures: string[];
  };
  meta: {
    err: any;                      // Error details if failed
    fee: number;                   // Transaction fee in lamports
    computeUnitsConsumed: number;
    preBalances: number[];
    postBalances: number[];
    preTokenBalances: TokenBalance[];
    postTokenBalances: TokenBalance[];
    logMessages: string[];
  };
}

Token Balance Changes

{
  accountIndex: number;
  mint: string;
  owner: string;
  uiTokenAmount: {
    amount: string;
    decimals: number;
    uiAmount: number;
    uiAmountString: string;
  };
}

Instruction Details

{
  programIdIndex: number; // Index in accountKeys array
  accounts: number[];
  data: string;           // Instruction data (base58)
}

Справочник по логике фильтров

Include Logic (OR)

accountInclude: транзакция должна включать ЛЮБОЙ из этих аккаунтов.["A", "B"] соответствует транзакциям с участием аккаунта A ИЛИ аккаунта B.

Required Logic (AND)

accountRequired: транзакция должна включать ВСЕ эти аккаунты.["A", "B"] соответствует транзакциям с участием аккаунта A И аккаунта B.

Exclude Logic (NOT)

accountExclude: транзакция НЕ должна включать ни один из этих аккаунтов.

Combined Logic

Итоговый фильтр: (accountInclude OR empty) AND (accountRequired AND all) AND NOT (accountExclude OR any).

Обработка ошибок

Too Many Transactions

Симптом: чрезмерный объем транзакций.Решения: добавьте более строгие фильтры (accountRequired, accountExclude); используйте более высокий уровень подтверждения; реализуйте выборку или ограничение частоты запросов; обрабатывайте данные асинхронно.

Missing Transactions

Симптом: ожидаемые транзакции не появляются.Решения: убедитесь, что адреса программ указаны правильно; проверьте, что транзакции действительно существуют; попробуйте processed для более быстрых обновлений; ослабьте строгие фильтры accountRequired/accountExclude.

Parse Errors

Симптом: не удается разобрать данные транзакции.Решения: корректно обрабатывайте отсутствующие поля; проверяйте структуру перед обработкой; оборачивайте разбор в try/catch; см. раздел Декодирование данных транзакций.

Дальнейшие действия

Slot & Block Monitoring

Отслеживайте консенсус сети и создание блоков.

Stream Pump AMM Data

Практический пример: мониторинг транзакций AMM Pump.fun.

Decoding Transaction Data

Преобразуйте двоичные полезные нагрузки транзакций в читаемые транзакции Solana.

Yellowstone protocol reference

Тот же рабочий процесс с использованием необработанного протокола Yellowstone gRPC.

Начните здесь

Данные в реальном времени

Торговля с низкой задержкой

Исторические данные и данные кошельков

Руководства по методам RPC

Готовность к эксплуатации

Использование Orb

Другие инструкции

Мониторинг транзакций с помощью LaserStream

Параметры фильтрации транзакций

Практические примеры

Пример 1. Мониторинг транзакций DEX

Пример 2. Мониторинг неуспешных транзакций

Пример 3. Мониторинг крупных транзакций

Пример 4. Отслеживание кошелька, включая переводы токенов

Структура данных транзакции

Справочник по логике фильтров

Include Logic (OR)

Required Logic (AND)

Exclude Logic (NOT)

Combined Logic

Рекомендации по производительности

Обработка ошибок

Дальнейшие действия

Slot & Block Monitoring

Stream Pump AMM Data

Decoding Transaction Data

Yellowstone protocol reference

​Параметры фильтрации транзакций

​Практические примеры

​Пример 1. Мониторинг транзакций DEX

​Пример 2. Мониторинг неуспешных транзакций

​Пример 3. Мониторинг крупных транзакций

​Пример 4. Отслеживание кошелька, включая переводы токенов

​Структура данных транзакции

​Справочник по логике фильтров

Include Logic (OR)

Required Logic (AND)

Exclude Logic (NOT)

Combined Logic

​Рекомендации по производительности

​Обработка ошибок

​Дальнейшие действия

Slot & Block Monitoring

Stream Pump AMM Data

Decoding Transaction Data

Yellowstone protocol reference

Параметры фильтрации транзакций

Практические примеры

Пример 1. Мониторинг транзакций DEX

Пример 2. Мониторинг неуспешных транзакций

Пример 3. Мониторинг крупных транзакций

Пример 4. Отслеживание кошелька, включая переводы токенов

Структура данных транзакции

Справочник по логике фильтров

Рекомендации по производительности

Обработка ошибок

Дальнейшие действия