update

backend/database.py

@@ -64,6 +64,7 @@ CREATE TABLE IF NOT EXISTS baustein_progress (
     topic TEXT NOT NULL,
     baustein TEXT NOT NULL,
     gute_antworten INTEGER NOT NULL DEFAULT 0,
+    streak INTEGER NOT NULL DEFAULT 0,
     absolviert TEXT,
     verstanden TEXT,
     gemeistert TEXT,
@@ -106,6 +107,10 @@ async def init_db():
         await db.execute("ALTER TABLE baustein_progress ADD COLUMN gemeistert TEXT")
     except aiosqlite.OperationalError:
         pass
+    try:  # Migration für Bestands-DBs ohne streak-Spalte (persistente Streak-Bonus-Folge)
+        await db.execute("ALTER TABLE baustein_progress ADD COLUMN streak INTEGER NOT NULL DEFAULT 0")
+    except aiosqlite.OperationalError:
+        pass
     # Migration: alte vertiefungen-Tabelle → baustein_texte (Bestand = lange Form, art 'deepdive')
     cursor = await db.execute("SELECT name FROM sqlite_master WHERE type = 'table' AND name = 'vertiefungen'")
     if await cursor.fetchone():
@@ -343,10 +348,10 @@ async def list_vertiefungen(topic: str) -> dict[str, set[str]]:
 async def list_baustein_progress(topic: str) -> list[dict]:
     db = await get_db()
     cursor = await db.execute(
-        "SELECT baustein, gute_antworten, absolviert, verstanden, gemeistert FROM baustein_progress WHERE topic = ?", (topic,)
+        "SELECT baustein, gute_antworten, streak, absolviert, verstanden, gemeistert FROM baustein_progress WHERE topic = ?", (topic,)
     )
     rows = await cursor.fetchall()
-    return [{"baustein": b, "gute_antworten": n, "absolviert": a, "verstanden": v, "gemeistert": m} for b, n, a, v, m in rows]
+    return [{"baustein": b, "gute_antworten": n, "streak": s, "absolviert": a, "verstanden": v, "gemeistert": m} for b, n, s, a, v, m in rows]
 
 
 async def set_baustein_score(topic: str, baustein: str, score: int) -> int:
@@ -363,6 +368,19 @@ async def set_baustein_score(topic: str, baustein: str, score: int) -> int:
     return score
 
 
+async def set_baustein_streak(topic: str, baustein: str, streak: int) -> None:
+    """Persistiert die Streak-Folge (Bonus) absolut — überlebt Reload/Session-Wechsel."""
+    db = await get_db()
+    await db.execute(
+        """INSERT INTO baustein_progress (topic, baustein, streak, updated_at)
+           VALUES (?, ?, ?, ?)
+           ON CONFLICT(topic, baustein) DO UPDATE SET
+               streak = excluded.streak, updated_at = excluded.updated_at""",
+        (topic, baustein, streak, _now()),
+    )
+    await db.commit()
+
+
 async def set_baustein_verstanden(topic: str, baustein: str) -> bool:
     """Markiert verstanden (Mastery); True nur beim ersten Mal. Sticky wie absolviert."""
     db = await get_db()

backend/lernen.py

@@ -66,6 +66,16 @@ def score_berechnen(
     return max(floor, min(cap, score_vor_frage + delta))
 
 
+def streak_berechnen(streak_vor: int, gut: bool, tier2: bool, tier3: bool, neu_absolviert: bool, neu_verstanden: bool) -> int:
+    """Neue Streak nach einer Antwort · persistiert. Reset NUR am Deckel der aktiven Stufe:
+    Tier 1 → bei neu-absolviert (3), Tier 2 → bei neu-verstanden (10). Sonst läuft sie durch."""
+    if not gut:
+        return 0
+    if (not tier2 and neu_absolviert) or (tier2 and not tier3 and neu_verstanden):
+        return 0
+    return streak_vor + 1
+
+
 def _transcript(messages: list[dict]) -> str:
     return "\n".join(
         f"{'Nutzer' if m.get('role') == 'user' else 'Assistent'}: {m.get('content', '')}"

backend/models.py

@@ -209,6 +209,7 @@ class BausteinPruefungResponse(BaseModel):
     feedback: str | None = None
     bewertung: Literal["gut", "schlecht"] | None = None
     gute_antworten: int
+    streak: int | None = None  # nur antwort_pruefen setzt die persistierte Streak
     absolviert: bool
     verstanden: bool = False
     gemeistert: bool = False
@@ -216,6 +217,7 @@ class BausteinPruefungResponse(BaseModel):
 
 class BausteinLernstand(BaseModel):
     gute_antworten: int
+    streak: int = 0
     absolviert: bool
     verstanden: bool
     gemeistert: bool

backend/routes.py

@@ -14,11 +14,11 @@ from database import (
     list_progress, set_progress, delete_progress,
     create_element, list_elements, get_element, update_element, delete_element,
     get_vertiefung, set_vertiefung, list_vertiefungen,
-    list_baustein_progress, set_baustein_score, set_baustein_absolviert, set_baustein_verstanden, set_baustein_gemeistert, delete_baustein_daten,
+    list_baustein_progress, set_baustein_score, set_baustein_streak, set_baustein_absolviert, set_baustein_verstanden, set_baustein_gemeistert, delete_baustein_daten,
 )
 from bausteine import generate_bausteine, cancel_bausteine, bausteine_status, active_bausteine, reset_bausteine
 from elements import generate_element, chat_with_guide, chat_with_element, check_element, style_element, refine_suggestion
-from lernen import NOETIG, MASTERY, MEISTERN, baustein_chat, baustein_diskussion, baustein_element_anlegen, pruefung_bewertung, pruefung_bewertung_schnell, pruefung_frage, score_berechnen, vertiefung_generieren
+from lernen import NOETIG, MASTERY, MEISTERN, baustein_chat, baustein_diskussion, baustein_element_anlegen, pruefung_bewertung, pruefung_bewertung_schnell, pruefung_frage, score_berechnen, streak_berechnen, vertiefung_generieren
 from guide import generate_guide, guide_slot_dateien
 from pipeline import cancel_guide
 from regeln import FORMATE, formate_stats, guide_lock, ist_absolviert, lade_lernstand, thema_abgeschlossen
@@ -162,6 +162,7 @@ async def baustein_lernstand(topic: str):
     bausteine = {
         p["baustein"]: {
             "gute_antworten": p["gute_antworten"],
+            "streak": p["streak"],
             "absolviert": p["absolviert"] is not None,
             "verstanden": p["verstanden"] is not None,
             "gemeistert": p["gemeistert"] is not None,
@@ -173,7 +174,7 @@ async def baustein_lernstand(topic: str):
     for b, arten in texte.items():
         if b not in bausteine:
             bausteine[b] = {
-                "gute_antworten": 0, "absolviert": False, "verstanden": False, "gemeistert": False,
+                "gute_antworten": 0, "streak": 0, "absolviert": False, "verstanden": False, "gemeistert": False,
                 "vertiefung": "vertiefung" in arten, "deepdive": "deepdive" in arten,
             }
     return {"bausteine": bausteine}
@@ -268,6 +269,7 @@ async def baustein_pruefung_route(req: BausteinPruefungRequest):
     score = score_berechnen(
         req.score_vor_frage, data["bewertung"] == "gut", req.streak, req.tier2, req.tier3, absolviert, verstanden, gemeistert,
     )
+    war_absolviert, war_verstanden = absolviert, verstanden
     gute = await set_baustein_score(req.topic, req.baustein, score)
     if score >= NOETIG and not absolviert:
         absolviert = True
@@ -279,7 +281,13 @@ async def baustein_pruefung_route(req: BausteinPruefungRequest):
     if score >= MEISTERN and not gemeistert:
         await set_baustein_gemeistert(req.topic, req.baustein)
         gemeistert = True
-    return {"feedback": data["feedback"], "bewertung": data["bewertung"], "gute_antworten": gute, "absolviert": absolviert, "verstanden": verstanden, "gemeistert": gemeistert}
+    # Streak persistieren — Reset nur am Deckel der gerade aktiven Stufe.
+    streak = streak_berechnen(
+        req.streak, data["bewertung"] == "gut", req.tier2, req.tier3,
+        absolviert and not war_absolviert, verstanden and not war_verstanden,
+    )
+    await set_baustein_streak(req.topic, req.baustein, streak)
+    return {"feedback": data["feedback"], "bewertung": data["bewertung"], "gute_antworten": gute, "streak": streak, "absolviert": absolviert, "verstanden": verstanden, "gemeistert": gemeistert}
 
 
 # --- Guides ---

frontend/src/components/BausteinPanel.vue

@@ -19,7 +19,7 @@ const emit = defineEmits(['statusChanged'])
 const NOETIG = 3    // absolviert
 const MAX = 10      // verstanden
 const MEISTERN = 25 // gemeistert (Maximum)
-const st = computed(() => props.status || { gute_antworten: 0, absolviert: false, verstanden: false, gemeistert: false, vertiefung: false, deepdive: false })
+const st = computed(() => props.status || { gute_antworten: 0, streak: 0, absolviert: false, verstanden: false, gemeistert: false, vertiefung: false, deepdive: false })
 
 // --- Toggle-Bereich ---
 const activeTab = ref(null) // null | 'vertiefung' | 'deepdive' | 'chat' | 'pruefung'
@@ -80,8 +80,8 @@ const pruefLoading = ref(false)
 const aktuelleFrage = ref('')    // ankert Bewertung/Diskussion
 const letztesFeedback = ref('')  // Kontext für die Diskussion über eine Bewertung
 const scoreVorFrage = ref(0)     // Score, als die aktuelle Frage gestellt wurde → driftfreies (Re-)Bewerten
-const streak = ref(0)            // aktuelle Folge korrekter Antworten im Baustein
 const streakVorFrage = ref(0)    // Streak, als die aktuelle Frage gestellt wurde (driftfrei)
+// Die aktuelle Streak lebt persistent in st.value.streak (DB → props.status, round-trip via applyPruefung).
 const naechsteFrage = ref(null)  // im Hintergrund vorbereitete nächste Frage (Prefetch)
 let prefetchPromise = null       // laufender Hintergrund-Abruf (verhindert Doppel-Prefetch)
 const pruefMessagesEl = ref(null)
@@ -94,7 +94,8 @@ function onPruefScroll() {
 }
 
 function applyPruefung(res) {
-  emit('statusChanged', { ...st.value, gute_antworten: res.gute_antworten, absolviert: res.absolviert, verstanden: res.verstanden, gemeistert: res.gemeistert })
+  // res.streak nur bei antwort_pruefen gesetzt (verbindlich, persistiert); sonst Streak unverändert lassen.
+  emit('statusChanged', { ...st.value, gute_antworten: res.gute_antworten, streak: res.streak ?? st.value.streak, absolviert: res.absolviert, verstanden: res.verstanden, gemeistert: res.gemeistert })
 }
 
 async function pruefScroll() {
@@ -136,7 +137,7 @@ function frageZeigen(text) {
   aktuelleFrage.value = text
   letztesFeedback.value = ''
   scoreVorFrage.value = st.value.gute_antworten
-  streakVorFrage.value = streak.value
+  streakVorFrage.value = st.value.streak
   pruefMessages.value.push({ role: 'assistant', kind: 'frage', content: text })
   pruefPhase.value = 'frage_offen'
 }
@@ -249,8 +250,6 @@ function antwortPayload() {
 async function verdictPruefen(gruendlich = false) {
   const meine = ++pruefenRun
   const ziel = letzteFeedbackMsg
-  const warAbsolviert = st.value.absolviert
-  const warVerstanden = st.value.verstanden
   if (gruendlich) pruefLoading.value = true
   try {
     const res = await pruefeBaustein({
@@ -258,15 +257,7 @@ async function verdictPruefen(gruendlich = false) {
       provider: props.provider, messages: pruefDialog(), ...antwortPayload(), aktion: 'antwort_pruefen', gruendlich,
     })
     if (meine !== pruefenRun) return // eine neuere Bewertung läuft → diese verwerfen
-    // Streak driftfrei aus streakVorFrage neu setzen; Reset nur am Deckel der
+    // Streak kommt verbindlich vom Backend (persistiert) und fließt über applyPruefung in st.
-    // aktiven Stufe (Tier 1 → absolviert/3, Tier 2 → verstanden/10). Bei Tier 3
-    // läuft die Streak durch 3/10 durch; bei 25 ist eh gemeistert (Score frozen).
-    let neu = res.bewertung === 'gut' ? streakVorFrage.value + 1 : 0
-    const deckelErreicht =
-      (!props.tier2 && res.absolviert && !warAbsolviert) ||
-      (props.tier2 && !props.tier3 && res.verstanden && !warVerstanden)
-    if (deckelErreicht) neu = 0
-    streak.value = neu
     applyPruefung(res)
     if (ziel) {
       if (res.bewertung !== ziel.bewertung || (res.feedback && res.feedback !== ziel.content)) {