Update main.py

main.py

@@ -407,20 +407,26 @@ def policy_windows():
 
 @app.get("/api/leads")
 @with_db_retry
-def get_leads():  # Changed function name to avoid conflicts
+def get_leads():
     limit = max(1, min(int(request.args.get("limit", 50)), 200))
     min_score = float(request.args.get("min_score", 0))
     source = request.args.get("source")
+    
+    # CORRECTED SQL: Join flagged_leads with objects table to filter on image_url
     sql = (
-        "SELECT object_id, source, title, creator, risk_score, top_signals "
-        "FROM flagged_leads WHERE risk_score >= %s AND image_url IS NOT NULL AND image_url != '' "
+        "SELECT fl.object_id, fl.source, fl.title, fl.creator, fl.risk_score, fl.top_signals "
+        "FROM flagged_leads fl "
+        "JOIN objects o ON fl.object_id = o.object_id "
+        "WHERE fl.risk_score >= %s AND o.image_url IS NOT NULL AND o.image_url != '' "
     )
     args = [min_score]
     if source:
-        sql += " AND source = %s "
+        sql += " AND fl.source = %s "
         args.append(source)
-    sql += " LIMIT %s"
+    
+    sql += " ORDER BY fl.risk_score DESC LIMIT %s"
     args.append(limit)
+    
     with cursor() as cur:
         cur.execute(sql, args)
         rows = cur.fetchall()