Function executeFlow

src/compiled/flows.js:12–44

(name, steps, ctx)

const logger_1 = require("./logger");
const metrics_1 = require("./metrics");
async function executeFlow(name, steps, ctx) {
    const completed = [];
    for (const step of steps) {
        try {
            logger_1.logger.info("flow_step_started", { event: name + "." + step.name });
            await step.action(ctx);
            completed.push({ step: step.name, compensation: step.compensation });
            (0, metrics_1.counter)("flow.step_completed", { flow: name, step: step.name });
        }
        catch (e) {
            logger_1.logger.error("flow_step_failed", { event: name + "." + step.name, metadata: { error: e.message } });
            (0, metrics_1.counter)("flow.step_failed", { flow: name, step: step.name });
            // Backward compensation in reverse order
            const compensated = [];
            for (const c of [...completed].reverse()) {
                if (!c.compensation)
                    continue;
                try {
                    await c.compensation(ctx);
                    compensated.push(c.step);
                    logger_1.logger.info("flow_compensated", { event: name + "." + c.step });
                }
                catch (compErr) {
                    logger_1.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 };
        }
    }
    (0, metrics_1.counter)("flow.completed", { flow: name });
    return { ok: true, compensated: [] };
}
// Flow: improvement_loop
// ctx must contain: { req, res, auth, client? } for transactional flows
async function execute_improvement_loop(ctx) {