liz/PluralKit
liz/PluralKit
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

fix: don't query /gateway/bot if we already have the info from cluster config

Browse Source
This commit is contained in:
spiral 2022-04-10 10:41:26 -04:00
parent 756859ebe6
commit 9314ce672a
No known key found for this signature in database
GPG Key ID: 244A11E4B0BCF40E
1 changed files with 12 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
PluralKit.Bot/Init.cs
View File

@ -3,6 +3,7 @@ using Autofac;
using Microsoft.Extensions.Configuration; using Microsoft.Extensions.Configuration;
using Myriad.Gateway; using Myriad.Gateway;
using Myriad.Types;
using Myriad.Rest; using Myriad.Rest;
using PluralKit.Core; using PluralKit.Core;
@ -151,8 +152,6 @@ public class Init
private static async Task StartCluster(IComponentContext services) private static async Task StartCluster(IComponentContext services)
{ {
var info = await services.Resolve<DiscordApiClient>().GetGatewayBot();
var redis = services.Resolve<RedisService>(); var redis = services.Resolve<RedisService>();
var cluster = services.Resolve<Cluster>(); var cluster = services.Resolve<Cluster>();
@ -160,6 +159,16 @@ public class Init
if (config.Cluster != null) if (config.Cluster != null)
{ {
var info = new GatewayInfo.Bot()
{
SessionStartLimit = new()
{
MaxConcurrency = config.MaxShardConcurrency ?? 1,
},
Shards = config.Cluster.TotalShards,
Url = "wss://gateway.discord.gg",
};
// For multi-instance deployments, calculate the "span" of shards this node is responsible for // For multi-instance deployments, calculate the "span" of shards this node is responsible for
var totalNodes = config.Cluster.TotalNodes; var totalNodes = config.Cluster.TotalNodes;
var totalShards = config.Cluster.TotalShards; var totalShards = config.Cluster.TotalShards;
@ -173,6 +182,7 @@ public class Init
} }
else else
{ {
var info = await services.Resolve<DiscordApiClient>().GetGatewayBot();
await cluster.Start(info, redis.Connection); await cluster.Start(info, redis.Connection);
} }
} }