Update app.py

app.py

@@ -18,22 +18,22 @@ import edge_tts
 from audio_recorder_streamlit import audio_recorder
 import nest_asyncio
 
-# Apply patch to allow nested asyncio.run() calls
+# Patch for nested async - sneaky fix! 🐍✨
 nest_asyncio.apply()
 
-# Initial App Configuration (static)
+# Static config - constants rule! 📏👑
 icons = '🤖🧠🔬📝'
 START_ROOM = "Sector 🌌"
 
-# Set page config once at the top
+# Page setup - dressing up the window! 🖼️🎀
 st.set_page_config(
-    page_title="🤖🧠MMO Chat Brain📝🔬",  # Initial static title
+    page_title="🤖🧠MMO Chat Brain📝🔬",
     page_icon=icons,
     layout="wide",
     initial_sidebar_state="auto"
 )
 
-# Fun usernames with emojis and their paired voices
+# Funky usernames - who’s who in the zoo! 🎭🐾
 FUN_USERNAMES = {
     "CosmicJester 🌌": "en-US-AriaNeural",
     "PixelPanda 🐼": "en-US-JennyNeural",
@@ -57,7 +57,7 @@ FUN_USERNAMES = {
     "ChronoChimp 🐒": "en-US-JennyNeural"
 }
 
-# Directories and files
+# Folders galore - organizing chaos! 📂🌀
 CHAT_DIR = "chat_logs"
 VOTE_DIR = "vote_logs"
 STATE_FILE = "user_state.txt"
@@ -73,34 +73,51 @@ QUOTE_VOTES_FILE = os.path.join(VOTE_DIR, "quote_votes.md")
 MEDIA_VOTES_FILE = os.path.join(VOTE_DIR, "media_votes.md")
 HISTORY_FILE = os.path.join(HISTORY_DIR, "chat_history.md")
 
-# Unicode digits and fonts
+# Fancy digits - numbers got style! 🔢💃
 UNICODE_DIGITS = {i: f"{i}\uFE0F⃣" for i in range(10)}
+
+# Massive font collection - typography bonanza! 🖋️🎨
 UNICODE_FONTS = [
     ("Normal", lambda x: x),
     ("Bold", lambda x: "".join(chr(ord(c) + 0x1D400 - 0x41) if 'A' <= c <= 'Z' else chr(ord(c) + 0x1D41A - 0x61) if 'a' <= c <= 'z' else c for c in x)),
+    ("Italic", lambda x: "".join(chr(ord(c) + 0x1D434 - 0x41) if 'A' <= c <= 'Z' else chr(ord(c) + 0x1D44E - 0x61) if 'a' <= c <= 'z' else c for c in x)),
+    ("Bold Italic", lambda x: "".join(chr(ord(c) + 0x1D468 - 0x41) if 'A' <= c <= 'Z' else chr(ord(c) + 0x1D482 - 0x61) if 'a' <= c <= 'z' else c for c in x)),
+    ("Script", lambda x: "".join(chr(ord(c) + 0x1D49C - 0x41) if 'A' <= c <= 'Z' else chr(ord(c) + 0x1D4B6 - 0x61) if 'a' <= c <= 'z' else c for c in x)),
+    ("Bold Script", lambda x: "".join(chr(ord(c) + 0x1D4D0 - 0x41) if 'A' <= c <= 'Z' else chr(ord(c) + 0x1D4EA - 0x61) if 'a' <= c <= 'z' else c for c in x)),
+    ("Fraktur", lambda x: "".join(chr(ord(c) + 0x1D504 - 0x41) if 'A' <= c <= 'Z' else chr(ord(c) + 0x1D51E - 0x61) if 'a' <= c <= 'z' else c for c in x)),
+    ("Bold Fraktur", lambda x: "".join(chr(ord(c) + 0x1D56C - 0x41) if 'A' <= c <= 'Z' else chr(ord(c) + 0x1D586 - 0x61) if 'a' <= c <= 'z' else c for c in x)),
+    ("Double Struck", lambda x: "".join(chr(ord(c) + 0x1D538 - 0x41) if 'A' <= c <= 'Z' else chr(ord(c) + 0x1D552 - 0x61) if 'a' <= c <= 'z' else c for c in x)),
+    ("Sans Serif", lambda x: "".join(chr(ord(c) + 0x1D5A0 - 0x41) if 'A' <= c <= 'Z' else chr(ord(c) + 0x1D5BA - 0x61) if 'a' <= c <= 'z' else c for c in x)),
+    ("Sans Serif Bold", lambda x: "".join(chr(ord(c) + 0x1D5D4 - 0x41) if 'A' <= c <= 'Z' else chr(ord(c) + 0x1D5EE - 0x61) if 'a' <= c <= 'z' else c for c in x)),
+    ("Sans Serif Italic", lambda x: "".join(chr(ord(c) + 0x1D608 - 0x41) if 'A' <= c <= 'Z' else chr(ord(c) + 0x1D622 - 0x61) if 'a' <= c <= 'z' else c for c in x)),
+    ("Sans Serif Bold Italic", lambda x: "".join(chr(ord(c) + 0x1D63C - 0x41) if 'A' <= c <= 'Z' else chr(ord(c) + 0x1D656 - 0x61) if 'a' <= c <= 'z' else c for c in x)),
+    ("Monospace", lambda x: "".join(chr(ord(c) + 0x1D670 - 0x41) if 'A' <= c <= 'Z' else chr(ord(c) + 0x1D68A - 0x61) if 'a' <= c <= 'z' else c for c in x)),
+    ("Circled", lambda x: "".join(chr(ord(c) - 0x41 + 0x24B6) if 'A' <= c <= 'Z' else chr(ord(c) - 0x61 + 0x24D0) if 'a' <= c <= 'z' else c for c in x)),
+    ("Squared", lambda x: "".join(chr(ord(c) - 0x41 + 0x1F130) if 'A' <= c <= 'Z' else c for c in x)),
+    ("Negative Circled", lambda x: "".join(chr(ord(c) - 0x41 + 0x1F150) if 'A' <= c <= 'Z' else c for c in x)),
+    ("Negative Squared", lambda x: "".join(chr(ord(c) - 0x41 + 0x1F170) if 'A' <= c <= 'Z' else c for c in x)),
+    ("Regional Indicator", lambda x: "".join(chr(ord(c) - 0x41 + 0x1F1E6) if 'A' <= c <= 'Z' else c for c in x)),
 ]
 
 server_running = False
 server_task = None
 
-# Helper Functions
+# Timestamp wizardry - clock ticks with flair! ⏰🎩
 def format_timestamp_prefix():
-    """📅 - Time Stamp Champ - Marks the clock, no flop!"""
     return datetime.now().strftime("%Y%m%d_%H%M%S")
 
+# Node naming - christening the beast! 🌐🍼
 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 🌟')
-    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 = parser.parse_args()
+    username = st.session_state.get('username', 'System 🌟')
+    log_action(username, "🌐🍼 - Node naming - christening the beast!")
     return args.node_name or f"node-{uuid.uuid4().hex[:8]}", args.port
 
+# Action logger - spying on deeds! 🕵️📜
 def log_action(username, action):
-    """📜 - Log Jog Blog - Tracks the deed, no greed!"""
     if 'action_log' not in st.session_state:
         st.session_state.action_log = {}
     user_log = st.session_state.action_log.setdefault(username, {})
@@ -112,36 +129,32 @@ def log_action(username, action):
             f.write(f"[{datetime.now().strftime('%Y-%m-%d %H:%M:%S')}] {username}: {action}\n")
         user_log[action] = current_time
 
+# Chat saver - words locked tight! 💬🔒
 async def save_chat_entry(username, message):
-    """📝 - Chat Snap Trap - Logs your yap, no cap! ✍️🧠"""
-    action = "📝 - Chat Snap Trap - Logs your yap, no cap! ✍️🧠"
-    await asyncio.to_thread(log_action, username, action)
+    await asyncio.to_thread(log_action, username, "💬🔒 - Chat saver - words locked tight!")
     timestamp = datetime.now().strftime("%Y-%m-%d %H:%M:%S")
     entry = f"[{timestamp}] {username}: {message}"
     await asyncio.to_thread(lambda: open(CHAT_FILE, 'a').write(f"{entry}\n"))
-    # Generate and save audio for the message
     voice = FUN_USERNAMES.get(username, "en-US-AriaNeural")
     audio_file = await async_edge_tts_generate(message, voice)
     if audio_file:
         with open(HISTORY_FILE, 'a') as f:
             f.write(f"[{timestamp}] {username}: Audio generated - {audio_file}\n")
 
+# Chat loader - history unleashed! 📜🚀
 async def load_chat():
-    """📖 - Chat Fetch Quest - Grabs the log, no jest!"""
-    action = "📖 - Chat Fetch Quest - Grabs the log, no jest!"
     username = st.session_state.get('username', 'System 🌟')
-    await asyncio.to_thread(log_action, username, action)
+    await asyncio.to_thread(log_action, username, "📜🚀 - Chat loader - history unleashed!")
     if not os.path.exists(CHAT_FILE):
         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
 
+# User lister - who’s in the gang! 👥🎉
 async 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)
+    await asyncio.to_thread(log_action, username, "👥🎉 - User lister - who’s in the gang!")
     users = set()
     for line in chat_content.split('\n'):
         if line.strip() and ': ' in line:
@@ -149,26 +162,23 @@ async def get_user_list(chat_content):
             users.add(user)
     return sorted(list(users))
 
+# Join checker - been here before? 🚪🔍
 async def has_joined_before(client_id, chat_content):
-    """🚪 - Join Check Trek - Sees who’s back, no wreck!"""
-    action = "🚪 - Join Check Trek - Sees who’s back, no wreck!"
     username = st.session_state.get('username', 'System 🌟')
-    await asyncio.to_thread(log_action, username, action)
+    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'))
 
+# Suggestion maker - old quips resurface! 💡📝
 async def get_message_suggestions(chat_content, prefix):
-    """🔍 - Suggest Jest Chest - Finds old quips, the best!"""
-    action = "🔍 - Suggest Jest Chest - Finds old quips, the best!"
     username = st.session_state.get('username', 'System 🌟')
-    await asyncio.to_thread(log_action, username, action)
+    await asyncio.to_thread(log_action, username, "💡📝 - Suggestion maker - old quips resurface!")
     lines = chat_content.split('\n')
     messages = [line.split(': ', 1)[1] for line in lines if ': ' in line and line.strip()]
     return [msg for msg in messages if msg.lower().startswith(prefix.lower())][:5]
 
+# Vote saver - cheers recorded! 👍📊
 async def save_vote(file, item, user_hash, username, comment=""):
-    """👍 - Vote Note Float - Cheers rise, we gloat!"""
-    action = "👍 - Vote Note Float - Cheers rise, we gloat!"
-    await asyncio.to_thread(log_action, username, action)
+    await asyncio.to_thread(log_action, username, "👍📊 - Vote saver - cheers recorded!")
     timestamp = datetime.now().strftime("%Y-%m-%d %H:%M:%S")
     entry = f"[{timestamp}] {user_hash} voted for {item}"
     await asyncio.to_thread(lambda: open(file, 'a').write(f"{entry}\n"))
@@ -178,11 +188,10 @@ async def save_vote(file, item, user_hash, username, comment=""):
         chat_message += f" - {comment}"
     await save_chat_entry(username, chat_message)
 
+# Vote counter - tallying the love! 🏆📈
 async def load_votes(file):
-    """🏆 - Tally Rally Call - Counts the cheers, no stall!"""
-    action = "🏆 - Tally Rally Call - Counts the cheers, no stall!"
     username = st.session_state.get('username', 'System 🌟')
-    await asyncio.to_thread(log_action, username, action)
+    await asyncio.to_thread(log_action, username, "🏆📈 - Vote counter - tallying the love!")
     if not os.path.exists(file):
         await asyncio.to_thread(lambda: open(file, 'w').write("# Vote Tally\n\nNo votes yet - get clicking! 🖱️\n"))
     with open(file, 'r') as f:
@@ -199,28 +208,26 @@ async def load_votes(file):
                 user_votes.add(vote_key)
     return votes
 
+# Hash generator - secret codes ahoy! 🔑🕵️
 async def generate_user_hash():
-    """🔑 - Hash Dash Bash - Crafts a code, so brash!"""
-    action = "🔑 - Hash Dash Bash - Crafts a code, so brash!"
     username = st.session_state.get('username', 'System 🌟')
-    await asyncio.to_thread(log_action, username, action)
+    await asyncio.to_thread(log_action, username, "🔑🕵️ - Hash generator - secret codes ahoy!")
     if 'user_hash' not in st.session_state:
         st.session_state.user_hash = hashlib.md5(str(random.getrandbits(128)).encode()).hexdigest()[:8]
     return st.session_state.user_hash
 
+# Audio maker - voices come alive! 🎶🌟
 async def async_edge_tts_generate(text, voice, rate=0, pitch=0, file_format="mp3"):
-    """🎶 - Tune Moon Boom - Drops a beat, so groom!"""
-    action = "🎶 - Tune Moon Boom - Drops a beat, so groom!"
     username = st.session_state.get('username', 'System 🌟')
-    await asyncio.to_thread(log_action, username, action)
+    await asyncio.to_thread(log_action, username, "🎶🌟 - Audio maker - voices come alive!")
     timestamp = format_timestamp_prefix()
     filename = os.path.join(AUDIO_DIR, f"audio_{timestamp}_{random.randint(1000, 9999)}.mp3")
     communicate = edge_tts.Communicate(text, voice, rate=f"{rate:+d}%", pitch=f"{pitch:+d}Hz")
     await communicate.save(filename)
     return filename if os.path.exists(filename) else None
 
+# Audio player - tunes blast off! 🔊🚀
 def play_and_download_audio(file_path):
-    """🔊 - Sound Pound Ground - Plays it loud, all around!"""
     if file_path and os.path.exists(file_path):
         st.audio(file_path)
         with open(file_path, "rb") as f:
@@ -228,11 +235,10 @@ def play_and_download_audio(file_path):
         dl_link = f'<a href="data:audio/mpeg;base64,{b64}" download="{os.path.basename(file_path)}">🎵 Download {os.path.basename(file_path)}</a>'
         st.markdown(dl_link, unsafe_allow_html=True)
 
+# Image saver - pics preserved! 📸💾
 async def save_pasted_image(image_data):
-    """📸 - Snap Cap Trap - Saves your pic, no flap!"""
-    action = "📸 - Snap Cap Trap - Saves your pic, no flap!"
     username = st.session_state.get('username', 'System 🌟')
-    await asyncio.to_thread(log_action, username, action)
+    await asyncio.to_thread(log_action, username, "📸💾 - Image saver - pics preserved!")
     timestamp = format_timestamp_prefix()
     filename = f"paste_{timestamp}.png"
     filepath = os.path.join('./', filename)
@@ -243,29 +249,26 @@ async def save_pasted_image(image_data):
     await asyncio.to_thread(img.save, filepath, "PNG")
     return filename
 
+# Video renderer - movies roll! 🎥🎬
 async def get_video_html(video_path, width="100%"):
-    """🎥 - Reel Deal Steal - Plays your flick, so real!"""
-    action = "🎥 - Reel Deal Steal - Plays your flick, so real!"
     username = st.session_state.get('username', 'System 🌟')
-    await asyncio.to_thread(log_action, username, action)
+    await asyncio.to_thread(log_action, username, "🎥🎬 - Video renderer - movies roll!")
     video_url = f"data:video/mp4;base64,{base64.b64encode(await asyncio.to_thread(open, video_path, 'rb').read()).decode()}"
     return f'<video width="{width}" controls autoplay muted loop><source src="{video_url}" type="video/mp4">Your browser does not support the video tag.</video>'
 
+# Audio renderer - sounds soar! 🎶✈️
 async def get_audio_html(audio_path, width="100%"):
-    """🎶 - Tune Moon Boom - Drops a beat, so groom!"""
-    action = "🎶 - Tune Moon Boom - Drops a beat, so groom!"
     username = st.session_state.get('username', 'System 🌟')
-    await asyncio.to_thread(log_action, username, action)
+    await asyncio.to_thread(log_action, username, "🎶✈️ - Audio renderer - sounds soar!")
     audio_url = f"data:audio/mpeg;base64,{base64.b64encode(await asyncio.to_thread(open, audio_path, 'rb').read()).decode()}"
     return f'<audio controls style="width: {width};"><source src="{audio_url}" type="audio/mpeg">Your browser does not support the audio element.</audio>'
 
 active_connections = {}
 
+# Websocket handler - chat links up! 🌐🔗
 async def websocket_handler(websocket, path):
-    """🌐 - Web Sock Jock - Links the chat, no block!"""
-    action = "🌐 - Web Sock Jock - Links the chat, no block!"
     username = st.session_state.get('username', 'System 🌟')
-    await asyncio.to_thread(log_action, username, action)
+    await asyncio.to_thread(log_action, username, "🌐🔗 - Websocket handler - chat links up!")
     try:
         client_id = str(uuid.uuid4())
         room_id = "chat"
@@ -286,11 +289,10 @@ async def websocket_handler(websocket, path):
         if room_id in active_connections and client_id in active_connections[room_id]:
             del active_connections[room_id][client_id]
 
+# Message broadcaster - words fly far! 📢✈️
 async def broadcast_message(message, room_id):
-    """📢 - Shout Out Bout - Blasts the word, no doubt!"""
-    action = "📢 - Shout Out Bout - Blasts the word, no doubt!"
     username = st.session_state.get('username', 'System 🌟')
-    await asyncio.to_thread(log_action, username, action)
+    await asyncio.to_thread(log_action, username, "📢✈️ - Message broadcaster - words fly far!")
     if room_id in active_connections:
         disconnected = []
         for client_id, ws in active_connections[room_id].items():
@@ -301,33 +303,28 @@ async def broadcast_message(message, room_id):
         for client_id in disconnected:
             del active_connections[room_id][client_id]
 
+# Server starter - web spins up! 🖥️🌀
 async def run_websocket_server():
-    """🖥️ - Server Ferver Verve - Spins the web, with nerve!"""
-    action = "🖥️ - Server Ferver Verve - Spins the web, with nerve!"
     username = st.session_state.get('username', 'System 🌟')
-    await asyncio.to_thread(log_action, username, action)
+    await asyncio.to_thread(log_action, username, "🖥️🌀 - Server starter - web spins up!")
     global server_running, server_task
     if not server_running:
         server = await websockets.serve(websocket_handler, '0.0.0.0', 8765)
         server_running = True
         await server.wait_closed()
 
+# Voice processor - speech to text! 🎤📝
 async def process_voice_input(audio_bytes):
-    """🎤 - Voice Choice Rejoice - Speaks your mind, oh boy!"""
-    action = "🎤 - Voice Choice Rejoice - Speaks your mind, oh boy!"
     username = st.session_state.get('username', 'System 🌟')
-    await asyncio.to_thread(log_action, username, action)
+    await asyncio.to_thread(log_action, username, "🎤📝 - Voice processor - speech to text!")
     if audio_bytes:
-        # Simple placeholder for speech-to-text (requires additional library like `speech_recognition`)
-        # For now, we'll simulate text input from audio
         text = "Voice input simulation"  # Replace with actual speech-to-text logic
         await save_chat_entry(username, text)
 
+# Interface builder - UI takes shape! 🎨🖌️
 async 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)
+    await asyncio.to_thread(log_action, username, "🎨🖌️ - Interface builder - UI takes shape!")
 
     if 'username' not in st.session_state:
         chat_content = await load_chat()
@@ -410,9 +407,7 @@ async def create_streamlit_interface():
         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!"""
-                action = "📢 - Quote Float Boat - Echoes chat, we gloat!"
-                await asyncio.to_thread(log_action, st.session_state.username, action)
+                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)
@@ -425,7 +420,7 @@ async def create_streamlit_interface():
             st.session_state.message_text = ''
             st.rerun()
 
-    # Username Change Dropdown
+    # Username changer
     new_username = st.selectbox("Change Name", [""] + list(FUN_USERNAMES.keys()), 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}")
@@ -530,16 +525,13 @@ async def create_streamlit_interface():
         history_content = f.read()
     st.sidebar.markdown(history_content)
 
-async def main():
-    """🎮 - Game Fame Claim - Starts the fun, no shame!"""
-    action = "🎮 - Game Fame Claim - Starts the fun, no shame!"
-    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()
-    if server_task is None:
-        server_task = asyncio.create_task(run_websocket_server())
-    await create_streamlit_interface()
-
-if __name__ == "__main__":
-    asyncio.run(main())
+# Main execution
+NODE_NAME, port = get_node_name()
+server_task = None
+
+# Start the websocket server
+if server_task is None:
+    server_task = asyncio.create_task(run_websocket_server())
+
+# Run the interface
+asyncio.run(create_streamlit_interface())