اشتراكات WebSocket

تدعم نقاط نهاية Rome EVM اشتراكات Ethereum عبر WebSocket (eth_subscribe / eth_unsubscribe) عبر wss://. اتصل بنفس المضيف الخاص بـ HTTPS RPC، مع wss:// المخطط:

wss://<chain>.testnet.romeprotocol.xyz/

هذا ما ethers / viem WebSocketProvider تستخدمه في الخلفية، لذا .on('block'), contract.on(event)، و viemلـ watchEvent / watchBlocks تعمل مباشرةً دون إعداد إضافي.

أنواع الاشتراك

النوع	يُفعَّل عند	يُستخدم لـ
newHeads	كل كتلة جديدة	مؤشرات الكتل، تحديث الأرصدة/الـ nonces، روبوتات لكل كتلة، المفهرسات
السجلات	الأحداث المطابقة (حسب العنوان / الموضوعات)	التفاعل مع أحداث عقدك، المرحّلات/الجسور، روبوتات التداول
newPendingTransactions	—	مقبول لكنه لا يُصدر أبدًا (Rome لا يملك mempool عامًا)

ethers (الإصدار 6)

import { ethers } from "ethers";

const provider = new ethers.WebSocketProvider(
  "wss://martius-i.testnet.romeprotocol.xyz/"
);

// newHeads
provider.on("block", (blockNumber) => {
  console.log("كتلة جديدة", blockNumber);
});

// السجلات — التفاعل مع حدث عقد
const contract = new ethers.Contract(address, abi, provider);
contract.on("Transfer", (from, to, value) => {
  console.log("Transfer", from, to, value.toString());
});

viem

import { createPublicClient, webSocket } from "viem";

const client = createPublicClient({
  transport: webSocket("wss://martius-i.testnet.romeprotocol.xyz/"),
});

const unwatch = client.watchBlocks({
  onBlock: (block) => console.log("كتلة جديدة", block.number),
});

client.watchEvent({
  address,
  onLogs: (logs) => console.log(logs),
});

JSON-RPC الخام

→ {"jsonrpc":"2.0","id":1,"method":"eth_subscribe","params":["newHeads"]}
← {"jsonrpc":"2.0","id":1,"result":"0x…"}                       // معرّف الاشتراك
← {"jsonrpc":"2.0","method":"eth_subscription","params":{"subscription":"0x…","result":{…block…}}}

لـ السجلات، مرِّر كائن فلتر كمعامل ثانٍ:

{"jsonrpc":"2.0","id":1,"method":"eth_subscribe","params":["logs",{"address":"0x…","topics":["0x…"]}]}

ملاحظات

• تدفع الاشتراكات التحديثات كلما أُنتجت كتل جديدة (زمن الكمون يكون في حدود زمن الكتلة).

• بالنسبة للاتصالات طويلة الأمد، تعامل مع إعادة الاتصال في العميل الخاص بك — وهذا أمر قياسي في أي WebSocket RPC.