Solver Integration Guide#

1interface RFQ {
2  id: string;
3  pair: string;          // e.g., "USDC/USDT"
4  side: "buy" | "sell";
5  amount: string;        // In source token
6  corridor: string;      // e.g., "ethereum-optimism"
7  deadline: number;      // Unix timestamp
8  complianceAttestation: string; // Hash proving taker is verified
9}
10
11async function handleRFQ(rfq: RFQ) {
12  // Validate pair support
13  if (!SUPPORTED_PAIRS.includes(rfq.pair)) {
14    console.log("Pair not supported, skipping:", rfq.pair);
15    return;
16  }
17
18  // Validate size
19  const amount = parseFloat(rfq.amount);
20  if (amount < MIN_TRADE_SIZE || amount > MAX_TRADE_SIZE) {
21    console.log("Trade size out of range:", amount);
22    return;
23  }
24
25  // Price and submit quote
26  const price = await calculatePrice(rfq);
27  await submitQuote(rfq.id, price);
28}
29
30const SUPPORTED_PAIRS = ["USDC/USDT", "USDC/EURC"];
31const MIN_TRADE_SIZE = ;
32const MAX_TRADE_SIZE = ;

1import { ethers } from "ethers";
2
3const QUOTE_TYPE = {
4  Quote: [
5    { name: "rfqId", type: "string" },
6    { name: "price", type: "string" },
7    { name: "ttl", type: "uint256" },
8    { name: "minAmount", type: "string" },
9    { name: "maxAmount", type: "string" },
10    { name: "nonce", type: "uint256" },
11  ]
12};
13
14async function submitQuote(rfqId: string, price: string) {
15  const signer = new ethers.Wallet(process.env.SOLVER_PRIVATE_KEY!);
16  
17  const quote = {
18    rfqId,
19    price,           // e.g., "0.9995"
20    ttl: 30,         // seconds until quote expires
21    minAmount: "10000",
22    maxAmount: "10000000",
23    nonce: Date.now(),
24  };
25
26  // EIP-712 typed signature - sealed, not visible to other solvers
27  const signature = await signer.signTypedData(
28    { name: "TetraFi", version: "1", chainId: 1 },
29    QUOTE_TYPE,
30    quote
31  );
32
33  await tetrafi.quotes.submit({ ...quote, signature });
34  console.log("Quote submitted:", price);
35}

1// Listen for escrow lock events
2ws.on("message", async (data) => {
3  const event = JSON.parse(data.toString());
4  
5  if (event.type === "settlement.pending") {
6    const settlement = event.settlement;
7    console.log("Escrow locked:", settlement.escrowTxHash);
8    console.log("Destination chain:", settlement.destinationChainId);
9    
10    // Fill on destination chain - must complete within window (typically 30s)
11    await fillSettlement(settlement);
12  }
13});
14
15async function fillSettlement(settlement: Settlement) {
16  // Monitor ERC-7683 fill events on destination chain
17  const provider = new ethers.JsonRpcProvider(DEST_RPC_URL);
18  const settler = new ethers.Contract(OUTPUT_SETTLER_ADDR, OutputSettlerABI, signer);
19  
20  // Deliver funds on destination chain
21  const tx = await settler.fill(
22    settlement.orderId,
23    settlement.originData,
24    settlement.destinationData,
25  );
26  
27  await tx.wait();
28  console.log("Fill TX:", tx.hash);
29}

1ws.on("message", async (data) => {
2  const event = JSON.parse(data.toString());
3  
4  if (event.type === "settlement.complete") {
5    const { settlement } = event;
6    console.log("Settlement complete!");
7    console.log("  Origin TX:", settlement.originTxHash);
8    console.log("  Destination TX:", settlement.destinationTxHash);
9    console.log("  Amount:", settlement.amount);
10    
11    // Fetch full audit trail
12    const audit = await tetrafi.audit.getTrail(settlement.id);
13    console.log("WORM audit entries:", audit.length);
14    
15    // Update your internal accounting
16    await reconcileSettlement(settlement);
17  }
18  
19  if (event.type === "settlement.failed") {
20    const { settlement } = event;
21    console.error("Settlement failed:", settlement.error);
22    console.log("Taker refunded via:", settlement.refundTxHash);
23    // No action needed - escrow auto-refunds taker
24  }
25});