Update app.py

app.py

@@ -10,6 +10,11 @@ from config import cookies, headers, groqapi
 from prompts import ChiplingPrompts
 from groq import Groq
 import json
+from fastapi.responses import HTMLResponse
+from fastapi.templating import Jinja2Templates
+from pathlib import Path
+from collections import Counter, defaultdict
+from utils.logger import log_request
 
 app = FastAPI()
 
@@ -22,6 +27,45 @@ app.add_middleware(
     allow_headers=["*"],
 )
 
+templates = Jinja2Templates(directory="templates")
+LOG_FILE = Path("logs.json")
+
+@app.get("/dashboard", response_class=HTMLResponse)
+async def dashboard(request: Request, endpoint: str = None):
+    try:
+        with open("logs.json") as f:
+            logs = json.load(f)
+    except FileNotFoundError:
+        logs = []
+
+    # Filter logs
+    if endpoint:
+        logs = [log for log in logs if log["endpoint"] == endpoint]
+
+    # Summary stats
+    total_requests = len(logs)
+    endpoint_counts = Counter(log["endpoint"] for log in logs)
+    query_counts = Counter(log["query"] for log in logs)
+
+    # Requests per date
+    date_counts = defaultdict(int)
+    for log in logs:
+        date = log["timestamp"].split("T")[0]
+        date_counts[date] += 1
+
+    # Sort logs by timestamp (desc)
+    logs_sorted = sorted(logs, key=lambda x: x["timestamp"], reverse=True)
+
+    return templates.TemplateResponse("dashboard.html", {
+        "request": request,
+        "logs": logs_sorted[:100],  # show top 100
+        "total_requests": total_requests,
+        "endpoint_counts": dict(endpoint_counts),
+        "query_counts": query_counts.most_common(5),
+        "date_counts": dict(date_counts),
+        "filter_endpoint": endpoint or "",
+    })
+
 # Define request model
 class ChatRequest(BaseModel):
     message: str
@@ -176,6 +220,7 @@ async def chat(request: ChatRequest):
     }
 
     selected_generator = random.choice([groqgenerate, generate])
+    log_request("/chat", selected_generator.__name__)
     return StreamingResponse(selected_generator(json_data), media_type='text/event-stream')
 
 
@@ -184,6 +229,9 @@ async def generate_modules(request: Request):
     data = await request.json()
     search_query = data.get("searchQuery")
 
+    log_request("/generate-modules", search_query)
+
+
     if not search_query:
         return {"error": "searchQuery is required"}
 
@@ -229,6 +277,9 @@ async def generate_topics(request: Request):
 
     if not search_query:
         return {"error": "searchQuery is required"}
+    
+    log_request("/generate-topics", search_query)
+
 
     system_prompt = ChiplingPrompts.generateTopics(search_query)