dogfather-universe/server/workspace-suche.js

/* =====================================================================
   workspace-suche.js — Suche über alle Bereiche (Konzept, Phase 4).

   Zwei Dinge machen den Unterschied zwischen einer Suche und einer
   brauchbaren Suche:

   1. SIE DARF NICHTS FINDEN, WAS DIE SEITE VERBERGEN WUERDE. Eine Suche
      ist die verlockendste Stelle fuer ein Datenleck: Man tippt einen
      Namen und bekommt Treffer aus Bereichen, die man nie oeffnen
      duerfte. Deshalb wird jede Quelle mit der Sichtbarkeitsregel ihres
      eigenen Moduls abgefragt -- importiert, nicht abgeschrieben. Und
      die management-internen Profilfelder (admin_notiz, plan_start,
      naechster_review) werden gar nicht erst durchsucht, fuer niemanden
      ausser dem Management.

   2. SIE MUSS SAGEN, WO ETWAS STEHT. Ein Treffer ohne Textstelle und
      ohne Weg dorthin zwingt zum Weitersuchen. Jeder Treffer traegt
      deshalb einen Ausschnitt rund um die Fundstelle und ein Ziel.

   Bewusst kein Volltextindex (FTS5). Die Datenmengen hier sind klein --
   ein paar tausend Zeilen -- und LIKE braucht keinen zweiten Datenstand,
   der irgendwann auseinanderlaeuft.
   ===================================================================== */

import express from "express";
import {
  db, sitzungLesen, betreuteIds, istLeitung,
} from "./workspace.js";
import { sichtbar as sichtbarAufgaben } from "./workspace-aufgaben.js";
import { sichtbar as sichtbarTermine } from "./workspace-kalender.js";
import { sichtbar as sichtbarDateien } from "./workspace-dateien.js";
import { sichtbar as sichtbarEintraege } from "./workspace-bereiche.js";

export const sucheRouter = express.Router();

const MIN = 2;
const JE_BEREICH = 6;
const AUSSCHNITT = 110;

const BEREICHSNAME = {
  live: "LIVE-Analyse", content: "Content", technik: "Technik",
  community: "Community", schutz: "Schutz",
};

function angemeldet(req, res, next) {
  const person = sitzungLesen(req);
  if (!person) return res.status(401).json({ fehler: "nicht_angemeldet" });
  req.person = person;
  next();
}

sucheRouter.use("/workspace/api/suche", angemeldet);

/* LIKE-Sonderzeichen unschaedlich machen. Ohne das waere die Suche nach
   "100%" eine Suche nach "100 gefolgt von irgendwas" und "a_b" faende
   auch "axb" -- beides falsch und beides faellt erst spaet auf. */
function muster(text) {
  return "%" + text.replace(/[\\%_]/g, (z) => "\\" + z) + "%";
}

/* Ausschnitt rund um die Fundstelle, damit man sieht, WARUM etwas
   gefunden wurde -- nicht nur die ersten Zeichen des Feldes. */
function ausschnitt(text, suche) {
  if (!text) return null;
  const flach = String(text).replace(/\s+/g, " ").trim();
  const wo = flach.toLowerCase().indexOf(suche.toLowerCase());
  if (wo < 0) return flach.length > AUSSCHNITT ? flach.slice(0, AUSSCHNITT) + " …" : flach;
  const von = Math.max(0, wo - 35);
  const bis = Math.min(flach.length, wo + suche.length + 70);
  return (von > 0 ? "… " : "") + flach.slice(von, bis) + (bis < flach.length ? " …" : "");
}

sucheRouter.get("/workspace/api/suche", (req, res) => {
  try {
    const person = req.person;
    const q = String(req.query.q ?? "").trim().slice(0, 100);
    if (q.length < MIN) {
      return res.json({ frage: q, zu_kurz: true, gruppen: [], gesamt: 0 });
    }
    const m = muster(q);
    const gruppen = [];

    /* Eine Quelle abfragen. Faellt eine aus, bleibt die Suche im Rest
       benutzbar -- eine leere Trefferliste waere schlimmer als eine
       unvollstaendige. */
    const quelle = (titel, sql, werte, bau) => {
      try {
        const zeilen = db().prepare(sql).all(...werte);
        if (!zeilen.length) return;
        gruppen.push({ titel, treffer: zeilen.map(bau) });
      } catch (fehler) {
        console.error(`[workspace] Suche (${titel}):`, fehler?.message);
      }
    };

    /* ---------- Aufgaben ---------- */
    const a = sichtbarAufgaben(person);
    if (a) {
      quelle("Aufgaben", `
        SELECT a.id, a.titel, a.beschreibung, a.status, a.frist, p.name AS creator_name
        FROM aufgaben a LEFT JOIN personen p ON p.id = a.creator_id
        WHERE ${a.wo} AND (a.titel LIKE ? ESCAPE '\\' OR a.beschreibung LIKE ? ESCAPE '\\')
        ORDER BY a.status = 'erledigt', a.id DESC LIMIT ${JE_BEREICH}`,
        [...a.werte, m, m],
        (z) => ({
          titel: z.titel,
          text: ausschnitt(z.beschreibung, q),
          zusatz: [z.creator_name, z.status].filter(Boolean).join(" · "),
          ziel: "aufgaben.html",
        }));
    }

    /* ---------- Termine, Calls und Protokolle ---------- */
    const t = sichtbarTermine(person);
    if (t) {
      quelle("Termine & Calls", `
        SELECT t.id, t.titel, t.beschreibung, t.art, t.beginn, t.ort, p.name AS creator_name
        FROM termine t LEFT JOIN personen p ON p.id = t.creator_id
        WHERE ${t.wo} AND (t.titel LIKE ? ESCAPE '\\' OR t.beschreibung LIKE ? ESCAPE '\\'
                           OR t.ort LIKE ? ESCAPE '\\')
        ORDER BY t.beginn DESC LIMIT ${JE_BEREICH}`,
        [...t.werte, m, m, m],
        (z) => ({
          titel: z.titel,
          text: ausschnitt(z.beschreibung, q),
          zusatz: [z.beginn?.replace("T", " · "), z.creator_name].filter(Boolean).join(" · "),
          ziel: z.art === "termin" ? "kalender.html" : "calls.html",
        }));

      /* Protokolle haengen an Terminen und erben deren Sichtbarkeit.
         Hier steckt oft das, wonach man wirklich sucht: was besprochen
         und was entschieden wurde. */
      quelle("Gesprächsprotokolle", `
        SELECT pr.id, pr.punkte, pr.entscheidungen, t.titel, t.beginn
        FROM protokolle pr JOIN termine t ON t.id = pr.termin_id
        WHERE ${t.wo} AND (pr.punkte LIKE ? ESCAPE '\\' OR pr.entscheidungen LIKE ? ESCAPE '\\')
        ORDER BY t.beginn DESC LIMIT ${JE_BEREICH}`,
        [...t.werte, m, m],
        (z) => {
          const treffer = (z.entscheidungen || "").toLowerCase().includes(q.toLowerCase())
            ? { feld: "Entscheidung", wert: z.entscheidungen }
            : { feld: "Besprochen", wert: z.punkte };
          return {
            titel: z.titel,
            text: ausschnitt(treffer.wert, q),
            zusatz: `${treffer.feld} · ${(z.beginn || "").slice(0, 10).split("-").reverse().join(".")}`,
            ziel: "calls.html",
          };
        });
    }

    /* ---------- Dateien ---------- */
    const d = sichtbarDateien(person);
    if (d) {
      quelle("Dateien", `
        SELECT d.id, d.name_original, d.notiz, d.status, p.name AS creator_name
        FROM dateien d LEFT JOIN personen p ON p.id = d.creator_id
        WHERE ${d.wo} AND (d.name_original LIKE ? ESCAPE '\\' OR d.notiz LIKE ? ESCAPE '\\')
        ORDER BY d.id DESC LIMIT ${JE_BEREICH}`,
        [...d.werte, m, m],
        (z) => ({
          titel: z.name_original,
          text: ausschnitt(z.notiz, q),
          zusatz: [z.creator_name, z.status].filter(Boolean).join(" · "),
          ziel: "dateien.html",
        }));
    }

    /* ---------- Betreuungsbereiche ---------- */
    const e = sichtbarEintraege(person);
    if (e) {
      quelle("Betreuungsbereiche", `
        SELECT e.id, e.bereich, e.titel, e.text, e.datum, e.status, p.name AS creator_name
        FROM eintraege e LEFT JOIN personen p ON p.id = e.creator_id
        WHERE ${e.wo} AND (e.titel LIKE ? ESCAPE '\\' OR e.text LIKE ? ESCAPE '\\')
        ORDER BY e.datum DESC LIMIT ${JE_BEREICH}`,
        [...e.werte, m, m],
        (z) => ({
          titel: z.titel,
          text: ausschnitt(z.text, q),
          zusatz: [BEREICHSNAME[z.bereich] || z.bereich, z.creator_name].filter(Boolean).join(" · "),
          ziel: `bereich.html?b=${z.bereich}`,
        }));
    }

    /* ---------- Scout-Pipeline ---------- */
    if (istLeitung(person) || person.rolle === "scout") {
      const nur = istLeitung(person) ? "1=1" : "l.scout_id = ?";
      const werte = istLeitung(person) ? [] : [person.id];
      quelle("Scout-Pipeline", `
        SELECT l.id, l.name, l.plattform, l.handle, l.status, l.notizen, l.potenzial, l.aktivitaet
        FROM leads l
        WHERE ${nur} AND (l.name LIKE ? ESCAPE '\\' OR l.handle LIKE ? ESCAPE '\\'
                          OR l.notizen LIKE ? ESCAPE '\\' OR l.potenzial LIKE ? ESCAPE '\\'
                          OR l.aktivitaet LIKE ? ESCAPE '\\')
        ORDER BY l.id DESC LIMIT ${JE_BEREICH}`,
        [...werte, m, m, m, m, m],
        (z) => ({
          titel: z.name,
          text: ausschnitt(z.notizen || z.potenzial || z.aktivitaet, q),
          zusatz: [z.plattform, z.handle, z.status].filter(Boolean).join(" · "),
          ziel: "scouting.html",
        }));
    }

    /* ---------- Creator-Profile ----------
       Nur die offenen Felder. admin_notiz, plan_start und
       naechster_review werden NICHT durchsucht -- auch nicht fuer das
       Management, denn ein Treffer daraus taucht sonst spaeter in einer
       Ansicht auf, die diese Felder gar nicht zeigen darf. Wer die Notiz
       lesen will, oeffnet das Profil. */
    if (istLeitung(person) || person.rolle === "scout") {
      let nur = "";
      let werte = [];
      if (person.rolle === "scout") {
        const ids = betreuteIds(person);
        if (!ids.length) nur = null;
        else {
          nur = ` AND p.id IN (${ids.map(() => "?").join(",")})`;
          werte = ids;
        }
      }
      if (nur !== null) {
        quelle("Creator-Profile", `
          SELECT p.id, p.name, f.nische, f.handles, f.live_zeiten, f.technik,
                 f.ziel_live, f.ziel_content, f.ziel_community, f.ziel_technik,
                 f.plan_prio1, f.plan_prio2, f.plan_prio3
          FROM personen p LEFT JOIN profile f ON f.person_id = p.id
          WHERE p.rolle = 'creator' AND p.aktiv = 1${nur}
            AND (p.name LIKE ? ESCAPE '\\' OR f.nische LIKE ? ESCAPE '\\'
                 OR f.handles LIKE ? ESCAPE '\\' OR f.live_zeiten LIKE ? ESCAPE '\\'
                 OR f.technik LIKE ? ESCAPE '\\'
                 OR f.ziel_live LIKE ? ESCAPE '\\' OR f.ziel_content LIKE ? ESCAPE '\\'
                 OR f.ziel_community LIKE ? ESCAPE '\\' OR f.ziel_technik LIKE ? ESCAPE '\\'
                 OR f.plan_prio1 LIKE ? ESCAPE '\\' OR f.plan_prio2 LIKE ? ESCAPE '\\'
                 OR f.plan_prio3 LIKE ? ESCAPE '\\')
          ORDER BY p.name LIMIT ${JE_BEREICH}`,
          [...werte, ...Array(12).fill(m)],
          (z) => {
            /* Zeigen, WELCHES Feld getroffen hat -- sonst raetselt man,
               warum ein Profil auftaucht. */
            const felder = [
              ["Nische", z.nische], ["Handles", z.handles], ["LIVE-Zeiten", z.live_zeiten],
              ["Technik", z.technik], ["Ziel LIVE", z.ziel_live], ["Ziel Content", z.ziel_content],
              ["Ziel Community", z.ziel_community], ["Ziel Technik", z.ziel_technik],
              ["Priorität 1", z.plan_prio1], ["Priorität 2", z.plan_prio2],
              ["Priorität 3", z.plan_prio3],
            ];
            const t2 = felder.find(([, w]) => w && w.toLowerCase().includes(q.toLowerCase()));
            return {
              titel: z.name,
              text: t2 ? ausschnitt(t2[1], q) : null,
              zusatz: t2 ? t2[0] : "Name",
              ziel: "profil.html",
            };
          });
      }
    }

    res.json({
      frage: q,
      zu_kurz: false,
      gruppen,
      gesamt: gruppen.reduce((s, g) => s + g.treffer.length, 0),
    });
  } catch (fehler) {
    console.error("[workspace] Suche:", fehler?.message);
    res.status(503).json({ fehler: "nicht_verfuegbar" });
  }
});