/* =====================================================================
   „WANN IST DER NÄCHSTE STREAM?" (17.09.2026)

   Aus dem Plan im Vault, Stufe 2. Bei "Was ansteht" gibt es genau EINE
   Frage, die ein Zuschauer hat -- und sie stand bisher in Zeile vier
   einer Liste wie jede andere Angabe auch.

   ---------------------------------------------------------------------
   DIE LUECKE, DIE ERST BEIM BAUEN AUFFIEL

   Der Plan versprach "Nächster Stream in 3 Std 12 Min". Die Daten
   gaben das nicht her: `eintraege.datum` ist ein TAG, die Pruefung im
   Server lehnte eine Uhrzeit ausdruecklich ab
   (`^\d{4}-\d{2}-\d{2}$`). Ein Stundencountdown war unmoeglich.

   Das ist die uebliche Sorte Planungsluecke -- sie steht nicht im Plan,
   sie steht in der Datenbank. Die Spalte `uhrzeit` ist deshalb heute
   dazugekommen, OPTIONAL: Viele Termine haben keine Uhrzeit ("diese
   Woche"), und ein Pflichtfeld haette dafuer eine erfundene erzwungen.
   Ohne Uhrzeit zaehlt der Countdown in Tagen, und "morgen" ist eine
   ehrliche Antwort.

   ---------------------------------------------------------------------
   WAS HIER GEPRUEFT WIRD

     1. Die Uhrzeit kommt an, kommt zurueck -- und laesst sich wieder
        ENTFERNEN. (Ein Feld, das `""` als "unveraendert" liest, macht
        aus dem Loeschen ein Nichtstun, ohne Fehlermeldung.)
     2. Eine unmoegliche Uhrzeit wird abgelehnt.
     3. Die Antwort steht im ERSTEN Bildschirm -- das war das
        Abnahmekriterium aus dem Plan, gemessen in Pixeln bei 390 px.
     4. Ohne Termin steht ein SATZ da, keine leere Flaeche.
     5. Der Zeitstrahl sortiert: Kommendes oben, Vergangenes unten.

   Aufrufen mit:  node server/pruef-countdown.mjs
   Bild:          SCHIRM=1 node server/pruef-countdown.mjs
   ===================================================================== */

import { mkdtempSync, rmSync } from "node:fs";
import { tmpdir } from "node:os";
import { join } from "node:path";
import { fileURLToPath } from "node:url";
import { eigenerPort } from "./helfer-port.mjs";
import { heuteLokal, tagLokal } from "./helfer-tag.mjs";

const PORT = await eigenerPort(import.meta, "pruef-countdown");
const ordner = mkdtempSync(join(tmpdir(), "ws-count-"));
process.env.WORKSPACE_DB = join(ordner, "workspace.db");
process.env.PORT = String(PORT);
process.env.SITE_ACCESS_SECRET = "lokaler-test";
process.env.SITE_ACCESS_CODE_DOGI = "DOGI-TEST-1";
process.env.SITE_PUBLIC_LAUNCH_AT = "2020-01-01T00:00:00+01:00";

const express = (await import("express")).default;
const ec = express.response.cookie;
express.response.cookie = function (n, w, o) { return ec.call(this, n, w, { ...(o || {}), secure: false }); };
import { notbremse } from "./helfer-notbremse.mjs";
await import("./index.js");
notbremse(180_000, "pruef-countdown");
await new Promise((r) => setTimeout(r, 700));
const BASIS = `http://127.0.0.1:${PORT}`;

process.on("uncaughtException", (f) => { console.error("ABSTURZ:", f); process.exit(7); });
process.on("unhandledRejection", (f) => { console.error("ABSTURZ (Versprechen):", f); process.exit(7); });

let fehler = 0, geprueft = 0;
const melde = (t) => console.log(t);
const ok = (b, t) => { geprueft++; console.log((b ? "  ok   " : "  FEHL ") + t); if (!b) fehler++; };

const { DatabaseSync } = await import("node:sqlite");
const { scryptSync, randomBytes, createHmac } = await import("node:crypto");
const d = new DatabaseSync(process.env.WORKSPACE_DB);
const jetzt = new Date().toISOString();
const schluessel = randomBytes(32).toString("hex");
d.prepare("INSERT INTO einstellungen (schluessel, wert, geaendert, von)"
  + " VALUES (?,?,?,NULL) ON CONFLICT(schluessel) DO NOTHING")
  .run("code_kennung_schluessel", schluessel, jetzt);
const salt = randomBytes(16).toString("hex");
const hash = scryptSync("CODE-DOGI-0001", salt, 64,
  { N: 32768, r: 8, p: 1, maxmem: 96 * 1024 * 1024 }).toString("hex");
d.prepare("INSERT INTO personen"
  + " (name, rolle, code_hash, code_salt, code_n, code_kennung, aktiv, erstellt)"
  + " VALUES (?,?,?,?,?,?,1,?)")
  .run("Filipe", "admin", hash, salt, 32768,
    createHmac("sha256", schluessel).update("CODE-DOGI-0001").digest("hex"), jetzt);
const spalten = d.prepare("PRAGMA table_info(eintraege)").all().map((s) => s.name);
d.close();

const an = await fetch(BASIS + "/workspace/api/anmelden", {
  method: "POST", headers: { "Content-Type": "application/json" },
  body: JSON.stringify({ rolle: "admin", code: "CODE-DOGI-0001" }),
});
const keks = (an.headers.getSetCookie?.() || []).map((z) => z.split(";")[0]).join("; ");
const jsonKopf = { "Content-Type": "application/json", cookie: keks };

async function anlegen(felder) {
  const a = await fetch(BASIS + "/workspace/api/bereich/ansteht", {
    method: "POST", headers: jsonKopf, body: JSON.stringify(felder),
  });
  return { status: a.status, daten: await a.json().catch(() => null) };
}
async function liste() {
  const a = await fetch(BASIS + "/workspace/api/bereich/ansteht", { headers: { cookie: keks } });
  return (await a.json().catch(() => null))?.eintraege || [];
}

/* =======================================================================
   0. DER PLATZ DAFUER
   ======================================================================= */
melde("");
melde("=== 0. Die Spalte ===");
ok(spalten.includes("uhrzeit"),
  `die Eintraege haben eine Spalte 'uhrzeit' (${spalten.length} Spalten)`);

/* =======================================================================
   1. SETZEN, WIEDERFINDEN, ENTFERNEN
   ======================================================================= */
melde("");
melde("=== 1. Die Uhrzeit ===");
let idHeute = 0;
{
  const a = await anlegen({ art: "stream", titel: "Abendstream",
    datum: heuteLokal(), uhrzeit: "23:30" });
  ok(a.status === 201, `ein Stream mit Uhrzeit (${a.status} ${a.daten?.fehler || ""})`);
  idHeute = a.daten?.id || 0;

  const l = await liste();
  const e = l.find((x) => x.id === idHeute);
  ok(e?.uhrzeit === "23:30", `sie kommt zurueck (${e?.uhrzeit})`);

  /* WIEDER ENTFERNEN. Ein Feld, das `""` als "unveraendert" liest,
     macht aus dem Loeschen ein Nichtstun -- ohne Fehlermeldung. */
  const w = await fetch(`${BASIS}/workspace/api/bereich/ansteht/${idHeute}`, {
    method: "PATCH", headers: jsonKopf, body: JSON.stringify({ uhrzeit: "" }),
  });
  const l2 = await liste();
  ok(w.ok && !l2.find((x) => x.id === idHeute)?.uhrzeit,
    `und laesst sich wieder entfernen (${w.status})`);

  const z = await fetch(`${BASIS}/workspace/api/bereich/ansteht/${idHeute}`, {
    method: "PATCH", headers: jsonKopf, body: JSON.stringify({ uhrzeit: "23:30" }),
  });
  const l3 = await liste();
  ok(z.ok && l3.find((x) => x.id === idHeute)?.uhrzeit === "23:30",
    "und wieder setzen auch");
}

/* =======================================================================
   2. WAS NICHT DURCHGEHT
   ======================================================================= */
melde("");
melde("=== 2. Unmoegliche Zeiten ===");
{
  /* DER TITEL MUSS GUELTIG SEIN -- sonst prueft man etwas anderes.
     Beim ersten Lauf stand hier "X": ein Zeichen, und der Server
     verlangt zwei. Die Absage kam dann fuer den Titel UND die Uhrzeit,
     und die Pruefung war aus dem halb falschen Grund gruen. Genau
     dafuer gibt es die Gegenprobe drei Zeilen tiefer -- sie ist
     durchgefallen und hat es verraten. */
  for (const falsch of ["25:00", "20:60", "7:00", "abends"]) {
    const a = await anlegen({ art: "stream", titel: "Probestream",
      datum: heuteLokal(), uhrzeit: falsch });
    ok(a.status === 400 && /Uhrzeit/i.test(a.daten?.fehler || ""),
      `"${falsch}" wird abgelehnt (${a.status} ${a.daten?.fehler || ""})`);
  }
  /* GEGENPROBE: Sonst hiesse 400 nur, dass Anlegen ueberhaupt scheitert. */
  const gut = await anlegen({ art: "stream", titel: "Frühstream",
    datum: heuteLokal(), uhrzeit: "07:00" });
  ok(gut.status === 201, `"07:00" dagegen geht (${gut.status} ${gut.daten?.fehler || ""})`);
}

/* =======================================================================
   3. DER ZEITSTRAHL BRAUCHT MEHR ALS EINEN TERMIN
   ======================================================================= */
melde("");
melde("=== 3. Termine in allen Abschnitten ===");
{
  await anlegen({ art: "event", titel: "Turnierabend", datum: tagLokal(3) });
  await anlegen({ art: "stream", titel: "Im naechsten Monat", datum: tagLokal(30) });
  await anlegen({ art: "pause", titel: "War letzte Woche", datum: tagLokal(-6) });
  const l = await liste();
  ok(l.length >= 5, `${l.length} Termine angelegt`);
}

/* =======================================================================
   4. IM BROWSER: DIE ANTWORT STEHT IM ERSTEN BILDSCHIRM
   ======================================================================= */
melde("");
melde("=== 4. Der erste Bildschirm ===");
const { chromium } = await import(
  "file:///C:/Users/qciga/Documents/Obelix/Analyse/node_modules/playwright/index.mjs");
const browser = await chromium.launch();
try {
  const HOEHE = 844;
  /* MIT FINGER. Ohne `hasTouch` meldet der Browser einen feinen
     Zeiger, und keine Regel aus `@media (pointer: coarse)` greift --
     dort stehen die 44-Pixel-Beruehrziele. Siehe pruef-fingermass.mjs. */
  const kontext = await browser.newContext({ viewport: { width: 390, height: HOEHE },
    hasTouch: true, isMobile: true });
  await kontext.addCookies(keks.split("; ").map((k) => {
    const [name, ...rest] = k.split("=");
    return { name, value: rest.join("="), domain: "127.0.0.1", path: "/" };
  }));
  const seite = await kontext.newPage();
  const konsole = [];
  seite.on("console", (e) => { if (e.type() === "error") konsole.push(e.text()); });
  await seite.goto(`${BASIS}/workspace/bereich.html?b=ansteht`, { waitUntil: "networkidle" });
  await seite.waitForSelector("#countdown", { timeout: 15_000 });
  await seite.waitForTimeout(600);

  const m = await seite.evaluate(() => {
    const k = document.getElementById("countdown");
    const wann = k?.querySelector(".countdown__wann");
    const schilder = [...document.querySelectorAll(".zeitstrahl__schild")]
      .map((z) => z.firstChild?.textContent?.trim() || z.textContent.trim());
    return {
      sichtbar: !!k && !k.hidden,
      wann: wann?.textContent?.trim() || "",
      /* DAS ABNAHMEKRITERIUM aus dem Plan, in Pixeln. */
      y: wann ? Math.round(wann.getBoundingClientRect().top + window.scrollY) : -1,
      groesse: wann ? Math.round(parseFloat(getComputedStyle(wann).fontSize)) : 0,
      titel: k?.querySelector(".countdown__titel")?.textContent?.trim() || "",
      stufe: k?.dataset.stufe || "",
      schilder,
    };
  });

  ok(m.sichtbar, "der Countdown steht da");
  ok(m.y >= 0 && m.y < HOEHE,
    `die Antwort steht im ersten Bildschirm (y = ${m.y} px von ${HOEHE})`);
  /* GROSS heisst messbar gross: groesser als jede Fliesstextzeile. */
  ok(m.groesse >= 24, `und sie ist gross genug (${m.groesse} px)`);
  /* MIT UHRZEIT UND HEUTE -> STUNDEN. Genau das war der Grund fuer die
     neue Spalte; ohne sie stuende hier "heute". */
  ok(/^in \d+ (Std|Min)/.test(m.wann) || m.wann === "läuft",
    `sie zaehlt in Stunden, nicht in Tagen ("${m.wann}")`);
  ok(m.titel.length > 0, `und sagt, WAS ansteht ("${m.titel}")`);

  /* DER ZEITSTRAHL. Kommendes zuerst, Vergangenes zuletzt -- ein
     abgelaufener Termin zwischen kommenden liest sich wie ein Fehler. */
  ok(m.schilder.length >= 3, `der Zeitstrahl hat Abschnitte (${m.schilder.join(" · ")})`);
  ok(m.schilder[m.schilder.length - 1] === "Vorbei",
    `und "Vorbei" steht ganz unten (${m.schilder[m.schilder.length - 1]})`);
  ok(m.schilder[0] === "Heute und morgen",
    `das Naechste ganz oben (${m.schilder[0]})`);

  if (process.env.SCHIRM) {
    const pfad = fileURLToPath(new URL("pruef-countdown.png", import.meta.url));
    await seite.screenshot({ path: pfad, fullPage: false });
    melde("  --   Bildschirmfoto: server/pruef-countdown.png");
  }

  /* =====================================================================
     5. UND WENN NICHTS ANSTEHT?
     ===================================================================== */
  melde("");
  melde("=== 5. Der leere Fall ===");
  {
    /* Alle Termine weg -- dann MUSS ein Satz dastehen. Eine leere
       Flaeche sieht kaputt aus, nicht leer. */
    const alle = await liste();
    for (const e of alle) {
      await fetch(`${BASIS}/workspace/api/bereich/ansteht/${e.id}`,
        { method: "DELETE", headers: { cookie: keks } });
    }
    await seite.reload({ waitUntil: "networkidle" });
    await seite.waitForTimeout(600);
    const leer = await seite.evaluate(() => {
      const k = document.getElementById("countdown");
      return {
        sichtbar: !!k && !k.hidden,
        satz: k?.querySelector(".countdown__leer")?.textContent?.trim() || "",
      };
    });
    ok(leer.sichtbar, "der Kasten bleibt stehen");
    ok(leer.satz.length > 30, `und sagt in Worten, dass nichts ansteht ("${leer.satz.slice(0, 60)}…")`);
  }

  ok(konsole.length === 0,
    konsole.length ? `Konsole: ${konsole[0]}` : "keine Fehler in der Konsole");
  await kontext.close();
} finally {
  await browser.close();
}

melde("");
melde(`${geprueft} Pruefungen, ${fehler} Fehler`);
melde(fehler ? "NICHT IN ORDNUNG" : "ALLES IN ORDNUNG");
try { rmSync(ordner, { recursive: true, force: true }); } catch { /* Aufraeumrest */ }
process.exit(fehler ? 1 : 0);