Deploy from GitHub (3f6ecba)

.gitattributes

@@ -1,3 +1,3 @@
+data/*.faiss filter=lfs diff=lfs merge=lfs -text
 data/*.json filter=lfs diff=lfs merge=lfs -text
 data/*.db filter=lfs diff=lfs merge=lfs -text
-data/*.faiss filter=lfs diff=lfs merge=lfs -text

app.py

@@ -189,14 +189,16 @@ async def lifespan(_app: FastAPI) -> AsyncGenerator[None, None]:
     """Spawn background pipeline loading so HTTP is available immediately."""
     thread = threading.Thread(target=_load_pipeline_background, daemon=True)
     thread.start()
-    start_flush_scheduler(
-        config.FEEDBACK_BUFFER_PATH,
-        config.FEEDBACK_HF_REPO,
-        config.FEEDBACK_FLUSH_INTERVAL_S,
-    )
+    if config.FEEDBACK_ENV == "production":
+        start_flush_scheduler(
+            config.FEEDBACK_BUFFER_PATH,
+            config.FEEDBACK_HF_REPO,
+            config.FEEDBACK_FLUSH_INTERVAL_S,
+        )
     yield
-    stop_flush_scheduler()
-    flush_remaining(config.FEEDBACK_BUFFER_PATH, config.FEEDBACK_HF_REPO)
+    if config.FEEDBACK_ENV == "production":
+        stop_flush_scheduler()
+        flush_remaining(config.FEEDBACK_BUFFER_PATH, config.FEEDBACK_HF_REPO)
     pipeline.clear()
     pipeline_ready.clear()
 
@@ -350,9 +352,10 @@ def feedback_endpoint(
     verse: str = Form(""),
     score: float = Form(0.0),
     feedback: str = Form(""),
+    session_id: str = Form(""),
 ) -> Response:
     """Record per-verse relevance feedback."""
-    if feedback not in ("up", "down"):
+    if feedback not in ("up", "down", "cancel_up", "cancel_down"):
         return Response(status_code=400)
     try:
         record_feedback(
@@ -365,6 +368,8 @@ def feedback_endpoint(
             buffer_path=config.FEEDBACK_BUFFER_PATH,
             flush_threshold=config.FEEDBACK_FLUSH_THRESHOLD,
             hf_repo=config.FEEDBACK_HF_REPO,
+            source=config.FEEDBACK_ENV,
+            session_id=session_id,
         )
     except Exception:
         logger.exception("Failed to record feedback")

config.py

@@ -50,7 +50,10 @@ MAX_QUERY_LENGTH: int = 300
 CONTEXT_VERSES: int = 2
 
 # Feedback
-FEEDBACK_BUFFER_PATH: Path = DATA_DIR / "feedback_buffer.jsonl"
+_is_production = bool(os.environ.get("SPACE_ID"))
+FEEDBACK_ENV: str = os.environ.get("FEEDBACK_ENV", "production" if _is_production else "local")
+_buffer_suffix = "" if FEEDBACK_ENV == "production" else f"_{FEEDBACK_ENV}"
+FEEDBACK_BUFFER_PATH: Path = DATA_DIR / f"feedback_buffer{_buffer_suffix}.jsonl"
 FEEDBACK_HF_REPO: str = os.environ.get("FEEDBACK_HF_REPO", "adedaran/rag-bible-feedback")
 FEEDBACK_FLUSH_THRESHOLD: int = 5
 FEEDBACK_FLUSH_INTERVAL_S: int = 300  # 5 minutes

pyproject.toml

@@ -1,6 +1,6 @@
 [project]
 name = "rag-bible"
-version = "1.1.2"
+version = "1.2.0"
 description = "French Bible RAG system with FAISS + cross-encoder reranking"
 requires-python = ">=3.12"
 dependencies = [

rag/feedback.py

@@ -11,6 +11,7 @@ logger = logging.getLogger(__name__)
 _lock = threading.Lock()
 _scheduler: threading.Timer | None = None
 _count = 0
+_seen: dict[tuple[str, ...], str] = {}
 
 
 def record_feedback(
@@ -23,6 +24,8 @@ def record_feedback(
     buffer_path: Path,
     flush_threshold: int,
     hf_repo: str,
+    source: str = "local",
+    session_id: str = "",
 ) -> None:
     """Append a feedback record to the local JSONL buffer.
 
@@ -46,9 +49,23 @@ def record_feedback(
         Number of records that triggers an automatic flush.
     hf_repo : str
         HuggingFace Dataset repo ID for flushing.
+    source : str
+        Environment source tag ("production" or "local").
+    session_id : str
+        Browser session identifier (UUID from client).
     """
     global _count  # noqa: PLW0603
 
+    dedup_key = (session_id, query, book_title, chapter, verse)
+
+    with _lock:
+        if feedback in ("up", "down"):
+            if _seen.get(dedup_key) == feedback:
+                return
+            _seen[dedup_key] = feedback
+        elif feedback.startswith("cancel_"):
+            _seen.pop(dedup_key, None)
+
     record = {
         "query": query,
         "book_title": book_title,
@@ -56,6 +73,8 @@ def record_feedback(
         "verse": verse,
         "score": score,
         "feedback": feedback,
+        "source": source,
+        "session_id": session_id,
         "timestamp": datetime.now(UTC).isoformat(),
     }
 
@@ -65,7 +84,7 @@ def record_feedback(
             f.write(json.dumps(record, ensure_ascii=False) + "\n")
         _count += 1
 
-        if _count >= flush_threshold:
+        if _count >= flush_threshold and source == "production":
             _count = 0
             threading.Thread(
                 target=_flush_to_hub,

static/app.js

@@ -435,6 +435,48 @@ document.addEventListener("DOMContentLoaded", function () {
     var container = document.getElementById("results-container");
     if (!container) return;
 
+    var sessionId = sessionStorage.getItem("feedback_session_id");
+    if (!sessionId) {
+      sessionId = crypto.randomUUID();
+      sessionStorage.setItem("feedback_session_id", sessionId);
+    }
+
+    function feedbackKey(card) {
+      return (
+        "fb:" +
+        (card.dataset.query || "") +
+        "|" +
+        (card.dataset.bookTitle || "") +
+        "|" +
+        (card.dataset.chapter || "") +
+        "|" +
+        (card.dataset.verse || "")
+      );
+    }
+
+    function restoreFeedbackState() {
+      var cards = container.querySelectorAll(".result-card");
+      cards.forEach(function (card) {
+        var stored = sessionStorage.getItem(feedbackKey(card));
+        if (!stored) return;
+        var btn = card.querySelector(
+          '.feedback-btn[data-feedback="' + stored + '"]'
+        );
+        if (btn) btn.setAttribute("aria-pressed", "true");
+      });
+    }
+
+    restoreFeedbackState();
+
+    document.body.addEventListener("htmx:afterSwap", function (e) {
+      if (
+        e.detail.target &&
+        e.detail.target.id === "results-container"
+      ) {
+        restoreFeedbackState();
+      }
+    });
+
     container.addEventListener("click", function (evt) {
       var btn = evt.target.closest(".feedback-btn");
       if (!btn) return;
@@ -443,9 +485,32 @@ document.addEventListener("DOMContentLoaded", function () {
       if (!card) return;
 
       var isActive = btn.getAttribute("aria-pressed") === "true";
+      var key = feedbackKey(card);
 
       if (isActive) {
         btn.setAttribute("aria-pressed", "false");
+        sessionStorage.removeItem(key);
+
+        var cancelParams = new URLSearchParams();
+        cancelParams.set("query", card.dataset.query || "");
+        cancelParams.set("book_title", card.dataset.bookTitle || "");
+        cancelParams.set("chapter", card.dataset.chapter || "");
+        cancelParams.set("verse", card.dataset.verse || "");
+        cancelParams.set("score", card.dataset.score || "0");
+        cancelParams.set(
+          "feedback",
+          "cancel_" + btn.dataset.feedback
+        );
+        cancelParams.set("session_id", sessionId);
+
+        fetch("/feedback", {
+          method: "POST",
+          headers: {
+            "Content-Type": "application/x-www-form-urlencoded"
+          },
+          body: cancelParams.toString()
+        }).catch(function () {});
+
         return;
       }
 
@@ -457,6 +522,7 @@ document.addEventListener("DOMContentLoaded", function () {
       }
 
       btn.setAttribute("aria-pressed", "true");
+      sessionStorage.setItem(key, btn.dataset.feedback);
 
       var params = new URLSearchParams();
       params.set("query", card.dataset.query || "");
@@ -465,6 +531,7 @@ document.addEventListener("DOMContentLoaded", function () {
       params.set("verse", card.dataset.verse || "");
       params.set("score", card.dataset.score || "0");
       params.set("feedback", btn.dataset.feedback);
+      params.set("session_id", sessionId);
 
       fetch("/feedback", {
         method: "POST",

static/index.html

@@ -65,7 +65,7 @@
     <h2 class="sidebar-title">Historique</h2>
     <div class="history-list"></div>
     <p class="history-empty">Vos recherches apparaîtront ici</p>
-    <p class="sidebar-version">v1.1.2</p>
+    <p class="sidebar-version">v1.2.0</p>
   </aside>
 
   <div class="hero-section">

templates/loading.html

@@ -1,6 +1,6 @@
 <div class="status-message loading-message" role="status" aria-live="polite"
      hx-post="/search" hx-trigger="load delay:2s"
-     hx-target="#results" hx-swap="innerHTML"
+     hx-target="#results-container" hx-swap="innerHTML"
      hx-vals='{"query": "{{ query }}"}'>
   <p>Chargement des modèles en cours...</p>
   <div class="loading-spinner" aria-hidden="true"></div>

uv.lock

@@ -1168,7 +1168,7 @@ wheels = [
 
 [[package]]
 name = "rag-bible"
-version = "1.1.1"
+version = "1.1.2"
 source = { virtual = "." }
 dependencies = [
     { name = "faiss-cpu" },