Sistema Anty-AFK

[Swarlog]

Código [Seleccionar] Expandir

### Eclipse Workspace Patch 1.0
#P l2jalpha_gameserver_mxc
Index: java/net/l2jalpha/gameserver/network/clientpackets/EnterWorld.java
===================================================================
--- java/net/l2jalpha/gameserver/network/clientpackets/EnterWorld.java (revision 31)
+++ java/net/l2jalpha/gameserver/network/clientpackets/EnterWorld.java (working copy)
@@ -27,6 +27,7 @@
 import net.l2jalpha.gameserver.Announcements;
 import net.l2jalpha.gameserver.GmListTable;
 import net.l2jalpha.gameserver.TaskPriority;
+import net.l2jalpha.gameserver.ThreadPoolManager;
 import net.l2jalpha.gameserver.cache.HtmCache;
 import net.l2jalpha.gameserver.communitybbs.Manager.RegionBBSManager;
 import net.l2jalpha.gameserver.datatables.sql.AdminCommandAccessRights;
@@ -45,6 +46,7 @@
 import net.l2jalpha.gameserver.model.base.PlayerClass;
 import net.l2jalpha.gameserver.model.entity.ClanHall;
 import net.l2jalpha.gameserver.model.entity.Hero;
+import net.l2jalpha.gameserver.model.entity.LeaveBuster;
 import net.l2jalpha.gameserver.model.entity.Siege;
 import net.l2jalpha.gameserver.model.olympiad.Olympiad;
 import net.l2jalpha.gameserver.model.quest.Quest;
@@ -281,6 +283,8 @@
 
  RegionBBSManager.getInstance().changeCommunityBoard();
 
+ activeChar.setLastActionMillis(System.currentTimeMillis());
+ LeaveBuster._players.put(activeChar, ThreadPoolManager.getInstance().scheduleGeneralAtFixedRate(new LeaveBuster(activeChar), 5000, 5000));
  }
 
  /**
Index: java/net/l2jalpha/gameserver/network/clientpackets/Logout.java
===================================================================
--- java/net/l2jalpha/gameserver/network/clientpackets/Logout.java (revision 31)
+++ java/net/l2jalpha/gameserver/network/clientpackets/Logout.java (working copy)
@@ -27,6 +27,7 @@
 import net.l2jalpha.gameserver.datatables.xml.SkillTable;
 import net.l2jalpha.gameserver.model.L2World;
 import net.l2jalpha.gameserver.model.actor.instance.L2PcInstance;
+import net.l2jalpha.gameserver.model.entity.LeaveBuster;
 import net.l2jalpha.gameserver.model.olympiad.OlympiadManager;
 import net.l2jalpha.gameserver.network.SystemMessageId;
 import net.l2jalpha.gameserver.network.serverpackets.ActionFailed;
@@ -56,6 +57,8 @@
 
  if (player == null)
  return;
+
+ player.setLastActionMillis(System.currentTimeMillis());
 
  player.getInventory().updateDatabase();
 
@@ -79,6 +82,9 @@
  {
  player.removeSkill(SkillTable.getInstance().getInfo(4289, 1));
  }
+
+ LeaveBuster._players.get(player).cancel(true);;
+        LeaveBuster._players.remove(player);
 
  RegionBBSManager.getInstance().changeCommunityBoard();
 
Index: java/net/l2jalpha/gameserver/network/clientpackets/Say2.java
===================================================================
--- java/net/l2jalpha/gameserver/network/clientpackets/Say2.java (revision 31)
+++ java/net/l2jalpha/gameserver/network/clientpackets/Say2.java (working copy)
@@ -113,6 +113,8 @@
  return;
  }
 
+ activeChar.setLastActionMillis(System.currentTimeMillis());
+
  if (_text.length() >= 100)
  {
  _log.warning("Say2: Max input exceeded.");
Index: java/net/l2jalpha/gameserver/model/actor/instance/L2PcInstance.java
===================================================================
--- java/net/l2jalpha/gameserver/model/actor/instance/L2PcInstance.java (revision 31)
+++ java/net/l2jalpha/gameserver/model/actor/instance/L2PcInstance.java (working copy)
@@ -196,6 +196,19 @@
  */
 public final class L2PcInstance extends L2Playable
 {
+ // LeaveBuster
+ private long _lastAction = 0;
+
+ public long getLastActionMillis()
+ {
+ return _lastAction;
+ }
+
+ public void setLastActionMillis(long val)
+ {
+ _lastAction = val;
+ }
+
  private static final String RESTORE_SKILLS_FOR_CHAR = "SELECT skill_id,skill_level FROM character_skills WHERE char_obj_id=? AND class_index=?";
  private static final String ADD_NEW_SKILL = "INSERT INTO character_skills (char_obj_id,skill_id,skill_level,skill_name,class_index) VALUES (?,?,?,?,?)";
  private static final String UPDATE_CHARACTER_SKILL_LEVEL = "UPDATE character_skills SET skill_level=? WHERE skill_id=? AND char_obj_id=? AND class_index=?";
Index: java/net/l2jalpha/gameserver/model/entity/LeaveBuster.java
===================================================================
--- java/net/l2jalpha/gameserver/model/entity/LeaveBuster.java (revision 0)
+++ java/net/l2jalpha/gameserver/model/entity/LeaveBuster.java (working copy)
@@ -0,0 +1,65 @@
+/* This program is free software; you can redistribute it and/or modify
+ * it under the terms of the GNU General Public License as published by
+ * the Free Software Foundation; either version 2, or (at your option)
+ * any later version.
+ *
+ * This program is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+ * GNU General Public License for more details.
+ *
+ * You should have received a copy of the GNU General Public License
+ * along with this program; if not, write to the Free Software
+ * Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA
+ * 02111-1307, USA.
+ *
+ * http://www.gnu.org/copyleft/gpl.html
+ */
+package net.l2jalpha.gameserver.model.entity;
+
+import java.util.concurrent.ScheduledFuture;
+import java.util.logging.Logger;
+
+import javolution.util.FastMap;
+import net.l2jalpha.gameserver.model.actor.instance.L2PcInstance;
+
+/**
+ *
+ * @author  Anarchy
+ */
+public class LeaveBuster implements Runnable
+{
+ public static FastMap<L2PcInstance, ScheduledFuture<?>> _players = new FastMap<>();
+
+ private static final Logger _log = Logger.getLogger(LeaveBuster.class.getName());
+
+ private L2PcInstance _p = null;
+
+ public LeaveBuster(L2PcInstance p)
+ {
+ _p = p;
+ }
+
+ @Override
+ public void run()
+ {
+ if (_p == null || !_p.isOnline())
+ {
+ if (_p != null)
+ {
+ _players.get(_p).cancel(true);
+ _players.remove(_p);
+ }
+
+ return;
+ }
+
+ if ((System.currentTimeMillis()-_p.getLastActionMillis())/1000/60 >= 30)
+ {
+ _log.info("Leave Buster: "+_p.getName()+" was kicked out of game.");
+ _players.get(_p).cancel(true);
+ _players.remove(_p);
+ _p.logout();
+ }
+ }
+}
Index: java/net/l2jalpha/gameserver/network/clientpackets/RequestRestart.java
===================================================================
--- java/net/l2jalpha/gameserver/network/clientpackets/RequestRestart.java (revision 31)
+++ java/net/l2jalpha/gameserver/network/clientpackets/RequestRestart.java (working copy)
@@ -22,6 +22,7 @@
 import net.l2jalpha.gameserver.communitybbs.Manager.RegionBBSManager;
 import net.l2jalpha.gameserver.datatables.xml.SkillTable;
 import net.l2jalpha.gameserver.model.actor.instance.L2PcInstance;
+import net.l2jalpha.gameserver.model.entity.LeaveBuster;
 import net.l2jalpha.gameserver.model.olympiad.OlympiadManager;
 import net.l2jalpha.gameserver.network.L2GameClient;
 import net.l2jalpha.gameserver.network.SystemMessageId;
@@ -56,6 +57,8 @@
             _log.warning("[RequestRestart] activeChar null!?");
             return;
         }
+       
+        player.setLastActionMillis(System.currentTimeMillis());
 
         if (player.isInOlympiadMode() || OlympiadManager.getInstance().isRegistered(player))
         {
@@ -92,6 +95,9 @@
         {
          player.removeSkill(SkillTable.getInstance().getInfo(4289, 1));
         }
+       
+        LeaveBuster._players.get(player).cancel(true);;
+        LeaveBuster._players.remove(player);
 
         L2GameClient client = getClient();
 
Index: java/net/l2jalpha/gameserver/network/clientpackets/MoveBackwardToLocation.java
===================================================================
--- java/net/l2jalpha/gameserver/network/clientpackets/MoveBackwardToLocation.java (revision 31)
+++ java/net/l2jalpha/gameserver/network/clientpackets/MoveBackwardToLocation.java (working copy)
@@ -91,6 +91,8 @@
  L2PcInstance activeChar = getClient().getActiveChar();
  if (activeChar == null)
  return;
+
+ activeChar.setLastActionMillis(System.currentTimeMillis());
 
  _curX = activeChar.getX();
         _curY = activeChar.getY();
Index: java/net/l2jalpha/gameserver/network/clientpackets/RequestRestartPoint.java
===================================================================
--- java/net/l2jalpha/gameserver/network/clientpackets/RequestRestartPoint.java (revision 31)
+++ java/net/l2jalpha/gameserver/network/clientpackets/RequestRestartPoint.java (working copy)
@@ -160,6 +160,8 @@
 
  if (activeChar == null)
  return;
+
+ activeChar.setLastActionMillis(System.currentTimeMillis());
 
  //SystemMessage sm2 = new SystemMessage(SystemMessage.S1_S2);
  //sm2.addString("type:"+requestedPointType);
Index: java/net/l2jalpha/gameserver/network/clientpackets/RequestSocialAction.java
===================================================================
--- java/net/l2jalpha/gameserver/network/clientpackets/RequestSocialAction.java (revision 31)
+++ java/net/l2jalpha/gameserver/network/clientpackets/RequestSocialAction.java (working copy)
@@ -49,6 +49,8 @@
  L2PcInstance activeChar = getClient().getActiveChar();
  if (activeChar == null)
      return;
+
+ activeChar.setLastActionMillis(System.currentTimeMillis());
 
         // check if its the actionId is allowed
         if (_actionId < 2 || _actionId > 13)
Index: java/net/l2jalpha/gameserver/network/clientpackets/TradeRequest.java
===================================================================
--- java/net/l2jalpha/gameserver/network/clientpackets/TradeRequest.java (revision 31)
+++ java/net/l2jalpha/gameserver/network/clientpackets/TradeRequest.java (working copy)
@@ -52,6 +52,8 @@
 
         if (player == null)
          return;
+       
+        player.setLastActionMillis(System.currentTimeMillis());
 
         if (!player.getAccessLevel().allowTransaction())
         {
Index: java/net/l2jalpha/gameserver/network/clientpackets/UseItem.java
===================================================================
--- java/net/l2jalpha/gameserver/network/clientpackets/UseItem.java (revision 31)
+++ java/net/l2jalpha/gameserver/network/clientpackets/UseItem.java (working copy)
@@ -63,6 +63,8 @@
 
  if (activeChar == null)
             return;
+
+ activeChar.setLastActionMillis(System.currentTimeMillis());
 
  // Flood protect UseItem
  if (!getClient().getFloodProtectors().getUseItem().tryPerformAction("use item"))