added subsciription messsage event

null-channel · Jul 27, 2024 · 58852a2 · 58852a2
1 parent bb32ba9
commit 58852a2
Show file tree

Hide file tree

Showing 2 changed files with 16 additions and 1 deletion.
diff --git a/deployment/twitch-alerts-deployment.yaml b/deployment/twitch-alerts-deployment.yaml
@@ -62,7 +62,7 @@ spec:
       # Start your application & Litestream to share a PVC data directory.
       containers:
         - name: twitch-alerts
-          image: nullchannel/twitch-alerts:0.1.35
+          image: nullchannel/twitch-alerts:0.1.36
           ports:
             - name: httpport
               containerPort: 8080

diff --git a/twitch_listener_service/src/websocket.rs b/twitch_listener_service/src/websocket.rs
@@ -173,6 +173,8 @@ impl WebsocketClient {
         if let Some(url) = data.reconnect_url {
             self.connect_url = url.parse()?;
         }
+
+        // One way of doing it
         let req = twitch_api::helix::eventsub::CreateEventSubSubscriptionRequest::new();
         let body = twitch_api::helix::eventsub::CreateEventSubSubscriptionBody::new(
             twitch_api::eventsub::channel::ChannelFollowV2::new(
@@ -187,6 +189,7 @@ impl WebsocketClient {
             .await?;
         let transport = twitch_api::eventsub::Transport::websocket(data.id.clone());
 
+        // Create Channel Subscription
         self.client
             .create_eventsub_subscription(
                 twitch_api::eventsub::channel::ChannelSubscribeV1::broadcaster_user_id(
@@ -197,6 +200,7 @@ impl WebsocketClient {
             )
             .await?;
 
+        // Create Channel Raid Subscription
         self.client
             .create_eventsub_subscription(
                 twitch_api::eventsub::channel::ChannelRaidV1::to_broadcaster_user_id(
@@ -207,6 +211,17 @@ impl WebsocketClient {
             )
             .await?;
 
+        // Create Channel Subscription Message Subscription
+        self.client
+            .create_eventsub_subscription(
+                twitch_api::eventsub::channel::ChannelSubscriptionMessageV1::broadcaster_user_id(
+                    self.user_id.clone(),
+                ),
+                transport.clone(),
+                &*self.token.read().await,
+            )
+            .await?;
+
         tracing::info!("we are listening");
         Ok(())
     }