From f6595aa73e54bafd7e9206aba6ef912cc27caa41 Mon Sep 17 00:00:00 2001 From: RogueException Date: Sun, 26 Jun 2016 19:47:53 -0300 Subject: [PATCH] Added IDisposable to DiscordClients, removed unused property --- src/Discord.Net/API/DiscordAPIClient.cs | 2 ++ src/Discord.Net/DiscordClient.cs | 6 +++--- src/Discord.Net/DiscordSocketClient.cs | 4 +--- src/Discord.Net/IDiscordClient.cs | 3 ++- 4 files changed, 8 insertions(+), 7 deletions(-) diff --git a/src/Discord.Net/API/DiscordAPIClient.cs b/src/Discord.Net/API/DiscordAPIClient.cs index c138e455f..2a0b4c02e 100644 --- a/src/Discord.Net/API/DiscordAPIClient.cs +++ b/src/Discord.Net/API/DiscordAPIClient.cs @@ -99,6 +99,8 @@ namespace Discord.API { _loginCancelToken?.Dispose(); _connectCancelToken?.Dispose(); + (_restClient as IDisposable)?.Dispose(); + (_gatewayClient as IDisposable)?.Dispose(); } _isDisposed = true; } diff --git a/src/Discord.Net/DiscordClient.cs b/src/Discord.Net/DiscordClient.cs index bc5601bb1..9b0cfbb6b 100644 --- a/src/Discord.Net/DiscordClient.cs +++ b/src/Discord.Net/DiscordClient.cs @@ -1,5 +1,4 @@ using Discord.API.Rest; -using Discord.Extensions; using Discord.Logging; using Discord.Net; using Discord.Net.Queue; @@ -56,7 +55,7 @@ namespace Discord if (bucket == null && id != null) await _queueLogger.WarningAsync($"Unknown rate limit bucket \"{id ?? "null"}\"").ConfigureAwait(false); }; - + ApiClient = new API.DiscordApiClient(config.RestClientProvider, (config as DiscordSocketConfig)?.WebSocketProvider, requestQueue: _requestQueue); ApiClient.SentRequest += async (method, endpoint, millis) => await _restLogger.VerboseAsync($"{method} {endpoint}: {millis} ms").ConfigureAwait(false); } @@ -256,10 +255,11 @@ namespace Discord return models.Select(x => new VoiceRegion(x)).Where(x => x.Id == id).FirstOrDefault(); } - internal void Dispose(bool disposing) + internal virtual void Dispose(bool disposing) { if (!_isDisposed) _isDisposed = true; + ApiClient.Dispose(); } /// public void Dispose() => Dispose(true); diff --git a/src/Discord.Net/DiscordSocketClient.cs b/src/Discord.Net/DiscordSocketClient.cs index 966b525c5..f27a26657 100644 --- a/src/Discord.Net/DiscordSocketClient.cs +++ b/src/Discord.Net/DiscordSocketClient.cs @@ -47,8 +47,7 @@ namespace Discord public ConnectionState ConnectionState { get; private set; } /// Gets the estimated round-trip latency, in milliseconds, to the gateway server. public int Latency { get; private set; } - - internal IWebSocketClient GatewaySocket { get; private set; } + internal int MessageCacheSize { get; private set; } internal DataStore DataStore { get; private set; } @@ -97,7 +96,6 @@ namespace Discord else await _gatewayLogger.WarningAsync($"Connection Closed").ConfigureAwait(false); }; - GatewaySocket = config.WebSocketProvider(); _voiceRegions = ImmutableDictionary.Create(); _largeGuilds = new ConcurrentQueue(); diff --git a/src/Discord.Net/IDiscordClient.cs b/src/Discord.Net/IDiscordClient.cs index 821de976f..c65d7b49e 100644 --- a/src/Discord.Net/IDiscordClient.cs +++ b/src/Discord.Net/IDiscordClient.cs @@ -1,4 +1,5 @@ using Discord.API; +using System; using System.Collections.Generic; using System.IO; using System.Threading.Tasks; @@ -6,7 +7,7 @@ using System.Threading.Tasks; namespace Discord { //TODO: Add docstrings - public interface IDiscordClient + public interface IDiscordClient : IDisposable { LoginState LoginState { get; } ConnectionState ConnectionState { get; }