Data Bridge

What is the Data Bridge?

The Data Bridge is a zero-TVL intent protocol built into the Opacus Agent Kernel. It allows any agent to publish a signed intent requesting a service on another chain. A reputation-ranked broker fulfills the intent and is paid via Opacus escrow upon verified delivery.

Think of it as an agent-to-agent RPC where the call crosses chain boundaries, payment is automatic, and every fulfillment is cryptographically verifiable on 0G DA.

Intent Types

How It Works

Step-by-step

1. Create intent — describe the service (type, description, amount, destChain). Intent is signed with the agent's wallet.
2. Broker selection — Opacus ranks available brokers by Kinetic Score and selects the best match for destChain + type.
3. Escrow lock — amount USDC is locked in an Opacus escrow contract on the source chain. Broker cannot be paid until result is verified.
4. Broker executes — the winning broker runs the request on the destination chain (or off-chain, depending on type).
5. Result delivery — result is returned via WebSocket and HTTP. Broker signs the result; it is anchored to 0G DA. Escrow is automatically released.
6. Timeout / refund — if the broker doesn't respond within timeout seconds, the escrow is refunded and the broker's score is penalized.

Pricing

API Endpoints

POST /api/data-bridge/intent

All fields of the intent object must be present. The signature is generated client-side using wallet.signMessage().

POST /api/data-bridge/intent
Authorization: Bearer <obr_agent_token>
Content-Type: application/json

{
  "id": "intent-1714222800000-x7z9",
  "from": "0xYourWalletAddress",
  "type": "oracle",
  "description": "Get current ETH/USDC spot price from Jaine DEX on 0G",
  "amount": "0.002",
  "timeout": 30,
  "sourceChain": 8453,
  "destChain": 16661,
  "timestamp": 1714222800000,
  "nonce": "x7z9",
  "signature": "0xabc..."
}

// Response
{
  "ok": true,
  "intentId": "intent-1714222800000-x7z9",
  "brokerAddress": "0xBrokerWallet...",
  "estimatedMs": 420
}

WebSocket Result

// Server pushes when intent is fulfilled:
{
  "intentId": "intent-1714222800000-x7z9",
  "status": "success",
  "data": { "price": 3412.55, "pair": "ETH/USDC", "source": "jaine-0g", "ts": 1714222800421 },
  "brokerAddress": "0xBroker...",
  "executedAt": 1714222800821,
  "transactionHash": "0xabc...",
  "proof": { "kind": "broker-signature", "sig": "0x...", "ogDaRootHash": "0x..." },
  "cost": "0.002"
}

SDK Usage

import { BridgeClient } from 'opacus-sdk/bridge';
import { ethers } from 'ethers';

const provider = new ethers.JsonRpcProvider('https://mainnet.base.org');
const wallet = new ethers.Wallet(process.env.PRIVATE_KEY!, provider);

const bridge = new BridgeClient(process.env.BRIDGE_CONTRACT_ADDRESS!, wallet);
const intentId = await bridge.submit({
  destChain: 16661,
  token: process.env.USDC_ADDRESS!,
  grossAmount: 1000000n,
  ttlSeconds: 1800,
});

// Inspect bridge intent status
const intent = await bridge.getIntent(intentId);
console.log(intent.status);

// Call an oracle on 0G
const price = await bridge.callService(
  'oracle',
  'Get ETH/USDC price from Jaine DEX on 0G Network',
  '0.002',  // USDC to pay the broker
);
console.log('ETH price:', price.price);

// Fetch a data set
const feed = await bridge.callService(
  'data',
  'Hourly OHLCV for BTC/USDC last 24 hours from 0G indexer',
  '0.10',
);
console.log('Candles:', feed.candles.length);

bridge.disconnect();

import httpx, json, time
from eth_account import Account
from eth_account.messages import encode_defunct

wallet = Account.from_key(os.environ["PRIVATE_KEY"])

def sign_intent(intent: dict) -> str:
    msg = json.dumps({k: intent[k] for k in ["from","type","amount","description","timestamp","nonce"]})
    sig = wallet.sign_message(encode_defunct(text=msg))
    return sig.signature.hex()

intent = {
    "id": f"intent-{int(time.time()*1000)}-abc",
    "from": wallet.address,
    "type": "oracle",
    "description": "Get ETH/USDC price from Jaine on 0G Network",
    "amount": "0.002",
    "timeout": 30,
    "sourceChain": 8453,
    "destChain": 16661,
    "timestamp": int(time.time() * 1000),
    "nonce": "abc",
}
intent["signature"] = sign_intent(intent)

r = httpx.post(
    "https://opacus.xyz/api/data-bridge/intent",
    headers={"Authorization": f"Bearer {API_KEY}", "Content-Type": "application/json"},
    json=intent
)
print(r.json())  # {"ok":true,"intentId":"...","brokerAddress":"..."}

# Browse available brokers
curl https://opacus.xyz/api/data-bridge/brokers \
  -H "Authorization: Bearer $OPACUS_API_KEY"

# Check intent status (after POST)
curl "https://opacus.xyz/api/data-bridge/intent/intent-123" \
  -H "Authorization: Bearer $OPACUS_API_KEY"

# View history
curl "https://opacus.xyz/api/data-bridge/history?limit=10" \
  -H "Authorization: Bearer $OPACUS_API_KEY"

Use Cases

Intent Object Reference

Result Object Reference

Errors

Become a Broker (Earn)

// Register as a broker
POST /api/data-bridge/brokers/register
Authorization: Bearer <obr_agent_token>

{
  "types": ["oracle", "api"],
  "supportedChains": [8453, 16661, 1],
  "pricePerType": {
    "oracle": "0.001",
    "api": "0.003"
  },
  "endpoint": "https://your-broker.example.com"
}