Zum Hauptinhalt springen

WebSocket-Ereignisse

QoreChain bietet Echtzeit-Ereignis-Streaming über zwei WebSocket-Schnittstellen: den EVM-kompatiblen WebSocket und den RPC-WebSocket der QoreChain-Konsens-Engine.

hinweis

Beide WebSocket-Schnittstellen sind im qorechain-vladi-Mainnet (live auf Chain-Version v3.1.85) und im qorechain-diana-Testnet verfügbar. Die untenstehenden lokalen Endpunkte gehen von einem Node aus, den Sie selbst betreiben; ersetzen Sie für den Fernzugriff den Mainnet- oder Testnet-Host Ihres Anbieters.

EVM-WebSocket​

Endpunkt: ws://localhost:8546

Der EVM-WebSocket unterstützt die Standardmethode eth_subscribe für Echtzeit-Ereignis-Streaming, das mit Ethereum-Werkzeugen kompatibel ist.

Abonnementtypen​

AbonnementBeschreibung
newHeadsSendet einen Header bei jedem Anhängen eines neuen Blocks
logsSendet Logs, die einem optionalen Filter entsprechen
newPendingTransactionsSendet Transaktions-Hashes, die in den Mempool gelangen
syncingSendet Aktualisierungen zum Sync-Status

Neue Blöcke abonnieren​

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

Logs mit Filter abonnieren​

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

Abonnement aufheben​

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

QoreChain-RPC-WebSocket​

Endpunkt: ws://localhost:26657/websocket

Der RPC-WebSocket verwendet das Ereignis-Abonnementsystem der QoreChain-Konsens-Engine. Clients abonnieren mit einer Abfragezeichenkette, die Ereignisse nach Typ und Attributen filtert.

Alle neuen Blöcke abonnieren​

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

Alle Transaktionen abonnieren​

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

Modulspezifische Ereignisse abonnieren​

Filtern Sie nach Ereignistyp, um nur Ereignisse eines bestimmten Moduls zu empfangen:

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

Abonnement aufheben​

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

Referenz der Modulereignisse​

PQC-Modul​

EreignistypSchlüsselattributeBeschreibung
pqc_hybrid_verifyaddress, algorithm, result (pass/fail), modeWird bei jeder Hybridsignaturverifizierung ausgelöst
pqc_hybrid_auto_registeraddress, algorithm, pubkey_hashWird ausgelöst, wenn ein PQC-Schlüssel automatisch registriert wird

KI-Modul​

EreignistypSchlüsselattributeBeschreibung
fraud_alertseverity (low/medium/high/critical), address, reason, scoreWird ausgelöst, wenn Betrug in einer Transaktion erkannt wird
circuit_breakermodule, action (tripped/reset), threshold, valueWird ausgelöst, wenn ein KI-Circuit-Breaker seinen Zustand ändert

Bridge-Modul​

EreignistypSchlüsselattributeBeschreibung
deposit_completedchain_id, sender, recipient, amount, asset, tx_hashWird ausgelöst, wenn eine eingehende Bridge-Einzahlung bestätigt wird
withdrawal_completedchain_id, sender, recipient, amount, asset, tx_hashWird ausgelöst, wenn eine ausgehende Bridge-Auszahlung bestätigt wird

Cross-VM-Modul​

EreignistypSchlüsselattributeBeschreibung
crossvm_requestmessage_id, source_vm, target_vm, sender, payload_hashWird ausgelöst, wenn ein VM-übergreifender Aufruf initiiert wird
crossvm_responsemessage_id, source_vm, target_vm, success, gas_usedWird ausgelöst, wenn ein VM-übergreifender Aufruf abgeschlossen wird
crossvm_timeoutmessage_id, source_vm, target_vm, queued_at_heightWird ausgelöst, wenn eine VM-übergreifende Nachricht das Warteschlangen-Timeout überschreitet

Multilayer-Modul​

EreignistypSchlüsselattributeBeschreibung
anchor_submittedlayer_id, layer_type, anchor_hash, height, submitterWird ausgelöst, wenn ein Layer-State-Anchor eingereicht wird
layer_status_changedlayer_id, previous_status, new_status, reasonWird ausgelöst, wenn eine Layer ihren Betriebsstatus ändert

RDK-Modul​

EreignistypSchlüsselattributeBeschreibung
rollup_createdrollup_id, operator, settlement_type, profileWird ausgelöst, wenn ein neues Rollup registriert wird
batch_submittedrollup_id, batch_index, state_root, tx_countWird ausgelöst, wenn ein Settlement-Batch eingereicht wird
batch_finalizedrollup_id, batch_index, finalized_at_heightWird ausgelöst, wenn ein Batch sein Challenge-Fenster durchläuft
da_blob_storedrollup_id, blob_index, size_bytes, commitmentWird ausgelöst, wenn ein DA-Blob gespeichert wird
da_blob_prunedrollup_id, blob_index, pruned_at_heightWird ausgelöst, wenn ein DA-Blob nach Ablauf der Aufbewahrung entfernt wird

Burn-Modul​

EreignistypSchlüsselattributeBeschreibung
fee_distributedtotal_fees, validator_amount, burn_amount, treasury_amount, staker_amountWird ausgelöst, wenn eingesammelte Gebühren verteilt werden
tokens_burnedamount, channel, block_heightWird ausgelöst, wenn Token dauerhaft verbrannt werden

xQORE-Modul​

EreignistypSchlüsselattributeBeschreibung
xqore_lockedaddress, amount, lock_duration, tierWird ausgelöst, wenn QOR in xQORE gesperrt wird
xqore_unlockedaddress, amount, penalty_applied, penalty_amountWird ausgelöst, wenn xQORE wieder zu QOR entsperrt wird
pvp_rebaseepoch, total_penalty, rebase_amount, beneficiary_countWird während der PvP-Rebase-Verteilung ausgelöst

Inflations-Modul​

EreignistypSchlüsselattributeBeschreibung
epoch_mintedepoch, minted_amount, inflation_rate, block_heightWird am Ende jeder Inflationsepoche ausgelöst

RL-Konsens-Modul​

PRISM-Parameteranpassungen und Circuit-Breaker-Aktivität werden über dieses Modul ausgegeben.

EreignistypSchlüsselattributeBeschreibung
rl_action_appliedaction_type, param_key, old_value, new_value, rewardWird ausgelöst, wenn der PRISM-Agent eine Parameteranpassung anwendet
circuit_breaker_triggeredreason, param_key, attempted_value, limitWird ausgelöst, wenn der PRISM-Circuit-Breaker eine Aktion blockiert

JavaScript-Client-Beispiel​

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 (nativ)​

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);
  }
};

Hinweise​

  • Verbindungslimits: Die standardmäßige maximale Anzahl von WebSocket-Verbindungen ist unbegrenzt (max-open-connections = 0). Legen Sie für Produktionsbereitstellungen ein Limit in app.toml fest.
  • Ereignispuffer: Der RPC-WebSocket puffert bis zu 200 Ereignisse pro Abonnement. Wenn der Client zurückfällt, werden ältere Ereignisse verworfen.
  • Wiederverbindung: Clients sollten eine automatische Wiederverbindung mit exponentiellem Backoff implementieren, da WebSocket-Verbindungen bei Node-Neustarts oder -Upgrades unterbrochen werden können.