Create app.py

app.py

@@ -0,0 +1,502 @@
+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 re
+from urllib.parse import quote
+
+# App Configuration
+Site_Name = '🤖🧠Chat & Quote Node📝🔬'
+title = "🤖🧠Chat & Quote Node📝🔬"
+icons = '🤖🧠🔬📝'
+START_ROOM = "Sector 🌌"
+
+st.set_page_config(
+    page_title=title,
+    page_icon=icons,
+    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 🐒"
+]
+
+# Directories for chat, votes, and media - the secret vaults where treasures are stashed! 🗄️🔒
+CHAT_DIR = "chat_logs"
+VOTE_DIR = "vote_logs"
+MEDIA_DIR = "media"
+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️⃣"
+}
+
+# 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}"
+    try:
+        with open(CHAT_FILE, 'a') as f:
+            f.write(f"{entry}\n")
+        return True
+    except Exception as e:
+        print(f"Oops! Failed to save chat: {e}")
+        return False
+
+# Chat loader - the archaeologist unearthing the chat saga! ⛏️📚
+def load_chat():
+    """🔍 Digs up the chat treasure from the filesystem - tales of old and new! 💰"""
+    if not os.path.exists(CHAT_FILE):
+        with open(CHAT_FILE, 'w') as f:
+            f.write(f"# {START_ROOM} Chat\n\nWelcome to the cosmic hub - start chatting! 🎤\n")
+    try:
+        with open(CHAT_FILE, 'r') as f:
+            content = f.read()
+        lines = content.strip().split('\n')
+        numbered_content = "\n".join(f"{i+1}. {line}" for i, line in enumerate(lines) if line.strip())
+        return numbered_content
+    except Exception as e:
+        print(f"Chat load hiccup: {e}")
+        return f"# Error loading {START_ROOM} chat\nSomething went wonky! 😵"
+
+# User list grabber - the social butterfly spotting all the chatters! 🦋👥
+def get_user_list(chat_content):
+    """👀 Peeks at the chat to spot all the cool cats talking - who’s in the club? 🎸"""
+    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! 👍📊
+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:
+        with open(file, 'a') as f:
+            f.write(f"{entry}\n")
+        with open(HISTORY_FILE, 'a') as f:
+            f.write(f"- {timestamp} - User {user_hash} voted for {item}\n")
+        return True
+    except Exception as e:
+        print(f"Vote save flop: {e}")
+        return False
+
+# Vote loader - the scorekeeper tallying the crowd’s cheers! 🎉🏅
+def load_votes(file):
+    """📈 Counts the votes from the ledger - who’s winning the popularity contest? 🏆"""
+    if not os.path.exists(file):
+        with open(file, 'w') as f:
+            f.write("# Vote Tally\n\nNo votes yet - get clicking! 🖱️\n")
+    try:
+        with open(file, 'r') as f:
+            lines = f.read().strip().split('\n')
+        votes = {}
+        for line in lines[2:]:  # Skip header
+            if line.strip() and 'voted for' in line:
+                item = line.split('voted for ')[1]
+                votes[item] = votes.get(item, 0) + 1
+        return votes
+    except Exception as e:
+        print(f"Vote load oopsie: {e}")
+        return {}
+
+# User hash generator - the secret agent giving you a cool code! 🕵️‍♂️🔑
+def generate_user_hash():
+    """🕵️ Crafts a snazzy 8-digit ID badge - you’re in the club now! 🎟️"""
+    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
+    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.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))
+    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)
+        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()
+
+    # Sidebar vote stats
+    st.sidebar.subheader("Vote Totals")
+    chat_votes = load_votes(QUOTE_VOTES_FILE)
+    image_votes = load_votes(IMAGE_VOTES_FILE)
+    for item, count in chat_votes.items():
+        st.sidebar.write(f"{item}: {count} votes")
+    for image, count in image_votes.items():
+        st.sidebar.write(f"{image}: {count} votes")
+
+# Main event - the ringmaster kicking off the Sector circus! 🎪🤡
+async def main():
+    """🎤 Drops the mic and starts the Sector party - it’s showtime, folks! 🎉"""
+    global NODE_NAME, server_task
+    NODE_NAME, port = get_node_name()
+
+    # 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!")
+
+    create_streamlit_interface(initial_username)
+
+if __name__ == "__main__":
+    asyncio.run(main())