package com.aionemu.gameserver.services.ban;
import java.util.Map;
import java.util.concurrent.ConcurrentHashMap;
import com.aionemu.gameserver.model.TaskId;
import com.aionemu.gameserver.model.gameobjects.player.Player;
import com.aionemu.gameserver.network.aion.serverpackets.SM_SYSTEM_MESSAGE;
import com.aionemu.gameserver.network.chatserver.ChatServer;
import com.aionemu.gameserver.utils.PacketSendUtility;
import com.aionemu.gameserver.utils.ThreadPoolManager;
/**
* @author ViAl, Neon
*/
public class ChatBanService {
/**
* List for player chat bans <player, expiration time>. Resets on server restart.
*/
private static final Map<Integer, Long> chatBans = new ConcurrentHashMap<>();
/**
* Bans a player from all chats.
*/
public static void banPlayer(Player player, long durationMillis) {
ChatServer.getInstance().sendPlayerGagPacket(player.getObjectId(), durationMillis);
chatBans.put(player.getObjectId(), System.currentTimeMillis() + durationMillis);
registerUnban(player, durationMillis);
}
public static void unbanPlayer(Player player) {
player.getController().cancelTask(TaskId.GAG);
ChatServer.getInstance().sendPlayerGagPacket(player.getObjectId(), 0);
if (chatBans.remove(player.getObjectId()) != null && player.isOnline())
PacketSendUtility.sendPacket(player, SM_SYSTEM_MESSAGE.STR_CAN_CHAT_NOW());
}
private static void registerUnban(Player player, long delay) {
player.getController().addTask(TaskId.GAG, ThreadPoolManager.getInstance().schedule(new Runnable() {
@Override
public void run() {
unbanPlayer(player);
}
}, delay));
}
public static boolean isBanned(Player player) {
return getBanMinutes(player) > 0;
}
/**
* Checks time left for the players ban.<br>
* If ban is over, this method automatically unbans the player.<br>
* If not and unban task is missing (e.g. due to logout), an unban task will be started.
*
* @return The remaining ban time in minutes. Only returns 0 if ban time is really over.
*/
public static int getBanMinutes(Player player) {
Long expireTime = chatBans.get(player.getObjectId());
if (expireTime == null)
return 0;
long millisLeft = expireTime - System.currentTimeMillis();
if (millisLeft <= 0) {
unbanPlayer(player);
return 0;
}
if (!player.getController().hasTask(TaskId.GAG))
registerUnban(player, millisLeft);
return (int) Math.max(0, Math.ceil(millisLeft / 60000f));
}
}