Build on 归海

// bot.ts: best-price swaps on BNB Chain through 归海. Run: npm i viem && PRIVATE_KEY=0x… API_KEY=… npx tsx bot.ts
import { createPublicClient, createWalletClient, defineChain, getAddress, http, type Hex } from "viem";
import { privateKeyToAccount } from "viem/accounts";

const BASE = "https://guihaitrade.com/api";
const API_KEY = process.env.API_KEY; // your builder key: higher limits, and your own fee
const PARTNER_FEE_BPS = 30; // 0.30% for you, paid on-chain to your payout address (max 50 bps, capped by your key)
const UNIVERSAL_ROUTER = getAddress("0x204faca1764b154221e35c0d20abb3c525710498");
const PERMIT2 = getAddress("0x000000000022d473030f116ddee9f6b43ac78ba3");
const NATIVE_ETH = "0x0000000000000000000000000000000000000000";

const bnb = defineChain({
  id: 56,
  name: "BNB Chain",
  nativeCurrency: { name: "BNB", symbol: "BNB", decimals: 18 },
  rpcUrls: { default: { http: ["https://bsc-dataseed.binance.org"] } },
});
const account = privateKeyToAccount(process.env.PRIVATE_KEY as Hex);
const wallet = createWalletClient({ account, chain: bnb, transport: http() });
const client = createPublicClient({ chain: bnb, transport: http() });

type Field = { name: string; type: string };
type Permit = {
  domain: { name: string; chainId: number; verifyingContract: Hex };
  types: Record<string, Field[]>;
  message: { details: { token: Hex; amount: string; expiration: number; nonce: number }; spender: Hex; sigDeadline: string };
};
type Step = { kind: "approve"; token: Hex; spender: Hex; tx: { to: Hex; data: Hex } } | { kind: "permit"; token: Hex; typedData: Permit };
type Quote = { id: string; sell: { token: string; amountAtomic: string }; buy: { amount: string; symbol: string }; steps: Step[]; fee: { partner: { amount: string } | null } };
type Built = { quoteId: string; tx: { to: Hex; data: Hex; value: string; chainId: number; gas: string | null } };
type Tracked = { status: "pending" | "confirmed" | "failed" | "unknown"; amountOut: string | null };

const sleep = (ms: number) => new Promise((r) => setTimeout(r, ms));

async function api<T>(path: string, body?: unknown): Promise<T> {
  for (let attempt = 0; attempt < 5; attempt++) {
    const res = await fetch(BASE + path, {
      method: body === undefined ? "GET" : "POST",
      headers: { "Content-Type": "application/json", ...(API_KEY ? { "X-Api-Key": API_KEY } : {}) },
      body: body === undefined ? undefined : JSON.stringify(body),
    });
    if (res.status === 429) {
      await sleep(Number(res.headers.get("Retry-After") ?? "5") * 1000);
      continue;
    }
    const data = await res.json();
    if (!res.ok) throw new Error(`${res.status} ${data.error.code}: ${data.error.message}`);
    return data as T;
  }
  throw new Error("Still rate limited after 5 attempts.");
}

async function swap(sell: string, buy: string, amount: string): Promise<Tracked> {
  const ask = { sell, buy, amount, taker: account.address, slippageBps: 50, ...(API_KEY ? { partnerFeeBps: PARTNER_FEE_BPS } : {}) };
  let quote = await api<Quote>("/quote", ask);

  // 1. Approve Permit2 once per token, then quote again (the steps change once it lands).
  const approve = quote.steps.find((s) => s.kind === "approve");
  if (approve) {
    if (getAddress(approve.spender) !== PERMIT2 || getAddress(approve.tx.to) !== getAddress(approve.token)) throw new Error("Unexpected approval");
    const hash = await wallet.sendTransaction({ to: approve.tx.to, data: approve.tx.data });
    if ((await client.waitForTransactionReceipt({ hash })).status !== "success") throw new Error("Approval reverted");
    quote = await api<Quote>("/quote", ask);
  }

  // 2. Sign the Permit2 allowance when asked (no gas). viem builds the EIP712Domain type itself.
  let permitSignature: Hex | undefined;
  const permit = quote.steps.find((s) => s.kind === "permit");
  if (permit) {
    const { domain, message } = permit.typedData;
    const { EIP712Domain: _domainType, ...types } = permit.typedData.types;
    if (getAddress(message.spender) !== UNIVERSAL_ROUTER || getAddress(domain.verifyingContract) !== PERMIT2 || domain.chainId !== 56) throw new Error("Unexpected Permit2 request");
    permitSignature = await wallet.signTypedData({
      domain,
      types,
      primaryType: "PermitSingle",
      message: { details: { ...message.details, amount: BigInt(message.details.amount) }, spender: message.spender, sigDeadline: BigInt(message.sigDeadline) },
    });
  }

  // 3. Build: simulated on the live chain before it comes back.
  const { tx, quoteId } = await api<Built>("/swap", { quoteId: quote.id, permitSignature });

  // 4. Verify before signing anything.
  const expectedValue = quote.sell.token === NATIVE_ETH ? quote.sell.amountAtomic : "0";
  if (quoteId !== quote.id) throw new Error("Refusing: built for another quote");
  if (getAddress(tx.to) !== UNIVERSAL_ROUTER) throw new Error("Refusing: tx.to is not the PancakeSwap Universal Router");
  if (tx.chainId !== 56) throw new Error("Refusing: wrong chain");
  if (tx.value !== expectedValue) throw new Error("Refusing: unexpected BNB value");

  // 5. Send, then 6. track until settled.
  const hash = await wallet.sendTransaction({ to: tx.to, data: tx.data, value: BigInt(tx.value), gas: tx.gas ? BigInt(tx.gas) : undefined });
  let status = await api<Tracked>("/swaps/track", { quoteId: quote.id, txHash: hash });
  while (status.status === "pending") {
    await sleep(2_000);
    status = await api<Tracked>(`/swaps/${hash}`);
  }
  console.log(status.status, quote.fee.partner ? `you earned ${quote.fee.partner.amount} ${quote.buy.symbol}` : "");
  console.log("Proof of Savings:", `https://guihaitrade.com/proof/${hash}`);
  return status;
}

swap("BNB", "USDT", "0.01").catch((err) => {
  console.error(err);
  process.exit(1);
});