From 3778da626ca8aa557b97853c76fea8ca4573120d Mon Sep 17 00:00:00 2001
From: rafi1212122 <rafi1212122@outlook.com>
Date: Tue, 30 May 2023 21:13:20 +0700
Subject: [PATCH] save to db and fix invalid avatardata on first login

---
 .../Handlers/GetPlayerTokenReqHandler.cs      |  1 +
 GameServer/Session.cs                         | 24 +++++++++++++++++--
 2 files changed, 23 insertions(+), 2 deletions(-)

diff --git a/GameServer/Handlers/GetPlayerTokenReqHandler.cs b/GameServer/Handlers/GetPlayerTokenReqHandler.cs
index 673e595..7136cd9 100644
--- a/GameServer/Handlers/GetPlayerTokenReqHandler.cs
+++ b/GameServer/Handlers/GetPlayerTokenReqHandler.cs
@@ -25,6 +25,7 @@ namespace PemukulPaku.GameServer.Handlers
                 if(session.Player.User.IsFirstLogin)
                 {
                     AvatarScheme avatar = Common.Database.Avatar.Create(101, session.Player.User.Uid, session.Player.Equipment);
+                    session.Player.AvatarList = session.Player.AvatarList.Append(avatar).ToArray();
                     if ((int)Global.config.VerboseLevel > 0)
                         session.c.Log($"Automatically created avatar with id: {avatar.AvatarId}");
                 }
diff --git a/GameServer/Session.cs b/GameServer/Session.cs
index 04a7ae2..5b5d9c8 100644
--- a/GameServer/Session.cs
+++ b/GameServer/Session.cs
@@ -11,7 +11,8 @@ namespace PemukulPaku.GameServer
         public readonly string Id;
         public readonly TcpClient Client;
         public readonly Logger c;
-        public long LastKeepAlive = Global.GetUnixInSeconds();
+        public long LastClientKeepAlive = Global.GetUnixInSeconds();
+        public long LastServerKeepAlive = Global.GetUnixInSeconds();
         public Player Player = default!;
 
         public Session(string id, TcpClient client)
@@ -20,6 +21,7 @@ namespace PemukulPaku.GameServer
             Client = client;
             c = new Logger(Id);
             Task.Run(ClientLoop);
+            new Thread(KeepAliveLoop).Start();
         }
 
         private void ClientLoop()
@@ -74,7 +76,25 @@ namespace PemukulPaku.GameServer
                     }
                 }
             }
+        }
 
+        public void KeepAliveLoop()
+        {
+            while(Client.Connected)
+            {
+                try
+                {
+                    Send(Packet.FromProto(new KeepAliveNotify() { }, CmdId.KeepAliveNotify));
+                }
+                catch
+                {
+                    break;
+                }
+                Thread.Sleep(3000);
+            }
+
+            Player.SaveAll();
+            c.Debug("Player data saved to database");
             c.Warn($"{Id} disconnected");
             Server.GetInstance().Sessions.Remove(Id);
             Server.GetInstance().LogClients();
@@ -83,7 +103,7 @@ namespace PemukulPaku.GameServer
         public void ProcessPacket(Packet _packet)
         {
             string PacketName = Enum.GetName(typeof(CmdId), _packet.CmdId)!;
-            if(PacketName == "KeepAliveNotify") { LastKeepAlive = Global.GetUnixInSeconds(); c.Log(PacketName); return; }
+            if(PacketName == "KeepAliveNotify") { LastClientKeepAlive = Global.GetUnixInSeconds(); c.Log(PacketName); return; }
             try
             {
                 CmdId cmdId = (CmdId)Enum.ToObject(typeof(CmdId), _packet.CmdId);