Add FYP dashboard

Dockerfile

@@ -0,0 +1,14 @@
+FROM python:3.10
+
+RUN useradd -m -u 1000 user
+USER user
+ENV PATH="/home/user/.local/bin:$PATH"
+
+WORKDIR /app
+
+COPY --chown=user ./requirements.txt requirements.txt
+RUN pip install --no-cache-dir --upgrade -r requirements.txt
+
+COPY --chown=user . /app
+
+CMD ["streamlit", "run", "dashboard.py", "--server.port=7860", "--server.address=0.0.0.0"]

app.py

@@ -0,0 +1,7 @@
+from fastapi import FastAPI
+
+app = FastAPI()
+
+@app.get("/")
+def home():
+    return {"status": "FYP Dashboard Running"}

dashboard.py

@@ -0,0 +1,131 @@
+import streamlit as st
+import requests
+import json
+from datetime import datetime
+import time
+
+st.set_page_config(page_title="FYP Monitoring", layout="wide")
+
+st.title("🚀 Multi-Agent Knowledge System - Monitoring Dashboard")
+
+# Sidebar for controls
+st.sidebar.header("⚙️ Controls")
+if st.sidebar.checkbox("📊 Show Performance Charts"):
+    col1, col2 = st.columns(2)
+    
+    with col1:
+        # Latency chart
+        fig = go.Figure()
+        fig.add_trace(go.Indicator(
+            mode="gauge+number",
+            value=metrics.get('avg_latency_ms', 0),
+            title={'text': "Avg Latency (ms)"},
+            domain={'x': [0, 1], 'y': [0, 1]},
+            gauge={'axis': {'range': [0, 5000]},
+                   'bar': {'color': "darkblue"},
+                   'steps': [{'range': [0, 1000], 'color': "lightgray"}]}
+        ))
+        st.plotly_chart(fig, use_container_width=True)
+    
+    with col2:
+        # Confidence chart
+        fig = go.Figure()
+        fig.add_trace(go.Indicator(
+            mode="gauge+number",
+            value=metrics.get('avg_confidence', 0) * 100,
+            title={'text': "Avg Confidence (%)"},
+            domain={'x': [0, 1], 'y': [0, 1]},
+            gauge={'axis': {'range': [0, 100]},
+                   'bar': {'color': "darkgreen"},
+                   'steps': [{'range': [0, 70], 'color': "lightcoral"},
+                            {'range': [70, 100], 'color': "lightgreen"}]}
+        ))
+        st.plotly_chart(fig, use_container_width=True)
+
+# Metrics columns
+col1, col2, col3, col4 = st.columns(4)
+
+try:
+    # Get metrics from API
+    metrics = requests.get(f"{api_url}/metrics").json()
+    
+    with col1:
+        st.metric("Total Queries", metrics.get("total_queries", 0))
+    with col2:
+        st.metric("Avg Latency (ms)", f"{metrics.get('avg_latency_ms', 0):.0f}")
+    with col3:
+        st.metric("Avg Confidence", f"{metrics.get('avg_confidence', 0):.0%}")
+    with col4:
+        st.metric("Cache Hit Rate", f"{metrics.get('cache_hit_rate', 0):.0%}")
+        
+except Exception as e:
+    st.error(f"❌ Cannot connect to API: {e}")
+
+st.divider()
+
+# Query Testing Section
+st.header("🧪 Test Queries")
+
+query = st.text_input("Enter a query:", "What is FastAPI?")
+
+if st.button("Send Query"):
+    try:
+        with st.spinner("Processing..."):
+            response = requests.post(
+                f"{api_url}/query",
+                json={"query": query}
+            ).json()
+        
+        # Display results
+        st.success("✅ Query processed successfully!")
+        
+        col1, col2 = st.columns([2, 1])
+        
+        with col1:
+            st.subheader("📝 Answer")
+            st.write(response.get("answer", "No answer"))
+            
+        with col2:
+            st.subheader("📊 Metrics")
+            st.metric("Confidence", f"{response['validation']['confidence']}%")
+            st.metric("Processing Time", f"{response['processing_time']:.2f}s")
+            st.metric("Status", response['validation']['status'])
+        
+        st.subheader("📚 Sources")
+        for i, source in enumerate(response.get("sources", []), 1):
+            st.write(f"{i}. **{source['source']}** (Relevance: {source['relevance']:.0%})")
+            
+    except Exception as e:
+        st.error(f"❌ Error: {e}")
+
+st.divider()
+
+# Query History Section
+
+st.header("📜 Query History")
+
+if 'query_history' not in st.session_state:
+    st.session_state.query_history = []
+
+# Store query in history
+if st.button("Send Query"):
+    st.session_state.query_history.append({
+        'query': query,
+        'time': datetime.now().strftime("%H:%M:%S"),
+        'confidence': response['validation']['confidence']
+    })
+
+# Display history
+for item in reversed(st.session_state.query_history[-5:]):
+    st.write(f"🕐 {item['time']} | {item['query']} | Confidence: {item['confidence']}%")
+
+# Health Check
+st.header("🏥 System Health")
+
+try:
+    health = requests.get(f"{api_url}/health").json()
+    st.success(f"✅ API Status: {health.get('status', 'unknown')}")
+except:
+    st.error("❌ API is down")
+
+st.info("💡 Tip: Keep this dashboard open to monitor your system in real-time!")

requirements.txt

@@ -0,0 +1,10 @@
+fastapi
+uvicorn[standard]
+streamlit
+requests
+plotly
+sentence-transformers
+chromadb
+langchain
+groq
+python-dotenv