トランザクションデータのデコード

Laserstreamからトランザクションデータを受け取ったとき、重要なことが2つあります。

Message → ユーザーがやりたかったこと（署名済みの提案）
Meta → 実際に起きたこと（実行結果）

課題: 生のトランザクションデータは、読みやすいアドレスや署名の代わりにバイナリのバイト配列（<Buffer 00 bf a0 e8...>のような形式）で提供されます。このガイドは、そのバイナリデータを人間が読みやすい形式にデコードし、意味のある情報を抽出し、提案から実行までの完全なトランザクションストーリーを理解する方法を示します。

ライブストリーム、デコードなし

以下の最小クライアントを実行します。フィルターフラグは投票および失敗したトランザクションをドロップし、accountInclude配列はJupiterプログラムIDに触れる活動の結果を制限します。

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

async function runTransactionSubscription() {
  const config: LaserstreamConfig = {
    apiKey: 'YOUR_API_KEY', // from https://dashboard.helius.dev/
    endpoint: 'https://laserstream-mainnet-ewr.helius-rpc.com', // pick the closest region
  };

  const request = {
    transactions: {
      "Jupiter-transactions": {
        vote: false,
        failed: false,
        accountInclude: ['JUP6LkbZbjS1jKKwapdHNy74zcZ3tLUZoi5QNyVTaV4']
      }
    },
    commitment: CommitmentLevel.PROCESSED,
    accounts: {}, slots: {}, transactionsStatus: {}, blocks: {}, blocksMeta: {}, entry: {}, accountsDataSlice: []
  };

  const stream = await subscribe(
    config,
    request,
    (u: SubscribeUpdate) => console.log('💸 Transaction update', u),
    console.error
  );

  console.log(`✅ stream id → ${stream.id}`);
  process.on('SIGINT', () => { stream.cancel(); process.exit(0); });
}
runTransactionSubscription().catch(console.error);

コンソールには、ラッパー（filters, createdAt）と、2つの子を隠すtransactionブランチが表示されます。

transaction.transaction.transaction → 署名済みのメッセージ
transaction.transaction.meta → 実行メタ

{
 filters: [ 'Jupiter-transactions' ],
  account: undefined,
  transaction: {
    transaction: {
      signature: <Buffer 00 bf a0 e8 9f cc 84 0c a4 83 e3 97 cd b7 57 e2 2b bc 1d ca 8c a6 1b ce b5 57 d7 47 5e ec 1f 46 ae b2 2d 6a 12 cb 88 48 1d 07 bf f6 b2 d3 a8 0b c9 04 ... 14 more bytes>,
      transaction: [Object],
      meta: [Object],
      index: '1177'
    },
    slot: '351704819'
  },
  transactionStatus: undefined,
  block: undefined,
  blockMeta: undefined,
  entry: undefined,
  ping: undefined,
  pong: undefined,
  createdAt: 2025-07-07T10:58:44.403Z
}

Uint8Arrayのように見えるものは、その時点では不透明なままです。デコード関数を使ってスクリプトを実行すると、読みやすいアドレスを持つ実際のネスト構造が見られます。

{
  "filters": ["Jupiter-transactions"],
  "account": undefined,
  "transaction": {
    "transaction": {
      "signature": "5u62i53R1Hdc4thm6DQTNWNkyypuJJSaXSMwwQDxNqKMaAw62H1Xa3Md7QDhYjoPk5dCPg18fwz83kUR6TrMviTx",
      "transaction": {
        "message": {
          "header": {
            "numRequiredSignatures": 1,
            "numReadonlySignedAccounts": 0,
            "numReadonlyUnsignedAccounts": 8
          },
          "accountKeys": [
            "AF9KFSWQeKVxd3kVvFvysWXmATHyYzrN8zN8GtXn4qTF",
            "G9VzXwhDPQ8KRbQAJN6TyGf2gWukYDAvmnXJhPZFev4f",
            "ES9qPxWQVMRZkobJ9yr3U6XSrXzGNLJdSe6p6fS7b82T",
            "JUP6LkbZbjS1jKKwapdHNy74zcZ3tLUZoi5QNyVTaV4",
            "ComputeBudget111111111111111111111111111111",
            "ATokenGPvbdGVxr1b2hvZbsiqW5xWH25efTNsLJA8knL",
            "So11111111111111111111111111111111111111112",
            "11111111111111111111111111111111",
            "TokenkegQfeZyiNwAJbNbGKPFXCWuBvf9Ss623VQ5DA"
          ],
          "recentBlockhash": "8sGjRxJHLJVWqpHt5UdN8qxtLLdgcnLKBpFj9Qrn5PNF",
          "instructions": [
            {
              "programIdIndex": 4,
              "accounts": [],
              "data": "3bjaAzoXPjbY"
            },
            {
              "programIdIndex": 3,
              "accounts": [0, 1, 2, 5, 6, 7, 8],
              "data": "2L1xoA2KEqBgWfGt3fwFJK8k4FPJRJzYHRgH4R3xC8A7"
            }
          ]
        },
        "signatures": [
          "5u62i53R1Hdc4thm6DQTNWNkyypuJJSaXSMwwQDxNqKMaAw62H1Xa3Md7QDhYjoPk5dCPg18fwz83kUR6TrMviTx"
        ]
      },
      "meta": {
        "err": null,
        "fee": 12500,
        "preBalances": [1075517572, 0, 207594496815, 0, 0, 0, 0, 0, 0],
        "postBalances": [1075502572, 1461600, 207594496815, 2001231920, 2039280, 0, 0, 0, 0],
        "innerInstructions": [
          {
            "index": 1,
            "instructions": [
              {
                "programIdIndex": 5,
                "accounts": [1, 2, 0],
                "data": "3Bxs4h24hBtQy9rw"
              }
            ]
          }
        ],
        "logMessages": [
          "Program ComputeBudget111111111111111111111111111111 invoke [1]",
          "Program ComputeBudget111111111111111111111111111111 success",
          "Program JUP6LkbZbjS1jKKwapdHNy74zcZ3tLUZoi5QNyVTaV4 invoke [1]",
          "Program log: Instruction: Swap",
          "Program ATokenGPvbdGVxr1b2hvZbsiqW5xWH25efTNsLJA8knL invoke [2]",
          "Program log: Create",
          "Program TokenkegQfeZyiNwAJbNbGKPFXCWuBvf9Ss623VQ5DA invoke [3]",
          "Program log: Instruction: GetAccountDataSize",
          "Program TokenkegQfeZyiNwAJbNbGKPFXCWuBvf9Ss623VQ5DA consumed 1569 of 242833 compute units",
          "Program return: TokenkegQfeZyiNwAJbNbGKPFXCWuBvf9Ss623VQ5DA pQAAAAAAAAA=",
          "Program TokenkegQfeZyiNwAJbNbGKPFXCWuBvf9Ss623VQ5DA success",
          "Program JUP6LkbZbjS1jKKwapdHNy74zcZ3tLUZoi5QNyVTaV4 success"
        ],
        "preTokenBalances": [],
        "postTokenBalances": [],
        "computeUnitsConsumed": 182564
      },
      "index": "1177"
    },
    "slot": "351709933"
  },
  "transactionStatus": undefined,
  "block": undefined,
  "blockMeta": undefined,
  "entry": undefined,
  "ping": undefined,
  "pong": undefined,
  "createdAt": "2025-01-14T10:58:44.403Z"
}

バイナリデータのデコード

デコードの理由: 生のLaserstreamデータには、署名、アカウントキー、ハッシュがバイナリUint8Arrayオブジェクトとして含まれており、読み取りができません。これらをbase58文字列に変換する必要があります。解決策: Laserstreamは、Yellowstone gRPCを使用しており、組み込みのデコードユーティリティを提供しています。各フィールドタイプのデコーダーを書く代わりに、再帰関数を使ってすべてのバイナリデータを人間が読みやすい形式に変換します。

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

// Recursive function to convert all Buffer/Uint8Array fields to base58
function convertBuffers(obj: any): any {
  if (!obj) return obj;
  if (Buffer.isBuffer(obj) || obj instanceof Uint8Array) {
    return bs58.encode(obj);
  }
  if (Array.isArray(obj)) {
    return obj.map(item => convertBuffers(item));
  }
  if (typeof obj === 'object') {
    return Object.fromEntries(
      Object.entries(obj).map(([key, value]) => [key, convertBuffers(value)])
    );
  }
  return obj;
}

async function runTransactionSubscription() {
  const config: LaserstreamConfig = {
    apiKey: 'YOUR_API_KEY', // from https://dashboard.helius.dev/
    endpoint: 'https://laserstream-mainnet-ewr.helius-rpc.com', // pick the closest region
  };

  const request = {
    transactions: {
      "Jupiter-transactions": {
        vote: false,
        failed: false,
        accountInclude: ['JUP6LkbZbjS1jKKwapdHNy74zcZ3tLUZoi5QNyVTaV4']
      }
    },
    commitment: CommitmentLevel.PROCESSED,
    accounts: {}, slots: {}, transactionsStatus: {}, blocks: {}, blocksMeta: {}, entry: {}, accountsDataSlice: []
  };

  const stream = await subscribe(
    config,
    request,
    (update: SubscribeUpdate) => {
      if (update.transaction) {
        // Convert all binary fields to human-readable format
        const decodedTransaction = convertBuffers(update.transaction);
        console.log('💸 Decoded transaction:', JSON.stringify(decodedTransaction, null, 2));
        
        // Or process specific fields
        processTransaction(update.transaction);
      }
    },
    console.error
  );

  console.log(`✅ stream id → ${stream.id}`);
  process.on('SIGINT', () => { stream.cancel(); process.exit(0); });
}

function processTransaction(txUpdate: any) {
  const tx = txUpdate.transaction;
  const meta = tx.meta;
  
  console.log('Transaction Details:');
  console.log('- Signature:', bs58.encode(tx.signature));
  console.log('- Slot:', txUpdate.slot);
  console.log('- Success:', meta.err === null);
  console.log('- Fee:', meta.fee, 'lamports');
  console.log('- Compute Units:', meta.computeUnitsConsumed);
  
  // Account keys are already available in the message
  const message = tx.transaction.message;
  if (message.accountKeys) {
    console.log('- Account Keys:');
    message.accountKeys.forEach((key: Uint8Array, index: number) => {
      console.log(`  ${index}: ${bs58.encode(key)}`);
    });
  }
  
  // Log messages are already UTF-8 strings
  if (meta.logMessages && meta.logMessages.length > 0) {
    console.log('- Log Messages:');
    meta.logMessages.forEach((log: string) => {
      console.log(`  ${log}`);
    });
  }
}

runTransactionSubscription();

このアプローチは、組み込みのデコードを活用しながら、手動変換が必要なバイナリフィールドを処理します。トランザクション構造はすでに解析されているので、バイナリフィールドを人間が読みやすい形式に変換するだけです。

トランザクション構造の理解

デコードされたデータが見えるようになったので、Laserstreamトランザクションアップデートの主な2つの部分を探ります。最初の例から、各トランザクションには2つのキーオブジェクトが含まれていることを思い出してください。

Message (Proposal) → transaction.transaction.transaction→ 署名されたメッセージ（ユーザーの提案）
Meta (Execution) → transaction.transaction.meta→ 実行メタデータ（バリデーターの応答）

この2部構成は、ユーザーの要求と実際に起こったことの完全なストーリーを伝えます。各部分を詳細に検討していきましょう。

提案: メッセージ内部のすべて

ユーザーは何を、誰が、そしていつまでを指定するメッセージを作成します。以下に各部分をデコードする方法を示します。

トランザクションヘッダー

{
  "header": {
    "numRequiredSignatures": 1,
    "numReadonlySignedAccounts": 0,
    "numReadonlyUnsignedAccounts": 5
  }
}

numRequiredSignaturesは、バリデーターにどれだけの署名を確認するかを伝え、2つのnumReadonly*の値は、ランタイムが読み取り専用として扱えるアカウントをラベル付けし、並列実行を可能にします。

アカウントキー辞書

{
  "accountKeys": [
    "7YttLkHDoNj9wyDur5pM1ejNaAvT9X4eqaYcHQqtj2G5",
    "JUP6LkbZbjS1jKKwapdHNy74zcZ3tLUZoi5QNyVTaV4",
    "TokenkegQfeZyiNwAJbNbGKPFXCWuBvf9Ss623VQ5DA",
    "EPjFWdd5AufqSSqeM2qN1xzybapC8G4wEGGkZwyTDt1v",
    "So11111111111111111111111111111111111111112",
    "11111111111111111111111111111111"
  ]
}

accountKeysは公開鍵の単純なリストで、検索テーブルとして機能します。トランザクション内の後の整数（programIdIndexや命令のaccounts配列内の各要素）がこのリストにインデックスを使用して戻ります。これによりメッセージあたり1キロバイト以上を節約できます。

リプレイ防止

{
  "recentBlockhash": "8sGjRxJHLJVWqpHt5UdN8qxtLLdgcnLKBpFj9Qrn5PNF"
}

recentBlockhashは、最後の150のブロックハッシュをスクロールすると期限切れになります。メインネットで約90秒です。

命令: 実際のコマンド

{
  "instructions": [
    {
      "programIdIndex": 10,
      "data": "HnkkG7"
    },
    {
      "programIdIndex": 15,
      "accounts": "3vtmrQMafzDoG2CBz1iqgXPTnC",
      "data": "5jRcjdixRUDKQKUEt6oHJ747HCB3vWb5y"
    }
  ]
}

各命令には3つの主要な部分があります。

Program ID (programIdIndex): accountKeys配列内のアドレスにポイントします（例: インデックス10 = ComputeBudget111111111111111111111111111111）
Accounts (accounts): この命令がどのアカウントインデックスに触れるのかを表すbase58エンコードされた文字列
Data (data): base58でエンコードされた実際の命令データ

convertBuffers関数により、アカウントはbase58として表示されますが、実際にはアカウントインデックスを含んでいます（例: "3vtmrQMafzDoG2CBz1iqgXPTnC"はインデックス[21, 19, 12, 17, 2, 6, 1, 22]にデコードされます）この設計により、フルの32バイトのアドレスを繰り返す代わりに、各命令はルックアップテーブル内の位置を参照するだけで済みます。

署名: 認証の証明

{
  "signatures": [
    "5u62i53R1Hdc4thm6DQTNWNkyypuJJSaXSMwwQDxNqKMaAw62H1Xa3Md7QDhYjoPk5dCPg18fwz83kUR6TrMviTx"
  ]
}

signaturesには必要なアカウントがこのトランザクションを承認したことを証明する暗号署名が含まれています。署名の数はheader.numRequiredSignaturesと一致する必要があります。

アドレスタブルックアップ

{
  "addressTableLookups": [
    {
      "accountKey": "5Q544fKrFoe6tsEbD7S8EmxGTJYAKtTVhAW5Q5pge4j1",
      "writableIndexes": [0, 1],
      "readonlyIndexes": [2, 3, 4]
    }
  ],
  "versioned": true
}

versionedがtrueの場合、addressTableLookupsはオンチェーンテーブルと2つのインデックスリストと共に表示されます。ルックアップテーブルにより、パケットを1,232バイトのMTU以下に保ちながら、アドレスカウントのハードキャップを数十に引き上げます。

トランザクション v1: ヘッダー内の計算予算

トランザクション v1 (SIMD-0385, Agave 4.2) はメッセージにもう一つのフィールドを追加します: transactionConfig。

{
  "transactionConfig": {
    "computeUnitLimit": 200000,
    "heapSize": null,
    "loadedAccountsDataSizeLimit": 200000,
    "priorityFee": 50000
  },
  "versioned": true
}

v1 トランザクションでは計算予算が ComputeBudget プログラムの命令ではなくここに含まれるため、v1 トランザクションの instructions 配列には ComputeBudget111111111111111111111111111111 エントリが含まれることはありません。priorityFee はトランザクション全体の手数料を lamports で表し、計算単位当たりのマイクロ-lamports ではありません。null フィールドは、送信者が設定していないことを意味します。レガシーおよび v0 メッセージには transactionConfig がないため、その存在が v1 トランザクションを識別します。デコーダーで確認すべき2つのこと:

優先手数料の抽出。 transactionConfig.priorityFee が存在する場合に読み取ります。レガシーおよび v0 トランザクションの場合のみ ComputeBudget 命令をスキャンします。命令のみをスキャンするコードは、すべての v1 トランザクションを優先手数料ゼロとして読み取ります。
プロトバージョン。 yellowstone-grpc-proto 12.6.0 は v1 フィールドを含む最初のリリースであり、helius-laserstream 0.8.4 (JavaScript)、0.6.3 (Rust)、0.2.0 (Go) はそれを基に構築された最初の SDK リリースです。古いバージョンでは transactionConfig を静かに破棄します。

完全な変更リストについては、トランザクション v1 サポートを参照してください。

すべての接続: フロー

基本原理から見た流れは次のとおりです:

ルックアップテーブルを構築する: accountKeys はこのトランザクションが触れるすべてのアドレスを列挙します
ルールを設定する: header は必要な署名の数と読み取り専用のアカウントを指定します
コマンドを作成する: 各 instruction は以下を指します:
- プログラム（programIdIndex → accountKeys[index] 経由）
- 必要なアカウント（accounts → 複数の accountKeys[index] 位置を通して）
- 命令データ（data にエンコード）
承認を追加する: signatures は必要なアカウントがこのトランザクションを承認したことを証明します
有効期限を設定する: recentBlockhash はこのトランザクションが後で再実行されないようにします

実行: meta 内のすべて

メッセージはユーザーが実行したかったことを示し、meta はバリデーターがトランザクションを実行したときに実際に起こったことを示します。

基本的な実行情報

成功/失敗

{
  "err": null,
  "fee": 12500
}

err: null = 成功
err: {...} = エラーディテール付きの失敗
fee = このトランザクションで課金された lamports

残高の変化

{
  "preBalances": [1075517572, 0, 207594496815, 0, 0, 0, 0, 0, 0],
  "postBalances": [1075502572, 1461600, 207594496815, 2001231920, 2039280, 0, 0, 0, 0]
}

残高配列はインデックスで accountKeys 配列に対応します:

アカウント 0: 15000 lamports 減少（手数料支払い）
アカウント 1: 1461600 lamports 増加（新しいアカウント作成）
アカウント 3: 2001231920 lamports 増加（プログラムアカウント）

計算使用量

{
  "computeUnitsConsumed": 182564
}

要求された量からどれだけの計算予算が使用されたかを示します。

高度な実行詳細

内部命令

{
  "innerInstructions": [
    {
      "index": 1,
      "instructions": [
        {
          "programIdIndex": 5,
          "accounts": [1, 2, 0],
          "data": "3Bxs4h24hBtQy9rw"
        }
      ]
    }
  ]
}

内部命令は、実行中にプログラムが呼び出した追加の命令です。それらは元のトランザクションの一部ではありませんが、主要命令によってトリガーされました。 ログメッセージ

{
  "logMessages": [
    "Program ComputeBudget111111111111111111111111111111 invoke [1]",
    "Program ComputeBudget111111111111111111111111111111 success",
    "Program JUP6LkbZbjS1jKKwapdHNy74zcZ3tLUZoi5QNyVTaV4 invoke [1]",
    "Program log: Instruction: Swap",
    "Program ATokenGPvbdGVxr1b2hvZbsiqW5xWH25efTNsLJA8knL invoke [2]",
    "Program log: Create",
    "Program TokenkegQfeZyiNwAJbNbGKPFXCWuBvf9Ss623VQ5DA invoke [3]",
    "Program log: Instruction: GetAccountDataSize",
    "Program TokenkegQfeZyiNwAJbNbGKPFXCWuBvf9Ss623VQ5DA consumed 1569 of 242833 compute units",
    "Program return: TokenkegQfeZyiNwAJbNbGKPFXCWuBvf9Ss623VQ5DA pQAAAAAAAAA=",
    "Program TokenkegQfeZyiNwAJbNbGKPFXCWuBvf9Ss623VQ5DA success",
    "Program JUP6LkbZbjS1jKKwapdHNy74zcZ3tLUZoi5QNyVTaV4 success"
  ]
}

ログメッセージはプログラムの実行を時系列で記録し、呼び出されたプログラムやそれらが出力したカスタムログメッセージを示します。 トークン残高の変化

{
  "preTokenBalances": [],
  "postTokenBalances": [
    {
      "accountIndex": 1,
      "mint": "EPjFWdd5AufqSSqeM2qN1xzybapC8G4wEGGkZwyTDt1v",
      "owner": "7YttLkHDoNj9wyDur5pM1ejNaAvT9X4eqaYcHQqtj2G5",
      "uiTokenAmount": {
        "amount": "1000000",
        "decimals": 6,
        "uiAmount": 1.0,
        "uiAmountString": "1"
      }
    }
  ]
}

トークン残高の変化は、SPL トークンアカウントの前後の状態を示し、適切な小数処理を伴う人間に読みやすい量を含みます。

実用的なデコードパターン

デコードされたトランザクションから有用な情報を抽出するための一般的なパターンは次のとおりです:

// Transaction Success
function isTransactionSuccessful(meta: any): boolean {
  return meta.err === null;
}

function getTransactionFee(meta: any): number {
  return meta.fee;
}

function getComputeUnitsUsed(meta: any): number {
  return meta.computeUnitsConsumed;
}

// Balance Changes
function getBalanceChanges(meta: any, accountKeys: string[]): Array<{account: string, change: number}> {
  const changes = [];
  
  for (let i = 0; i < meta.preBalances.length; i++) {
    const change = meta.postBalances[i] - meta.preBalances[i];
    if (change !== 0) {
      changes.push({
        account: accountKeys[i],
        change: change
      });
    }
  }
  
  return changes;
}

// Program Calls
function getInvokedPrograms(meta: any, accountKeys: string[]): string[] {
  const programs = new Set<string>();
  
  meta.logMessages.forEach((log: string) => {
    const match = log.match(/Program ([1-9A-HJ-NP-Za-km-z]{32,}) invoke/);
    if (match) {
      programs.add(match[1]);
    }
  });
  
  return Array.from(programs);
}

// Token Transfers
function getTokenTransfers(meta: any): Array<{mint: string, from: string, to: string, amount: number}> {
  const transfers = [];
  
  // Compare pre and post token balances
  const preBalances = new Map();
  const postBalances = new Map();
  
  meta.preTokenBalances.forEach((balance: any) => {
    preBalances.set(balance.accountIndex, balance);
  });
  
  meta.postTokenBalances.forEach((balance: any) => {
    postBalances.set(balance.accountIndex, balance);
  });
  
  // Find changes
  for (const [accountIndex, postBalance] of postBalances) {
    const preBalance = preBalances.get(accountIndex);
    const preAmount = preBalance ? parseInt(preBalance.uiTokenAmount.amount) : 0;
    const postAmount = parseInt(postBalance.uiTokenAmount.amount);
    
    if (preAmount !== postAmount) {
      transfers.push({
        mint: postBalance.mint,
        account: postBalance.owner,
        change: postAmount - preAmount,
        decimals: postBalance.uiTokenAmount.decimals
      });
    }
  }
  
  return transfers;
}

完全な例: Jupiter スワップデコーダー

Jupiter スワップトランザクションをデコードし、意味のある情報を抽出する完全な例は次のとおりです:

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

interface SwapInfo {
  signature: string;
  slot: number;
  user: string;
  inputMint: string;
  outputMint: string;
  inputAmount: number;
  outputAmount: number;
  fee: number;
  success: boolean;
}

function convertBuffers(obj: any): any {
  if (!obj) return obj;
  if (Buffer.isBuffer(obj) || obj instanceof Uint8Array) {
    return bs58.encode(obj);
  }
  if (Array.isArray(obj)) {
    return obj.map(item => convertBuffers(item));
  }
  if (typeof obj === 'object') {
    return Object.fromEntries(
      Object.entries(obj).map(([key, value]) => [key, convertBuffers(value)])
    );
  }
  return obj;
}

function decodeJupiterSwap(txUpdate: any): SwapInfo | null {
  const tx = txUpdate.transaction;
  const meta = tx.meta;
  const message = tx.transaction.message;
  
  // Convert binary fields to readable format
  const signature = bs58.encode(tx.signature);
  const accountKeys = message.accountKeys.map((key: any) => bs58.encode(key));
  
  // Check if this is a Jupiter transaction
  const jupiterProgram = "JUP6LkbZbjS1jKKwapdHNy74zcZ3tLUZoi5QNyVTaV4";
  if (!accountKeys.includes(jupiterProgram)) {
    return null;
  }
  
  // Extract user (first account is typically the fee payer/user)
  const user = accountKeys[0];
  
  // Get token balance changes
  const tokenChanges = getTokenTransfers(meta);
  
  // Find input (negative change) and output (positive change)
  const inputChange = tokenChanges.find(change => change.change < 0);
  const outputChange = tokenChanges.find(change => change.change > 0);
  
  if (!inputChange || !outputChange) {
    return null;
  }
  
  return {
    signature,
    slot: parseInt(txUpdate.slot),
    user,
    inputMint: inputChange.mint,
    outputMint: outputChange.mint,
    inputAmount: Math.abs(inputChange.change),
    outputAmount: outputChange.change,
    fee: meta.fee,
    success: meta.err === null
  };
}

function getTokenTransfers(meta: any): Array<{mint: string, change: number}> {
  const transfers = [];
  
  const preBalances = new Map();
  const postBalances = new Map();
  
  meta.preTokenBalances.forEach((balance: any) => {
    preBalances.set(balance.accountIndex, balance);
  });
  
  meta.postTokenBalances.forEach((balance: any) => {
    postBalances.set(balance.accountIndex, balance);
  });
  
  for (const [accountIndex, postBalance] of postBalances) {
    const preBalance = preBalances.get(accountIndex);
    const preAmount = preBalance ? parseInt(preBalance.uiTokenAmount.amount) : 0;
    const postAmount = parseInt(postBalance.uiTokenAmount.amount);
    
    if (preAmount !== postAmount) {
      transfers.push({
        mint: postBalance.mint,
        change: postAmount - preAmount
      });
    }
  }
  
  return transfers;
}

async function runJupiterSwapMonitor() {
  const config: LaserstreamConfig = {
    apiKey: 'YOUR_API_KEY', // from https://dashboard.helius.dev/
    endpoint: 'https://laserstream-mainnet-ewr.helius-rpc.com', // pick the closest region
  };

  const request = {
    transactions: {
      "Jupiter-swaps": {
        vote: false,
        failed: false,
        accountInclude: ['JUP6LkbZbjS1jKKwapdHNy74zcZ3tLUZoi5QNyVTaV4']
      }
    },
    commitment: CommitmentLevel.PROCESSED,
    accounts: {}, slots: {}, transactionsStatus: {}, blocks: {}, blocksMeta: {}, entry: {}, accountsDataSlice: []
  };

  const stream = await subscribe(
    config,
    request,
    (update: SubscribeUpdate) => {
      if (update.transaction) {
        const swapInfo = decodeJupiterSwap(update.transaction);
        if (swapInfo) {
          console.log('🔄 Jupiter Swap:');
          console.log(`  User: ${swapInfo.user}`);
          console.log(`  Input: ${swapInfo.inputAmount} of ${swapInfo.inputMint}`);
          console.log(`  Output: ${swapInfo.outputAmount} of ${swapInfo.outputMint}`);
          console.log(`  Fee: ${swapInfo.fee} lamports`);
          console.log(`  Success: ${swapInfo.success}`);
          console.log(`  Signature: ${swapInfo.signature}`);
          console.log('---');
        }
      }
    },
    console.error
  );

  console.log(`✅ Jupiter swap monitor started (id: ${stream.id})`);
  process.on('SIGINT', () => { stream.cancel(); process.exit(0); });
}

runJupiterSwapMonitor().catch(console.error);

この例は、メッセージデコードをメタ解析と組み合わせ、複雑な DeFi トランザクションからビジネスに関連する情報を抽出する方法を示しています。

主なポイント

二部構成: すべてのトランザクションは、メッセージ（要求された内容）と meta（実際に起こった内容）を持ちます。
バイナリデコード: バイナリフィールドを読みやすい base58 文字列に変換するために bs58.encode() を使用します。
アカウントキーのルックアップ: 命令は accountKeys 配列のインデックスでアカウントを参照します。
残高追跡: preBalances と postBalances を比較して何が変わったかを確認します。
トランザクション v1: transactionConfig が存在する場合に計算予算と優先手数料を読み込みます。v1 トランザクションには ComputeBudget 命令はありません。

Solana トランザクションを理解する鍵は、それらが効率性のために設計されていることを認識することです: アドレスを繰り返す代わりに、ルックアップテーブルとインデックスを使用してトランザクションサイズを最小にし、情報密度を最大にしています。

ここから始める

リアルタイムデータ

低レイテンシ取引

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

RPC メソッドガイド

本番環境への対応

Orb の使用

その他のハウツー

トランザクションデータのデコードとパース

ライブストリーム、デコードなし

バイナリデータのデコード

トランザクション構造の理解

提案: メッセージ内部のすべて

トランザクションヘッダー

アカウントキー辞書

リプレイ防止

命令: 実際のコマンド

署名: 認証の証明

アドレスタブルックアップ

トランザクション v1: ヘッダー内の計算予算

すべての接続: フロー

実行: meta 内のすべて

基本的な実行情報

高度な実行詳細

実用的なデコードパターン

完全な例: Jupiter スワップデコーダー

主なポイント

​ライブストリーム、デコードなし

​バイナリデータのデコード

​トランザクション構造の理解

​提案: メッセージ内部のすべて

​トランザクションヘッダー

​アカウントキー辞書

​リプレイ防止

​命令: 実際のコマンド

​署名: 認証の証明

​アドレスタブルックアップ

​トランザクション v1: ヘッダー内の計算予算

​すべての接続: フロー

​実行: meta 内のすべて

​基本的な実行情報

​高度な実行詳細

​実用的なデコードパターン

​完全な例: Jupiter スワップデコーダー

​主なポイント

ライブストリーム、デコードなし

バイナリデータのデコード

トランザクション構造の理解

提案: メッセージ内部のすべて

トランザクションヘッダー

アカウントキー辞書

リプレイ防止

命令: 実際のコマンド

署名: 認証の証明

アドレスタブルックアップ

トランザクション v1: ヘッダー内の計算予算

すべての接続: フロー

実行: meta 内のすべて

基本的な実行情報

高度な実行詳細

実用的なデコードパターン

完全な例: Jupiter スワップデコーダー

主なポイント