Merge branch 'feat-pluscampaign'

Reviewed-on: #1

.gitmodules

@@ -3,7 +3,7 @@
 	url = https://git.thewisewolf.dev/HoloTech/psqlmapper.git
 [submodule "src/modules/subathon"]
 	path = src/modules/subathon
-	url = https://git.thewisewolf.dev/HoloTech/twitch-subathon-plugin.git
+	url = https://git.thewisewolf.dev/CarmiCoven/lilac-subathon-plugin.git
 [submodule "src/modules/tracker"]
 	path = src/modules/tracker
 	url = https://git.thewisewolf.dev/HoloTech/twitch-eventtracker-plugin.git
@@ -13,3 +13,6 @@
 [submodule "src/modules/exec"]
 	path = src/modules/exec
 	url = https://git.thewisewolf.dev/HoloTech/exec-plugin.git
+[submodule "src/modules/pluscampaign"]
+	path = src/modules/pluscampaign
+	url = https://git.thewisewolf.dev/CarmiCoven/pluscampaign-plugin.git

data/schema.sql

@@ -17,6 +17,18 @@ BEGIN
 END;
 $$ language 'plpgsql';
 
+CREATE OR REPLACE FUNCTION current_module_version(module_name TEXT)
+RETURNS INTEGER
+AS $$
+    SELECT 
+      to_version 
+    FROM version_history 
+    WHERE 
+      component = $1 
+    ORDER BY _timestamp DESC 
+    LIMIT 1;
+$$ LANGUAGE SQL;
+
 CREATE TABLE app_config(
   appname TEXT PRIMARY KEY,
   created_at TIMESTAMPTZ NOT NULL DEFAULT now()

src/meta/bot.py

@@ -197,3 +197,9 @@ class Bot(commands.Bot):
                 await self.add_token(row.token, row.refresh_token)
             except Exception:
                 logger.exception(f"Failed to add token for {row}")
+
+    async def event_command_error(self, payload: commands.CommandErrorPayload) -> None:
+        if isinstance(payload.exception, commands.CommandNotFound):
+            logger.debug(f"Attempt to execute nonexistent command for context {payload.context!r}")
+        else:
+            return await super().event_command_error(payload)

src/modules/__init__.py

@@ -6,9 +6,10 @@ if TYPE_CHECKING:
 
 async def twitch_setup(bot: "Bot"):
     # Import and run setup methods from each module
-    from . import profiles, tracker, subathon, exec
+    from . import profiles, tracker, subathon, exec, yarn
 
     await profiles.twitch_setup(bot)
     await tracker.twitch_setup(bot)
     await subathon.twitch_setup(bot)
     await exec.twitch_setup(bot)
+    await yarn.twitch_setup(bot)

src/modules/yarn/__init__.py

@@ -0,0 +1,7 @@
+import logging
+
+logger = logging.getLogger()
+
+async def twitch_setup(bot):
+    from .component import YarnComponent
+    await bot.add_component(YarnComponent(bot))

src/modules/yarn/component.py

@@ -0,0 +1,20 @@
+import asyncio
+
+import twitchio
+from twitchio import PartialUser, Scopes, eventsub
+from twitchio.ext import commands as cmds
+
+from meta import Bot, Context
+
+from . import logger
+
+class YarnComponent(cmds.Component):
+    def __init__(self, bot: Bot):
+        self.bot = bot
+
+
+    @cmds.Component.listener()
+    async def event_custom_redemption_add(self, payload: twitchio.ChannelPointsRedemptionAdd):
+        logger.info(f"Yarn got {payload!r}")
+        if payload.reward.title == 'pet lilac':
+            await payload.broadcaster.send_message("lilac PETPET", sender="1097964183")