Update app.py

app.py

@@ -1,13 +1,15 @@
 # app.py — Spine Coder (Chatbot + Feedback + Session Logs) — Gradio 4.x
 # ------------------------------------------------------------------------------
-# FINAL-v2.1 UI build (hardened):
+# FINAL-v2.1 UI build (hardened) + LIVE REPO LOGGING:
 # - Purge caches, dynamic file loader (SPINE_CORE_PATH override) + SHA print
 # - Startup PROBE to logs + in-UI Diagnostics/Probe
 # - Clean CPT table (no per-row modifier columns) + Case Modifiers panel
 # - Build/Core chips, structured logs/export, modern Gradio usage
+# - Optional: push each log line to your Space repo (logs-live/YYYY-MM-DD.jsonl)
 # ------------------------------------------------------------------------------
 
 import os
+import io
 import json
 import uuid
 import pathlib
@@ -121,6 +123,26 @@ os.environ.setdefault("GRADIO_ANALYTICS_ENABLED", "False")
 DEBUG = os.environ.get("DEBUG", "0") == "1"
 PAYER_CHOICES = ["Medicare", "BCBS", "Aetna", "Cigna", "UnitedHealthcare", "Other"]
 
+# ==== Remote log push settings (optional) =====================================
+# Set HF_TOKEN (or HUGGINGFACEHUB_API_TOKEN) as a Space secret with write access.
+# LOG_PUSH_ENABLE=1 to enable. Defaults to current Space repo (SPACE_ID) if HF_TARGET_REPO not set.
+LOG_PUSH_ENABLE = os.environ.get("LOG_PUSH_ENABLE", "0") == "1"
+HF_TARGET_REPO = os.environ.get("HF_TARGET_REPO") or os.environ.get("SPACE_ID")  # e.g., "Slaiwala/Vertebro"
+HF_WRITE_TOKEN = (
+    os.environ.get("HF_TOKEN") or
+    os.environ.get("HUGGINGFACEHUB_API_TOKEN")
+)
+HF_REPO_TYPE = "space"  # keep this as 'space' for Spaces
+
+# Lazy import to avoid runtime dependency if not enabled
+_hf_api = None
+def _get_hf_api():
+    global _hf_api
+    if _hf_api is None:
+        from huggingface_hub import HfApi
+        _hf_api = HfApi(token=HF_WRITE_TOKEN)
+    return _hf_api
+
 # ==== Logging =================================================================
 LOG_DIR = os.environ.get("LOG_DIR", "logs")
 pathlib.Path(LOG_DIR).mkdir(parents=True, exist_ok=True)
@@ -131,10 +153,59 @@ def _log_path(session_id: str) -> str:
 def _utcnow_iso() -> str:
     return datetime.now(timezone.utc).isoformat(timespec="seconds")
 
+def _push_log_line_to_repo(entry: Dict[str, Any]) -> None:
+    """Append a single JSON line to logs-live/YYYY-MM-DD.jsonl in the Space repo."""
+    if not LOG_PUSH_ENABLE:
+        return
+    if not HF_TARGET_REPO or not HF_WRITE_TOKEN:
+        return
+    try:
+        from huggingface_hub import CommitOperationAdd, hf_hub_download
+        api = _get_hf_api()
+
+        day = datetime.utcnow().strftime("%Y-%m-%d")
+        path_in_repo = f"logs-live/{day}.jsonl"
+
+        # Get existing file (if any)
+        existing = ""
+        try:
+            local_fp = hf_hub_download(
+                repo_id=HF_TARGET_REPO,
+                filename=path_in_repo,
+                repo_type=HF_REPO_TYPE,
+                token=HF_WRITE_TOKEN,
+                local_dir="/tmp",
+                local_dir_use_symlinks=False,
+                force_download=False,
+            )
+            with open(local_fp, "r", encoding="utf-8") as f:
+                existing = f.read()
+        except Exception:
+            existing = ""
+
+        # Append one line
+        new_line = json.dumps(entry, ensure_ascii=False)
+        if existing and not existing.endswith("\n"):
+            existing += "\n"
+        merged = (existing + new_line + "\n").encode("utf-8")
+
+        api.create_commit(
+            repo_id=HF_TARGET_REPO,
+            repo_type=HF_REPO_TYPE,
+            operations=[CommitOperationAdd(path_in_repo=path_in_repo, path_or_fileobj=io.BytesIO(merged))],
+            commit_message=f"logs: append {day} ({entry.get('event','')})",
+        )
+    except Exception as e:
+        # Never break the app due to logging; just print.
+        print("[LOG PUSH] failed:", e)
+
 def _append_log(session_id: str, entry: Dict[str, Any]) -> None:
     entry = {"ts": _utcnow_iso(), "session_id": session_id, **entry}
+    # Local JSONL  (unchanged)
     with open(_log_path(session_id), "a", encoding="utf-8") as f:
         f.write(json.dumps(entry, ensure_ascii=False) + "\n")
+    # NEW: push to repo (optional)
+    _push_log_line_to_repo(entry)
 
 def export_session(session_id: str) -> str:
     src = _log_path(session_id)