Eventsub expierment

tbot/runner.py

@@ -21,6 +21,8 @@ def twitch_bot():
 @cli.command()
 def web():
     set_logger('web.log')
+    from tbot.web.handlers.api.twitch.eventsubs.eventsub import task_check_channels
+    asyncio.run(task_check_channels())
     import tbot.web.app
     asyncio.run(tbot.web.app.main()) 
 

tbot/web/app.py

@@ -67,7 +67,9 @@ def App():
             (r'/api/rtmp-auth', handlers.api.rtmp_auth.Handler),
             (r'/api/srt-auth', handlers.api.srt_auth.Handler),
 
-            #(r'/api/twitch/webhooks/channel.subscribe', handlers.api.twitch.eventsubs.channel_subscribe.Handler),
+            (r'/api/twitch/webhooks/channel.subscribe', handlers.api.twitch.eventsubs.channel_subscribe.Handler),
+            (r'/api/twitch/webhooks/channel.subscribe.end', handlers.api.twitch.eventsubs.channel_subscribe_end.Handler),
+
             (r"/api/twitch/widget-ws", handlers.api.twitch.widgets.widget_ws.Handler),
 
             (r"/twitch/widgets/goal/([a-zA-Z0-9]+)", handlers.twitch.widgets.goal.Handler),

tbot/web/handlers/api/twitch/eventsubs/channel_subscribe.py

@@ -0,0 +1,8 @@
+from tbot import logger
+from . import eventsub
+
+
+class Handler(eventsub.Handler):
+
+    async def notification(self):
+        logger.info(self.request.body)

tbot/web/handlers/api/twitch/eventsubs/channel_subscribe_end.py

@@ -0,0 +1,8 @@
+from tbot import logger
+from . import eventsub
+
+
+class Handler(eventsub.Handler):
+
+    async def notification(self):
+        logger.info(self.request.body)

tbot/web/handlers/api/twitch/eventsubs/eventsub.py

@@ -24,10 +24,14 @@ class EventSubResponse(BaseModel, Generic[T]):
 
 def channel_events(channel_id: str, scopes: list[str]):
     events = [
-        #{
-        #    'type': 'channel.subscribe',
-        #    'scope': 'channel:read:subscriptions'
-        #}
+        {
+            'type': 'channel.subscribe',
+            'scope': 'channel:read:subscriptions'
+        },
+        {
+            'type': 'channel.subscription.end',
+            'scope': 'channel:read:subscriptions'
+        },
     ]
     r = []
     for e in events: