* ConnectAsync(bool external) API implemented This allows developers to handle the AudioClient externally (for example with Lavalink) * Modify ConnectAsync API and add DisconnectAsync to IAudioChannel * Update summary message on IAudioChannel.DisconnectAsync() * Review changes: - Fix `if (!external)` styling - Remove unecessary ConnectAsync overload * SocketVoiceChannel overload update * Update IAudioChannel.ConnectAsync() - Remove ConfigAction from parameters - Add SelfDeafen/SelfMute to parameters * Remove SocketVoiceChannel.ConnectAsync() default params (Inherit)tags/2.0
| @@ -1,4 +1,4 @@ | |||||
| using Discord.Audio; | |||||
| using Discord.Audio; | |||||
| using System; | using System; | ||||
| using System.Threading.Tasks; | using System.Threading.Tasks; | ||||
| @@ -7,6 +7,9 @@ namespace Discord | |||||
| public interface IAudioChannel : IChannel | public interface IAudioChannel : IChannel | ||||
| { | { | ||||
| /// <summary> Connects to this audio channel. </summary> | /// <summary> Connects to this audio channel. </summary> | ||||
| Task<IAudioClient> ConnectAsync(Action<IAudioClient> configAction = null); | |||||
| Task<IAudioClient> ConnectAsync(bool selfDeaf = false, bool selfMute = false, bool external = false); | |||||
| /// <summary> Disconnects from this audio channel. </summary> | |||||
| Task DisconnectAsync(); | |||||
| } | } | ||||
| } | } | ||||
| @@ -147,7 +147,8 @@ namespace Discord.Rest | |||||
| => EnterTypingState(options); | => EnterTypingState(options); | ||||
| //IAudioChannel | //IAudioChannel | ||||
| Task<IAudioClient> IAudioChannel.ConnectAsync(Action<IAudioClient> configAction) { throw new NotSupportedException(); } | |||||
| Task<IAudioClient> IAudioChannel.ConnectAsync(bool selfDeaf, bool selfMute, bool external) { throw new NotSupportedException(); } | |||||
| Task IAudioChannel.DisconnectAsync() { throw new NotSupportedException(); } | |||||
| //IChannel | //IChannel | ||||
| Task<IUser> IChannel.GetUserAsync(ulong id, CacheMode mode, RequestOptions options) | Task<IUser> IChannel.GetUserAsync(ulong id, CacheMode mode, RequestOptions options) | ||||
| @@ -45,7 +45,8 @@ namespace Discord.Rest | |||||
| private string DebuggerDisplay => $"{Name} ({Id}, Voice)"; | private string DebuggerDisplay => $"{Name} ({Id}, Voice)"; | ||||
| //IAudioChannel | //IAudioChannel | ||||
| Task<IAudioClient> IAudioChannel.ConnectAsync(Action<IAudioClient> configAction) { throw new NotSupportedException(); } | |||||
| Task<IAudioClient> IAudioChannel.ConnectAsync(bool selfDeaf, bool selfMute, bool external) { throw new NotSupportedException(); } | |||||
| Task IAudioChannel.DisconnectAsync() { throw new NotSupportedException(); } | |||||
| //IGuildChannel | //IGuildChannel | ||||
| Task<IGuildUser> IGuildChannel.GetUserAsync(ulong id, CacheMode mode, RequestOptions options) | Task<IGuildUser> IGuildChannel.GetUserAsync(ulong id, CacheMode mode, RequestOptions options) | ||||
| @@ -211,7 +211,8 @@ namespace Discord.WebSocket | |||||
| => EnterTypingState(options); | => EnterTypingState(options); | ||||
| //IAudioChannel | //IAudioChannel | ||||
| Task<IAudioClient> IAudioChannel.ConnectAsync(Action<IAudioClient> configAction) { throw new NotSupportedException(); } | |||||
| Task<IAudioClient> IAudioChannel.ConnectAsync(bool selfDeaf, bool selfMute, bool external) { throw new NotSupportedException(); } | |||||
| Task IAudioChannel.DisconnectAsync() { throw new NotSupportedException(); } | |||||
| //IChannel | //IChannel | ||||
| Task<IUser> IChannel.GetUserAsync(ulong id, CacheMode mode, RequestOptions options) | Task<IUser> IChannel.GetUserAsync(ulong id, CacheMode mode, RequestOptions options) | ||||
| @@ -43,11 +43,14 @@ namespace Discord.WebSocket | |||||
| public Task ModifyAsync(Action<VoiceChannelProperties> func, RequestOptions options = null) | public Task ModifyAsync(Action<VoiceChannelProperties> func, RequestOptions options = null) | ||||
| => ChannelHelper.ModifyAsync(this, Discord, func, options); | => ChannelHelper.ModifyAsync(this, Discord, func, options); | ||||
| public async Task<IAudioClient> ConnectAsync(Action<IAudioClient> configAction = null) | |||||
| public async Task<IAudioClient> ConnectAsync(bool selfDeaf, bool selfMute, bool external) | |||||
| { | { | ||||
| return await Guild.ConnectAudioAsync(Id, false, false, configAction).ConfigureAwait(false); | |||||
| return await Guild.ConnectAudioAsync(Id, selfDeaf, selfMute, external).ConfigureAwait(false); | |||||
| } | } | ||||
| public async Task DisconnectAsync() | |||||
| => await Guild.DisconnectAudioAsync(); | |||||
| public override SocketGuildUser GetUser(ulong id) | public override SocketGuildUser GetUser(ulong id) | ||||
| { | { | ||||
| var user = Guild.GetUser(id); | var user = Guild.GetUser(id); | ||||
| @@ -508,11 +508,8 @@ namespace Discord.WebSocket | |||||
| { | { | ||||
| return _audioClient?.GetInputStream(userId); | return _audioClient?.GetInputStream(userId); | ||||
| } | } | ||||
| internal async Task<IAudioClient> ConnectAudioAsync(ulong channelId, bool selfDeaf, bool selfMute, Action<IAudioClient> configAction) | |||||
| internal async Task<IAudioClient> ConnectAudioAsync(ulong channelId, bool selfDeaf, bool selfMute, bool external) | |||||
| { | { | ||||
| selfDeaf = false; | |||||
| selfMute = false; | |||||
| TaskCompletionSource<AudioClient> promise; | TaskCompletionSource<AudioClient> promise; | ||||
| await _audioLock.WaitAsync().ConfigureAwait(false); | await _audioLock.WaitAsync().ConfigureAwait(false); | ||||
| @@ -522,6 +519,13 @@ namespace Discord.WebSocket | |||||
| promise = new TaskCompletionSource<AudioClient>(); | promise = new TaskCompletionSource<AudioClient>(); | ||||
| _audioConnectPromise = promise; | _audioConnectPromise = promise; | ||||
| if (external) | |||||
| { | |||||
| var _ = promise.TrySetResultAsync(null); | |||||
| await Discord.ApiClient.SendVoiceStateUpdateAsync(Id, channelId, selfDeaf, selfMute).ConfigureAwait(false); | |||||
| return null; | |||||
| } | |||||
| if (_audioClient == null) | if (_audioClient == null) | ||||
| { | { | ||||
| var audioClient = new AudioClient(this, Discord.GetAudioId(), channelId); | var audioClient = new AudioClient(this, Discord.GetAudioId(), channelId); | ||||
| @@ -529,7 +533,9 @@ namespace Discord.WebSocket | |||||
| { | { | ||||
| if (!promise.Task.IsCompleted) | if (!promise.Task.IsCompleted) | ||||
| { | { | ||||
| try { audioClient.Dispose(); } catch { } | |||||
| try | |||||
| { audioClient.Dispose(); } | |||||
| catch { } | |||||
| _audioClient = null; | _audioClient = null; | ||||
| if (ex != null) | if (ex != null) | ||||
| await promise.TrySetExceptionAsync(ex); | await promise.TrySetExceptionAsync(ex); | ||||
| @@ -543,7 +549,6 @@ namespace Discord.WebSocket | |||||
| var _ = promise.TrySetResultAsync(_audioClient); | var _ = promise.TrySetResultAsync(_audioClient); | ||||
| return Task.Delay(0); | return Task.Delay(0); | ||||
| }; | }; | ||||
| configAction?.Invoke(audioClient); | |||||
| _audioClient = audioClient; | _audioClient = audioClient; | ||||
| } | } | ||||
| @@ -602,8 +607,11 @@ namespace Discord.WebSocket | |||||
| await _audioLock.WaitAsync().ConfigureAwait(false); | await _audioLock.WaitAsync().ConfigureAwait(false); | ||||
| try | try | ||||
| { | { | ||||
| await RepopulateAudioStreamsAsync().ConfigureAwait(false); | |||||
| await _audioClient.StartAsync(url, Discord.CurrentUser.Id, voiceState.VoiceSessionId, token).ConfigureAwait(false); | |||||
| if (_audioClient != null) | |||||
| { | |||||
| await RepopulateAudioStreamsAsync().ConfigureAwait(false); | |||||
| await _audioClient.StartAsync(url, Discord.CurrentUser.Id, voiceState.VoiceSessionId, token).ConfigureAwait(false); | |||||
| } | |||||
| } | } | ||||
| catch (OperationCanceledException) | catch (OperationCanceledException) | ||||
| { | { | ||||