diff --git a/app.py b/app.py index be018e7..6f56932 100644 --- a/app.py +++ b/app.py @@ -15,8 +15,9 @@ import os from pathlib import Path from dotenv import load_dotenv -from flask import Flask, render_template, request +from flask import Flask, render_template, request, session, redirect, url_for +from database import get_db from tiere import tier_emoji, tier_name # Routes-Blueprints @@ -37,6 +38,65 @@ app.register_blueprint(bp_admin) app.register_blueprint(bp_api) +# =========================================================================== +# Alph-PummelHummel-Feedback-Modul (Pattern aus arduino.lehrstun.de) +# =========================================================================== +# Zwei-Stufen-Schalter: +# 1) Soft-Aus (Default-DB): einstellung.feedback_widget_aktiv = '0' +# → Hummel unsichtbar, Modul ist aber geladen (Routen aktiv). +# Im Admin-Panel umschaltbar, kein Restart noetig. +# 2) Hart-Aus: ENV ALPH_DEAKTIVIERT=1 → der ganze Init-Block uebersprungen, +# keine Routen, kein Context-Processor. Fuer Notfall. Restart noetig. + +def _alph_get_einstellung(schluessel: str, default: str = "0") -> str: + """Liefert einen Einstellungs-Wert aus der DB als String.""" + conn = get_db() + row = conn.execute( + "SELECT wert FROM einstellung WHERE schluessel = ?", (schluessel,) + ).fetchone() + conn.close() + return row["wert"] if row else default + + +def _alph_user_kontext(): + """Liefert den User-Kontext fuer das Alph-Widget — bestimmt zugleich, + OB das Widget angezeigt wird (None → kein Widget). + """ + if session.get("admin"): + return {"rolle": "admin", "tier": "lehrer", "kasten": "-"} + if not session.get("profil_id"): + return None + return { + "rolle": "schueler", + "tier": session.get("tier", "?"), + "kasten": session.get("vorname", "?"), # bei uns: Vorname statt Kasten-Nummer + "profil_id": session.get("profil_id"), + } + + +def _alph_widget_aktiv(): + return _alph_get_einstellung("feedback_widget_aktiv", "0") == "1" + + +def _alph_admin_unauthorized(): + return redirect(url_for("admin.admin_login")) + + +if os.environ.get("ALPH_DEAKTIVIERT", "0") != "1": + from feedback_modul import init_feedback_modul # noqa: E402 + + init_feedback_modul( + app, + get_db=get_db, + app_name="3d-druck-ag", + ist_admin=lambda: bool(session.get("admin")), + user_kontext=_alph_user_kontext, + widget_aktiv=_alph_widget_aktiv, + admin_unauthorized=_alph_admin_unauthorized, + parent_template="base.html", + ) + + # =========================================================================== # Markdown-Filter fuer Templates (Pattern wie arduino.lehrstun.de) # =========================================================================== diff --git a/feedback_modul/__init__.py b/feedback_modul/__init__.py new file mode 100644 index 0000000..54cc484 --- /dev/null +++ b/feedback_modul/__init__.py @@ -0,0 +1,31 @@ +"""Alph-Feedback-Modul (PummelHummel) — Lazy-Init. + +Damit das Modul sowohl in Flask- als auch in FastAPI-Projekten genutzt werden +kann (ohne dass die jeweils andere Dependency Pflicht ist), wird der Flask-Code +in `flask_app.py` und der FastAPI-Code in `fastapi_app.py` gehalten. + +Bestehender Importpfad bleibt erhalten: + from feedback_modul import init_feedback_modul # Flask-Variante (auto) + +FastAPI-Variante: + from feedback_modul.fastapi_app import init_feedback_modul + +Wenn Flask nicht installiert ist, schlaegt der Top-Level-Import nicht fehl — +nur der Versuch, `init_feedback_modul` ohne Submodul-Pfad zu nutzen. +""" + +from .schema import DDL, KATEGORIEN # immer verfuegbar, hat keine Dependencies + +try: + from .flask_app import init_feedback_modul, render_widget_snippet +except ImportError: + # Flask nicht installiert — das ist OK fuer FastAPI-only-Projekte. + # Wer `from feedback_modul import init_feedback_modul` aufruft, bekommt + # einen klaren Fehler beim Aufruf, nicht beim Import des Pakets. + def init_feedback_modul(*args, **kwargs): # type: ignore + raise ImportError( + "Flask ist nicht installiert. Fuer FastAPI nutze " + "`from feedback_modul.fastapi_app import init_feedback_modul`." + ) + +__all__ = ["init_feedback_modul", "render_widget_snippet", "DDL", "KATEGORIEN"] diff --git a/feedback_modul/fastapi_app.py b/feedback_modul/fastapi_app.py new file mode 100644 index 0000000..6630ff9 --- /dev/null +++ b/feedback_modul/fastapi_app.py @@ -0,0 +1,450 @@ +"""FastAPI-Adapter fuer das Alph-PummelHummel-Feedback-Modul. + +Bietet aequivalente Routen wie der Flask-Blueprint, fuer FastAPI-Projekte. + +Einbindung: + + from feedback_modul.fastapi_app import init_feedback_modul + + def get_db(): + return sqlite3.connect("/pfad/zu/feedback.db", check_same_thread=False) + + init_feedback_modul( + app, + get_db=get_db, + app_name="meta-lehrstun", + ist_admin=lambda request: request.cookies.get("admin_token") == ADMIN_TOKEN, + # user_kontext optional — fuer reine Drop-Ins kann das weg bleiben. + user_kontext=lambda request: {"site": "meta", "rolle": "user"}, + widget_aktiv=lambda: True, + ) + +In static/index.html vor
"] + parts.append(f"" + "export.json · " + "export.md · " + "claude-prompt.md
") + if not eintraege: + parts.append("Keine Feedbacks im aktuellen Filter.
") + for e in eintraege: + u = e.get("user", {}) + team = u.get("tier") or u.get("site") or "?" + kasten = u.get("kasten") + team_str = f"{team}" + (f" / Kasten {kasten}" if kasten else "") + rolle = u.get("rolle", "") + parts.append(f": + + +""" + +import hashlib +import json +import sqlite3 +import time +from collections import defaultdict, OrderedDict +from datetime import datetime +from pathlib import Path + +from fastapi import APIRouter, HTTPException, Request, Response, Form +from fastapi.responses import (HTMLResponse, JSONResponse, PlainTextResponse, + RedirectResponse, FileResponse) +from fastapi.staticfiles import StaticFiles + +from .schema import DDL, KATEGORIEN + + +_config = { + "get_db": None, + "app_name": "unknown", + "ist_admin": lambda request: False, + "user_kontext": lambda request: None, + "widget_aktiv": lambda: True, + "admin_unauthorized": None, # Callable(request) -> Response +} + +_rate_buckets = {} # ip -> list[timestamp] +_RATE_LIMIT_PER_MIN = 10 + +_STATIC_DIR = Path(__file__).parent / "static" + + +def _rate_limited(ip: str) -> bool: + now = time.time() + bucket = _rate_buckets.setdefault(ip, []) + bucket[:] = [t for t in bucket if now - t < 60] + if len(bucket) >= _RATE_LIMIT_PER_MIN: + return True + bucket.append(now) + return False + + +def _cluster_hash(url_pfad: str, kategorie: str, text: str) -> str: + norm = (text or "").lower().strip()[:30] + raw = f"{url_pfad}|{kategorie}|{norm}" + return hashlib.sha1(raw.encode("utf-8")).hexdigest()[:16] + + +def _admin_check(request: Request): + """Liefert None wenn Admin OK, sonst eine Response (Redirect/403).""" + if _config["ist_admin"](request): + return None + handler = _config.get("admin_unauthorized") + if callable(handler): + return handler(request) + raise HTTPException(status_code=403, detail="forbidden") + + +def _hole_offene_feedbacks() -> list: + conn = _config["get_db"]() + conn.row_factory = sqlite3.Row + rows = conn.execute( + """SELECT * FROM feedback + WHERE app_name = ? AND status NOT IN ('erledigt', 'wontfix', 'spam') + ORDER BY url_pfad, kategorie, erstellt_am""", + (_config["app_name"],), + ).fetchall() + conn.close() + return [dict(r) for r in rows] + + +def _build_md(eintraege: list) -> str: + cluster = defaultdict(list) + for e in eintraege: + cluster[(e["url_pfad"], e["kategorie"], e["cluster_hash"])].append(e) + + kat_label = {k[0]: k[1] for k in KATEGORIEN} + kat_emoji = {"code": "🐛", "link": "🔗", "verstehen": "❓", "fehlt": "❌", "sonstiges": "💬"} + + nach_kategorie = defaultdict(list) + for key, eintrags in cluster.items(): + nach_kategorie[key[1]].append((key, eintrags)) + + out = [] + out.append(f"# Alph-Feedback {_config['app_name']} — Stand {datetime.now().strftime('%Y-%m-%d %H:%M')}") + out.append("") + out.append(f"**{len(eintraege)} offene Feedbacks** in {len(cluster)} Clustern.") + out.append("") + + for kat in ["code", "link", "verstehen", "fehlt", "sonstiges"]: + clusterliste = nach_kategorie.get(kat, []) + if not clusterliste: + continue + emoji = kat_emoji.get(kat, "•") + out.append(f"## {emoji} {kat_label.get(kat, kat)} ({sum(len(c[1]) for c in clusterliste)})") + out.append("") + for key, eintrags in clusterliste: + url, _, _ = key + n = len(eintrags) + mehrfach = f" — **{n}× gemeldet**" if n > 1 else "" + out.append(f"### `{url}`{mehrfach}") + out.append("") + for e in eintrags: + user = {} + try: user = json.loads(e["user_kontext"] or "{}") + except Exception: pass + tech = {} + try: tech = json.loads(e["technik_kontext"] or "{}") + except Exception: pass + team = user.get("tier") or user.get("site") or "?" + rolle = user.get("rolle", "") + rolle_str = f" ({rolle})" if rolle else "" + viewport = tech.get("viewport", "") + out.append(f"- **{team}**{rolle_str} — *\"{e['text']}\"*") + meta = [str(e["erstellt_am"])] + if viewport: + meta.append(f"viewport {viewport}") + if e.get("element_selector"): + meta.append(f"@ `{e['element_selector']}`") + out.append(f" {' · '.join(meta)}") + out.append("") + return "\n".join(out) + + +def _build_router() -> APIRouter: + r = APIRouter() + + @r.post("/api/feedback") + async def api_feedback_post(request: Request): + if _rate_limited(request.client.host if request.client else "unknown"): + return JSONResponse({"ok": False, "error": "rate_limit"}, status_code=429) + + try: + data = await request.json() + except Exception: + data = {} + if not isinstance(data, dict): + data = {} + + kategorie = (data.get("kategorie") or "").strip().lower() + text = (data.get("text") or "").strip() + url_pfad = (data.get("url_pfad") or "").strip()[:500] + valid_kats = {k[0] for k in KATEGORIEN} + + if kategorie not in valid_kats: + return JSONResponse({"ok": False, "error": "kategorie_ungueltig"}, status_code=400) + if len(text) < 3: + return JSONResponse({"ok": False, "error": "text_zu_kurz"}, status_code=400) + if len(text) > 2000: + text = text[:2000] + if not url_pfad: + return JSONResponse({"ok": False, "error": "url_pfad_fehlt"}, status_code=400) + + seitentitel = (data.get("seitentitel") or "")[:200] + element_selector = (data.get("element_selector") or "")[:300] + element_text = (data.get("element_text") or "")[:500] + + # Server-Kontext hat Vorrang. Im Drop-In-Modus akzeptieren wir Client-Kontext. + user_kontext = _config["user_kontext"](request) or {} + if not user_kontext: + client_user = data.get("user_kontext") + if isinstance(client_user, dict): + user_kontext = { + str(k)[:40]: (str(v)[:120] if not isinstance(v, (int, float, bool)) else v) + for k, v in list(client_user.items())[:12] + } + + technik_kontext = { + "viewport": (data.get("viewport") or "")[:20], + "sprache": (data.get("sprache") or "")[:10], + "ua": (request.headers.get("user-agent") or "")[:300], + "referer": (request.headers.get("referer") or "")[:500], + } + cluster = _cluster_hash(url_pfad, kategorie, text) + + conn = _config["get_db"]() + conn.execute( + """INSERT INTO feedback + (app_name, kategorie, text, url_pfad, seitentitel, + user_kontext, technik_kontext, element_selector, element_text, + cluster_hash) + VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?)""", + (_config["app_name"], kategorie, text, url_pfad, seitentitel, + json.dumps(user_kontext, ensure_ascii=False), + json.dumps(technik_kontext, ensure_ascii=False), + element_selector, element_text, cluster), + ) + conn.commit() + conn.close() + return JSONResponse({"ok": True}) + + @r.get("/admin/feedback", response_class=HTMLResponse) + async def admin_feedback_liste(request: Request, status: str = "offen", kategorie: str = ""): + unauth = _admin_check(request) + if unauth is not None: + return unauth + + where = ["app_name = ?"] + params = [_config["app_name"]] + if status == "offen": + where.append("status NOT IN ('erledigt', 'wontfix', 'spam')") + elif status and status != "alle": + where.append("status = ?") + params.append(status) + if kategorie: + where.append("kategorie = ?") + params.append(kategorie) + + sql = ("SELECT * FROM feedback WHERE " + " AND ".join(where) + + " ORDER BY status='neu' DESC, erstellt_am DESC") + conn = _config["get_db"]() + conn.row_factory = sqlite3.Row + rows = conn.execute(sql, params).fetchall() + eintraege = [dict(r) for r in rows] + for e in eintraege: + try: e["user"] = json.loads(e["user_kontext"] or "{}") + except Exception: e["user"] = {} + try: e["technik"] = json.loads(e["technik_kontext"] or "{}") + except Exception: e["technik"] = {} + + stats = OrderedDict() + for s in ["neu", "triagiert", "in_arbeit", "erledigt", "wontfix", "spam"]: + stats[s] = conn.execute( + "SELECT COUNT(*) FROM feedback WHERE app_name=? AND status=?", + (_config["app_name"], s), + ).fetchone()[0] + conn.close() + + return HTMLResponse(_render_admin_html(eintraege, stats, status, kategorie)) + + @r.post("/admin/feedback/{feedback_id}/status") + async def admin_feedback_status(feedback_id: int, request: Request, + status: str = Form(...), notiz: str = Form("")): + unauth = _admin_check(request) + if unauth is not None: + return unauth + erlaubt = {"neu", "triagiert", "in_arbeit", "erledigt", "wontfix", "spam"} + if status not in erlaubt: + raise HTTPException(status_code=400, detail="status_ungueltig") + conn = _config["get_db"]() + conn.execute( + """UPDATE feedback SET status = ?, bearbeitet_notiz = ?, + aktualisiert_am = CURRENT_TIMESTAMP WHERE id = ?""", + (status, notiz or None, feedback_id), + ) + conn.commit() + conn.close() + ref = request.headers.get("referer") or "/admin/feedback" + return RedirectResponse(ref, status_code=303) + + @r.get("/admin/feedback/export.json") + async def admin_feedback_export_json(request: Request): + unauth = _admin_check(request) + if unauth is not None: + return unauth + eintraege = _hole_offene_feedbacks() + for e in eintraege: + try: e["user_kontext"] = json.loads(e["user_kontext"] or "{}") + except Exception: pass + try: e["technik_kontext"] = json.loads(e["technik_kontext"] or "{}") + except Exception: pass + return JSONResponse({ + "app": _config["app_name"], + "exportiert_am": datetime.utcnow().isoformat() + "Z", + "anzahl": len(eintraege), + "feedbacks": eintraege, + }) + + @r.get("/admin/feedback/export.md") + async def admin_feedback_export_md(request: Request): + unauth = _admin_check(request) + if unauth is not None: + return unauth + return PlainTextResponse(_build_md(_hole_offene_feedbacks()), + media_type="text/markdown; charset=utf-8") + + @r.get("/admin/feedback/claude-prompt.md") + async def admin_feedback_claude_prompt(request: Request): + unauth = _admin_check(request) + if unauth is not None: + return unauth + eintraege = _hole_offene_feedbacks() + md_body = _build_md(eintraege) + prompt = [] + prompt.append("# Aufgabe fuer Claude Code: Alphatest-Feedback auswerten") + prompt.append("") + prompt.append(f"Du arbeitest im Repo der App **{_config['app_name']}**. Unten " + f"findest du {len(eintraege)} offene Feedbacks aus dem Alphatest, " + f"gesammelt vom Alph-PummelHummel-Widget.") + prompt.append("") + prompt.append("## Bitte arbeite das so ab:") + prompt.append("") + prompt.append("1. **Cluster lesen.** Mehrfach-Reports am gleichen Pfad sind Prioritaet.") + prompt.append("2. **Quelldateien anschauen.** URL `/foo` -> templates/foo.html etc.") + prompt.append("3. **Symptom vs. Ursache.** Die Reports beschreiben oft nur was sichtbar ist.") + prompt.append("4. **Pro Cluster ein Vorschlag:** Datei + Zeile + konkrete Aenderung.") + prompt.append("5. **Unklare Reports markieren.** Lieber zum Nachfragen flaggen als raten.") + prompt.append("6. **Spam erkennen.** Quatsch markiere mit STATUS:spam zum Wegklicken.") + prompt.append("") + prompt.append("## Antwortformat:") + prompt.append("") + prompt.append("```") + prompt.append("[ID|Cluster] Kategorie · Pfad") + prompt.append(" Diagnose: ...") + prompt.append(" Fix: Datei foo.html Zeile 42 — alt: '...' neu: '...'") + prompt.append(" Status-Vorschlag: in_arbeit | wontfix | spam | nachfragen") + prompt.append("```") + prompt.append("") + prompt.append("---") + prompt.append("") + prompt.append(md_body) + return PlainTextResponse("\n".join(prompt), + media_type="text/markdown; charset=utf-8") + + return r + + +# Minimaler HTML-Renderer (kein Jinja-Zwang fuer FastAPI) +def _render_admin_html(eintraege, stats, status_filter, kategorie_filter): + from html import escape as h + kat_emoji = {"code": "🐛", "link": "🔗", "verstehen": "❓", "fehlt": "❌", "sonstiges": "💬"} + status_label = {"neu": "neu", "triagiert": "triagiert", "in_arbeit": "in Arbeit", + "erledigt": "erledigt", "wontfix": "wontfix", "spam": "spam"} + css = """body{font-family:-apple-system,sans-serif;max-width:1100px;margin:1rem auto;padding:0 1rem;color:#2C3E50} +.fb-stats{display:flex;flex-wrap:wrap;gap:.5rem;margin:.5rem 0 1rem} +.fb-stat{background:#F8F9FA;padding:.4rem .8rem;border-radius:6px;border:1px solid #DEE2E6;font-size:.88rem} +.fb-stat strong{color:#00979D} +.fb-card{border:1px solid #DEE2E6;border-radius:8px;padding:.8rem 1rem;margin-bottom:.8rem;background:white} +.fb-card.fb-neu{border-left:4px solid #E67E22} +.fb-head{display:flex;gap:.6rem;align-items:center;flex-wrap:wrap;margin-bottom:.4rem;font-size:.85rem;color:#7F8C8D} +.fb-kat{background:#EBF8F9;color:#00979D;padding:.15rem .5rem;border-radius:4px;font-weight:bold} +.fb-pfad{font-family:Consolas,monospace;background:#F4F6F7;padding:.1rem .4rem;border-radius:3px} +.fb-text{font-size:.95rem;line-height:1.4;margin:.4rem 0} +.fb-statusform{display:flex;gap:.4rem;flex-wrap:wrap;margin-top:.6rem;padding-top:.5rem;border-top:1px solid #ECEFF1} +.fb-statusform select,.fb-statusform input,.fb-statusform button{padding:.3rem .5rem;border:1px solid #DEE2E6;border-radius:4px;font-size:.85rem} +.fb-statusform input{flex:1;min-width:180px} +.fb-statusform button{background:#00979D;color:white;cursor:pointer} +.fb-exports a{margin-right:.5rem}""" + parts = [f"