Update app.py

app.py

@@ -38,7 +38,7 @@ st.set_page_config(
     initial_sidebar_state="auto"
 )
 
-# Funky usernames with corresponding Edge TTS voices
+# Funky usernames with corresponding Edge TTS voices – a cosmic cast! 🌌🎭
 FUN_USERNAMES = {
     "CosmicJester 🌌": "en-US-AriaNeural",
     "PixelPanda 🐼": "en-US-JennyNeural",
@@ -62,18 +62,21 @@ FUN_USERNAMES = {
     "ChronoChimp 🐒": "en-GB-LibbyNeural"
 }
 
-# Top-level files (no subdirectories)
+# Top-level files and directories – the treasure trove of shared lore! 🗺️📜
 CHAT_FILE = "global_chat.md"
 QUOTE_VOTES_FILE = "quote_votes.md"
 MEDIA_VOTES_FILE = "media_votes.md"
 HISTORY_FILE = "chat_history.md"
 STATE_FILE = "user_state.txt"
-MEDIA_DIR = "media_base64"
+AUDIO_DIR = "audio_logs"
+MEDIA_DIR = "media_files"
+os.makedirs(AUDIO_DIR, exist_ok=True)
+os.makedirs(MEDIA_DIR, exist_ok=True)
 
-# Fancy digits - numbers got style! 🔢💃
+# Fancy digits - numbers got style, dancing in the cosmic light! 🔢💃
 UNICODE_DIGITS = {i: f"{i}\uFE0F⃣" for i in range(10)}
 
-# Massive font collection - typography bonanza! 🖋️🎨
+# Massive font collection - typography bonanza, a scribe’s delight! 🖋️🎨
 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)),
@@ -96,7 +99,7 @@ UNICODE_FONTS = [
     ("Regional Indicator", lambda x: "".join(chr(ord(c) - 0x41 + 0x1F1E6) if 'A' <= c <= 'Z' else c for c in x)),
 ]
 
-# Global state - keeping tabs! 🌍📋
+# Global state - keeping tabs! 🌍📋 – a shared saga begins! 🎭
 if 'server_running' not in st.session_state:
     st.session_state.server_running = False
 if 'server_task' not in st.session_state:
@@ -130,13 +133,13 @@ if 'user_id' not in st.session_state:
 if 'user_hash' not in st.session_state:
     st.session_state.user_hash = None
 
-# Timestamp wizardry - clock ticks with flair! ⏰🎩
+# Timestamp wizardry - clock ticks with flair, a temporal affair! ⏰🎩
 def format_timestamp_prefix(username):
     central = pytz.timezone('US/Central')
     now = datetime.now(central)
-    return f"{username}-{now.strftime('%I-%M-%p-%m-%d-%Y')}"
+    return f"{username}-{now.strftime('%I-%M-%p-%m-%d-%Y')}-{st.session_state.user_id}"
 
-# Compute image hash from binary data
+# Compute image hash - a cryptographic clash, securing our flash! 🛡️🔍
 def compute_image_hash(image_data):
     if isinstance(image_data, Image.Image):
         img_byte_arr = io.BytesIO()
@@ -146,7 +149,7 @@ def compute_image_hash(image_data):
         img_bytes = image_data
     return hashlib.md5(img_bytes).hexdigest()[:8]
 
-# Node naming - christening the beast! 🌐🍼
+# Node naming - christening the beast, a heroic feast! 🌐🍼
 def get_node_name():
     parser = argparse.ArgumentParser(description='Start a chat node with a specific name')
     parser.add_argument('--node-name', type=str, default=None)
@@ -156,7 +159,7 @@ def get_node_name():
     log_action(username, "🌐🍼 - Node naming - christening the beast!")
     return args.node_name or f"node-{uuid.uuid4().hex[:8]}", args.port
 
-# Action logger - spying on deeds! 🕵️📜
+# Action logger - spying on deeds, a stealthy steed! 🕵️📜
 def log_action(username, action):
     if 'action_log' not in st.session_state:
         st.session_state.action_log = {}
@@ -170,16 +173,53 @@ def log_action(username, action):
             f.write(f"[{datetime.now(central).strftime('%Y-%m-%d %H:%M:%S')}] {username}: {action}\n")
         user_log[action] = current_time
 
-# Clean text - strip the fancy stuff! 🧹📝
+# Clean text - strip the fancy fluff, a scribe’s tough bluff! 🧹📝
 def clean_text_for_tts(text):
     cleaned = re.sub(r'[#*!\[\]]+', '', text)
     cleaned = ' '.join(cleaned.split())
     return cleaned if cleaned else "No text to speak"  # Default if empty
 
-# Audio Processor Class from your code, adapted
+# Shared Memory Cache - the epic vault, a shared memory assault! 🗳️💾
+@st.cache_resource
+def get_shared_memory():
+    """
+    Oh, the cache, a grand, shared hall, where data dances, never to fall!
+    Thread-safe and global, it holds our lore, across users and sessions, forevermore! 🌍🧙
+    """
+    class SharedMemory:
+        def __init__(self):
+            self.chat_history = []  # Condensed dialogs, epic tales condensed!
+            self.media_files = []  # Media treasures, shared with flair and bends!
+            self.cache_time = datetime.now()  # Timestamp of glory, a hero’s blend!
+
+        def update_chat(self, entry):
+            """Add a chat entry, a rhyme in the stream, keeping our saga supreme! 💬🎶"""
+            self.chat_history.append(entry)
+            if len(self.chat_history) > 100:  # Limit to keep it tight, a knight’s fight!
+                self.chat_history.pop(0)
+
+        def update_media(self, media_path):
+            """Store media files, a visual dream, in our shared cache, a radiant beam! 🖼️🌟"""
+            self.media_files.append(media_path)
+            if len(self.media_files) > 50:  # Cap the hoard, lest it grow too wide!
+                self.media_files.pop(0)
+
+        def get_condensed_dialogs(self):
+            """Condense the chatter, a poetic pact, short and sweet, our story intact! 🗣️✨"""
+            return "\n".join(f"- {entry.split(': ')[1][:50]}" for entry in self.chat_history[-10:])
+
+        def clear(self):
+            """Clear the cache, a dramatic purge, resetting our tale, a new surge! 🌀🔥"""
+            self.chat_history.clear()
+            self.media_files.clear()
+            self.cache_time = datetime.now()
+
+    return SharedMemory()
+
+# Audio Processor Class - voices echo, a sonic hero! 🎶🌟
 class AudioProcessor:
     def __init__(self):
-        self.cache_dir = "audio_cache"
+        self.cache_dir = AUDIO_DIR
         os.makedirs(self.cache_dir, exist_ok=True)
         self.metadata = self._load_metadata()
 
@@ -193,28 +233,32 @@ class AudioProcessor:
             json.dump(self.metadata, f)
 
     async def create_audio(self, text, voice='en-US-AriaNeural', filename=None):
+        """
+        Create audio, a voice that roars, in our shared cache, through cosmic doors! 🎤🌌
+        """
         cache_key = hashlib.md5(f"{text}:{voice}".encode()).hexdigest()
-        cache_path = filename or os.path.join(self.cache_dir, f"{cache_key}.mp3")
+        timestamp = format_timestamp_prefix(st.session_state.username)
+        filename = filename or os.path.join(self.cache_dir, f"audio_{timestamp}_{random.randint(1000, 9999)}.mp3")
 
-        if cache_key in self.metadata and os.path.exists(cache_path):
-            return cache_path
+        if cache_key in self.metadata and os.path.exists(filename):
+            return filename
 
-        # Clean text for speech
+        # Clean text for speech, a bard’s clean sweep!
         text = text.replace("\n", " ").replace("</s>", " ").strip()
         if not text:
             return None
 
-        # Generate audio with edge_tts
+        # Generate audio, a sonic leap, with edge_tts, our voices deep!
         try:
             communicate = edge_tts.Communicate(text, voice)
-            await communicate.save(cache_path)
-            if not os.path.exists(cache_path):
+            await communicate.save(filename)
+            if not os.path.exists(filename):
                 raise edge_tts.exceptions.NoAudioReceived("No audio file created")
         except edge_tts.exceptions.NoAudioReceived as e:
             log_action("System 🌟", f"TTS failed for text '{text}' with voice '{voice}': {str(e)}")
             return None
 
-        # Update metadata
+        # Update metadata, our epic creed, in shared memory, a heroic deed!
         self.metadata[cache_key] = {
             'timestamp': datetime.now().isoformat(),
             'text_length': len(text),
@@ -222,18 +266,21 @@ class AudioProcessor:
         }
         self._save_metadata()
 
-        return cache_path
+        return filename
 
-# Chat saver - words locked tight! 💬🔒
+# Chat saver - words locked tight, in shared memory’s light! 💬🔒
 async def save_chat_entry(username, message, is_markdown=False, quote_line=None, media_file=None, skip_audio=False):
+    """
+    Save chats with flair, in shared cache we dare, a rhyming affair! ✨🎉
+    """
     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")
     user_history_file = f"{username}_history.md"
     voice = st.session_state.voice if username == st.session_state.username else FUN_USERNAMES.get(username, "en-US-AriaNeural")
-    indent = "  " if quote_line else ""  # Nesting for replies
+    indent = "  " if quote_line else ""  # Nesting for replies, a poetic spree!
 
-    # Prepare entry
+    # Prepare entry, a verse so bright, in shared memory’s sight!
     if is_markdown:
         entry = f"{indent}[{timestamp}] {username}:\n{indent}```markdown\n{indent}{message}\n{indent}```"
     else:
@@ -241,46 +288,52 @@ async def save_chat_entry(username, message, is_markdown=False, quote_line=None,
     if quote_line:
         entry = f"{indent}> {quote_line}\n{entry}"
 
-    # Save to global chat file
+    # Save to global chat file, a shared epic tale, never frail!
     with open(CHAT_FILE, 'a') as f:
         f.write(f"{entry}\n")
 
-    # Save to user-specific history file
+    # Save to user-specific history, a personal rhyme, in shared time!
     if not os.path.exists(user_history_file):
         with open(user_history_file, 'w') as f:
             f.write(f"# Chat History for {username} (Voice: {voice})\n\n")
     with open(user_history_file, 'a') as f:
         f.write(f"{entry}\n")
 
-    # Generate audio (unless skipped)
+    # Generate audio, unless we skip, in shared cache, a sonic grip!
+    audio_filename = None  # Initialize, lest our tale derail!
     if not skip_audio and message.strip():
         cleaned_message = clean_text_for_tts(message)
         audio_processor = AudioProcessor()
-        audio_filename = f"{format_timestamp_prefix(username)}-{hashlib.md5(cleaned_message.encode()).hexdigest()[:8]}.mp3"
-        log_action(username, f"Attempting TTS with text: '{cleaned_message}' and voice: '{voice}'")
-        audio_file = await audio_processor.create_audio(cleaned_message, voice, audio_filename)
-        
-        # Log audio
-        if audio_file:
+        audio_filename = await audio_processor.create_audio(cleaned_message, voice)
+        if audio_filename:
             with open(HISTORY_FILE, 'a') as f:
                 f.write(f"[{timestamp}] {username} ({voice}): Audio generated - {audio_filename}\n")
             with open(user_history_file, 'a') as f:
                 f.write(f"{indent}[{timestamp}] Audio: {audio_filename}\n")
             with open(CHAT_FILE, 'a') as f:
                 f.write(f"{indent}[{timestamp}] Audio: {audio_filename}\n")
+
+    # Handle media files, a visual quest, in shared memory, our treasure chest!
     if media_file:
         if isinstance(media_file, Image.Image):
             timestamp_prefix = format_timestamp_prefix(username)
-            media_filename = f"{username}-{timestamp_prefix.split('-')[-1]}.png"
-            media_path = media_filename  # Save at root
+            media_filename = f"{username}-{timestamp_prefix.split('-')[-1]}.{media_file.format.lower()}"
+            media_path = os.path.join(MEDIA_DIR, media_filename)
             img_byte_arr = io.BytesIO()
-            media_file.save(img_byte_arr, format='PNG')
+            media_file.save(img_byte_arr, format=media_file.format)
             await asyncio.to_thread(lambda: open(media_path, 'wb').write(img_byte_arr.getvalue()))
             media_file = media_filename
-        elif media_file.name in ['png', 'jpg', 'mp4', 'mp3']:
+        elif media_file.name in ['png', 'jpg', 'mp4', 'mp3', 'wav']:
             timestamp_prefix = format_timestamp_prefix(username)
             media_filename = f"{username}-{timestamp_prefix.split('-')[-1]}.{media_file.name.split('.')[-1]}"
-            media_path = media_filename  # Save at root
+            media_path = os.path.join(MEDIA_DIR, media_filename)
+            await asyncio.to_thread(lambda: open(media_path, 'wb').write(media_file.getbuffer()))
+            media_file = media_filename
+        elif media_file.name == 'pdf':
+            timestamp_prefix = format_timestamp_prefix(username)
+            file_hash = hashlib.md5(media_file.getbuffer()).hexdigest()[:8]
+            media_filename = f"{username}-{timestamp_prefix.split('-')[-1]}-{file_hash}.pdf"
+            media_path = os.path.join(MEDIA_DIR, media_filename)
             await asyncio.to_thread(lambda: open(media_path, 'wb').write(media_file.getbuffer()))
             media_file = media_filename
         with open(CHAT_FILE, 'a') as f:
@@ -288,12 +341,21 @@ async def save_chat_entry(username, message, is_markdown=False, quote_line=None,
         with open(user_history_file, 'a') as f:
             f.write(f"{indent}[{timestamp}] Media: ![Media]({media_file})\n")
 
+    # Update shared memory, our epic lore, in cache forevermore!
+    shared_memory = get_shared_memory()
+    shared_memory.update_chat(entry)
+    if media_file:
+        shared_memory.update_media(os.path.join(MEDIA_DIR, media_file))
+
     await broadcast_message(f"{username}|{message}", "chat")
     st.session_state.last_chat_update = time.time()
-    return audio_filename
+    return audio_filename  # Return, even if silent, our tale’s delight!
 
-# Save chat history with image or PDF
+# Save chat history with image or PDF - a scribe’s historic flight! 📜🚀
 async def save_chat_history_with_image(username, image_path):
+    """
+    Save history, a scribe’s grand sight, in shared memory, pure and bright! ✨📖
+    """
     central = pytz.timezone('US/Central')
     timestamp = datetime.now(central).strftime("%Y-%m-%d_%H-%M-%S")
     user_history_file = f"{username}_history.md"
@@ -306,8 +368,12 @@ async def save_chat_history_with_image(username, image_path):
         f.write(f"[{timestamp}] {username} (Voice: {voice}) Shared Media: {os.path.basename(image_path)}\n")
         f.write(f"```markdown\n{chat_content}\n```\n")
 
-# Chat loader - history unleashed! 📜🚀
+# Chat loader - history unleashed, a shared epic feast! 📜🚀
+@st.cache_resource
 async def load_chat():
+    """
+    Load chats, a shared memory spree, from cache with glee, our history free! 🌟💬
+    """
     username = st.session_state.get('username', 'System 🌟')
     await asyncio.to_thread(log_action, username, "📜🚀 - Chat loader - history unleashed!")
     if not os.path.exists(CHAT_FILE):
@@ -316,8 +382,11 @@ async def load_chat():
         content = await asyncio.to_thread(f.read)
     return content
 
-# User lister - who’s in the gang! 👥🎉
+# User lister - who’s in the gang, a shared memory bang! 👥🎉
 async def get_user_list(chat_content):
+    """
+    List users, a shared roster’s rhyme, in cache divine, through space and time! 🌍🎭
+    """
     username = st.session_state.get('username', 'System 🌟')
     await asyncio.to_thread(log_action, username, "👥🎉 - User lister - who’s in the gang!")
     users = set()
@@ -327,22 +396,32 @@ async def get_user_list(chat_content):
             users.add(user)
     return sorted(list(users))
 
-# Join checker - been here before? 🚪🔍
+# Join checker - been here before, in shared cache, a lore galore! 🚪🔍
 async def has_joined_before(client_id, chat_content):
+    """
+    Check joins, a shared memory chore, in cache secure, forevermore! 🌀🔐
+    """
     username = st.session_state.get('username', 'System 🌟')
     await asyncio.to_thread(log_action, username, "🚪🔍 - Join checker - been here before?")
     return any(f"Client-{client_id}" in line for line in chat_content.split('\n'))
 
-# Suggestion maker - old quips resurface! 💡📝
+# Suggestion maker - old quips resurface, in shared cache, a verse so fierce! 💡📝
 async def get_message_suggestions(chat_content, prefix):
+    """
+    Suggest quips, a shared memory jest, in cache we nest, our humor blessed! 😂🌟
+    """
     username = st.session_state.get('username', 'System 🌟')
     await asyncio.to_thread(log_action, username, "💡📝 - Suggestion maker - old quips resurface!")
     lines = chat_content.split('\n')
     messages = [line.split(': ', 1)[1] for line in lines if ': ' in line and line.strip()]
     return [msg for msg in messages if msg.lower().startswith(prefix.lower())][:5]
 
-# Vote saver - cheers recorded! 👍📊
+# Vote saver - cheers recorded, in shared cache, our cheers restored! 👍📊
+@st.cache_resource
 async def save_vote(file, item, user_hash, username, comment=""):
+    """
+    Save votes, a shared tally’s cheer, in cache so clear, our triumph near! 🏆🎉
+    """
     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")
@@ -353,9 +432,14 @@ async def save_vote(file, item, user_hash, username, comment=""):
     if comment:
         chat_message += f" - {comment}"
     await save_chat_entry(username, chat_message)
+    return entry  # Return for caching, our epic fling!
 
-# Vote counter - tallying the love! 🏆📈
+# Vote counter - tallying the love, in shared cache, a tale above! 🏆📈
+@st.cache_resource
 async def load_votes(file):
+    """
+    Count votes, a shared tally’s might, in cache so bright, our victory’s light! 🌟📊
+    """
     username = st.session_state.get('username', 'System 🌟')
     await asyncio.to_thread(log_action, username, "🏆📈 - Vote counter - tallying the love!")
     if not os.path.exists(file):
@@ -375,76 +459,88 @@ async def load_votes(file):
                 user_votes.add(vote_key)
     return votes
 
-# Hash generator - secret codes ahoy! 🔑🕵️
+# Hash generator - secret codes ahoy, in shared cache, a cryptic joy! 🔑🕵️
 async def generate_user_hash():
+    """
+    Generate hashes, a shared code’s chime, in cache sublime, through space and time! 🌌🔐
+    """
     username = st.session_state.get('username', 'System 🌟')
     await asyncio.to_thread(log_action, username, "🔑🕵️ - Hash generator - secret codes ahoy!")
     if 'user_hash' not in st.session_state:
         st.session_state.user_hash = hashlib.md5(str(random.getrandbits(128)).encode()).hexdigest()[:8]
     return st.session_state.user_hash
 
-# Audio maker - voices come alive! 🎶🌟
+# Audio maker - voices come alive, in shared cache, a sonic dive! 🎶🌟
 async def async_edge_tts_generate(text, voice, rate=0, pitch=0, file_format="mp3"):
+    """
+    Make audio, a shared voice’s thrill, in cache we fill, with sonic will! 🎤🔊
+    """
     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}-{hashlib.md5(text.encode()).hexdigest()[:8]}.{file_format}"
-    filepath = filename  # Top-level file
+    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")
         return None
 
-# Audio player - tunes blast off! 🔊🚀
+# Audio player - tunes blast off, in shared cache, a musical scoff! 🔊🚀
 def play_and_download_audio(file_path):
+    """
+    Play tunes, a shared melody’s jest, in cache expressed, our audio quest! 🎵🌌
+    """
     if file_path and os.path.exists(file_path):
+        st.audio(file_path)
         with open(file_path, "rb") as f:
-            audio_data = f.read()
-        b64 = base64.b64encode(audio_data).decode()
-        audio_html = f'''
-        <audio controls style="display:inline; vertical-align:middle; width:100px;">
-            <source src="data:audio/mpeg;base64,{b64}" type="audio/mpeg">
-        </audio>
-        <a href="data:audio/mpeg;base64,{b64}" download="{os.path.basename(file_path)}" style="vertical-align:middle;">🎵</a>
-        '''
-        return audio_html
-    return ""
-
-# Image saver - pics preserved with naming! 📸💾
+            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, in shared cache, a visual burst! 📸💾
 async def save_pasted_image(image, username):
+    """
+    Save images, a shared sight’s cheer, in cache so clear, our vision near! 🖼️🌟
+    """
     await asyncio.to_thread(log_action, username, "📸💾 - Image saver - pics preserved!")
     timestamp = format_timestamp_prefix(username)
     media_filename = f"{username}-{timestamp.split('-')[-1]}.png"
-    media_path = media_filename  # Save at root
+    media_path = os.path.join(MEDIA_DIR, media_filename)
     img_byte_arr = io.BytesIO()
     image.save(img_byte_arr, format='PNG')
     await asyncio.to_thread(lambda: open(media_path, 'wb').write(img_byte_arr.getvalue()))
     return media_filename
 
-# Video and Audio savers
+# Video and Audio savers - media magic, in shared cache, a heroic tragic! 🎥🎶
 async def save_media(file, username, ext):
+    """
+    Save media, a shared epic’s might, in cache so bright, our treasures ignite! 🧙🔥
+    """
     await asyncio.to_thread(log_action, username, f"📸💾 - Media saver - {ext} preserved!")
     timestamp = format_timestamp_prefix(username)
     media_filename = f"{username}-{timestamp.split('-')[-1]}.{ext}"
-    media_path = media_filename  # Save at root
+    media_path = os.path.join(MEDIA_DIR, media_filename)
     await asyncio.to_thread(lambda: open(media_path, 'wb').write(file.getbuffer()))
     return media_filename
 
-# PDF saver and audio generator
+# PDF saver and audio generator - documents dance, in shared cache, a chance! 📜🎶
 async def save_pdf_and_generate_audio(pdf_file, username, max_pages=10):
+    """
+    Save PDFs, a shared document’s glee, in cache we see, our history’s key! 📚🌟
+    """
     await asyncio.to_thread(log_action, username, "📜🎶 - PDF saver and audio generator!")
     timestamp = format_timestamp_prefix(username)
     file_hash = hashlib.md5(pdf_file.getbuffer()).hexdigest()[:8]
     pdf_filename = f"{username}-{timestamp.split('-')[-1]}-{file_hash}.pdf"
-    with open(pdf_filename, 'wb') as f:
+    media_path = os.path.join(MEDIA_DIR, pdf_filename)
+    with open(media_path, 'wb') as f:
         f.write(pdf_file.getbuffer())
 
-    reader = PdfReader(pdf_filename)
+    reader = PdfReader(media_path)
     total_pages = min(len(reader.pages), max_pages)
     texts = []
     audio_files = []
@@ -456,15 +552,19 @@ async def save_pdf_and_generate_audio(pdf_file, username, max_pages=10):
         text = reader.pages[i].extract_text()
         texts.append(text)
         audio_filename = f"{username}-{timestamp.split('-')[-1]}-page{i+1}-{file_hash}-voice-{voice}.mp3"
-        audio_data = await audio_processor.create_audio(text, voice, audio_filename)
+        audio_path = os.path.join(AUDIO_DIR, audio_filename)
+        audio_data = await audio_processor.create_audio(text, voice, audio_path)
         if audio_data:
             audio_files.append(audio_filename)
 
     return pdf_filename, texts, audio_files
 
-# Video renderer - movies roll with autoplay! 🎥🎬
+# Video renderer - movies roll, in shared cache, a visual toll! 🎥🎬
 def get_video_html(video_path, width="100px"):
-    video_url = f"data:video/mp4;base64,{base64.b64encode(open(video_path, 'rb').read()).decode()}"
+    """
+    Render videos, a shared screen’s thrill, in cache we fill, with cinematic will! 📺🌌
+    """
+    video_url = f"data:video/mp4;base64,{base64.b64encode(open(os.path.join(MEDIA_DIR, video_path), 'rb').read()).decode()}"
     return f'''
     <video width="{width}" controls autoplay muted loop>
         <source src="{video_url}" type="video/mp4">
@@ -472,11 +572,14 @@ def get_video_html(video_path, width="100px"):
     </video>
     '''
 
-# Audio renderer - sounds soar! 🎶✈️
+# Audio renderer - sounds soar, in shared cache, a sonic roar! 🎶✈️
 async def get_audio_html(audio_path, width="100px"):
+    """
+    Render audio, a shared sound’s cheer, in cache so clear, our music near! 🎵🌟
+    """
     username = st.session_state.get('username', 'System 🌟')
     await asyncio.to_thread(log_action, username, "���✈️ - Audio renderer - sounds soar!")
-    audio_url = f"data:audio/mpeg;base64,{base64.b64encode(await asyncio.to_thread(open, audio_path, 'rb').read()).decode()}"
+    audio_url = f"data:audio/mpeg;base64,{base64.b64encode(await asyncio.to_thread(open, os.path.join(AUDIO_DIR, audio_path), 'rb').read()).decode()}"
     return f'''
     <audio controls style="width: {width};">
         <source src="{audio_url}" type="audio/mpeg">
@@ -484,8 +587,11 @@ async def get_audio_html(audio_path, width="100px"):
     </audio>
     '''
 
-# Websocket handler - chat links up! 🌐🔗
+# Websocket handler - chat links up, in shared cache, a connection’s cup! 🌐🔗
 async def websocket_handler(websocket, path):
+    """
+    Handle chats, a shared link’s might, in cache so bright, our network’s light! 🌍🔌
+    """
     username = st.session_state.get('username', 'System 🌟')
     await asyncio.to_thread(log_action, username, "🌐🔗 - Websocket handler - chat links up!")
     try:
@@ -507,8 +613,11 @@ async def websocket_handler(websocket, path):
         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]
 
-# Message broadcaster - words fly far! 📢✈️
+# Message broadcaster - words fly far, in shared cache, a starry czar! 📢✈️
 async def broadcast_message(message, room_id):
+    """
+    Broadcast words, a shared echo’s cheer, in cache so clear, our message near! 🌠📡
+    """
     username = st.session_state.get('username', 'System 🌟')
     await asyncio.to_thread(log_action, username, "📢✈️ - Message broadcaster - words fly far!")
     if room_id in st.session_state.active_connections:
@@ -521,8 +630,11 @@ async def broadcast_message(message, room_id):
         for client_id in disconnected:
             del st.session_state.active_connections[room_id][client_id]
 
-# Server starter - web spins up! 🖥️🌀
+# Server starter - web spins up, in shared cache, a digital pup! 🖥️🌀
 async def run_websocket_server():
+    """
+    Start server, a shared spin’s delight, in cache so right, our web takes flight! 🚀🌐
+    """
     username = st.session_state.get('username', 'System 🌟')
     await asyncio.to_thread(log_action, username, "🖥️🌀 - Server starter - web spins up!")
     if not st.session_state.server_running:
@@ -530,9 +642,12 @@ async def run_websocket_server():
         st.session_state.server_running = True
         await server.wait_closed()
 
-# Delete all user files function
+# Delete all user files - a purge so grand, in shared cache, a clearing band! 🗑️🔥
 def delete_user_files():
-    protected_files = {'app.py', 'requirements.txt', 'README.md', CHAT_FILE, QUOTE_VOTES_FILE, MEDIA_VOTES_FILE, HISTORY_FILE, STATE_FILE, MEDIA_DIR}
+    """
+    Delete files, a shared purge’s might, in cache so light, our slate wiped tight! 🧹🌌
+    """
+    protected_files = {'app.py', 'requirements.txt', 'README.md', CHAT_FILE, QUOTE_VOTES_FILE, MEDIA_VOTES_FILE, HISTORY_FILE, STATE_FILE, AUDIO_DIR, MEDIA_DIR}
     deleted_files = []
     for file in os.listdir('.'):
         if file not in protected_files and not file.endswith('_history.md'):
@@ -541,6 +656,14 @@ def delete_user_files():
                 deleted_files.append(file)
             except Exception as e:
                 st.error(f"Failed to delete {file}: {e}")
+    for root, dirs, files in os.walk(AUDIO_DIR):
+        for file in files:
+            file_path = os.path.join(root, file)
+            try:
+                os.remove(file_path)
+                deleted_files.append(file_path)
+            except Exception as e:
+                st.error(f"Failed to delete {file_path}: {e}")
     for root, dirs, files in os.walk(MEDIA_DIR):
         for file in files:
             file_path = os.path.join(root, file)
@@ -555,8 +678,11 @@ def delete_user_files():
     st.session_state.displayed_chat_lines.clear()
     return deleted_files
 
-# Query parameter checker - parse q for username
+# Query parameter checker - parse q with flair, in shared cache, a naming affair! 🚪🔍
 def check_query_params():
+    """
+    Check queries, a shared name’s quest, in cache so blessed, our path expressed! 🌟🔍
+    """
     query_params = st.query_params if hasattr(st, 'query_params') else st.experimental_get_query_params()
     q_value = query_params.get("q", [None])[0]
     if q_value and q_value in FUN_USERNAMES:
@@ -567,8 +693,11 @@ def check_query_params():
         st.session_state.user_id = q_value  # Use as user_id if not a valid username
     return None
 
-# Mermaid graph generator
+# Mermaid graph generator - visualize our tale, in shared cache, a graphic gale! 🌳📈
 def generate_mermaid_graph(chat_lines):
+    """
+    Generate graphs, a shared vision’s rhyme, in cache sublime, our story’s chime! 🧩🌌
+    """
     mermaid_code = "graph TD\n"
     nodes = {}
     edges = []
@@ -579,7 +708,7 @@ def generate_mermaid_graph(chat_lines):
             user = content.split(' ')[0]
             message = content.split(' ', 1)[1] if ' ' in content else ''
             node_id = f"{user}_{i}"
-            nodes[node_id] = f"{user}: {message}"
+            nodes[node_id] = f"{user}: {message[:20]}..." if len(message) > 20 else f"{user}: {message}"
             if i + 1 < len(chat_lines) and "Audio:" in chat_lines[i + 1]:
                 audio_node = f"audio_{i}"
                 nodes[audio_node] = "🎵"
@@ -598,20 +727,23 @@ def generate_mermaid_graph(chat_lines):
     mermaid_code += "\n".join(f"    {edge}" for edge in edges)
     return mermaid_code
 
-# Main execution - let’s roll! 🎲🚀
+# Main execution - let’s roll, in shared cache, a heroic toll! 🎲🚀
 def main():
+    """
+    Launch our tale, a shared epic’s start, in cache so smart, our hearts impart! 🌠🎉
+    """
     NODE_NAME, port = get_node_name()
 
     loop = asyncio.new_event_loop()
     asyncio.set_event_loop(loop)
 
     async def async_interface():
-        # Generate user ID and hash if not set
+        # Generate user ID and hash, a shared identity’s clash! 🆔🔮
         if not st.session_state.user_id:
             st.session_state.user_id = str(uuid.uuid4())
             st.session_state.user_hash = await generate_user_hash()
 
-        # Check query params first to override username
+        # Check query params, a shared name’s quest, in cache expressed, our path impressed! 🚪🔍
         q_value = check_query_params()
         if not q_value and 'username' not in st.session_state:
             chat_content = await load_chat()
@@ -620,7 +752,7 @@ def main():
             st.session_state.voice = FUN_USERNAMES[st.session_state.username]
             st.markdown(f"**🎙️ Voice Selected**: {st.session_state.voice} 🗣️ for {st.session_state.username}")
 
-        # Check existing history file for content
+        # Check existing history, a shared memory’s cheer, in cache so clear, our lore near! 📜🌟
         user_history_file = f"{st.session_state.username}_history.md"
         if os.path.exists(user_history_file):
             with open(user_history_file, 'r') as f:
@@ -637,9 +769,10 @@ def main():
         if not st.session_state.server_task:
             st.session_state.server_task = loop.create_task(run_websocket_server())
 
-        # Unified Chat History at Top with Markdown Emoji Output
+        # Unified Chat History at Top - a shared epic’s roar, condensed and stored! 💬🌌
         with st.container():
             st.markdown(f"##### {START_ROOM} Chat History 💬")
+            shared_memory = get_shared_memory()
             chat_content = await load_chat()
             chat_lines = [line for line in chat_content.split('\n') if line.strip() and not line.startswith('#')]
             if chat_lines:
@@ -668,19 +801,27 @@ def main():
                                     audio_html = play_and_download_audio(audio_file)
                                 elif "Media:" in nl:
                                     media_file = nl.split("Media: ")[-1].strip('![]()')
-                                    if media_file.endswith(('.png', '.jpg')):
-                                        media_content = f"<img src='file://{media_file}' width='100'>"
-                                    elif media_file.endswith('.mp4'):
-                                        media_content = get_video_html(media_file)
-                                    elif media_file.endswith('.mp3'):
-                                        media_content = await get_audio_html(media_file)
-                                    elif media_file.endswith('.pdf'):
-                                        media_content = f"📜 {os.path.basename(media_file)}"
-                            minute_output += f"- 💬 **{user}**: {msg} {audio_html} {media_content}\n"
+                                    media_path = os.path.join(MEDIA_DIR, media_file)
+                                    if os.path.exists(media_path):
+                                        if media_file.endswith(('.png', '.jpg')):
+                                            media_content = f"<img src='file://{media_path}' width='100'>"
+                                        elif media_file.endswith('.mp4'):
+                                            media_content = get_video_html(media_file)
+                                        elif media_file.endswith('.mp3'):
+                                            media_content = await get_audio_html(media_file)
+                                        elif media_file.endswith('.pdf'):
+                                            media_content = f"📜 {os.path.basename(media_file)}"
+                            minute_output += f"- 💬 **{user}**: {msg[:50]}... {audio_html} {media_content}\n"  # Condensed dialog
                     markdown_output += minute_output
                 st.markdown(markdown_output, unsafe_allow_html=True)
+                shared_memory.update_chat(markdown_output)  # Cache condensed dialogs
 
-            # Mermaid Graph Visualization
+            # Condensed Dialogs Display - a shared tale, concise and hale! 🗣️✨
+            st.markdown("###### Condensed Dialogs 🗣️")
+            condensed_dialogs = shared_memory.get_condensed_dialogs()
+            st.markdown(condensed_dialogs)
+
+            # Mermaid Graph Visualization - a shared map, our chat’s trap! 🌳📈
             st.markdown("###### Chat Relationship Tree 🌳")
             mermaid_code = generate_mermaid_graph(chat_lines)
             mermaid_html = f"""
@@ -725,7 +866,7 @@ def main():
                 st.markdown(f"**🎙️ Voice Changed**: {st.session_state.voice} 🗣️ for {st.session_state.username}")
                 st.rerun()
 
-            # Message input with Send button on the right
+            # Message input with Send button on the right - a shared chat’s might! 💬🚀
             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)
@@ -747,7 +888,6 @@ def main():
                     st.image(paste_result_msg.image_data, caption="Received Image for Quote")
                     filename = await save_pasted_image(paste_result_msg.image_data, st.session_state.username)
                     if filename:
-                        st.session_state.pasted_image_data = filename
                         await save_chat_entry(st.session_state.username, "Image shared", is_markdown=True, media_file=paste_result_msg.image_data, skip_audio=True)
                         st.session_state.pasted_image_data = None
                         st.rerun()
@@ -768,16 +908,21 @@ def main():
                     filename = pdf_filename
                 else:
                     filename = f"{username}-{timestamp.split('-')[-1]}.{ext}"
-                    await asyncio.to_thread(lambda: open(filename, 'wb').write(uploaded_file.getbuffer()))
+                    media_path = os.path.join(MEDIA_DIR, filename)
+                    await asyncio.to_thread(lambda: open(media_path, 'wb').write(uploaded_file.getbuffer()))
                 await save_chat_entry(username, f"Uploaded {ext.upper()}: {os.path.basename(filename)}", media_file=uploaded_file, skip_audio=True)
+                shared_memory = get_shared_memory()
+                shared_memory.update_media(os.path.join(MEDIA_DIR, filename))  # Cache media
                 st.success(f"Uploaded {filename}")
 
-            # Big Red Delete Button
+            # Big Red Delete Button - a purge so grand, clearing our shared land! 🗑️🔥
             st.markdown("###### 🛑 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]))
+                    shared_memory = get_shared_memory()
+                    shared_memory.clear()  # Clear shared cache on purge
                 else:
                     st.markdown("### 🗑️ Nothing to Delete!")
                 st.rerun()
@@ -793,11 +938,12 @@ def main():
                 time.sleep(1)
             st.rerun()
 
-        # Separate Galleries for Own and Shared Files
+        # Separate Galleries for Own and Shared Files - a shared gallery’s glare! 🖼️🎥
         with st.container():
-            all_files = glob.glob("*.md") + glob.glob("*.pdf") + glob.glob("*.txt") + glob.glob("*.py") + glob.glob("*.png") + glob.glob("*.jpg") + glob.glob("*.mp3") + glob.glob("*.mp4") + glob.glob(os.path.join(MEDIA_DIR, "*.b64"))
+            all_files = glob.glob(os.path.join(MEDIA_DIR, "*.md")) + glob.glob(os.path.join(MEDIA_DIR, "*.pdf")) + glob.glob(os.path.join(MEDIA_DIR, "*.txt")) + glob.glob(os.path.join(MEDIA_DIR, "*.py")) + glob.glob(os.path.join(MEDIA_DIR, "*.png")) + glob.glob(os.path.join(MEDIA_DIR, "*.jpg")) + glob.glob(os.path.join(MEDIA_DIR, "*.mp3")) + glob.glob(os.path.join(MEDIA_DIR, "*.mp4")) + glob.glob(os.path.join(AUDIO_DIR, "*.mp3"))
+            shared_memory = get_shared_memory()
             own_files = [f for f in all_files if st.session_state.user_id in os.path.basename(f) or st.session_state.username in os.path.basename(f)]
-            shared_files = [f for f in all_files if f not in own_files and not f in [CHAT_FILE, QUOTE_VOTES_FILE, MEDIA_VOTES_FILE, HISTORY_FILE, STATE_FILE, os.path.join(MEDIA_DIR, "*")]]
+            shared_files = [f for f in all_files if f not in own_files and not f in [CHAT_FILE, QUOTE_VOTES_FILE, MEDIA_VOTES_FILE, HISTORY_FILE, STATE_FILE, os.path.join(AUDIO_DIR, "*"), os.path.join(MEDIA_DIR, "*")]]
 
             st.markdown("###### Your Files 📂")
             st.markdown("###### Image Gallery 🖼")
@@ -807,6 +953,7 @@ def main():
             for idx, image_file in enumerate(own_image_files):
                 with cols[idx % image_cols]:
                     st.image(image_file, use_container_width=True)
+                    shared_memory.update_media(image_file)  # Cache media
 
             st.markdown("###### Video Gallery 🎥")
             own_video_files = [f for f in own_files if f.endswith('.mp4')]
@@ -815,14 +962,16 @@ def main():
             for idx, video_file in enumerate(own_video_files):
                 with cols[idx % video_cols]:
                     st.markdown(get_video_html(video_file), unsafe_allow_html=True)
+                    shared_memory.update_media(video_file)  # Cache media
 
             st.markdown("###### Audio Gallery 🎧")
-            own_audio_files = [f for f in own_files if f.endswith(('.mp3', '.wav'))]
+            own_audio_files = [f for f in own_files if f.endswith(('.mp3', '.wav')) or f.startswith(os.path.join(AUDIO_DIR, "audio_"))]
             audio_cols = st.slider("Audio Gallery Columns 🎶 (Own)", min_value=1, max_value=15, value=5)
             cols = st.columns(audio_cols)
             for idx, audio_file in enumerate(own_audio_files):
                 with cols[idx % audio_cols]:
                     st.markdown(await get_audio_html(audio_file), unsafe_allow_html=True)
+                    shared_memory.update_media(audio_file)  # Cache media
 
             st.markdown("###### Shared Files 📤")
             st.markdown("###### Image Gallery 🖼")
@@ -832,6 +981,7 @@ def main():
             for idx, image_file in enumerate(shared_image_files):
                 with cols[idx % image_cols]:
                     st.image(image_file, use_container_width=True)
+                    shared_memory.update_media(image_file)  # Cache media
 
             st.markdown("###### Video Gallery 🎥")
             shared_video_files = [f for f in shared_files if f.endswith('.mp4')]
@@ -840,16 +990,18 @@ def main():
             for idx, video_file in enumerate(shared_video_files):
                 with cols[idx % video_cols]:
                     st.markdown(get_video_html(video_file), unsafe_allow_html=True)
+                    shared_memory.update_media(video_file)  # Cache media
 
             st.markdown("###### Audio Gallery 🎧")
-            shared_audio_files = [f for f in shared_files if f.endswith(('.mp3', '.wav'))]
+            shared_audio_files = [f for f in shared_files if f.endswith(('.mp3', '.wav')) or f.startswith(os.path.join(AUDIO_DIR, "audio_"))]
             audio_cols = st.slider("Audio Gallery Columns 🎶 (Shared)", min_value=1, max_value=15, value=5)
             cols = st.columns(audio_cols)
             for idx, audio_file in enumerate(shared_audio_files):
                 with cols[idx % audio_cols]:
                     st.markdown(await get_audio_html(audio_file), unsafe_allow_html=True)
+                    shared_memory.update_media(audio_file)  # Cache media
 
-        # Full Log at End with Download
+        # Full Log at End with Download - a shared epic’s end, our tale to mend! 📜📥
         with st.container():
             st.markdown("###### Full Chat Log 📜")
             with open(CHAT_FILE, 'r') as f:
@@ -857,7 +1009,16 @@ def main():
             st.markdown(history_content)
             st.download_button("Download Chat Log as .md", history_content, file_name=f"chat_{st.session_state.user_id}.md", mime="text/markdown")
 
+        # Clear Cache Button - purge the cache, a shared epic’s crash! 🗑️🔄
+        if st.button("Clear Shared Memory Cache", key="clear_cache"):
+            shared_memory = get_shared_memory()
+            shared_memory.clear()
+            st.success("Shared memory cache cleared, a fresh start with a bard’s heart! 🌟🎶")
+
     loop.run_until_complete(async_interface())
 
 if __name__ == "__main__":
+    """
+    Launch our saga, a shared memory’s cheer, in Streamlit’s cache, our epic year! 🚀✨
+    """
     main()