Added validation table endpoint

app.py

@@ -32,6 +32,7 @@ if not SUPABASE_URL or not SUPABASE_KEY:
     raise ValueError("Supabase credentials not found.")
 supabase: Client = create_client(SUPABASE_URL, SUPABASE_KEY)
 
+# --- Helper Functions ---
 def convert_to_decimal(coord):
     if coord and len(coord.values) >= 3:
         deg = float(coord.values[0])
@@ -88,10 +89,6 @@ def process_video_in_background(video_data: bytes, video_guid: str, filename: st
     os.remove(temp_path)
     supabase.table("videos").update({"status": "complete"}).eq("guid", video_guid).execute()
 
-@app.get("/")
-async def root():
-    return {"message": "API is running"}
-
 def safe_date_converter(date_string):
     if not date_string:
         return datetime.min.replace(tzinfo=timezone.utc)
@@ -103,6 +100,34 @@ def safe_date_converter(date_string):
     except (ValueError, TypeError):
         return datetime.min.replace(tzinfo=timezone.utc)
 
+# --- API Endpoints ---
+@app.get("/")
+async def root():
+    return {"message": "API is running"}
+
+@app.get("/report_summary")
+async def get_report_summary():
+    try:
+        reports_response = supabase.table("potholes").select("category, approved").execute()
+        all_reports = reports_response.data
+        summary = {
+            "billboard": {"total": 0, "approved": 0, "unapproved": 0, "damage": 0},
+            "guardrails": {"total": 0, "missing": 0, "damaged": 0},
+            "construction": {"total": 0},
+            "potholes": {"total": 0}
+        }
+        for report in all_reports:
+            category = report.get("category")
+            is_approved = report.get("approved")
+            if category in summary:
+                summary[category]["total"] += 1
+                if is_approved == 1:
+                    summary[category]["approved"] += 1
+                summary[category]["unapproved"] = summary[category]["total"] - summary[category]["approved"]
+        return summary
+    except Exception as e:
+        raise HTTPException(status_code=500, detail=f"Database error: {str(e)}")
+
 @app.get("/latest_reports")
 async def get_latest_reports():
     try:
@@ -112,19 +137,65 @@ async def get_latest_reports():
             video['type'] = 'video'
             first_frame_response = supabase.table("detected_frames").select("frame_image_url").eq("video_guid", video["guid"]).order("frame_number").limit(1).execute()
             video["thumbnail_url"] = first_frame_response.data[0]["frame_image_url"] if first_frame_response.data else None
-
         images_response = supabase.table("potholes").select("guid, image_name, image_url, created_at, status, category").order("created_at", desc=True).limit(30).execute()
         images = images_response.data
         for image in images:
             image['type'] = 'image'
             image['thumbnail_url'] = image.get('image_url') 
-
         all_reports = videos + images
         combined_reports = sorted(all_reports, key=lambda x: safe_date_converter(x.get('created_at')), reverse=True)
         return combined_reports[:30]
     except Exception as e:
         raise HTTPException(status_code=500, detail=f"A severe database error occurred: {str(e)}")
 
+@app.post("/upload")
+async def upload_image(
+    file: UploadFile = File(...), 
+    location: str = Form(None),
+    category: str = Form(...)
+):
+    image_data = await file.read()
+    with tempfile.NamedTemporaryFile(delete=False, suffix=".jpg") as temp_image_file:
+        temp_image_file.write(image_data)
+        temp_path = temp_image_file.name
+    results = model(temp_path, device='cpu')
+    annotated_image_array = results[0].plot()
+    os.remove(temp_path)
+    is_success, buffer = cv2.imencode(".jpg", annotated_image_array)
+    if not is_success: raise HTTPException(status_code=500, detail="Failed to encode annotated image.")
+    annotated_image_bytes = buffer.tobytes()
+    bucket_name = 'pothole-images'
+    uuid_path = f"annotated_{uuid.uuid4()}.jpg"
+    try:
+        supabase.storage.from_(bucket_name).upload(path=uuid_path, file=annotated_image_bytes, file_options={"content-type": "image/jpeg"})
+        url = supabase.storage.from_(bucket_name).get_public_url(uuid_path)
+    except Exception as e: raise HTTPException(status_code=500, detail=f"Storage Error: {str(e)}")
+    
+    await file.seek(0)
+    lat, lon = get_gps_location(file.file)
+    location_point = f"Point({lon:.6f} {lat:.6f})" if lat and lon else None
+    guid = str(uuid.uuid4())
+    
+    try:
+        validation_response = supabase.table("validation").select("location_text").execute()
+        approved_locations = {item['location_text'] for item in validation_response.data}
+        is_approved = 1 if location in approved_locations else 0
+        insert_data = {
+            "guid": guid, 
+            "image_name": file.filename, 
+            "image_url": url, 
+            "location": location_point, 
+            "location_text": location if not location_point and location else None, 
+            "status": "In Progress",
+            "category": category,
+            "approved": is_approved
+        }
+        response = supabase.table("potholes").insert(insert_data).execute()
+    except Exception as e:
+        raise HTTPException(status_code=500, detail=f"Database Error: {str(e)}")
+        
+    return {"message": "Upload successful", "guid": guid, "image_url": url, "db_response": response.data}
+
 @app.patch("/report/{guid}/status")
 async def update_report_status(guid: str, payload: dict = Body(...)):
     new_status = payload.get("status")
@@ -205,49 +276,5 @@ async def get_report(guid: str):
         return response.data
     except Exception as e: raise HTTPException(status_code=500, detail=f"Database Error: {str(e)}")
 
-@app.post("/upload")
-async def upload_image(
-    file: UploadFile = File(...), 
-    location: str = Form(None),
-    category: str = Form(...)
-):
-    image_data = await file.read()
-    with tempfile.NamedTemporaryFile(delete=False, suffix=".jpg") as temp_image_file:
-        temp_image_file.write(image_data)
-        temp_path = temp_image_file.name
-    results = model(temp_path, device='cpu')
-    annotated_image_array = results[0].plot()
-    os.remove(temp_path)
-    is_success, buffer = cv2.imencode(".jpg", annotated_image_array)
-    if not is_success: raise HTTPException(status_code=500, detail="Failed to encode annotated image.")
-    annotated_image_bytes = buffer.tobytes()
-    bucket_name = 'pothole-images'
-    uuid_path = f"annotated_{uuid.uuid4()}.jpg"
-    try:
-        supabase.storage.from_(bucket_name).upload(path=uuid_path, file=annotated_image_bytes, file_options={"content-type": "image/jpeg"})
-        url = supabase.storage.from_(bucket_name).get_public_url(uuid_path)
-    except Exception as e: raise HTTPException(status_code=500, detail=f"Storage Error: {str(e)}")
-    
-    await file.seek(0)
-    lat, lon = get_gps_location(file.file)
-    location_point = f"Point({lon:.6f} {lat:.6f})" if lat and lon else None
-    guid = str(uuid.uuid4())
-    
-    try:
-        insert_data = {
-            "guid": guid, 
-            "image_name": file.filename, 
-            "image_url": url, 
-            "location": location_point, 
-            "location_text": location if not location_point and location else None, 
-            "status": "In Progress",
-            "category": category
-        }
-        response = supabase.table("potholes").insert(insert_data).execute()
-    except Exception as e:
-        raise HTTPException(status_code=500, detail=f"Database Error: {str(e)}")
-        
-    return {"message": "Upload successful", "guid": guid, "image_url": url, "db_response": response.data}
-
 if __name__ == "__main__":
     uvicorn.run(app, port=8000, host="127.0.0.1")