Update chat_session/state_orchestrator.py

chat_session/state_orchestrator.py

@@ -276,8 +276,6 @@ class StateOrchestrator:
         text = result_data.get("text", "").strip()
         if not text:
             log_warning(f"⚠️ Empty final transcription", session_id=session_id)
-            # ✅ DÜZELTME: return yerine devam et
-            # return  # BU SATIRI KALDIR VEYA YORUMA AL
     
         if current_state != ConversationState.LISTENING:
             log_warning(
@@ -287,25 +285,27 @@ class StateOrchestrator:
             )
             return
     
-        # ✅ Text boş olsa bile log at
+        # Text boş olsa bile log at
         if text:
             log_info(f"💬 Final transcription: '{text}'", session_id=session_id)
         else:
             log_info(f"💬 Final transcription: (silence detected)", session_id=session_id)
     
-        # ✅ STT'yi otomatik durdur
+        # ✅ STT'yi durdur ve dispose et
         await self.event_bus.publish(Event(
             type=EventType.STT_STOPPED,
             session_id=session_id,
             data={"reason": "utterance_completed"}
         ))
     
-        # ✅ Boş transcript'te LLM'e göndermek istemiyorsanız burada kontrol edin
+        # ✅ Boş transcript'te LLM'e gönderme
         if not text:
             # Tekrar dinlemeye geç
             await self.transition_to(session_id, ConversationState.LISTENING)
             
-            # STT'yi tekrar başlat
+            # ✅ Biraz bekle ve STT'yi yeniden başlat
+            await asyncio.sleep(0.5)
+            
             await self.event_bus.publish(Event(
                 type=EventType.STT_STARTED,
                 session_id=session_id,
@@ -322,6 +322,7 @@ class StateOrchestrator:
             session_id=session_id,
             data={"text": text}
         ))
+        
     async def _handle_llm_response_ready(self, event: Event):
         """Handle LLM response"""
         session_id = event.session_id