Function executeFlow

src/compiled/flows.ts:23–56

(name: string, steps: FlowStep[], ctx: any)

}

export async function executeFlow(name: string, steps: FlowStep[], ctx: any): Promise<FlowResult> {
  const completed: { step: string; compensation: ((c: any) => Promise<void>) | null }[] = [];

  for (const step of steps) {
    try {
      logger.info("flow_step_started", { event: name + "." + step.name });
      await step.action(ctx);
      completed.push({ step: step.name, compensation: step.compensation });
      counter("flow.step_completed", { flow: name, step: step.name });
    } catch (e: any) {
      logger.error("flow_step_failed", { event: name + "." + step.name, metadata: { error: e.message } });
      counter("flow.step_failed", { flow: name, step: step.name });

      // Backward compensation in reverse order
      const compensated: string[] = [];
      for (const c of [...completed].reverse()) {
        if (!c.compensation) continue;
        try {
          await c.compensation(ctx);
          compensated.push(c.step);
          logger.info("flow_compensated", { event: name + "." + c.step });
        } catch (compErr: any) {
          logger.error("flow_compensation_failed", { event: name + "." + c.step, metadata: { error: compErr.message } });
          // Continue with other compensations even if one fails
        }
      }

      return { ok: false, failed_step: step.name, compensated, error: e.message };
    }
  }

  counter("flow.completed", { flow: name });
  return { ok: true, compensated: [] };
}

// Flow: improvement_loop
// ctx must contain: { req, res, auth, client? } for transactional flows