OpenAI Anthropic Gemini works

app.py

@@ -5,6 +5,7 @@ import json
 from dotenv import load_dotenv
 import gradio as gr
 from typing import AsyncGenerator, List, Dict, Tuple
+import traceback
 
 # Configure logging
 logging.basicConfig(level=logging.INFO)
@@ -108,18 +109,31 @@ async def ask_anthropic(query: str, history: List[Dict[str, str]]) -> str:
     }
 
     try:
-        async with httpx.AsyncClient() as client:
+        async with httpx.AsyncClient(timeout=30.0) as client:
             logger.info(f"Sending Anthropic request: {payload}")
             response = await client.post("https://api.anthropic.com/v1/messages", headers=headers, json=payload)
         
         response.raise_for_status()
-        logger.info(f"Anthropic response: {response.json()}")
-        return response.json()['content'][0]['text']
+        response_json = response.json()
+        logger.info(f"Anthropic response: {response_json}")
+        
+        # Validate response structure
+        if not isinstance(response_json, dict) or "content" not in response_json or not response_json["content"]:
+            logger.error(f"Invalid Anthropic response structure: {response_json}")
+            return f"Error: Invalid Anthropic response structure"
+        
+        content = response_json["content"]
+        if not isinstance(content, list) or not content or "text" not in content[0]:
+            logger.error(f"Invalid Anthropic content format: {content}")
+            return f"Error: Invalid Anthropic content format"
+        
+        return response_json["content"][0]["text"]
     except httpx.HTTPStatusError as e:
-        logger.error(f"Anthropic HTTP Status Error: {e.response.status_code}, {e.response.text}")
-        return f"Error: Anthropic HTTP Status Error: {e.response.status_code}, {e.response.text}"
+        response_text = await e.response.aread()
+        logger.error(f"Anthropic HTTP Status Error: {e.response.status_code}, {response_text.decode('utf-8')}")
+        return f"Error: Anthropic HTTP Status Error: {e.response.status_code}, {response_text.decode('utf-8')}"
     except Exception as e:
-        logger.error(f"Anthropic Error: {str(e)}")
+        logger.error(f"Anthropic Error: {str(e)}\nStack trace: {traceback.format_exc()}")
         return f"Error: Anthropic Error: {str(e)}"
 
 async def ask_gemini(query: str, history: List[Dict[str, str]]) -> str:
@@ -183,7 +197,7 @@ async def query_model(query: str, providers: List[str], history: List[Dict[str,
     # Handle Anthropic (non-streaming)
     if "Anthropic" in providers:
         response = await ask_anthropic(query, history)
-        if response.strip():
+        if response.strip() and not response.startswith("Error:"):
             responses.append(f"[Anthropic]: {response}")
 
     # Handle Gemini (non-streaming)