Update state_orchestrator.py

state_orchestrator.py

@@ -78,6 +78,10 @@ class StateOrchestrator:
         
     def _setup_event_handlers(self):
         """Subscribe to relevant events"""
+
+        # Conversation events
+        event_bus.subscribe(EventType.CONVERSATION_STARTED, self._handle_conversation_started)
+
         # Session lifecycle
         self.event_bus.subscribe(EventType.SESSION_STARTED, self._handle_session_started)
         self.event_bus.subscribe(EventType.SESSION_ENDED, self._handle_session_ended)
@@ -100,7 +104,35 @@ class StateOrchestrator:
         
         # Error events
         self.event_bus.subscribe(EventType.CRITICAL_ERROR, self._handle_critical_error)
+
+    async def _handle_conversation_started(self, event: Event) -> None:
+        """Handle conversation start within existing session"""
+        session_id = event.session_id
+        context = self.sessions.get(session_id)
+        
+        if not context:
+            log_error(f"❌ Session not found for conversation start | session_id={session_id}")
+            return
+        
+        log_info(f"🎤 Conversation started | session_id={session_id}")
         
+        # Welcome mesajını şimdi başlat
+        if context.project_config and context.project_config.get("welcome_enabled", True):
+            await self.transition_to(session_id, ConversationState.PREPARING_WELCOME)
+            await self._prepare_welcome_message(session_id)
+        else:
+            # Welcome yoksa direkt listening'e geç
+            await self.transition_to(session_id, ConversationState.LISTENING)
+            
+            # Start STT
+            await self._event_bus.publish(
+                Event(
+                    type=EventType.START_STT,
+                    data={"session_id": session_id},
+                    session_id=session_id
+                )
+            )
+            
     async def _handle_session_started(self, event: Event):
         """Handle session start"""
         session_id = event.session_id