using Google.Protobuf; using Google.Protobuf.WellKnownTypes; using ServerCore; using ServerBase; using ServerCommon; using ServerCommon.BusinessLogDomain; using MetaAssets; namespace GameServer.PacketHandler; [PacketHandler(typeof(ClientToGameReq), typeof(ClientToGameReq.Types.C2GS_REQ_PING), typeof(PickPacketHandler), typeof(GameLoginListener))] public class PickPacketHandler : PacketRecvHandler { public override async Task onProcessPacket(ISession entityWithSession, IMessage recvMessage) { var result = new Result(); var err_msg = string.Empty; var entity_player = entityWithSession as Player; NullReferenceCheckHelper.throwIfNull(entity_player, () => $"entity_player is null !!!"); var server_logic = GameServerApp.getServerLogic(); var game_msg = recvMessage as ClientToGame; if (game_msg == null) { err_msg = $"Failed to cast ClientToGame !!! : {nameof(ClientToGame.Request.ChangeStateReq)}"; result.setFail(ServerErrorCode.ClassTypeCastIsNull, err_msg); Log.getLogger().error(result.toBasicString()); send_S2C_ACK_PING(entity_player, result, 0); return result; } var request = game_msg.Request.ReqPing; var idx = request.Idx; send_S2C_ACK_PING(entity_player, result, idx); await Task.CompletedTask; return result; } public static bool send_S2C_ACK_PING(Player player, Result result, int idx) { var ack_packet = new ClientToGame(); ack_packet.Response = new ClientToGameRes(); ack_packet.Response.ErrorCode = result.ErrorCode; ack_packet.Response.AckPing = new(); ack_packet.Response.AckPing.Idx = idx; if (false == GameServerApp.getServerLogic().onSendPacket(player, ack_packet)) { return false; } return true; } }