Merge pull request #86 from standleypg-dev/Feat/Rewind

Added simple rewind mechanism

Author: standleypg

src/Application/Interfaces/Services/IMusicQueueService.cs

@@ -9,5 +9,6 @@ public interface IMusicQueueService
     void DequeueAsync(CancellationToken cancellationToken);
     int Count { get; }
     PlayRequest[] GetAllRequests();
+    void Rewind();
     void Clear();
 }

src/Infrastructure/Commands/MusicActionCommands.cs

@@ -77,6 +77,27 @@ await executor.ExecuteAsync(async serviceProvider =>
         }
     }
 
+    [SlashCommand("rewind", "Rewind the current track")]
+    public async Task Rewind()
+    {
+        if (await CommandUtils.NotInVoiceChannel(Context, (message) => RespondAsync(message)))
+        {
+            return;
+        }
+
+        InteractionMessageProperties message;
+        if(queue.Count == 0)
+        {
+            message = CommandUtils.CreateMessage<InteractionMessageProperties>("No songs in queue.");
+            await RespondAsync(InteractionCallback.Message(message));
+            return;
+        }
+        
+        queue.Rewind();
+        message = CommandUtils.CreateMessage<InteractionMessageProperties>("Rewinding the current track.");
+        await RespondAsync(InteractionCallback.Message(message));
+    }
+
     [SlashCommand("statistics", "Show some statistics")]
     public async Task Statistics()
     {

src/Infrastructure/Services/MusicQueueService.cs

@@ -74,6 +74,30 @@ public PlayRequest[] GetAllRequests()
         }
     }
 
+    public void Rewind()
+    {
+        lock (_lock)
+        {
+            if (_queue.Count > 1)
+            {
+                var current = _queue.Peek();
+                var list = _queue.ToList();
+                list.Reverse();
+                list.Add(current);
+                list.Reverse();
+                _queue.Clear();
+                foreach (var item in list)
+                {
+                    _queue.Enqueue(item);
+                }
+            }
+            else
+            {
+                logger.LogWarning("Attempted to rewind with less than two items in the queue.");
+            }
+        }
+    }
+
     public void Clear()
     {
         lock (_lock)