Mirror/PemukulPaku
1
0
Fork 0
mirror of https://github.com/rafi1212122/PemukulPaku synced 2025-12-14 23:34:34 +01:00
Code Issues Packages Projects Releases Wiki Activity

save to db and fix invalid avatardata on first login

Browse Source
This commit is contained in:
rafi1212122
2023-05-30 21:13:20 +07:00
parent 62abc6a784
commit 3778da626c
2 changed files with 23 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
GameServer/Handlers/GetPlayerTokenReqHandler.cs
View File

@@ -25,6 +25,7 @@ namespace PemukulPaku.GameServer.Handlers
if(session.Player.User.IsFirstLogin) if(session.Player.User.IsFirstLogin)
{ {
AvatarScheme avatar = Common.Database.Avatar.Create(101, session.Player.User.Uid, session.Player.Equipment); 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) if ((int)Global.config.VerboseLevel > 0)
session.c.Log($"Automatically created avatar with id: {avatar.AvatarId}"); session.c.Log($"Automatically created avatar with id: {avatar.AvatarId}");
} }

24
GameServer/Session.cs
View File

@@ -11,7 +11,8 @@ namespace PemukulPaku.GameServer
public readonly string Id; public readonly string Id;
public readonly TcpClient Client; public readonly TcpClient Client;
public readonly Logger c; public readonly Logger c;
public long LastKeepAlive = Global.GetUnixInSeconds(); public long LastClientKeepAlive = Global.GetUnixInSeconds();
public long LastServerKeepAlive = Global.GetUnixInSeconds();
public Player Player = default!; public Player Player = default!;
public Session(string id, TcpClient client) public Session(string id, TcpClient client)
@@ -20,6 +21,7 @@ namespace PemukulPaku.GameServer
Client = client; Client = client;
c = new Logger(Id); c = new Logger(Id);
Task.Run(ClientLoop); Task.Run(ClientLoop);
new Thread(KeepAliveLoop).Start();
} }
private void ClientLoop() 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"); c.Warn($"{Id} disconnected");
Server.GetInstance().Sessions.Remove(Id); Server.GetInstance().Sessions.Remove(Id);
Server.GetInstance().LogClients(); Server.GetInstance().LogClients();
@@ -83,7 +103,7 @@ namespace PemukulPaku.GameServer
public void ProcessPacket(Packet _packet) public void ProcessPacket(Packet _packet)
{ {
string PacketName = Enum.GetName(typeof(CmdId), _packet.CmdId)!; 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 try
{ {
CmdId cmdId = (CmdId)Enum.ToObject(typeof(CmdId), _packet.CmdId); CmdId cmdId = (CmdId)Enum.ToObject(typeof(CmdId), _packet.CmdId);