Update app.py

app.py

@@ -58,15 +58,15 @@ UNICODE_FONTS = [
 server_running = False
 server_task = None
 
-async def get_node_name():
+def get_node_name():
     """🌐 - Naming Node with Code - Spins a name, oh so bold!"""
     action = "🌐 - Naming Node with Code - Spins a name, oh so bold!"
     username = st.session_state.get('username', 'System 🌟')
-    await asyncio.to_thread(log_action, username, action)
+    log_action(username, action)
     parser = argparse.ArgumentParser(description='Start a chat node with a specific name')
     parser.add_argument('--node-name', type=str, default=None)
     parser.add_argument('--port', type=int, default=8501)
-    args = await asyncio.to_thread(parser.parse_args)
+    args = parser.parse_args()
     return args.node_name or f"node-{uuid.uuid4().hex[:8]}", args.port
 
 def log_action(username, action):
@@ -99,13 +99,13 @@ async def load_chat():
         await asyncio.to_thread(lambda: open(CHAT_FILE, 'w').write(f"# {START_ROOM} Chat\n\nWelcome to the cosmic hub - start chatting! 🎤\n"))
     with open(CHAT_FILE, 'r') as f:
         content = await asyncio.to_thread(f.read)
-    return content  # Return the raw string, splitting handled where needed
+    return content
 
-async def get_user_list(chat_content):
+def get_user_list(chat_content):
     """👥 - Crew Clue Brew - Spots who’s who in the crew!"""
     action = "👥 - Crew Clue Brew - Spots who’s who in the crew!"
     username = st.session_state.get('username', 'System 🌟')
-    await asyncio.to_thread(log_action, username, action)
+    log_action(username, action)
     users = set()
     for line in chat_content.split('\n'):
         if line.strip() and ': ' in line:
@@ -269,11 +269,11 @@ async def run_websocket_server():
         server_running = True
         await server.wait_closed()
 
-async def create_streamlit_interface():
+def create_streamlit_interface():
     """🎨 - UI Brew Crew - Builds the view, so new!"""
     action = "🎨 - UI Brew Crew - Builds the view, so new!"
     username = st.session_state.get('username', 'System 🌟')
-    await asyncio.to_thread(log_action, username, action)
+    log_action(username, action)  # Sync call here since we're in Streamlit context
 
     # Dynamic title based on username
     if 'username' in st.session_state:
@@ -298,7 +298,7 @@ async def create_streamlit_interface():
     if 'client_id' not in st.session_state:
         st.session_state.client_id = str(uuid.uuid4())
     if 'username' not in st.session_state:
-        chat_content = await load_chat()  # Await the coroutine here
+        chat_content = asyncio.run(load_chat())  # Run async function synchronously
         available_names = [name for name in FUN_USERNAMES if not any(f"{name} has joined" in line for line in chat_content.split('\n'))]
         st.session_state.username = random.choice(available_names) if available_names else random.choice(FUN_USERNAMES)
 
@@ -308,7 +308,7 @@ async def create_streamlit_interface():
     if 'timer_start' not in st.session_state:
         st.session_state.timer_start = time.time()
     if 'quote_index' not in st.session_state:
-        quotes = await load_quotes("famous")
+        quotes = asyncio.run(load_quotes("famous"))
         st.session_state.quote_index = random.randint(0, max(0, len(quotes) - 1)) if quotes else 0
     if 'quote_source' not in st.session_state:
         st.session_state.quote_source = "famous"
@@ -349,17 +349,17 @@ async def create_streamlit_interface():
     # Handle pasted image data
     pasted_image = st.session_state.get('pasted_image_data')
     if pasted_image:
-        filename = await save_pasted_image(pasted_image)
+        filename = asyncio.run(save_pasted_image(pasted_image))
         if filename:
-            await save_chat_entry(st.session_state.username, f"Pasted image: {filename}")
+            asyncio.run(save_chat_entry(st.session_state.username, f"Pasted image: {filename}"))
             st.session_state.pasted_image_data = None
             st.rerun()
 
     # Chat section with quoting
     st.subheader(f"{START_ROOM} Chat 💬")
-    chat_content = await load_chat()
+    chat_content = asyncio.run(load_chat())
     chat_lines = chat_content.split('\n')
-    chat_votes = await load_votes(QUOTE_VOTES_FILE)
+    chat_votes = asyncio.run(load_votes(QUOTE_VOTES_FILE))
     for i, line in enumerate(chat_lines):
         if line.strip() and ': ' in line:
             col1, col2, col3 = st.columns([4, 1, 1])
@@ -369,11 +369,11 @@ async def create_streamlit_interface():
                 vote_count = chat_votes.get(line.split('. ')[1] if '. ' in line else line, 0)
                 if st.button(f"👍 {vote_count}", key=f"chat_vote_{i}"):
                     comment = st.session_state.message_text
-                    await save_vote(QUOTE_VOTES_FILE, line.split('. ')[1] if '. ' in line else line, await generate_user_hash(), st.session_state.username, comment)
+                    asyncio.run(save_vote(QUOTE_VOTES_FILE, line.split('. ')[1] if '. ' in line else line, asyncio.run(generate_user_hash()), st.session_state.username, comment))
                     if st.session_state.pasted_image_data:
-                        filename = await save_pasted_image(st.session_state.pasted_image_data)
+                        filename = asyncio.run(save_pasted_image(st.session_state.pasted_image_data))
                         if filename:
-                            await save_chat_entry(st.session_state.username, f"Pasted image: {filename}")
+                            asyncio.run(save_chat_entry(st.session_state.username, f"Pasted image: {filename}"))
                             st.session_state.pasted_image_data = None
                     st.session_state.message_text = ''
                     st.rerun()
@@ -387,18 +387,17 @@ async def create_streamlit_interface():
         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():
-                """📢 - Quote Float Boat - Echoes chat, we gloat!"""
+            def process_quote():
                 action = "📢 - Quote Float Boat - Echoes chat, we gloat!"
-                await asyncio.to_thread(log_action, st.session_state.username, action)
+                log_action(st.session_state.username, action)
                 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)
+                    filename = asyncio.run(save_pasted_image(st.session_state.pasted_image_data))
                     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)
-            await process_quote()
+                asyncio.run(save_chat_entry(st.session_state.username, markdown_response))
+            process_quote()
             del st.session_state.quote_line
             st.session_state.message_text = ''
             st.rerun()
@@ -406,18 +405,18 @@ async def create_streamlit_interface():
     # Username change dropdown
     new_username = st.selectbox("Change Name", [""] + FUN_USERNAMES, index=0)
     if new_username and new_username != st.session_state.username:
-        await save_chat_entry("System 🌟", f"{st.session_state.username} changed name to {new_username}")
+        asyncio.run(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():
-        await save_chat_entry(st.session_state.username, message)
+        asyncio.run(save_chat_entry(st.session_state.username, message))
         if st.session_state.pasted_image_data:
-            filename = await save_pasted_image(st.session_state.pasted_image_data)
+            filename = asyncio.run(save_pasted_image(st.session_state.pasted_image_data))
             if filename:
-                await save_chat_entry(st.session_state.username, f"Pasted image: {filename}")
+                asyncio.run(save_chat_entry(st.session_state.username, f"Pasted image: {filename}"))
                 st.session_state.pasted_image_data = None
         st.session_state.message_text = ''
         st.rerun()
@@ -427,13 +426,14 @@ async def create_streamlit_interface():
     uploaded_file = st.file_uploader("Upload Media", type=['png', 'jpg', 'mp3', 'mp4'])
     if uploaded_file:
         file_path = os.path.join('./', uploaded_file.name)
-        await asyncio.to_thread(lambda: open(file_path, 'wb').write(uploaded_file.getbuffer()))
+        with open(file_path, 'wb') as f:
+            f.write(uploaded_file.getbuffer())
         st.success(f"Uploaded {uploaded_file.name}")
 
     media_files = glob.glob("./*.png") + glob.glob("./*.jpg") + glob.glob("./*.mp3") + glob.glob("./*.mp4")
     if media_files:
         cols = st.columns(3)
-        media_votes = await load_votes(MEDIA_VOTES_FILE)
+        media_votes = asyncio.run(load_votes(MEDIA_VOTES_FILE))
         for idx, media_file in enumerate(media_files):
             vote_count = media_votes.get(media_file, 0)
             if vote_count > 0:
@@ -441,24 +441,24 @@ async def create_streamlit_interface():
                     if media_file.endswith(('.png', '.jpg')):
                         st.image(media_file, use_container_width=True)
                     elif media_file.endswith('.mp3'):
-                        st.markdown(await get_audio_html(media_file), unsafe_allow_html=True)
+                        st.markdown(asyncio.run(get_audio_html(media_file)), unsafe_allow_html=True)
                     elif media_file.endswith('.mp4'):
-                        st.markdown(await get_video_html(media_file), unsafe_allow_html=True)
+                        st.markdown(asyncio.run(get_video_html(media_file)), unsafe_allow_html=True)
                     col1, col2 = st.columns(2)
                     with col1:
                         if st.button(f"👍 {vote_count}", key=f"media_vote_{idx}"):
                             comment = st.session_state.message_text
-                            await save_vote(MEDIA_VOTES_FILE, media_file, await generate_user_hash(), st.session_state.username, comment)
+                            asyncio.run(save_vote(MEDIA_VOTES_FILE, media_file, asyncio.run(generate_user_hash()), st.session_state.username, comment))
                             if st.session_state.pasted_image_data:
-                                filename = await save_pasted_image(st.session_state.pasted_image_data)
+                                filename = asyncio.run(save_pasted_image(st.session_state.pasted_image_data))
                                 if filename:
-                                    await save_chat_entry(st.session_state.username, f"Pasted image: {filename}")
+                                    asyncio.run(save_chat_entry(st.session_state.username, f"Pasted image: {filename}"))
                                     st.session_state.pasted_image_data = None
                             st.session_state.message_text = ''
                             st.rerun()
                     with col2:
                         if st.button("🗑️", key=f"media_delete_{idx}"):
-                            await asyncio.to_thread(os.remove, media_file)
+                            os.remove(media_file)
                             st.rerun()
 
     # Refresh timer
@@ -470,13 +470,13 @@ async def create_streamlit_interface():
         font_name, font_func = random.choice(UNICODE_FONTS)
         countdown_str = "".join(UNICODE_DIGITS[int(d)] for d in str(i)) if i < 10 else font_func(str(i))
         timer_placeholder.markdown(f"<p class='timer'>⏳ {font_func('Refresh in:')} {countdown_str}</p>", unsafe_allow_html=True)
-        await asyncio.sleep(1)
+        time.sleep(1)  # Sync sleep here since it's UI-driven
     st.rerun()
 
     # Sidebar vote stats
     st.sidebar.subheader("Vote Counts")
-    chat_votes = await load_votes(QUOTE_VOTES_FILE)
-    media_votes = await load_votes(MEDIA_VOTES_FILE)
+    chat_votes = asyncio.run(load_votes(QUOTE_VOTES_FILE))
+    media_votes = asyncio.run(load_votes(MEDIA_VOTES_FILE))
     for item, count in {**chat_votes, **media_votes}.items():
         if count > 0:
             st.sidebar.write(f"{item}: {count} votes")
@@ -487,10 +487,10 @@ async def main():
     username = st.session_state.get('username', 'System 🌟')
     await asyncio.to_thread(log_action, username, action)
     global NODE_NAME, server_task
-    NODE_NAME, port = await get_node_name()
+    NODE_NAME, port = get_node_name()  # Sync call since it's CLI parsing
     if server_task is None:
         server_task = asyncio.create_task(run_websocket_server())
-    await create_streamlit_interface()
+    create_streamlit_interface()  # Call synchronously
 
 if __name__ == "__main__":
     asyncio.run(main())