Update app.py

app.py

@@ -9,6 +9,11 @@ from pathlib import Path
 import base64
 from io import BytesIO
 import numpy as np
+import asyncio
+import threading
+from typing import Optional
+import queue
+import atexit
 
 # 🎮 Game Constants
 GRID_WIDTH = 16
@@ -17,7 +22,40 @@ REFRESH_RATE = 5
 INTERACTION_RADIUS = 2
 POINTS_PER_INTERACTION = 1
 
-# 📝 Name Generation - Independent function
+# 🕒 Timer Management
+class GameTimer:
+    def __init__(self):
+        self.running = True
+        self._loop: Optional[asyncio.AbstractEventLoop] = None
+        self.update_queue = queue.Queue()
+        self.thread = threading.Thread(target=self._run_timer, daemon=True)
+        self.thread.start()
+
+    def _run_timer(self):
+        self._loop = asyncio.new_event_loop()
+        asyncio.set_event_loop(self._loop)
+        self._loop.run_until_complete(self._timer_loop())
+
+    async def _timer_loop(self):
+        while self.running:
+            try:
+                current_time = time.time()
+                self.update_queue.put(('update', current_time))
+                await asyncio.sleep(REFRESH_RATE)
+            except Exception as e:
+                print(f"Timer error: {e}")
+                await asyncio.sleep(1)
+
+    def stop(self):
+        self.running = False
+        if self._loop:
+            self._loop.stop()
+
+# Initialize timer in session state
+if 'game_timer' not in st.session_state:
+    st.session_state.game_timer = GameTimer()
+
+# 📝 Name Generation
 def generate_fantasy_name():
     prefixes = ['Aer', 'Bal', 'Cal', 'Dor', 'El', 'Fae', 'Gor', 'Hel', 'Il', 'Jor',
                 'Kal', 'Lyr', 'Mel', 'Nym', 'Oro', 'Pyr', 'Qar', 'Ryn', 'Syl', 'Tyr']
@@ -59,19 +97,22 @@ def create_autorefresh():
     refresh_html = """
         <script>
             let lastUpdate = Date.now();
-            let serverTimeOffset = 0;
+            let updateInterval = null;
             
             function checkForUpdates() {
                 const now = Date.now();
                 if (now - lastUpdate >= 5000) {
                     lastUpdate = now;
                     window.parent.document.querySelector('.stApp').classList.add('refreshing');
-                    setTimeout(() => window.location.reload(), 100);
+                    window.location.reload();
                 }
             }
 
             function startAutoRefresh() {
-                setInterval(checkForUpdates, 1000);
+                if (!updateInterval) {
+                    updateInterval = setInterval(checkForUpdates, 1000);
+                }
+                
                 document.addEventListener('visibilitychange', function() {
                     if (!document.hidden) {
                         lastUpdate = Date.now() - 4900;
@@ -84,6 +125,13 @@ def create_autorefresh():
             } else {
                 window.addEventListener('load', startAutoRefresh);
             }
+
+            // Cleanup on unload
+            window.addEventListener('unload', function() {
+                if (updateInterval) {
+                    clearInterval(updateInterval);
+                }
+            });
         </script>
     """
     st.components.v1.html(refresh_html, height=0)
@@ -218,7 +266,16 @@ def create_game_board():
 # 🎮 Main Game Loop
 def main():
     create_autorefresh()
-    update_nearby_players()
+    
+    # Process any queued updates
+    try:
+        while not st.session_state.game_timer.update_queue.empty():
+            update_type, timestamp = st.session_state.game_timer.update_queue.get_nowait()
+            if update_type == 'update':
+                update_nearby_players()
+                save_player_state()
+    except queue.Empty:
+        pass
     
     st.sidebar.title("Player Info")
     
@@ -267,6 +324,7 @@ def main():
             st.rerun()
         
         if st.sidebar.button("Clear Game State"):
+            st.session_state.game_timer.stop()
             st.query_params.clear()
             clear_caches()
             st.rerun()
@@ -274,5 +332,13 @@ def main():
     st.title("Multiplayer Tile Game")
     create_game_board()
 
+# 🧹 Cleanup on exit
+def cleanup():
+    if 'game_timer' in st.session_state:
+        st.session_state.game_timer.stop()
+
+# Register cleanup
+atexit.register(cleanup)
+
 if __name__ == "__main__":
     main()