Update app.py

app.py

@@ -10,6 +10,7 @@ import time
 import hashlib
 from PIL import Image
 import glob
+from urllib.parse import quote
 import base64
 import io
 import streamlit.components.v1 as components
@@ -17,9 +18,6 @@ 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()
@@ -38,26 +36,26 @@ st.set_page_config(
 
 # Funky usernames - who’s who in the zoo with unique voices! 🎭🐾🎙️
 FUN_USERNAMES = {
-    "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"
+    "CosmicJester 🌌": "en-US-AriaNeural",      # US Female, bright & clear
+    "PixelPanda 🐼": "en-US-JennyNeural",       # US Female, warm & friendly
+    "QuantumQuack 🦆": "en-GB-SoniaNeural",     # UK Female, posh & crisp
+    "StellarSquirrel 🐿️": "en-AU-NatashaNeural",  # AU Female, lively & upbeat
+    "GizmoGuru ⚙️": "en-CA-ClaraNeural",        # CA Female, calm & soothing
+    "NebulaNinja 🌠": "en-US-GuyNeural",        # US Male, deep & cool
+    "ByteBuster 💾": "en-GB-RyanNeural",        # UK Male, smooth & refined
+    "GalacticGopher 🌍": "en-AU-WilliamNeural", # AU Male, bold & rugged
+    "RocketRaccoon 🚀": "en-CA-LiamNeural",     # CA Male, steady & warm
+    "EchoElf 🧝": "en-US-AnaNeural",            # US Female, soft & gentle (child-like)
+    "PhantomFox 🦊": "en-US-BrandonNeural",     # US Male, confident & rich
+    "WittyWizard 🧙": "en-GB-ThomasNeural",     # UK Male, authoritative & clear
+    "LunarLlama 🌙": "en-AU-FreyaNeural",       # AU Female, sweet & melodic
+    "SolarSloth ☀️": "en-CA-LindaNeural",      # CA Female, neutral & pleasant
+    "AstroAlpaca 🦙": "en-US-ChristopherNeural",# US Male, strong & resonant
+    "CyberCoyote 🐺": "en-GB-ElliotNeural",     # UK Male, youthful & energetic
+    "MysticMoose 🦌": "en-AU-JamesNeural",      # AU Male, deep & grounded
+    "GlitchGnome 🧚": "en-CA-EthanNeural",      # CA Male, bright & lively
+    "VortexViper 🐍": "en-US-AmberNeural",      # US Female, expressive & vibrant
+    "ChronoChimp 🐒": "en-GB-LibbyNeural"       # UK Female, cheerful & distinct
 }
 
 # Folders galore - organizing chaos! 📂🌀
@@ -66,12 +64,10 @@ 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)
 
 CHAT_FILE = os.path.join(CHAT_DIR, "global_chat.md")
 QUOTE_VOTES_FILE = os.path.join(VOTE_DIR, "quote_votes.md")
@@ -100,7 +96,7 @@ UNICODE_FONTS = [
     ("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)),  # Fixed mapping
+    ("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)),
 ]
 
@@ -111,52 +107,10 @@ 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]
+def format_timestamp_prefix():
+    return datetime.now().strftime("%Y%m%d_%H%M%S")
 
 # Node naming - christening the beast! 🌐🍼
 def get_node_name():
@@ -177,50 +131,31 @@ def log_action(username, action):
     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")
+            f.write(f"[{datetime.now().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):
+    # Remove Markdown formatting (e.g., #, *, [], ![])
     cleaned = re.sub(r'[#*!\[\]]+', '', text)
+    # Replace newlines with spaces and strip extra whitespace
     cleaned = ' '.join(cleaned.split())
+    # Ensure some text exists, max 200 chars to avoid edgeTTS limits
     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):
+async def save_chat_entry(username, message):
     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}"
+    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"))
     voice = 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 = 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
+            f.write(f"[{timestamp}] {username}: Audio generated - {audio_file}\n")
 
 # Chat loader - history unleashed! 📜🚀
 async def load_chat():
@@ -247,7 +182,7 @@ async def get_user_list(chat_content):
 async def has_joined_before(client_id, chat_content):
     username = st.session_state.get('username', 'System 🌟')
     await asyncio.to_thread(log_action, username, "🚪🔍 - Join checker - been here before?")
-    return any(f"Client-{client_id}" in line for line in chat_content.split('\n'))
+    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):
@@ -260,8 +195,7 @@ async def get_message_suggestions(chat_content, prefix):
 # 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")
+    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"))
     await asyncio.to_thread(lambda: open(HISTORY_FILE, "a").write(f"- {timestamp} - User {user_hash} voted for {item}\n"))
@@ -303,53 +237,46 @@ async def generate_user_hash():
 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)
+    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")
     try:
-        await communicate.save(filepath)
-        return filepath if os.path.exists(filepath) else None
+        await communicate.save(filename)
+        return filename if os.path.exists(filename) 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")
+            f.write(f"[{datetime.now().strftime('%Y-%m-%d %H:%M:%S')}] {username}: Audio failed - No audio received for '{text}'\n")
         return None
 
 # 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]
+        with open(file_path, "rb") as f:
+            b64 = base64.b64encode(f.read()).decode()
         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):
+# Image saver - pics preserved! 📸💾
+async def save_pasted_image(image_data):
+    username = st.session_state.get('username', 'System 🌟')
     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)  # Save chat history with image
-    return filepath
-
-# Video renderer - movies roll with autoplay! 🎥🎬
+    timestamp = format_timestamp_prefix()
+    filename = f"paste_{timestamp}.png"
+    filepath = os.path.join('./', filename)
+    if ',' in image_data:
+        image_data = image_data.split(',')[1]
+    img_bytes = base64.b64decode(image_data)
+    img = Image.open(io.BytesIO(img_bytes))
+    await asyncio.to_thread(img.save, filepath, "PNG")
+    return filename
+
+# Video renderer - movies roll! 🎥🎬
 async def get_video_html(video_path, width="100%"):
     username = st.session_state.get('username', 'System 🌟')
     await asyncio.to_thread(log_action, username, "🎥🎬 - Video renderer - movies roll!")
-    with open(video_path, 'rb') as f:
-        video_data = await asyncio.to_thread(f.read)
-    video_url = f"data:video/mp4;base64,{base64.b64encode(video_data).decode()}"
-    return f'<video width="{width}" controls autoplay><source src="{video_url}" type="video/mp4">Your browser does not support the video tag.</video>'
+    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%"):
@@ -375,6 +302,7 @@ async def websocket_handler(websocket, path):
             if len(parts) == 2:
                 username, content = parts
                 await save_chat_entry(username, content)
+                await broadcast_message(f"{username}|{content}", room_id)
     except websockets.ConnectionClosed:
         pass
     finally:
@@ -409,214 +337,11 @@ 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"
+        text = "Voice input simulation"  # Replace with actual speech-to-text logic
         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, FUN_USERNAMES.get(username, "en-US-AriaNeural"))
-        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;
-            background: #e8f5e9;
-            border-radius: 4px;
-        }
-        #output {
-            white-space: pre-wrap;
-            padding: 15px;
-            background: #f5f5f5;
-            border-radius: 4px;
-            margin: 10px 0;
-            min-height: 100px;
-            max-height: 400px;
-            overflow-y: auto;
-        }
-        .controls {
-            margin: 10px 0;
-        }
-    </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;
-                }
-            };
-
-            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>
-</body>
-</html>
-"""
-
-# Main execution - let’s roll! 🎲🚀
-def main():
-    NODE_NAME, port = get_node_name()
-
+# Interface builder - UI takes shape! 🎨🖌️
+def create_streamlit_interface():
     loop = asyncio.new_event_loop()
     asyncio.set_event_loop(loop)
 
@@ -625,8 +350,30 @@ def main():
             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}")
+
+        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()
+        if 'quote_line' not in st.session_state:
+            st.session_state.quote_line = None
+        if 'pasted_image_data' not in st.session_state:
+            st.session_state.pasted_image_data = None
+        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 'chat_history' not in st.session_state:
+            st.session_state.chat_history = []
+
+        st.markdown("""
+            <style>
+            .chat-box {font-family: monospace; background: #1e1e1e; color: #d4d4d4; padding: 10px; border-radius: 5px; height: 300px; overflow-y: auto;}
+            .timer {font-size: 24px; color: #ffcc00; text-align: center; animation: pulse 1s infinite;}
+            @keyframes pulse {0% {transform: scale(1);} 50% {transform: scale(1.1);} 100% {transform: scale(1);}}
+            #paste-target {border: 2px dashed #ccc; padding: 20px; text-align: center; cursor: pointer;}
+            </style>
+        """, unsafe_allow_html=True)
 
         st.title(f"🤖🧠MMO {st.session_state.username}📝🔬")
         st.markdown(f"Welcome to {START_ROOM} - chat, vote, upload, paste images, and enjoy quoting! 🎉")
@@ -639,140 +386,150 @@ def main():
             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 💬")
+        st.subheader(f"{START_ROOM} Chat 💬")
         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])
-                            audio_file = await async_edge_tts_generate(cleaned_text, FUN_USERNAMES.get(username, "en-US-AriaNeural"))
-                            st.session_state.audio_cache[cache_key] = audio_file
-                        audio_file = st.session_state.audio_cache.get(cache_key)
-                        if audio_file:
-                            play_and_download_audio(audio_file)
-
-        if st.session_state.quote_line:
+        chat_votes = await 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])
+                with col1:
+                    st.markdown(line)
+                    username = line.split(': ')[1].split(' ')[0]
+                    audio_file = None
+                    cache_key = f"{line}_{FUN_USERNAMES.get(username, 'en-US-AriaNeural')}"
+                    if cache_key in st.session_state.audio_cache:
+                        audio_file = st.session_state.audio_cache[cache_key]
+                    else:
+                        cleaned_text = clean_text_for_tts(line.split(': ', 1)[1])
+                        audio_file = await async_edge_tts_generate(cleaned_text, FUN_USERNAMES.get(username, "en-US-AriaNeural"))
+                        st.session_state.audio_cache[cache_key] = audio_file
+                    if audio_file:
+                        play_and_download_audio(audio_file)
+                with col2:
+                    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)
+                        if st.session_state.pasted_image_data:
+                            filename = await save_pasted_image(st.session_state.pasted_image_data)
+                            if filename:
+                                await 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 col3:
+                    if st.button("📢 Quote", key=f"quote_{i}"):
+                        st.session_state.quote_line = line
+                        st.rerun()
+
+        if 'quote_line' in st.session_state:
             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
+            quote_response = st.text_area("Add your response", key="quote_response")
             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
+                async def process_quote():
+                    await asyncio.to_thread(log_action, st.session_state.username, "📢💬 - Quote processor - echoes resound!")
+                    markdown_response = f"### Quote Response\n- **Original**: {st.session_state.quote_line}\n- **{st.session_state.username} Replies**: {quote_response}"
+                    if st.session_state.pasted_image_data:
+                        filename = await save_pasted_image(st.session_state.pasted_image_data)
+                        if filename:
+                            markdown_response += f"\n- **Image**: ![Pasted Image]({filename})"
+                            st.session_state.pasted_image_data = None
+                    try:
+                        await save_chat_entry(st.session_state.username, markdown_response)
+                    except edge_tts.exceptions.NoAudioReceived:
+                        # Log failure but continue without audio
+                        timestamp = datetime.now().strftime("%Y-%m-%d %H:%M:%S")
+                        with open(HISTORY_FILE, 'a') as f:
+                            f.write(f"[{timestamp}] {st.session_state.username}: Quote saved without audio - No audio received\n")
+                        await asyncio.to_thread(lambda: open(CHAT_FILE, 'a').write(f"[{timestamp}] {st.session_state.username}: {markdown_response}\n"))
+                loop.run_until_complete(process_quote())
+                del st.session_state.quote_line
                 st.session_state.message_text = ''
                 st.rerun()
 
-        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")
+        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}")
+            loop.run_until_complete(save_chat_entry("System 🌟", f"{st.session_state.username} changed name to {new_username}"))
             st.session_state.username = new_username
-            st.session_state.voice = FUN_USERNAMES[new_username]
-            st.markdown(f"**🎙️ Voice Changed**: {st.session_state.voice} 🗣️ for {st.session_state.username}")
             st.rerun()
 
-        # 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()
-
-        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)
+        message = st.text_input(f"Message as {st.session_state.username}", key="message_input", value=st.session_state.message_text, on_change=lambda: st.session_state.update(message_text=st.session_state.message_input))
+        if st.button("Send 🚀", key="send_button") and message.strip():
+            loop.run_until_complete(save_chat_entry(st.session_state.username, message))
+            if st.session_state.pasted_image_data:
+                filename = loop.run_until_complete(save_pasted_image(st.session_state.pasted_image_data))
                 if filename:
-                    st.session_state.pasted_image_data = filename
+                    loop.run_until_complete(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()
 
-        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)
+        components.html(
+            """
+            <div id="paste-target">Paste an image here (Ctrl+V)</div>
+            <script>
+            const pasteTarget = document.getElementById('paste-target');
+            pasteTarget.addEventListener('paste', (event) => {
+                const items = (event.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 = (e) => {
+                            window.parent.postMessage({
+                                type: 'streamlit:setComponentValue',
+                                value: e.target.result
+                            }, '*');
+                            pasteTarget.innerHTML = '<p>Image pasted! Processing...</p>';
+                        };
+                        reader.readAsDataURL(blob);
+                    }
+                }
+                event.preventDefault();
+            });
+            </script>
+            """,
+            height=100
+        )
 
-        st.subheader("Upload Media 🎨🎶🎥")
-        uploaded_file = st.file_uploader("Upload Media", type=['png', 'jpg', 'mp4', 'mp3'])
+        st.subheader("Media Gallery 🎨🎶🎥")
+        uploaded_file = st.file_uploader("Upload Media", type=['png', 'jpg', 'mp3', 'mp4'])
         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)  # Save chat history with upload
-                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()
+            file_path = os.path.join('./', uploaded_file.name)
+            await asyncio.to_thread(lambda: open(file_path, 'wb').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 = loop.run_until_complete(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:
+                    with cols[idx % 3]:
+                        if media_file.endswith(('.png', '.jpg')):
+                            st.image(media_file, use_container_width=True)
+                        elif media_file.endswith('.mp3'):
+                            st.markdown(loop.run_until_complete(get_audio_html(media_file)), unsafe_allow_html=True)
+                        elif media_file.endswith('.mp4'):
+                            st.markdown(loop.run_until_complete(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
+                                loop.run_until_complete(save_vote(MEDIA_VOTES_FILE, media_file, await generate_user_hash(), st.session_state.username, comment))
+                                if st.session_state.pasted_image_data:
+                                    filename = loop.run_until_complete(save_pasted_image(st.session_state.pasted_image_data))
+                                    if filename:
+                                        loop.run_until_complete(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)
+                                st.rerun()
 
         st.subheader("Refresh ⏳")
         refresh_rate = st.slider("Refresh Rate", 1, 300, st.session_state.refresh_rate)
@@ -782,42 +539,20 @@ def main():
             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)
+            loop.run_until_complete(asyncio.sleep(1))
         st.rerun()
 
-        # 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(await get_video_html(media_file), unsafe_allow_html=True)
-                        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 📜")
+        st.sidebar.subheader("Chat History 📜")
         with open(HISTORY_FILE, 'r') as f:
             history_content = f.read()
-        st.markdown(history_content)
+        st.sidebar.markdown(history_content)
 
     loop.run_until_complete(async_interface())
 
+# Main execution - let’s roll! 🎲🚀
+def main():
+    NODE_NAME, port = get_node_name()
+    create_streamlit_interface()
+
 if __name__ == "__main__":
     main()