Nitro Routing API

{
  "ok": true,
  "rttMs": 94,
  "blockNumber": "0x1D3E7A2",
  "winner": "https://0g-rpc.publicnode.com",
  "pool": [
    { "url": "https://0g-rpc.publicnode.com", "latencyMs": 94,   "healthy": true },
    { "url": "https://evmrpc.0g.ai",          "latencyMs": 1843, "healthy": true }
  ]
}

curl https://opacus.xyz/api/v1/nitro/ping | jq .

// Request
{ "intent": "swap USDC to W0G on Jaine", "chain": "0g", "latitude": 41.0082, "longitude": 28.9784 }

// Response
{
  "ok": true,
  "quicEndpoint": "quic://sg-sin-1.0g.network:4433",
  "nitroLabel": "Singapore Nitro",
  "anchor_mode": "execution",
  "reason": "Execution anchor: 0G Jaine infra on Singapore (AWS ap-southeast-1)",
  "failover": "Mumbai Nitro",
  "latency_p50_ms": 16
}

// Request
{ "intent": "analyze my portfolio risk", "latitude": 52.5200, "longitude": 13.4050 }

// Response
{
  "ok": true,
  "quicEndpoint": "quic://eu-fra-1.0g.network:4433",
  "nitroLabel": "Frankfurt Nitro",
  "anchor_mode": "interactive",
  "reason": "Read-only analysis, no execution anchor needed. Nearest node to Frankfurt selected.",
  "failover": "Amsterdam Nitro",
  "latency_p50_ms": 9
}

import { generateKeyPairSync } from 'node:crypto';

const { privateKey, publicKey } = generateKeyPairSync('ed25519');
const privDer = privateKey.export({ type: 'pkcs8', format: 'der' });
const pubDer  = publicKey.export({ type: 'spki', format: 'der' });

import { sign } from 'node:crypto';

const payload   = Buffer.from(JSON.stringify({ taskId, result, timestamp }));
const signature = sign(null, payload, privateKey).toString('hex');

const signedResult = { taskId, result, timestamp, agentPubKey: pubDer.toString('hex'), sig: signature };

import { verify, createPublicKey } from 'node:crypto';

function verifyTaskResult(r) {
  const payload = Buffer.from(JSON.stringify({ taskId: r.taskId, result: r.result, timestamp: r.timestamp }));
  const pubKey  = createPublicKey({ key: Buffer.from(r.agentPubKey, 'hex'), format: 'der', type: 'spki' });
  return verify(null, payload, pubKey, Buffer.from(r.sig, 'hex'));
}

const API = 'https://opacus.xyz/api';
const KEY = 'YOUR_API_KEY';

async function runTask(intent: string, lat: number, lng: number) {
  // 1. Race the RPC pool
  const ping = await fetch(`${API}/v1/nitro/ping`).then(r => r.json());
  console.log(`Best RPC: ${ping.winner} @ ${ping.rttMs}ms  block #${parseInt(ping.blockNumber, 16)}`);

  // 2. Get optimal Nitro node
  const handoff = await fetch(`${API}/v1/nitro/handoff`, {
    method: 'POST',
    headers: { Authorization: `Bearer ${KEY}`, 'Content-Type': 'application/json' },
    body: JSON.stringify({ intent, latitude: lat, longitude: lng })
  }).then(r => r.json());

  console.log(`→ ${handoff.nitroLabel} (${handoff.anchor_mode})  ${handoff.quicEndpoint}`);

  // 3. Execute
  const exec = await fetch(`${API}/v1/task-execution`, {
    method: 'POST',
    headers: { Authorization: `Bearer ${KEY}`, 'Content-Type': 'application/json' },
    body: JSON.stringify({ intent, nitroEndpoint: handoff.quicEndpoint })
  }).then(r => r.json());

  // 4. Verify Ed25519 signature
  if (exec.sig && exec.agentPubKey) {
    const valid = verifyTaskResult(exec);
    console.log(`Signature: ${valid ? '✓ valid' : '✗ INVALID'}`);
  }
  return exec;
}

runTask('swap 10 USDC to W0G on Jaine', 41.0082, 28.9784);