import { NextRequest, NextResponse } from "next/server";
import { detectCommitments } from "@/lib/commitment/detector";
import { loadProcessedEmails } from "@/lib/config";
import { upsertCommitmentByEmailId, listCommitments, loadMetrics } from "@/lib/commitment/store";

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

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

    const detected = detectCommitments(records);

    for (const c of detected) {
      try {
        upsertCommitmentByEmailId(c);
      } catch (e: any) {
        console.error("[commitments/detect] upsert error:", e);
      }
    }

    const commitments = listCommitments();
    const metrics = loadMetrics();

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