Fixed a bug that made user-input rewards impossible to update.

Added Sentry error reporting using Streamer.bot dependency.
Fixed chat config trigger.
Fixed reported errors.
New trigger : Kicks Gifted.
Also added informations about automoderated messages.

Author: Sehelitar

API/Events/ChatMessageDeletedEvent.cs

@@ -25,6 +25,10 @@ public class ChatMessageDeletedEvent
         public string Id { get; internal set; }
         [JsonProperty("message")]
         public ChatMessageDeletedInfos Message { get; internal set; }
+        [JsonProperty("aiModerated")]
+        public bool AiModerated { get; internal set; }
+        [JsonProperty("violatedRules")]
+        public string[] ViolatedRules { get; internal set; } = {};
     }
 
     public class ChatMessageDeletedInfos

API/Events/KicksGiftedEvent.cs

@@ -0,0 +1,59 @@
+/*
+    Copyright (C) 2023-2025 Sehelitar
+
+    This program is free software: you can redistribute it and/or modify
+    it under the terms of the GNU Affero General Public License as published
+    by the Free Software Foundation, either version 3 of the License, or
+    (at your option) any later version.
+
+    This program is distributed in the hope that it will be useful,
+    but WITHOUT ANY WARRANTY; without even the implied warranty of
+    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+    GNU Affero General Public License for more details.
+
+    You should have received a copy of the GNU Affero General Public License
+    along with this program.  If not, see <https://www.gnu.org/licenses/>.
+ */
+
+using Newtonsoft.Json;
+
+namespace Kick.API.Events
+{
+    public class KicksGiftedEvent
+    {
+        [JsonProperty("message")]
+        public string Message { get; internal set; }
+        [JsonProperty("sender")]
+        public KicksGiftingUser Sender { get; internal set; }
+        [JsonProperty("gift")]
+        public KicksGift Gift { get; internal set; }
+    }
+
+    public class KicksGiftingUser
+    {
+        [JsonProperty("id")]
+        public string Id { get; internal set; }
+        [JsonProperty("username")]
+        public string Username { get; internal set; }
+        [JsonProperty("username_color")]
+        public string Color { get; internal set; }
+    }
+
+    public class KicksGift
+    {
+        [JsonProperty("gift_id")]
+        public string GiftId { get; internal set; }
+        [JsonProperty("name")]
+        public string Name { get; internal set; }
+        [JsonProperty("amount")]
+        public int Amount { get; internal set; }
+        [JsonProperty("type")]
+        public string Type { get; internal set; }
+        [JsonProperty("tier")]
+        public string Tier { get; internal set; }
+        [JsonProperty("character_limit")]
+        public int CharacterLimit { get; internal set; }
+        [JsonProperty("pinned_time")]
+        public int PinnedTime { get; internal set; }
+    }
+}

API/KickClient.cs

@@ -613,7 +613,7 @@ public async Task<Reward> UpdateReward(Channel channel, Reward reward)
                 { "should_redemptions_skip_request_queue", reward.ShouldRedemptionsSkipRequestQueue },
                 { "title", reward.Title },
             };
-            if(reward.IsUserInputRequired)
+            if(reward.IsUserInputRequired && !string.IsNullOrEmpty(reward.Prompt))
                 data.Add("prompt", reward.Prompt);
             var response = await ApiJsonPatch<KickApiMessageOperationResponse<Reward>>($"/api/v2/channels/{channel.Slug}/rewards/{reward.Id}", data);
             if (response.Message != "OK")

API/KickEventListener.cs

@@ -123,6 +123,9 @@ public sealed class KickEventListener
         public delegate void OnPredictionUpdatedHandler(Prediction prediction);
         public event OnPredictionUpdatedHandler OnPredictionUpdated;
 
+        public delegate void OnKicksGiftedHandler(KicksGiftedEvent kicksGiftedEvent);
+        public event OnKicksGiftedHandler OnKicksGifted;
+        
         private readonly Pusher _pusherClient;
         //private delegate void PusherEventHandler(string eventType, PusherEvent eventData);
 
@@ -155,6 +158,7 @@ public async Task JoinAsync(Models.Channel channel)
         private async Task RegisterChannel(Models.Channel channel)
         {
             var channels = new List<string> {
+                $"channel_{channel.Id}",
                 $"chatrooms.{channel.Chatroom.Id}.v2",
                 $"predictions-channel-{channel.Id}"
             };
@@ -225,6 +229,12 @@ private void HandleEvent(string eventType, PusherEvent eventData)
 
             switch (eventType)
             {
+                // channel_<id>
+                case "KicksGifted":
+                    var kicksGifted = JsonConvert.DeserializeObject<KicksGiftedEvent>(eventData.Data);
+                    OnKicksGifted?.Invoke(kicksGifted);
+                    return;
+                
                 // chatrooms.<id>.v2
                 case "App\\Events\\ChatMessageEvent":
                     var chatMessageEvent = JsonConvert.DeserializeObject<ChatMessageEvent>(eventData.Data);
@@ -449,49 +459,50 @@ private void PollUpdate(Models.Channel channel, PollUpdateEvent pollUpdateEvent)
             if(!_currentPolls.ContainsKey(channel.Id))
             {
                 _currentPolls[channel.Id] = pollUpdateEvent;
+                
+                // Poll Created
+                OnPollCreated?.Invoke(pollUpdateEvent);
+                
                 var pollUpdater = new Thread(() =>
                 {
-                    // Poll Created
-                    OnPollCreated?.Invoke(pollUpdateEvent);
-
                     // Wait for poll to end
                     var waitHandle = new AutoResetEvent(false);
-                    var remaining = pollUpdateEvent.Poll.Remaining;
-                    var timer = new Timer(state => {
-                        if(!_currentPolls.TryGetValue(channel.Id, out var currentPoll))
-                        {
-                            // Not supposed to happen, thread will be stopped
-                            currentPoll = pollUpdateEvent; // Restore context
-                            pollUpdateEvent.State = PollState.Cancelled;
-                        } else
+                    if (pollUpdateEvent?.Poll != null)
+                    {
+                        var timer = new Timer(state =>
                         {
-                            pollUpdateEvent = currentPoll; // Save context
-                        }
-
-                        if(pollUpdateEvent.State == PollState.Cancelled)
-                        {
-                            OnPollCancelled?.Invoke(pollUpdateEvent);
-                            waitHandle.Set();
-                            return;
-                        }
-
-                        currentPoll.Poll.Remaining = --remaining;
-                        if (currentPoll.Poll.Remaining >= 0)
-                        {
-                            OnPollUpdated?.Invoke(currentPoll);
-                        }
-                        else
-                        {
-                            currentPoll.Poll.Remaining = 0;
-                            currentPoll.State = PollState.Completed;
-                            OnPollCompleted?.Invoke(currentPoll);
-                            waitHandle.Set();
-                        }
-                    }, null, 1000, 1000);
-                    waitHandle.WaitOne();
-
-                    // Stop Timer
-                    timer.Dispose();
+                            if (!_currentPolls.TryGetValue(channel.Id, out var currentPoll))
+                            {
+                                // Not supposed to happen, thread will be stopped
+                                currentPoll = pollUpdateEvent; // Restore context
+                                currentPoll.State = PollState.Cancelled;
+                            }
+
+                            if (currentPoll.State == PollState.Cancelled)
+                            {
+                                OnPollCancelled?.Invoke(currentPoll);
+                                waitHandle.Set();
+                                return;
+                            }
+
+                            --currentPoll.Poll.Remaining;
+                            if (currentPoll.Poll.Remaining >= 0)
+                            {
+                                OnPollUpdated?.Invoke(currentPoll);
+                            }
+                            else
+                            {
+                                currentPoll.Poll.Remaining = 0;
+                                currentPoll.State = PollState.Completed;
+                                OnPollCompleted?.Invoke(currentPoll);
+                                waitHandle.Set();
+                            }
+                        }, null, 1000, 1000);
+                        waitHandle.WaitOne();
+
+                        // Stop Timer
+                        timer.Dispose();
+                    }
 
                     // Poll completed
                     _currentPolls.Remove(channel.Id);
@@ -501,7 +512,8 @@ private void PollUpdate(Models.Channel channel, PollUpdateEvent pollUpdateEvent)
             else {
                 if (pollUpdateEvent != null)
                 {
-                    _currentPolls[channel.Id].Poll = pollUpdateEvent.Poll;
+                    if (pollUpdateEvent.Poll != null)
+                        _currentPolls[channel.Id].Poll.Options = pollUpdateEvent.Poll.Options;
                 }
                 else
                 {