[Channel Points] Automatically checking off sounds we play

Author: ProgrammingByPermutation

streaming-tools/streaming-tools/Utilities/GlobalSoundManager.cs

@@ -3,6 +3,7 @@
     using System.Collections.Concurrent;
     using System.IO;
     using System.Threading;
+    using System.Threading.Tasks;
     using NAudio.Wave;
 
     /// <summary>
@@ -33,7 +34,7 @@ public class GlobalSoundManager {
         ///     Initializes a new instance of the <see cref="GlobalSoundManager" /> class.
         /// </summary>
         protected GlobalSoundManager() {
-            this.exitSentinel = new SoundPlayingWrapper(string.Empty, string.Empty, -1);
+            this.exitSentinel = new SoundPlayingWrapper(string.Empty, string.Empty, -1, null);
             this.soundsToPlay = new BlockingCollection<SoundPlayingWrapper>();
             this.soundPlayThread = new Thread(this.SoundPlayThreadMain);
             this.soundPlayThread.IsBackground = true;
@@ -64,12 +65,13 @@ public static GlobalSoundManager Instance {
         /// <param name="filename">The name of the file to play.</param>
         /// <param name="outputDevice">The output device to play the file on.</param>
         /// <param name="volume">The volume to play the file at.</param>
-        public void QueueSound(string filename, string outputDevice, int volume) {
+        /// <param name="callback">The callback in invoke after the sound is played.</param>
+        public void QueueSound(string filename, string outputDevice, int volume, Action? callback) {
             if (string.IsNullOrWhiteSpace(filename) || string.IsNullOrWhiteSpace(outputDevice) || volume < 0 || volume > 100) {
                 return;
             }
 
-            this.soundsToPlay.Add(new SoundPlayingWrapper(filename, outputDevice, volume));
+            this.soundsToPlay.Add(new SoundPlayingWrapper(filename, outputDevice, volume, callback));
         }
 
         /// <summary>
@@ -99,14 +101,24 @@ private void SoundPlayThreadMain() {
                         signal.Wait();
                         this.CurrentlyPlayingSound = false;
                     }
-                } catch (Exception) { }
+
+                    if (null != sound.Callback) {
+                        Task.Run(sound.Callback);
+                    }
+                } catch (Exception) {
+                }
             }
         }
 
         /// <summary>
         ///     A wrapper that contains all of the information we need to play a sound.
         /// </summary>
         public class SoundPlayingWrapper {
+            /// <summary>
+            ///     The callback to invoke after the sound is played.
+            /// </summary>
+            public Action? Callback;
+
             /// <summary>
             ///     The name of the file.
             /// </summary>
@@ -128,10 +140,12 @@ public class SoundPlayingWrapper {
             /// <param name="filename">The name of the file.</param>
             /// <param name="outputDevice">The output device to stream to.</param>
             /// <param name="volume">The volume to play the file at.</param>
-            public SoundPlayingWrapper(string filename, string outputDevice, int volume) {
+            /// <param name="callback">The callback to invoke after the sound is played.</param>
+            public SoundPlayingWrapper(string filename, string outputDevice, int volume, Action? callback) {
                 this.Filename = filename;
                 this.OutputDevice = outputDevice;
                 this.Volume = volume;
+                this.Callback = callback;
             }
         }
     }

streaming-tools/streaming-tools/ViewModels/ChannelPointViewModel.cs

@@ -9,6 +9,8 @@
     using DynamicData;
     using ReactiveUI;
     using Twitch;
+    using TwitchLib.Api.Core.Enums;
+    using TwitchLib.Api.Helix.Models.ChannelPoints.UpdateCustomRewardRedemptionStatus;
     using TwitchLib.PubSub.Events;
     using Utilities;
 
@@ -97,7 +99,7 @@ public async void RefreshChannelPointRewards() {
                     return;
                 }
 
-                var response = await api.Helix.Users.GetUsersAsync(logins: new List<string> { account.Username });
+                var response = await api.Helix.Users.GetUsersAsync(logins: new List<string> {account.Username});
                 var user = response.Users.FirstOrDefault();
                 if (null == user) {
                     return;
@@ -109,8 +111,26 @@ public async void RefreshChannelPointRewards() {
                 var toAdd = actualRewardNames.Except(knownRewardNames);
                 var toDelete = knownRewardNames.Except(actualRewardNames);
 
+                // foreach (var reward in rewards.Data.Where(d => d.Title.StartsWith("Sound:"))) {
+                //     await api.Helix.ChannelPoints.CreateCustomRewards(user.Id, new CreateCustomRewardsRequest {
+                //         BackgroundColor = reward.BackgroundColor,
+                //         Cost = reward.Cost,
+                //         GlobalCooldownSeconds = reward.GlobalCooldownSetting.GlobalCooldownSeconds,
+                //         ShouldRedemptionsSkipRequestQueue = reward.ShouldRedemptionsSkipQueue,
+                //         IsEnabled = reward.IsEnabled,
+                //         IsGlobalCooldownEnabled = reward.GlobalCooldownSetting.IsEnabled,
+                //         IsMaxPerStreamEnabled = reward.MaxPerStreamSetting.IsEnabled,
+                //         IsMaxPerUserPerStreamEnabled = reward.MaxPerUserPerStreamSetting.IsEnabled,
+                //         IsUserInputRequired = reward.IsUserInputRequired,
+                //         MaxPerStream = reward.MaxPerStreamSetting.MaxPerStream,
+                //         MaxPerUserPerStream = reward.MaxPerUserPerStreamSetting.MaxPerStream,
+                //         Title = "Sound: Scream",
+                //         Prompt = reward.Prompt
+                //     });
+                // }
+
                 foreach (var reward in toAdd) {
-                    Configuration.Instance.ChannelPointSoundRedemptions.Add(new ChannelPointSoundRedemption { Name = reward });
+                    Configuration.Instance.ChannelPointSoundRedemptions.Add(new ChannelPointSoundRedemption {Name = reward});
                 }
 
                 foreach (var reward in toDelete) {
@@ -122,15 +142,16 @@ public async void RefreshChannelPointRewards() {
 
                 this.ChannelPointSounds.AddRange(Configuration.Instance.ChannelPointSoundRedemptions.Select(c => new ChannelPointSoundWrapper(this, c)));
                 TwitchChatManager.Instance.AddChannelPointsCallback(account, account.Username, this.OnRewardRedeemed);
-            } catch (Exception) { }
+            } catch (Exception) {
+            }
         }
 
         /// <summary>
         ///     Raised when a channel point is redeemed.
         /// </summary>
         /// <param name="sender">The pub sub object.</param>
         /// <param name="e">The reward information.</param>
-        private void OnRewardRedeemed(object? sender, OnRewardRedeemedArgs e) {
+        private async void OnRewardRedeemed(object? sender, OnRewardRedeemedArgs e) {
             if (null == Configuration.Instance.ChannelPointSoundRedemptions || string.IsNullOrWhiteSpace(this.OutputDevice)) {
                 return;
             }
@@ -149,7 +170,33 @@ private void OnRewardRedeemed(object? sender, OnRewardRedeemedArgs e) {
                 volume = 0;
             }
 
-            GlobalSoundManager.Instance.QueueSound(reward.Filename, this.OutputDevice, (int)volume);
+            GlobalSoundManager.Instance.QueueSound(reward.Filename, this.OutputDevice, (int) volume, async () => {
+                var account = Configuration.Instance.TwitchAccounts?.FirstOrDefault(a => a.IsUsersStreamingAccount);
+                if (null == account || null == account.Username) {
+                    return;
+                }
+
+                var api = await TwitchChatManager.Instance.GetTwitchClientApi(account.Username);
+                if (null == api) {
+                    return;
+                }
+
+                var userResponse = await api.Helix.Users.GetUsersAsync(logins: new List<string> {account.Username});
+                var user = userResponse.Users.FirstOrDefault();
+                if (null == user) {
+                    return;
+                }
+
+                try {
+                    await api.Helix.ChannelPoints.UpdateCustomRewardRedemptionStatus(
+                        user.Id,
+                        e.RewardId.ToString(),
+                        new List<string>(new[] {e.RedemptionId.ToString()}),
+                        new UpdateCustomRewardRedemptionStatusRequest {Status = CustomRewardRedemptionStatus.FULFILLED}
+                    );
+                } catch {
+                }
+            });
         }
 
         /// <summary>
@@ -266,7 +313,7 @@ public void PlayPreview() {
                     volume = 0;
                 }
 
-                GlobalSoundManager.Instance.QueueSound(this.Filename, this.parent.OutputDevice, (int)volume);
+                GlobalSoundManager.Instance.QueueSound(this.Filename, this.parent.OutputDevice, (int) volume, null);
             }
 
             /// <summary>