メインコンテンツまでスキップ

WebSocket イベント

QoreChain は、2つの WebSocket インターフェースを通じてリアルタイムのイベントストリーミングを提供します。EVM 互換の WebSocket と、QoreChain コンセンサスエンジン RPC WebSocket です。

注記

両方の WebSocket インターフェースは、qorechain-vladi メインネット（チェーンバージョン v3.1.85 で稼働中）と qorechain-diana テストネットで利用できます。以下のローカルエンドポイントは自分で運用するノードを前提としています。リモートアクセスの場合は、プロバイダーのメインネットまたはテストネットのホストに置き換えてください。

EVM WebSocket​

エンドポイント: ws://localhost:8546

EVM WebSocket は、Ethereum ツールと互換性のあるリアルタイムイベントストリーミングのための標準的な eth_subscribe メソッドをサポートします。

サブスクリプションタイプ​

サブスクリプション説明
newHeads新しいブロックが追加されるたびにヘッダーを発行します
logsオプションのフィルターに一致するログを発行します
newPendingTransactionsmempool に入るトランザクションハッシュを発行します
syncing同期ステータスの更新を発行します

新しいブロックのサブスクライブ​

{
  "jsonrpc": "2.0",
  "method": "eth_subscribe",
  "params": ["newHeads"],
  "id": 1
}

フィルター付きでログをサブスクライブ​

{
  "jsonrpc": "2.0",
  "method": "eth_subscribe",
  "params": [
    "logs",
    {
      "address": "0x742d35Cc6634C0532925a3b844Bc9e7595f2bD28",
      "topics": ["0xddf252ad1be2c89b69c2b068fc378daa952ba7f163c4a11628f55a4df523b3ef"]
    }
  ],
  "id": 2
}

サブスクライブ解除​

{
  "jsonrpc": "2.0",
  "method": "eth_unsubscribe",
  "params": ["0x1a2b3c..."],
  "id": 3
}

QoreChain RPC WebSocket​

エンドポイント: ws://localhost:26657/websocket

RPC WebSocket は、QoreChain コンセンサスエンジンのイベントサブスクリプションシステムを使用します。クライアントは、タイプと属性でイベントをフィルタリングするクエリ文字列を使ってサブスクライブします。

すべての新しいブロックをサブスクライブ​

{
  "jsonrpc": "2.0",
  "method": "subscribe",
  "params": {
    "query": "tm.event='NewBlock'"
  },
  "id": 1
}

すべてのトランザクションをサブスクライブ​

{
  "jsonrpc": "2.0",
  "method": "subscribe",
  "params": {
    "query": "tm.event='Tx'"
  },
  "id": 2
}

モジュール固有のイベントをサブスクライブ​

イベントタイプでフィルタリングして、特定のモジュールからのイベントのみを受信します。

{
  "jsonrpc": "2.0",
  "method": "subscribe",
  "params": {
    "query": "tm.event='Tx' AND fraud_alert.severity EXISTS"
  },
  "id": 3
}

サブスクライブ解除​

{
  "jsonrpc": "2.0",
  "method": "unsubscribe",
  "params": {
    "query": "tm.event='NewBlock'"
  },
  "id": 4
}

モジュールイベントリファレンス​

PQC モジュール​

イベントタイプ主な属性説明
pqc_hybrid_verifyaddress, algorithm, result (pass/fail), mode各ハイブリッド署名検証時に発行されます
pqc_hybrid_auto_registeraddress, algorithm, pubkey_hashPQC キーが自動登録されたときに発行されます

AI モジュール​

イベントタイプ主な属性説明
fraud_alertseverity (low/medium/high/critical), address, reason, scoreトランザクションで不正が検出されたときに発行されます
circuit_breakermodule, action (tripped/reset), threshold, valueAI サーキットブレーカーが状態を変更したときに発行されます

ブリッジモジュール​

イベントタイプ主な属性説明
deposit_completedchain_id, sender, recipient, amount, asset, tx_hashインバウンドのブリッジデポジットが確認されたときに発行されます
withdrawal_completedchain_id, sender, recipient, amount, asset, tx_hashアウトバウンドのブリッジ出金が確認されたときに発行されます

クロス VM モジュール​

イベントタイプ主な属性説明
crossvm_requestmessage_id, source_vm, target_vm, sender, payload_hashクロス VM 呼び出しが開始されたときに発行されます
crossvm_responsemessage_id, source_vm, target_vm, success, gas_usedクロス VM 呼び出しが完了したときに発行されます
crossvm_timeoutmessage_id, source_vm, target_vm, queued_at_heightクロス VM メッセージがキューのタイムアウトを超えたときに発行されます

マルチレイヤーモジュール​

イベントタイプ主な属性説明
anchor_submittedlayer_id, layer_type, anchor_hash, height, submitterレイヤー状態アンカーが提出されたときに発行されます
layer_status_changedlayer_id, previous_status, new_status, reasonレイヤーが稼働ステータスを変更したときに発行されます

RDK モジュール​

イベントタイプ主な属性説明
rollup_createdrollup_id, operator, settlement_type, profile新しいロールアップが登録されたときに発行されます
batch_submittedrollup_id, batch_index, state_root, tx_count決済バッチが提出されたときに発行されます
batch_finalizedrollup_id, batch_index, finalized_at_heightバッチがチャレンジウィンドウを通過したときに発行されます
da_blob_storedrollup_id, blob_index, size_bytes, commitmentDA ブロブが保存されたときに発行されます
da_blob_prunedrollup_id, blob_index, pruned_at_height保持期間後に DA ブロブがプルーニングされたときに発行されます

バーンモジュール​

イベントタイプ主な属性説明
fee_distributedtotal_fees, validator_amount, burn_amount, treasury_amount, staker_amount収集された手数料が分配されたときに発行されます
tokens_burnedamount, channel, block_heightトークンが永久にバーンされたときに発行されます

xQORE モジュール​

イベントタイプ主な属性説明
xqore_lockedaddress, amount, lock_duration, tierQOR が xQORE にロックされたときに発行されます
xqore_unlockedaddress, amount, penalty_applied, penalty_amountxQORE が QOR に戻ってアンロックされたときに発行されます
pvp_rebaseepoch, total_penalty, rebase_amount, beneficiary_countPvP リベース分配時に発行されます

インフレーションモジュール​

イベントタイプ主な属性説明
epoch_mintedepoch, minted_amount, inflation_rate, block_height各インフレエポックの終わりに発行されます

RL コンセンサスモジュール​

PRISM パラメータの調整とサーキットブレーカーの動作は、このモジュールを通じて発行されます。

イベントタイプ主な属性説明
rl_action_appliedaction_type, param_key, old_value, new_value, rewardPRISM エージェントがパラメータ調整を適用したときに発行されます
circuit_breaker_triggeredreason, param_key, attempted_value, limitPRISM サーキットブレーカーがアクションをブロックしたときに発行されます

JavaScript クライアントの例​

EVM WebSocket（ethers.js）​

import { ethers } from "ethers";

const provider = new ethers.WebSocketProvider("ws://localhost:8546");

// Subscribe to new blocks
provider.on("block", (blockNumber) => {
  console.log("New block:", blockNumber);
});

// Subscribe to contract events
const filter = {
  address: "0x742d35Cc6634C0532925a3b844Bc9e7595f2bD28",
  topics: [ethers.id("Transfer(address,address,uint256)")],
};
provider.on(filter, (log) => {
  console.log("Transfer event:", log);
});

QoreChain RPC WebSocket（ネイティブ）​

const ws = new WebSocket("ws://localhost:26657/websocket");

ws.onopen = () => {
  // Subscribe to fraud alerts
  ws.send(JSON.stringify({
    jsonrpc: "2.0",
    method: "subscribe",
    params: { query: "tm.event='Tx' AND fraud_alert.severity EXISTS" },
    id: 1,
  }));

  // Subscribe to rollup batch submissions
  ws.send(JSON.stringify({
    jsonrpc: "2.0",
    method: "subscribe",
    params: { query: "tm.event='Tx' AND batch_submitted.rollup_id EXISTS" },
    id: 2,
  }));
};

ws.onmessage = (event) => {
  const data = JSON.parse(event.data);
  if (data.result && data.result.events) {
    console.log("Event received:", data.result.events);
  }
};

注記​

  • 接続制限: WebSocket 接続のデフォルトの最大数は無制限です（max-open-connections = 0）。本番デプロイでは app.toml で制限を設定してください。
  • イベントバッファ: RPC WebSocket は、サブスクリプションごとに最大 200 件のイベントをバッファリングします。クライアントが遅れた場合、古いイベントは破棄されます。
  • 再接続: WebSocket 接続はノードの再起動やアップグレード中に中断される可能性があるため、クライアントは指数バックオフを用いた自動再接続を実装する必要があります。