twitch: Extra exception handling in setTitle, setGame

This to stop `twitchTryCatchDg` from exiting the program on API key expiry.
zorael · Jul 10, 2022 · f64166b · f64166b
1 parent 81ef4dd
commit f64166b
Showing 1 changed file with 63 additions and 17 deletions.
diff --git a/source/kameloso/plugins/twitch/base.d b/source/kameloso/plugins/twitch/base.d
@@ -2247,10 +2247,33 @@ void onCommandSetTitle(TwitchPlugin plugin, const /*ref*/ IRCEvent event)
         return;
     }
 
+    immutable title = unescapedTitle.unquoted.replace(`"`, `\"`);
+
     void setTitleDg()
     {
-        immutable title = unescapedTitle.unquoted.replace(`"`, `\"`);
-        modifyChannel(plugin, event.channel, title, string.init);
+        try
+        {
+            modifyChannel(plugin, event.channel, title, string.init);
+        }
+        catch (TwitchQueryException e)
+        {
+            if ((e.code == 401) && (e.error == "Unauthorized"))
+            {
+                static bool hasComplainedAboutExpiredKey;
+
+                if (!hasComplainedAboutExpiredKey)
+                {
+                    // broadcaster "superkey" expired.
+                    enum message = "The broadcaster-level API key has expired.";
+                    chan(plugin.state, event.channel, message);
+                    hasComplainedAboutExpiredKey = true;
+                }
+            }
+            else
+            {
+                throw e;
+            }
+        }
     }
 
     Fiber setTitleFiber = new Fiber(&twitchTryCatchDg!setTitleDg, BufferSize.fiberStack);
@@ -2298,30 +2321,53 @@ void onCommandSetGame(TwitchPlugin plugin, const /*ref*/ IRCEvent event)
         return;
     }
 
-    void setGameDg()
+    immutable specified = unescapedGameName.unquoted.replace(`"`, `\"`);
+    string id;
+
+    if (specified.isNumeric)
     {
-        immutable specified = unescapedGameName.unquoted.replace(`"`, `\"`);
-        string id;
+        id = specified;
+    }
 
-        if (specified.isNumeric)
+    void setGameDg()
+    {
+        try
         {
-            id = specified;
+            if (!id.length)
+            {
+                immutable gameInfo = getTwitchGame(plugin, specified.encodeComponent);
+
+                if (!gameInfo.id.length)
+                {
+                    enum message = "Could not find a game by that name.";
+                    chan(plugin.state, event.channel, message);
+                    return;
+                }
+
+                id = gameInfo.id;
+            }
+
+            modifyChannel(plugin, event.channel, string.init, id);
         }
-        else
+        catch (TwitchQueryException e)
         {
-            immutable gameInfo = getTwitchGame(plugin, specified.encodeComponent);
+            if ((e.code == 401) && (e.error == "Unauthorized"))
+            {
+                static bool hasComplainedAboutExpiredKey;
 
-            if (!gameInfo.id.length)
+                if (!hasComplainedAboutExpiredKey)
+                {
+                    // broadcaster "superkey" expired.
+                    enum message = "The broadcaster-level API key has expired.";
+                    chan(plugin.state, event.channel, message);
+                    hasComplainedAboutExpiredKey = true;
+                }
+            }
+            else
             {
-                enum message = "Could not find a game by that name.";
-                chan(plugin.state, event.channel, message);
-                return;
+                throw e;
             }
-
-            id = gameInfo.id;
         }
-
-        modifyChannel(plugin, event.channel, string.init, id);
     }
 
     Fiber setGameFiber = new Fiber(&twitchTryCatchDg!setGameDg, BufferSize.fiberStack);