Update app.py

app.py

@@ -2,7 +2,6 @@ import streamlit as st
 import asyncio
 import websockets
 import uuid
-import argparse
 from datetime import datetime
 import os
 import random
@@ -10,155 +9,491 @@ import time
 import hashlib
 from PIL import Image
 import glob
+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 urllib.parse import quote
-
-# App Configuration
-Site_Name = '🤖🧠Chat & Quote Node📝🔬'
-title = "🤖🧠Chat & Quote Node📝🔬"
-icons = '🤖🧠🔬📝'
-START_ROOM = "Sector 🌌"
-
+from streamlit_paste_button import paste_image_button
+import pytz
+import shutil
+import anthropic
+import openai
+from PyPDF2 import PdfReader
+import threading
+import json
+import zipfile
+from gradio_client import Client
+from dotenv import load_dotenv
+from streamlit_marquee import streamlit_marquee
+from collections import defaultdict, Counter
+import pandas as pd
+
+# 🛠️ Patch asyncio for nesting
+nest_asyncio.apply()
+
+# 🎨 Page Config
 st.set_page_config(
-    page_title=title,
-    page_icon=icons,
+    page_title="🚲TalkingAIResearcher🏆",
+    page_icon="🚲🏆",
     layout="wide",
     initial_sidebar_state="auto"
 )
 
-# Fun usernames with emojis - the VIP list of quirky characters! 🎉😜
-FUN_USERNAMES = [
-    "CosmicJester 🌌", "PixelPanda 🐼", "QuantumQuack 🦆", "StellarSquirrel 🐿️",
-    "GizmoGuru ⚙️", "NebulaNinja 🌠", "ByteBuster 💾", "GalacticGopher 🌍",
-    "RocketRaccoon 🚀", "EchoElf 🧝", "PhantomFox 🦊", "WittyWizard 🧙",
-    "LunarLlama 🌙", "SolarSloth ☀️", "AstroAlpaca 🦙", "CyberCoyote 🐺",
-    "MysticMoose 🦌", "GlitchGnome 🧚", "VortexViper 🐍", "ChronoChimp 🐒"
-]
+# 🌟 Static Config
+icons = '🤖🧠🔬📝'
+Site_Name = '🤖🧠Chat & Quote Node📝🔬'
+START_ROOM = "Sector 🌌"
+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"
+}
+EDGE_TTS_VOICES = list(set(FUN_USERNAMES.values()))
+FILE_EMOJIS = {"md": "📝", "mp3": "🎵", "png": "🖼️", "mp4": "🎥"}
+
+# 📁 Directories (Media at Root)
+for d in ["chat_logs", "vote_logs", "audio_logs", "history_logs", "audio_cache"]:
+    os.makedirs(d, exist_ok=True)
 
-# Directories for chat, votes, and media - the secret vaults where treasures are stashed! 🗄️🔒
 CHAT_DIR = "chat_logs"
 VOTE_DIR = "vote_logs"
-MEDIA_DIR = "media"
+MEDIA_DIR = "."
+AUDIO_CACHE_DIR = "audio_cache"
+AUDIO_DIR = "audio_logs"
 STATE_FILE = "user_state.txt"
-os.makedirs(CHAT_DIR, exist_ok=True)
-os.makedirs(VOTE_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")
 
-# 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️⃣"
-}
+# 🔑 API Keys
+load_dotenv()
+anthropic_key = os.getenv('ANTHROPIC_API_KEY', st.secrets.get('ANTHROPIC_API_KEY', ""))
+openai_api_key = os.getenv('OPENAI_API_KEY', st.secrets.get('OPENAI_API_KEY', ""))
+openai_client = openai.OpenAI(api_key=openai_api_key)
+
+# 🕒 Timestamp Helper
+def format_timestamp_prefix(username=""):
+    central = pytz.timezone('US/Central')
+    now = datetime.now(central)
+    return f"{now.strftime('%Y%m%d_%H%M%S')}-by-{username}"
+
+# 📈 Performance Timer
+class PerformanceTimer:
+    def __init__(self, name):
+        self.name, self.start = name, None
+    def __enter__(self):
+        self.start = time.time()
+        return self
+    def __exit__(self, *args):
+        duration = time.time() - self.start
+        st.session_state['operation_timings'][self.name] = duration
+        st.session_state['performance_metrics'][self.name].append(duration)
+
+# 🎛️ Session State Init
+def init_session_state():
+    defaults = {
+        'server_running': False, 'server_task': None, 'active_connections': {},
+        'media_notifications': [], 'last_chat_update': 0, 'displayed_chat_lines': [],
+        'message_text': "", 'audio_cache': {}, 'pasted_image_data': None,
+        'quote_line': None, 'refresh_rate': 5, 'base64_cache': {},
+        'transcript_history': [], 'last_transcript': "", 'image_hashes': set(),
+        'tts_voice': "en-US-AriaNeural", 'chat_history': [], 'marquee_settings': {
+            "background": "#1E1E1E", "color": "#FFFFFF", "font-size": "14px",
+            "animationDuration": "20s", "width": "100%", "lineHeight": "35px"
+        }, 'operation_timings': {}, 'performance_metrics': defaultdict(list),
+        'enable_audio': True, 'download_link_cache': {}, 'username': None,
+        'autosend': True, 'autosearch': True, 'last_message': "", 'last_query': "",
+        'mp3_files': {}, 'timer_start': time.time(), 'quote_index': 0,
+        'quote_source': "famous", 'last_sent_transcript': "", 'old_val': None
+    }
+    for k, v in defaults.items():
+        if k not in st.session_state:
+            st.session_state[k] = v
+
+# 🖌️ Marquee Helpers
+def update_marquee_settings_ui():
+    st.sidebar.markdown("### 🎯 Marquee Settings")
+    cols = st.sidebar.columns(2)
+    with cols[0]:
+        st.session_state['marquee_settings']['background'] = st.color_picker("🎨 Background", "#1E1E1E")
+        st.session_state['marquee_settings']['color'] = st.color_picker("✍️ Text", "#FFFFFF")
+    with cols[1]:
+        st.session_state['marquee_settings']['font-size'] = f"{st.slider('📏 Size', 10, 24, 14)}px"
+        st.session_state['marquee_settings']['animationDuration'] = f"{st.slider('⏱️ Speed', 1, 20, 20)}s"
+
+def display_marquee(text, settings, key_suffix=""):
+    truncated = text[:280] + "..." if len(text) > 280 else text
+    streamlit_marquee(content=truncated, **settings, key=f"marquee_{key_suffix}")
+    st.write("")
+
+# 📝 Text & File Helpers
+def clean_text_for_tts(text):
+    return re.sub(r'[#*!\[\]]+', '', ' '.join(text.split()))[:200] or "No text"
+
+def clean_text_for_filename(text):
+    return '_'.join(re.sub(r'[^\w\s-]', '', text.lower()).split())[:200]
+
+def get_high_info_terms(text, top_n=10):
+    stop_words = {'the', 'a', 'an', 'and', 'or', 'but', 'in', 'on', 'at', 'to', 'for', 'of', 'with'}
+    words = re.findall(r'\b\w+(?:-\w+)*\b', text.lower())
+    bi_grams = [' '.join(pair) for pair in zip(words, words[1:])]
+    filtered = [t for t in words + bi_grams if t not in stop_words and len(t.split()) <= 2]
+    return [t for t, _ in Counter(filtered).most_common(top_n)]
+
+def generate_filename(prompt, username, file_type="md"):
+    timestamp = format_timestamp_prefix(username)
+    hash_val = hashlib.md5(prompt.encode()).hexdigest()[:8]
+    return f"{timestamp}-{hash_val}.{file_type}"
+
+def create_file(prompt, username, file_type="md"):
+    filename = generate_filename(prompt, username, file_type)
+    with open(filename, 'w', encoding='utf-8') as f:
+        f.write(prompt)
+    return filename
+
+def get_download_link(file, file_type="mp3"):
+    cache_key = f"dl_{file}"
+    if cache_key not in st.session_state['download_link_cache']:
+        with open(file, "rb") as f:
+            b64 = base64.b64encode(f.read()).decode()
+        mime_types = {"mp3": "audio/mpeg", "png": "image/png", "mp4": "video/mp4", "md": "text/markdown"}
+        st.session_state['download_link_cache'][cache_key] = f'<a href="data:{mime_types.get(file_type, "application/octet-stream")};base64,{b64}" download="{os.path.basename(file)}">{FILE_EMOJIS.get(file_type, "Download")} Download {os.path.basename(file)}</a>'
+    return st.session_state['download_link_cache'][cache_key]
 
-# Unicode font examples - the stylish wardrobe of text flair! 👗📝
-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)),
-    ("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)),
-    ("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)),
-    ("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))
-]
-
-# Global WebSocket server flag
-server_running = False
-server_task = None
-
-# Node name - the app’s codename generator, sneaky and slick! 🕵️‍♂️💾
-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')
-    args = parser.parse_args()
-    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}"
+def save_username(username):
     try:
-        with open(CHAT_FILE, 'a') as f:
-            f.write(f"{entry}\n")
-        return True
+        with open(STATE_FILE, 'w') as f:
+            f.write(username)
     except Exception as e:
-        print(f"Oops! Failed to save chat: {e}")
-        return False
+        print(f"Failed to save username: {e}")
 
-# Chat loader - the archaeologist unearthing the chat saga! ⛏️📚
-def load_chat():
-    """🔍 Digs up the chat treasure from the filesystem - tales of old and new! 💰"""
-    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")
+def load_username():
+    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
+
+def concatenate_markdown_files():
+    md_files = sorted(glob.glob("*.md"), key=os.path.getmtime, reverse=True)
+    all_md_content = ""
+    for md_file in md_files:
+        with open(md_file, 'r', encoding='utf-8') as f:
+            all_md_content += f.read() + "\n\n---\n\n"
+    return all_md_content.strip()
+
+# 🎶 Audio Processing
+async def async_edge_tts_generate(text, voice, username, rate=0, pitch=0, file_format="mp3"):
+    cache_key = f"{text[:100]}_{voice}_{rate}_{pitch}_{file_format}"
+    if cache_key in st.session_state['audio_cache']:
+        return st.session_state['audio_cache'][cache_key], 0
+    start_time = time.time()
+    text = clean_text_for_tts(text)
+    if not text or text == "No text":
+        print(f"Skipping audio generation for empty/invalid text: '{text}'")
+        return None, 0
+    filename = f"{format_timestamp_prefix(username)}-{hashlib.md5(text.encode()).hexdigest()[:8]}.{file_format}"
     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
+        communicate = edge_tts.Communicate(text, voice, rate=f"{rate:+d}%", pitch=f"{pitch:+d}Hz")
+        await communicate.save(filename)
+        st.session_state['audio_cache'][cache_key] = filename
+        return filename, time.time() - start_time
+    except edge_tts.exceptions.NoAudioReceived as e:
+        print(f"No audio received for text: '{text}' with voice: {voice}. Error: {e}")
+        return None, 0
     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? 🎸"""
-    users = set()
-    for line in chat_content.split('\n'):
-        if line.strip() and ': ' in line:
-            user = line.split(': ')[1].split(' ')[0]
-            users.add(user)
-    return sorted(list(users))
-
-# 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! 👍📊
+        print(f"Error generating audio for text: '{text}' with voice: {voice}. Error: {e}")
+        return None, 0
+
+def play_and_download_audio(file_path):
+    if file_path and os.path.exists(file_path):
+        st.audio(file_path)
+        st.markdown(get_download_link(file_path), unsafe_allow_html=True)
+
+def load_mp3_viewer():
+    mp3_files = sorted(glob.glob(f"*.mp3"), key=os.path.getmtime, reverse=True)
+    for mp3 in mp3_files:
+        filename = os.path.basename(mp3)
+        if filename not in st.session_state['mp3_files']:
+            st.session_state['mp3_files'][filename] = mp3
+
+async def save_chat_entry(username, message, voice, is_markdown=False):
+    if not message.strip() or message == st.session_state.last_transcript:
+        return None, None
+    central = pytz.timezone('US/Central')
+    timestamp = datetime.now(central).strftime("%Y-%m-%d %H:%M:%S")
+    entry = f"[{timestamp}] {username} ({voice}): {message}" if not is_markdown else f"[{timestamp}] {username} ({voice}):\n```markdown\n{message}\n```"
+    md_file = create_file(entry, username, "md")
+    with open(CHAT_FILE, 'a') as f:
+        f.write(f"{entry}\n")
+    audio_file, _ = await async_edge_tts_generate(message, voice, username)
+    if audio_file:
+        with open(HISTORY_FILE, 'a') as f:
+            f.write(f"[{timestamp}] {username}: Audio - {audio_file}\n")
+        st.session_state['mp3_files'][os.path.basename(audio_file)] = audio_file
+    await broadcast_message(f"{username}|{message}", "chat")
+    st.session_state.last_chat_update = time.time()
+    st.session_state.chat_history.append(entry)
+    st.session_state.last_transcript = message  # Update last processed transcript
+    return md_file, audio_file
+
+async def load_chat():
+    if not os.path.exists(CHAT_FILE):
+        with open(CHAT_FILE, 'a') as f:
+            f.write(f"# {START_ROOM} Chat\n\nWelcome to the cosmic hub! 🎤\n")
+    with open(CHAT_FILE, 'r') as f:
+        content = f.read().strip()
+    lines = content.split('\n')
+    # Remove duplicates and empty lines
+    unique_lines = list(dict.fromkeys(line for line in lines if line.strip()))
+    numbered_content = "\n".join(f"{i+1}. {line}" for i, line in enumerate(unique_lines))
+    return numbered_content
+
+# Claude Search Function
+async def perform_claude_search(query, username):
+    if not query.strip() or query == st.session_state.last_transcript:
+        return None, None
+    client = anthropic.Anthropic(api_key=anthropic_key)
+    response = client.messages.create(
+        model="claude-3-sonnet-20240229",
+        max_tokens=1000,
+        messages=[{"role": "user", "content": query}]
+    )
+    result = response.content[0].text
+    st.markdown(f"### Claude's Reply 🧠\n{result}")
+    
+    # Save to chat history with audio
+    voice = FUN_USERNAMES.get(username, "en-US-AriaNeural")
+    md_file, audio_file = await save_chat_entry(username, f"Claude Search: {query}\nResponse: {result}", voice, True)
+    return md_file, audio_file
+
+# ArXiv Search Function
+async def perform_arxiv_search(query, username):
+    if not query.strip() or query == st.session_state.last_transcript:
+        return None, None
+    # Step 1: Claude Search
+    client = anthropic.Anthropic(api_key=anthropic_key)
+    claude_response = client.messages.create(
+        model="claude-3-sonnet-20240229",
+        max_tokens=1000,
+        messages=[{"role": "user", "content": query}]
+    )
+    claude_result = claude_response.content[0].text
+    st.markdown(f"### Claude's Reply 🧠\n{claude_result}")
+
+    # Step 2: Feed Claude result into ArXiv
+    enhanced_query = f"{query}\n\n{claude_result}"
+    gradio_client = Client("awacke1/Arxiv-Paper-Search-And-QA-RAG-Pattern")
+    refs = gradio_client.predict(
+        enhanced_query, 10, "Semantic Search", "mistralai/Mixtral-8x7B-Instruct-v0.1", api_name="/update_with_rag_md"
+    )[0]
+    result = f"🔎 {enhanced_query}\n\n{refs}"
+    st.markdown(f"### ArXiv Results 🔍\n{result}")
+
+    # Save to chat history with audio
+    voice = FUN_USERNAMES.get(username, "en-US-AriaNeural")
+    md_file, audio_file = await save_chat_entry(username, f"ArXiv Search: {query}\nClaude Response: {claude_result}\nArXiv Results: {refs}", voice, True)
+    return md_file, audio_file
+
+async def perform_ai_lookup(q, vocal_summary=True, extended_refs=False, titles_summary=True, full_audio=False, useArxiv=True, useArxivAudio=False):
+    start = time.time()
+    client = anthropic.Anthropic(api_key=anthropic_key)
+    response = client.messages.create(
+        model="claude-3-sonnet-20240229",
+        max_tokens=1000,
+        messages=[{"role": "user", "content": q}]
+    )
+    st.write("Claude's reply 🧠:")
+    st.markdown(response.content[0].text)
+
+    result = response.content[0].text
+    md_file = create_file(result, "System", "md")
+    audio_file, _ = await async_edge_tts_generate(result, st.session_state['tts_voice'], "System")
+    st.subheader("📝 Main Response Audio")
+    play_and_download_audio(audio_file)
+
+    if useArxiv:
+        q = q + result
+        st.write('Running Arxiv RAG with Claude inputs.')
+        gradio_client = Client("awacke1/Arxiv-Paper-Search-And-QA-RAG-Pattern")
+        refs = gradio_client.predict(
+            q, 10, "Semantic Search", "mistralai/Mixtral-8x7B-Instruct-v0.1", api_name="/update_with_rag_md"
+        )[0]
+        result = f"🔎 {q}\n\n{refs}"
+        md_file = create_file(result, "System", "md")
+        audio_file, _ = await async_edge_tts_generate(result, st.session_state['tts_voice'], "System")
+        st.subheader("📝 ArXiv Response Audio")
+        play_and_download_audio(audio_file)
+
+        papers = parse_arxiv_refs(refs)
+        if papers and useArxivAudio:
+            await create_paper_audio_files(papers, q)
+        return result, papers
+    elapsed = time.time() - start
+    st.write(f"**Total Elapsed:** {elapsed:.2f} s")
+    return result, []
+
+# 🌐 WebSocket Handling
+async def websocket_handler(websocket, path):
+    client_id = str(uuid.uuid4())
+    room_id = "chat"
+    if room_id not in st.session_state.active_connections:
+        st.session_state.active_connections[room_id] = {}
+    st.session_state.active_connections[room_id][client_id] = websocket
+    username = st.session_state.get('username', random.choice(list(FUN_USERNAMES.keys())))
+    chat_content = await load_chat()
+    if not any(f"Client-{client_id}" in line for line in chat_content.split('\n')):
+        await save_chat_entry("System 🌟", f"{username} has joined {START_ROOM}!", "en-US-AriaNeural")
+    try:
+        async for message in websocket:
+            if '|' in message:
+                username, content = message.split('|', 1)
+                voice = FUN_USERNAMES.get(username, "en-US-AriaNeural")
+                await save_chat_entry(username, content, voice)
+            else:
+                await websocket.send("ERROR|Message format: username|content")
+    except websockets.ConnectionClosed:
+        await save_chat_entry("System 🌟", f"{username} has left {START_ROOM}!", "en-US-AriaNeural")
+    finally:
+        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]
+
+async def broadcast_message(message, room_id):
+    if room_id in st.session_state.active_connections:
+        disconnected = []
+        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:
+            if client_id in st.session_state.active_connections[room_id]:
+                del st.session_state.active_connections[room_id][client_id]
+
+async def run_websocket_server():
+    if not st.session_state.server_running:
+        server = await websockets.serve(websocket_handler, '0.0.0.0', 8765)
+        st.session_state.server_running = True
+        await server.wait_closed()
+
+def start_websocket_server():
+    asyncio.run(run_websocket_server())
+
+# 📚 PDF to Audio
+class AudioProcessor:
+    def __init__(self):
+        self.cache_dir = AUDIO_CACHE_DIR
+        os.makedirs(self.cache_dir, exist_ok=True)
+        self.metadata = json.load(open(f"{self.cache_dir}/metadata.json")) if os.path.exists(f"{self.cache_dir}/metadata.json") else {}
+
+    def _save_metadata(self):
+        with open(f"{self.cache_dir}/metadata.json", 'w') as f:
+            json.dump(self.metadata, f)
+
+    async def create_audio(self, text, voice='en-US-AriaNeural'):
+        cache_key = hashlib.md5(f"{text}:{voice}".encode()).hexdigest()
+        cache_path = f"{self.cache_dir}/{cache_key}.mp3"
+        if cache_key in self.metadata and os.path.exists(cache_path):
+            return cache_path
+        text = clean_text_for_tts(text)
+        if not text:
+            return None
+        communicate = edge_tts.Communicate(text, voice)
+        await communicate.save(cache_path)
+        self.metadata[cache_key] = {'timestamp': datetime.now().isoformat(), 'text_length': len(text), 'voice': voice}
+        self._save_metadata()
+        return cache_path
+
+def process_pdf(pdf_file, max_pages, voice, audio_processor):
+    reader = PdfReader(pdf_file)
+    total_pages = min(len(reader.pages), max_pages)
+    texts, audios = [], {}
+    async def process_page(i, text):
+        audio_path = await audio_processor.create_audio(text, voice)
+        if audio_path:
+            audios[i] = audio_path
+    for i in range(total_pages):
+        text = reader.pages[i].extract_text()
+        texts.append(text)
+        threading.Thread(target=lambda: asyncio.run(process_page(i, text))).start()
+    return texts, audios, total_pages
+
+# 🔍 ArXiv & AI Lookup
+def parse_arxiv_refs(ref_text):
+    if not ref_text:
+        return []
+    papers = []
+    current = {}
+    for line in ref_text.split('\n'):
+        if line.count('|') == 2:
+            if current:
+                papers.append(current)
+            date, title, *_ = line.strip('* ').split('|')
+            url = re.search(r'(https://arxiv.org/\S+)', line).group(1) if re.search(r'(https://arxiv.org/\S+)', line) else f"paper_{len(papers)}"
+            current = {'date': date, 'title': title, 'url': url, 'authors': '', 'summary': '', 'full_audio': None, 'download_base64': ''}
+        elif current:
+            if not current['authors']:
+                current['authors'] = line.strip('* ')
+            else:
+                current['summary'] += ' ' + line.strip() if current['summary'] else line.strip()
+    if current:
+        papers.append(current)
+    return papers[:20]
+
+def generate_5min_feature_markdown(paper):
+    title, summary, authors, date, url = paper['title'], paper['summary'], paper['authors'], paper['date'], paper['url']
+    pdf_url = url.replace("abs", "pdf") + (".pdf" if not url.endswith(".pdf") else "")
+    wct, sw = len(title.split()), len(summary.split())
+    terms = get_high_info_terms(summary, 15)
+    rouge = round((len(terms) / max(sw, 1)) * 100, 2)
+    mermaid = "```mermaid\nflowchart TD\n" + "\n".join(f'    T{i+1}["{t}"] --> T{i+2}["{terms[i+1]}"]' for i in range(len(terms)-1)) + "\n```"
+    return f"""
+## 📄 {title}
+**Authors:** {authors} | **Date:** {date} | **Words:** Title: {wct}, Summary: {sw}  
+**Links:** [Abstract]({url}) | [PDF]({pdf_url})  
+**Terms:** {', '.join(terms)} | **ROUGE:** {rouge}%  
+### 🎤 TTF Read Aloud
+- **Title:** {title} | **Terms:** {', '.join(terms)} | **ROUGE:** {rouge}%  
+#### Concepts Graph
+{mermaid}
+---
+"""
+
+def create_detailed_paper_md(papers):
+    return "# Detailed Summary\n" + "\n".join(generate_5min_feature_markdown(p) for p in papers)
+
+async def create_paper_audio_files(papers, query):
+    for p in papers:
+        audio_text = clean_text_for_tts(f"{p['title']} by {p['authors']}. {p['summary']}")
+        p['full_audio'], _ = await async_edge_tts_generate(audio_text, st.session_state['tts_voice'], p['authors'])
+        if p['full_audio']:
+            p['download_base64'] = get_download_link(p['full_audio'])
+
 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")
     entry = f"[{timestamp}] {user_hash} voted for {item}"
     try:
@@ -171,9 +506,7 @@ def save_vote(file, item, user_hash):
         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? 🏆"""
     if not os.path.exists(file):
         with open(file, 'w') as f:
             f.write("# Vote Tally\n\nNo votes yet - get clicking! 🖱️\n")
@@ -190,290 +523,209 @@ def load_votes(file):
         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! 🎟️"""
     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
-
-# Media HTML generators - IVA’s multimedia magic! 🎥🎶🖼️
-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>
-        <source src="{video_url}" type="video/mp4">
-        Your browser does not support the video tag.
-    </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 = {}
-
-# WebSocket handler - the bouncer at the Sector rave, keeping it hopping! 🎉🚪
-async def websocket_handler(websocket, path):
-    """🎧 Guards the cosmic gate, welcoming all to Sector and booting crashers! 🚨"""
-    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!")
-        # Auto-join message for every connection
-        username = st.session_state.get('username', random.choice(FUN_USERNAMES))
-        save_chat_entry("System 🌟", 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! 😬")
-    except websockets.ConnectionClosed:
-        print(f"Client {client_id} bailed from Sector!")
-        save_chat_entry("System 🌟", f"{username} has left {START_ROOM}!")
-    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]
-
-# Broadcaster - the megaphone blasting Sector vibes to all! 📣🎶
-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:
-        disconnected = []
-        for client_id, ws in 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]
-
-# WebSocket server runner - the DJ spinning up the Sector tunes once! 🎧🔥
-async def run_websocket_server():
-    """🌐 Cranks up the WebSocket jukebox once, keeping Sector rocking! 🎸"""
-    global server_running, server_task
-    if not 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
-        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 for a sleek chat box and timer
-    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); }
-        }
-        </style>
-    """, unsafe_allow_html=True)
-
-    # Title and intro
-    st.title(f"{Site_Name}")
-    st.markdown(f"Welcome to {START_ROOM} - chat, vote, and enjoy IVA’s media magic! 🎉")
-
-    # Load or set username
+async def save_pasted_image(image, username):
+    img_hash = hashlib.md5(image.tobytes()).hexdigest()[:8]
+    if img_hash in st.session_state.image_hashes:
+        return None
+    timestamp = format_timestamp_prefix(username)
+    filename = f"{timestamp}-{img_hash}.png"
+    filepath = filename
+    image.save(filepath, "PNG")
+    st.session_state.image_hashes.add(img_hash)
+    return filepath
+
+# 📦 Zip Files
+def create_zip_of_files(md_files, mp3_files, png_files, mp4_files, query):
+    all_files = md_files + mp3_files + png_files + mp4_files
+    if not all_files:
+        return None
+    terms = get_high_info_terms(" ".join([open(f, 'r', encoding='utf-8').read() if f.endswith('.md') else os.path.splitext(os.path.basename(f))[0].replace('_', ' ') for f in all_files] + [query]), 5)
+    zip_name = f"{format_timestamp_prefix()}_{'-'.join(terms)[:20]}.zip"
+    with zipfile.ZipFile(zip_name, 'w') as z:
+        [z.write(f) for f in all_files]
+    return zip_name
+
+# 🎮 Main Interface
+def main():
+    init_session_state()
+    load_mp3_viewer()
     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"
-
-    # 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.username = saved_username
+    if not st.session_state.username:
+        available = [n for n in FUN_USERNAMES if not any(f"{n} has joined" in l for l in asyncio.run(load_chat()).split('\n'))]
+        st.session_state.username = random.choice(available or list(FUN_USERNAMES.keys()))
+        st.session_state.tts_voice = FUN_USERNAMES[st.session_state.username]
+        asyncio.run(save_chat_entry("System 🌟", f"{st.session_state.username} has joined {START_ROOM}!", "en-US-AriaNeural"))
+    save_username(st.session_state.username)
+
+    st.title(f"{Site_Name} for {st.session_state.username}")
+    update_marquee_settings_ui()
+    display_marquee(f"🚀 Welcome to {START_ROOM} | 🤖 {st.session_state.username}", st.session_state['marquee_settings'], "welcome")
+
+    # Speech Component at Top Level
+    mycomponent = components.declare_component("mycomponent", path="mycomponent")
+    val = mycomponent(my_input_value="")
+    if val and val != st.session_state.last_transcript:
+        val_stripped = val.strip().replace('\n', ' ')
+        if val_stripped:
+            voice = FUN_USERNAMES.get(st.session_state.username, "en-US-AriaNeural")
+            md_file, audio_file = asyncio.run(save_chat_entry(st.session_state.username, val_stripped, voice))
+            if audio_file:
+                play_and_download_audio(audio_file)
+            st.rerun()
+
+    tab_main = st.radio("Action:", ["🎤 Chat & Voice", "🔍 ArXiv", "📚 PDF to Audio"], horizontal=True, key="tab_main")
+    useArxiv = st.checkbox("Search ArXiv", True, key="use_arxiv")
+    useArxivAudio = st.checkbox("ArXiv Audio", False, key="use_arxiv_audio")
+    st.checkbox("Autosend Chat", value=True, key="autosend")
+    st.checkbox("Autosearch ArXiv", value=True, key="autosearch")
+
+    # 🎤 Chat & Voice
+    if tab_main == "🎤 Chat & Voice":
+        st.subheader(f"{START_ROOM} Chat 💬")
+        chat_content = asyncio.run(load_chat())
+        chat_container = st.container()
+        with chat_container:
+            st.markdown(chat_content)
+
+        message = st.text_input(f"Message as {st.session_state.username}", key="message_input")
+        paste_result = paste_image_button("📋 Paste Image or Text", key="paste_button_msg")
+        if paste_result.image_data is not None:
+            if isinstance(paste_result.image_data, str):
+                st.session_state.message_text = paste_result.image_data
+                message = st.text_input(f"Message as {st.session_state.username}", key="message_input_paste", value=st.session_state.message_text)
+            else:
+                st.image(paste_result.image_data, caption="Pasted Image")
+                filename = asyncio.run(save_pasted_image(paste_result.image_data, st.session_state.username))
+                if filename:
+                    st.session_state.pasted_image_data = filename
+        
+        if (message and message != st.session_state.last_message) or st.session_state.pasted_image_data:
+            st.session_state.last_message = message
+            col_send, col_claude, col_arxiv = st.columns([1, 1, 1])
+            
+            with col_send:
+                if st.session_state.autosend or st.button("Send 🚀", key="send_button"):
+                    voice = FUN_USERNAMES.get(st.session_state.username, "en-US-AriaNeural")
+                    if message.strip():
+                        md_file, audio_file = asyncio.run(save_chat_entry(st.session_state.username, message, voice, True))
+                        if audio_file:
+                            play_and_download_audio(audio_file)
+                    if st.session_state.pasted_image_data:
+                        asyncio.run(save_chat_entry(st.session_state.username, f"Pasted image: {st.session_state.pasted_image_data}", voice))
+                        st.session_state.pasted_image_data = None
                     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 User", user_list + [st.session_state.username], index=len(user_list))
+            with col_claude:
+                if st.button("🧠 Claude", key="claude_button"):
+                    voice = FUN_USERNAMES.get(st.session_state.username, "en-US-AriaNeural")
+                    if message.strip():
+                        md_file, audio_file = asyncio.run(perform_claude_search(message, st.session_state.username))
+                        if audio_file:
+                            play_and_download_audio(audio_file)
+                        st.session_state.timer_start = time.time()
+                        save_username(st.session_state.username)
+                        st.rerun()
+
+            with col_arxiv:
+                if st.button("🔍 ArXiv", key="arxiv_button"):
+                    voice = FUN_USERNAMES.get(st.session_state.username, "en-US-AriaNeural")
+                    if message.strip():
+                        md_file, audio_file = asyncio.run(perform_arxiv_search(message, st.session_state.username))
+                        if audio_file:
+                            play_and_download_audio(audio_file)
+                        st.session_state.timer_start = time.time()
+                        save_username(st.session_state.username)
+                        st.rerun()
+
+    # 🔍 ArXiv
+    elif tab_main == "🔍 ArXiv":
+        st.subheader("🔍 Query ArXiv")
+        q = st.text_input("🔍 Query:", key="arxiv_query")
+        if q and q != st.session_state.last_query:
+            st.session_state.last_query = q
+            if st.session_state.autosearch or st.button("🔍 Run", key="arxiv_run"):
+                result, papers = asyncio.run(perform_ai_lookup(q, useArxiv=useArxiv, useArxivAudio=useArxivAudio))
+                for i, p in enumerate(papers, 1):
+                    with st.expander(f"{i}. 📄 {p['title']}"):
+                        st.markdown(f"**{p['date']} | {p['title']}** — [Link]({p['url']})")
+                        st.markdown(generate_5min_feature_markdown(p))
+                        if p.get('full_audio'):
+                            play_and_download_audio(p['full_audio'])
+
+    # 📚 PDF to Audio
+    elif tab_main == "📚 PDF to Audio":
+        audio_processor = AudioProcessor()
+        pdf_file = st.file_uploader("Choose PDF", "pdf", key="pdf_upload")
+        max_pages = st.slider('Pages', 1, 100, 10, key="pdf_pages")
+        if pdf_file:
+            with st.spinner('Processing...'):
+                texts, audios, total = process_pdf(pdf_file, max_pages, st.session_state['tts_voice'], audio_processor)
+                for i, text in enumerate(texts):
+                    with st.expander(f"Page {i+1}"):
+                        st.markdown(text)
+                        while i not in audios:
+                            time.sleep(0.1)
+                        if audios.get(i):
+                            st.audio(audios[i])
+                            st.markdown(get_download_link(audios[i], "mp3"), unsafe_allow_html=True)
+                            voice = FUN_USERNAMES.get(st.session_state.username, "en-US-AriaNeural")
+                            asyncio.run(save_chat_entry(st.session_state.username, f"PDF Page {i+1} converted to audio: {audios[i]}", voice))
+
+    # Always Visible Media Gallery
+    st.header("📸 Media Gallery")
+    all_files = sorted(glob.glob("*.md") + glob.glob("*.mp3") + glob.glob("*.png") + glob.glob("*.mp4"), key=os.path.getmtime, reverse=True)
+    md_files = [f for f in all_files if f.endswith('.md')]
+    mp3_files = [f for f in all_files if f.endswith('.mp3')]
+    png_files = [f for f in all_files if f.endswith('.png')]
+    mp4_files = [f for f in all_files if f.endswith('.mp4')]
+
+    st.subheader("All Submitted Text")
+    all_md_content = concatenate_markdown_files()
+    st.markdown(all_md_content)
+
+    st.subheader("🎵 Audio (MP3)")
+    for mp3 in mp3_files:
+        with st.expander(os.path.basename(mp3)):
+            st.audio(mp3)
+            st.markdown(get_download_link(mp3, "mp3"), unsafe_allow_html=True)
+
+    st.subheader("🖼️ Images (PNG)")
+    for png in png_files:
+        with st.expander(os.path.basename(png)):
+            st.image(png, use_container_width=True)
+            st.markdown(get_download_link(png, "png"), unsafe_allow_html=True)
+
+    st.subheader("🎥 Videos (MP4)")
+    for mp4 in mp4_files:
+        with st.expander(os.path.basename(mp4)):
+            st.video(mp4)
+            st.markdown(get_download_link(mp4, "mp4"), unsafe_allow_html=True)
+
+    # 🗂️ Sidebar with Dialog and Audio
+    st.sidebar.subheader("Voice Settings")
+    new_username = st.sidebar.selectbox("Change Name/Voice", list(FUN_USERNAMES.keys()), index=list(FUN_USERNAMES.keys()).index(st.session_state.username), key="username_select")
     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 = st.text_input("Message", placeholder="Type your epic line here! ✍️")
-    if st.button("Send 🚀") and message.strip():
-        save_chat_entry(st.session_state.username, message)
+        asyncio.run(save_chat_entry("System 🌟", f"{st.session_state.username} changed to {new_username}", "en-US-AriaNeural"))
+        st.session_state.username, st.session_state.tts_voice = new_username, FUN_USERNAMES[new_username]
         st.session_state.timer_start = time.time()
         save_username(st.session_state.username)
         st.rerun()
 
-    # Quote section
-    st.subheader("Quote of the Moment 📝")
-    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("👍 Upvote", 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)
-                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)
-            st.rerun()
-    else:
-        st.markdown("No quotes available - check back later! 📭")
-
-    # IVA Media Gallery
-    st.subheader("IVA Media Gallery 🎨🎶🎥")
-    media_files = (
-        glob.glob(f"{MEDIA_DIR}/*.png") + glob.glob(f"{MEDIA_DIR}/*.jpg") + glob.glob(f"{MEDIA_DIR}/*.jpeg") +
-        glob.glob(f"{MEDIA_DIR}/*.mp3") + glob.glob(f"{MEDIA_DIR}/*.wav") +
-        glob.glob(f"{MEDIA_DIR}/*.mp4")
-    )
-    if media_files:
-        media_cols = st.slider("Gallery Columns", min_value=1, max_value=5, value=3)
-        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"👍 Upvote {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 'media' directory!")
-
-    # Refresh rate controls with pulsing timer
-    st.subheader("Set Refresh Rate ⏳")
-    refresh_rate = st.slider("Refresh Rate (seconds)", 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 (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 (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 (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()
+    st.sidebar.markdown("### 💬 Chat Dialog & Media")
+    chat_content = asyncio.run(load_chat())
+    st.sidebar.markdown(chat_content)
 
-    # Sidebar vote stats
     st.sidebar.subheader("Vote Totals")
     chat_votes = load_votes(QUOTE_VOTES_FILE)
     image_votes = load_votes(IMAGE_VOTES_FILE)
@@ -482,21 +734,18 @@ def create_streamlit_interface(initial_username):
     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()
-
-    # Start WebSocket server only once as a background task
-    if server_task is None:
-        server_task = asyncio.create_task(run_websocket_server())
-
-    query_params = st.query_params if hasattr(st, 'query_params') else {}
-    initial_username = query_params.get("username", random.choice(FUN_USERNAMES)) if query_params else random.choice(FUN_USERNAMES)
-    print(f"Welcoming {initial_username} to the Sector bash!")
+    st.sidebar.markdown("### 📂 File History")
+    for f in all_files[:10]:
+        st.sidebar.write(f"{FILE_EMOJIS.get(f.split('.')[-1], '📄')} {os.path.basename(f)}")
+    if st.sidebar.button("⬇️ Zip All", key="zip_all"):
+        zip_name = create_zip_of_files(md_files, mp3_files, png_files, mp4_files, "latest_query")
+        if zip_name:
+            st.sidebar.markdown(get_download_link(zip_name, "zip"), unsafe_allow_html=True)
 
-    create_streamlit_interface(initial_username)
+    # Start WebSocket server in a separate thread
+    if not st.session_state.server_running and not st.session_state.server_task:
+        st.session_state.server_task = threading.Thread(target=start_websocket_server, daemon=True)
+        st.session_state.server_task.start()
 
 if __name__ == "__main__":
-    asyncio.run(main())
+    main()