Add remaining changes to previous commit

.gitignore

@@ -3,4 +3,7 @@ __pycache__
 .env
 data
 .gradio
-supabase_dump.sql
+supabase_dump.sql
+src/ui/node_modules/
+src/ui/.next/
+src/ui/.env.local

config.py

@@ -8,9 +8,11 @@ class Settings(BaseSettings):
     postgres_user: str
     postgres_password: str
     postgres_db: str
-    database_url: str
+    database_url: str   
     qdrant_url: str
     qdrant_api_key: str
+    fastapi_api_key: str
+    frontend_api_key: str
 
     class Config:
         env_file = '.env'

src/api/main.py

@@ -1,5 +1,6 @@
 from src.retrieval.rag_pipeline import AnimeRAGPipeline
-from fastapi import FastAPI, HTTPException, status, Request
+from fastapi import FastAPI, HTTPException, status, Request, Security, Depends
+from fastapi.security import APIKeyHeader
 from fastapi.middleware.cors import CORSMiddleware
 from pydantic import BaseModel, Field
 import uvicorn
@@ -13,6 +14,15 @@ from contextlib import asynccontextmanager
 logger = logging.basicConfig(level=logging.INFO)
 logger = logging.getLogger(__name__)
 
+api_key_header = APIKeyHeader(name="X-API-Key")
+
+
+async def verify_api_key(api_key: str = Security(api_key_header)):
+    if api_key != settings.fastapi_api_key:
+        raise HTTPException(
+            status_code=status.HTTP_403_FORBIDDEN, detail="Invalid API Key")
+    return api_key
+
 
 @asynccontextmanager
 async def lifespan(app: FastAPI):
@@ -53,7 +63,7 @@ async def root():
 
 
 @app.post("/recommend", response_model=RecommendationResponse)
-async def get_recommendations(request: RecommendationRequest, fastapi_req: Request):
+async def get_recommendations(request: RecommendationRequest, fastapi_req: Request, _=Depends(verify_api_key)):
     """
     Get anime recommendation based on user query
 
@@ -112,12 +122,12 @@ async def get_recommendations(request: RecommendationRequest, fastapi_req: Reque
 
 
 @app.get("/stats")
-async def get_stats(fastapi_req: Request):
+async def get_stats(fastapi_req: Request, _=Depends(verify_api_key)):
     """Get system statistics"""
     rag_pipeline = fastapi_req.app.state.pipeline
 
     return {
-        "total_anime": rag_pipeline.retriever.collection.count(),
+        "total_anime": rag_pipeline.retriever.points_count,
         "embedding_model": "all-MiniLM-L6-v2",
         "llm_model": settings.model_name,
         "retrieval_k": rag_pipeline.retriever_k