Solana Workflow Engine That Recovers From Every Failure

1{
2  "id": "yield_farm_entry",
3  "blocks": [
4    {
5      "type": "step",
6      "handler": "check_pool_conditions",
7      "retry": { "max_attempts": 3, "backoff": "2s" }
8    },
9    {
10      "type": "step",
11      "handler": "swap_usdc_to_sol",
12      "retry": { "max_attempts": 5, "backoff": "3s" },
13      "compensation": "reverse_swap_sol_to_usdc",
14      "rate_limit_key": "rpc:helius",
15      "rate_limit": { "max": 50, "window_seconds": 1 }
16    },
17    {
18      "type": "step",
19      "handler": "swap_usdc_to_msol",
20      "compensation": "reverse_swap_msol_to_usdc"
21    },
22    {
23      "type": "step",
24      "handler": "provide_liquidity_orca",
25      "retry": { "max_attempts": 10, "backoff": "5s" },
26      "compensation": "withdraw_liquidity_orca"
27    },
28    {
29      "type": "step",
30      "handler": "stake_lp_token"
31    }
32  ]
33}

1// TypeScript handler — Jupiter swap with priority fees
2app.post('/workers/swap_usdc_to_sol', async (req, res) => {
3  const { context } = req.body;
4  const { amount, slippage } = context.data;
5
6  // Get Jupiter quote
7  const quote = await jupiter.getQuote({
8    inputMint: USDC_MINT,
9    outputMint: SOL_MINT,
10    amount,
11    slippageBps: slippage,
12  });
13
14  // Build transaction with priority fee
15  const { transaction } = await jupiter.getSwapTransaction({
16    quoteResponse: quote,
17    userPublicKey: wallet.publicKey,
18    prioritizationFeeLamports: 'auto',
19  });
20
21  // Sign and send
22  const signature = await connection.sendTransaction(
23    transaction, { skipPreflight: true }
24  );
25
26  // Confirm with timeout
27  await connection.confirmTransaction(signature, 'confirmed');
28
29  // Persist this receipt; reconcile chain state if the outcome is unknown.
30  res.json({
31    signature,
32    amount_out: quote.outAmount,
33    status: 'confirmed'
34  });
35});

1POST /sequences/yield_farm_entry/instances
2{
3  "context": {
4    "data": {
5      "amount": 1000000000,
6      "slippage": 50,
7      "pool": "7XawhbbxtsRcQA8KTkHT9f9nc6d69UwqCDh6U5EEbEmX",
8      "min_apy": 12.5
9    }
10  },
11  "idempotency_key": "yield-farm-entry-2026-05-10-pool-7Xaw"
12}