Update app.py

app.py

@@ -87,7 +87,7 @@ def load_username():
             return f.read().strip()
     return None
 
-# Audio Processing (Moved Up for save_chat_entry Dependency)
+# Audio Processing
 async def async_edge_tts_generate(text, voice, username):
     cache_key = f"{text[:100]}_{voice}"
     if cache_key in st.session_state['audio_cache']:
@@ -106,7 +106,20 @@ def play_and_download_audio(file_path):
         st.audio(file_path)
         st.markdown(get_download_link(file_path), unsafe_allow_html=True)
 
-# Chat and Quest Log (Moved Up for init_session_state Dependency)
+# WebSocket Broadcast (Moved Up for save_chat_entry Dependency)
+async def broadcast_message(message, room_id):
+    if room_id in st.session_state.active_connections:
+        disconnected = []
+        for client_id, ws in st.session_state.active_connections[room_id].items():
+            try:
+                await ws.send(message)
+            except websockets.ConnectionClosed:
+                disconnected.append(client_id)
+        for client_id in disconnected:
+            if client_id in st.session_state.active_connections[room_id]:
+                del st.session_state.active_connections[room_id][client_id]
+
+# Chat and Quest Log
 async def save_chat_entry(username, message, voice, is_markdown=False):
     if not message.strip() or message == st.session_state.last_transcript:
         return None, None
@@ -204,18 +217,6 @@ async def websocket_handler(websocket, path):
         if room_id in st.session_state.active_connections and client_id in st.session_state.active_connections[room_id]:
             del st.session_state.active_connections[room_id][client_id]
 
-async def broadcast_message(message, room_id):
-    if room_id in st.session_state.active_connections:
-        disconnected = []
-        for client_id, ws in st.session_state.active_connections[room_id].items():
-            try:
-                await ws.send(message)
-            except websockets.ConnectionClosed:
-                disconnected.append(client_id)
-        for client_id in disconnected:
-            if client_id in st.session_state.active_connections[room_id]:
-                del st.session_state.active_connections[room_id][client_id]
-
 async def periodic_update():
     while True:
         if st.session_state.active_connections.get("quest"):