For Frontends

async function post(path: string, body: object) {
    const API = "https://swap.symbiotic.fi/api/v1";
    const response = await fetch(`${API}${path}`, {
        method: "POST",
        headers: { "Content-Type": "application/json" },
        body: JSON.stringify(body),
        signal: AbortSignal.timeout(15_000),
    });
    if (!response.ok) throw new Error(`${path}: HTTP ${response.status}`);
    return response.json();
}
 
import type { TypedData } from "viem";
 
const [swapper] = await walletClient.getAddresses();
 
// Quote
const { quotes } = await post("/quote", {
    tokenInChainId: 1,
    tokenOutChainId: 1,
    tokenIn,
    tokenOut,
    amount,
    type: "EXACT_INPUT",
    swapper,
    outputs: [{ token: tokenOut, recipient: swapper }],
});
 
// Choose the best quote (highest output)
const { quote, signatureData } = quotes[0];
 
// Approve the Reactor if needed
const { cancel, approval } = await post("/check_approval", {
    walletAddress: swapper,
    chainId: 1,
    token: tokenIn,
    amount,
});
for (const payload of [cancel, approval]) {
    if (!payload) continue;
    const hash = await walletClient.sendTransaction({
        account: swapper,
        ...payload,
        value: BigInt(payload.value),
    });
    const receipt = await publicClient.waitForTransactionReceipt({ hash });
    if (receipt.status !== "success") throw new Error("Approval reverted.");
}
 
// Sign
if (quote.orderInfo.deadline <= Date.now() / 1000)
    throw new Error("Quote expired. Request a new quote.");
const { domain, types, primaryType, value } = signatureData;
const signature = await walletClient.signTypedData({
    account: swapper,
    domain,
    types: types as unknown as TypedData,
    primaryType,
    message: value,
});
 
// Submit; save orderId to track settlement
const { orderId } = await post("/order", { quote, signature });

async function post(path: string, body: object) {
    const API = "https://swap.symbiotic.fi/api/v1";
    const response = await fetch(`${API}${path}`, {
        method: "POST",
        headers: { "Content-Type": "application/json" },
        body: JSON.stringify(body),
        signal: AbortSignal.timeout(15_000),
    });
    if (!response.ok) throw new Error(`${path}: HTTP ${response.status}`);
    return response.json();
}
 
import { TransactionOperation, TransferPeerPathType } from "@fireblocks/ts-sdk";
import type { Address, Hex } from "viem";
 
const source = { type: TransferPeerPathType.VaultAccount, id: "0" };
const swapper = process.env.FIREBLOCKS_SWAPPER_ADDRESS! as Address; // Address of vault 0.
 
async function waitForCompletion(txId: string) {
    for (let attempt = 0; attempt < 40; attempt++) {
        const { data } = await fireblocks.transactions.getTransaction({ txId });
        if (data.status === "COMPLETED") return data;
        if (["FAILED", "BLOCKED", "CANCELLED", "REJECTED", "TIMEOUT"].includes(data.status ?? ""))
            throw new Error(`Fireblocks: ${data.status}`);
        await new Promise((resolve) => setTimeout(resolve, 3_000));
    }
    throw new Error(`Check Fireblocks transaction ${txId} before retrying.`);
}
 
// Quote
const { quotes } = await post("/quote", {
    tokenInChainId: 1,
    tokenOutChainId: 1,
    tokenIn,
    tokenOut,
    amount,
    type: "EXACT_INPUT",
    swapper,
    outputs: [{ token: tokenOut, recipient: swapper }],
});
 
// Choose the best quote (highest output)
const { quote, signatureData } = quotes[0];
 
// Approve the Reactor if needed
const { cancel, approval } = await post("/check_approval", {
    walletAddress: swapper,
    chainId: 1,
    token: tokenIn,
    amount,
});
for (const payload of [cancel, approval]) {
    if (!payload) continue;
    const { data } = await fireblocks.transactions.createTransaction({
        transactionRequest: {
            operation: TransactionOperation.ContractCall,
            assetId: "ETH",
            source,
            destination: {
                type: TransferPeerPathType.OneTimeAddress,
                oneTimeAddress: { address: payload.to },
            },
            amount: "0",
            extraParameters: { contractCallData: payload.data },
        },
    });
    await waitForCompletion(data.id!);
}
 
// Sign
if (quote.orderInfo.deadline <= Date.now() / 1000)
    throw new Error("Quote expired. Request a new quote.");
const { domain, types, primaryType, value } = signatureData;
const EIP712Domain = [
    { name: "name", type: "string" },
    { name: "version", type: "string" },
    { name: "chainId", type: "uint256" },
    { name: "verifyingContract", type: "address" },
];
const { data } = await fireblocks.transactions.createTransaction({
    transactionRequest: {
        operation: TransactionOperation.TypedMessage,
        assetId: "ETH",
        source,
        extraParameters: {
            rawMessageData: {
                messages: [
                    {
                        type: "EIP712",
                        content: {
                            types: { EIP712Domain, ...types },
                            domain,
                            primaryType,
                            message: value,
                        },
                    },
                ],
            },
        },
    },
});
const signed = await waitForCompletion(data.id!);
const { r, s, v } = signed.signedMessages![0]!.signature!;
const signature: Hex = `0x${r}${s}${(v! + 27).toString(16)}`;
 
// Submit; save orderId to track settlement
if (quote.orderInfo.deadline <= Date.now() / 1000)
    throw new Error("Quote expired. Request a new quote.");
const { orderId } = await post("/order", { quote, signature });