On-ramp

// Fetch supported chains
const chainsRes = await fetch(`${BASE}/onramp/chains`, {
  headers: makeHeaders(),
});
const { data: chains } = await chainsRes.json();
// chains = [{ id: "tron", name: "Tron", icon: "...", ... }]

// Fetch supported coins (optionally filter by chain)
const coinsRes = await fetch(`${BASE}/onramp/coins?chain=tron`, {
  headers: makeHeaders(),
});
const { data: coins } = await coinsRes.json();
// coins = [{ _id: "...", id: "usdt", name: "Tether USD", symbol: "USDT", ... }]
// Use coin.symbol as targetCurrency and chain.id as targetChain.

import requests

chains_res = requests.get(f"{BASE}/onramp/chains", headers=make_headers())
chains = chains_res.json()["data"]

coins_res = requests.get(f"{BASE}/onramp/coins?chain=tron", headers=make_headers())
coins = coins_res.json()["data"]

const quoteRes = await fetch(`${BASE}/onramp/quote`, {
  method: 'POST',
  headers: makeHeaders(),
  body: JSON.stringify({
    fiatAmount:     50000,      // NGN, in whole units (not kobo)
    fiatCurrency:   'NGN',      // defaults to NGN if omitted
    targetCurrency: 'USDT',     // the coin's symbol
    targetChain:    'tron',     // the chain's id
  }),
});

const { data: quote } = await quoteRes.json();
console.log(quote);
/*
{
  quoteId:               "b7f2a1c3-9d4e-4b2f-a8c0-1e2d3f4a5b6c",
  fiatCurrency:          "NGN",
  fiatAmount:            50000,
  targetCurrency:        "USDT",
  targetChain:           "tron",
  swapCurrency:          "USDT",
  swapChain:             "tron",
  rate:                  1600,          // NGN per 1 USD
  estimatedCryptoAmount: "31.250000",   // 50000 / 1600 = $31.25 → 31.25 USDT at $1.00
  expiresAt:             "2026-10-15T10:01:00.000Z"
}
*/

quote_res = requests.post(
    f"{BASE}/onramp/quote",
    headers=make_headers(),
    json={
        "fiatAmount":     50000,
        "fiatCurrency":   "NGN",
        "targetCurrency": "USDT",
        "targetChain":    "tron",
    },
)
quote = quote_res.json()["data"]

const initiateRes = await fetch(`${BASE}/onramp/initiate`, {
  method: 'POST',
  headers: makeHeaders(),
  body: JSON.stringify({
    quoteId:       quote.quoteId,
    targetAddress: 'TRDFGhjkytywooiueonuoo',  // customer's USDT/Tron address
    customer: {
      email: 'customer@example.com',
      name:  'Ada Obi',
    },
    metadata: { orderId: 'ORD-9821' },  // optional; not returned by the status endpoint
  }),
});

const { data: onramp } = await initiateRes.json();
console.log(onramp);
/*
{
  reference:   "a3f1c2d4-8e7b-4f0a-9c1d-2e3f4a5b6c7d",
  status:      "pending_payment",
  bankTransfer: {
    accountNumber: "0123456789",
    accountName:   "Tender / Ada Obi",
    bankName:      "Wema Bank"
  },
  expiresAt: "2026-10-15T11:00:20.000Z",
  amount:    { value: 50000, currency: "NGN" },
  targetChain:    "tron",
  targetAddress:  "TRDFGhjkytywooiueonuoo",
  targetCurrency: "USDT"
}
*/

initiate_res = requests.post(
    f"{BASE}/onramp/initiate",
    headers=make_headers(),
    json={
        "quoteId":       quote["quoteId"],
        "targetAddress": "TRDFGhjkytywooiueonuoo",
        "customer": {
            "email": "customer@example.com",
            "name":  "Ada Obi",
        },
    },
)
onramp = initiate_res.json()["data"]
reference = onramp["reference"]

async function pollOnramp(reference, intervalMs = 30000) {
  while (true) {
    const res  = await fetch(`${BASE}/onramp/${reference}`, { headers: makeHeaders() });
    const { data } = await res.json();

    console.log(`Status: ${data.status}`, data.stages);

    if (data.status === 'crypto_sent') {
      console.log('On-ramp complete!', data.stages.cryptoSend.data?.txRef);
      return data;
    }

    if (data.status === 'failed') {
      throw new Error(`On-ramp ${reference} failed`);
    }

    await new Promise(r => setTimeout(r, intervalMs));
  }
}

const result = await pollOnramp(onramp.reference);

import time

def poll_onramp(reference, interval_s=30):
    while True:
        res  = requests.get(f"{BASE}/onramp/{reference}", headers=make_headers())
        data = res.json()["data"]

        print(f"Status: {data['status']}")

        if data["status"] == "crypto_sent":
            print("On-ramp complete!")
            return data

        if data["status"] == "failed":
            raise RuntimeError(f"On-ramp {reference} failed")

        time.sleep(interval_s)

result = poll_onramp(reference)