Function execute_improvement_loop

src/compiled/flows.js:47–95

(ctx)

// Flow: improvement_loop
// ctx must contain: { req, res, auth, client? } for transactional flows
async function execute_improvement_loop(ctx) {
    const steps = [
        {
            name: "validate",
            action: async (ctx) => {
                // Calls capability: validate_file(ctx.file_path)
                const response = await fetch(`${process.env.SERVICE_BASE_URL || "http://localhost:3000"}/validate-file`, {
                    method: "POST",
                    headers: { "Content-Type": "application/json", "Authorization": ctx.req.headers.authorization || "" },
                    body: JSON.stringify(ctx.req.body),
                });
                if (!response.ok)
                    throw new Error(`Step validate failed: ${await response.text()}`);
                ctx.validate_result = await response.json();
            },
            compensation: async (ctx) => {
                // Compensates: rollback_file(ctx.file_path)
                await fetch(`${process.env.SERVICE_BASE_URL || "http://localhost:3000"}/rollback-file`, {
                    method: "POST",
                    headers: { "Content-Type": "application/json", "Authorization": ctx.req.headers.authorization || "" },
                    body: JSON.stringify({ ...ctx.req.body, _compensating: true }),
                });
            },
        },
        {
            name: "fix",
            action: async (ctx) => {
                // Calls capability: fix_code(ctx.file_path, validate.output)
                const response = await fetch(`${process.env.SERVICE_BASE_URL || "http://localhost:3000"}/fix-code`, {
                    method: "POST",
                    headers: { "Content-Type": "application/json", "Authorization": ctx.req.headers.authorization || "" },
                    body: JSON.stringify(ctx.req.body),
                });
                if (!response.ok)
                    throw new Error(`Step fix failed: ${await response.text()}`);
                ctx.fix_result = await response.json();
            },
            compensation: async (ctx) => {
                // Compensates: rollback_file(ctx.file_path)
                await fetch(`${process.env.SERVICE_BASE_URL || "http://localhost:3000"}/rollback-file`, {
                    method: "POST",
                    headers: { "Content-Type": "application/json", "Authorization": ctx.req.headers.authorization || "" },
                    body: JSON.stringify({ ...ctx.req.body, _compensating: true }),
                });
            },
        },
    ];
    return executeFlow("improvement_loop", steps, ctx);
}