Updated

api_clients.py

@@ -5,7 +5,7 @@ import elevenlabs
 import time
 from contextlib import asynccontextmanager
 from logger import setup_logger, log_execution_time, log_async_execution_time
-from models import OpenRouterModel
+from models import OpenRouterModel, OpenRouterRequest, OpenRouterResponse, Message
 
 logger = setup_logger("api_clients")
 
@@ -159,15 +159,13 @@ Focus on making it engaging and natural to listen to."""
             async with self.get_session() as session:
                 async with session.post(
                     f"{self.base_url}/chat/completions",
-                    json=request_data
+                    json=request.dict()
                 ) as response:
-                    if response.status != 200:
-                        error_text = await response.text()
-                        logger.error(f"OpenRouter API error: {error_text}")
-                        raise ValueError(f"API request failed: {error_text}")
-                    
+                    response.raise_for_status()
                     data = await response.json()
-                    return data['choices'][0]['message']['content']
+                    router_response = OpenRouterResponse(**data)
+                    logger.debug(f"Generated script length: {len(router_response.choices[0].message.content)} chars")
+                    return router_response.choices[0].message.content
                     
         except Exception as e:
             logger.error(f"Script generation failed", exc_info=True)
@@ -188,17 +186,14 @@ class ElevenLabsClient:
         """
         try:
             voices = elevenlabs.voices()
-            return [(
-                
-                f"{voice.name} ({voice.labels.get('accent', 'No accent')})" + 
-                (f" - {voice.description[:50]}..." if voice.description else ""),
-                voice.voice_id  # Value (hidden from user)
-            ) for voice in voices]
+            return [(voice.voice_id, f"{voice.name} ({voice.labels.get('accent', 'No accent')})" + 
+                    (f" - {voice.description[:50]}..." if voice.description else ""))
+                    for voice in voices]
         except Exception as e:
             logger.error("Failed to fetch voices from ElevenLabs", exc_info=True)
             raise
 
-    def generate_audio(self, text: str, voice_id: str):
+    async def generate_audio(self, text: str, voice_id: str):
         """Generate audio synchronously"""
         logger.info(f"Starting audio generation with voice: {voice_id}")
         logger.debug(f"Input text length: {len(text)} chars")
@@ -208,7 +203,7 @@ class ElevenLabsClient:
         
         try:
             start_time = time.time()
-            audio = elevenlabs.generate(
+            audio = await elevenlabs.generate(
                 text=text,
                 voice=voice_id,
                 model="eleven_monolingual_v1"

models.py

@@ -10,9 +10,13 @@ class OpenRouterRequest(BaseModel):
     messages: List[Message]
 
 class OpenRouterChoice(BaseModel):
+    index: int = 0
     message: Message
+    finish_reason: Optional[str] = None
 
 class OpenRouterResponse(BaseModel):
+    id: str
+    model: str
     choices: List[OpenRouterChoice]
 
 class OpenRouterModel(BaseModel):