From 79f11455b92a9443f24d587065dd439186775191 Mon Sep 17 00:00:00 2001 From: RogueException Date: Fri, 29 Jul 2016 18:02:39 -0300 Subject: [PATCH] Added logging for RPC events --- src/Discord.Net/Rpc/DiscordRpcClient.cs | 17 +++++++++++++++++ 1 file changed, 17 insertions(+) diff --git a/src/Discord.Net/Rpc/DiscordRpcClient.cs b/src/Discord.Net/Rpc/DiscordRpcClient.cs index c4bb1c38b..7cdbccfff 100644 --- a/src/Discord.Net/Rpc/DiscordRpcClient.cs +++ b/src/Discord.Net/Rpc/DiscordRpcClient.cs @@ -307,6 +307,8 @@ namespace Discord.Rpc //Guilds case "GUILD_STATUS": { + await _rpcLogger.DebugAsync("Received Dispatch (GUILD_STATUS)").ConfigureAwait(false); + await _guildUpdatedEvent.InvokeAsync().ConfigureAwait(false); } break; @@ -314,27 +316,36 @@ namespace Discord.Rpc //Voice case "VOICE_STATE_CREATE": { + await _rpcLogger.DebugAsync("Received Dispatch (VOICE_STATE_CREATE)").ConfigureAwait(false); + await _voiceStateUpdatedEvent.InvokeAsync().ConfigureAwait(false); } break; case "VOICE_STATE_UPDATE": { + await _rpcLogger.DebugAsync("Received Dispatch (VOICE_STATE_UPDATE)").ConfigureAwait(false); + await _voiceStateUpdatedEvent.InvokeAsync().ConfigureAwait(false); } break; case "VOICE_STATE_DELETE": { + await _rpcLogger.DebugAsync("Received Dispatch (VOICE_STATE_DELETE)").ConfigureAwait(false); + await _voiceStateUpdatedEvent.InvokeAsync().ConfigureAwait(false); } break; case "SPEAKING_START": { + await _rpcLogger.DebugAsync("Received Dispatch (SPEAKING_START)").ConfigureAwait(false); await _voiceStateUpdatedEvent.InvokeAsync().ConfigureAwait(false); } break; case "SPEAKING_STOP": { + await _rpcLogger.DebugAsync("Received Dispatch (SPEAKING_STOP)").ConfigureAwait(false); + await _voiceStateUpdatedEvent.InvokeAsync().ConfigureAwait(false); } break; @@ -342,21 +353,27 @@ namespace Discord.Rpc //Messages case "MESSAGE_CREATE": { + await _rpcLogger.DebugAsync("Received Dispatch (MESSAGE_CREATE)").ConfigureAwait(false); var data = (payload.Value as JToken).ToObject(_serializer); var msg = new Message(null, new User(data.Message.Author.Value), data.Message); + await _messageReceivedEvent.InvokeAsync(data.ChannelId, msg).ConfigureAwait(false); } break; case "MESSAGE_UPDATE": { + await _rpcLogger.DebugAsync("Received Dispatch (MESSAGE_UPDATE)").ConfigureAwait(false); var data = (payload.Value as JToken).ToObject(_serializer); var msg = new Message(null, new User(data.Message.Author.Value), data.Message); + await _messageUpdatedEvent.InvokeAsync(data.ChannelId, msg).ConfigureAwait(false); } break; case "MESSAGE_DELETE": { + await _rpcLogger.DebugAsync("Received Dispatch (MESSAGE_DELETE)").ConfigureAwait(false); var data = (payload.Value as JToken).ToObject(_serializer); + await _messageDeletedEvent.InvokeAsync(data.ChannelId, data.Message.Id).ConfigureAwait(false); } break;