Branding: gate sync via helper function

Sync make also be invoked with a command; avoid logic duplication.

1 files changed, 19 insertions, 8 deletions

diff --git a/bot/exts/backend/branding/_cog.py b/bot/exts/backend/branding/_cog.py
index 4387e68b4..dce2b7bc0 100644
--- a/bot/exts/backend/branding/_cog.py
+++ b/bot/exts/backend/branding/_cog.py
@@ -240,6 +240,23 @@ class Branding(commands.Cog):
         # Notify guild of new event ~ this reads the information that we cached above!
         await self.send_info_embed(Channels.change_log)
 
+    async def synchronise(self) -> None:
+        """
+        Fetch the current event and delegate to `enter_event`.
+
+        This is a convenience wrapper to force synchronisation either via a command, or when the daemon starts
+        with an empty cache. It is generally only used in a recovery scenario. In the usual case, the daemon
+        already has an `Event` instance and can pass it to `enter_event` directly.
+        """
+        log.debug("Synchronise: fetching current event")
+
+        event = await self.repository.get_current_event()
+
+        if event is None:
+            log.error("Failed to fetch event ~ cannot synchronise!")
+        else:
+            await self.enter_event(event)
+
     # endregion
     # region: Daemon
 
@@ -323,14 +340,8 @@ class Branding(commands.Cog):
         current_event = await self.cache_information.get("event_path")
 
         if current_event is None:  # Maiden case ~ first start or cache loss
-            log.debug("Applying event immediately as cache is empty (indicating maiden case)")
-
-            event = await self.repository.get_current_event()
-
-            if event is None:
-                log.warning("Failed to fetch event ~ cache will remain empty!")
-            else:
-                await self.enter_event(event)
+            log.debug("Event cache is empty (indicating maiden case), invoking synchronisation")
+            await self.synchronise()
 
         now = datetime.utcnow()