eightball/PluralKit
1
0
Fork 0
mirror of https://github.com/PluralKit/PluralKit.git synced 2026-02-04 04:56:49 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 1

fix(bot): add shard up count to stats embed, add stats fallback

Browse source
This commit is contained in:
alyssa 2025-01-05 01:49:32 +00:00
parent 9f8d3d22d2
commit 57ae3b5e49
1 changed files with 15 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

18
PluralKit.Bot/Commands/Misc.cs
View file

@ -61,11 +61,23 @@ public class Misc
var shards = await _shards.GetShards();
var shardInfo = shards.Where(s => s.ShardId == ctx.ShardId).FirstOrDefault();
var shardsUp = shards.Where(s => s.Up).Count();
if (stats == null)
{
var content = $"Stats unavailable (is scheduled_tasks service running?)\n\n**Quick info:**"
+ $"\nPluralKit [{BuildInfoService.Version}](<https://github.com/pluralkit/pluralkit/commit/{BuildInfoService.FullVersion}>)"
+ $"\nCurrently on shard {ctx.ShardId}, {shardsUp}/{shards.Count()} shards up,"
+ $" API latency: {apiLatency.TotalMilliseconds:F0}ms";
await ctx.Rest.EditMessage(msg.ChannelId, msg.Id,
new MessageEditRequest { Content = content });
return;
}
var embed = new EmbedBuilder();
embed
.Field(new("Connection status", $"**{shards.Count()}** shards across **{shards.Select(s => s.ClusterId).Distinct().Count()}** clusters\n"
.Field(new("Connection status", $"**{shards.Count()}** shards across **{shards.Select(s => s.ClusterId).Distinct().Count()}** clusters (**{shardsUp} up**)\n"
+ $"Current server is on **shard {ctx.ShardId} (cluster {shardInfo.ClusterId ?? 0})**\n"
+ $"Latency: API **{apiLatency.TotalMilliseconds:F0}ms** (p90: {stats.prom.nirn_proxy_latency_p90 * 1000:F0}ms, p99: {stats.prom.nirn_proxy_latency_p99 * 1000:F0}ms), "
+ $"shard **{shardInfo.Latency}ms** (avg: {stats.prom.shard_latency_average}ms)", true))
@ -91,11 +103,11 @@ public class Misc
new MessageEditRequest { Content = "", Embeds = new[] { embed.Build() } });
}
private async Task<Stats> GetStats(Context ctx)
private async Task<Stats?> GetStats(Context ctx)
{
var db = ctx.Redis.Connection.GetDatabase();
var data = await db.StringGetAsync("statsapi");
return JsonConvert.DeserializeObject<Stats>(data);
return data.HasValue ? JsonConvert.DeserializeObject<Stats>(data) : null;
}
}