61 lines
2 KiB
C#
61 lines
2 KiB
C#
using SharpChat.Misuzu;
|
|
using SharpChat.SockChat.PacketsS2C;
|
|
using System;
|
|
using System.Collections.Generic;
|
|
using System.Linq;
|
|
using System.Threading.Tasks;
|
|
|
|
namespace SharpChat.SockChat.PacketsC2S {
|
|
public class PingC2SPacketHandler : IC2SPacketHandler {
|
|
private readonly MisuzuClient Misuzu;
|
|
|
|
private readonly TimeSpan BumpInterval = TimeSpan.FromMinutes(1);
|
|
private DateTimeOffset LastBump = DateTimeOffset.MinValue;
|
|
|
|
public PingC2SPacketHandler(MisuzuClient msz) {
|
|
Misuzu = msz;
|
|
}
|
|
|
|
public bool IsMatch(C2SPacketHandlerContext ctx) {
|
|
return ctx.CheckPacketId("0");
|
|
}
|
|
|
|
public void Handle(C2SPacketHandlerContext ctx) {
|
|
string[] parts = ctx.SplitText(2);
|
|
|
|
if(!int.TryParse(parts.FirstOrDefault(), out int pTime))
|
|
return;
|
|
|
|
ctx.Connection.BumpPing();
|
|
ctx.Connection.Send(new PongS2CPacket());
|
|
|
|
ctx.Chat.ContextAccess.Wait();
|
|
try {
|
|
if(LastBump < DateTimeOffset.UtcNow - BumpInterval) {
|
|
List<(string, string)> bumpList = new();
|
|
|
|
foreach(UserInfo userInfo in ctx.Chat.Users.All) {
|
|
if(ctx.Chat.UserStatuses.GetStatus(userInfo) != UserStatus.Online)
|
|
continue;
|
|
|
|
string[] remoteAddrs = ctx.Chat.Connections.GetUserRemoteAddresses(userInfo);
|
|
if(remoteAddrs.Length < 1)
|
|
continue;
|
|
|
|
bumpList.Add((userInfo.UserId.ToString(), remoteAddrs[0]));
|
|
}
|
|
|
|
if(bumpList.Count > 0)
|
|
Task.Run(async () => {
|
|
await Misuzu.BumpUsersOnlineAsync(bumpList);
|
|
}).Wait();
|
|
|
|
LastBump = DateTimeOffset.UtcNow;
|
|
}
|
|
} finally {
|
|
ctx.Chat.ContextAccess.Release();
|
|
}
|
|
}
|
|
}
|
|
}
|