Фильтрация по минту токена

​

Проблема: обычные фильтры аккаунтов пропускают большинство переводов токенов

​

Как работает matchMints

​

Семантика

• Предикаты внутри одного именованного фильтра по-прежнему объединяются оператором AND (vote, failed, signature и списки аккаунтов).
• Несколько именованных фильтров по-прежнему объединяются оператором OR.
• Значения внутри списка объединяются оператором OR (кроме accountRequired, где должны совпасть все значения).
• Для транзакции без балансов токенов используется сопоставление только по ключам. matchMints никогда не добавляет транзакции без активности токенов.
• Сам по себе matchMints не ограничивает поток. Чтобы фильтр был принят, необходимо указать хотя бы один ключ или минт в списке аккаунтов либо другой ограничивающий предикат.

​

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

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

const USDC = 'EPjFWdd5AufqSSqeM2qN1xzybapC8G4wEGGkZwyTDt1v';

const subscriptionRequest: SubscribeRequest = {
  transactions: {
    'usdc-txs': {
      accountInclude: [USDC],
      accountExclude: [],
      accountRequired: [],
      vote: false,
      failed: false,
      matchMints: true, // match USDC via pre/post token-balance mints
    },
  },
  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) => {
  const tx = data.transaction?.transaction;
  if (!tx) return;
  // USDC balances touched by this transaction
  const usdcBalances = (tx.meta?.postTokenBalances || []).filter((b: any) => b.mint === USDC);
  console.log(bs58.encode(tx.signature), usdcBalances);
}, async (error) => {
  console.error('Stream error:', error);
});

use std::collections::HashMap;
use helius_laserstream::grpc::{SubscribeRequest, SubscribeRequestFilterTransactions};

let request = SubscribeRequest {
    transactions: HashMap::from([(
        "usdc-txs".to_string(),
        SubscribeRequestFilterTransactions {
            account_include: vec!["EPjFWdd5AufqSSqeM2qN1xzybapC8G4wEGGkZwyTDt1v".to_string()],
            vote: Some(false),
            failed: Some(false),
            match_mints: true,
            ..Default::default()
        },
    )]),
    ..Default::default()
};

vote := false
failed := false
req := &laserstream.SubscribeRequest{
    Transactions: map[string]*laserstream.SubscribeRequestFilterTransactions{
        "usdc-txs": {
            AccountInclude: []string{"EPjFWdd5AufqSSqeM2qN1xzybapC8G4wEGGkZwyTDt1v"},
            Vote:           &vote,
            Failed:         &failed,
            MatchMints:     true,
        },
    },
    Commitment: &commitmentLevel,
}

​

Сочетание с tokenAccounts для отслеживания одного токена одного кошелька

transactions: {
  'wallet-usdc': {
    accountInclude: [WALLET],
    accountRequired: [USDC],
    accountExclude: [],
    tokenAccounts: 'balanceChanged', // wallet matched via its token accounts
    matchMints: true,                // USDC matched via balance mints
    vote: false,
    failed: false,
  },
},

​

Чтение результатов сопоставления

​

Ограничения и примечания

• Минты указываются в тех же списках accountInclude, accountExclude и accountRequired, что и ключи аккаунтов, поэтому на них распространяются те же ограничения тарифного плана для каждого списка. Отдельного ограничения для минтов нет.
• Затраты на сопоставление не зависят от количества указанных минтов. Производительность одинакова для 100 и 100 000 минтов, а подписчики, которые не устанавливают этот флаг, не несут дополнительных затрат.
• Воспроизведение истории учитывает matchMints, поэтому подписка на воспроизведение возвращает те же транзакции, которые вернул бы поток в реальном времени.
• Если вы прикрепите сжатый фильтр (кукушкин фильтр) к подписке на транзакции, matchMints будет проверять по нему набор минтов наряду с ключами аккаунтов.
• matchMints работает во всех регионах LaserStream gRPC, в основной и тестовой сетях. В настоящее время он недоступен в LaserStream WebSocket.
• Минимальные версии SDK: JavaScript/TypeScript helius-laserstream 0.8.5, Rust helius-laserstream 0.6.4, Go go/v0.3.0.

​

Связанные материалы