Update app.py

app.py

@@ -10,126 +10,232 @@ import time
 import hashlib
 from PIL import Image
 import glob
-import re
-from urllib.parse import quote
 import base64
 import io
+import streamlit.components.v1 as components
+import edge_tts
+from audio_recorder_streamlit import audio_recorder
+import nest_asyncio
+import re
+from streamlit_paste_button import paste_image_button
+import pytz
+import shutil
+
+# Patch for nested async - sneaky fix! 🐍✨
+nest_asyncio.apply()
 
-# App Configuration
-Site_Name = '🤖🧠MMO Chat Brain📝🔬'
-title = "🤖🧠MMO Chat Brain📝🔬"
+# Static config - constants rule! 📏👑
 icons = '🤖🧠🔬📝'
 START_ROOM = "Sector 🌌"
 
+# Page setup - dressing up the window! 🖼️🎀
 st.set_page_config(
-    page_title=title,
+    page_title="🤖🧠MMO Chat Brain📝🔬",
     page_icon=icons,
     layout="wide",
     initial_sidebar_state="auto"
 )
 
-# Fun usernames with emojis and rhyming labels - the VIP list of quirky characters! 🎉😜
+# Funky usernames with corresponding Edge TTS voices
 FUN_USERNAMES = {
-    "CosmicJester 🌌": "Jest Best",
-    "PixelPanda 🐼": "Panda Dandy",
-    "QuantumQuack 🦆": "Quack Pack",
-    "StellarSquirrel 🐿️": "Squirrel Whirl",
-    "GizmoGuru ⚙️": "Guru Brew",
-    "NebulaNinja 🌠": "Ninja Zinger",
-    "ByteBuster 💾": "Buster Cluster",
-    "GalacticGopher 🌍": "Gopher Loafer",
-    "RocketRaccoon 🚀": "Raccoon Zoom",
-    "EchoElf 🧝": "Elf Shelf",
-    "PhantomFox 🦊": "Fox Rocks",
-    "WittyWizard 🧙": "Wizard Blizzard",
-    "LunarLlama 🌙": "Llama Drama",
-    "SolarSloth ☀️": "Sloth Growth",
-    "AstroAlpaca 🦙": "Alpaca Plaque",
-    "CyberCoyote 🐺": "Coyote Byte",
-    "MysticMoose 🦌": "Moose Juice",
-    "GlitchGnome 🧚": "Gnome Roam",
-    "VortexViper 🐍": "Viper Hyper",
-    "ChronoChimp 🐒": "Chimp Whimp"
+    "CosmicJester 🌌": "en-US-AriaNeural",
+    "PixelPanda 🐼": "en-US-JennyNeural",
+    "QuantumQuack 🦆": "en-GB-SoniaNeural",
+    "StellarSquirrel 🐿️": "en-AU-NatashaNeural",
+    "GizmoGuru ⚙️": "en-CA-ClaraNeural",
+    "NebulaNinja 🌠": "en-US-GuyNeural",
+    "ByteBuster 💾": "en-GB-RyanNeural",
+    "GalacticGopher 🌍": "en-AU-WilliamNeural",
+    "RocketRaccoon 🚀": "en-CA-LiamNeural",
+    "EchoElf 🧝": "en-US-AnaNeural",
+    "PhantomFox 🦊": "en-US-BrandonNeural",
+    "WittyWizard 🧙": "en-GB-ThomasNeural",
+    "LunarLlama 🌙": "en-AU-FreyaNeural",
+    "SolarSloth ☀️": "en-CA-LindaNeural",
+    "AstroAlpaca 🦙": "en-US-ChristopherNeural",
+    "CyberCoyote 🐺": "en-GB-ElliotNeural",
+    "MysticMoose 🦌": "en-AU-JamesNeural",
+    "GlitchGnome 🧚": "en-CA-EthanNeural",
+    "VortexViper 🐍": "en-US-AmberNeural",
+    "ChronoChimp 🐒": "en-GB-LibbyNeural"
 }
 
-# Directories for chat and votes - the secret vaults where treasures are stashed! 🗄️🔒
+# Folders galore - organizing chaos! 📂🌀
 CHAT_DIR = "chat_logs"
 VOTE_DIR = "vote_logs"
 STATE_FILE = "user_state.txt"
+AUDIO_DIR = "audio_logs"
+HISTORY_DIR = "history_logs"
+MEDIA_DIR = "media_files"
 os.makedirs(CHAT_DIR, exist_ok=True)
 os.makedirs(VOTE_DIR, exist_ok=True)
+os.makedirs(AUDIO_DIR, exist_ok=True)
+os.makedirs(HISTORY_DIR, exist_ok=True)
+os.makedirs(MEDIA_DIR, exist_ok=True)
 
-# Persistent files - the grand tomes of chatter and votes! 📖✨
 CHAT_FILE = os.path.join(CHAT_DIR, "global_chat.md")
 QUOTE_VOTES_FILE = os.path.join(VOTE_DIR, "quote_votes.md")
-IMAGE_VOTES_FILE = os.path.join(VOTE_DIR, "image_votes.md")
-HISTORY_FILE = os.path.join(VOTE_DIR, "vote_history.md")
+MEDIA_VOTES_FILE = os.path.join(VOTE_DIR, "media_votes.md")
+HISTORY_FILE = os.path.join(HISTORY_DIR, "chat_history.md")
 
-# Unicode digit conversion table - the magic map for emoji numbers! 🔢✨
-UNICODE_DIGITS = {
-    0: "0️⃣", 1: "1️⃣", 2: "2️⃣", 3: "3️⃣", 4: "4️⃣",
-    5: "5️⃣", 6: "6️⃣", 7: "7️⃣", 8: "8️⃣", 9: "9️⃣"
-}
+# Fancy digits - numbers got style! 🔢💃
+UNICODE_DIGITS = {i: f"{i}\uFE0F⃣" for i in range(10)}
 
-# Unicode font examples - the stylish wardrobe of text flair! 👗📝
+# 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 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)),
-    ("Mono", 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)),
-    ("Circle", lambda x: "".join(chr(ord(c) + 0x24B6 - 0x41) if 'A' <= c <= 'Z' else chr(ord(c) + 0x24D0 - 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)),
 ]
 
-# Global WebSocket server flag
-server_running = False
-server_task = None
+# Global state - keeping tabs! 🌍📋
+if 'server_running' not in st.session_state:
+    st.session_state.server_running = False
+if 'server_task' not in st.session_state:
+    st.session_state.server_task = None
+if 'active_connections' not in st.session_state:
+    st.session_state.active_connections = {}
+if 'media_notifications' not in st.session_state:
+    st.session_state.media_notifications = []
+if 'last_chat_update' not in st.session_state:
+    st.session_state.last_chat_update = 0
+if 'displayed_chat_lines' not in st.session_state:
+    st.session_state.displayed_chat_lines = []
+if 'old_val' not in st.session_state:
+    st.session_state.old_val = ""
+if 'last_query' not in st.session_state:
+    st.session_state.last_query = ""
+if 'message_text' not in st.session_state:
+    st.session_state.message_text = ""
+if 'audio_cache' not in st.session_state:
+    st.session_state.audio_cache = {}
+if 'pasted_image_data' not in st.session_state:
+    st.session_state.pasted_image_data = None
+if 'quote_line' not in st.session_state:
+    st.session_state.quote_line = None
+if 'refresh_rate' not in st.session_state:
+    st.session_state.refresh_rate = 5
+if 'base64_cache' not in st.session_state:
+    st.session_state.base64_cache = {}
+if 'transcript_history' not in st.session_state:
+    st.session_state.transcript_history = []
+if 'last_transcript' not in st.session_state:
+    st.session_state.last_transcript = ""
+if 'image_hashes' not in st.session_state:
+    st.session_state.image_hashes = set()
+if 'gallery_columns' not in st.session_state:
+    st.session_state.gallery_columns = 1  # Default gallery tiles
+
+# Timestamp wizardry - clock ticks with flair! ⏰🎩
+def format_timestamp_prefix(username):
+    central = pytz.timezone('US/Central')
+    now = datetime.now(central)
+    return f"{now.strftime('%I-%M-%p-ct-%m-%d-%Y')}-by-{username}"
+
+# Compute image hash from binary data
+def compute_image_hash(image_data):
+    if isinstance(image_data, Image.Image):
+        img_byte_arr = io.BytesIO()
+        image_data.save(img_byte_arr, format='PNG')
+        img_bytes = img_byte_arr.getvalue()
+    else:
+        img_bytes = image_data
+    return hashlib.md5(img_bytes).hexdigest()[:8]
 
-# Node name - the app’s codename generator, sneaky and slick! 🕵️‍♂️💾
+# Node naming - christening the beast! 🌐🍼
 def get_node_name():
-    """🎲 Spins the wheel of fate to name our node - a random alias or user pick! 🏷️"""
     parser = argparse.ArgumentParser(description='Start a chat node with a specific name')
-    parser.add_argument('--node-name', type=str, default=None, help='Name for this chat node')
-    parser.add_argument('--port', type=int, default=8501, help='Port to run the Streamlit interface on')
+    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
 
-# Chat saver - the scribe etching epic messages into the eternal scroll! 🖋️📜
-def save_chat_entry(username, message):
-    """🖌️ Carves a chat line into the grand Markdown tome - history in the making! 🏛️"""
-    timestamp = datetime.now().strftime("%Y-%m-%d %H:%M:%S")
-    entry = f"[{timestamp}] {username}: {message}"
-    try:
-        with open(CHAT_FILE, 'a') as f:
-            f.write(f"{entry}\n")
-        return True
-    except Exception as e:
-        print(f"Oops! Failed to save chat: {e}")
-        return False
-
-# Chat loader - the archaeologist unearthing the chat saga! ⛏️📚
-def load_chat():
-    """🔍 Digs up the chat treasure from the filesystem - tales of old and new! 💰"""
+# Action logger - spying on deeds! 🕵️📜
+def log_action(username, action):
+    if 'action_log' not in st.session_state:
+        st.session_state.action_log = {}
+    user_log = st.session_state.action_log.setdefault(username, {})
+    current_time = time.time()
+    user_log = {k: v for k, v in user_log.items() if current_time - v < 10}
+    st.session_state.action_log[username] = user_log
+    if action not in user_log:
+        central = pytz.timezone('US/Central')
+        with open(HISTORY_FILE, 'a') as f:
+            f.write(f"[{datetime.now(central).strftime('%Y-%m-%d %H:%M:%S')}] {username}: {action}\n")
+        user_log[action] = current_time
+
+# Clean text - strip the fancy stuff! 🧹📝
+def clean_text_for_tts(text):
+    cleaned = re.sub(r'[#*!\[\]]+', '', text)
+    cleaned = ' '.join(cleaned.split())
+    return cleaned[:200] if cleaned else "No text to speak"
+
+# Chat saver - words locked tight! 💬🔒
+async def save_chat_entry(username, message, is_markdown=False):
+    await asyncio.to_thread(log_action, username, "💬🔒 - Chat saver - words locked tight!")
+    central = pytz.timezone('US/Central')
+    timestamp = datetime.now(central).strftime("%Y-%m-%d %H:%M:%S")
+    if is_markdown:
+        entry = f"[{timestamp}] {username}:\n```markdown\n{message}\n```"
+    else:
+        entry = f"[{timestamp}] {username}: {message}"
+    await asyncio.to_thread(lambda: open(CHAT_FILE, 'a').write(f"{entry}\n"))
+    voice = st.session_state.voice if username == st.session_state.username else FUN_USERNAMES.get(username, "en-US-AriaNeural")
+    cleaned_message = clean_text_for_tts(message)
+    audio_file = await async_edge_tts_generate(cleaned_message, voice)
+    if audio_file:
+        with open(HISTORY_FILE, 'a') as f:
+            f.write(f"[{timestamp}] {username} ({voice}): Audio generated - {audio_file}\n")
+    await broadcast_message(f"{username}|{message}", "chat")
+    st.session_state.last_chat_update = time.time()
+    return audio_file
+
+# Save chat history with image
+async def save_chat_history_with_image(username, image_path):
+    central = pytz.timezone('US/Central')
+    timestamp = datetime.now(central).strftime("%Y-%m-%d_%H-%M-%S")
+    history_filename = f"chat_history_{timestamp}-by-{username}.md"
+    history_filepath = os.path.join(HISTORY_DIR, history_filename)
+    chat_content = await load_chat()
+    voice = st.session_state.voice if username == st.session_state.username else FUN_USERNAMES.get(username, "en-US-AriaNeural")
+    with open(history_filepath, 'w') as f:
+        f.write(f"# Chat History at {timestamp} by {username} (Voice: {voice})\n\n")
+        f.write(f"## Image Shared: {os.path.basename(image_path)}\n")
+        f.write(chat_content)
+    return history_filepath
+
+# Chat loader - history unleashed! 📜🚀
+async def load_chat():
+    username = st.session_state.get('username', 'System 🌟')
+    await asyncio.to_thread(log_action, username, "📜🚀 - Chat loader - history unleashed!")
     if not os.path.exists(CHAT_FILE):
-        with open(CHAT_FILE, 'w') as f:
-            f.write(f"# {START_ROOM} Chat\n\nWelcome to the cosmic hub - start chatting! 🎤\n")
-    try:
-        with open(CHAT_FILE, 'r') as f:
-            content = f.read()
-        lines = content.strip().split('\n')
-        numbered_content = "\n".join(f"{i+1}. {line}" for i, line in enumerate(lines) if line.strip())
-        return numbered_content
-    except Exception as e:
-        print(f"Chat load hiccup: {e}")
-        return f"# Error loading {START_ROOM} chat\nSomething went wonky! 😵"
-
-# User list grabber - the social butterfly spotting all the chatters! 🦋👥
-def get_user_list(chat_content):
-    """👀 Peeks at the chat to spot all the cool cats talking - who’s in the club? 🎸"""
+        await asyncio.to_thread(lambda: open(CHAT_FILE, 'a').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):
+    username = st.session_state.get('username', 'System 🌟')
+    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:
@@ -137,129 +243,107 @@ def get_user_list(chat_content):
             users.add(user)
     return sorted(list(users))
 
-# Message suggestion loader - the oracle of past chats! 🔮💬
-def get_message_suggestions(chat_content, prefix):
-    """🔮 Pulls past messages from the cosmic archives for autocomplete magic! ✨"""
+# Join checker - been here before? 🚪🔍
+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}" in line for line in chat_content.split('\n'))
+
+# Suggestion maker - old quips resurface! 💡📝
+async def get_message_suggestions(chat_content, prefix):
+    username = st.session_state.get('username', 'System 🌟')
+    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]  # Top 5 matches
-
-# Quote loader - the sage pulling wisdom from the ages! 📜🧙
-def load_quotes(source="famous"):
-    """📚 Grabs a stack of wise words from famous folks or custom quips! 🗣️"""
-    famous_quotes = [
-        "The true sign of intelligence is not knowledge but imagination. – Albert Einstein",
-        "I have not failed. I've just found 10,000 ways that won't work. – Thomas Edison",
-        "Innovation distinguishes between a leader and a follower. – Steve Jobs",
-        "Research is what I'm doing when I don't know what I'm doing. – Wernher von Braun",
-        "The only way to discover the limits of the possible is to go beyond them into the impossible. – Arthur C. Clarke",
-        "Success is a science; if you have the conditions, you get the result. – Oscar Wilde",
-        "An expert is a person who has made all the mistakes that can be made in a very narrow field. – Niels Bohr",
-        "The important thing is to not stop questioning. Curiosity has its own reason for existing. – Albert Einstein",
-        "The best way to predict the future is to invent it. – Alan Kay",
-        "If I have seen further it is by standing on the shoulders of Giants. – Isaac Newton",
-        "Logic will get you from A to B. Imagination will take you everywhere. – Albert Einstein",
-        "Imagination is more important than knowledge. Knowledge is limited. Imagination encircles the world. – Albert Einstein",
-        "Science is a way of thinking much more than it is a body of knowledge. – Carl Sagan",
-        "We cannot solve our problems with the same thinking we used when we created them. – Albert Einstein",
-        "The true method of knowledge is experiment. – William Blake",
-        "The scientist is not a person who gives the right answers, he's one who asks the right questions. – Claude Levi-Strauss",
-        "It's kind of fun to do the impossible. – Walt Disney",
-        "Any sufficiently advanced technology is indistinguishable from magic. – Arthur C. Clarke",
-        "Creativity is intelligence having fun. – Albert Einstein",
-        "To invent, you need a good imagination and a pile of junk. – Thomas Edison"
-    ]
-    custom_quotes = [
-        "Every age unfolds a new lesson. Life's chapters evolve, each teaching us anew.",
-        "From infancy to twilight, our journey is painted in growth. Every stage shines with its own wisdom.",
-        "Love is the universal language, transcending boundaries and touching souls.",
-        "Through love, we find connection, unity, and the essence of existence."
-    ]
-    quotes = famous_quotes if source == "famous" else custom_quotes
-    return quotes if quotes else ["No quotes available - check back later! 📭"]
-
-# Vote saver - the tally keeper counting thumbs up! 👍📊
-def save_vote(file, item, user_hash):
-    """✍️ Tallies a vote in the grand ledger - your opinion matters! 🗳️"""
-    timestamp = datetime.now().strftime("%Y-%m-%d %H:%M:%S")
+    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=""):
+    await asyncio.to_thread(log_action, username, "👍📊 - Vote saver - cheers recorded!")
+    central = pytz.timezone('US/Central')
+    timestamp = datetime.now(central).strftime("%Y-%m-%d %H:%M:%S")
     entry = f"[{timestamp}] {user_hash} voted for {item}"
-    try:
-        with open(file, 'a') as f:
-            f.write(f"{entry}\n")
-        with open(HISTORY_FILE, 'a') as f:
-            f.write(f"- {timestamp} - User {user_hash} voted for {item}\n")
-        return True
-    except Exception as e:
-        print(f"Vote save flop: {e}")
-        return False
-
-# Vote loader - the scorekeeper tallying the crowd’s cheers! 🎉🏅
-def load_votes(file):
-    """📈 Counts the votes from the ledger - who’s winning the popularity contest? 🏆"""
+    await asyncio.to_thread(lambda: open(file, 'a').write(f"{entry}\n"))
+    await asyncio.to_thread(lambda: open(HISTORY_FILE, "a").write(f"- {timestamp} - User {user_hash} voted for {item}\n"))
+    chat_message = f"{username} upvoted: \"{item}\""
+    if comment:
+        chat_message += f" - {comment}"
+    await save_chat_entry(username, chat_message)
+
+# Vote counter - tallying the love! 🏆📈
+async def load_votes(file):
+    username = st.session_state.get('username', 'System 🌟')
+    await asyncio.to_thread(log_action, username, "🏆📈 - Vote counter - tallying the love!")
     if not os.path.exists(file):
-        with open(file, 'w') as f:
-            f.write("# Vote Tally\n\nNo votes yet - get clicking! 🖱️\n")
-    try:
-        with open(file, 'r') as f:
-            lines = f.read().strip().split('\n')
-        votes = {}
-        for line in lines[2:]:  # Skip header
-            if line.strip() and 'voted for' in line:
-                item = line.split('voted for ')[1]
+        await asyncio.to_thread(lambda: open(file, 'w').write("# Vote Tally\n\nNo votes yet - get clicking! 🖱️\n"))
+    with open(file, 'r') as f:
+        content = await asyncio.to_thread(f.read)
+        lines = content.strip().split('\n')[2:]
+    votes = {}
+    user_votes = set()
+    for line in lines:
+        if line.strip() and 'voted for' in line:
+            user_hash = line.split('] ')[1].split(' voted for ')[0]
+            item = line.split('voted for ')[1]
+            vote_key = f"{user_hash}-{item}"
+            if vote_key not in user_votes:
                 votes[item] = votes.get(item, 0) + 1
-        return votes
-    except Exception as e:
-        print(f"Vote load oopsie: {e}")
-        return {}
-
-# User hash generator - the secret agent giving you a cool code! 🕵️‍♂️🔑
-def generate_user_hash():
-    """🕵️ Crafts a snazzy 8-digit ID badge - you’re in the club now! 🎟️"""
+                user_votes.add(vote_key)
+    return votes
+
+# Hash generator - secret codes ahoy! 🔑🕵️
+async def generate_user_hash():
+    username = st.session_state.get('username', 'System 🌟')
+    await asyncio.to_thread(log_action, username, "🔑🕵️ - Hash generator - secret codes ahoy!")
     if 'user_hash' not in st.session_state:
-        session_id = str(random.getrandbits(128))
-        hash_object = hashlib.md5(session_id.encode())
-        st.session_state['user_hash'] = hash_object.hexdigest()[:8]
-    return st.session_state['user_hash']
-
-# Username persistence - save and load across refreshes! 💾🔄
-def save_username(username):
-    """💾 Stashes your cosmic alias before the refresh void claims it! 🌌"""
-    try:
-        with open(STATE_FILE, 'w') as f:
-            f.write(username)
-    except Exception as e:
-        print(f"Failed to save username: {e}")
-
-def load_username():
-    """🔄 Resurrects your cosmic alias from the refresh abyss! 🌠"""
-    if os.path.exists(STATE_FILE):
-        try:
-            with open(STATE_FILE, 'r') as f:
-                return f.read().strip()
-        except Exception as e:
-            print(f"Failed to load username: {e}")
-    return None
-
-# Image paste handler - the cosmic courier delivering pasted pics! 📸🚀
-def save_pasted_image(image_data):
-    """📸 Saves a pasted image to the root vault with a cosmic name! 🌠"""
-    timestamp = datetime.now().strftime("%Y%m%d_%H%M%S")
-    filename = f"paste_{timestamp}.png"
-    filepath = os.path.join('./', filename)  # Root directory
+        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"):
+    username = st.session_state.get('username', 'System 🌟')
+    await asyncio.to_thread(log_action, username, "🎶🌟 - Audio maker - voices come alive!")
+    timestamp = format_timestamp_prefix(username)
+    filename = f"{timestamp}.{file_format}"
+    filepath = os.path.join(AUDIO_DIR, filename)
+    communicate = edge_tts.Communicate(text, voice, rate=f"{rate:+d}%", pitch=f"{pitch:+d}Hz")
     try:
-        if ',' in image_data:
-            image_data = image_data.split(',')[1]
-        img_bytes = base64.b64decode(image_data)
-        img = Image.open(io.BytesIO(img_bytes))
-        img.save(filepath, "PNG")
-        return filename
-    except Exception as e:
-        print(f"Failed to save pasted image: {e}")
+        await communicate.save(filepath)
+        return filepath if os.path.exists(filepath) else None
+    except edge_tts.exceptions.NoAudioReceived:
+        with open(HISTORY_FILE, 'a') as f:
+            central = pytz.timezone('US/Central')
+            f.write(f"[{datetime.now(central).strftime('%Y-%m-%d %H:%M:%S')}] {username}: Audio failed - No audio received for '{text}'\n")
         return None
 
-# Media HTML generators - IVA’s multimedia magic! 🎥🎶🖼️
+# Audio player - tunes blast off! 🔊🚀
+def play_and_download_audio(file_path):
+    if file_path and os.path.exists(file_path):
+        st.audio(file_path)
+        if file_path not in st.session_state.base64_cache:
+            with open(file_path, "rb") as f:
+                b64 = base64.b64encode(f.read()).decode()
+            st.session_state.base64_cache[file_path] = b64
+        b64 = st.session_state.base64_cache[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 with naming! 📸💾
+async def save_pasted_image(image, username):
+    await asyncio.to_thread(log_action, username, "📸💾 - Image saver - pics preserved!")
+    img_hash = compute_image_hash(image)
+    if img_hash in st.session_state.image_hashes:
+        return None
+    timestamp = format_timestamp_prefix(username)
+    filename = f"{timestamp}-{img_hash}.png"
+    filepath = os.path.join(MEDIA_DIR, filename)
+    await asyncio.to_thread(image.save, filepath, "PNG")
+    st.session_state.image_hashes.add(img_hash)
+    await save_chat_history_with_image(username, filepath)
+    return filepath
+
+# Video renderer verbatim from your last version - movies roll with autoplay! 🎥🎬
 def get_video_html(video_path, width="100%"):
-    """🎬 Rolls out the red carpet for videos - autoplay and loop like a star! 🌟"""
     video_url = f"data:video/mp4;base64,{base64.b64encode(open(video_path, 'rb').read()).decode()}"
     return f'''
     <video width="{width}" controls autoplay muted loop>
@@ -268,320 +352,474 @@ def get_video_html(video_path, width="100%"):
     </video>
     '''
 
-def get_audio_html(audio_path, width="100%"):
-    """🎶 Drops a beat with audio - your personal DJ in action! 🎧"""
-    audio_url = f"data:audio/mpeg;base64,{base64.b64encode(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 = {}
+# Audio renderer - sounds soar! 🎶✈️
+async def get_audio_html(audio_path, width="100%"):
+    username = st.session_state.get('username', 'System 🌟')
+    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>'
 
-# WebSocket handler - the bouncer at the Sector rave, keeping it hopping! 🎉🚪
+# Websocket handler - chat links up! 🌐🔗
 async def websocket_handler(websocket, path):
-    """🎧 Guards the cosmic gate, welcoming all to Sector and booting crashers! 🚨"""
+    username = st.session_state.get('username', 'System 🌟')
+    await asyncio.to_thread(log_action, username, "🌐🔗 - Websocket handler - chat links up!")
     try:
         client_id = str(uuid.uuid4())
-        room_id = "chat"  # Single room "Sector 🌌"
-        active_connections.setdefault(room_id, {})[client_id] = websocket
-        print(f"Client {client_id} joined the Sector party!")
+        room_id = "chat"
+        st.session_state.active_connections.setdefault(room_id, {})[client_id] = websocket
+        chat_content = await load_chat()
         username = st.session_state.get('username', random.choice(list(FUN_USERNAMES.keys())))
-        save_chat_entry("System 🌟", f"{username} has joined {START_ROOM}!")
-
+        if not await has_joined_before(client_id, chat_content):
+            await save_chat_entry(f"Client-{client_id}", f"{username} has joined {START_ROOM}!")
         async for message in websocket:
-            try:
-                parts = message.split('|', 1)
-                if len(parts) == 2:
-                    username, content = parts
-                    save_chat_entry(username, content)
-                    await broadcast_message(f"{username}|{content}", room_id)
-            except Exception as e:
-                print(f"Message mishap: {e}")
-                await websocket.send(f"ERROR|Oops, bad message format! 😬")
+            parts = message.split('|', 1)
+            if len(parts) == 2:
+                username, content = parts
+                await save_chat_entry(username, content)
     except websockets.ConnectionClosed:
-        print(f"Client {client_id} bailed from Sector!")
-        save_chat_entry("System 🌟", f"{username} has left {START_ROOM}!")
+        pass
     finally:
-        if room_id in active_connections and client_id in active_connections[room_id]:
-            del active_connections[room_id][client_id]
-            if not active_connections[room_id]:
-                del active_connections[room_id]
+        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]
 
-# Broadcaster - the megaphone blasting Sector vibes to all! 📣🎶
+# Message broadcaster - words fly far! 📢✈️
 async def broadcast_message(message, room_id):
-    """📢 Shouts the latest Sector beat to every cosmic dancer - hear it loud! 🎵"""
-    if room_id in active_connections:
+    username = st.session_state.get('username', 'System 🌟')
+    await asyncio.to_thread(log_action, username, "📢✈️ - Message broadcaster - words fly far!")
+    if room_id in st.session_state.active_connections:
         disconnected = []
-        for client_id, ws in active_connections[room_id].items():
+        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:
-            del active_connections[room_id][client_id]
+            del st.session_state.active_connections[room_id][client_id]
 
-# WebSocket server runner - the DJ spinning up the Sector tunes once! 🎧🔥
+# Server starter - web spins up! 🖥️🌀
 async def run_websocket_server():
-    """🌐 Cranks up the WebSocket jukebox once, keeping Sector rocking! 🎸"""
-    global server_running, server_task
-    if not server_running:
+    username = st.session_state.get('username', 'System 🌟')
+    await asyncio.to_thread(log_action, username, "🖥️🌀 - Server starter - web spins up!")
+    if not st.session_state.server_running:
         server = await websockets.serve(websocket_handler, '0.0.0.0', 8765)
-        print(f"WebSocket server jamming on ws://0.0.0.0:8765")
-        server_running = True
+        st.session_state.server_running = True
         await server.wait_closed()
 
-# Chat interface maker - the stage builder for our Sector extravaganza! 🎭🏟️
-def create_streamlit_interface(initial_username):
-    """🖌️ Sets up the Sector stage with pulsing timers, voting, and IVA media flair! 🌟"""
-    # Custom CSS and JS for chat box, timer, and paste detection
-    st.markdown("""
-        <style>
-        .chat-box {
-            font-family: monospace;
-            background: #1e1e1e;
-            color: #d4d4d4;
+# Voice processor - speech to text! 🎤📝
+async def process_voice_input(audio_bytes):
+    username = st.session_state.get('username', 'System 🌟')
+    await asyncio.to_thread(log_action, username, "🎤📝 - Voice processor - speech to text!")
+    if audio_bytes:
+        text = "Voice input simulation"
+        await save_chat_entry(username, text)
+
+# Dummy AI lookup function (replace with actual implementation)
+async def perform_ai_lookup(query, vocal_summary=True, extended_refs=False, titles_summary=True, full_audio=False, useArxiv=True, useArxivAudio=False):
+    username = st.session_state.get('username', 'System 🌟')
+    result = f"AI Lookup Result for '{query}' (Arxiv: {useArxiv}, Audio: {useArxivAudio})"
+    await save_chat_entry(username, result)
+    if useArxivAudio:
+        audio_file = await async_edge_tts_generate(result, st.session_state.voice)
+        if audio_file:
+            st.audio(audio_file)
+
+# Delete all user files function
+def delete_user_files():
+    protected_files = {'app.py', 'requirements.txt', 'README.md'}
+    deleted_files = []
+    directories = [MEDIA_DIR, AUDIO_DIR, CHAT_DIR, VOTE_DIR, HISTORY_DIR]
+    for directory in directories:
+        if os.path.exists(directory):
+            for root, _, files in os.walk(directory):
+                for file in files:
+                    file_path = os.path.join(root, file)
+                    if os.path.basename(file_path) not in protected_files:
+                        try:
+                            os.remove(file_path)
+                            deleted_files.append(file_path)
+                        except Exception as e:
+                            st.error(f"Failed to delete {file_path}: {e}")
+            try:
+                shutil.rmtree(directory, ignore_errors=True)
+                os.makedirs(directory, exist_ok=True)
+            except Exception as e:
+                st.error(f"Failed to remove directory {directory}: {e}")
+    st.session_state.image_hashes.clear()
+    st.session_state.audio_cache.clear()
+    st.session_state.base64_cache.clear()
+    st.session_state.displayed_chat_lines.clear()
+    return deleted_files
+
+# ASR Component HTML
+ASR_HTML = """
+<html>
+<head>
+    <title>Continuous Speech Demo</title>
+    <style>
+        body { 
+            font-family: sans-serif; 
+            padding: 20px; 
+            max-width: 800px;
+            margin: 0 auto;
+        }
+        button { 
+            padding: 10px 20px; 
+            margin: 10px 5px;
+            font-size: 16px;
+        }
+        #status { 
+            margin: 10px 0;
             padding: 10px;
-            border-radius: 5px;
-            height: 300px;
-            overflow-y: auto;
+            background: #e8f5e9;
+            border-radius: 4px;
         }
-        .timer {
-            font-size: 24px;
-            color: #ffcc00;
-            text-align: center;
-            animation: pulse 1s infinite;
+        #output {
+            white-space: pre-wrap;
+            padding: 15px;
+            background: #f5f5f5;
+            border-radius: 4px;
+            margin: 10px 0;
+            min-height: 100px;
+            max-height: 400px;
+            overflow-y: auto;
         }
-        @keyframes pulse {
-            0% { transform: scale(1); }
-            50% { transform: scale(1.1); }
-            100% { transform: scale(1); }
+        .controls {
+            margin: 10px 0;
         }
-        </style>
-        <script>
-        document.addEventListener('paste', function(e) {
-            const items = (e.clipboardData || window.clipboardData).items;
-            for (let i = 0; i < items.length; i++) {
-                if (items[i].type.indexOf('image') !== -1) {
-                    const blob = items[i].getAsFile();
-                    const reader = new FileReader();
-                    reader.onload = function(event) {
-                        const imageData = event.target.result;
-                        sessionStorage.setItem('pastedImage', imageData);
-                        document.getElementById('message_input').value = 'PastedImage:' + blob.name;
-                        document.getElementById('send_button').click();
-                    };
-                    reader.readAsDataURL(blob);
+    </style>
+</head>
+<body>
+    <div class="controls">
+        <button id="start">Start Listening</button>
+        <button id="stop" disabled>Stop Listening</button>
+        <button id="clear">Clear Text</button>
+    </div>
+    <div id="status">Ready</div>
+    <div id="output"></div>
+    
+    <script>
+        if (!('webkitSpeechRecognition' in window)) {
+            alert('Speech recognition not supported');
+        } else {
+            const recognition = new webkitSpeechRecognition();
+            const startButton = document.getElementById('start');
+            const stopButton = document.getElementById('stop');
+            const clearButton = document.getElementById('clear');
+            const status = document.getElementById('status');
+            const output = document.getElementById('output');
+            let fullTranscript = '';
+            let lastUpdateTime = Date.now();
+
+            recognition.continuous = true;
+            recognition.interimResults = true;
+
+            const startRecognition = () => {
+                try {
+                    recognition.start();
+                    status.textContent = 'Listening...';
+                    startButton.disabled = true;
+                    stopButton.disabled = false;
+                } catch (e) {
+                    console.error(e);
+                    status.textContent = 'Error: ' + e.message;
                 }
-            }
-        });
-        document.getElementById('message_input')?.addEventListener('keypress', function(e) {
-            if (e.key === 'Enter') {
-                document.getElementById('send_button').click();
-            }
+            };
+
+            window.addEventListener('load', () => {
+                setTimeout(startRecognition, 1000);
+            });
+
+            startButton.onclick = startRecognition;
+
+            stopButton.onclick = () => {
+                recognition.stop();
+                status.textContent = 'Stopped';
+                startButton.disabled = false;
+                stopButton.disabled = true;
+            };
+
+            clearButton.onclick = () => {
+                fullTranscript = '';
+                output.textContent = '';
+                sendDataToPython({value: '', dataType: "json"});
+            };
+
+            recognition.onresult = (event) => {
+                let interimTranscript = '';
+                let finalTranscript = '';
+
+                for (let i = event.resultIndex; i < event.results.length; i++) {
+                    const transcript = event.results[i][0].transcript;
+                    if (event.results[i].isFinal) {
+                        finalTranscript += transcript + '\\n';
+                    } else {
+                        interimTranscript += transcript;
+                    }
+                }
+
+                if (finalTranscript || (Date.now() - lastUpdateTime > 5000)) {
+                    if (finalTranscript) {
+                        fullTranscript += finalTranscript;
+                    }
+                    lastUpdateTime = Date.now();
+                    output.textContent = fullTranscript + (interimTranscript ? '... ' + interimTranscript : '');
+                    output.scrollTop = output.scrollHeight;
+                    sendDataToPython({value: fullTranscript, dataType: "json"});
+                }
+            };
+
+            recognition.onend = () => {
+                if (!stopButton.disabled) {
+                    try {
+                        recognition.start();
+                        console.log('Restarted recognition');
+                    } catch (e) {
+                        console.error('Failed to restart recognition:', e);
+                        status.textContent = 'Error restarting: ' + e.message;
+                        startButton.disabled = false;
+                        stopButton.disabled = true;
+                    }
+                }
+            };
+
+            recognition.onerror = (event) => {
+                console.error('Recognition error:', event.error);
+                status.textContent = 'Error: ' + event.error;
+                if (event.error === 'not-allowed' || event.error === 'service-not-allowed') {
+                    startButton.disabled = false;
+                    stopButton.disabled = true;
+                }
+            };
+        }
+
+        function sendDataToPython(data) {
+            window.parent.postMessage({
+                isStreamlitMessage: true,
+                type: "streamlit:setComponentValue",
+                ...data
+            }, "*");
+        }
+
+        window.addEventListener('load', function() {
+            window.setTimeout(function() {
+                window.parent.postMessage({
+                    isStreamlitMessage: true,
+                    type: "streamlit:setFrameHeight",
+                    height: document.documentElement.clientHeight
+                }, "*");
+            }, 0);
         });
-        </script>
-    """, unsafe_allow_html=True)
-
-    # Title and intro
-    st.title(f"{Site_Name}")
-    st.markdown(f"Welcome to {START_ROOM} - chat, vote, paste images, and enjoy IVA’s media magic! 🎉")
-
-    # Load or set username
-    saved_username = load_username()
-    if saved_username and saved_username in FUN_USERNAMES:
-        initial_username = saved_username
-    if 'username' not in st.session_state:
-        st.session_state.username = initial_username
-        save_chat_entry("System 🌟", f"{initial_username} has joined {START_ROOM}!")
-    save_username(st.session_state.username)  # Persist before any refresh
-
-    # Session state for refresh rate and quote index
-    if 'refresh_rate' not in st.session_state:
-        st.session_state.refresh_rate = 5
-    if 'timer_start' not in st.session_state:
-        st.session_state.timer_start = time.time()  # Autostart timer
-    if 'quote_index' not in st.session_state:
-        quotes = 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"
-    if 'pasted_image' not in st.session_state:
-        st.session_state.pasted_image = None
-
-    # Chat section
-    st.subheader(f"{START_ROOM} Chat 💬")
-    chat_content = load_chat()
-    chat_lines = chat_content.split('\n')
-    for i, line in enumerate(chat_lines):
-        if line.strip() and ': ' in line:
-            col1, col2 = st.columns([5, 1])
-            with col1:
-                st.markdown(line)
-            with col2:
-                if st.button(f"👍", key=f"chat_vote_{i}"):
-                    user_hash = generate_user_hash()
-                    save_vote(QUOTE_VOTES_FILE, line, user_hash)
-                    st.session_state.timer_start = time.time()
-                    save_username(st.session_state.username)
-                    st.rerun()
-
-    user_list = get_user_list(chat_content)
-    new_username = st.selectbox("Switch Star", user_list + [st.session_state.username], index=len(user_list))
-    if new_username != st.session_state.username:
-        save_chat_entry("System 🌟", f"{st.session_state.username} switched to {new_username} in {START_ROOM}!")
-        st.session_state.username = new_username
-        st.session_state.timer_start = time.time()
-        save_username(st.session_state.username)
-
-    # Message input with search engine and paste handling
-    agent_icon = st.session_state.username.split()[-1]  # Extract emoji
-    agent_label = FUN_USERNAMES.get(st.session_state.username, "Chatty Brat")
-    message = st.text_input(f"Message Mate {agent_icon} - {agent_label} 🔍📸", key="message_input", placeholder="Type or paste here...")
-    suggestions = get_message_suggestions(chat_content, message) if message else []
-    if suggestions:
-        suggestion = st.selectbox("Chat Snap", [""] + suggestions, index=0)
-        if suggestion:
-            message = suggestion
-            st.session_state.message_input = suggestion
-
-    col_send, _ = st.columns([1, 5])
-    with col_send:
-        send_button = st.button("Send Bend 🚀", key="send_button")
-    if send_button and message.strip():
-        if message.startswith("PastedImage:"):
-            # Handle pasted image
-            image_data = st.session_state.get('pasted_image')
-            if image_data:
-                filename = save_pasted_image(image_data)
-                if filename:
-                    save_chat_entry(st.session_state.username, f"Pasted image: {filename}")
-                    st.session_state.pasted_image = None
-        else:
-            save_chat_entry(st.session_state.username, message)
-        st.session_state.timer_start = time.time()
-        save_username(st.session_state.username)
-        st.rerun()
+    </script>
+</body>
+</html>
+"""
+
+# Main execution - let’s roll! 🎲🚀
+def main():
+    NODE_NAME, port = get_node_name()
+
+    loop = asyncio.new_event_loop()
+    asyncio.set_event_loop(loop)
+
+    async def async_interface():
+        if 'username' not in st.session_state:
+            chat_content = await load_chat()
+            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(list(FUN_USERNAMES.keys()))
+            st.session_state.voice = FUN_USERNAMES[st.session_state.username]
+            st.markdown(f"**🎙️ Voice Selected**: {st.session_state.voice} 🗣️ for {st.session_state.username}")
+
+        st.title(f"🤖🧠MMO {st.session_state.username}📝🔬")
+        st.markdown(f"Welcome to {START_ROOM} - chat, vote, upload, paste images, and enjoy quoting! 🎉")
 
-    # Quote section
-    st.subheader("Quote Note 📝")
-    quotes = load_quotes(st.session_state.quote_source)
-    if quotes:
-        st.session_state.quote_index = st.session_state.quote_index % len(quotes)
-        quote = quotes[st.session_state.quote_index]
-        col1, col2 = st.columns([5, 1])
-        with col1:
-            st.markdown(quote)
-        with col2:
-            if st.button("👍 Vote Float", key="quote_vote"):
-                user_hash = generate_user_hash()
-                save_vote(QUOTE_VOTES_FILE, quote, user_hash)
-                st.session_state.timer_start = time.time()
-                save_username(st.session_state.username)
+        if not st.session_state.server_task:
+            st.session_state.server_task = loop.create_task(run_websocket_server())
+
+        audio_bytes = audio_recorder()
+        if audio_bytes:
+            await process_voice_input(audio_bytes)
+            st.rerun()
+
+        # Continuous Speech Input (ASR)
+        st.subheader("🎤 Continuous Speech Input")
+        asr_component = components.html(ASR_HTML, height=400)
+        if asr_component and isinstance(asr_component, dict) and 'value' in asr_component:
+            transcript = asr_component['value'].strip()
+            if transcript and transcript != st.session_state.last_transcript:
+                st.session_state.transcript_history.append(transcript)
+                await save_chat_entry(st.session_state.username, transcript, is_markdown=True)
+                st.session_state.last_transcript = transcript
+                st.rerun()
+
+        # Unified Chat History at Top
+        st.subheader(f"{START_ROOM} Chat History 💬")
+        chat_content = await load_chat()
+        chat_lines = chat_content.split('\n')
+        chat_lines = [line for line in chat_lines if line.strip() and ': ' in line and not line.startswith('#')]
+        if chat_lines:
+            col1, col2 = st.columns([2, 1])
+            with col1:
+                st.write("### Text & Audio Chat")
+                for i, line in enumerate(reversed(chat_lines)):  # Descending order
+                    col_text, col_audio = st.columns([3, 1])
+                    with col_text:
+                        if "```markdown" in line:
+                            markdown_content = re.search(r'```markdown\n(.*?)```', line, re.DOTALL)
+                            if markdown_content:
+                                st.markdown(markdown_content.group(1))
+                            else:
+                                st.markdown(line)
+                        else:
+                            st.markdown(line)
+                    with col_audio:
+                        username = line.split(': ')[1].split(' ')[0]
+                        cache_key = f"{line}_{FUN_USERNAMES.get(username, 'en-US-AriaNeural')}"
+                        if cache_key not in st.session_state.audio_cache:
+                            cleaned_text = clean_text_for_tts(line.split(': ', 1)[1])
+                            voice = st.session_state.voice if username == st.session_state.username else FUN_USERNAMES.get(username, "en-US-AriaNeural")
+                            audio_file = await async_edge_tts_generate(cleaned_text, voice)
+                            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 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", value=st.session_state.message_text)
+            paste_result_quote = paste_image_button("📋 Paste Image or Text with Quote", key="paste_button_quote")
+            if paste_result_quote.image_data is not None:
+                if isinstance(paste_result_quote.image_data, str):
+                    st.session_state.message_text = paste_result_quote.image_data
+                    st.text_area("Add your response", key="quote_response", value=st.session_state.message_text)
+                else:
+                    st.image(paste_result_quote.image_data, caption="Received Image for Quote")
+                    filename = await save_pasted_image(paste_result_quote.image_data, st.session_state.username)
+                    if filename:
+                        st.session_state.pasted_image_data = filename
+            if st.button("Send Quote 🚀", key="send_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:
+                    markdown_response += f"\n- **Image**: ![Pasted Image]({st.session_state.pasted_image_data})"
+                    await save_chat_entry(st.session_state.username, f"Pasted image: {st.session_state.pasted_image_data}")
+                    st.session_state.pasted_image_data = None
+                await save_chat_entry(st.session_state.username, markdown_response, is_markdown=True)
+                st.session_state.quote_line = None
+                st.session_state.message_text = ''
                 st.rerun()
-        if time.time() - st.session_state.timer_start > 10:  # 10s quote refresh
-            st.session_state.quote_index = (st.session_state.quote_index + 1) % len(quotes)
-            st.session_state.quote_source = "custom" if st.session_state.quote_source == "famous" else "famous"
-            quotes = load_quotes(st.session_state.quote_source)
-            st.session_state.quote_index = st.session_state.quote_index % len(quotes) if quotes else 0
-            st.session_state.timer_start = time.time()
-            save_username(st.session_state.username)
+
+        current_selection = st.session_state.username if st.session_state.username in FUN_USERNAMES else ""
+        new_username = st.selectbox("Change Name and Voice", [""] + list(FUN_USERNAMES.keys()), index=(list(FUN_USERNAMES.keys()).index(current_selection) + 1 if current_selection else 0), format_func=lambda x: f"{x} ({FUN_USERNAMES.get(x, 'No Voice')})" if x else "Select a name")
+        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}")
+            st.session_state.username = new_username
+            st.session_state.voice = FUN_USERNAMES[new_username]
+            st.markdown(f"**🎙️ Voice Changed**: {st.session_state.voice} 🗣️ for {st.session_state.username}")
             st.rerun()
-    else:
-        st.markdown("No quotes available - check back later! 📭")
-
-    # IVA Media Gallery - Root Directory
-    st.subheader("IVA Gallery 🎨🎶🎥")
-    media_files = (
-        glob.glob("./*.png") + glob.glob("./*.jpg") + glob.glob("./*.jpeg") +
-        glob.glob("./*.mp3") + glob.glob("./*.wav") +
-        glob.glob("./*.mp4")
-    )
-    if media_files:
-        media_cols = st.slider("Gallery Rally", min_value=1, max_value=5, value=1)
-        cols = st.columns(media_cols)
-        for idx, media_file in enumerate(media_files):
-            with cols[idx % media_cols]:
-                if media_file.endswith(('.png', '.jpg', '.jpeg')):
-                    st.image(media_file, use_container_width=True)
-                elif media_file.endswith(('.mp3', '.wav')):
-                    st.markdown(get_audio_html(media_file, width="100%"), unsafe_allow_html=True)
-                elif media_file.endswith('.mp4'):
-                    st.markdown(get_video_html(media_file, width="100%"), unsafe_allow_html=True)
-                if st.button(f"👍 Vote Tote {os.path.basename(media_file)}", key=f"media_vote_{idx}"):
-                    user_hash = generate_user_hash()
-                    save_vote(IMAGE_VOTES_FILE, media_file, user_hash)
-                    st.session_state.timer_start = time.time()
-                    save_username(st.session_state.username)
-                    st.rerun()
-    else:
-        st.error("No media files (images, audio, video) found in root directory!")
 
-    # Refresh rate controls with pulsing timer
-    st.subheader("Refresh Dash ⏳")
-    refresh_rate = st.slider("Refresh Clash", min_value=1, max_value=300, value=st.session_state.refresh_rate, step=1)
-    if refresh_rate != st.session_state.refresh_rate:
-        st.session_state.refresh_rate = refresh_rate
-        st.session_state.timer_start = time.time()
-        save_username(st.session_state.username)
-
-    col1, col2, col3 = st.columns(3)
-    with col1:
-        if st.button("🐇 Small Call (1s)"):
-            st.session_state.refresh_rate = 1
-            st.session_state.timer_start = time.time()
-            save_username(st.session_state.username)
-    with col2:
-        if st.button("🐢 Medium Fling (5s)"):
-            st.session_state.refresh_rate = 5
-            st.session_state.timer_start = time.time()
-            save_username(st.session_state.username)
-    with col3:
-        if st.button("🐘 Large Surge (5m)"):
-            st.session_state.refresh_rate = 300
-            st.session_state.timer_start = time.time()
-            save_username(st.session_state.username)
-
-    # Pulsing countdown timer with emoji digits and random Unicode font
-    timer_placeholder = st.empty()
-    start_time = st.session_state.timer_start
-    for i in range(st.session_state.refresh_rate, -1, -1):
-        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_emoji = "⏳" if i % 2 == 0 else "💓"  # Pulse effect
-        timer_placeholder.markdown(f"<p class='timer'>{timer_emoji} {font_func('Next refresh in:')} {countdown_str} {font_func('seconds')}</p>", unsafe_allow_html=True)
-        time.sleep(1)  # Pulse every second
-    st.session_state.timer_start = time.time()
-    st.session_state.last_refresh = time.time()
-    save_username(st.session_state.username)
-    st.rerun()
-
-    # Sidebar vote stats
-    st.sidebar.subheader("Vote Loads")
-    chat_votes = load_votes(QUOTE_VOTES_FILE)
-    image_votes = load_votes(IMAGE_VOTES_FILE)
-    for item, count in chat_votes.items():
-        st.sidebar.write(f"{item}: {count} votes")
-    for image, count in image_votes.items():
-        st.sidebar.write(f"{image}: {count} votes")
-
-# Main event - the ringmaster kicking off the Sector circus! 🎪🤡
-async def main():
-    """🎤 Drops the mic and starts the Sector party - it’s showtime, folks! 🎉"""
-    global NODE_NAME, server_task
-    NODE_NAME, port = get_node_name()
+        # Message input with Send button on the right
+        col_input, col_send = st.columns([5, 1])
+        with col_input:
+            message = st.text_input(f"Message as {st.session_state.username} (Voice: {st.session_state.voice})", key="message_input", value=st.session_state.message_text)
+        with col_send:
+            if st.button("Send 🚀", key="send_button"):
+                if message.strip():
+                    audio_file = await save_chat_entry(st.session_state.username, message, is_markdown=True)
+                    if audio_file:
+                        st.session_state.audio_cache[f"{message}_{FUN_USERNAMES[st.session_state.username]}"] = audio_file
+                        st.audio(audio_file)  # Immediate preview
+                if st.session_state.pasted_image_data:
+                    await save_chat_entry(st.session_state.username, f"Pasted image: {st.session_state.pasted_image_data}")
+                    st.session_state.pasted_image_data = None
+                st.session_state.message_text = ''
+                st.rerun()
 
-    # Start WebSocket server only once as a background task
-    if server_task is None:
-        server_task = asyncio.create_task(run_websocket_server())
+        paste_result_msg = paste_image_button("📋 Paste Image or Text with Message", key="paste_button_msg")
+        if paste_result_msg.image_data is not None:
+            if isinstance(paste_result_msg.image_data, str):
+                st.session_state.message_text = paste_result_msg.image_data
+                st.text_input(f"Message as {st.session_state.username} (Voice: {st.session_state.voice})", key="message_input_paste", value=st.session_state.message_text)
+            else:
+                st.image(paste_result_msg.image_data, caption="Received Image for Message")
+                filename = await save_pasted_image(paste_result_msg.image_data, st.session_state.username)
+                if filename:
+                    st.session_state.pasted_image_data = filename
+
+        tab_main = st.radio("Action:", ["🎤 Voice", "📸 Media", "🔍 ArXiv", "📝 Editor"], horizontal=True)
+        useArxiv = st.checkbox("Search Arxiv for Research Paper Answers", value=True)
+        useArxivAudio = st.checkbox("Generate Audio File for Research Paper Answers", value=False)
+
+        st.subheader("Upload Media 🎨🎶🎥")
+        uploaded_file = st.file_uploader("Upload Media", type=['png', 'jpg', 'mp4', 'mp3'])
+        if uploaded_file:
+            timestamp = format_timestamp_prefix(st.session_state.username)
+            username = st.session_state.username
+            ext = uploaded_file.name.split('.')[-1]
+            file_hash = hashlib.md5(uploaded_file.getbuffer()).hexdigest()[:8]
+            if file_hash not in st.session_state.image_hashes:
+                filename = f"{timestamp}-{file_hash}.{ext}"
+                file_path = os.path.join(MEDIA_DIR, filename)
+                await asyncio.to_thread(lambda: open(file_path, 'wb').write(uploaded_file.getbuffer()))
+                st.success(f"Uploaded {filename}")
+                await save_chat_entry(username, f"Uploaded media: {file_path}")
+                await save_chat_history_with_image(username, file_path)
+                st.session_state.image_hashes.add(file_hash)
+                if file_path.endswith('.mp4'):
+                    st.session_state.media_notifications.append(file_path)
+
+        # Big Red Delete Button
+        st.subheader("🛑 Danger Zone")
+        if st.button("Try Not To Delete It All On Your First Day", key="delete_all", help="Deletes all user-added files!", type="primary", use_container_width=True):
+            deleted_files = delete_user_files()
+            if deleted_files:
+                st.markdown("### 🗑️ Deleted Files:\n" + "\n".join([f"- `{file}`" for file in deleted_files]))
+            else:
+                st.markdown("### 🗑️ Nothing to Delete!")
+            st.rerun()
 
-    query_params = st.query_params if hasattr(st, 'query_params') else {}
-    initial_username = query_params.get("username", random.choice(list(FUN_USERNAMES.keys()))) if query_params else random.choice(list(FUN_USERNAMES.keys()))
-    print(f"Welcoming {initial_username} to the Sector bash!")
+        st.subheader("Refresh ⏳")
+        refresh_rate = st.slider("Refresh Rate", 1, 300, st.session_state.refresh_rate)
+        st.session_state.refresh_rate = refresh_rate
+        timer_placeholder = st.empty()
+        for i in range(st.session_state.refresh_rate, -1, -1):
+            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)
+            time.sleep(1)
+        st.rerun()
 
-    create_streamlit_interface(initial_username)
+        # Gallery with Adjustable Tiles
+        st.subheader("Media Gallery 🎨🎶🎥")
+        gallery_columns = st.slider("Number of Gallery Tiles", 1, 20, st.session_state.gallery_columns)
+        st.session_state.gallery_columns = gallery_columns
+        media_files = glob.glob(f"{MEDIA_DIR}/*.png") + glob.glob(f"{MEDIA_DIR}/*.jpg") + glob.glob(f"{MEDIA_DIR}/*.mp4")
+        if media_files:
+            media_votes = await load_votes(MEDIA_VOTES_FILE)
+            seen_files = set()
+            cols = st.columns(gallery_columns)
+            col_idx = 0
+            for media_file in sorted(media_files, key=os.path.getmtime, reverse=True):
+                if media_file not in seen_files:
+                    seen_files.add(media_file)
+                    with cols[col_idx]:
+                        filename = os.path.basename(media_file)
+                        vote_count = media_votes.get(media_file, 0)
+                        st.markdown(f"**{filename}**")
+                        if media_file.endswith(('.png', '.jpg')):
+                            st.image(media_file, use_container_width=True)
+                        elif media_file.endswith('.mp4'):
+                            st.markdown(get_video_html(media_file), unsafe_allow_html=True)  # Verbatim autoplay
+                        if st.button(f"👍 {vote_count}", key=f"media_vote_{media_file}"):
+                            await save_vote(MEDIA_VOTES_FILE, media_file, await generate_user_hash(), st.session_state.username)
+                            st.rerun()
+                    col_idx = (col_idx + 1) % gallery_columns
+
+        # Full Log at End
+        st.subheader("Full Chat Log 📜")
+        with open(HISTORY_FILE, 'r') as f:
+            history_content = f.read()
+        st.markdown(history_content)
+
+    loop.run_until_complete(async_interface())
 
 if __name__ == "__main__":
-    asyncio.run(main())
+    main()