transactionSubscribeの使用方法

`transactionSubscribe`とは何ですか？

transactionSubscribe WebSocketメソッド（標準Solana WebSocket APIへのHelius拡張）は、リアルタイムのトランザクションイベントを可能にします。使用するには、TransactionSubscribeFilterを提供し、さらにカスタマイズのためにTransactionSubscribeOptionsをオプションで含めます。 transactionSubscribeは、標準のSolanaサブスクリプションメソッドと同じ統合されたwss://mainnet.helius-rpc.comおよびwss://devnet.helius-rpc.com エンドポイント上にあります。

`TransactionSubscribeFilter`

vote: 投票関連のトランザクションを含める/除外するためのブールフラグ
failed: 失敗したトランザクションを含める/除外するためのブールフラグ
signature: 署名に基づいて特定のトランザクションへの更新をフィルタ
accountInclude: トランザクション更新を受け取りたいアカウントのリスト。トランザクション更新には1つのアカウントのみが含まれている必要があります（例: アカウント1または2）。
accountExclude: トランザクション更新から除外したいアカウントのリスト
accountRequired: トランザクションに指定したすべてのアカウントを含める必要があります（例: アカウント1と2）。
tokenAccounts: オプトイン関連トークンアカウント（ATA）展開（balanceChanged、all、またはnone）。下記のウォレットの監視、トークン転送を含むを参照してください。

accountInclude、accountExclude、およびaccountRequired配列には最大50,000アドレスを含めることができます。

TransactionSubscribeOptions (オプション)

commitment: データ取得のためのコミットメントレベル (processed, confirmed, または finalized)
encoding: 返されるデータのエンコーディング形式 (base58, base64, または jsonParsed)
transactionDetails: 返されるデータの詳細レベル (full, signatures, accounts および none)
showRewards: 報酬データを更新に含めるかどうかを示すブールフラグ
maxSupportedTransactionVersion: 更新を受け取りたい取引の最高バージョンを指定します。レガシー、v0、およびv1の取引を受け取るには、値を 1 に設定します。トランザクションv1のサポートを参照してください。

maxSupportedTransactionVersionは、特定のトランザクションのアカウントおよびフルレベルの詳細を返すために必要です（例: transactionDetails: "accounts" | "full"）。

トランザクションサブスクライブ例

この例では、Raydiumアカウント675kPX9MHTjS2zt1qfr1NYHuzeLXfQM9H24wFSUt1Mp8を含むトランザクションを購読しています。 675k...1Mp8アカウントを含むトランザクションが発生すると、トランザクションのaccountKeysでWSS通知を受け取ります。サブスクリプションオプションに基づき、トランザクション通知はprocessedコミットメントレベル、jsonParsedエンコーディング、fullトランザクション詳細で送信され、報酬が表示されます。

const WebSocket = require('ws');

// Create a WebSocket connection
const ws = new WebSocket('wss://mainnet.helius-rpc.com/?api-key=<API_KEY>');

// Function to send a request to the WebSocket server
function sendRequest(ws) {
    const request = {
        jsonrpc: "2.0",
        id: 420,
        method: "transactionSubscribe",
        params: [
            {
                accountInclude: ["675kPX9MHTjS2zt1qfr1NYHuzeLXfQM9H24wFSUt1Mp8"]
            },
            {
                commitment: "processed",
                encoding: "jsonParsed",
                transactionDetails: "full",
                showRewards: true,
                maxSupportedTransactionVersion: 1
            }
        ]
    };
    ws.send(JSON.stringify(request));
}

// Function to send a ping to the WebSocket server
function startPing(ws) {
    setInterval(() => {
        if (ws.readyState === WebSocket.OPEN) {
            ws.ping();
            console.log('Ping sent');
        }
    }, 30000); // Ping every 30 seconds
}

// Define WebSocket event handlers

ws.on('open', function open() {
    console.log('WebSocket is open');
    sendRequest(ws);  // Send a request once the WebSocket is open
    startPing(ws);    // Start sending pings
});

ws.on('message', function incoming(data) {
    const messageStr = data.toString('utf8');
    try {
        const messageObj = JSON.parse(messageStr);
        console.log('Received:', messageObj);
    } catch (e) {
        console.error('Failed to parse JSON:', e);
    }
});

ws.on('error', function error(err) {
    console.error('WebSocket error:', err);
});

ws.on('close', function close() {
    console.log('WebSocket is closed');
});

通知例

{
    "jsonrpc": "2.0",
    "method": "transactionNotification",
    "params": {
        "subscription": 4743323479349712,
        "result": {
            "transaction": {
                "transaction": [
                    "Ae6zfSExLsJ/E1+q0jI+3ueAtSoW+6HnuDohmuFwagUo2BU4OpkSdUKYNI1dJfMOonWvjaumf4Vv1ghn9f3Avg0BAAEDGycH0OcYRpfnPNuu0DBQxTYPWpmwHdXPjb8y2P200JgK3hGiC2JyC9qjTd2lrug7O4cvSRUVWgwohbbefNgKQAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAA0HcpwKokfYDDAJTaF/TWRFWm0Gz5/me17PRnnywHurMBAgIAAQwCAAAAoIYBAAAAAAA=",
                    "base64"
                ],
                "meta": {
                    "err": null,
                    "status": {
                        "Ok": null
                    },
                    "fee": 5000,
                    "preBalances": [
                        28279852264,
                        158122684,
                        1
                    ],
                    "postBalances": [
                        28279747264,
                        158222684,
                        1
                    ],
                    "innerInstructions": [],
                    "logMessages": [
                        "Program 11111111111111111111111111111111 invoke [1]",
                        "Program 11111111111111111111111111111111 success"
                    ],
                    "preTokenBalances": [],
                    "postTokenBalances": [],
                    "rewards": null,
                    "loadedAddresses": {
                        "writable": [],
                        "readonly": []
                    },
                    "computeUnitsConsumed": 0
                }
            },
            "signature": "5moMXe6VW7L7aQZskcAkKGQ1y19qqUT1teQKBNAAmipzdxdqVLAdG47WrsByFYNJSAGa9TByv15oygnqYvP6Hn2p",
            "slot": 224341380,
            "transactionIndex": 42
        }
    }
}

ウォレットの監視、トークン転送を含む

accountIncludeでウォレットを監視すると、ウォレットの公開鍵がアカウントキーに直接現れるトランザクションにのみ一致します。通常のケースでは見逃しが発生します。誰かがウォレットにSPLトークン（例えばUSDC）を送信すると、その転送はウォレットの**関連トークンアカウント（ATA）**に触れるため、ウォレットの公開鍵には触れません — そのため、通常のaccountInclude: [wallet]サブスクリプションではそれを認識しません。監視対象アカウントがトークン残高を所有しているトランザクションにも一致するようにマッチングを拡張するため、tokenAccountsフィールドを設定します。

balanceChanged: トランザクションでウォレットが所有するトークン残高の額が変わった（またはトークンアカウントが閉じられた）場合に一致します。これは「実際にお金が動いたときに教えてください」という用途に使用します。これは通常の狭義の、低ボリュームで、最も一般的な選択です。
all: ウォレットが所有するトークン残高を参照するトランザクションすべてに一致します、たとえ変更がなくても。高ボリューム。
none: 拡張なし。このフィールドの省略と同じです（デフォルト）。

マッチングは所有者ベースで行われます: ウォレットが所有する、派生ATAアドレスだけでなく、非標準的なものを含むあらゆるトークンアカウントをキャッチします。無効な値はJSON-RPCエラー-32602を返します。tokenAccountsを省略したサブスクリプションは、以前とまったく同じように動作します。ATA拡張の仕組み全体については、WebSocketを介したトークンアカウント(ATA)フィルタリングを参照してください。

const ws = new WebSocket('wss://mainnet.helius-rpc.com/?api-key=<API_KEY>');

ws.on('open', () => {
  ws.send(JSON.stringify({
    jsonrpc: '2.0',
    id: 1,
    method: 'transactionSubscribe',
    params: [
      {
        accountInclude: ['<WALLET_PUBKEY>'],
        tokenAccounts: 'balanceChanged' // also match the wallet's ATAs
      },
      { commitment: 'confirmed', encoding: 'jsonParsed', maxSupportedTransactionVersion: 1 }
    ]
  }));
  setInterval(() => ws.ping(), 30_000);
});

ws.on('message', (data) => {
  const msg = JSON.parse(data.toString());
  const result = msg.params?.result;
  if (!result) return;
  // Token balances this wallet owns that changed in the tx
  const owned = (result.transaction.meta.postTokenBalances || [])
    .filter((b) => b.owner === '<WALLET_PUBKEY>');
  console.log(result.signature, owned);
});

新しいJupiter DCAの監視

Jupiter DCA、またはドルコスト平均法は、Solanaで定期的な取引をスケジュールする方法です。これらの定期購入/販売注文はオンチェーンで記録されるため、トレーダーはtransactionSubscribeメソッドとgetAssetを使用して新しい注文をリスニングできます。

const WebSocket = require('ws');   
const bs58      = require('bs58').default;

/* ───────────────────── 1.  CONFIG ──────────────────────────── */
const API_KEY   = process.env.HELIUS_API_KEY || (() => { throw new Error('Set HELIUS_API_KEY'); })();
const HELIUS_WS  = `wss://mainnet.helius-rpc.com?api-key=${API_KEY}`;
const HELIUS_RPC = `https://mainnet.helius-rpc.com/?api-key=${API_KEY}`;
const DCA_PROGRAM_ID = 'DCA265Vj8a9CEuX1eb1LWRnDT7uK6q1xMipnNyatn23M';

/* ───────────────────── 2.  BINARY DECODER ──────────────────── */
function decodeOpenDcaV2(base58Data) {
  const buf = Buffer.from(bs58.decode(base58Data));
  return {
    appIdx:    buf.readBigUInt64LE(8), // Application Index
    inAmount:  buf.readBigUInt64LE(16), // Input Amount
    perCycle:  buf.readBigUInt64LE(24), // Per Cycle
    interval:  buf.readBigUInt64LE(32) // Interval
  };
}

const TOKEN_META = new Map();   // mint → { symbol, decimals }
/**
 * Fetch symbol & decimals for a mint once then cache.
 * Uses Helius getAsset DAS method: https://www.helius.dev/docs/api-reference/das/getasset
 */
async function getMeta(mint) {
  if (TOKEN_META.has(mint)) return TOKEN_META.get(mint);

  const body = {
    jsonrpc: '2.0',
    id:      'meow',
    method:  'getAsset',
    params:  { id: mint, displayOptions: { showFungible: true } }
  };

  const { result } = await fetch(HELIUS_RPC, {
    method:  'POST',
    headers: { 'Content-Type': 'application/json' },
    body:    JSON.stringify(body)
  }).then(r => r.json());

  const tokenInfo = result.token_info || {};
  const metadata = { symbol: tokenInfo.symbol || '?', decimals: tokenInfo.decimals ?? 0 };
  TOKEN_META.set(mint, metadata);
  return metadata;
}

/* ───────────────────── 4.  PRETTY HELPERS ──────────────────── */
function formatTimestamp(unixSeconds) {
    return new Date(Number(unixSeconds) * 1_000)
             .toISOString()
             .replace('T', ' ')
             .replace('.000Z', ' UTC');
}
function formatInterval(seconds) {
    if (seconds % 86_400 === 0) return `every ${seconds / 86_400}d`;
    if (seconds %  3_600 === 0) return `every ${seconds /  3_600}h`;
    if (seconds %     60 === 0) return `every ${seconds /     60}m`;
    return `every ${seconds}s`;
  }

  function formatAmount(raw, decimals, symbol) {
    const ui = Number(raw) / 10 ** decimals;
    return `${ui} ${symbol}`;
  }
/* ───────────────────── 5.  WEBSOCKET SETUP ─────────────────── */
const ws = new WebSocket(HELIUS_WS);

ws.on('open', () => {
  ws.send(JSON.stringify({
    jsonrpc: '2.0',
    id:      1,
    method:  'transactionSubscribe',
    params: [
      { failed: false, accountInclude: [DCA_PROGRAM_ID] },
      {
        commitment: 'confirmed',
        encoding:   'jsonParsed',
        transactionDetails: 'full',
        maxSupportedTransactionVersion: 1
      }
    ]
  }));

  setInterval(() => ws.ping(), 10_000);
});

/* ───────────────────── 6.  MAIN MESSAGE HANDLER ────────────── */
ws.on('message', async raw => {
  const payload = JSON.parse(raw);
  const result  = payload.params?.result;
  if (!result) return;

  // Look for the `OpenDcaV2` log message
  const logs = result.transaction.meta.logMessages || [];
  if (!logs.some(l => l.includes('OpenDcaV2'))) return;

  // loop through all instructions in the transaction to find the DCA instruction
  for (const ix of result.transaction.transaction.message.instructions) {
    if (ix.programId !== DCA_PROGRAM_ID) continue;

    try {
      // 1) decode binary payload
      const d = decodeOpenDcaV2(ix.data);

      // 2) fetch token symbols / decimals (cached)
      const [inMeta, outMeta] = await Promise.all([
        getMeta(ix.accounts[3]),   // input mint
        getMeta(ix.accounts[4])    // output mint
      ]);

      // 3) create a nice looking table
      console.table({
        user:        ix.accounts[2],
        pair:        `${inMeta.symbol} → ${outMeta.symbol}`,
        opened:      formatTimestamp(d.appIdx),
        'total in':  formatAmount(d.inAmount,  inMeta.decimals, inMeta.symbol),
        'per cycle': formatAmount(d.perCycle,  inMeta.decimals, inMeta.symbol),
        interval:    formatInterval(Number(d.interval))
      });
    } catch (e) {}
  }
});

ws.on('error', console.error);

ws.on('close', () => process.exit(1));

通知例

ユーザーウォレット、トークンペア、オープン時間、合計入力、サイクルごとの金額、間隔を示す新しいジュピターDCA注文のターミナルテーブル

新しいpump.funトークンの監視

const WebSocket = require('ws');

const KEY    = process.env.HELIUS_API_KEY ?? (() => { throw new Error('Set HELIUS_API_KEY'); })();
const WS_URL = `wss://mainnet.helius-rpc.com?api-key=${KEY}`;
const PUMP_FUN_PROG = '6EF8rrecthR5Dkzon8Nwu78hRvfCKubJ14M5uBEwF6P';

/* ────────── 2.  OPEN WEBSOCKET & SUBSCRIBE ──────────────────── */
const ws = new WebSocket(WS_URL);

ws.on('open', () => {
  ws.send(JSON.stringify({
    jsonrpc : '2.0',
    id      : 1,
    method  : 'transactionSubscribe',
    params  : [
      { failed:false, accountInclude:[PUMP_FUN_PROG] },
      { commitment:'confirmed', encoding:'jsonParsed',
        transactionDetails:'full', maxSupportedTransactionVersion:1 }
    ]
  }));
  // ping every 10 s so we don't get dropped
  setInterval(() => ws.ping(), 10_000);
});

/* ────────── 3.  MESSAGE HANDLER ─────────────────────────────── */
ws.on('message', raw => {
  const payload = JSON.parse(raw);
  const result  = payload.params?.result;
  if (!result) return;

  const logs = result.transaction.meta.logMessages || [];
  // filter for the pump.fun "InitializeMint2" log
  if (!logs.some(l => l.includes('Instruction: InitializeMint2'))) return;

  const sig   = result.signature;    // transaction signature
  const keys  = result.transaction.transaction.message.accountKeys
                             .map(k => k.pubkey);
  //   keys[0] → creator wallet
  //   keys[1] → the new token
  console.table({
    tx:      sig,
    creator: keys[0],
    token:   keys[1]
  });
});

ws.on('error', console.error);
ws.on('close', () => process.exit(1));  

通知例

トランザクションシグネチャ、作成者ウォレット、トークン発行アドレスを示す新しく作成されたpump.funトークンのターミナルテーブル

サブスクリプションの管理

サブスクリプションID

transactionSubscribeが成功すると、サーバーはresultフィールドにサブスクリプションIDを返します。これは、サブスクリプションからのすべての通知においてparams.subscriptionに表示される同じ番号です:

{
  "jsonrpc": "2.0",
  "result": 4743323479349712,
  "id": 420
}

{
  "jsonrpc": "2.0",
  "method": "transactionNotification",
  "params": {
    "subscription": 4743323479349712,
    "result": {}
  }
}

応答からサブスクリプションIDを保存します。これを解除するには必要です。

解除

通知を受け取らないようにするには、サブスクリプションIDを使ってtransactionUnsubscribeを呼び出します。同じ接続での各transactionSubscribe呼び出しは個別のIDを持つ別のサブスクリプションを作成するため、再サブスクライブする前に解除して重複通知の受信を避けてください。

{
  "jsonrpc": "2.0",
  "id": 421,
  "method": "transactionUnsubscribe",
  "params": [4743323479349712]
}

{
  "jsonrpc": "2.0",
  "result": true,
  "id": 421
}

この例では、Raydiumトランザクションを購読し、サーバーの応答からサブスクリプションIDを取得し、そのIDを使用して解除します。transactionUnsubscribeを呼び出した直後に数件のフライトメッセージが届くことがあります。これは予想される動作です。

const WebSocket = require('ws');

const ws = new WebSocket('wss://mainnet.helius-rpc.com/?api-key=<API_KEY>');
let subscriptionId = null;

ws.on('open', () => {
    ws.send(JSON.stringify({
        jsonrpc: '2.0',
        id: 420,
        method: 'transactionSubscribe',
        params: [
            { accountInclude: ['675kPX9MHTjS2zt1qfr1NYHuzeLXfQM9H24wFSUt1Mp8'] },
            {
                commitment: 'processed',
                encoding: 'jsonParsed',
                transactionDetails: 'full',
                maxSupportedTransactionVersion: 1,
            },
        ],
    }));
    setInterval(() => ws.ping(), 30000);
});

ws.on('message', (data) => {
    const msg = JSON.parse(data.toString());

    // Capture the subscription ID from the subscribe response
    if (msg.id === 420 && msg.result !== undefined) {
        subscriptionId = msg.result;
        console.log('Subscribed, ID:', subscriptionId);
        return;
    }

    // Handle transaction notifications
    if (msg.method === 'transactionNotification') {
        console.log('Received:', msg.params.result.signature);
    }
});

function unsubscribe() {
    if (subscriptionId !== null) {
        ws.send(JSON.stringify({
            jsonrpc: '2.0',
            id: 421,
            method: 'transactionUnsubscribe',
            params: [subscriptionId],
        }));
        subscriptionId = null;
    }
}

ここから始める

リアルタイムデータ

低レイテンシ取引

履歴データとウォレットデータ

RPC メソッドガイド

本番環境への対応

Orb の使用

その他のハウツー

transactionSubscribeの使用方法

`transactionSubscribe`とは何ですか？

`TransactionSubscribeFilter`

TransactionSubscribeOptions (オプション)

トランザクションサブスクライブ例

通知例

ウォレットの監視、トークン転送を含む

新しいJupiter DCAの監視

通知例

新しいpump.funトークンの監視

通知例

サブスクリプションの管理

サブスクリプションID

解除

​transactionSubscribeとは何ですか？

​TransactionSubscribeFilter

​TransactionSubscribeOptions (オプション)

​トランザクションサブスクライブ例

​通知例

​ウォレットの監視、トークン転送を含む

​新しいJupiter DCAの監視

​通知例

​新しいpump.funトークンの監視

​通知例

​サブスクリプションの管理

​サブスクリプションID

​解除

`transactionSubscribe`とは何ですか？

`TransactionSubscribeFilter`

TransactionSubscribeOptions (オプション)

トランザクションサブスクライブ例

通知例

ウォレットの監視、トークン転送を含む

新しいJupiter DCAの監視

通知例

新しいpump.funトークンの監視

通知例

サブスクリプションの管理

サブスクリプションID

解除