feat: Enhance analysis endpoints to support JSON body input and CSV file uploads for argument analysis

routes/analysis.py

@@ -1,10 +1,11 @@
 """Analysis endpoints for processing arguments, extracting topics, and predicting stance"""
 
-from fastapi import APIRouter, HTTPException, Header, UploadFile, File
-from typing import Optional, List
+from fastapi import APIRouter, HTTPException, Header, UploadFile, File, Form
+from typing import Optional, List, Union
 import logging
 import csv
 import io
+import json
 from datetime import datetime
 
 from services.analysis_service import analysis_service
@@ -71,20 +72,63 @@ def parse_csv_file(file_content: bytes) -> List[str]:
 
 @router.post("", response_model=AnalysisResponse, tags=["Analysis"])
 async def analyse_arguments(
-    request: Optional[AnalysisRequest] = None,
-    file: Optional[UploadFile] = File(None),
+    request: AnalysisRequest,
     x_user_id: Optional[str] = Header(None, alias="X-User-ID")
 ):
     """
-    Analyze arguments: extract topics and predict stance
+    Analyze arguments: extract topics and predict stance (JSON body)
     
-    Accepts either:
-    - JSON body with `arguments` array, OR
-    - CSV file upload with arguments
+    - **X-User-ID**: User UUID (required in header)
+    - **arguments**: List of argument texts in JSON body
+    
+    Returns analysis results with extracted topics and stance predictions
+    """
+    if not x_user_id:
+        raise HTTPException(status_code=400, detail="X-User-ID header is required")
+    
+    try:
+        arguments = request.arguments
+        logger.info(f"Received {len(arguments)} arguments from JSON body")
+        
+        # Analyze arguments
+        results = analysis_service.analyze_arguments(
+            user_id=x_user_id,
+            arguments=arguments
+        )
+        
+        # Convert to response models
+        analysis_results = [
+            AnalysisResult(**result) for result in results
+        ]
+        
+        logger.info(f"Analysis completed: {len(analysis_results)} results")
+        
+        return AnalysisResponse(
+            results=analysis_results,
+            total_processed=len(analysis_results),
+            timestamp=datetime.now().isoformat()
+        )
+        
+    except HTTPException:
+        raise
+    except ValueError as e:
+        logger.error(f"Validation error: {str(e)}")
+        raise HTTPException(status_code=400, detail=str(e))
+    except Exception as e:
+        logger.error(f"Analysis error: {str(e)}")
+        raise HTTPException(status_code=500, detail=f"Analysis failed: {str(e)}")
+
+
+@router.post("/csv", response_model=AnalysisResponse, tags=["Analysis"])
+async def analyse_arguments_csv(
+    file: UploadFile = File(...),
+    x_user_id: Optional[str] = Header(None, alias="X-User-ID")
+):
+    """
+    Analyze arguments from CSV file: extract topics and predict stance
     
     - **X-User-ID**: User UUID (required in header)
-    - **arguments**: List of argument texts (if using JSON)
-    - **file**: CSV file with arguments (if using file upload)
+    - **file**: CSV file with arguments
     
     Returns analysis results with extracted topics and stance predictions
     """
@@ -92,31 +136,18 @@ async def analyse_arguments(
         raise HTTPException(status_code=400, detail="X-User-ID header is required")
     
     try:
-        arguments = []
+        # Read CSV file
+        file_content = await file.read()
+        arguments = parse_csv_file(file_content)
         
-        # Get arguments from either JSON body or CSV file
-        if file:
-            # Read CSV file
-            file_content = await file.read()
-            arguments = parse_csv_file(file_content)
-            
-            if not arguments:
-                raise HTTPException(
-                    status_code=400,
-                    detail="CSV file is empty or contains no valid arguments"
-                )
-            
-            logger.info(f"Parsed {len(arguments)} arguments from CSV file")
-            
-        elif request and request.arguments:
-            arguments = request.arguments
-            logger.info(f"Received {len(arguments)} arguments from JSON body")
-        else:
+        if not arguments:
             raise HTTPException(
                 status_code=400,
-                detail="Either 'arguments' in JSON body or CSV 'file' must be provided"
+                detail="CSV file is empty or contains no valid arguments"
             )
         
+        logger.info(f"Parsed {len(arguments)} arguments from CSV file")
+        
         # Analyze arguments
         results = analysis_service.analyze_arguments(
             user_id=x_user_id,