aion-server 4.8

package com.aionemu.gameserver.services.antihack;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import com.aionemu.gameserver.configs.main.SecurityConfig;
import com.aionemu.gameserver.controllers.movement.MovementMask;
import com.aionemu.gameserver.controllers.movement.PlayerMoveController;
import com.aionemu.gameserver.model.gameobjects.player.Player;
import com.aionemu.gameserver.network.aion.AionConnection;
import com.aionemu.gameserver.network.aion.serverpackets.SM_FORCED_MOVE;
import com.aionemu.gameserver.network.aion.serverpackets.SM_MOVE;
import com.aionemu.gameserver.network.aion.serverpackets.SM_QUIT_RESPONSE;
import com.aionemu.gameserver.skillengine.effect.AbnormalState;
import com.aionemu.gameserver.utils.PacketSendUtility;
import com.aionemu.gameserver.utils.PositionUtil;
import com.aionemu.gameserver.utils.audit.AuditLogger;
import com.aionemu.gameserver.world.WorldPosition;

/**
 * @author Source
 */
public class AntiHackService {

	private static Logger log = LoggerFactory.getLogger(AntiHackService.class);

	public static boolean canMove(Player player, float x, float y, float z, byte type) {
		PlayerMoveController m = player.getMoveController();
		WorldPosition lastPositionFromClient = m.getLastPositionFromClient();
		if (lastPositionFromClient == null || lastPositionFromClient.getMapId() != player.getWorldId())
			return true;

		if (SecurityConfig.ABNORMAL) {
			if (!player.canPerformMove() && !player.getEffectController().isAbnormalSet(AbnormalState.PULLED)
				&& (type & MovementMask.GLIDE) != MovementMask.GLIDE) {
				if (player.abnormalHackCounter > SecurityConfig.ABNORMAL_COUNTER) {
					return punish(player, false, "possibly performed illegal move action (Anti-Abnormal Hack)");
				} else
					player.abnormalHackCounter++;
			} else
				player.abnormalHackCounter = 0;
		}

		float speed = player.getGameStats().getMovementSpeedFloat();
		if (SecurityConfig.SPEEDHACK) {
			if (type != 0) {
				if ((type & MovementMask.POSITION) == MovementMask.POSITION) {
					double vector2D = PositionUtil.getDistance(x, y, m.getTargetX2(), m.getTargetY2());

					if (vector2D != 0) {
						if ((type & MovementMask.MANUAL) == MovementMask.MANUAL && vector2D > 5 && vector2D > speed + 0.001)
							player.speedHackCounter++;
						else if (vector2D > 37.5 && vector2D > 1.5 * speed * speed + 0.001)
							player.speedHackCounter++;
						else if (player.speedHackCounter > 0)
							player.speedHackCounter--;

						if (player.speedHackCounter > SecurityConfig.SPEEDHACK_COUNTER) {
							return punish(player, false, "possibly used speed hack - SHC:" + player.speedHackCounter + " S:" + speed + " V:"
								+ Math.rint(1000.0 * vector2D) / 1000.0 + " type:" + type);
						}
					}
				} else if ((type & MovementMask.ABSOLUTE) == MovementMask.ABSOLUTE && (type & MovementMask.GLIDE) != MovementMask.GLIDE) {
					double vector = PositionUtil.getDistance(x, y, lastPositionFromClient.getX(), lastPositionFromClient.getY());
					long timeDiff = System.currentTimeMillis() - m.getLastPositionFromClientMillis();

					if ((type & MovementMask.POSITION) == MovementMask.POSITION) {
						boolean isMoveToTarget = false;
						if (player.getTarget() != null && player.getTarget() != player) {
							double distDiff = PositionUtil.getDistance(player.getTarget().getX(), player.getTarget().getY(), m.getTargetX2(), m.getTargetY2());
							isMoveToTarget = distDiff <= 5;
						}

						if (timeDiff > 1000 && player.speedHackCounter > 0)
							player.speedHackCounter--;

						if (vector > timeDiff * (speed + 0.85) * 0.001)
							player.speedHackCounter++;
						else if (isMoveToTarget && player.speedHackCounter > 0)
							player.speedHackCounter--;
					} else if (vector > timeDiff * (speed + 0.25) * 0.001)
						player.speedHackCounter++;
					else if (player.speedHackCounter > 0)
						player.speedHackCounter--;

					if (SecurityConfig.PUNISH > 0 && player.speedHackCounter > SecurityConfig.SPEEDHACK_COUNTER + 5) {
						return punish(player, false,
							"possibly used speed hack - SHC:" + player.speedHackCounter + " SMS:" + Math.rint(100.0 * (timeDiff * (speed + 0.25) * 0.001)) / 100.0
								+ " TDF:" + timeDiff + " VTD:" + Math.rint(1000.0 * (timeDiff * (speed + 0.85) * 0.001)) / 1000.0 + " VS:"
								+ Math.rint(100.0 * vector) / 100.0 + " type:" + type);
					} else if (player.speedHackCounter > SecurityConfig.SPEEDHACK_COUNTER) {
						moveBack(player, false);
						return false;
					}
				}
			} else {
				double vector = PositionUtil.getDistance(x, y, lastPositionFromClient.getX(), lastPositionFromClient.getY());
				long timeDiff = System.currentTimeMillis() - m.getLastPositionFromClientMillis();

				if (m.getLastMovementMask() == 0 && vector > timeDiff * speed * 0.00075)
					player.speedHackCounter++;

				if (SecurityConfig.PUNISH > 0 && player.speedHackCounter > SecurityConfig.SPEEDHACK_COUNTER + 5) {
					return punish(player, false, "possibly used speed hack - SHC:" + player.speedHackCounter + " TD:" + Math.rint(1000.0 * timeDiff) / 1000.0
						+ " VTD:" + Math.rint(1000.0 * (timeDiff * speed * 0.00075)) / 1000.0 + " VS:" + Math.rint(100.0 * vector) / 100.0 + " type:" + type);
				} else if (player.speedHackCounter > SecurityConfig.SPEEDHACK_COUNTER + 2) {
					moveBack(player, false);
					return false;
				}
			}
		}

		if (SecurityConfig.TELEPORTATION) {
			double delta = PositionUtil.getDistance(x, y, player.getX(), player.getY()) / speed;
			if (speed > 5.0 && delta > 5.0 && (type & MovementMask.GLIDE) != MovementMask.GLIDE) {
				return punish(player, true, "possibly used teleport hack - S:" + speed + " D:" + Math.rint(1000.0 * delta) / 1000.0 + " type:" + type);
			}
		}

		return true;
	}

	private static boolean punish(Player player, boolean normalMovePacket, String message) {
		AuditLogger.log(player, message);
		switch (SecurityConfig.PUNISH) {
			case 1:
				moveBack(player, normalMovePacket);
				return false;
			case 2:
				moveBack(player, normalMovePacket);
				if (player.speedHackCounter > SecurityConfig.SPEEDHACK_COUNTER * 3 || player.abnormalHackCounter > SecurityConfig.ABNORMAL_COUNTER * 3)
					player.getClientConnection().close(new SM_QUIT_RESPONSE());
				return false;
			case 3:
				player.getClientConnection().close(new SM_QUIT_RESPONSE());
				return false;
			default:
				return true;
		}
	}

	private static void moveBack(Player player, boolean normalMovePacket) {
		if (normalMovePacket)
			PacketSendUtility.broadcastPacketAndReceive(player, new SM_MOVE(player));
		else {
			WorldPosition lastPos = player.getMoveController().getLastPositionFromClient();
			PacketSendUtility.broadcastPacketAndReceive(player,
				new SM_FORCED_MOVE(player, player.getObjectId(), lastPos.getX(), lastPos.getY(), lastPos.getZ()));
		}
		player.getMoveController().updateLastMove();
		player.speedHackCounter = 0;
	}

	public static void checkAionBin(int size, AionConnection con) {
		int legitSize = 212; // 212 after login, exactly 30 minutes later: 224, right after that: 1128 o.O
		if (SecurityConfig.AION_BIN_CHECK) {
			if (size != legitSize) {
				log.warn("Detected modified aion.bin for account ID " + con.getAccount().getId());
				con.close(new SM_QUIT_RESPONSE());
			}
		}
		// con.sendPacket(new SM_GAMEGUARD(size)); // not sent on GF servers currently
	}
}