Added Hugging Face WebHook Trigger Compatibility

app.py

@@ -35,16 +35,18 @@ api_app = FastAPI(title="HackRx API", description="AI-powered document query sys
 @api_app.post("/hackrx/run")
 async def hackrx_run(
     request: Request,
-    authorization: str = Header(default=None)
+    authorization: Optional[str] = Header(default=None),
+    x_webhook_secret: Optional[str] = Header(default=None)
 ):
     try:
-        if not authorization:
-            return JSONResponse(status_code=401, content={"error": "Missing Authorization header"})
+        # ⚠️ You can optionally log headers for debugging
+        # print("Authorization:", authorization)
+        # print("Webhook secret:", x_webhook_secret)
 
-        # Optional: Validate the Bearer token if needed
-        # token_value = authorization.replace("Bearer ", "")
-        # if token_value != EXPECTED_TOKEN:
-        #     return JSONResponse(status_code=403, content={"error": "Invalid token"})
+        # 🔐 Optional: Validate at least one of them if needed
+        # Example if you want: 
+        # if not authorization and not x_webhook_secret:
+        #     return JSONResponse(status_code=401, content={"error": "Missing authentication"})
 
         data = await request.json()
         document_url = data.get("documents")
@@ -56,12 +58,12 @@ async def hackrx_run(
         if not isinstance(questions, list) or not all(isinstance(q, str) for q in questions):
             return JSONResponse(status_code=400, content={"error": "'questions' must be a list of strings"})
 
-        # Step 1: Process document
+        # ✅ Step 1: Process document
         doc_result = hackathon_system.process_document_efficiently(document_url)
         if not doc_result.get("success"):
-            return JSONResponse({"error": doc_result.get("error")}, status_code=500)
+            return JSONResponse(content={"error": doc_result.get("error")}, status_code=500)
 
-        # Step 2: Process questions
+        # ✅ Step 2: Answer questions
         batch_result = hackathon_system.process_batch_queries(questions)
         answers = batch_result.get("answers", [])