Add feedback UI and capture to nitdaa_summary.json

app.py

@@ -193,7 +193,7 @@ def log_session(event_type: str, token: str, ip: str):
 
 _known_sessions = {}
 
-def log_query_summary(token: str, ip: str, query: str, chunks_retrieved: int, gen_time: float, success: bool, error: str = ""):
+def log_query_summary(token: str, ip: str, query: str, chunks_retrieved: int, gen_time: float, success: bool, error: str = "", job_id: str = ""):
     try:
         log_dir = Path(__file__).parent / "app" / "logs"
         log_dir.mkdir(parents=True, exist_ok=True)
@@ -205,6 +205,7 @@ def log_query_summary(token: str, ip: str, query: str, chunks_retrieved: int, ge
         
         entry = {
             "timestamp": ts,
+            "job_id": job_id,
             "ip_address": ip,
             "session_token": token,
             "question": query,
@@ -857,13 +858,12 @@ def query_start():
             _query_jobs[job_id]["done"] = True
             
             gen_time = metrics.get("time_seconds", 0)
-            log_query_summary(token, remote_addr, q, top_k or 10, gen_time, True)
+            log_query_summary(token, remote_addr, q, top_k or 10, gen_time, True, "", job_id)
         except Exception as e:
-            log.exception("Query pipeline error")
+            log.exception("Query failed")
             _query_jobs[job_id]["events"].append({"error": str(e)})
-            _query_jobs[job_id]["error"] = str(e)
             _query_jobs[job_id]["done"] = True
-            log_query_summary(token, remote_addr, q, top_k or 10, 0, False, str(e))
+            log_query_summary(token, remote_addr, q, top_k or 10, 0, False, str(e), job_id)
 
     _query_executor.submit(_run)
     
@@ -901,6 +901,41 @@ def query_stream(job_id):
         headers={"Cache-Control": "no-cache", "X-Accel-Buffering": "no"},
     )
 
+@app.route("/api/feedback", methods=["POST"])
+@limiter.limit("20 per minute")
+def api_feedback():
+    data = request.get_json() or {}
+    job_id = data.get("job_id", "")
+    rating = data.get("rating", "neutral")
+    text = data.get("text", "")
+    token = get_session_token()
+    
+    try:
+        log_dir = Path(__file__).parent / "app" / "logs"
+        log_dir.mkdir(parents=True, exist_ok=True)
+        summary_file = log_dir / "nitdaa_summary.json"
+        
+        from datetime import datetime, timezone, timedelta
+        ist = timezone(timedelta(hours=5, minutes=30))
+        ts = datetime.now(ist).strftime("%Y-%m-%d %H:%M:%S")
+        
+        entry = {
+            "timestamp": ts,
+            "session_token": token,
+            "job_id": job_id,
+            "type": "feedback",
+            "feedback_rating": rating,
+            "feedback_text": text
+        }
+        with open(summary_file, "a") as f:
+            f.write(json.dumps(entry) + "\n")
+            
+        async_sync_log(str(summary_file), "nitdaa_summary.json")
+        return jsonify({"ok": True})
+    except Exception as e:
+        log.error(f"Failed to save feedback: {e}")
+        return jsonify({"error": str(e)}), 500
+
 
 # ── Headless API v1 ───────────────────────────────────────────────────────────
 

templates/index.html

@@ -507,6 +507,12 @@
                               Analysis took ${data.metrics.time_seconds?.toFixed(1) || '?'} seconds.
                               Tokens: ${data.metrics.tokens_in || '?'} in, ${data.metrics.tokens_out || '?'} out.
                             </div>
+                            <div id="feedback-container-${jobId}" style="margin-top: 15px; display: flex; align-items: center; gap: 10px; background: rgba(0,0,0,0.03); padding: 10px; border-radius: 8px;">
+                              <button class="fb-btn fb-up" onclick="submitFeedback('${jobId}', 'positive')" style="background:none; border:none; cursor:pointer; font-size:1.5rem; transition: transform 0.2s;">👍</button>
+                              <button class="fb-btn fb-down" onclick="submitFeedback('${jobId}', 'negative')" style="background:none; border:none; cursor:pointer; font-size:1.5rem; transition: transform 0.2s;">👎</button>
+                              <input type="text" id="fb-text-${jobId}" placeholder="Optional feedback..." style="flex-grow:1; padding:8px; border:1px solid #ddd; border-radius:4px; font-size: 0.9rem;">
+                              <button onclick="submitFeedback('${jobId}', null)" style="padding:8px 15px; background: var(--primary-color); color: white; border: none; border-radius: 4px; cursor:pointer; font-weight: bold;">Submit</button>
+                            </div>
                           `;
                           answerContent.innerHTML += metricsHtml;
                           window.scrollTo(0, document.body.scrollHeight);
@@ -550,6 +556,45 @@
         }
       });
     });
+    
+    // Feedback Logic
+    window.submitFeedback = async function(jobId, explicitRating) {
+      const container = document.getElementById(`feedback-container-${jobId}`);
+      if (!container) return;
+      
+      let rating = container.getAttribute('data-rating') || 'neutral';
+      
+      if (explicitRating) {
+        rating = explicitRating;
+        container.setAttribute('data-rating', rating);
+        // UI updates for selected icon
+        const upBtn = container.querySelector('.fb-up');
+        const downBtn = container.querySelector('.fb-down');
+        upBtn.style.transform = rating === 'positive' ? 'scale(1.2)' : 'scale(1)';
+        upBtn.style.filter = rating === 'positive' ? 'drop-shadow(0 0 5px #4caf50)' : 'none';
+        
+        downBtn.style.transform = rating === 'negative' ? 'scale(1.2)' : 'scale(1)';
+        downBtn.style.filter = rating === 'negative' ? 'drop-shadow(0 0 5px #f44336)' : 'none';
+      }
+      
+      const textInput = document.getElementById(`fb-text-${jobId}`);
+      const text = textInput ? textInput.value : "";
+      
+      try {
+        const res = await fetch('/api/feedback', {
+          method: 'POST',
+          headers: { 'Content-Type': 'application/json', 'X-Session-Token': SESSION_TOKEN },
+          body: JSON.stringify({ job_id: jobId, rating: rating, text: text })
+        });
+        
+        if (res.ok && !explicitRating) {
+          // If explicitRating is null, user clicked the Submit button
+          container.innerHTML = '<span style="color: #4caf50; font-weight: bold; margin: 0 auto;">Feedback submitted! Thank you.</span>';
+        }
+      } catch (e) {
+        console.error("Failed to submit feedback", e);
+      }
+    };
   </script>
 </body>
 </html>