"use server";

import { redirect } from "next/navigation";
import { getDb } from "../../lib/db";
import { requireAdmin } from "../../lib/auth";
import { setRondeExperts } from "../../lib/experts";
import { defaultRikxPrijs } from "../../lib/rikxCalculatie";

// Leeg veld → null; accepteert zowel 1234.5 als 1234,5
function parseNumber(value: FormDataEntryValue | null): number | null {
  if (typeof value !== "string" || value.trim() === "") return null;
  const n = Number(value.replace(",", "."));
  return Number.isFinite(n) ? n : NaN;
}

// Leest en controleert het rondeformulier; geeft een foutcode terug bij ongeldige invoer.
function readRonde(formData: FormData) {
  const label = ((formData.get("label") as string) ?? "").trim();
  const rikxWaarde = parseNumber(formData.get("rikx_waarde"));
  let rikxPrijs = parseNumber(formData.get("rikx_prijs"));
  if (!label) return { error: "missing" } as const;
  if ((rikxWaarde !== null && !(rikxWaarde >= 0)) || (rikxPrijs !== null && !(rikxPrijs >= 0))) {
    return { error: "invalid" } as const;
  }
  if (rikxPrijs === null && rikxWaarde !== null) rikxPrijs = defaultRikxPrijs(rikxWaarde);
  return { label, rikxWaarde, rikxPrijs } as const;
}

function readExpertIds(formData: FormData): number[] {
  return formData.getAll("expert_ids").map(Number).filter((id) => Number.isInteger(id) && id > 0);
}

export async function createRonde(formData: FormData) {
  const session = await requireAdmin();

  const ronde = readRonde(formData);
  if ("error" in ronde) redirect(`/rondes?error=${ronde.error}`);

  const db = getDb();
  if (db.prepare("SELECT id FROM rikx_rondes WHERE label = ?").get(ronde.label)) {
    redirect("/rondes?error=label");
  }
  const result = db.prepare("INSERT INTO rikx_rondes (label, rikx_waarde, rikx_prijs) VALUES (?, ?, ?)").run(
    ronde.label,
    ronde.rikxWaarde,
    ronde.rikxPrijs
  );
  setRondeExperts(Number(result.lastInsertRowid), readExpertIds(formData));

  redirect("/rondes");
}

export async function updateRonde(formData: FormData) {
  const session = await requireAdmin();

  const id = Number(formData.get("id"));
  if (!id) redirect("/rondes");

  const ronde = readRonde(formData);
  if ("error" in ronde) redirect(`/rondes/${id}?error=${ronde.error}`);

  const db = getDb();
  if (db.prepare("SELECT id FROM rikx_rondes WHERE label = ? AND id != ?").get(ronde.label, id)) {
    redirect(`/rondes/${id}?error=label`);
  }
  db.prepare(
    "UPDATE rikx_rondes SET label = ?, rikx_waarde = ?, rikx_prijs = ?, updated_at = datetime('now') WHERE id = ?"
  ).run(ronde.label, ronde.rikxWaarde, ronde.rikxPrijs, id);
  setRondeExperts(id, readExpertIds(formData));

  redirect("/rondes");
}

export async function deleteRonde(formData: FormData) {
  const session = await requireAdmin();

  const id = Number(formData.get("id"));
  // Projecten in deze ronde blijven bestaan; hun ronde_id wordt NULL (ON DELETE SET NULL).
  if (id) getDb().prepare("DELETE FROM rikx_rondes WHERE id = ?").run(id);

  redirect("/rondes");
}