Update app.py

app.py

@@ -17,6 +17,10 @@ FAISS_PATH = os.environ.get("FAISS_PATH", f"{ASSETS_DIR}/index.faiss")
 META_PATH  = os.environ.get("META_PATH",  f"{ASSETS_DIR}/index_meta.filtered.jsonl")
 REL_CONFIG_PATH = os.environ.get("REL_CONFIG_PATH", f"{ASSETS_DIR}/relevance_config.json")
 QUANTIZE = os.environ.get("QUANTIZE", "4bit")  # "none" | "8bit" | "4bit"
+# --- Turn logging ---
+TRANSCRIPT_PATH   = os.environ.get("TRANSCRIPT_PATH", "transcripts.jsonl")
+PUSH_TRANSCRIPTS  = os.environ.get("PUSH_TRANSCRIPTS", "1") == "1"  # set to "0" to disable
+
 
 # Models
 BASE_MODEL   = os.environ.get("BASE_MODEL", "mistralai/Mistral-7B-Instruct-v0.2")
@@ -810,35 +814,59 @@ def enter_app(first_name, last_name, state):
     state["last_name"]  = last_name
     return gr.update(visible=False), gr.update(visible=True), state, f"Welcome, {first_name}! You can start chatting."
 
+def _log_turn(state: Dict[str, Any], question: str, answer: str):
+    rec = {
+        "timestamp_utc": _now_iso(),
+        "session_id": state.get("session_id", ""),
+        "first_name": state.get("first_name", ""),
+        "last_name":  state.get("last_name", ""),
+        "question": question,
+        "answer":   answer,
+    }
+    with open(TRANSCRIPT_PATH, "a", encoding="utf-8") as f:
+        f.write(json.dumps(rec, ensure_ascii=False) + "\n")
+
+    if PUSH_TRANSCRIPTS:
+        _push_file_to_hub(TRANSCRIPT_PATH, "analytics/transcripts.jsonl")
+    
+
 def predict(message, chat_history, state):
-    answer = ask(message)
-    chat_history = chat_history + [(message, answer)]
-    state["last_q"] = message
+    msg = (message or "").strip()
+    if not msg:
+        # No input → don't show feedback, just return current state
+        return chat_history, "", gr.update(visible=False), None, "", state
+
+    try:
+        answer = ask(msg)
+    except Exception as e:
+        answer = f"Sorry — something went wrong: {e!r}"
+
+    chat_history = (chat_history or []) + [(msg, answer)]
+    state["last_q"] = msg
     state["last_a"] = answer
+
+    # Log every turn (safe if _log_turn isn't defined)
+    try:
+        _log_turn(state, msg, answer)
+    except Exception:
+        pass
+
     return (
         chat_history,
-        "",  # clear input
-        gr.update(visible=True),  # show feedback pane
-        gr.update(value=None),    # reset rating
-        gr.update(value=""),      # reset comment
+        "",                          # clear input
+        gr.update(visible=True),     # show feedback pane
+        gr.update(value=None),       # reset rating
+        gr.update(value=""),         # reset comment
         state
     )
 
+
 def _push_feedback_to_hub():
-    """Optional: upload feedback.csv to Space repo path analytics/feedback.csv"""
-    if not (PUSH_FEEDBACK and HF_WRITE_TOKEN and SPACE_REPO_ID and os.path.exists(FEEDBACK_PATH)):
+    """Upload feedback.csv to analytics/feedback.csv in this Space repo (if enabled)."""
+    if not PUSH_FEEDBACK:
         return
-    try:
-        api = HfApi(token=HF_WRITE_TOKEN)
-        api.upload_file(
-            path_or_fileobj=FEEDBACK_PATH,
-            path_in_repo="analytics/feedback.csv",
-            repo_id=SPACE_REPO_ID,
-            repo_type="space",
-        )
-        dlog("FEEDBACK", "Uploaded analytics/feedback.csv to Hub")
-    except Exception as e:
-        dlog("FEEDBACK", f"Hub upload failed: {e}")
+    _push_file_to_hub(FEEDBACK_PATH, "analytics/feedback.csv")
+
 
 
 def save_feedback(rating, comment, state):