Execution API

curl -X POST https://your-worker.workers.dev/api/v1/execute \
  -H "Authorization: Bearer YOUR_API_KEY" \
  -H "Content-Type: application/json" \
  -d '{
    "ensemble": "order-processing",
    "input": {
      "orderId": "ORD-123",
      "customerId": "CUST-456"
    }
  }'

{
  "id": "exec_abc123def456",
  "status": "completed",
  "output": {
    "status": "success",
    "total": 99.99,
    "paymentId": "ch_1234567890"
  },
  "duration": 1523,
  "timestamp": 1704067200000
}

curl https://your-worker.workers.dev/api/v1/executions/exec_abc123def456 \
  -H "Authorization: Bearer YOUR_API_KEY"

{
  "id": "exec_abc123def456",
  "status": "running",
  "progress": {
    "completed": 3,
    "total": 7,
    "current": "process-payment"
  },
  "timestamp": 1704067200000
}

curl -X POST https://your-worker.workers.dev/api/v1/executions/exec_abc123/resume \
  -H "Authorization: Bearer YOUR_API_KEY" \
  -H "Content-Type: application/json" \
  -d '{
    "token": "hitl_xyz789",
    "input": {
      "approved": true,
      "comments": "Looks good"
    }
  }'

{
  "id": "exec_abc123def456",
  "status": "completed",
  "output": {
    "approved": true,
    "result": "published"
  },
  "duration": 3522,
  "timestamp": 1704067200000
}

curl -X DELETE https://your-worker.workers.dev/api/v1/executions/exec_abc123 \
  -H "Authorization: Bearer YOUR_API_KEY"

{
  "id": "exec_abc123def456",
  "status": "cancelled",
  "message": "Execution cancelled successfully"
}

const eventSource = new EventSource(
  'https://your-worker.workers.dev/api/v1/stream',
  {
    method: 'POST',
    headers: {
      'Authorization': 'Bearer YOUR_API_KEY',
      'Content-Type': 'application/json'
    },
    body: JSON.stringify({
      ensemble: 'order-processing',
      input: { orderId: 'ORD-123' }
    })
  }
);

eventSource.addEventListener('member.complete', (event) => {
  const data = JSON.parse(event.data);
  console.log(`Completed: ${data.member}`);
});

eventSource.addEventListener('complete', (event) => {
  const data = JSON.parse(event.data);
  console.log('Final output:', data.output);
  eventSource.close();
});

eventSource.addEventListener('error', (event) => {
  console.error('Stream error:', event);
  eventSource.close();
});

event: start
data: {"id":"exec_abc123","timestamp":1704067200000}

event: member.start
data: {"member":"validate-order","timestamp":1704067200100}

event: member.complete
data: {"member":"validate-order","duration":123,"timestamp":1704067200223}

event: member.start
data: {"member":"process-payment","timestamp":1704067200250}

event: member.complete
data: {"member":"process-payment","duration":1200,"output":{"paymentId":"ch_123"},"timestamp":1704067201450}

event: complete
data: {"id":"exec_abc123","status":"completed","output":{"total":99.99},"duration":1523,"timestamp":1704067201523}