Update app.py

app.py

@@ -14,6 +14,7 @@ import re
 import signal
 from starlette.middleware import Middleware
 from starlette.middleware.base import BaseHTTPMiddleware
+from pydantic import BaseModel  
 
 # Setup logging
 logging.basicConfig(
@@ -37,7 +38,11 @@ class LoggingMiddleware(BaseHTTPMiddleware):
         response = await call_next(request)
         logger.info(f"Response status: {response.status_code}")
         return response
-
+        
+class AudioRequest(BaseModel):
+    audio_url: str
+    user_id: str
+    
 # Initialize FastAPI app with lifecycle hooks
 app = FastAPI(
     title="EvalBot Interview Analysis API",
@@ -241,24 +246,27 @@ async def analyze_multiple_audios(files: List[UploadFile] = File(...)):
         logger.error(f"Error in analyze_multiple_audios: {e}")
         raise HTTPException(status_code=500, detail=str(e))
 
-@app.post("/analyze_audio_url/")
-async def analyze_audio_url(audio_url: str = Form(...), user_id: str = Form(...)):
-    """Analyze a single audio file from a URL with user_id."""
+
+
+# الـ endpoint الجديد لدعم JSON
+@app.post("/analyze_audio_url_json/")
+async def analyze_audio_url_json(request: AudioRequest):
+    """Analyze a single audio file from a URL with user_id using JSON body."""
     try:
         # Validate user_id (alphanumeric, underscores, hyphens)
-        if not re.match(r'^[a-zA-Z0-9_-]+$', user_id):
+        if not re.match(r'^[a-zA-Z0-9_-]+$', request.user_id):
             raise HTTPException(status_code=400, detail="Invalid user_id. Use alphanumeric characters, underscores, or hyphens.")
 
         # Create temporary directory
         temp_dir = tempfile.mkdtemp()
         
         # Download audio file
-        file_path = download_audio(audio_url, temp_dir)
+        file_path = download_audio(request.audio_url, temp_dir)
         
         # Process audio
-        result = process_single_audio(file_path, user_id)
+        result = process_single_audio(file_path, request.user_id)
         
-        # Clean up temporary file
+        # Clean up temporary directory
         shutil.rmtree(temp_dir, ignore_errors=True)
         
         if "error" in result:
@@ -270,12 +278,16 @@ async def analyze_audio_url(audio_url: str = Form(...), user_id: str = Form(...)
             "summary": result["summary"],
             "json_data": result["json_data"],
             "pdf_url": f"/download_pdf/{os.path.basename(pdf_path)}",
-            "user_id": user_id
+            "user_id": request.user_id
         }
     except Exception as e:
-        logger.error(f"Error in analyze_audio_url: {e}")
+        logger.error(f"Error in analyze_audio_url_json: {e}")
         raise HTTPException(status_code=500, detail=str(e))
 
+
+
+
+
 @app.get("/download_pdf/{pdf_filename}")
 async def download_pdf(pdf_filename: str):
     """Download a generated PDF report."""