Restructure to create FastAPI app first, then mount Gradio

- Create FastAPI app and add webhook routes FIRST
- Then create Gradio interface
- Mount Gradio on FastAPI using gr.mount_gradio_app()
- This ensures webhook routes have priority over Gradio routes
- Add uvicorn and fastapi back to requirements

Co-Authored-By: Claude Sonnet 4.5 <noreply@anthropic.com>

app.py

@@ -1,5 +1,5 @@
 import gradio as gr
-from fastapi import Request, HTTPException
+from fastapi import FastAPI, Request, HTTPException
 from fastapi.responses import JSONResponse
 import os
 import json
@@ -108,6 +108,65 @@ def process_webhook(payload: dict, event_type: str):
     return True
 
 
+# Create FastAPI app first
+app = FastAPI()
+
+
+# Add webhook endpoints BEFORE mounting Gradio
+@app.post("/webhooks/hub")
+async def webhook_endpoint(request: Request):
+    """
+    Webhook endpoint for HuggingFace Hub events.
+
+    Supports all webhook events documented at:
+    https://huggingface.co/docs/hub/webhooks
+    """
+    try:
+        # Get the event type from headers
+        event_type = request.headers.get("X-Event-Type", "unknown")
+
+        # Parse JSON payload
+        payload = await request.json()
+
+        # Process the webhook
+        processed = process_webhook(payload, event_type)
+
+        if processed:
+            return JSONResponse(
+                content={
+                    "status": "success",
+                    "message": "Webhook received and queued",
+                    "scope": payload.get("event", {}).get("scope")
+                },
+                status_code=200
+            )
+        else:
+            return JSONResponse(
+                content={
+                    "status": "ignored",
+                    "message": "Webhook scope not in allowed list",
+                    "scope": payload.get("event", {}).get("scope")
+                },
+                status_code=200
+            )
+
+    except Exception as e:
+        print(f"Error processing webhook: {str(e)}")
+        raise HTTPException(status_code=500, detail=str(e))
+
+
+@app.get("/webhooks/health")
+async def health_check():
+    """Health check endpoint."""
+    with message_lock:
+        return {
+            "status": "healthy",
+            "messages_in_memory": len(webhook_messages),
+            "batches_saved": batch_counter,
+            "allowed_scopes": list(ALLOWED_SCOPES)
+        }
+
+
 # Create Gradio interface
 with gr.Blocks(title="HuggingFace Webhook Processor") as demo:
     gr.Markdown("""
@@ -215,65 +274,12 @@ with gr.Blocks(title="HuggingFace Webhook Processor") as demo:
         outputs=[status_text, message_count, batch_count, latest_batch]
     )
 
-# Get the FastAPI app instance
-app = demo.app
-
-
-# Add webhook endpoints to FastAPI app
-@app.post("/webhooks/hub")
-async def webhook_endpoint(request: Request):
-    """
-    Webhook endpoint for HuggingFace Hub events.
-
-    Supports all webhook events documented at:
-    https://huggingface.co/docs/hub/webhooks
-    """
-    try:
-        # Get the event type from headers
-        event_type = request.headers.get("X-Event-Type", "unknown")
-
-        # Parse JSON payload
-        payload = await request.json()
-
-        # Process the webhook
-        processed = process_webhook(payload, event_type)
-
-        if processed:
-            return JSONResponse(
-                content={
-                    "status": "success",
-                    "message": "Webhook received and queued",
-                    "scope": payload.get("event", {}).get("scope")
-                },
-                status_code=200
-            )
-        else:
-            return JSONResponse(
-                content={
-                    "status": "ignored",
-                    "message": "Webhook scope not in allowed list",
-                    "scope": payload.get("event", {}).get("scope")
-                },
-                status_code=200
-            )
-
-    except Exception as e:
-        print(f"Error processing webhook: {str(e)}")
-        raise HTTPException(status_code=500, detail=str(e))
 
-
-@app.get("/webhooks/health")
-async def health_check():
-    """Health check endpoint."""
-    with message_lock:
-        return {
-            "status": "healthy",
-            "messages_in_memory": len(webhook_messages),
-            "batches_saved": batch_counter,
-            "allowed_scopes": list(ALLOWED_SCOPES)
-        }
+# Mount Gradio on our FastAPI app
+app = gr.mount_gradio_app(app, demo, path="/")
 
 
-# Launch the Gradio app
+# Launch the app
 if __name__ == "__main__":
-    demo.queue().launch(server_name="0.0.0.0", server_port=7860)
+    import uvicorn
+    uvicorn.run(app, host="0.0.0.0", port=7860)

requirements.txt

@@ -3,3 +3,5 @@ huggingface-hub
 datasets
 pandas
 pyarrow
+uvicorn
+fastapi