Add Google Sheets integration to backend API

- Integrate sheets_storage with /api/entity-feedback endpoint
- Integrate sheets_storage with /api/rating endpoint
- Keep local file backup alongside cloud storage

Co-Authored-By: Claude Opus 4.5 <noreply@anthropic.com>

backend/api.py

@@ -23,6 +23,16 @@ except ImportError:
 
 from .services import get_knowledge_base, get_retriever, search_knowledge_base, get_stats
 
+# Google Sheets storage for persistent feedback
+import sys
+sys.path.insert(0, str(Path(__file__).parent.parent / "ir"))
+try:
+    import sheets_storage
+    SHEETS_ENABLED = sheets_storage.is_sheets_enabled()
+except ImportError:
+    SHEETS_ENABLED = False
+    sheets_storage = None
+
 # DeepL API configuration
 DEEPL_API_KEY = os.environ.get("DEEPL_API_KEY", "")
 DEEPL_API_URL = "https://api-free.deepl.com/v2/translate"  # Use api.deepl.com for paid plans
@@ -289,7 +299,26 @@ async def api_rating(request: RatingRequest, req: Request):
             "rating_value": request.rating_value
         }
 
-        # Load existing ratings
+        # Try Google Sheets first (persistent cloud storage)
+        sheets_saved = False
+        if SHEETS_ENABLED and sheets_storage:
+            try:
+                success = sheets_storage.save_rating_to_sheets(
+                    query=request.query,
+                    category=request.category or "Not selected",
+                    entity_id=request.entity_id,
+                    entity_name=request.entity_id,  # Use ID as name fallback
+                    rank=request.entity_index + 1,
+                    score=0,
+                    rating=f"{request.rating_type}:{request.rating_value}",
+                    page=1,
+                    client_ip=client_ip
+                )
+                sheets_saved = success
+            except Exception as e:
+                print(f"Google Sheets save failed: {e}")
+
+        # Also save to local file as backup
         if rating_file.exists():
             with open(rating_file, "r", encoding="utf-8") as f:
                 all_ratings = json.load(f)
@@ -298,11 +327,10 @@ async def api_rating(request: RatingRequest, req: Request):
 
         all_ratings.append(rating)
 
-        # Save ratings
         with open(rating_file, "w", encoding="utf-8") as f:
             json.dump(all_ratings, f, ensure_ascii=False, indent=2)
 
-        return {"success": True, "total": len(all_ratings)}
+        return {"success": True, "total": len(all_ratings), "sheets_saved": sheets_saved}
 
     except Exception as e:
         return {"success": False, "error": str(e)}
@@ -336,7 +364,28 @@ async def api_entity_feedback(request: EntityFeedbackRequest, req: Request):
             "submitted_at": request.submitted_at
         }
 
-        # Load existing feedbacks
+        # Try Google Sheets first (persistent cloud storage)
+        sheets_saved = False
+        if SHEETS_ENABLED and sheets_storage:
+            try:
+                # Convert ratings dict to string for sheet
+                ratings_str = json.dumps(request.ratings) if request.ratings else ""
+                success = sheets_storage.save_rating_to_sheets(
+                    query=request.query,
+                    category=str(request.rank_position),  # Use rank as category placeholder
+                    entity_id=request.entity_id,
+                    entity_name=request.entity_name,
+                    rank=request.rank_position,
+                    score=request.rank_score,
+                    rating=ratings_str,
+                    page=1,
+                    client_ip=client_ip
+                )
+                sheets_saved = success
+            except Exception as e:
+                print(f"Google Sheets save failed: {e}")
+
+        # Also save to local file as backup
         if feedback_file.exists():
             with open(feedback_file, "r", encoding="utf-8") as f:
                 all_feedbacks = json.load(f)
@@ -345,11 +394,10 @@ async def api_entity_feedback(request: EntityFeedbackRequest, req: Request):
 
         all_feedbacks.append(feedback)
 
-        # Save feedbacks
         with open(feedback_file, "w", encoding="utf-8") as f:
             json.dump(all_feedbacks, f, ensure_ascii=False, indent=2)
 
-        return {"success": True, "total": len(all_feedbacks)}
+        return {"success": True, "total": len(all_feedbacks), "sheets_saved": sheets_saved}
 
     except Exception as e:
         return {"success": False, "error": str(e)}