Browse Source

Fixed edit message queue

tags/docs-0.9
RogueException 9 years ago
parent
commit
954fea856f
1 changed files with 18 additions and 9 deletions
  1. +18
    -9
      src/Discord.Net/DiscordClient.Messages.cs

+ 18
- 9
src/Discord.Net/DiscordClient.Messages.cs View File

@@ -353,22 +353,31 @@ namespace Discord
{ {
while (_pendingMessages.TryDequeue(out queuedMessage)) while (_pendingMessages.TryDequeue(out queuedMessage))
{ {
SendMessageResponse response = null;
var msg = queuedMessage.Message; var msg = queuedMessage.Message;
try try
{ {
response = await _api.SendMessage(
if (msg.Id < 0)
{
await _api.SendMessage(
msg.Channel.Id,
queuedMessage.Text,
queuedMessage.MentionedUsers,
IdConvert.ToString(msg.Id), //Nonce
msg.IsTTS)
.ConfigureAwait(false);
RaiseMessageSent(msg);
}
else
{
await _api.EditMessage(
msg.Id,
msg.Channel.Id, msg.Channel.Id,
queuedMessage.Text, queuedMessage.Text,
queuedMessage.MentionedUsers,
IdConvert.ToString(msg.Id), //Nonce
msg.IsTTS)
.ConfigureAwait(false);
queuedMessage.MentionedUsers);
}
} }
catch (WebException) { break; } catch (WebException) { break; }
catch (HttpException) { msg.State = MessageState.Failed; }
RaiseMessageSent(msg);
catch (HttpException) { msg.State = MessageState.Failed; }
} }
await Task.Delay(interval).ConfigureAwait(false); await Task.Delay(interval).ConfigureAwait(false);
} }


Loading…
Cancel
Save