using SharpChat.Misuzu;
using SharpChat.S2CPackets;

namespace SharpChat.C2SPacketHandlers {
    public class PingC2SPacketHandler(MisuzuClient msz) : C2SPacketHandler {
        private readonly MisuzuClient Misuzu = msz ?? throw new ArgumentNullException(nameof(msz));

        private readonly TimeSpan BumpInterval = TimeSpan.FromMinutes(1);
        private DateTimeOffset LastBump = DateTimeOffset.MinValue;

        public bool IsMatch(ChatPacketHandlerContext ctx) {
            return ctx.CheckPacketId("0");
        }

        public void Handle(ChatPacketHandlerContext 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) {
                    (string, string)[] bumpList = [.. ctx.Chat.Users
                        .Where(u => u.Status == ChatUserStatus.Online && ctx.Chat.Connections.Any(c => c.User == u))
                        .Select(u => (u.UserId.ToString(), ctx.Chat.GetRemoteAddresses(u).FirstOrDefault()?.ToString() ?? string.Empty))];

                    if(bumpList.Length > 0)
                        Task.Run(async () => {
                            await Misuzu.BumpUsersOnlineAsync(bumpList);
                        }).Wait();

                    LastBump = DateTimeOffset.UtcNow;
                }
            } finally {
                ctx.Chat.ContextAccess.Release();
            }
        }
    }
}