mattburchett/NadekoBot
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

More attempts to stabilize

Browse Source
This commit is contained in:
Kwoth 2017-01-03 22:49:39 +01:00
parent c7c555d010
commit 703dc7b3b2
1 changed files with 15 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
src/NadekoBot/ShardedDiscordClient.cs
View File

@ -65,6 +65,13 @@ namespace NadekoBot
client.ChannelUpdated += (arg1, arg2) => { ChannelUpdated(arg1, arg2); return Task.CompletedTask; }; client.ChannelUpdated += (arg1, arg2) => { ChannelUpdated(arg1, arg2); return Task.CompletedTask; };
_log.Info($"Shard #{i} initialized."); _log.Info($"Shard #{i} initialized.");
client.Disconnected += (ex) =>
{
_log.Error("Shard #{0} disconnected", i);
_log.Error(ex);
return Task.CompletedTask;
};
} }
Clients = clientList.AsReadOnly(); Clients = clientList.AsReadOnly();
@ -85,8 +92,14 @@ namespace NadekoBot
public Task<IDMChannel> GetDMChannelAsync(ulong channelId) => public Task<IDMChannel> GetDMChannelAsync(ulong channelId) =>
Clients[0].GetDMChannelAsync(channelId); Clients[0].GetDMChannelAsync(channelId);
internal Task LoginAsync(TokenType tokenType, string token) => internal async Task LoginAsync(TokenType tokenType, string token)
Task.WhenAll(Clients.Select(async c => { await c.LoginAsync(tokenType, token).ConfigureAwait(false); _log.Info($"Shard #{c.ShardId} logged in."); })); {
foreach (var c in Clients)
{
await c.LoginAsync(tokenType, token).ConfigureAwait(false);
_log.Info($"Shard #{c.ShardId} logged in.");
}
}
internal async Task ConnectAsync() internal async Task ConnectAsync()
{ {