Upload chat_handler.py

routes/chat_handler.py

@@ -15,7 +15,7 @@ from utils.logger import log_info, log_error, log_warning, log_debug
 from api.api_executor import call_api as execute_api
 from config.config_provider import ConfigProvider
 from llm.validation_engine import validate
-from session import session_store, Session
+from chat_session.session import session_store, Session
 
 # Initialize router
 router = APIRouter()
@@ -259,7 +259,7 @@ async def start_session(req: StartRequest, request: Request):
 
         # For realtime sessions, publish event to start the flow
         if req.is_realtime and hasattr(request.app.state, 'event_bus'):
-            from event_bus import Event, EventType
+            from chat_session.event_bus import Event, EventType
 
             await request.app.state.event_bus.publish(Event(
                 type=EventType.SESSION_STARTED,
@@ -522,7 +522,7 @@ async def end_session(x_session_id: str = Header(...), request: Request = None):
 
         # For realtime sessions, publish end event
         if session.is_realtime and request and hasattr(request.app.state, 'event_bus'):
-            from event_bus import Event, EventType
+            from chat_session.event_bus import Event, EventType
 
             await request.app.state.event_bus.publish(Event(
                 type=EventType.SESSION_ENDED,