Update realtime_stt_manager.py

realtime_stt_manager.py

@@ -8,7 +8,7 @@ import sys
 
 from stt_interface import STTInterface, STTConfig, TranscriptionResult
 from config_provider import ConfigProvider
-from utils import log
+from logger import log_info, log_error, log_warning, log_debug
 
 class STTStreamManager:
     """Manages real-time STT streaming"""
@@ -39,12 +39,12 @@ class STTStreamManager:
         # Start streaming session
         await self.stt_provider.start_streaming(self.config)
         self.is_streaming = True
-        log("✅ STT stream manager initialized")
+        log_info("✅ STT stream manager initialized")
         
     async def process_chunk(self, audio_chunk: bytes) -> AsyncIterator[TranscriptionResult]:
         """Process audio chunk and yield transcription results"""
         if not self.is_streaming or not self.stt_provider:
-            log("⚠️ STT not streaming or provider not initialized")
+            log_info("⚠️ STT not streaming or provider not initialized")
             return
             
         try:
@@ -58,7 +58,7 @@ class STTStreamManager:
                 yield result
                 
         except Exception as e:
-            log(f"❌ STT processing error: {e}")
+            log_error("❌ STT processing error", e)
             # Yield error result
             yield TranscriptionResult(
                 text="",
@@ -81,18 +81,18 @@ class STTStreamManager:
                 self.accumulated_text = final_result.text
                 self.last_final_result = final_result
                 
-            log("✅ STT streaming stopped")
+            log_info("✅ STT streaming stopped")
             return final_result
             
         except Exception as e:
-            log(f"❌ Error stopping STT stream: {e}")
+            log_error("❌ Error stopping STT stream", e)
             return None
             
     def reset(self):
         """Reset accumulated text and state"""
         self.accumulated_text = ""
         self.last_final_result = None
-        log("🔄 STT stream manager reset")
+        log_info("🔄 STT stream manager reset")
         
     def get_accumulated_text(self) -> str:
         """Get all accumulated text from the session"""