Update app.py

app.py

@@ -7,13 +7,13 @@ import requests
 import json
 import gradio as gr
 from gtts import gTTS
-
+ 
 # ── llama-server connection ──────────────────────────────────────────────────
 LLAMA_URL      = os.getenv("LLAMA_SERVER_URL", "http://127.0.0.1:8080")
 CHAT_ENDPOINT  = f"{LLAMA_URL}/v1/chat/completions"
 _server_ok     = False
 _server_lock   = threading.Lock()
-
+ 
 def _check_server():
     """Background thread: poll until llama-server is ready."""
     global _server_ok
@@ -29,20 +29,20 @@ def _check_server():
             pass
         time.sleep(2)
     print("[law-app] llama-server not reachable – keyword fallback active")
-
+ 
 threading.Thread(target=_check_server, daemon=True).start()
-
+ 
 # ── Leçons ───────────────────────────────────────────────────────────────────
 with open("lessons.json") as f:
     LESSONS = json.load(f)
-
+ 
 LISTEN_SECONDS = 10   # 900 en production (15 min)
 PASS_SCORE     = 6
-
+ 
 # ── Cache audio par leçon ─────────────────────────────────────────────────────
 _audio_cache = {}
 _audio_lock  = threading.Lock()
-
+ 
 def get_lecture_audio(lesson_idx):
     if lesson_idx in _audio_cache and os.path.exists(_audio_cache[lesson_idx]):
         return _audio_cache[lesson_idx]
@@ -59,15 +59,15 @@ def get_lecture_audio(lesson_idx):
         except Exception as e:
             print(f"[law-app] gTTS erreur : {e}")
             return None
-
+ 
 # ── État ──────────────────────────────────────────────────────────────────────
 def fresh():
     return json.dumps({"phase": "idle", "listen_start": None,
                        "question_idx": None, "lesson_idx": 0})
-
+ 
 def S(s): return json.loads(s)
 def D(d): return json.dumps(d)
-
+ 
 # ── Évaluation ────────────────────────────────────────────────────────────────
 _SYSTEM_PROMPT = (
     "Tu es un professeur de droit français strict et bienveillant. "
@@ -90,18 +90,18 @@ _SYSTEM_PROMPT = (
     "Éléments attendus : L'OPJ (Officier) a le pouvoir de prendre des mesures coercitives comme le placement en garde à vue, l'APJ (Agent) le seconde.\n"
     '{"score": 1, "feedback": "C\'est incorrect. L\'APJ et l\'OPJ relèvent tous deux de la police judiciaire. La différence majeure réside dans les pouvoirs coercitifs (comme décider d\'une garde à vue) réservés à l\'OPJ, que l\'APJ seconde."}'
 )
-
+ 
 def _keyword_fallback(answer, hint, reason=""):
     kw    = [w.strip().lower() for w in hint.split(",")]
     hits  = sum(1 for k in kw if k in answer.lower())
     score = min(10, round((hits / max(len(kw), 1)) * 10))
     label = f"(Sans IA – {reason} – " if reason else "(Sans IA – "
     return score, f"{label}mots-clés : {hits}/{len(kw)})"
-
+ 
 def evaluate_answer(question, answer, hint):
     if not _server_ok:
         return _keyword_fallback(answer, hint, reason="serveur indisponible")
-
+ 
     user_msg = (
         f"Question : {question}\n"
         f"Réponse de l'étudiant : {answer}\n"
@@ -110,7 +110,7 @@ def evaluate_answer(question, answer, hint):
         "Réponds UNIQUEMENT avec ce JSON sur une seule ligne, sans rien d'autre :\n"
         '{"score": <entier 0-10>, "feedback": "<commentaire bref>"}'
     )
-
+ 
     payload = {
         "model": "local",
         "messages": [
@@ -121,7 +121,7 @@ def evaluate_answer(question, answer, hint):
         "temperature": 0.1,
         "stop": ["\n\n", "###"],
     }
-
+ 
     try:
         resp = requests.post(CHAT_ENDPOINT, json=payload, timeout=60)
         resp.raise_for_status()
@@ -136,7 +136,7 @@ def evaluate_answer(question, answer, hint):
     except Exception as e:
         print(f"[law-app] Erreur éval : {e}")
         return _keyword_fallback(answer, hint, reason=str(e))
-
+ 
 # ── Handlers ──────────────────────────────────────────────────────────────────
 def start_listening(ss):
     state      = S(ss)
@@ -158,7 +158,7 @@ def start_listening(ss):
         gr.update(interactive=False, value="⏳ Écoute en cours…"),
         D(state),
     )
-
+ 
 def check_timer(ss):
     state = S(ss)
     if state["phase"] != "listen" or not state["listen_start"]:
@@ -176,7 +176,7 @@ def check_timer(ss):
         f"🎧 Patientez encore **{m} min {s:02d} s**.",
         ss,
     )
-
+ 
 def open_quiz(ss):
     state   = S(ss)
     elapsed = time.time() - (state["listen_start"] or 0)
@@ -185,22 +185,29 @@ def open_quiz(ss):
         return (
             gr.update(visible=True),  gr.update(visible=False),
             gr.update(visible=False), gr.update(visible=False),
-            f"⚠️ Patientez encore **{m} min {s:02d} s**.", "", "", ss,
+            gr.update(value=f"⚠️ Patientez encore **{m} min {s:02d} s**."),
+            gr.update(value=""),
+            gr.update(value=""),
+            ss,
         )
     lesson_idx = state.get("lesson_idx", 0)
     idx        = random.randrange(len(LESSONS[lesson_idx]["questions"]))
     state.update({"phase": "quiz", "question_idx": idx})
+    question_text = LESSONS[lesson_idx]["questions"][idx]["q"]
     return (
         gr.update(visible=False), gr.update(visible=True),
         gr.update(visible=False), gr.update(visible=False),
-        "", LESSONS[lesson_idx]["questions"][idx]["q"], "", D(state),
+        gr.update(value=""),
+        gr.update(value=question_text),
+        gr.update(value=""),
+        D(state),
     )
-
+ 
 # ── Submit avec désactivation immédiate du bouton ─────────────────────────────
 def submit_answer(answer, ss):
     state      = S(ss)
     lesson_idx = state.get("lesson_idx", 0)
-
+ 
     if state["phase"] != "quiz":
         yield (
             gr.update(visible=True),  gr.update(visible=False),
@@ -211,7 +218,7 @@ def submit_answer(answer, ss):
             ss,
         )
         return
-
+ 
     # Étape 1 : désactiver immédiatement bouton + textbox
     yield (
         gr.update(visible=False), gr.update(visible=True),
@@ -221,13 +228,13 @@ def submit_answer(answer, ss):
         gr.update(interactive=False),
         ss,
     )
-
+ 
     # Étape 2 : évaluation IA
     q            = LESSONS[lesson_idx]["questions"][state["question_idx"]]
     score, fb    = evaluate_answer(q["q"], answer, q["hint"])
     total        = len(LESSONS)
     is_last      = (lesson_idx >= total - 1)
-
+ 
     if score >= PASS_SCORE:
         state["phase"] = "pass"
         result = (
@@ -244,7 +251,7 @@ def submit_answer(answer, ss):
             "Veuillez **réécouter la leçon** avant de retenter."
         )
         next_label = "🔄 Réécouter la leçon"
-
+ 
     # Étape 3 : afficher résultat, réactiver bouton, mettre à jour next_btn
     yield (
         gr.update(visible=False), gr.update(visible=False),
@@ -254,15 +261,15 @@ def submit_answer(answer, ss):
         gr.update(value="", interactive=True),
         D(state),
     )
-
+ 
 def handle_next(ss):
     state      = S(ss)
     lesson_idx = state.get("lesson_idx", 0)
     total      = len(LESSONS)
-
+ 
     if state["phase"] == "fail":
         return start_listening(D(state))
-
+ 
     if lesson_idx >= total - 1:
         state["phase"] = "done"
         cert = (
@@ -290,22 +297,22 @@ def handle_next(ss):
         state["lesson_idx"] = lesson_idx + 1
         state["listen_start"] = None
         return start_listening(D(state))
-
+ 
 def restart_from_cert(ss):
     return start_listening(fresh())
-
+ 
 # ── UI ────────────────────────────────────────────────────────────────────────
 CSS = "footer{display:none!important;} #title{text-align:center;}"
-
+ 
 with gr.Blocks(title="Cours de Droit", css=CSS) as demo:
     session = gr.State(fresh())
-
+ 
     gr.Markdown(
         "# ⚖️ Cours de Droit — Formation Juridique\n"
         "Écoutez chaque leçon · Répondez à la question · Progressez leçon par leçon",
         elem_id="title",
     )
-
+ 
     with gr.Column(visible=True) as listen_col:
         gr.Markdown("## 🎧 Étape 1 — Écoute de la leçon")
         listen_msg = gr.Markdown("Cliquez sur **Démarrer** pour commencer.")
@@ -315,43 +322,44 @@ with gr.Blocks(title="Cours de Droit", css=CSS) as demo:
             start_btn = gr.Button("▶️ Démarrer l'écoute", variant="primary")
             check_btn = gr.Button("🔄 Vérifier le temps",  variant="secondary")
             quiz_btn  = gr.Button("✅ Accéder au Quiz",    variant="secondary", interactive=False)
-
+ 
     with gr.Column(visible=False) as quiz_col:
         gr.Markdown("## 📝 Étape 2 — Question d'évaluation")
         question_md = gr.Markdown("")
         answer_box  = gr.Textbox(label="Votre réponse", placeholder="Rédigez ici…", lines=5)
         submit_btn  = gr.Button("📤 Soumettre", variant="primary")
-
+ 
     with gr.Column(visible=False) as result_col:
         gr.Markdown("## 📊 Résultat")
         result_md = gr.Markdown("")
         next_btn  = gr.Button("➡️ Leçon suivante", variant="primary")
-
+ 
     with gr.Column(visible=False) as cert_col:
         cert_md     = gr.Markdown("")
         restart_btn = gr.Button("🔄 Recommencer depuis le début", variant="secondary")
-
+ 
     # ── Câblage ──────────────────────────────────────────────────────��────────
     LISTEN_OUT = [audio_out, listen_msg,
                   listen_col, quiz_col, result_col, cert_col,
                   quiz_btn, session]
-
+ 
     start_btn.click(start_listening, [session], LISTEN_OUT)
     check_btn.click(check_timer, [session], [quiz_btn, timer_info, session])
-
+ 
     QUIZ_OUT = [listen_col, quiz_col, result_col, cert_col,
                 timer_info, question_md, answer_box, session]
     quiz_btn.click(open_quiz, [session], QUIZ_OUT)
-
+ 
     # submit_answer est un générateur → outputs inclut submit_btn et answer_box
     RES_OUT = [listen_col, quiz_col, result_col, cert_col,
                result_md, submit_btn, answer_box, session]
     submit_btn.click(submit_answer, [answer_box, session], RES_OUT)
     answer_box.submit(submit_answer, [answer_box, session], RES_OUT)
-
+ 
     next_btn.click(handle_next, [session], LISTEN_OUT)
     restart_btn.click(restart_from_cert, [session], LISTEN_OUT)
-
+ 
 if __name__ == "__main__":
     demo.queue()
     demo.launch(server_name="0.0.0.0", server_port=7860, show_error=True)
+