dogfather-universe/server/bild-calls.mjs

/* Macht ein Bild der Call-Liste mit vielen Terminen -- zum Ansehen.
   Nachgestellt wird Filipes Lage: eine wöchentliche Serie, die sich
   über Monate zieht. */
import { mkdtempSync, rmSync } from "node:fs";
import { tmpdir } from "node:os";
import { join } from "node:path";
import { heuteLokal } from "./helfer-zeit.mjs";

const ordner = mkdtempSync(join(tmpdir(), "ws-callbild-"));
process.env.WORKSPACE_DB = join(ordner, "workspace.db");
const { portMussFreiSein } = await import("./helfer-port.mjs");
await portMussFreiSein(4319, "das Bildwerkzeug");
process.env.PORT = "4319";
process.env.SITE_ACCESS_SECRET = "lokaler-test";
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 }); };
await import("./index.js");
await new Promise((r) => setTimeout(r, 1000));
const BASIS = "http://127.0.0.1:4319";

const { DatabaseSync } = await import("node:sqlite");
const { scryptSync, randomBytes } = await import("node:crypto");
await fetch(BASIS + "/workspace/api/anmelden", {
  method: "POST", headers: { "Content-Type": "application/json" },
  body: JSON.stringify({ rolle: "admin", code: "x" }) }).catch(() => {});
for (let i = 0; i < 60; i++) {
  try {
    const p = new DatabaseSync(process.env.WORKSPACE_DB);
    try { p.prepare("SELECT 1 FROM personen LIMIT 1").get(); break; } finally { p.close(); }
  } catch { await new Promise((r) => setTimeout(r, 250)); }
}
const d = new DatabaseSync(process.env.WORKSPACE_DB);
const jetzt = new Date().toISOString();
function anlegen(name, rolle, code) {
  const salt = randomBytes(16).toString("hex");
  const hash = scryptSync(code, 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, aktiv, erstellt) VALUES (?,?,?,?,?,1,?)")
    .run(name, rolle, hash, salt, 32768, jetzt);
  return d.prepare("SELECT last_insert_rowid() AS id").get().id;
}
const idDogi = anlegen("Filipe", "admin", "CODE-DOGI-0001");
const idLuna = anlegen("Luna", "creator", "CODE-CREA-0001");

/* Wie bei Filipe: zwei wöchentliche Serien über ein Vierteljahr, dazu
   etwas heute und diese Woche. */
const tag = (versatz) => {
  const t = new Date();
  t.setDate(t.getDate() + versatz);
  const p = (n) => String(n).padStart(2, "0");
  return `${t.getFullYear()}-${p(t.getMonth() + 1)}-${p(t.getDate())}`;
};
function call(titel, versatz, zeit, beschreibung) {
  d.prepare(`INSERT INTO termine (titel, art, beginn, dauer_min, creator_id,
    teilnehmer_id, beschreibung, erstellt, erstellt_von)
    VALUES (?,'call',?,30,?,?,?,?,?)`)
    .run(titel, `${tag(versatz)}T${zeit}`, idLuna, idLuna, beschreibung, jetzt, idDogi);
}
call("Wochen-Call mit Luna", 0, "18:00", "Kurzer Stand");
call("Content-Abnahme", 0, "20:00", "Freigabe der Clips");
call("Community-Talk", 2, "18:00", "Community-Call");
call("GrundSchulung", 3, "18:00", "Schulung über GrundRegeln");
for (let w = 1; w <= 12; w++) {
  call("Community-Talk", 7 * w, "18:00", "Community-Call");
  call("GrundSchulung", 7 * w + 1, "18:00", "Schulung über GrundRegeln");
}
/* Und zwei vergangene ohne Protokoll, damit die erste Gruppe nicht
   leer ist. */
call("Rückblick August", -3, "17:00", "Monatsgespräch");
d.close();

const pw = await import("file:///C:/Users/qciga/Documents/Obelix/Analyse/node_modules/playwright/index.mjs");
const browser = await pw.chromium.launch();
const ctx = await browser.newContext({ viewport: { width: 1280, height: 1100 }, deviceScaleFactor: 2 });
const seite = await ctx.newPage();
await seite.goto(BASIS + "/workspace/", { waitUntil: "networkidle" });
await seite.click('.rolle[data-rolle="admin"]');
await seite.fill("#code", "CODE-DOGI-0001");
await seite.click("button[type=submit]");
await seite.waitForURL("**/start.html", { timeout: 25000 });
await seite.goto(BASIS + "/workspace/calls.html", { waitUntil: "networkidle" });
await seite.waitForTimeout(1600);

const bloecke = await seite.$$eval(".zeitblock", (b) => b.map((x) => ({
  raum: x.dataset.zeitraum,
  offen: x.open,
  zahl: x.querySelector(".zeitblock__zahl")?.textContent,
})));
console.log("Blöcke:", JSON.stringify(bloecke));

/* Nur den anstehenden Teil ins Bild -- darum ging es. */
const teil = await seite.$('.gruppe[data-gruppe="anstehend"]');
if (teil) {
  await teil.screenshot({ path: "calls-kategorien.png" });
  console.log("calls-kategorien.png geschrieben");
}

await browser.close();
try { rmSync(ordner, { recursive: true, force: true }); } catch { /* egal */ }
process.exit(0);