API Reference

POST /api/v1/flows/:id/execute

{
  "event": {
    "userId": "user_123",
    "action": "signup",
    "recordId": "contact_456"
  },
  "idempotencyKey": "unique-request-id"
}

{
  "executionId": "run_abc",
  "status": "COMPLETED",
  "outputs": {
    "result": "..."
  },
  "duration": 1250
}

GET /api/v1/executions/:executionId

GET /api/v1/flows/:flowId/executions

POST /api/v1/executions/:executionId/replay

GET /api/v1/executions/:executionId/nodes/:nodeId

import { FlowExecutionEngine } from "./flow-execution.engine";

const program = Effect.flatMap(
  FlowExecutionEngine,
  engine => engine.execute({
    flowId: "flow_123",
    event: { userId: "user_456" },
  })
);

const result = await Effect.runPromise(
  program.pipe(Effect.provide(FlowExecutionEngineLive))
);

const result = await Effect.runPromise(
  FlowExecutionEngine.execute({
    flowId: "flow_123",
    event: { 
      recordId: "contact_789",
      action: "created" 
    },
    context: {
      orgId: "org_abc",
      userId: "user_123",
    },
  }).pipe(Effect.provide(FlowExecutionEngineLive))
);