Code Examples

JavaScript/TypeScript

Send Priority Message

import { ethers } from "ethers";

async function sendPriorityMessage(content, bidAmount) {
  const provider = new ethers.JsonRpcProvider("https://rpc.obsidian.network");
  const wallet = new ethers.Wallet(process.env.PRIVATE_KEY, provider);

  const payload = "0x" + Buffer.from(content).toString("hex");
  const nonce = "0x" + Date.now().toString(16);
  const chainId = "0x1a5";

  // Create signature
  const messageHash = ethers.keccak256(
    ethers.solidityPacked(["bytes", "uint256", "uint256"], [payload, nonce, chainId])
  );
  const signature = await wallet.signMessage(ethers.getBytes(messageHash));

  // Send with bid
  const result = await provider.send("eth_sendMessageBlob", [
    {
      from: wallet.address,
      data: payload,
      signature,
      nonce,
      chainId,
      bid: "0x" + ethers.parseEther(bidAmount).toString(16),
    },
  ]);

  return result;
}

// Usage
const hash = await sendPriorityMessage("Important update!", "0.01");

Send Free Message (with VDF)

async function computeVDF(challenge, iterations) {
  let hash = challenge;
  for (let i = 0; i < iterations; i++) {
    const iterHex = i.toString(16).padStart(16, "0");
    hash = ethers.keccak256(hash + iterHex);
  }
  return hash;
}

async function sendFreeMessage(content) {
  const provider = new ethers.JsonRpcProvider("https://rpc.obsidian.network");
  const wallet = new ethers.Wallet(process.env.PRIVATE_KEY, provider);

  const payload = "0x" + Buffer.from(content).toString("hex");
  const nonce = "0x" + Date.now().toString(16);
  const chainId = "0x1a5";

  // Get VDF work
  const payloadBytes = Buffer.from(content).length;
  const work = await provider.send("eth_getMessageWork", [
    {
      payloadSize: "0x" + payloadBytes.toString(16),
    },
  ]);

  // Compute challenge and VDF
  const challenge = ethers.keccak256(ethers.encodeRlp([chainId, wallet.address, payload, nonce]));
  const vdfProof = await computeVDF(challenge, parseInt(work.requiredIterations, 16));

  // Sign
  const messageHash = ethers.keccak256(
    ethers.solidityPacked(["bytes", "uint256", "uint256"], [payload, nonce, chainId])
  );
  const signature = await wallet.signMessage(ethers.getBytes(messageHash));

  // Send
  return await provider.send("eth_sendMessageBlob", [
    {
      from: wallet.address,
      data: payload,
      signature,
      nonce,
      chainId,
      vdfProof,
      vdfIterations: work.requiredIterations,
      vdfAlgVersion: "0x1",
    },
  ]);
}

Fetch Messages

async function getRecentMessages(blockCount = 10) {
  const provider = new ethers.JsonRpcProvider("https://rpc.obsidian.network");

  const latest = await provider.getBlockNumber();
  const messages = [];

  for (let i = 0; i < blockCount; i++) {
    const blockNum = latest - i;
    const result = await provider.send("eth_getBlockMessages", [
      {
        blockNumber: "0x" + blockNum.toString(16),
      },
    ]);
    messages.push(...(result.messages || []));
  }

  return messages;
}

// Decode payload
function decodePayload(hexPayload) {
  return Buffer.from(hexPayload.slice(2), "hex").toString("utf8");
}

Check Queue Status

async function checkQueueStatus() {
  const provider = new ethers.JsonRpcProvider("https://rpc.obsidian.network");

  const status = await provider.send("eth_getMessageQueueSize", []);

  console.log("PMQ size:", parseInt(status.pmqSize, 16));
  console.log("SMQ size:", parseInt(status.smqSize, 16));
  console.log("Top bid:", ethers.formatEther(BigInt(status.topBid || "0x0")), "OBS");

  return status;
}

Python

from web3 import Web3
from eth_account import Account
import time

w3 = Web3(Web3.HTTPProvider('https://rpc.obsidian.network'))

def send_message(private_key, content, bid_obs=None):
    account = Account.from_key(private_key)

    payload = '0x' + content.encode().hex()
    nonce = hex(int(time.time() * 1000))
    chain_id = '0x1a5'

    # Sign message
    message_hash = Web3.keccak(payload + nonce + chain_id)
    signed = account.sign_message(message_hash)

    params = {
        'from': account.address,
        'data': payload,
        'signature': signed.signature.hex(),
        'nonce': nonce,
        'chainId': chain_id
    }

    if bid_obs:
        params['bid'] = hex(int(bid_obs * 10**18))

    return w3.provider.make_request('eth_sendMessageBlob', [params])

cURL

# Get queue status
curl -X POST https://rpc.obsidian.network \
  -H "Content-Type: application/json" \
  -d '{"jsonrpc":"2.0","method":"eth_getMessageQueueSize","params":[],"id":1}'

# Get block messages
curl -X POST https://rpc.obsidian.network \
  -H "Content-Type: application/json" \
  -d '{"jsonrpc":"2.0","method":"eth_getBlockMessages","params":[{"blockNumber":"latest"}],"id":1}'