🚀 Deployment: Final fix for backend 500 error (resilient startup + folder entrypoint)

backend/app.py

@@ -1,50 +1,204 @@
 import os
 import sys
+import uuid
+import asyncio
+import httpx
 import traceback
+from datetime import datetime, timezone
+from typing import List, Optional
+
 from fastapi import FastAPI, Request
-from fastapi.responses import JSONResponse
+from fastapi.responses import JSONResponse, FileResponse
 from fastapi.middleware.cors import CORSMiddleware
 
-# Force current directory into path for local imports
-sys.path.append(os.path.dirname(__file__))
-
-# Global error capture for imports
-IMPORT_ERROR = None
+# Import agent pipeline logic
 try:
+    # Ensure current directory is in path for Vercel
+    sys.path.append(os.path.dirname(__file__))
     from agents import run_pipeline, AMD_INFERENCE_URL, AMD_MODEL_NAME, AMD_INFERENCE_TOKEN, generate_social_post
-except Exception as e:
-    IMPORT_ERROR = f"Import Error: {str(e)}\n{traceback.format_exc()}"
+except ImportError:
+    # Fallback if running from root
+    from backend.agents import run_pipeline, AMD_INFERENCE_URL, AMD_MODEL_NAME, AMD_INFERENCE_TOKEN, generate_social_post
+
+# ── CONFIGURATION ────────────────────────────────────────────────────────────
+
+MONGO_URL = os.environ.get("MONGO_URL") or os.environ.get("MONGODB_URI")
+# Global database references
+_db = None
+_inspections_col = None
+_journal_col = None
+
+# In-memory fallbacks
+_mem_inspections = []
+_mem_journal = []
+
+# ── APP INITIALIZATION ───────────────────────────────────────────────────────
 
-app = FastAPI(title="ForgeSight Debug API")
+app = FastAPI(title="ForgeSight Backend")
 
 app.add_middleware(
     CORSMiddleware,
     allow_origins=["*"],
+    allow_credentials=True,
     allow_methods=["*"],
     allow_headers=["*"],
 )
 
-@app.middleware("http")
-async def error_logging_middleware(request: Request, call_next):
-    if IMPORT_ERROR:
-        return JSONResponse({"status": "error", "message": IMPORT_ERROR}, status_code=500)
+async def _init_db():
+    """Attempt to connect to MongoDB; silently fall back to in-memory if unavailable."""
+    global _db, _inspections_col, _journal_col
+    if not MONGO_URL:
+        print("⚠️ MONGO_URL not set – using in-memory storage")
+        return
     try:
-        return await call_next(request)
+        from motor.motor_asyncio import AsyncIOMotorClient
+        import certifi
+        client = AsyncIOMotorClient(
+            MONGO_URL, 
+            serverSelectionTimeoutMS=5000,
+            tlsCAFile=certifi.where(),
+            tlsAllowInvalidCertificates=True
+        )
+        _db = client["forgesight"]
+        _inspections_col = _db["inspections"]
+        _journal_col = _db["journal"]
+        print("✅ MongoDB client initialized")
     except Exception as e:
-        return JSONResponse({
-            "status": "error",
-            "message": str(e),
-            "traceback": traceback.format_exc()
-        }, status_code=500)
+        print(f"⚠️  MongoDB unavailable ({e}) – using in-memory storage")
+
+async def _seed_journal():
+    """Seed the journal with initial milestones (instant, no LLM calls)."""
+    try:
+        existing = await _db_list_journal(1)
+        if existing: return
+    except: return
+
+    seeds = [
+        {"id": str(uuid.uuid4()), "type": "system", "content": "ForgeSight Backend initialized.", "created_at": datetime.now(timezone.utc).isoformat()},
+        {"id": str(uuid.uuid4()), "type": "checkpoint", "content": "AMD MI300X vLLM pipeline linked.", "created_at": datetime.now(timezone.utc).isoformat()},
+    ]
+    for s in seeds:
+        await _db_insert_journal(s)
+
+@app.on_event("startup")
+async def startup_event():
+    await _init_db()
+    await _seed_journal()
+
+# ── DATABASE HELPERS ────────────────────────────────────────────────────────
+
+async def _db_insert_inspection(data):
+    if _inspections_col is not None:
+        await _inspections_col.insert_one(data.copy())
+    else:
+        _mem_inspections.append(data)
+
+async def _db_list_inspections(limit=20):
+    if _inspections_col is not None:
+        cursor = _inspections_col.find({}, {"_id": 0}).sort("timestamp", -1).limit(limit)
+        return await cursor.to_list(length=limit)
+    return sorted(_mem_inspections, key=lambda x: x.get("timestamp", ""), reverse=True)[:limit]
+
+async def _db_insert_journal(data):
+    if _journal_col is not None:
+        await _journal_col.insert_one(data.copy())
+    else:
+        _mem_journal.append(data)
+
+async def _db_list_journal(limit=50):
+    if _journal_col is not None:
+        cursor = _journal_col.find({}, {"_id": 0}).sort("created_at", -1).limit(limit)
+        return await cursor.to_list(length=limit)
+    return sorted(_mem_journal, key=lambda x: x.get("created_at", ""), reverse=True)[:limit]
+
+# ─�� API ENDPOINTS ───────────────────────────────────────────────────────────
 
 @app.get("/api/health")
-@app.get("/_/backend/api/health")
+@app.get("/health")
 async def health():
-    return {"status": "online", "debug": True, "cwd": os.getcwd(), "path": sys.path}
+    return {
+        "status": "online", 
+        "service": "forgesight", 
+        "db": "mongodb" if _inspections_col is not None else "memory",
+        "timestamp": datetime.now(timezone.utc).isoformat()
+    }
 
 @app.get("/api/inspections")
-@app.get("/_/backend/api/inspections")
-async def list_inspections():
-    return {"items": [], "total": 0, "note": "Debug mode"}
+async def get_inspections():
+    items = await _db_list_inspections()
+    return items
+
+@app.get("/api/journal")
+async def get_journal():
+    items = await _db_list_journal()
+    return items
+
+@app.post("/api/inspect")
+async def handle_inspect(request: Request):
+    """Triggers the full multi-agent QC pipeline."""
+    try:
+        body = await request.json()
+        image_url = body.get("image_url")
+        if not image_url:
+            return JSONResponse({"error": "image_url is required"}, status_code=400)
+        
+        # Add a journal entry for the start
+        await _db_insert_journal({
+            "id": str(uuid.uuid4()),
+            "type": "process",
+            "content": f"Starting multimodal inspection for image: {image_url[:40]}...",
+            "created_at": datetime.now(timezone.utc).isoformat()
+        })
+
+        # Run pipeline
+        result = await run_pipeline(image_url)
+        
+        # Save to DB
+        inspection_data = {
+            "id": result.get("id", str(uuid.uuid4())),
+            "timestamp": datetime.now(timezone.utc).isoformat(),
+            "image_url": image_url,
+            "status": result.get("status", "COMPLETED"),
+            "score": result.get("score", 0),
+            "findings": result.get("findings", []),
+            "agents": result.get("agents", {}),
+            "report_url": result.get("report_url", "")
+        }
+        await _db_insert_inspection(inspection_data)
+
+        # Generate social post
+        try:
+            social = await generate_social_post(inspection_data)
+            inspection_data["social"] = social
+        except:
+            inspection_data["social"] = "Social generation unavailable."
+
+        return inspection_data
+    except Exception as e:
+        return JSONResponse({"error": str(e), "traceback": traceback.format_exc()}, status_code=500)
+
+@app.get("/api/metrics")
+async def get_metrics():
+    """Returns system-wide metrics for the dashboard."""
+    inspections = await _db_list_inspections(100)
+    total = len(inspections)
+    if total == 0:
+        return {"avg_score": 0, "total_inspections": 0, "status_distribution": {}}
+    
+    avg_score = sum(i.get("score", 0) for i in inspections) / total
+    dist = {}
+    for i in inspections:
+        s = i.get("status", "UNKNOWN")
+        dist[s] = dist.get(s, 0) + 1
+        
+    return {
+        "avg_score": round(avg_score, 2),
+        "total_inspections": total,
+        "status_distribution": dist,
+        "system_load": "nominal"
+    }
 
-# ... other minimal routes to avoid crashes ...
+if __name__ == "__main__":
+    import uvicorn
+    import traceback
+    uvicorn.run(app, host="0.0.0.0", port=7860)

vercel.json

@@ -6,7 +6,7 @@
             "framework": "create-react-app"
         },
         "backend": {
-            "entrypoint": "backend/app.py",
+            "entrypoint": "backend",
             "routePrefix": "/_/backend",
             "framework": "python"
         }