Deploy Sentinel AI with service fixes

.gitattributes

@@ -17,4 +17,6 @@
 *.safetensors filter=lfs diff=lfs merge=lfs -text
 *.tar filter=lfs diff=lfs merge=lfs -text
 *.zip filter=lfs diff=lfs merge=lfs -text
-*.png filter=lfs diff=lfs merge=lfs -text
+assets/logo.png filter=lfs diff=lfs merge=lfs -text
+assets/sentinel_logo.png filter=lfs diff=lfs merge=lfs -text
+logo.png filter=lfs diff=lfs merge=lfs -text

Dockerfile

@@ -9,21 +9,26 @@ RUN apt-get update && apt-get install -y \
 
 # Create non-root user (required by HF Spaces)
 RUN useradd -m -u 1000 user
-ENV HOME=/home/user \
-    PATH="/home/user/.local/bin:$PATH"
 
 WORKDIR /app
 
-# Copy requirements first to leverage Docker cache
-COPY --chown=user requirements.txt .
+# Copy and install requirements as root (system-wide)
+COPY requirements.txt .
 RUN pip install --no-cache-dir -r requirements.txt
 
 # Copy the entire application
-COPY --chown=user . .
+COPY . .
+
+# Make the app directory writable by user (for SQLite DB, logs, JSON files)
+RUN chown -R user:user /app
 
 # Switch to non-root user
 USER user
 
+ENV HOME=/home/user \
+    PATH="/home/user/.local/bin:$PATH" \
+    PYTHONUNBUFFERED=1
+
 # Expose the port Hugging Face expects
 EXPOSE 7860
 

app.py

@@ -43,7 +43,7 @@ def start_background_services():
 start_background_services()
 
 # --- Helper Functions ---
-@st.cache_data(ttl=60)
+@st.cache_data(ttl=30)
 def check_server_status():
     # All services are mounted as sub-apps under the gateway on port 8000
     urls = {
@@ -53,12 +53,17 @@ def check_server_status():
         "Private DB": "http://127.0.0.1:8000/private/",
     }
     statuses = {}
-    with httpx.Client(timeout=3.0) as client:
-        for name, url in urls.items():
-            try:
-                response = client.get(url)
-                statuses[name] = "✅ Online" if response.status_code == 200 else "⚠️ Error"
-            except: statuses[name] = "❌ Offline"
+    try:
+        with httpx.Client(timeout=5.0) as client:
+            for name, url in urls.items():
+                try:
+                    response = client.get(url)
+                    statuses[name] = "✅ Online" if response.status_code == 200 else "⚠️ Error"
+                except:
+                    statuses[name] = "❌ Offline"
+    except Exception:
+        for name in urls:
+            statuses[name] = "❌ Offline"
     return statuses
 
 def load_watchlist():
@@ -345,8 +350,9 @@ def render_analysis():
             all_online = all(s == "✅ Online" for s in server_statuses.values())
             
             if not all_online:
-                st.error("SYSTEM HALTED: Core services offline. Check sidebar status.")
-            else:
+                st.warning("⚠️ Some core services are still starting up. Analysis may have limited data. Proceeding anyway...")
+            
+            if True:  # Always allow analysis to proceed
                 with st.status("🚀 SENTINEL ORCHESTRATOR ENGAGED...", expanded=True) as status:
                     try:
                         from agents.orchestrator_v3 import get_orchestrator

main.py

@@ -3,38 +3,61 @@ import sys
 import os
 import time
 import signal
+import httpx
 
 def cleanup(signum, frame):
-    print("Stopping services...")
-    # Add cleanup logic here if needed
+    print("Stopping services...", flush=True)
     sys.exit(0)
 
 signal.signal(signal.SIGINT, cleanup)
 signal.signal(signal.SIGTERM, cleanup)
 
+def wait_for_gateway(url="http://127.0.0.1:8000/", timeout=60, interval=2):
+    """Wait until the MCP Gateway is responding before starting Streamlit."""
+    print(f"⏳ Waiting for Gateway at {url} (timeout={timeout}s)...", flush=True)
+    start = time.time()
+    while time.time() - start < timeout:
+        try:
+            resp = httpx.get(url, timeout=3.0)
+            if resp.status_code == 200:
+                print("✅ Gateway is healthy!", flush=True)
+                return True
+        except Exception:
+            pass
+        time.sleep(interval)
+    print("⚠️  Gateway did not respond in time. Starting Streamlit anyway...", flush=True)
+    return False
+
 def main():
-    print("🚀 Starting Sentinel Monolith...")
+    print("🚀 Starting Sentinel Monolith...", flush=True)
     
     # 1. Start the MCP Gateway (which now includes all microservices)
-    # running on port 8000
     gateway_cmd = [sys.executable, "mcp_gateway.py"]
-    gateway_process = subprocess.Popen(gateway_cmd, cwd=os.getcwd())
-    print(f"✅ Gateway started (PID: {gateway_process.pid})")
+    gateway_process = subprocess.Popen(
+        gateway_cmd,
+        cwd=os.getcwd(),
+        stdout=sys.stdout,
+        stderr=sys.stderr,
+    )
+    print(f"✅ Gateway started (PID: {gateway_process.pid})", flush=True)
     
     # 2. Start the Monitor (runs in background loop)
-    # Using the same interpreter
     monitor_cmd = [sys.executable, "monitor.py"]
-    monitor_process = subprocess.Popen(monitor_cmd, cwd=os.getcwd())
-    print(f"✅ Monitor started (PID: {monitor_process.pid})")
+    monitor_process = subprocess.Popen(
+        monitor_cmd,
+        cwd=os.getcwd(),
+        stdout=sys.stdout,
+        stderr=sys.stderr,
+    )
+    print(f"✅ Monitor started (PID: {monitor_process.pid})", flush=True)
 
-    # Give backend a moment to initialize
-    time.sleep(5)
+    # 3. Wait for gateway to be healthy before starting Streamlit
+    wait_for_gateway()
     
-    # 3. Start Streamlit (Frontend)
-    # This commands blocks until Streamlit exits
-    print("✅ Starting Streamlit on port 7860...")
+    # 4. Start Streamlit (Frontend)
+    print("✅ Starting Streamlit on port 7860...", flush=True)
     streamlit_cmd = [
-        "streamlit", "run", "app.py",
+        sys.executable, "-m", "streamlit", "run", "app.py",
         "--server.port", "7860",
         "--server.address", "0.0.0.0",
         "--server.headless", "true",