import { NextRequest, NextResponse } from "next/server";
import {
  getCommitmentById,
  listCommitments,
  loadMetrics,
  upsertCommitment,
  addCommitmentAuditEvent,
} from "@/lib/commitment/store";
import { executeCommitment } from "@/lib/commitment/executor";

export const dynamic = "force-dynamic";
export const maxDuration = 120;

export async function POST(request: NextRequest) {
  try {
    const body = await request.json().catch(() => ({}));

    const executeAll = !!body.executeAll;
    const id = typeof body.id === "string" ? body.id : "";

    if (!executeAll && !id) {
      return NextResponse.json({ error: "id is required (or executeAll=true)" }, { status: 400 });
    }

    let targets = [];
    if (executeAll) {
      targets = listCommitments().filter((c) => c.status === "detected");
    } else {
      const found = getCommitmentById(id);
      if (!found) {
        return NextResponse.json({ error: `Commitment not found: ${id}` }, { status: 404 });
      }
      targets = [found];
    }

    let metrics = loadMetrics();
    const executed: any[] = [];

    for (const c of targets) {
      try {
        addCommitmentAuditEvent(c.id, "execute_requested", executeAll ? "Bulk execution requested" : "Execution requested");
      } catch (e) {
        console.error("[commitments/execute] audit error:", e);
      }

      const result = executeCommitment(c, metrics);
      metrics = result.metrics;

      const saved = upsertCommitment(result.contract);
      executed.push({
        id: saved.id,
        emailId: saved.emailId,
        status: saved.status,
        staged: result.staged,
        deliverableCount: saved.deliverables?.length ?? 0,
      });
    }

    return NextResponse.json({
      success: true,
      executedCount: executed.length,
      executed,
      metrics,
      timestamp: new Date().toISOString(),
    });
  } catch (e: any) {
    console.error("[commitments/execute] error:", e);
    return NextResponse.json({ error: e.message }, { status: 500 });
  }
}