Development (#33)

* pop up mode and chat buble toggle

* potential audio fix

* linux sh and better docker support

* fixed linux build?

* linux fix part 2

* docker fix part 1

* Initial plan

* Initial plan

* Initial plan

* Initial plan

* Initial plan

* Initial plan

* Initial plan

* Update frontend/src/pages/YappersPage.jsx

Co-authored-by: Copilot <175728472+Copilot@users.noreply.github.com>

* Initial plan

* Update frontend/src/pages/YappersPage.jsx

Co-authored-by: Copilot <175728472+Copilot@users.noreply.github.com>

* Replace sys.platform with platform.system() for OS detection

Co-authored-by: pladisdev <127021507+pladisdev@users.noreply.github.com>

* Fix race condition in popup avatar lifecycle

Co-authored-by: pladisdev <127021507+pladisdev@users.noreply.github.com>

* Extract magic numbers to named constants for better readability

Co-authored-by: pladisdev <127021507+pladisdev@users.noreply.github.com>

* Extract magic number -2.5px into avatarActiveOffset setting

Co-authored-by: pladisdev <127021507+pladisdev@users.noreply.github.com>

* Fix audio cleanup in popup mode when play() fails

Co-authored-by: pladisdev <127021507+pladisdev@users.noreply.github.com>

* Extract hex opacity calculation to utility function

Co-authored-by: pladisdev <127021507+pladisdev@users.noreply.github.com>

* Fix audio error handlers to clean up tracking references

Co-authored-by: pladisdev <127021507+pladisdev@users.noreply.github.com>

* update flow for builds

* better build and release file

* workflow fix

* build fix

* usernames in chat bubbles

* twitch authentifcation

* tts limit

* notifcation that user needs to click page, quick status

* update readme, version

* emergency twitch fix

* yep

* dang

* better twitch logging

* animations and avatar layout editor

* fix spin animation

* twitch fix part 2

* twitch fix, better fonts, cleanup

* fixed imports

* fixed things

* undefined fix

* twitch test fix

* another mock fix

* another fix for twitch creds tests

* better logging

---------

Co-authored-by: copilot-swe-agent[bot] <198982749+Copilot@users.noreply.github.com>
Co-authored-by: Copilot <175728472+Copilot@users.noreply.github.com>

Author: 3 people

backend/app.py

@@ -482,8 +482,9 @@ async def restart_twitch_if_needed(settings: Dict[str, Any]):
                 # Catch any other errors during cancellation (e.g., twitchio internal errors)
                 logger.warning(f"Error while cancelling Twitch bot task: {e}")
 
-            # Give it a moment to fully clean up
-            await asyncio.sleep(0.1)
+            # Give TwitchIO's EventSub server more time to fully shut down
+            # This prevents CancelledError spam from aiohttp adapter callbacks
+            await asyncio.sleep(0.5)
 
         # Start new task if enabled
         if run_twitch_bot and settings.get("twitch", {}).get("enabled"):
@@ -819,8 +820,8 @@ async def restart_youtube_if_needed(settings: Dict[str, Any]):
             except Exception as e:
                 logger.warning(f"Error while cancelling YouTube bot task: {e}")
 
-            # Give it a moment to fully clean up
-            await asyncio.sleep(0.1)
+            # Give YouTube API more time to fully clean up
+            await asyncio.sleep(0.5)
 
         # Start new task if enabled
         if run_youtube_bot and settings.get("youtube", {}).get("enabled"):
@@ -1512,9 +1513,37 @@ async def handle_moderation_event(evt: Dict[str, Any]):
 # ---------- Avatar Slot Management API ----------
 # Avatar slot endpoints have been moved to routers/avatars.py
 
+def custom_exception_handler(loop, context):
+    """
+    Custom exception handler to suppress harmless TwitchIO internal errors during shutdown.
+    These CancelledError exceptions from aiohttp adapter callbacks are expected during bot restarts.
+    """
+    exception = context.get("exception")
+    message = context.get("message", "")
+    handle = str(context.get("handle", ""))
+    
+    # Suppress TwitchIO EventSub server cancellation errors (harmless during shutdown)
+    if isinstance(exception, asyncio.CancelledError):
+        # Check if this is from TwitchIO's aiohttp adapter
+        if ("AiohttpAdapter._task_callback" in message or 
+            "AiohttpAdapter._task_callback" in handle or
+            "aio_adapter.py" in message or
+            "web_runner.py" in message):
+            # This is an expected error during TwitchIO bot shutdown - don't log it
+            return
+    
+    # For all other exceptions, use the default handler
+    loop.default_exception_handler(context)
+
 @app.on_event("startup")
 async def startup():
     logger.info("FastAPI startup event triggered")
+    
+    # Install custom exception handler to suppress TwitchIO shutdown noise
+    loop = asyncio.get_running_loop()
+    loop.set_exception_handler(custom_exception_handler)
+    logger.info("Custom exception handler installed for cleaner TwitchIO shutdown")
+    
     try:
         # Broadcast initial avatar slot assignments to any connected clients
         await broadcast_avatar_slots()

backend/modules/youtube_listener.py

@@ -9,13 +9,15 @@
     from google.oauth2.credentials import Credentials
     from googleapiclient.discovery import build
     from googleapiclient.errors import HttpError
+    from google.auth.exceptions import RefreshError
     YOUTUBE_AVAILABLE = True
 except ImportError as e:
     logger.error(f"Failed to import YouTube dependencies: {e}")
     logger.info("Please install: pip install google-auth google-auth-oauthlib google-api-python-client")
     YOUTUBE_AVAILABLE = False
     Credentials = None  # type: ignore
     HttpError = Exception
+    RefreshError = Exception  # type: ignore
 
 
 class YouTubeListener:
@@ -82,15 +84,20 @@ async def find_active_stream(self) -> bool:
             else:
                 logger.warning("No active live stream found for this channel")
                 return False
+        except RefreshError as e:
+            logger.error("YouTube authentication token has expired or been revoked")
+            logger.info("Please reconnect your YouTube account in settings to continue using YouTube chat integration")
+            return False
         except HttpError as e:
             status_code = getattr(e, 'resp', {}).get('status', 0)
             if status_code == 401:
-                logger.error("YouTube API authentication error while finding active stream - token may be expired")
+                logger.error("YouTube API authentication error - token may be expired")
+                logger.info("Please reconnect your YouTube account in settings")
             else:
                 logger.error(f"YouTube API error finding active stream: {e}")
             return False
         except Exception as e:
-            logger.error(f"Error finding active stream: {e}", exc_info=True)
+            logger.error(f"Error finding active stream: {e}")
             return False
 
     async def get_live_chat_id(self) -> Optional[str]:
@@ -122,15 +129,20 @@ async def get_live_chat_id(self) -> Optional[str]:
             else:
                 logger.error(f"Video {self.video_id} not found")
                 return None
+        except RefreshError as e:
+            logger.error("YouTube authentication token has expired or been revoked")
+            logger.info("Please reconnect your YouTube account in settings to continue using YouTube chat integration")
+            return None
         except HttpError as e:
             status_code = getattr(e, 'resp', {}).get('status', 0)
             if status_code == 401:
-                logger.error("YouTube API authentication error while getting live chat ID - token may be expired")
+                logger.error("YouTube API authentication error - token may be expired")
+                logger.info("Please reconnect your YouTube account in settings")
             else:
                 logger.error(f"YouTube API error getting live chat ID: {e}")
             return None
         except Exception as e:
-            logger.error(f"Error getting live chat ID: {e}", exc_info=True)
+            logger.error(f"Error getting live chat ID: {e}")
             return None
 
     async def listen_to_chat(self, on_event: Callable[[Dict[str, Any]], None]):