Update app.py

app.py

@@ -161,8 +161,8 @@ async def save_chat_entry(username, message):
     if audio_file:
         with open(HISTORY_FILE, 'a') as f:
             f.write(f"[{timestamp}] {username}: Audio generated - {audio_file}\n")
-    await broadcast_message(f"{username}|{message}", "chat")  # Notify all clients
-    st.session_state.last_chat_update = time.time()  # Update timestamp for new chat
+    await broadcast_message(f"{username}|{message}", "chat")
+    st.session_state.last_chat_update = time.time()
 
 # Chat loader - history unleashed! 📜🚀
 async def load_chat():
@@ -189,7 +189,7 @@ async def get_user_list(chat_content):
 async def has_joined_before(client_id, chat_content):
     username = st.session_state.get('username', 'System 🌟')
     await asyncio.to_thread(log_action, username, "🚪🔍 - Join checker - been here before?")
-    return any(f"Client-{client_id} has joined" in line for line in chat_content.split('\n'))
+    return any(f"Client-{client_id}" in line for line in chat_content.split('\n'))
 
 # Suggestion maker - old quips resurface! 💡📝
 async def get_message_suggestions(chat_content, prefix):
@@ -310,7 +310,6 @@ async def websocket_handler(websocket, path):
             if len(parts) == 2:
                 username, content = parts
                 await save_chat_entry(username, content)
-                await broadcast_message(f"{username}|{content}", room_id)
     except websockets.ConnectionClosed:
         pass
     finally:
@@ -392,20 +391,20 @@ def create_streamlit_interface():
             await process_voice_input(audio_bytes)
             st.rerun()
 
-        # Load chat only if there’s an update
+        # Load and display chat
         st.subheader(f"{START_ROOM} Chat 💬")
         chat_content = await load_chat()
         chat_lines = chat_content.split('\n')
         chat_votes = await load_votes(QUOTE_VOTES_FILE)
 
-        # Only add new lines that haven’t been displayed yet
+        # Update displayed lines only with new, valid chat entries
         current_time = time.time()
         if current_time - st.session_state.last_chat_update > 1 or not st.session_state.displayed_chat_lines:
-            new_lines = [line for line in chat_lines if line.strip() and ': ' in line and line not in st.session_state.displayed_chat_lines]
+            new_lines = [line for line in chat_lines if line.strip() and ': ' in line and line not in st.session_state.displayed_chat_lines and not line.startswith('#')]
             st.session_state.displayed_chat_lines.extend(new_lines)
             st.session_state.last_chat_update = current_time
 
-        # Display chat lines from session state
+        # Display chat lines
         for i, line in enumerate(st.session_state.displayed_chat_lines):
             col1, col2, col3, col4 = st.columns([3, 1, 1, 2])
             with col1:
@@ -428,47 +427,39 @@ def create_streamlit_interface():
                     st.rerun()
             with col4:
                 username = line.split(': ')[1].split(' ')[0]
-                audio_file = None
                 cache_key = f"{line}_{FUN_USERNAMES.get(username, 'en-US-AriaNeural')}"
-                if cache_key in st.session_state.audio_cache:
-                    audio_file = st.session_state.audio_cache[cache_key]
-                else:
+                if cache_key not in st.session_state.audio_cache:
                     cleaned_text = clean_text_for_tts(line.split(': ', 1)[1])
                     audio_file = await async_edge_tts_generate(cleaned_text, FUN_USERNAMES.get(username, "en-US-AriaNeural"))
                     st.session_state.audio_cache[cache_key] = audio_file
+                audio_file = st.session_state.audio_cache.get(cache_key)
                 if audio_file:
                     play_and_download_audio(audio_file)
 
-        if 'quote_line' in st.session_state:
+        # Quoting interface
+        if 'quote_line' in st.session_state and st.session_state.quote_line:
             st.markdown(f"### Quoting: {st.session_state.quote_line}")
             quote_response = st.text_area("Add your response", key="quote_response")
             if st.button("Send Quote 🚀", key="send_quote"):
-                async def process_quote():
-                    await asyncio.to_thread(log_action, st.session_state.username, "📢💬 - Quote processor - echoes resound!")
-                    markdown_response = f"### Quote Response\n- **Original**: {st.session_state.quote_line}\n- **{st.session_state.username} Replies**: {quote_response}"
-                    if st.session_state.pasted_image_data:
-                        filename = await save_pasted_image(st.session_state.pasted_image_data, st.session_state.username)
-                        if filename:
-                            markdown_response += f"\n- **Image**: ![Pasted Image]({filename})"
-                            st.session_state.pasted_image_data = None
-                    try:
-                        await save_chat_entry(st.session_state.username, markdown_response)
-                    except edge_tts.exceptions.NoAudioReceived:
-                        timestamp = datetime.now().strftime("%Y-%m-%d %H:%M:%S")
-                        with open(HISTORY_FILE, 'a') as f:
-                            f.write(f"[{timestamp}] {st.session_state.username}: Quote saved without audio - No audio received\n")
-                        await asyncio.to_thread(lambda: open(CHAT_FILE, 'a').write(f"[{timestamp}] {st.session_state.username}: {markdown_response}\n"))
-                loop.run_until_complete(process_quote())
+                markdown_response = f"### Quote Response\n- **Original**: {st.session_state.quote_line}\n- **{st.session_state.username} Replies**: {quote_response}"
+                if st.session_state.pasted_image_data:
+                    filename = await save_pasted_image(st.session_state.pasted_image_data, st.session_state.username)
+                    if filename:
+                        markdown_response += f"\n- **Image**: ![Pasted Image]({filename})"
+                        st.session_state.pasted_image_data = None
+                await save_chat_entry(st.session_state.username, markdown_response)
                 del st.session_state.quote_line
                 st.session_state.message_text = ''
                 st.rerun()
 
+        # Username change
         new_username = st.selectbox("Change Name", [""] + list(FUN_USERNAMES.keys()), index=0)
         if new_username and new_username != st.session_state.username:
             loop.run_until_complete(save_chat_entry("System 🌟", f"{st.session_state.username} changed name to {new_username}"))
             st.session_state.username = new_username
             st.rerun()
 
+        # Message input
         message = st.text_input(f"Message as {st.session_state.username}", key="message_input", value=st.session_state.message_text, on_change=lambda: st.session_state.update(message_text=st.session_state.message_input))
         if st.button("Send 🚀", key="send_button") and message.strip():
             loop.run_until_complete(save_chat_entry(st.session_state.username, message))
@@ -520,13 +511,13 @@ def create_streamlit_interface():
             st.success(f"Uploaded {filename}")
             await save_chat_entry(username, f"Uploaded media: {file_path}")
             if file_path.endswith('.mp4'):
-                st.session_state.media_notifications.append(file_path)  # Trigger autoplay for all clients
+                st.session_state.media_notifications.append(file_path)
 
         # Organize gallery by user
         media_files = glob.glob(f"{MEDIA_DIR}/*.png") + glob.glob(f"{MEDIA_DIR}/*.jpg") + glob.glob(f"{MEDIA_DIR}/*.mp3") + glob.glob(f"{MEDIA_DIR}/*.mp4")
         if media_files:
             media_votes = loop.run_until_complete(load_votes(MEDIA_VOTES_FILE))
-            users = sorted(set(f.split('_')[-1].split('.')[0] for f in media_files))  # Extract usernames
+            users = sorted(set(f.split('_')[-1].split('.')[0] for f in media_files))
             for user in users:
                 with st.expander(f"{user}'s Media"):
                     user_files = [f for f in media_files if user in f]
@@ -544,7 +535,7 @@ def create_streamlit_interface():
                                     st.markdown(await get_video_html(media_file), unsafe_allow_html=True)
                                     st.caption(os.path.basename(media_file))
                                     if media_file in st.session_state.media_notifications:
-                                        st.session_state.media_notifications.remove(media_file)  # Autoplay once
+                                        st.session_state.media_notifications.remove(media_file)
                             with col2:
                                 if st.button(f"👍 {vote_count}", key=f"media_vote_{media_file}"):
                                     comment = st.session_state.message_text