add notification message parsing

dmmulroy · Apr 15, 2024 · e829117 · e829117
1 parent 8e6d4ef
commit e829117
Show file tree

Hide file tree

Showing 9 changed files with 505 additions and 42 deletions.
diff --git a/src/glitch.gleam b/src/glitch.gleam
@@ -16,6 +16,8 @@ pub fn get_access_token() {
   let assert Ok(client_secret) = env.get("CLIENT_SECRET")
   let scopes = [
     scope.ChannelBot,
+    scope.ChannelManageRedemptions,
+    scope.ChannelReadRedemptions,
     scope.ChannelReadSubscriptions,
     scope.ChatRead,
     scope.UserBot,
@@ -47,6 +49,8 @@ fn new_client() {
   let assert Ok(client_secret) = env.get("CLIENT_SECRET")
   let scopes = [
     scope.ChannelBot,
+    scope.ChannelManageRedemptions,
+    scope.ChannelReadRedemptions,
     scope.ChannelReadSubscriptions,
     scope.ChatRead,
     scope.UserBot,
@@ -93,6 +97,6 @@ pub fn test_eventsub() {
 
 pub fn main() {
   // get_access_token()
-  // let _ = test_chat()
+  // // let _ = test_chat()
   test_eventsub()
 }
diff --git a/src/glitch/api/transport.gleam b/src/glitch/api/transport.gleam
diff --git a/src/glitch/eventsub/eventsub.gleam b/src/glitch/eventsub/eventsub.gleam
@@ -60,6 +60,10 @@ fn handle(state: EventSub, message: WebSocketMessage) {
       io.println("Closed")
       io.debug(message)
     }
+    websocket_message.NotificationMessage(..) -> {
+      io.println("NotificationMessage")
+      io.debug(message)
+    }
     websocket_message.SessionKeepaliveMessage(..) -> {
       io.println("SessionKeepaliveMessage")
       io.debug(message)
@@ -69,21 +73,50 @@ fn handle(state: EventSub, message: WebSocketMessage) {
       io.debug(message)
     }
     websocket_message.WelcomeMessage(_, payload) -> {
+      // let resp =
+      //   eventsub.create_eventsub_subscription(
+      //     state.client,
+      //     CreateEventSubSubscriptionRequest(
+      //       ChannelChatMessage,
+      //       "1",
+      //       Condition(
+      //         Some("209286766"),
+      //         None,
+      //         None,
+      //         None,
+      //         None,
+      //         Some(client.client_id(state.client)),
+      //         None,
+      //         Some("209286766"),
+      //       ),
+      //       Transport(
+      //         WebSocket,
+      //         None,
+      //         None,
+      //         Some(payload.session.id),
+      //         None,
+      //         None,
+      //         None,
+      //       ),
+      //     ),
+      //   )
+      // let _ = io.debug(resp)
+
       let resp =
         eventsub.create_eventsub_subscription(
           state.client,
           CreateEventSubSubscriptionRequest(
-            ChannelChatMessage,
+            subscription.ChannelPointsCustomRewardRedemptionAdd,
             "1",
             Condition(
               Some("209286766"),
               None,
               None,
               None,
               None,
-              Some(client.client_id(state.client)),
               None,
-              Some("209286766"),
+              None,
+              None,
             ),
             Transport(
               WebSocket,

diff --git a/src/glitch/eventsub/subscription.gleam b/src/glitch/eventsub/subscription.gleam