Register an oracle provider

Register with a node's Service Registry (OFS-1500) as an Oracle Provider, then publish a signed exchange-rate record (OFS-7000). The median rate across every provider for a pair is what floating-price advertisements reference.

Start a local node first:

cargo run -p openfiat-cli -- --rpc-bind-address 127.0.0.1:7080

Rust

Full source: examples/oracle_provider.rs (cargo run --example oracle_provider from openfiat-sdks/rust).

let keypair = Keypair::generate();
let provider = peer_id(&keypair);

let registration = Registration {
    service_id: ServiceId::new("my-oracle"),
    service_type: ServiceType::MarketData(MarketDataService::FxOracle),
    provider: provider.clone(),
    provider_public_key: keypair.public_key(),
    endpoints: vec!["/ip4/127.0.0.1/udp/4001/quic-v1".to_string()],
    supported_ofs: vec![1500, 7000],
    region: Some("Kenya".to_string()),
    capabilities: vec!["USDC/KES".to_string()],
    pricing: None,
    timestamp: Timestamp::now(),
};
let service_id = client.send_provider_register(registration, &keypair).await?;

let now = Timestamp::now();
let publish = OraclePublish {
    id: OracleId::new("usdc-kes"),
    provider,
    provider_public_key: keypair.public_key(),
    data: OracleData::ExchangeRate { base: "USDC".to_string(), quote: "KES".to_string(), rate: 129.52 },
    version: 1,
    timestamp: now,
    expires_at: Timestamp::from_millis(now.as_millis() + 60_000),
};
let oracle_id = client.send_oracle_publish(publish, &keypair).await?;

let median = client.get_median_exchange_rate("USDC", "KES").await?;
println!("median rate: {:?}", median);

TypeScript

Full source: examples/oracle_provider.ts (pnpm tsx examples/oracle_provider.ts from openfiat-sdks/typescript).

const keypair = await generateKeypair();
const peerId = peerIdFromPublicKey(keypair.publicKey);

const registration: Registration = {
  service_id: "my-oracle",
  service_type: { MarketData: "FxOracle" },
  provider: toBytes(peerId),
  provider_public_key: toBytes(keypair.publicKey),
  endpoints: ["/ip4/127.0.0.1/udp/4001/quic-v1"],
  supported_ofs: [1500, 7000],
  region: "Kenya",
  capabilities: ["USDC/KES"],
  pricing: null,
  timestamp: Date.now(),
};
const serviceId = await providers.sendProviderRegister(client, registration, keypair);

const now = Date.now();
const publish: OraclePublish = {
  id: "usdc-kes",
  provider: toBytes(peerId),
  provider_public_key: toBytes(keypair.publicKey),
  data: { ExchangeRate: { base: "USDC", quote: "KES", rate: 129.52 } },
  version: 1,
  timestamp: now,
  expires_at: now + 60_000,
};
const oracleId = await oracles.sendOraclePublish(client, publish, keypair);

const median = await oracles.getMedianExchangeRate(client, "USDC", "KES");
console.log(`median rate: ${median}`);