Update app.py

app.py

@@ -6,14 +6,13 @@ 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()
 
 app.mount("/static", StaticFiles(directory="static"), name="static")
 
-
 TEMP_DIR = "./temp_files"
 OUTPUT_DIR = "./static/outputs"
 
@@ -23,6 +22,8 @@ os.makedirs(OUTPUT_DIR, exist_ok=True)
 VALID_EXTENSIONS = ('.wav', '.mp3', '.m4a', '.flac')
 MAX_FILE_SIZE_MB = 300
 
+BASE_URL = os.getenv("BASE_URL", "http://localhost:7860/static/outputs")
+
 class ProcessResponse(BaseModel):
     summary: str
     json_url: str
@@ -36,15 +37,15 @@ async def root():
 async def process_audio(file_url: str = Query(..., description="URL of the audio file"),
                         user_id: str = Query(..., description="User ID")):
     try:
-        # تحميل الملف مؤقتًا
+        # التحقق من امتداد الملف
         file_ext = os.path.splitext(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)
         if resp.status_code != 200:
             raise HTTPException(status_code=400, detail="Could not download the file from URL")
@@ -54,23 +55,22 @@ 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")
 
-        # معالجة الملف (process_interview ترجع dict فيها json_path و pdf_path)
+        # استدعاء دالة المعالجة
         result = process_interview(local_path)
         if not result:
             os.remove(local_path)
             raise HTTPException(status_code=500, detail="Processing failed")
 
-        # نسخ ملفات JSON و PDF لمجلد ثابت للاحتفاظ بهم
+        # نسخ ملفات json و pdf للمجلد النهائي
         json_src = result['json_path']
         pdf_src = result['pdf_path']
 
-        # أسماء جديدة مع UUID
         json_dest_name = f"{user_id}_{uuid.uuid4().hex}.json"
         pdf_dest_name = f"{user_id}_{uuid.uuid4().hex}.pdf"
 
@@ -80,7 +80,7 @@ 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 للملخص
+        # قراءة بيانات JSON لتحضير الملخص
         with open(json_src, "r") as jf:
             analysis_data = json.load(jf)
 
@@ -96,12 +96,11 @@ async def process_audio(file_url: str = Query(..., description="URL of the audio
             f"Anxiety: {voice.get('anxiety_level', 'N/A')}"
         )
 
-        # بناء URLs للملفات
-        base_url = f"http://localhost:7860/static/outputs"
-        json_url = f"{base_url}/{json_dest_name}"
-        pdf_url = f"{base_url}/{pdf_dest_name}"
+        # بناء روابط الملفات التي ستُعاد
+        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)