Never Lose an Agent Workflow Again.

import {
  EpochAgent, RpcCheckpointChain, ReplicatedStorage, IpfsStorageAdapter,
  LocalAesGcmProvider, StateSerializer, FileJournal, httpProvider,
} from "./sdk/src/index.ts"; // not yet published as a package

const agent = new EpochAgent({
  agentId: "rebalancer-1",
  chain: new RpcCheckpointChain({
    provider: httpProvider(process.env.RPC_URL!),
    ledger: EPOCH_ADDRESS,      // the deployed Upoch contract
    workflowId: 1n,             // registered with registerWorkflow
    from: EXECUTOR_ADDRESS,     // an executor of that workflow
  }),
  storage: new ReplicatedStorage([new IpfsStorageAdapter({
    apiUrl: "https://rpc.filebase.io", authorization: "Bearer " + IPFS_TOKEN, gatewayUrl: "https://ipfs.filebase.io",
  })]),
  encryption: new LocalAesGcmProvider(KEY_32_BYTES), // development provider
  serializer: new StateSerializer({ applicationVersion: "rebalancer/1", schemaVersion: 1 }),
  journal: new FileJournal("./epoch-journal.jsonl"),
  checkpointPolicy: { everySteps: 3, beforeExternalAction: true, afterConfirmedAction: true },
  reconcilers: { swap: (op) => venue.status(op.operationId) }, // query before any retry
});

const result = await agent.executeWithAutosave(async (session) => {
  const state = await session.restoreOrInitialize(() => ({ step: 0, fills: [] }));
  while (state.step < 3) {
    state.step++;
    await session.step(state);             // SAFE_BOUNDARY checkpoint every 3 steps
  }
  await session.action({                   // PRE_ACTION and POST_ACTION checkpoints
    operationId: "swap-1",                 // stable: a confirmed swap-1 is never re-run
    operationType: "swap",
    input: { amount: "100" },
    run: (input) => venue.swap(input),
  });
  return state;
});