🤷‍♀️Move tuesday problems to Dota component

Author: Aluerie

src/modules/public/dota_rp_flow/component.py

@@ -610,6 +610,7 @@ async def component_load(self) -> None:
         self.fill_completed_matches_from_gc_match_history.start()
         self.remove_way_too_old_matches.start()
         self.debug_announce_gc_ready.start()
+        self.tuesday_problems.start()
 
     @override
     async def component_teardown(self) -> None:
@@ -618,6 +619,7 @@ async def component_teardown(self) -> None:
         self.fill_completed_matches_from_gc_match_history.cancel()
         self.remove_way_too_old_matches.cancel()
         self.debug_announce_gc_ready.cancel()
+        self.tuesday_problems.cancel()
 
     #################################
     #           EVENTS              #
@@ -1562,3 +1564,19 @@ async def debug_announce_activity_change(self, friend: Friend) -> None:
         """Announce in Irene's twitch chat that their activity data has changed."""
         if friend.steam_user.id == config["STEAM"]["IRENE_ID32"]:
             await self.debug_deliver(f"Activity changed to: {friend.activity}")
+
+    @ireloop(count=1)
+    async def tuesday_problems(self) -> None:
+        """A crutch to try to solve infamous Tuesday problems.
+
+        When steam crashes - it always is a big problem for the bot;
+        It doesn't ever properly reconnect on its own.
+
+        Let's put a crutch to simply restart the bot if that happens.
+        """
+        try:
+            async with asyncio.timeout(11 * 60):  # 11 minutes
+                await self.bot.dota.wait_until_gc_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")

src/utils/dota/dota2client.py

@@ -1,6 +1,5 @@
 from __future__ import annotations
 
-import asyncio
 import logging
 from typing import TYPE_CHECKING, NamedTuple, override
 
@@ -71,13 +70,8 @@ async def close(self) -> None:
     @override
     async def on_ready(self) -> None:
         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")
+        await self.wait_until_gc_ready()
+        log.info("Dota 2 Game Coordinator: Ready")
 
     @override
     async def on_user_update(self, before: User, after: User) -> None: