Reapply all fixes on main after merge overwrite

- Strip env vars (.strip()) to handle trailing newlines
- Default model: openrouter/free
- Server-side phase progression (2 turns per phase max)
- System prompt: ban suggested examples, ban excessive validation
- Frontend: strip phase marker from chat, proper error handling
- Add /download endpoint for corpus files
- Add LLM call logging and timeout

https://claude.ai/code/session_015z3yZxNNfXF63JuQDuPbEG

app/llm.py

@@ -1,23 +1,26 @@
 """LLM interaction via OpenAI-compatible API."""
 
 import json
+import logging
 import os
 
 from openai import AsyncOpenAI
 
+logger = logging.getLogger(__name__)
+
 _client: AsyncOpenAI | None = None
 
 
 def _get_client() -> AsyncOpenAI:
     global _client
     if _client is None:
-        api_key = os.environ.get("OPENROUTER_API_KEY", "")
-        base_url = os.environ.get("LLM_BASE_URL", "") or None
+        api_key = os.environ.get("OPENROUTER_API_KEY", "").strip()
+        base_url = os.environ.get("LLM_BASE_URL", "").strip() or None
         _client = AsyncOpenAI(api_key=api_key, base_url=base_url)
     return _client
 
 # ---------------------------------------------------------------------------
-# System prompts (verbatim from spec)
+# System prompts
 # ---------------------------------------------------------------------------
 
 SYSTEM_TUTOR = """Tu es un mentor socratique bienveillant, empathique et complice.
@@ -31,9 +34,12 @@ Règles :
 4. Si une définition est demandée, explique en max 2 phrases puis pose immédiatement une question de vérification.
 5. Dès qu'une base est posée en Phase 1, avance vers Phase 2.
 6. Préfère l'invitation au reproche : "Ce point semble complexe, essayons un autre angle..."
+7. INTERDIT : ne propose JAMAIS d'exemples, de listes d'options ou de choix multiples dans tes questions. L'apprenant·e doit produire le contenu. Mauvais : "Par exemple, X, Y ou Z ?" — Bon : "Donne-moi un exemple concret issu de ta propre expérience."
+8. Ta question doit être ouverte et exiger que l'apprenant·e formule sa propre réponse.
+9. Interdit absolu : "Excellent", "Très bien", "Parfait", "Bravo", "Super", "C'est une excellente question", "Absolument", "Exactement" et tout équivalent enthousiaste. Validation autorisée : une phrase neutre et courte maximum ("C'est une piste.", "Je vois ce que tu veux dire.") avant de poser la question suivante.
 À la fin de chaque message, ajoute obligatoirement :
 ---
-Phase: [Numéro]
+Phase: {phase}
 Mode : Tuteur
 Sujet d'exploration : "{topic}"
 Contexte du cours (extrait RAG) :
@@ -50,9 +56,12 @@ Règles :
 4. Si une définition est demandée, explique en max 2 phrases puis pose immédiatement une question de vérification.
 5. Dès qu'une base est posée en Phase 1, avance vers Phase 2.
 6. Préfère l'invitation au reproche : "Ce point semble complexe, essayons un autre angle..."
+7. INTERDIT : ne propose JAMAIS d'exemples, de listes d'options ou de choix multiples dans tes questions. L'apprenant·e doit produire le contenu. Mauvais : "Par exemple, X, Y ou Z ?" — Bon : "Donne-moi un exemple concret issu de ta propre expérience."
+8. Ta question doit être ouverte et exiger que l'apprenant·e formule sa propre réponse.
+9. Interdit absolu : "Excellent", "Très bien", "Parfait", "Bravo", "Super", "C'est une excellente question", "Absolument", "Exactement" et tout équivalent enthousiaste. Validation autorisée : une phrase neutre et courte maximum ("C'est une piste.", "Je vois ce que tu veux dire.") avant de poser la question suivante.
 À la fin de chaque message, ajoute obligatoirement :
 ---
-Phase: [Numéro]
+Phase: {phase}
 Mode : Critique
 Ta mission : proposer des raisonnements fallacieux pour tester la vigilance.
 Reste un partenaire de jeu élégant, jamais méprisant.
@@ -89,7 +98,10 @@ def build_system_prompt(mode: str, topic: str, phase: int, rag_chunks: list[str]
     template = SYSTEM_TUTOR if mode == "TUTOR" else SYSTEM_CRITIC
 
     rag_text = "\n---\n".join(rag_chunks) if rag_chunks else "(aucun document chargé)"
-    prompt = template.replace("{topic}", topic).replace("{rag_context}", rag_text)
+    prompt = (template
+              .replace("{topic}", topic)
+              .replace("{rag_context}", rag_text)
+              .replace("{phase}", str(phase)))
 
     prompt += f"\n\n{PHASE_GUIDANCE.get(phase, PHASE_GUIDANCE[0])}"
 
@@ -99,14 +111,19 @@ def build_system_prompt(mode: str, topic: str, phase: int, rag_chunks: list[str]
 async def chat(system_prompt: str, messages: list[dict]) -> str:
     """Send chat completion request and return assistant message."""
     client = _get_client()
-    model = os.environ.get("LLM_MODEL", "mistralai/mistral-7b-instruct")
+    model = os.environ.get("LLM_MODEL", "openrouter/free").strip()
     api_messages = [{"role": "system", "content": system_prompt}] + messages
 
+    logger.info(f"LLM call: model={model!r}, messages={len(api_messages)}, system_prompt_len={len(system_prompt)}")
+
     response = await client.chat.completions.create(
         model=model,
         messages=api_messages,
+        timeout=60,
     )
-    return response.choices[0].message.content
+    reply = response.choices[0].message.content
+    logger.info(f"LLM response: {len(reply)} chars")
+    return reply
 
 
 async def analyze_session(messages: list[dict]) -> dict:
@@ -117,7 +134,7 @@ async def analyze_session(messages: list[dict]) -> dict:
     )
 
     analysis_messages = [
-        {"role": "user", "content": f"Voici la conversation \u00e0 analyser :\n\n{conversation_text}"}
+        {"role": "user", "content": f"Voici la conversation à analyser :\n\n{conversation_text}"}
     ]
 
     raw = await chat(ANALYSIS_SYSTEM, analysis_messages)

app/main.py

@@ -1,6 +1,7 @@
 """FastAPI application for AIM Learning Companion."""
 
 import logging
+import os
 import re
 import traceback
 from contextlib import asynccontextmanager
@@ -29,6 +30,7 @@ async def lifespan(app: FastAPI):
 app = FastAPI(title="AIM Learning Companion", lifespan=lifespan)
 
 STATIC_DIR = Path(__file__).parent.parent / "static"
+CORPUS_DIR = Path(__file__).parent.parent / "corpus"
 app.mount("/static", StaticFiles(directory=str(STATIC_DIR)), name="static")
 
 ALLOWED_EXTENSIONS = {".txt", ".pdf", ".pptx", ".ppt", ".zip"}
@@ -39,7 +41,7 @@ class ChatRequest(BaseModel):
     mode: str = "TUTOR"
     topic: str = ""
     phase: int = 0
-    phase_turns: int = 0  # how many turns spent in current phase
+    phase_turns: int = 0
     history: list[dict] = []
 
 
@@ -72,27 +74,54 @@ async def index():
     return FileResponse(str(STATIC_DIR / "index.html"))
 
 
-def _detect_phase(reply: str, current_phase: int) -> int:
-    """Extract phase number from the companion's reply."""
-    match = re.search(r"Phase:\s*(\d)", reply)
-    if match:
-        return int(match.group(1))
-    return current_phase
+@app.get("/download/{filename}")
+async def download_file(filename: str):
+    """Serve a file from the corpus directory for download."""
+    file_path = CORPUS_DIR / filename
+    if not file_path.exists() or not file_path.is_file():
+        return JSONResponse(status_code=404, content={"error": "Fichier non trouvé"})
+    return FileResponse(str(file_path), filename=filename)
+
+
+MAX_TURNS_PER_PHASE = 2
+
+
+def _compute_phase(current_phase: int, phase_turns: int) -> tuple[int, int]:
+    """Advance phase based on conversation depth.
+
+    Returns (new_phase, new_phase_turns).
+    Phase advances after MAX_TURNS_PER_PHASE learner turns in the same phase.
+    """
+    new_turns = phase_turns + 1
+    if new_turns >= MAX_TURNS_PER_PHASE and current_phase < 4:
+        return current_phase + 1, 0
+    return current_phase, new_turns
 
 
 @app.post("/api/chat", response_model=ChatResponse)
 async def api_chat(req: ChatRequest):
+    api_key = os.environ.get("OPENROUTER_API_KEY", "").strip()
+    base_url = os.environ.get("LLM_BASE_URL", "").strip()
+    model = os.environ.get("LLM_MODEL", "").strip()
+    if not api_key:
+        logger.error("OPENROUTER_API_KEY is not set!")
+        return JSONResponse(status_code=500, content={"error": "Cle API non configuree (OPENROUTER_API_KEY manquant)"})
+
     try:
+        # Compute phase progression server-side
+        new_phase, new_phase_turns = _compute_phase(req.phase, req.phase_turns)
+        logger.info(f"Chat request: mode={req.mode}, topic={req.topic[:50]}, phase={req.phase}->{new_phase}, turns={req.phase_turns}->{new_phase_turns}, model={model}")
+
         rag_chunks = retrieve(req.message)
-        system_prompt = build_system_prompt(req.mode, req.topic, req.phase, rag_chunks)
+        system_prompt = build_system_prompt(req.mode, req.topic, new_phase, rag_chunks)
 
         messages = [{"role": m["role"], "content": m["content"]} for m in req.history]
         messages.append({"role": "user", "content": req.message})
 
         reply = await chat(system_prompt, messages)
-        detected_phase = _detect_phase(reply, req.phase)
+        logger.info(f"LLM reply received ({len(reply)} chars)")
 
-        return ChatResponse(reply=reply, phase=detected_phase)
+        return ChatResponse(reply=reply, phase=new_phase, phase_turns=new_phase_turns)
     except Exception as e:
         logger.error(f"Chat error: {e}\n{traceback.format_exc()}")
         return JSONResponse(status_code=500, content={"error": str(e)})
@@ -107,7 +136,7 @@ async def api_upload(files: List[UploadFile] = File(...)):
     for f in files:
         ext = Path(f.filename).suffix.lower() if f.filename else ""
         if ext not in ALLOWED_EXTENSIONS:
-            skipped.append({"filename": f.filename, "reason": f"Type non support\u00e9: {ext}"})
+            skipped.append({"filename": f.filename, "reason": f"Type non supporté: {ext}"})
             continue
         content = await f.read()
         file_data.append((f.filename, content))
@@ -128,7 +157,7 @@ async def api_delete_document(filename: str):
     ok = delete_document(filename)
     if ok:
         return {"status": "ok"}
-    return {"status": "error", "message": "Fichier non trouv\u00e9"}
+    return {"status": "error", "message": "Fichier non trouvé"}
 
 
 @app.post("/api/analyze", response_model=AnalysisResponse)
@@ -159,7 +188,6 @@ async def api_analyze(req: AnalysisRequest):
 
 @app.get("/api/health")
 async def health():
-    import os
     return {
         "status": "ok",
         "has_api_key": bool(os.environ.get("OPENROUTER_API_KEY", "")),

static/app.js

@@ -11,6 +11,7 @@
         mode: "TUTOR",
         topic: "",
         phase: 0,
+        phaseTurns: 0,
         history: [],      // {role, content}
         timestamps: [],   // epoch ms for every message (user & assistant alternating)
         analysisResult: null,
@@ -94,10 +95,17 @@
     }
 
     /* ===== Messages ===== */
+    function stripPhaseMarker(text) {
+        // Remove "---\nPhase: ..." block from the end of assistant messages
+        var idx = text.indexOf("\n---");
+        if (idx === -1) idx = text.indexOf("---\nPhase");
+        return idx >= 0 ? text.substring(0, idx).trim() : text;
+    }
+
     function addMessage(role, content) {
         var div = document.createElement("div");
         div.className = "message " + role;
-        div.textContent = content;
+        div.textContent = role === "assistant" ? stripPhaseMarker(content) : content;
         messagesEl.insertBefore(div, typingEl);
         messagesEl.scrollTop = messagesEl.scrollHeight;
     }
@@ -252,13 +260,27 @@
                 mode: state.mode,
                 topic: state.topic,
                 phase: state.phase,
+                phase_turns: state.phaseTurns,
                 history: state.history.slice(0, -1)
             })
         })
-        .then(function (res) { return res.json(); })
+        .then(function (res) {
+            if (!res.ok) {
+                return res.json().then(function (err) {
+                    throw new Error(err.error || "Erreur serveur " + res.status);
+                });
+            }
+            return res.json();
+        })
         .then(function (data) {
             setTyping(false);
+            if (!data.reply) {
+                addMessage("assistant", "Reponse vide du serveur. Verifiez la configuration API.");
+                btnSend.disabled = false;
+                return;
+            }
             state.phase = data.phase;
+            state.phaseTurns = data.phase_turns || 0;
             state.history.push({ role: "assistant", content: data.reply });
             state.timestamps.push(Date.now());
             addMessage("assistant", data.reply);
@@ -268,7 +290,8 @@
         })
         .catch(function (err) {
             setTyping(false);
-            addMessage("assistant", "Erreur de connexion. Veuillez reessayer.");
+            console.error("sendMessage error:", err);
+            addMessage("assistant", "Erreur: " + (err.message || "Connexion impossible. Veuillez reessayer."));
             btnSend.disabled = false;
         });
     }
@@ -364,6 +387,7 @@
         state.mode = "TUTOR";
         state.topic = "";
         state.phase = 0;
+        state.phaseTurns = 0;
         state.history = [];
         state.timestamps = [];
         state.analysisResult = null;
@@ -424,6 +448,10 @@
         if (!topic) return;
 
         state.topic = topic;
+        state.phase = 0;
+        state.phaseTurns = 0;
+        state.history = [];
+        state.timestamps = [];
         modeBadge.textContent = state.mode === "TUTOR" ? "Tuteur" : "Critique";
         topicBadge.textContent = topic;
 
@@ -455,13 +483,27 @@
                 mode: state.mode,
                 topic: state.topic,
                 phase: state.phase,
+                phase_turns: state.phaseTurns,
                 history: []
             })
         })
-        .then(function (res) { return res.json(); })
+        .then(function (res) {
+            if (!res.ok) {
+                return res.json().then(function (err) {
+                    throw new Error(err.error || "Erreur serveur " + res.status);
+                });
+            }
+            return res.json();
+        })
         .then(function (data) {
             setTyping(false);
+            if (!data.reply) {
+                addMessage("assistant", "Reponse vide du serveur. Verifiez la configuration API.");
+                btnSend.disabled = false;
+                return;
+            }
             state.phase = data.phase;
+            state.phaseTurns = data.phase_turns || 0;
             state.history.push({ role: "assistant", content: data.reply });
             state.timestamps.push(Date.now());
             addMessage("assistant", data.reply);
@@ -469,9 +511,10 @@
             btnSend.disabled = false;
             chatInput.focus();
         })
-        .catch(function () {
+        .catch(function (err) {
             setTyping(false);
-            addMessage("assistant", "Erreur de connexion. Veuillez reessayer.");
+            console.error("startSession error:", err);
+            addMessage("assistant", "Erreur: " + (err.message || "Connexion impossible. Veuillez reessayer."));
             btnSend.disabled = false;
         });
     }