Function execute_improvement_loop

src/compiled/flows.ts:60–106

(ctx: { req: any; res: any; auth: any; client?: any })

// Flow: improvement_loop
// ctx must contain: { req, res, auth, client? } for transactional flows
export async function execute_improvement_loop(ctx: { req: any; res: any; auth: any; client?: any }): Promise<FlowResult> {
  const steps: FlowStep[] = [
    {
      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);
}