import streamlit as st
import asyncio
import websockets
import uuid
import argparse
from datetime import datetime
import os
import random
import time
import hashlib
from PIL import Image
import glob
import base64
import io
import streamlit.components.v1 as components
import edge_tts
import nest_asyncio
import re
from streamlit_paste_button import paste_image_button
import pytz
import shutil
from urllib.parse import urlencode
from PyPDF2 import PdfReader
import json
# Patch for nested async - sneaky fix! ๐โจ
nest_asyncio.apply()
# Static config - constants rule! ๐๐
icons = '๐ค๐ง ๐ฌ๐'
START_ROOM = "Sector ๐"
# Page setup - dressing up the window! ๐ผ๏ธ๐
st.set_page_config(
page_title="๐ค๐ง MMO Chat Brain๐๐ฌ",
page_icon=icons,
layout="wide",
initial_sidebar_state="auto"
)
# Funky usernames with corresponding Edge TTS voices โ a cosmic cast! ๐๐ญ
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"
}
# 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"
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, dancing in the cosmic light! ๐ข๐
UNICODE_DIGITS = {i: f"{i}\uFE0Fโฃ" for i in range(10)}
# 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)),
("Italic", lambda x: "".join(chr(ord(c) + 0x1D434 - 0x41) if 'A' <= c <= 'Z' else chr(ord(c) + 0x1D44E - 0x61) if 'a' <= c <= 'z' else c for c in x)),
("Bold Italic", lambda x: "".join(chr(ord(c) + 0x1D468 - 0x41) if 'A' <= c <= 'Z' else chr(ord(c) + 0x1D482 - 0x61) if 'a' <= c <= 'z' else c for c in x)),
("Script", lambda x: "".join(chr(ord(c) + 0x1D49C - 0x41) if 'A' <= c <= 'Z' else chr(ord(c) + 0x1D4B6 - 0x61) if 'a' <= c <= 'z' else c for c in x)),
("Bold Script", lambda x: "".join(chr(ord(c) + 0x1D4D0 - 0x41) if 'A' <= c <= 'Z' else chr(ord(c) + 0x1D4EA - 0x61) if 'a' <= c <= 'z' else c for c in x)),
("Fraktur", lambda x: "".join(chr(ord(c) + 0x1D504 - 0x41) if 'A' <= c <= 'Z' else chr(ord(c) + 0x1D51E - 0x61) if 'a' <= c <= 'z' else c for c in x)),
("Bold Fraktur", lambda x: "".join(chr(ord(c) + 0x1D56C - 0x41) if 'A' <= c <= 'Z' else chr(ord(c) + 0x1D586 - 0x61) if 'a' <= c <= 'z' else c for c in x)),
("Double Struck", lambda x: "".join(chr(ord(c) + 0x1D538 - 0x41) if 'A' <= c <= 'Z' else chr(ord(c) + 0x1D552 - 0x61) if 'a' <= c <= 'z' else c for c in x)),
("Sans Serif", lambda x: "".join(chr(ord(c) + 0x1D5A0 - 0x41) if 'A' <= c <= 'Z' else chr(ord(c) + 0x1D5BA - 0x61) if 'a' <= c <= 'z' else c for c in x)),
("Sans Serif Bold", lambda x: "".join(chr(ord(c) + 0x1D5D4 - 0x41) if 'A' <= c <= 'Z' else chr(ord(c) + 0x1D5EE - 0x61) if 'a' <= c <= 'z' else c for c in x)),
("Sans Serif Italic", lambda x: "".join(chr(ord(c) + 0x1D608 - 0x41) if 'A' <= c <= 'Z' else chr(ord(c) + 0x1D622 - 0x61) if 'a' <= c <= 'z' else c for c in x)),
("Sans Serif Bold Italic", lambda x: "".join(chr(ord(c) + 0x1D63C - 0x41) if 'A' <= c <= 'Z' else chr(ord(c) + 0x1D656 - 0x61) if 'a' <= c <= 'z' else c for c in x)),
("Monospace", lambda x: "".join(chr(ord(c) + 0x1D670 - 0x41) if 'A' <= c <= 'Z' else chr(ord(c) + 0x1D68A - 0x61) if 'a' <= c <= 'z' else c for c in x)),
("Circled", lambda x: "".join(chr(ord(c) - 0x41 + 0x24B6) if 'A' <= c <= 'Z' else chr(ord(c) - 0x61 + 0x24D0) if 'a' <= c <= 'z' else c for c in x)),
("Squared", lambda x: "".join(chr(ord(c) - 0x41 + 0x1F130) if 'A' <= c <= 'Z' else c for c in x)),
("Negative Circled", lambda x: "".join(chr(ord(c) - 0x41 + 0x1F150) if 'A' <= c <= 'Z' else c for c in x)),
("Negative Squared", lambda x: "".join(chr(ord(c) - 0x41 + 0x1F170) if 'A' <= c <= 'Z' else c for c in x)),
("Regional Indicator", lambda x: "".join(chr(ord(c) - 0x41 + 0x1F1E6) if 'A' <= c <= 'Z' else c for c in x)),
]
# 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:
st.session_state.server_task = None
if 'active_connections' not in st.session_state:
st.session_state.active_connections = {}
if 'media_notifications' not in st.session_state:
st.session_state.media_notifications = []
if 'last_chat_update' not in st.session_state:
st.session_state.last_chat_update = 0
if 'displayed_chat_lines' not in st.session_state:
st.session_state.displayed_chat_lines = []
if 'message_text' not in st.session_state:
st.session_state.message_text = ""
if 'audio_cache' not in st.session_state:
st.session_state.audio_cache = {}
if 'pasted_image_data' not in st.session_state:
st.session_state.pasted_image_data = None
if 'quote_line' not in st.session_state:
st.session_state.quote_line = None
if 'refresh_rate' not in st.session_state:
st.session_state.refresh_rate = 5
if 'base64_cache' not in st.session_state:
st.session_state.base64_cache = {}
if 'image_hashes' not in st.session_state:
st.session_state.image_hashes = set()
if 'gallery_columns' not in st.session_state:
st.session_state.gallery_columns = 1
if 'user_id' not in st.session_state:
st.session_state.user_id = None
if 'user_hash' not in st.session_state:
st.session_state.user_hash = None
# 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')}-{st.session_state.user_id}"
# 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()
image_data.save(img_byte_arr, format='PNG')
img_bytes = img_byte_arr.getvalue()
else:
img_bytes = image_data
return hashlib.md5(img_bytes).hexdigest()[:8]
# Node 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)
parser.add_argument('--port', type=int, default=8501)
args = parser.parse_args()
username = st.session_state.get('username', 'System ๐')
log_action(username, "๐๐ผ - Node naming - christening the beast!")
return args.node_name or f"node-{uuid.uuid4().hex[:8]}", args.port
# Action logger - spying on deeds, a stealthy steed! ๐ต๏ธ๐
def log_action(username, action):
if 'action_log' not in st.session_state:
st.session_state.action_log = {}
user_log = st.session_state.action_log.setdefault(username, {})
current_time = time.time()
user_log = {k: v for k, v in user_log.items() if current_time - v < 10}
st.session_state.action_log[username] = user_log
if action not in user_log:
central = pytz.timezone('US/Central')
with open(HISTORY_FILE, 'a') as f:
f.write(f"[{datetime.now(central).strftime('%Y-%m-%d %H:%M:%S')}] {username}: {action}\n")
user_log[action] = current_time
# Clean text - strip the fancy 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
# 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_DIR
os.makedirs(self.cache_dir, exist_ok=True)
self.metadata = self._load_metadata()
def _load_metadata(self):
metadata_file = os.path.join(self.cache_dir, "metadata.json")
return json.load(open(metadata_file)) if os.path.exists(metadata_file) else {}
def _save_metadata(self):
metadata_file = os.path.join(self.cache_dir, "metadata.json")
with open(metadata_file, 'w') as f:
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()
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(filename):
return filename
# Clean text for speech, a bardโs clean sweep!
text = text.replace("\n", " ").replace("", " ").strip()
if not text:
return None
# Generate audio, a sonic leap, with edge_tts, our voices deep!
try:
communicate = edge_tts.Communicate(text, voice)
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, our epic creed, in shared memory, a heroic deed!
self.metadata[cache_key] = {
'timestamp': datetime.now().isoformat(),
'text_length': len(text),
'voice': voice
}
self._save_metadata()
return filename
# 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, a poetic spree!
# 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:
entry = f"{indent}[{timestamp}] {username}: {message}"
if quote_line:
entry = f"{indent}> {quote_line}\n{entry}"
# 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, 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 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 = 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]}.{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=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', 'wav']:
timestamp_prefix = format_timestamp_prefix(username)
media_filename = f"{username}-{timestamp_prefix.split('-')[-1]}.{media_file.name.split('.')[-1]}"
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:
f.write(f"{indent}[{timestamp}] Media: \n")
with open(user_history_file, 'a') as f:
f.write(f"{indent}[{timestamp}] Media: \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, even if silent, our taleโs delight!
# 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"
chat_content = await load_chat()
voice = st.session_state.voice if username == st.session_state.username else FUN_USERNAMES.get(username, "en-US-AriaNeural")
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"[{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, 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):
await asyncio.to_thread(lambda: open(CHAT_FILE, 'a').write(f"# {START_ROOM} Chat\n\nWelcome to the cosmic hub - start chatting! ๐ค\n"))
with open(CHAT_FILE, 'r') as f:
content = await asyncio.to_thread(f.read)
return content
# User lister - whoโs in the gang, 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()
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))
# 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, 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, 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")
entry = f"[{timestamp}] {user_hash} voted for {item}"
await asyncio.to_thread(lambda: open(file, 'a').write(f"{entry}\n"))
await asyncio.to_thread(lambda: open(HISTORY_FILE, "a").write(f"- {timestamp} - User {user_hash} voted for {item}\n"))
chat_message = f"{username} upvoted: \"{item}\""
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, 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):
await asyncio.to_thread(lambda: open(file, 'w').write("# Vote Tally\n\nNo votes yet - get clicking! ๐ฑ๏ธ\n"))
with open(file, 'r') as f:
content = await asyncio.to_thread(f.read)
lines = content.strip().split('\n')[2:]
votes = {}
user_votes = set()
for line in lines:
if line.strip() and 'voted for' in line:
user_hash = line.split('] ')[1].split(' voted for ')[0]
item = line.split('voted for ')[1]
vote_key = f"{user_hash}-{item}"
if vote_key not in user_votes:
votes[item] = votes.get(item, 0) + 1
user_votes.add(vote_key)
return votes
# 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, 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 = 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(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, 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:
b64 = base64.b64encode(f.read()).decode()
dl_link = f'๐ต Download {os.path.basename(file_path)}'
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 = 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 - 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 = 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 - 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"
media_path = os.path.join(MEDIA_DIR, pdf_filename)
with open(media_path, 'wb') as f:
f.write(pdf_file.getbuffer())
reader = PdfReader(media_path)
total_pages = min(len(reader.pages), max_pages)
texts = []
audio_files = []
audio_processor = AudioProcessor()
voice = st.session_state.voice if username == st.session_state.username else FUN_USERNAMES.get(username, "en-US-AriaNeural")
for i in range(total_pages):
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_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, in shared cache, a visual toll! ๐ฅ๐ฌ
def get_video_html(video_path, width="100px"):
"""
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'''
'''
# 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, os.path.join(AUDIO_DIR, audio_path), 'rb').read()).decode()}"
return f'''
'''
# 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:
client_id = str(uuid.uuid4())
room_id = "chat"
st.session_state.active_connections.setdefault(room_id, {})[client_id] = websocket
chat_content = await load_chat()
username = st.session_state.get('username', random.choice(list(FUN_USERNAMES.keys())))
if not await has_joined_before(client_id, chat_content):
await save_chat_entry(f"Client-{client_id}", f"{username} has joined {START_ROOM}!")
async for message in websocket:
parts = message.split('|', 1)
if len(parts) == 2:
username, content = parts
await save_chat_entry(username, content)
except websockets.ConnectionClosed:
pass
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]
# 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:
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:
del st.session_state.active_connections[room_id][client_id]
# 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:
server = await websockets.serve(websocket_handler, '0.0.0.0', 8765)
st.session_state.server_running = True
await server.wait_closed()
# Delete all user files - a purge so grand, in shared cache, a clearing band! ๐๏ธ๐ฅ
def delete_user_files():
"""
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'):
try:
os.remove(file)
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)
try:
os.remove(file_path)
deleted_files.append(file_path)
except Exception as e:
st.error(f"Failed to delete {file_path}: {e}")
st.session_state.image_hashes.clear()
st.session_state.audio_cache.clear()
st.session_state.base64_cache.clear()
st.session_state.displayed_chat_lines.clear()
return deleted_files
# 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:
st.session_state.username = q_value
st.session_state.voice = FUN_USERNAMES[q_value]
return q_value
elif q_value:
st.session_state.user_id = q_value # Use as user_id if not a valid username
return None
# 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 = []
for i, line in enumerate(chat_lines):
if line.strip() and not line.startswith(' '):
timestamp = line.split('] ')[0][1:] if '] ' in line else "Unknown"
content = line.split(': ', 1)[1] if ': ' in line else line
user = content.split(' ')[0]
message = content.split(' ', 1)[1] if ' ' in content else ''
node_id = f"{user}_{i}"
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] = "๐ต"
edges.append(f"{node_id} --> {audio_node}")
if i + 2 < len(chat_lines) and "Media:" in chat_lines[i + 2]:
media_node = f"media_{i}"
nodes[media_node] = "๐ผ"
edges.append(f"{node_id} --> {media_node}")
if i > 0 and "> " in line:
parent_user = chat_lines[i-1].split(': ')[1].split(' ')[0]
parent_id = f"{parent_user}_{i-1}"
edges.append(f"{parent_id} --> {node_id}")
for node_id, label in nodes.items():
mermaid_code += f" {node_id}[\"{label}\"]\n"
mermaid_code += "\n".join(f" {edge}" for edge in edges)
return mermaid_code
# 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, 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, 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()
available_names = [name for name in FUN_USERNAMES if not any(f"{name} has joined" in line for line in chat_content.split('\n'))]
st.session_state.username = random.choice(available_names) if available_names else random.choice(list(FUN_USERNAMES.keys()))
st.session_state.voice = FUN_USERNAMES[st.session_state.username]
st.markdown(f"**๐๏ธ Voice Selected**: {st.session_state.voice} ๐ฃ๏ธ for {st.session_state.username}")
# 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:
st.session_state.displayed_chat_lines = f.read().split('\n')
user_url = f"/q={st.session_state.username}"
with st.container():
st.markdown(f"Your unique URL path: [{user_url}]({user_url})", unsafe_allow_html=True)
with st.container():
st.markdown(f"#### ๐ค๐ง MMO {st.session_state.username}๐๐ฌ")
st.markdown(f"Welcome to {START_ROOM} - chat, vote, upload, paste images, and enjoy quoting! ๐ User ID: {st.session_state.user_id}", unsafe_allow_html=True)
if not st.session_state.server_task:
st.session_state.server_task = loop.create_task(run_websocket_server())
# 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:
chat_by_minute = {}
for line in reversed(chat_lines):
timestamp = line.split('] ')[0][1:] if '] ' in line else "Unknown"
minute_key = timestamp[:16] # Up to minute
if minute_key not in chat_by_minute:
chat_by_minute[minute_key] = []
chat_by_minute[minute_key].append(line)
markdown_output = ""
for minute, lines in chat_by_minute.items():
minute_output = f"###### {minute[-5:]}\n" # Show only HH:MM
for line in lines:
if ': ' in line and not line.startswith(' '):
user_message = line.split(': ', 1)[1]
user = user_message.split(' ')[0]
msg = user_message.split(' ', 1)[1] if ' ' in user_message else ''
audio_html = ""
media_content = ""
next_lines = chat_lines[chat_lines.index(line)+1:chat_lines.index(line)+3]
for nl in next_lines:
if "Audio:" in nl:
audio_file = nl.split("Audio: ")[-1].strip()
audio_html = play_and_download_audio(audio_file)
elif "Media:" in nl:
media_file = nl.split("Media: ")[-1].strip('![]()')
media_path = os.path.join(MEDIA_DIR, media_file)
if os.path.exists(media_path):
if media_file.endswith(('.png', '.jpg')):
media_content = f""
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
# 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"""
{mermaid_code}
"""
components.html(mermaid_html, height=250)
with st.container():
if st.session_state.quote_line:
st.markdown(f"###### Quoting: {st.session_state.quote_line}")
quote_response = st.text_area("Add your response", key="quote_response", value=st.session_state.message_text)
paste_result_quote = paste_image_button("๐ Paste Image or Text with Quote", key="paste_button_quote")
if paste_result_quote.image_data is not None:
if isinstance(paste_result_quote.image_data, str):
st.session_state.message_text = paste_result_quote.image_data
st.text_area("Add your response", key="quote_response", value=st.session_state.message_text)
else:
st.image(paste_result_quote.image_data, caption="Received Image for Quote")
filename = await save_pasted_image(paste_result_quote.image_data, st.session_state.username)
if filename:
st.session_state.pasted_image_data = filename
await save_chat_entry(st.session_state.username, f"Pasted image: {filename}", quote_line=st.session_state.quote_line, media_file=paste_result_quote.image_data)
if st.button("Send Quote ๐", key="send_quote"):
markdown_response = f"### Quote Response\n- **Original**: {st.session_state.quote_line}\n- **{st.session_state.username} Replies**: {quote_response}"
if st.session_state.pasted_image_data:
markdown_response += f"\n- **Image**: "
await save_chat_entry(st.session_state.username, f"Pasted image: {st.session_state.pasted_image_data}", quote_line=st.session_state.quote_line, media_file=st.session_state.pasted_image_data)
st.session_state.pasted_image_data = None
await save_chat_entry(st.session_state.username, markdown_response, is_markdown=True, quote_line=st.session_state.quote_line)
st.session_state.quote_line = None
st.session_state.message_text = ''
st.rerun()
current_selection = st.session_state.username if st.session_state.username in FUN_USERNAMES else ""
new_username = st.selectbox("Change Name and Voice", [""] + list(FUN_USERNAMES.keys()), index=(list(FUN_USERNAMES.keys()).index(current_selection) + 1 if current_selection else 0), format_func=lambda x: f"{x} ({FUN_USERNAMES.get(x, 'No Voice')})" if x else "Select a name")
if new_username and new_username != st.session_state.username:
await save_chat_entry("System ๐", f"{st.session_state.username} changed name to {new_username}")
st.session_state.username = new_username
st.session_state.voice = FUN_USERNAMES[new_username]
st.markdown(f"**๐๏ธ Voice Changed**: {st.session_state.voice} ๐ฃ๏ธ for {st.session_state.username}")
st.rerun()
# 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)
with col_send:
if st.button("Send ๐", key="send_button"):
if message.strip() or st.session_state.pasted_image_data:
await save_chat_entry(st.session_state.username, message if message.strip() else "Image shared", is_markdown=True, media_file=st.session_state.pasted_image_data if st.session_state.pasted_image_data else None, skip_audio=not message.strip())
if st.session_state.pasted_image_data:
st.session_state.pasted_image_data = None
st.session_state.message_text = ''
st.rerun()
paste_result_msg = paste_image_button("๐ Paste Image or Text with Message", key="paste_button_msg")
if paste_result_msg.image_data is not None:
if isinstance(paste_result_msg.image_data, str):
st.session_state.message_text = paste_result_msg.image_data
st.text_input(f"Message as {st.session_state.username} (Voice: {st.session_state.voice})", key="message_input_paste", value=st.session_state.message_text)
else:
st.image(paste_result_msg.image_data, caption="Received Image for Quote")
filename = await save_pasted_image(paste_result_msg.image_data, st.session_state.username)
if 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()
with st.container():
st.markdown("###### Upload Media ๐จ๐ถ๐๐ฅ")
uploaded_file = st.file_uploader("Upload Media", type=['png', 'jpg', 'mp4', 'mp3', 'wav', 'pdf', 'txt', 'md', 'py'])
if uploaded_file:
timestamp = format_timestamp_prefix(st.session_state.username)
username = st.session_state.username
ext = uploaded_file.name.split('.')[-1].lower()
if ext in ['png', 'jpg']:
filename = await save_pasted_image(uploaded_file, username)
elif ext in ['mp4', 'mp3', 'wav']:
filename = await save_media(uploaded_file, username, ext)
elif ext == 'pdf':
pdf_filename, _, _ = await save_pdf_and_generate_audio(uploaded_file, username)
filename = pdf_filename
else:
filename = f"{username}-{timestamp.split('-')[-1]}.{ext}"
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 - 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()
st.markdown("###### Refresh โณ")
refresh_rate = st.slider("Refresh Rate", 1, 300, st.session_state.refresh_rate)
st.session_state.refresh_rate = refresh_rate
timer_placeholder = st.empty()
for i in range(st.session_state.refresh_rate, -1, -1):
font_name, font_func = random.choice(UNICODE_FONTS)
countdown_str = "".join(UNICODE_DIGITS[int(d)] for d in str(i)) if i < 10 else font_func(str(i))
timer_placeholder.markdown(f"โณ {font_func('Refresh in:')} {countdown_str}", unsafe_allow_html=True)
time.sleep(1)
st.rerun()
# Separate Galleries for Own and Shared Files - a shared galleryโs glare! ๐ผ๏ธ๐ฅ
with st.container():
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(AUDIO_DIR, "*"), os.path.join(MEDIA_DIR, "*")]]
st.markdown("###### Your Files ๐")
st.markdown("###### Image Gallery ๐ผ")
own_image_files = [f for f in own_files if f.endswith(('.png', '.jpg'))]
image_cols = st.slider("Image Gallery Columns ๐ผ (Own)", min_value=1, max_value=15, value=5)
cols = st.columns(image_cols)
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')]
video_cols = st.slider("Video Gallery Columns ๐ฌ (Own)", min_value=1, max_value=5, value=3)
cols = st.columns(video_cols)
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')) 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 ๐ผ")
shared_image_files = [f for f in shared_files if f.endswith(('.png', '.jpg'))]
image_cols = st.slider("Image Gallery Columns ๐ผ (Shared)", min_value=1, max_value=15, value=5)
cols = st.columns(image_cols)
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')]
video_cols = st.slider("Video Gallery Columns ๐ฌ (Shared)", min_value=1, max_value=5, value=3)
cols = st.columns(video_cols)
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')) 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 - a shared epicโs end, our tale to mend! ๐๐ฅ
with st.container():
st.markdown("###### Full Chat Log ๐")
with open(CHAT_FILE, 'r') as f:
history_content = f.read()
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()