プレコンファメーション

preconfSubscribe

バリデーターがSolanaのトランザクションを実行することをコミットした瞬間にスケジュールされたトランザクションを購読します—シュレッドにされる前に。HeliusとJito BAMのプレコンファメーションをソース、ステータス、地域、アカウントでオプションのサーバーサイドフィルタリングでストリームします。

{
  "jsonrpc": "2.0",
  "id": 1,
  "method": "preconfSubscribe",
  "params": [
    {
      "failed": false,
      "regionInclude": ["ewr", "fra"],
      "accountInclude": ["9WzDXwBbmkg8ZTbNMqUxvQRAyrZzDsGYdLVL9zYtAWWM"]
    }
  ]
}

{
  "jsonrpc": "2.0",
  "id": 1,
  "method": "preconfSubscribe",
  "params": [{ "includeBam": false }]
}

const WebSocket = require('ws');

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

ws.on('open', () => {
  ws.send(JSON.stringify({
    jsonrpc: '2.0',
    id: 1,
    method: 'preconfSubscribe' // Helius and BAM preconfirmations by default
    // Optional filter:
    // params: [{ failed: false, accountInclude: ['9WzDXwBbmkg8ZTbNMqUxvQRAyrZzDsGYdLVL9zYtAWWM'] }]
    // Helius preconfirmations only:
    // params: [{ includeBam: false }]
  }));

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

ws.on('message', (data, isBinary) => {
  // The subscribe acknowledgement arrives as a JSON text frame
  if (!isBinary) {
    const msg = JSON.parse(data.toString());
    if (msg.id === 1) console.log('Subscribed, ID:', msg.result);
    return;
  }

  // Notifications arrive as binary frames:
  // version (u8) | slot (u64 LE) | tx_index (u64 LE) | status (u8) | transaction bytes
  const buf = Buffer.from(data);
  const version = buf.readUInt8(0);
  if (version !== 1) return; // unknown schema version; update your decoder
  const slot = buf.readBigUInt64LE(1);
  const txIndex = buf.readBigUInt64LE(9); // always 0 for BAM preconfirmations
  const status = buf.readUInt8(17); // 0 = failed, 1 = success, 2 = unknown (always 2 for BAM)
  const txBytes = buf.subarray(18); // transaction in Solana wire format (legacy, v0, or v1)

  console.log('Scheduled transaction:', { slot, txIndex, status, bytes: txBytes.length });
});

{ "jsonrpc": "2.0", "id": 1, "result": 24040 }

version   u8              payload schema version, currently 1
slot      u64 (LE)        slot the transaction is scheduled in
tx_index  u64 (LE)        index of the transaction within the slot (always 0 for BAM)
status    u8              0 = failed, 1 = success, 2 = unknown (always 2 for BAM)
tx        bytes           transaction in Solana wire format (legacy, v0, or v1)

Preconfirmationsへの購読を開始します — エントリに収集されシュレッドに変換される前のスケジュールされたトランザクション段階で配信されるトランザクションです。これはHeliusが提供する最も低遅延のトランザクション信号です。1回の購読でHeliusプレコンファメーションとBAMプレコンファメーションの両方をストリームします; includeBam: falseを設定してHeliusプレコンファメーションのみを受け取ります。

Endpoints

preconfSubscribe is served from the Helius Gatekeeper endpoint:

wss://beta.helius-rpc.com/?api-key=<API_KEY>

The beta hostname refers to the Gatekeeper rollout, not the maturity of Preconfirmations — it will become the standard endpoint as traffic migrates to Gatekeeper.

ストリームは連続していません。HeliusまたはBAMを実行するネットワークステークのシェアに応じてカバレッジがスケールするため、メッセージのないスロットが発生することを予測し、これらのギャップを優雅に処理します。詳細はCoverageをご覧ください。

Authorizations

string

必須

Your Helius API key, passed as the api-key query parameter. Requires a Professional plan or higher.

Body

array

オプションです。paramsを省略すると、HeliusとBAMからのすべてのスケジュールされたトランザクションを受け取ります。ストリームを狭めるために、最初の要素としてフィルターオブジェクトを渡します—フィルタリングはサーバー側で行われるため、関心のあるトランザクションのみを受け取り、支払うだけです。

非表示 Filter

すべてのフィールドはオプションです — 欠落しているフィールドはその述語に対して”制約なし”を意味するため、空のフィルターは両方のソースからのすべてのトランザクションに一致します。設定されたフィールドはANDで結合され、includeBam → failed → regionInclude → accountExclude → accountRequired → accountIncludeの順番で評価されます。

boolean

デフォルト:"true"

falseはBAMプレコンファメーションをドロップし、Heliusプレコンファメーションのみを受け取ります。trueは、フィールドを省略した場合と同様に、両方のソースを保持します。

boolean

ステータスフィルタリングはHeliusの事前承認でのみサポートされ、BAMの事前承認では無視されます。Heliusの場合、true は失敗（リバートされた）トランザクションのみを返し、false は成功したトランザクションのみを返します。どちらの値もステータスが不明なHeliusトランザクションは除外します。すべてのステータスを受け取るにはフィールドを省略してください。BAMの事前承認は、ソース、リージョン、およびアカウントフィルターに一致する場合にのみ配信されます。

string[]

もし空ではない場合、トランザクションはこれらの地域のいずれかから発信する必要があります。地域情報がないトランザクションは、これが設定されている場合にドロップされます。

string[]

もし空ではない場合、トランザクションはこれらのアカウント（base58 pubkeys）の少なくとも1つを参照する必要があります。500エントリまで制限されています。

string[]

もしトランザクションがこれらのアカウントのいずれかを参照する場合、それはドロップされます。accountIncludeよりも優先されます。500エントリまで制限されています。

string[]

トランザクションはこれらのアカウントすべてを参照する必要があります。500エントリまで制限されています。

無効なアカウント値または認識されない地域コードは、JSON-RPCエラー-32602（無効なパラメータ）を返します。アカウントフィルターは、トランザクションの静的なアカウントキー以上のものに一致します — Heliusはサーバー側でv0 アドレスルックアップ表を解決し、accountInclude、accountExclude、およびaccountRequiredもトランザクションがALTを通じてロードするアカウントに一致します。

地域コード

コード	場所	コード	場所
`slc`	ソルトレイクシティ	`tyo`	東京
`fra`	フランクフルト	`ams`	アムステルダム
`lon`	ロンドン	`dal`	ダラス
`pit`	ピッツバーグ	`dub`	ダブリン
`sgp`	シンガポール	`mia`	マイアミ
`ewr`	ニューアーク	`lax`	ロサンゼルス
`iad`	アッシュバーン	`sea`	シアトル
`hkg`	香港	`sqq`	リトアニア、シャウレイ

Heliusプレコンファメーションの場合、地域はHeliusがトランザクションを取り込んだ場所です。BAMプレコンファメーションの場合、それはプレコンファメーションを発行した地域のBAMエンドポイントであり、Heliusがそれを取り込んだ場所ではありません。BAMのシンガポールおよびダラスのエンドポイントはsgpおよびdalにマップされます。

レスポンス

integer

購読ID（購読解除に必要）

{
  "jsonrpc": "2.0",
  "id": 1,
  "method": "preconfSubscribe",
  "params": [
    {
      "failed": false,
      "regionInclude": ["ewr", "fra"],
      "accountInclude": ["9WzDXwBbmkg8ZTbNMqUxvQRAyrZzDsGYdLVL9zYtAWWM"]
    }
  ]
}

{
  "jsonrpc": "2.0",
  "id": 1,
  "method": "preconfSubscribe",
  "params": [{ "includeBam": false }]
}

const WebSocket = require('ws');

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

ws.on('open', () => {
  ws.send(JSON.stringify({
    jsonrpc: '2.0',
    id: 1,
    method: 'preconfSubscribe' // Helius and BAM preconfirmations by default
    // Optional filter:
    // params: [{ failed: false, accountInclude: ['9WzDXwBbmkg8ZTbNMqUxvQRAyrZzDsGYdLVL9zYtAWWM'] }]
    // Helius preconfirmations only:
    // params: [{ includeBam: false }]
  }));

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

ws.on('message', (data, isBinary) => {
  // The subscribe acknowledgement arrives as a JSON text frame
  if (!isBinary) {
    const msg = JSON.parse(data.toString());
    if (msg.id === 1) console.log('Subscribed, ID:', msg.result);
    return;
  }

  // Notifications arrive as binary frames:
  // version (u8) | slot (u64 LE) | tx_index (u64 LE) | status (u8) | transaction bytes
  const buf = Buffer.from(data);
  const version = buf.readUInt8(0);
  if (version !== 1) return; // unknown schema version; update your decoder
  const slot = buf.readBigUInt64LE(1);
  const txIndex = buf.readBigUInt64LE(9); // always 0 for BAM preconfirmations
  const status = buf.readUInt8(17); // 0 = failed, 1 = success, 2 = unknown (always 2 for BAM)
  const txBytes = buf.subarray(18); // transaction in Solana wire format (legacy, v0, or v1)

  console.log('Scheduled transaction:', { slot, txIndex, status, bytes: txBytes.length });
});

{ "jsonrpc": "2.0", "id": 1, "result": 24040 }

version   u8              payload schema version, currently 1
slot      u64 (LE)        slot the transaction is scheduled in
tx_index  u64 (LE)        index of the transaction within the slot (always 0 for BAM)
status    u8              0 = failed, 1 = success, 2 = unknown (always 2 for BAM)
tx        bytes           transaction in Solana wire format (legacy, v0, or v1)

通知

JSONの受理通知後、通知はバイナリのWebSocketフレームとして配信されます（JSONではありません）。HeliusとBAMプレコンファメーションは同じレイアウトを共有しています。各フレームは1つのスケジュールされたトランザクションを運ぶパックされたバイトレイアウトです。

バイト	フィールド	型	説明
0	`version`	`u8`	ペイロードのスキーマバージョン。現在は`1`です。
1–8	`slot`	`u64`（リトルエンディアン）	トランザクションがスケジュールされたスロットです。
9–16	`tx_index`	`u64`（リトルエンディアン）	スロット内のトランザクションのインデックス。BAMプレコンファメーションの場合、常に`0`で、スロットインデックスではなくシーケンスIDとバンドル位置を運びます。
17	`status`	`u8`	トランザクションのステータス: `0` = 失敗, `1` = 成功, `2` = 不明。Heliusプレコンファメーションはベストエフォートで実行ステータスを報告し、利用できない場合は`2`になります。BAMプレコンファメーションは常に`2`を報告します。
18+	`transaction`	`bytes`	Solanaワイヤーフォーマットでのスケジュールされたトランザクション。詳細はDecoding the transactionを参照してください。

ペイロードにソースフィールドはありません。Heliusプレコンファメーションも同じ値を持つことができるため、tx_index = 0およびstatus = 2からBAMの起源を推測しないでください。

実行ステータスを持っているのはHeliusプレコンファメーションのみです。 Helius プレコンファメーションはバリデーターが提供する場合に0（失敗）や1（成功）を報告し、利用できない場合にのみ2を報告します。BAMプレコンファメーションは常に 2（不明）を報告するため、statusだけでBAM由来のトランザクションが成功したかどうかを判断することはできません。実行ステータスに依存する戦略を立てる場合は、 includeBam: falseを設定するか、オンチェーンで結果を確認してください。

常にversionバイトを最初に読み取り、チェックしてください。 現在は1です。もし Heliusがペイロードフォーマットを更新する必要が生じた場合、バージョンがインクリメントされます — スキーマの変更に応じてデコーダーが動作を維持するようにブランチしてください。

プレコンファメーションは初期のシグナルであり保証ではありません。トランザクションはまだオンチェーンに着地しておらず、失敗したりドロップされたりすることがあります。最終的なものとみなす前に、標準のコミットメントチェックを通じて着地を確認してください。

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

トランザクションのバイトは、バリデーターがシリアライズしたとおりに正確に転送され、トランザクションのバージョンに対する標準のワイヤーエンコーディングでエンコードされています。レガシーおよびv0のトランザクションはbincodeが生成するシグネチャ優先レイアウトを使用します。トランザクションv1（SIMD-0385）はメッセージ優先レイアウトで、シグネチャは末尾に置かれ、bincodeはv1ペイロードに対しては機能しません。すべてのバージョンに対応するデコーダを使用してください。Rustでは、agave-transaction-viewはレガシー、v0、およびv1トランザクションをその場でパースし、推奨オプションです; wincodeは現在のSolana SDK VersionedTransactionでも機能します。JavaScriptでは、必ずライブラリバージョンがトランザクションv1をサポートしていることを確認してください。Rustの例はガイドをご覧ください。

重複通知

HeliusとBAMプレコンファメーションはソースごとに重複排除され、ソース全体ではありません。少量のトランザクションが両方の経路でHeliusに届くことがあるため、同じシグネチャを2回受け取ることができ、2つのコピーが異なるスロットを報告する可能性があります。クライアントでシグネチャによる重複排除を行い、トランザクションをトリガーとしてアクションを冪等にしてください。詳細はガイドをご覧ください。

価格

プレコンファメーションはプロフェッショナルプラン以上が必要で、1メッセージにつき10クレジットかかります—1メッセージはストリームされたトランザクションごとです。詳細はクレジットをご覧ください。請求はユニークなシグネチャごとではなく、メッセージごとに行われます。HeliusとBAMの両方から配信されたトランザクションは2回カウントされます。includeBam: falseを設定すれば、Heliusプレコンファメーションのみを受け取ることができます。

プレコンファメーション概要

プレコンファメーションとは何か、およびバリデーターパイプラインのどこに位置するかを説明します。

preconfUnsubscribe

idで購読を停止します。

⌘I

{
  "jsonrpc": "2.0",
  "id": 1,
  "method": "preconfSubscribe",
  "params": [
    {
      "failed": false,
      "regionInclude": ["ewr", "fra"],
      "accountInclude": ["9WzDXwBbmkg8ZTbNMqUxvQRAyrZzDsGYdLVL9zYtAWWM"]
    }
  ]
}

{
  "jsonrpc": "2.0",
  "id": 1,
  "method": "preconfSubscribe",
  "params": [{ "includeBam": false }]
}

const WebSocket = require('ws');

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

ws.on('open', () => {
  ws.send(JSON.stringify({
    jsonrpc: '2.0',
    id: 1,
    method: 'preconfSubscribe' // Helius and BAM preconfirmations by default
    // Optional filter:
    // params: [{ failed: false, accountInclude: ['9WzDXwBbmkg8ZTbNMqUxvQRAyrZzDsGYdLVL9zYtAWWM'] }]
    // Helius preconfirmations only:
    // params: [{ includeBam: false }]
  }));

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

ws.on('message', (data, isBinary) => {
  // The subscribe acknowledgement arrives as a JSON text frame
  if (!isBinary) {
    const msg = JSON.parse(data.toString());
    if (msg.id === 1) console.log('Subscribed, ID:', msg.result);
    return;
  }

  // Notifications arrive as binary frames:
  // version (u8) | slot (u64 LE) | tx_index (u64 LE) | status (u8) | transaction bytes
  const buf = Buffer.from(data);
  const version = buf.readUInt8(0);
  if (version !== 1) return; // unknown schema version; update your decoder
  const slot = buf.readBigUInt64LE(1);
  const txIndex = buf.readBigUInt64LE(9); // always 0 for BAM preconfirmations
  const status = buf.readUInt8(17); // 0 = failed, 1 = success, 2 = unknown (always 2 for BAM)
  const txBytes = buf.subarray(18); // transaction in Solana wire format (legacy, v0, or v1)

  console.log('Scheduled transaction:', { slot, txIndex, status, bytes: txBytes.length });
});

{ "jsonrpc": "2.0", "id": 1, "result": 24040 }

version   u8              payload schema version, currently 1
slot      u64 (LE)        slot the transaction is scheduled in
tx_index  u64 (LE)        index of the transaction within the slot (always 0 for BAM)
status    u8              0 = failed, 1 = success, 2 = unknown (always 2 for BAM)
tx        bytes           transaction in Solana wire format (legacy, v0, or v1)

はじめに

データストリーミング & イベントリスニング

データAPI & RPCs

トレーディング

トランザクションの送信

アカウント管理

preconfSubscribe

Endpoints

Authorizations

Body

地域コード

レスポンス

通知

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

重複通知

価格

関連

プレコンファメーション概要

preconfUnsubscribe

​Endpoints

​Authorizations

​Body

​地域コード

​レスポンス

​通知

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

​重複通知

​価格

​関連

プレコンファメーション概要

preconfUnsubscribe

Endpoints

Authorizations

Body

地域コード

レスポンス

通知

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

重複通知

価格

関連