Send Orders

import "dotenv/config";

import {
  Connection,
  Keypair,
  VersionedTransaction,
} from "@solana/web3.js";
import bs58 from "bs58";

const DFLOW_TRADE_API_URL = process.env.DFLOW_TRADE_API_URL ?? "https://dev-quote-api.dflow.net";
const DFLOW_API_KEY = process.env.DFLOW_API_KEY; // optional; not needed for dev endpoints
const DFLOW_SETTLEMENT_MINT = process.env.DFLOW_SETTLEMENT_MINT ?? "EPjFWdd5AufqSSqeM2qN1xzybapC8G4wEGGkZwyTDt1v"; // USDC
const SOLANA_RPC_URL = process.env.SOLANA_RPC_URL ?? "https://api.mainnet-beta.solana.com";

const SOL_MINT = "So11111111111111111111111111111111111111112";
const AMOUNT = 10_000_000; // 0.01 SOL (9 decimals)
const SLIPPAGE_BPS = 50; // 0.5%

const connection = new Connection(SOLANA_RPC_URL, "confirmed");
const keypair = Keypair.fromSecretKey(
  bs58.decode(process.env.SOLANA_PRIVATE_KEY ?? "")
);

const headers: HeadersInit = {};
if (DFLOW_API_KEY) headers["x-api-key"] = DFLOW_API_KEY;

const params = new URLSearchParams({
  inputMint: SOL_MINT,
  outputMint: DFLOW_SETTLEMENT_MINT,
  amount: AMOUNT.toString(),
  slippageBps: SLIPPAGE_BPS.toString(),
  userPublicKey: keypair.publicKey.toBase58(),
});

const orderResponse = await fetch(
  `${DFLOW_TRADE_API_URL}/order?${params}`,
  { headers }
).then((r) => r.json());

const tx = VersionedTransaction.deserialize(
  Buffer.from(orderResponse.transaction, "base64")
);
tx.sign([keypair]);

const signature = await connection.sendTransaction(tx);
const explorerUrl = `https://orbmarkets.io/tx/${signature}`;

const { value } = await connection.confirmTransaction(signature, "confirmed");

if (value.err) {
  console.log(`Failed: ${JSON.stringify(value.err)}`);
} else {
  console.log("Success: trade landed");
}
console.log(`  Tx: ${explorerUrl}`);