Sync GitHub commit 440dace robustness fix

main.py

@@ -6,8 +6,8 @@ import os
 import uuid
 import time
 import asyncio
-from typing import Dict, Optional, List
-from fastapi import FastAPI, UploadFile, File, HTTPException, Depends, Header, Body
+from typing import Dict, Optional
+from fastapi import FastAPI, UploadFile, File, HTTPException, Depends, Header
 from fastapi.staticfiles import StaticFiles
 from fastapi.responses import FileResponse, JSONResponse
 from fastapi.middleware.cors import CORSMiddleware
@@ -125,9 +125,6 @@ async def get_api_key(
     authorization: Optional[str] = Header(None, alias="Authorization"),
 ) -> str:
     """Validate incoming API key from header or bearer auth."""
-    if not config.REQUIRE_API_KEY:
-        return "public"
-
     token = x_api_key
     if authorization:
         bearer_prefix = "Bearer "
@@ -293,38 +290,16 @@ async def synchronous_extract(
     file: Optional[UploadFile] = File(None),
     document: Optional[UploadFile] = File(None),
     upload: Optional[UploadFile] = File(None),
-    files: Optional[List[UploadFile]] = File(None),
-    data: Optional[Dict[str, str]] = Body(None),
 ):
     """
     Synchronous extraction endpoint for API testers and bots.
-    Directly returns the extraction results.
+    Supports multple field names for maximum compatibility (file, document, upload).
     """
-    # 1. Resolve the input source (supports common bot field names)
+    # 1. Selection
     selected_file = file or document or upload
-    if not selected_file and files:
-        selected_file = files[0]
-
-    # URL payload fallback for bots that send JSON to this endpoint.
-    if not selected_file and data and data.get("url"):
-        url = data.get("url", "")
-        if not url.startswith(("http://", "https://")):
-            raise HTTPException(status_code=400, detail="Invalid URL format. Must start with http:// or https://")
-
-        file_id = f"sync_{str(uuid.uuid4())[:8]}"
-        filename = url.split('/')[2] if '//' in url else url.split('/')[0]
-        task = ProcessingResult.create_pending(file_id=file_id, filename=filename, file_type="url")
-        start_time = time.time()
-        await asyncio.get_event_loop().run_in_executor(
-            None, _perform_extraction_and_analysis, task, url, "url", start_time
-        )
-        if task.status == TaskStatus.ERROR:
-            raise HTTPException(status_code=500, detail=task.error_message or "Processing failed.")
-        return task
-
     if not selected_file:
         raise HTTPException(
-            status_code=400,
+            status_code=400, 
             detail="No input provided. Send multipart file field 'file' (or 'document'/'upload') or JSON with {'url': 'https://...'}"
         )
 
@@ -352,10 +327,10 @@ async def synchronous_extract(
     
     # Create the result object
     task = ProcessingResult.create_pending(file_id=file_id, filename=filename, file_type=file_type)
+    # Explicitly set CamelCase for tester
+    task.fileName = filename
     
-    # Run processing synchronously in the current thread (it's okay here because it's a dedicated sync endpoint)
-    # Actually, to be safe with FastAPI's async loop, we should run it in a thread still, 
-    # but await its completion.
+    # Run processing synchronously in the current thread
     await asyncio.get_event_loop().run_in_executor(
         None, _perform_extraction_and_analysis, task, file_path, file_type, start_time
     )