Upload app.py

app.py

@@ -23,10 +23,10 @@ from pydantic import ValidationError
 from dotenv import load_dotenv
 
 # Event-driven architecture imports
-from event_bus import event_bus
-from state_orchestrator import StateOrchestrator
-from websocket_manager import WebSocketManager
-from resource_manager import ResourceManager
+from chat_session.event_bus import event_bus
+from chat_session.state_orchestrator import StateOrchestrator
+from chat_session.websocket_manager import WebSocketManager
+from chat_session.resource_manager import ResourceManager
 from stt.stt_lifecycle_manager import STTLifecycleManager
 from tts.tts_lifecycle_manager import TTSLifecycleManager
 from llm.llm_manager import LLMManager
@@ -35,7 +35,7 @@ from stt.audio_buffer_manager import AudioBufferManager
 # Project imports
 from routes.admin_routes import router as admin_router, start_cleanup_task
 from llm.llm_startup import run_in_thread
-from session import session_store, start_session_cleanup
+from chat_session.session import session_store, start_session_cleanup
 from config.config_provider import ConfigProvider
 
 # Logger imports
@@ -243,7 +243,7 @@ async def websocket_route(websocket: WebSocket, session_id: str):
 @app.post("/api/test/realtime")
 async def test_realtime():
     """Test endpoint for event-driven realtime flow"""
-    from event_bus import Event, EventType
+    from chat_session.event_bus import Event, EventType
 
     try:
         # Create a test session