🤷‍♀️Add some crutches to address Tuesday problems

Author: Aluerie

src/core/bases/tasks.py

@@ -61,6 +61,9 @@ def __init__(
         super().__init__(coro, seconds, hours, minutes, time, count, reconnect, name)
         if wait_for_ready:
             self._before_loop = self._wait_for_ready
+        # Not sure how I feel about it, but it's annoying that it silences `aiohttp.ClientError, asyncio.TimeoutError`
+        # because valid aiohttp requests raise them as well !
+        self.clear_exception_types()
 
     async def _wait_for_ready(self, cog: HasBotAttribute) -> None:  # *args: Any
         await cog.bot.wait_until_ready()

src/core/bot.py

@@ -5,14 +5,12 @@
 import logging
 import platform
 import pprint
-
-# import sys
+import sys
 from dataclasses import dataclass
 from typing import TYPE_CHECKING, Any, TypedDict, override
 
 import discord
-
-# import steam
+import steam
 import twitchio
 from twitchio import eventsub
 from twitchio.ext import commands
@@ -366,17 +364,20 @@ async def load_tokens(self, _: str | None = None) -> None:  # _ is `path`
     async def start(self) -> None:
         if "modules.public.dota_rp_flow" in self.modules_to_load:
             self.dota = Dota2Client(self)
-            # try:
-            await asyncio.gather(
-                super().start(),
-                self.dota.login(),
-            )
+            try:
+                await asyncio.gather(
+                    super().start(),
+                    self.dota.login(),
+                )
             # A potential workaround for steam login issues
             # https://github.com/Gobot1234/steam.py/issues/446
-            # except steam.errors.NoCMsFound:
-            #     sys.exit(1)
-            # except steam.errors.LoginError:
-            #     sys.exit(1)
+            # Not sure if it works :D
+            except steam.errors.NoCMsFound:
+                log.warning("🔴 Encountered `steam.errors.NoCMsFound` - restarting. 🔴")
+                sys.exit(1)
+            except steam.errors.LoginError:
+                log.warning("🔴 Encountered `steam.errors.LoginError` - restarting. 🔴")
+                sys.exit(1)
         else:
             await super().start()
 

src/modules/dev/webhook_logs.py

@@ -86,7 +86,7 @@ async def component_load(self) -> None:
     @override
     async def component_teardown(self) -> None:
         self.logging_worker.stop()
-        log.warning("Tearing down logger via webhook.")
+        # log.warning("Tearing down logger via webhook.")
         logging.getLogger().removeHandler(self.logs_handler)
         del self.logs_handler
         await super().component_teardown()

src/utils/dota/dota2client.py

@@ -1,5 +1,6 @@
 from __future__ import annotations
 
+import asyncio
 import logging
 from typing import TYPE_CHECKING, NamedTuple, override
 
@@ -69,9 +70,14 @@ async def close(self) -> None:
 
     @override
     async def on_ready(self) -> None:
-        log.info("Dota 2 Client: Ready - Successfully %s", self.user.name)
-        await self.wait_until_gc_ready()
-        log.info("Dota 2 Game Coordinator: Ready")
+        log.info("Dota 2 Client: Ready %s, now waiting till Game Coordinator is ready;", self.user.name)
+        try:
+            async with asyncio.timeout(11 * 60):  # 11 minutes
+                await self.wait_until_gc_ready()
+                log.info("Dota 2 Game Coordinator: Ready")
+        except TimeoutError:
+            log.warning("🔴 Failed to wait for Dota 2 Game Coordinator to get ready - restarting the bot. 🔴")
+            await asyncio.create_subprocess_shell("sudo systemctl restart irebot")
 
     @override
     async def on_user_update(self, before: User, after: User) -> None:

src/utils/dota/web_api.py

@@ -40,7 +40,7 @@ async def invoke(
         for _ in range(max_failures):
             async with self.session.get(url) as resp:
                 # encoding='utf-8' errored out one day
-                result = await resp.json(loads=orjson.loads, encoding="ISO-8859-1")
+                result = await resp.json(loads=orjson.loads, content_type=None)
                 if result:
                     break
                 # Valve, why does it return an empty dict `{}` on the very first request for every match...