Order & Execute

// Step 1: Get an order
const orderResponse = await fetch(
  `${BASE_URL}/order?` +
    new URLSearchParams({
      inputMint: "So11111111111111111111111111111111111111112", // SOL
      outputMint: "EPjFWdd5AufqSSqeM2qN1xzybapC8G4wEGGkZwyTDt1v", // USDC
      amount: "100000000",
      taker: signer.address,
      swapMode: "ExactIn",
    }),
  { headers: { "x-api-key": API_KEY } },
);
if (!orderResponse.ok) {
  console.error(`/order failed: ${orderResponse.status}`, await orderResponse.text());
  process.exit(1);
}
const order = await orderResponse.json();

if (!order.transaction) {
  // Indicative quote: no taker, insufficient balance, or missing token account
  console.error("No transaction in response:", JSON.stringify(order, null, 2));
  process.exit(1);
}

// Step 2: Sign the transaction
// Use partiallySignTransaction because the market maker adds the
// final signature during /execute
const transactionBytes = Buffer.from(order.transaction, "base64");
const transaction = getTransactionDecoder().decode(transactionBytes);
const signedTransaction = await partiallySignTransaction(
  [signer.keyPair],
  transaction,
);

// Step 3: Execute, re-checking while the fill is pending
const signedTxBytes = getTransactionEncoder().encode(signedTransaction);
const executeBody = {
  requestId: order.requestId,
  quoteId: order.quoteId,
  transaction: Buffer.from(signedTxBytes).toString("base64"),
};

let result;
for (let attempt = 0; attempt < 10; attempt++) {
  const executeResponse = await fetch(`${BASE_URL}/execute`, {
    method: "POST",
    headers: { "Content-Type": "application/json", "x-api-key": API_KEY },
    body: JSON.stringify(executeBody),
  });
  if (!executeResponse.ok) {
    console.error(`/execute failed: ${executeResponse.status}`, await executeResponse.text());
    process.exit(1);
  }
  result = await executeResponse.json();
  // "accepted" means submitted but not yet confirmed; re-calling with the
  // same requestId re-checks the swap, it does not re-execute it
  if (result.state !== "accepted") break;
  await new Promise((r) => setTimeout(r, 1000));
}

if (result.state === "confirmed") {
  console.log("Swap confirmed:", `https://solscan.io/tx/${result.signature}`);
} else {
  console.error("Swap not confirmed:", JSON.stringify(result, null, 2));
}