Quickstart: trading bot / agent

import { createAggClient, isAggApiError, MarketStatus } from "@agg-build/sdk";
import { privateKeyToAccount } from "viem/accounts";

async function main() {
  const ORIGIN = "https://bot.example.com"; // one of your app's allowed origins
  const MODE = process.env.AGG_LIVE === "1" ? "live" : "paper";
  const client = createAggClient({
    baseUrl: "https://api.t.sufwankhalid.com",
    appId: process.env.AGG_APP_ID ?? "your-app-id",
    persistSession: false,
  });
  const account = privateKeyToAccount(process.env.BOT_PRIVATE_KEY as `0x${string}`);
  const sleep = (ms: number) => new Promise((r) => setTimeout(r, ms));

  try {
    // 1. Sign in with the bot's key
    const start = await client.authStart({ provider: "siwe" });
    if (start.type !== "nonce") throw new Error(`Expected a nonce, got ${start.type}`);
    const message = client.buildSiweMessage({
      address: account.address,
      chainId: 1,
      nonce: start.nonce,
      statement: start.statement,
      domain: new URL(ORIGIN).host,
      uri: ORIGIN,
    });
    await client.verify({ message, signature: await account.signMessage({ message }) });

    // 2. Fund (live only) and check the balance
    if (MODE === "live") {
      let deposit = await client.getDepositAddresses();
      while (!deposit.ready) {
        await sleep(2000);
        deposit = await client.getDepositAddresses();
      }
      console.log("send USDC to", deposit.evmAddress, "on", deposit.supportedChains);
    }
    const balances = await client.getManagedBalances({ mode: MODE });
    console.log(balances.cash.map((c) => [c.tokenSymbol, c.availableRaw, c.decimals]));

    // 3. Find an outcome
    const markets = await client.getVenueMarkets({ status: MarketStatus.open, search: "bitcoin", limit: 5 });
    const outcomeId = markets.data[0]?.venueMarketOutcomes?.[0]?.id;
    if (!outcomeId) throw new Error("No open outcome found; try another search");

    // 4. Quote
    const quote = await client.getSmartRoute({
      venueMarketOutcomeId: outcomeId,
      tradeSide: "buy",
      maxSpend: 5,
      mode: MODE,
    });
    if (quote.status !== "ok") throw new Error(`${quote.status}: ${quote.error ?? ""}`);

    // 5. Fill
    const fill = await client.executeManaged({ quoteId: quote.quoteId, mode: MODE });

    // 6. Poll to a final state
    let status = await client.getExecutionStatus({ quoteId: fill.quoteId, mode: MODE });
    while (!status.terminal) {
      await sleep(status.pollAfterMs ?? 1000);
      status = await client.getExecutionStatus({ quoteId: fill.quoteId, mode: MODE });
    }
    console.log(status.overallState, status.errorReason ?? "");

    // 7. Positions
    const positions = await client.getExecutionPositions({ mode: MODE });
    for (const p of positions.data) {
      console.log(p.venueMarket.question, p.venueMarket.venueMarketOutcomes.map((o) => [o.label, o.totalSize]));
    }
  } catch (err) {
    if (isAggApiError(err)) console.error(err.status, err.code, err.message);
    throw err;
  } finally {
    client.destroy(); // lets Node exit
  }
}

main().catch(() => process.exit(1));