事前確認での取引

事前確認はトランザクションがシュレッド化される前にストリームします—Heliusはリーダーがトランザクションを実行すると同時に、実行ステータスと共に事前確認を行います。このガイドでは、ターゲットアカウントを監視し、各トランザクションをデコードし、Sender Maxを使用して反応するリスナーを構築します。

Preconfirmations はすべての有料プランで利用でき、配信されたメッセージ 1 件につき 10 クレジットかかります。配信されたメッセージが 0 件のスロットには、クレジットはかかりません。スロットで 1 件以上のメッセージが配信されると、各サブスクリプションには最低 300 クレジットが課金されます。料金をご覧ください。

接続する前にストリームの範囲を決定する

フィルターが設定されていない preconfSubscribe は、すべてのトランザクションを配信し、各トランザクションに 10 クレジットがかかります。サーバー側でフィルタリングし、実際に取引するトランザクションだけに料金を抑えてください。対象となるスロットで 1 件以上のメッセージを受信すると、各サブスクリプションは個別に課金されます。そのため、可能であればアカウントフィルターを 1 つのサブスクリプションにまとめてください。regionInclude を使用して、必要なリージョンのみに課金対象を限定してください。BAM が不要な場合は includeSource: ["helius"] を設定し、Helius Dashboardでクレジットを監視してください。

{
  "jsonrpc": "2.0",
  "id": 1,
  "method": "preconfSubscribe",
  "params": [
    {
      "includeSource": ["helius"],
      "failed": false,
      "regionInclude": ["ewr"],
      "accountInclude": ["TARGET_WALLET_OR_PROGRAM"]
    }
  ]
}

ほとんどのトレーディングリスナーに対応する3つのフィルター:

failed: falseは、すでに逆転が知られているトランザクションを除外します。競争する理由がありません。
regionIncludeは、インフラに最も近い地域にストリームを固定します。クロスリージョンのホップがスタートを消費しないようにします。
accountIncludeは、ターゲットに関連する任意のtxと一致します。ウォレット、AMMプール、プログラムなどです。Heliusはアドレス検索テーブルをサーバー側で解決するため、アカウントがALT経由で読み込まれてもフィルターが一致します。

接続、購読、デコード

preconfSubscribeはゲートキーパーエンドポイント(wss://beta.helius-rpc.com)から提供され、通知はバイナリフレームとして送信され、JSONではありません。各フレームは固定の18バイトのプレフィックスに続き、bincodeでシリアライズされたトランザクションが続きます:

listener.js

const WebSocket = require('ws');
const { VersionedTransaction } = require('@solana/web3.js');

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

ws.on('open', () => {
  ws.send(JSON.stringify({
    jsonrpc: '2.0',
    id: 1,
    method: 'preconfSubscribe',
    params: [{
      failed: false,
      regionInclude: ['ewr'],
      accountInclude: ['TARGET_WALLET_OR_PROGRAM']
    }]
  }));
  setInterval(() => ws.ping(), 30_000); // keep the connection alive
});

ws.on('message', (data, isBinary) => {
  if (!isBinary) {
    const msg = JSON.parse(data.toString());
    if (msg.id === 1) console.log('Subscribed, ID:', msg.result);
    return;
  }

  // version (u8) | slot (u64 LE) | tx_index (u64 LE) | status (u8) | bincode(VersionedTransaction)
  const buf = Buffer.from(data);
  if (buf.readUInt8(0) !== 1) return; // unknown schema version; update your decoder
  const slot = buf.readBigUInt64LE(1);
  const status = buf.readUInt8(17); // 0 = failed, 1 = success, 2 = unknown
  const tx = VersionedTransaction.deserialize(buf.subarray(18));

  onScheduledTransaction({ slot, status, tx });
});

ws.on('error', console.error);
ws.on('close', () => process.exit(1)); // let your supervisor restart and resubscribe

最初にバージョンバイトを確認します。Heliusがペイロードフォーマットを更新するとバージョンが増加し、それに基づいて分岐することでデコーダーを正常に動作させ続けます。デシリアライズされたトランザクションは、命令、アカウント、および署名を提供します。

Sender Maxで行動する

事前確認は、反応が最初に着地する場合にのみ価値があります。 Sender Maxを介して反応を送信します。0.001 SOLのチップは優先チップバッファに入り、すべての高速経路を通ります:

async function onScheduledTransaction({ slot, status, tx }) {
  if (!strategy.shouldReact(tx)) return;

  // strategy is your own code: it decides whether to react and returns a
  // signed, base64-encoded transaction that includes the tip and priority fee
  const reaction = await strategy.buildTransaction(tx);
  await fetch('http://ewr-sender.helius-rpc.com/fast', {
    method: 'POST',
    headers: { 'Content-Type': 'application/json' },
    body: JSON.stringify({
      jsonrpc: '2.0',
      id: Date.now().toString(),
      method: 'sendTransaction',
      params: [reaction, { encoding: 'base64', skipPreflight: true, maxRetries: 0 }]
    })
  });
}

このハンドラーを短く保ちます。決定して送信し、ログ、会計、調整を受信パスから外してください。フル送信ループ、接続のウォーミングアップ、手数料見積もりについてはSend Trades with Senderを参照してください。

着地を確認しギャップを予測する

事前確認は早期の確認です。トランザクションはまだ着地しておらず、失敗またはドロップされる可能性があるため、次の2つのルールが適用されます。

標準のコミットメントチェック(getSignatureStatuses、またはprocessedコミットメントストリーム経由)で確認し、観測されたトランザクションまたは反応を最終的なものとして扱う前に確認してください。
ギャップを予測します。カバレッジはHeliusに転送されるステークのシェアとともにスケールするため、いくつかのスロットではメッセージが生成されません。それは期待される動作であり、切断された接続とは異なります。キープアライブのpingがそれを区別します。接続が閉じたら再購読してください。

preconfSubscribe APIリファレンス

フィルターの完全なセマンティクス、地域コード、バイナリペイロードのレイアウト

事前処理されたトランザクションでの取引

すべての有料プランで、メッセージごとに0.1クレジットの事前実行カバレッジ

ここから始める

リアルタイムデータ

低レイテンシ取引

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

RPC メソッドガイド

本番環境への対応

Orb の使用

その他のハウツー

事前確認での取引

接続する前にストリームの範囲を決定する

接続、購読、デコード

Sender Maxで行動する

着地を確認しギャップを予測する

関連ガイド

preconfSubscribe APIリファレンス

事前処理されたトランザクションでの取引

​接続する前にストリームの範囲を決定する

​接続、購読、デコード

​Sender Maxで行動する

​着地を確認しギャップを予測する

​関連ガイド

preconfSubscribe APIリファレンス

事前処理されたトランザクションでの取引

接続する前にストリームの範囲を決定する

接続、購読、デコード

Sender Maxで行動する

着地を確認しギャップを予測する

関連ガイド