Update app.py

app.py

@@ -1,10 +1,9 @@
 import logging
 import os
 from fastapi import FastAPI, HTTPException
-from fastapi.responses import FileResponse # --- NEW IMPORT ---
+from fastapi.responses import FileResponse
 from pydantic import BaseModel, HttpUrl
-from typing import List, Dict
-from concurrent.futures import ThreadPoolExecutor
+from typing import Dict
 from process_interview import process_interview
 
 logging.basicConfig(
@@ -14,29 +13,26 @@ logger = logging.getLogger(__name__)
 
 app = FastAPI(
     title="EvalBot API",
-    description="API to analyze audio interviews.",
+    description="API to analyze a single audio interview URL.",
     version="1.0.0"
 )
 
-# --- The directory where output files are stored ---
+# Directory where output files are stored
 OUTPUT_DIR = "./processed_audio"
-
+os.makedirs(OUTPUT_DIR, exist_ok=True)
 
 class AudioItem(BaseModel):
     url: HttpUrl
     user_id: str
 
-class AnalysisRequest(BaseModel):
-    audio_items: List[AudioItem]
-
 def process_item_wrapper(item: AudioItem) -> Dict:
     try:
         logger.info(f"Starting analysis for user '{item.user_id}' with URL: {item.url}")
         result = process_interview(str(item.url))
-        # --- MODIFICATION: Return just the filename, not the full path ---
-        if result and "pdf_path" in result:
+        # Return just the filename, not the full path
+        if result and "pdf_path" in result and result["pdf_path"]:
             result["pdf_filename"] = os.path.basename(result["pdf_path"])
-        if result and "json_path" in result:
+        if result and "json_path" in result and result["json_path"]:
             result["json_filename"] = os.path.basename(result["json_path"])
         
         return {
@@ -58,21 +54,16 @@ def process_item_wrapper(item: AudioItem) -> Dict:
 def health_check():
     return {"status": "ok"}
 
-@app.post("/analyze", summary="Analyze a list of audio URLs")
-def analyze_audios(request: AnalysisRequest):
-    if not request.audio_items:
-        raise HTTPException(status_code=400, detail="No audio items provided.")
-    logger.info(f"Received request to analyze {len(request.audio_items)} audio items.")
-    results = []
-    with ThreadPoolExecutor(max_workers=5) as executor:
-        futures = [executor.submit(process_item_wrapper, item) for item in request.audio_items]
-        for future in futures:
-            results.append(future.result())
-    logger.info("Finished processing all items.")
-    return {"analysis_results": results}
-
+@app.post("/analyze", summary="Analyze a single audio URL")
+def analyze_audio(request: AudioItem):
+    """
+    Analyze a single audio URL and return analysis results.
+    """
+    logger.info(f"Received request to analyze audio for user '{request.user_id}' with URL: {request.url}")
+    result = process_item_wrapper(request)
+    logger.info(f"Finished processing audio for user '{request.user_id}'")
+    return {"analysis_result": result}
 
-# --- NEW ENDPOINT TO DOWNLOAD OUTPUT FILES ---
 @app.get("/outputs/{file_name}", summary="Download an output file")
 def get_output_file(file_name: str):
     """