Update realtime_session_manager.py

realtime_session_manager.py

@@ -5,8 +5,9 @@ import base64
 from typing import Optional
 from datetime import datetime
 import sys
+import traceback
 
-from logger import log_info, log_error, log_debug
+from logger import log_info, log_error, log_debug, log_warning
 
 def log(message: str):
     """Log helper with timestamp"""
@@ -17,31 +18,49 @@ def log(message: str):
 async def send_tts_welcome_message(websocket, session_id: str, tts_provider, text: str):
     """Send welcome message TTS audio"""
     try:
+        log_info(f"🎙️ Generating welcome TTS for: '{text[:50]}...'", session_id=session_id)
+        
         # Generate TTS
         audio_data = await tts_provider.synthesize(text)
+        log_info(f"✅ Welcome TTS generated: {len(audio_data)} bytes", session_id=session_id)
         
         # Convert to base64
+        log_debug(f"📦 Converting welcome audio to base64...")
         audio_base64 = base64.b64encode(audio_data).decode('utf-8')
+        log_info(f"📊 Welcome base64 ready: {len(audio_base64)} chars", session_id=session_id)
+        
+        # Log preview
+        log_debug(f"🔍 Welcome base64 preview: {audio_base64[:100]}...")
         
         # Send in chunks
         chunk_size = 16384
         total_length = len(audio_base64)
         total_chunks = (total_length + chunk_size - 1) // chunk_size
         
+        log_info(f"📤 Sending welcome TTS in {total_chunks} chunks", session_id=session_id)
+        
         for i in range(0, total_length, chunk_size):
             chunk = audio_base64[i:i + chunk_size]
             chunk_index = i // chunk_size
+            is_last = chunk_index == total_chunks - 1
+            
+            log_debug(f"📨 Welcome chunk {chunk_index}/{total_chunks}, size: {len(chunk)}")
             
             await websocket.send_json({
                 "type": "tts_audio",
                 "data": chunk,
                 "chunk_index": chunk_index,
                 "total_chunks": total_chunks,
-                "is_last": chunk_index == total_chunks - 1,
+                "is_last": is_last,
                 "mime_type": "audio/mpeg"
             })
         
-        log_info(f"✅ Welcome message TTS sent", session_id=session_id)
+        log_info(f"✅ Welcome message TTS sent successfully", session_id=session_id, chunks=total_chunks)
         
     except Exception as e:
-        log_error(f"Failed to send welcome TTS", error=str(e), session_id=session_id)
+        log_error(
+            f"❌ Failed to send welcome TTS", 
+            error=str(e),
+            traceback=traceback.format_exc(),
+            session_id=session_id
+        )