sharp-chat/SharpChat/C2SPacketHandlers/PingC2SPacketHandler.cs

44 lines
1.6 KiB
C#
Raw Normal View History

2023-02-16 22:16:06 +01:00
using SharpChat.Misuzu;
using SharpChat.S2CPackets;
2023-02-16 22:16:06 +01:00
namespace SharpChat.C2SPacketHandlers {
public class PingC2SPacketHandler(MisuzuClient msz) : C2SPacketHandler {
2025-04-25 15:49:46 +00:00
private readonly MisuzuClient Misuzu = msz ?? throw new ArgumentNullException(nameof(msz));
2023-02-16 22:16:06 +01:00
private readonly TimeSpan BumpInterval = TimeSpan.FromMinutes(1);
private DateTimeOffset LastBump = DateTimeOffset.MinValue;
public bool IsMatch(C2SPacketHandlerContext ctx) {
2023-02-16 22:16:06 +01:00
return ctx.CheckPacketId("0");
}
public void Handle(C2SPacketHandlerContext ctx) {
2023-02-16 22:16:06 +01:00
string[] parts = ctx.SplitText(2);
if(!int.TryParse(parts.FirstOrDefault(), out int pTime))
return;
2023-02-16 22:25:41 +01:00
ctx.Connection.BumpPing();
ctx.Connection.Send(new PongS2CPacket());
2023-02-16 22:16:06 +01:00
ctx.Chat.ContextAccess.Wait();
try {
2023-02-16 22:16:06 +01:00
if(LastBump < DateTimeOffset.UtcNow - BumpInterval) {
2025-04-25 15:49:46 +00:00
(string, string)[] bumpList = [.. ctx.Chat.Users
.Where(u => u.Status == UserStatus.Online && ctx.Chat.Connections.Any(c => c.User == u))
2025-04-25 15:49:46 +00:00
.Select(u => (u.UserId.ToString(), ctx.Chat.GetRemoteAddresses(u).FirstOrDefault()?.ToString() ?? string.Empty))];
2023-02-16 22:16:06 +01:00
2025-04-25 15:49:46 +00:00
if(bumpList.Length > 0)
2023-02-16 22:16:06 +01:00
Task.Run(async () => {
await Misuzu.BumpUsersOnlineAsync(bumpList);
}).Wait();
LastBump = DateTimeOffset.UtcNow;
}
} finally {
ctx.Chat.ContextAccess.Release();
2023-02-16 22:16:06 +01:00
}
}
}
}