Update app.py

app.py

@@ -1,12 +1,11 @@
+from fastapi import FastAPI, HTTPException, Body
+from pydantic import BaseModel, HttpUrl
 import os
 import uuid
 import shutil
 import json
-from fastapi import FastAPI, HTTPException, Query
-from fastapi.responses import JSONResponse, FileResponse
-from pydantic import BaseModel
 import requests
-from process_interview import process_interview  # لازم يكون ملفك موجود فيه الدالة دي
+from process_interview import process_interview
 from fastapi.staticfiles import StaticFiles
 
 app = FastAPI()
@@ -29,24 +28,23 @@ class ProcessResponse(BaseModel):
     json_url: str
     pdf_url: str
 
-@app.get("/")
-async def root():
-    return {"message": "EvalBot API is running"}
+class ProcessAudioRequest(BaseModel):
+    file_url: HttpUrl
+    user_id: str
 
 @app.post("/process-audio", response_model=ProcessResponse)
-async def process_audio(file_url: str = Query(..., description="URL of the audio file"),
-                        user_id: str = Query(..., description="User ID")):
+async def process_audio(request: ProcessAudioRequest = Body(...)):
+    file_url = request.file_url
+    user_id = request.user_id
     try:
-        # التحقق من امتداد الملف
-        file_ext = os.path.splitext(file_url)[1].lower()
+        file_ext = os.path.splitext(str(file_url))[1].lower()
         if file_ext not in VALID_EXTENSIONS:
             raise HTTPException(status_code=400, detail=f"Invalid file extension: {file_ext}")
 
-        # تنزيل الملف مؤقتًا
         local_filename = f"{user_id}_{uuid.uuid4().hex}{file_ext}"
         local_path = os.path.join(TEMP_DIR, local_filename)
 
-        resp = requests.get(file_url, stream=True, timeout=30)
+        resp = requests.get(str(file_url), stream=True, timeout=30)
         if resp.status_code != 200:
             raise HTTPException(status_code=400, detail="Could not download the file from URL")
 
@@ -55,19 +53,16 @@ async def process_audio(file_url: str = Query(..., description="URL of the audio
                 if chunk:
                     f.write(chunk)
 
-        # التحقق من حجم الملف
         file_size_mb = os.path.getsize(local_path) / (1024 * 1024)
         if file_size_mb > MAX_FILE_SIZE_MB:
             os.remove(local_path)
             raise HTTPException(status_code=400, detail=f"File too large: {file_size_mb:.2f} MB")
 
-        # استدعاء دالة المعالجة
         result = process_interview(local_path)
         if not result:
             os.remove(local_path)
             raise HTTPException(status_code=500, detail="Processing failed")
 
-        # نسخ ملفات json و pdf للمجلد النهائي
         json_src = result['json_path']
         pdf_src = result['pdf_path']
 
@@ -80,7 +75,6 @@ async def process_audio(file_url: str = Query(..., description="URL of the audio
         shutil.copyfile(json_src, json_dest)
         shutil.copyfile(pdf_src, pdf_dest)
 
-        # قراءة بيانات JSON لتحضير الملخص
         with open(json_src, "r") as jf:
             analysis_data = json.load(jf)
 
@@ -96,11 +90,9 @@ async def process_audio(file_url: str = Query(..., description="URL of the audio
             f"Anxiety: {voice.get('anxiety_level', 'N/A')}"
         )
 
-        # بناء روابط الملفات التي ستُعاد
         json_url = f"{BASE_URL}/{json_dest_name}"
         pdf_url = f"{BASE_URL}/{pdf_dest_name}"
 
-        # حذف الملف الصوتي المؤقت
         os.remove(local_path)
 
         return ProcessResponse(summary=summary, json_url=json_url, pdf_url=pdf_url)