音频中继示例

samples/Kook.Net.Samples.Audio/Modules/MusicModule.cs

@@ -234,6 +234,106 @@ public async Task ListAsync()
         await ReplyTextAsync(string.Join(Environment.NewLine, queue.Select((x, i) => $"[{i}] {x}")));
     }
 
+    [Command("relay", RunMode = RunMode.Async)]
+    [RequireContext(ContextType.Guild)]
+    public async Task RelayAsync(SocketVoiceChannel targetChannel)
+    {
+        if (Context.Message.Source is not MessageSource.User) return;
+        if (Context.Channel is not SocketVoiceChannel voiceChannel)
+        {
+            await ReplyTextAsync("You muse use this command in a voice channel.");
+            return;
+        }
+
+        IAudioClient? sourceClient = await voiceChannel.ConnectAsync();
+        if (sourceClient is null)
+        {
+            await ReplyTextAsync("Failed to connect to the voice channel.");
+            return;
+        }
+        await Task.Delay(TimeSpan.FromSeconds(3));
+        IAudioClient? targetClient = await targetChannel.ConnectAsync();
+        if (targetClient is null)
+        {
+            await ReplyTextAsync("Failed to connect to the target voice channel.");
+            return;
+        }
+        bool hasStarted = false;
+
+        CancellationTokenSource relayCancellationTokenSource = new();
+        sourceClient.StreamCreated += (ssrc, stream) =>
+        {
+            if (hasStarted)
+                return Task.CompletedTask;
+            hasStarted = true;
+            Task.Run(async () =>
+            {
+                try
+                {
+                    Console.WriteLine($"Stream created for SSRC: {ssrc}.");
+                    _ = Task.Run(async () => await PushStreamAsync(targetClient, stream, relayCancellationTokenSource.Token));
+                }
+                catch (Exception e)
+                {
+                    Console.WriteLine(e);
+                }
+            });
+            return Task.CompletedTask;
+        };
+        sourceClient.StreamDestroyed += ssrc =>
+        {
+            relayCancellationTokenSource.Cancel();
+            Console.WriteLine($"Stream destroyed for {ssrc}.");
+            return Task.CompletedTask;
+        };
+
+        CancellationTokenSource cancellationTokenSource = new(TimeSpan.FromSeconds(10));
+        await PushStreamAsync(sourceClient, cancellationTokenSource.Token);
+
+        await ReplyTextAsync("Relaying.");
+
+    }
+
+    private async Task PushStreamAsync(IAudioClient audioClient, Stream stream, CancellationToken cancellationToken)
+    {
+        await using AudioOutStream kook = audioClient.CreatePcmStream(AudioApplication.Music);
+        try
+        {
+            await stream.CopyToAsync(kook, cancellationToken);
+        }
+        finally
+        {
+            await kook.FlushAsync(cancellationToken);
+        }
+    }
+
+    private async Task PushStreamAsync(IAudioClient audioClient, CancellationToken cancellationToken)
+    {
+        // Just push some audio data to the audio client to start receiving audio data.
+        using Process? ffmpeg = Process.Start(new ProcessStartInfo
+        {
+            FileName = "ffmpeg",
+            Arguments = $"""-hide_banner -loglevel panic -i "https://sao.fm/api/fm/?id=734" -ac 2 -f s16le -ar 48000 -""",
+            UseShellExecute = false,
+            RedirectStandardOutput = true,
+        });
+        if (ffmpeg is null) return;
+        await using Stream output = ffmpeg.StandardOutput.BaseStream;
+        await using AudioOutStream kook = audioClient.CreatePcmStream(AudioApplication.Music);
+        try
+        {
+            await output.CopyToAsync(kook, cancellationToken);
+        }
+        catch (Exception e)
+        {
+            Console.WriteLine(e);
+        }
+        finally
+        {
+            await kook.FlushAsync(cancellationToken);
+        }
+    }
+
     private static readonly Regex neteaseSongPageRegex = new(@"^https://music.163.com(/#)?/song\?id=(?<id>\d+)(&.*)?$", RegexOptions.Compiled);
     private static readonly Regex qqSongPageRegex = new(@"^https://y.qq.com/n/ryqq/songDetail/(?<id>\w+)(&.*)?$", RegexOptions.Compiled);
 
@@ -298,3 +398,4 @@ public async Task ListAsync()
         return null;
     }
 }
+

src/Kook.Net.Core/Entities/Roles/IRole.cs

@@ -1,7 +1,7 @@
 namespace Kook;
 
 /// <summary>
-///     表示一个基于网关的可授予服务器用户的角色。
+///     表示一个通用的可授予服务器用户的角色。
 /// </summary>
 public interface IRole : IEntity<uint>, IDeletable, IMentionable, IComparable<IRole>
 {

src/Kook.Net.Rest/Net/DefaultRestClient.cs

@@ -41,7 +41,9 @@ public DefaultRestClient(string baseUrl, bool useProxy = false)
 
         _client = new HttpClient(new HttpClientHandler
         {
-            AutomaticDecompression = DecompressionMethods.GZip | DecompressionMethods.Deflate, UseCookies = false, UseProxy = useProxy
+            AutomaticDecompression = DecompressionMethods.GZip | DecompressionMethods.Deflate,
+            UseCookies = false,
+            UseProxy = useProxy
         });
         SetHeader("accept-encoding", "gzip, deflate");
 
@@ -60,8 +62,8 @@ private void Dispose(bool disposing)
     {
         if (!_isDisposed)
         {
-            if (disposing) _client.Dispose();
-
+            if (disposing)
+                _client.Dispose();
             _isDisposed = true;
         }
     }
@@ -83,7 +85,8 @@ public async Task<RestResponse> SendAsync(HttpMethod method, string endpoint, Ca
         string uri = Path.Combine(_baseUrl, endpoint);
         using (HttpRequestMessage restRequest = new(method, uri))
         {
-            if (reason != null) restRequest.Headers.Add("X-Audit-Log-Reason", Uri.EscapeDataString(reason));
+            if (reason != null)
+                restRequest.Headers.Add("X-Audit-Log-Reason", Uri.EscapeDataString(reason));
 
             if (requestHeaders != null)
                 foreach (KeyValuePair<string, IEnumerable<string>> header in requestHeaders)
@@ -99,7 +102,8 @@ public async Task<RestResponse> SendAsync(HttpMethod method, string endpoint, st
     {
         string uri = Path.Combine(_baseUrl, endpoint);
         using HttpRequestMessage restRequest = new(method, uri);
-        if (reason != null) restRequest.Headers.Add("X-Audit-Log-Reason", Uri.EscapeDataString(reason));
+        if (reason != null)
+            restRequest.Headers.Add("X-Audit-Log-Reason", Uri.EscapeDataString(reason));
 
         if (requestHeaders != null)
             foreach (KeyValuePair<string, IEnumerable<string>> header in requestHeaders)

src/Kook.Net.WebSocket/Audio/Streams/InputStream.cs

@@ -77,7 +77,11 @@ public override async Task<RtpFrame> ReadFrameAsync(CancellationToken cancellati
     public override void WriteHeader(ushort seq, uint timestamp, bool missed)
     {
         if (_hasHeader)
+        {
+            _hasHeader = false;
             throw new InvalidOperationException("Header received with no payload");
+        }
+
         _hasHeader = true;
         _nextSeq = seq;
         _nextTimestamp = timestamp;

src/Kook.Net.WebSocket/Audio/Streams/OpusDecodeStream.cs

@@ -29,7 +29,11 @@ public OpusDecodeStream(AudioStream next)
     public override void WriteHeader(ushort seq, uint timestamp, bool missed)
     {
         if (_hasHeader)
-            throw new InvalidOperationException("Header received with no payload.");
+        {
+            _hasHeader = false;
+            throw new InvalidOperationException("Header received with no payload");
+        }
+
         _hasHeader = true;
 
         _nextMissed = missed;

src/Kook.Net.WebSocket/Audio/Streams/RtpWriteStream.cs

@@ -45,7 +45,10 @@ public RtpWriteStream(AudioStream next, uint ssrc, byte payloadType, int bufferS
     public override void WriteHeader(ushort seq, uint timestamp, bool missed)
     {
         if (_hasHeader)
+        {
+            _hasHeader = false;
             throw new InvalidOperationException("Header received with no payload");
+        }
 
         _hasHeader = true;
         _nextSeq = seq;