(yarn): Add yarn module for one-off commands

.gitmodules

@@ -3,10 +3,13 @@
 	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
 [submodule "src/modules/profiles"]
 	path = src/modules/profiles
 	url = https://git.thewisewolf.dev/HoloTech/profiles-plugin.git
+[submodule "src/modules/exec"]
+	path = src/modules/exec
+	url = https://git.thewisewolf.dev/HoloTech/exec-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/modules/__init__.py

@@ -4,9 +4,12 @@ if TYPE_CHECKING:
     from meta import Bot
 
 
-async def twitch_setup(bot: 'Bot'):
+async def twitch_setup(bot: "Bot"):
-    # Import and run setup methods from each module 
+    # Import and run setup methods from each module
-    from . import profiles, tracker, subathon
+    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")