Added commands

dependency-reduced-pom.xml

@@ -3,7 +3,7 @@
   <modelVersion>4.0.0</modelVersion>
   <groupId>com.ishland.bukkit.AsyncKeepAlive</groupId>
   <artifactId>AsyncKeepAlive</artifactId>
-  <version>0.3</version>
+  <version>0.4-SNAPSHOT</version>
   <build>
     <plugins>
       <plugin>

src/main/java/com/ishland/bukkit/AsyncKeepAlive/launcher/LauncherForPacketListener.java

@@ -24,4 +24,8 @@ public void register(Plugin plugin, boolean debug, AsyncPacketThread packetThrea
 	object.register(plugin, debug, packetThread, placeHolder);
 	plugin.getLogger().info("Packet listener started.");
     }
+
+    public AsyncPacketListener getObject() {
+	return this.object;
+    }
 }

src/main/java/com/ishland/bukkit/AsyncKeepAlive/main/Launcher.java

@@ -14,7 +14,7 @@
 import org.bukkit.plugin.java.JavaPlugin;
 
 import com.comphenix.protocol.ProtocolLibrary;
-import com.ishland.bukkit.AsyncKeepAlive.detection.LagDetection;
+import com.ishland.bukkit.AsyncKeepAlive.command.CommandHandler;
 import com.ishland.bukkit.AsyncKeepAlive.launcher.LauncherForPacketListener;
 import com.ishland.bukkit.AsyncKeepAlive.launcher.LauncherForPacketThread;
 
@@ -30,7 +30,6 @@ public class Launcher extends JavaPlugin {
     private Metrics metrics;
     private LauncherForPacketThread packetThread;
     private LauncherForPacketListener packetListener;
-    private LagDetection lagDetection;
 
     @Override
     public void onEnable() {
@@ -56,8 +55,7 @@ public void onEnable() {
 
 	this.startSendingThread();
 	this.startPacketListener();
-	this.lagDetection = new LagDetection(this);
-
+	new CommandHandler(this);
 	getLogger().info("AsyncKeepAlive " + this.getDescription().getVersion() + " enabled in "
 		+ String.valueOf(System.currentTimeMillis() - startTime) + "ms");
     }
@@ -116,7 +114,6 @@ protected void startPacketListener() {
     @Override
     public void onDisable() {
 	long startTime = System.currentTimeMillis();
-	this.getLagDetection().stopDetection();
 	getLogger().info("Removing packet listener...");
 	ProtocolLibrary.getProtocolManager().removePacketListeners(this);
 	getLogger().info("Stopping packet thread...");
@@ -203,11 +200,4 @@ public void setPacketListener(LauncherForPacketListener packetListener) {
 	this.packetListener = packetListener;
     }
 
-    /**
-     * @return the lagDetection
-     */
-    public LagDetection getLagDetection() {
-	return lagDetection;
-    }
-
 }

src/main/java/com/ishland/bukkit/AsyncKeepAlive/thread/AsyncPacketListener.java

@@ -5,9 +5,23 @@
 import com.ishland.bukkit.AsyncKeepAlive.main.PlaceHolderMain;
 
 public class AsyncPacketListener {
+    private long count = (long) 0;
 
     public void register(Plugin plugin, boolean debug, AsyncPacketThread packetThread, PlaceHolderMain placeHolder) {
 
     }
 
+    /**
+     * @return the count
+     */
+    public long getCount() {
+	return count;
+    }
+
+    /**
+     * @param count the count to set
+     */
+    public void setCount(long count) {
+	this.count = count;
+    }
 }

src/main/java/com/ishland/bukkit/AsyncKeepAlive/thread/AsyncPacketListenerFor1_12toLatest.java

@@ -37,6 +37,7 @@ public void onPacketReceiving(PacketEvent e) {
 					if (placeHolder != null)
 					    placeHolder.latency.put(e.getPlayer().getName(), latency);
 					e.setCancelled(true);
+					setCount(getCount() + 1);
 					if (isDebug())
 					    plugin.getLogger().info("[Debug] Got plugin-sent keepalive "
 						    + String.valueOf(packetValue) + " from " + e.getPlayer().getName()

src/main/java/com/ishland/bukkit/AsyncKeepAlive/thread/AsyncPacketListenerFor1_8to1_11.java

@@ -36,6 +36,7 @@ public void onPacketReceiving(PacketEvent e) {
 						    + String.valueOf(packetValue) + " from " + e.getPlayer().getName()
 						    + " after " + latency.toString() + " ms");
 					e.setCancelled(true);
+					setCount(getCount() + 1);
 				    } else {
 					if (debug)
 					    plugin.getLogger().info("[Debug] Got server-sent keepalive "

src/main/java/com/ishland/bukkit/AsyncKeepAlive/thread/AsyncPacketThread.java

@@ -2,7 +2,6 @@
 
 import java.util.HashMap;
 import java.util.Iterator;
-import java.util.Map;
 import java.util.Map.Entry;
 import java.util.Timer;
 import java.util.TimerTask;
@@ -22,6 +21,7 @@ public class AsyncPacketThread {
     private Timer timer = new Timer();
     private TimerTask mainloop;
     protected Long index = (long) 0;
+    protected Long count = (long) 0;
 
     public void doDebug() {
 	debug = true;
@@ -87,23 +87,6 @@ public void run() {
 	getPlugin().getLogger().info("Packet thread started.");
 
 	timer.schedule(mainloop, 1000, this.frequency);
-	timer.schedule(new TimerTask() {
-
-	    @Override
-	    public void run() {
-		// TODO Auto-generated method stub
-		System.out.println("Nothing, just a new timer");
-		Map<Thread, StackTraceElement[]> map = Thread.getAllStackTraces();
-		Iterator<Entry<Thread, StackTraceElement[]>> entries = map.entrySet().iterator();
-		while (entries.hasNext()) {
-		    Entry<Thread, StackTraceElement[]> entry = entries.next();
-		    Thread thr = entry.getKey();
-		    System.out.println(
-			    "Thread " + thr.getName() + "(" + thr.getId() + ") Status: " + thr.getState().toString());
-		}
-	    }
-
-	}, 10000);
     }
 
     public Plugin getPlugin() {
@@ -155,4 +138,19 @@ public boolean isDebug() {
     public HashMap<Long, KeepAlivePacketGarbargeClean> getGarbargeCleanList() {
 	return garbargeCleanList;
     }
+
+    /**
+     * @return the index
+     */
+    public long getIndex() {
+	return index;
+    }
+
+    /**
+     * @return the index
+     */
+    public long getCount() {
+	return count;
+    }
+
 }

src/main/java/com/ishland/bukkit/AsyncKeepAlive/thread/AsyncPacketThreadFor1_12toLatest.java

@@ -2,6 +2,8 @@
 
 import java.util.TimerTask;
 
+import org.bukkit.Bukkit;
+
 import com.ishland.bukkit.AsyncKeepAlive.packet.KeepAlivePacket;
 import com.ishland.bukkit.AsyncKeepAlive.packet.KeepAlivePacketFor1_12toLatest;
 import com.ishland.bukkit.AsyncKeepAlive.packet.KeepAlivePacketGarbargeClean;
@@ -15,6 +17,7 @@ public void run() {
 		if (!getPlugin().getServer().getOnlinePlayers().isEmpty())
 		    try {
 			KeepAlivePacket packet = new KeepAlivePacketFor1_12toLatest(getPlugin());
+			count += Bukkit.getOnlinePlayers().size();
 			packet.boardcast();
 			getPing().put(packet.getBody(), packet);
 			KeepAlivePacketGarbargeClean gc = new KeepAlivePacketGarbargeClean(getPing(), packet.getBody(),

src/main/java/com/ishland/bukkit/AsyncKeepAlive/thread/AsyncPacketThreadFor1_8to1_11.java

@@ -2,6 +2,8 @@
 
 import java.util.TimerTask;
 
+import org.bukkit.Bukkit;
+
 import com.ishland.bukkit.AsyncKeepAlive.packet.KeepAlivePacket;
 import com.ishland.bukkit.AsyncKeepAlive.packet.KeepAlivePacketFor1_7to1_11;
 import com.ishland.bukkit.AsyncKeepAlive.packet.KeepAlivePacketGarbargeClean;
@@ -15,6 +17,7 @@ public void run() {
 		if (!getPlugin().getServer().getOnlinePlayers().isEmpty())
 		    try {
 			KeepAlivePacket packet = new KeepAlivePacketFor1_7to1_11(getPlugin());
+			count += Bukkit.getOnlinePlayers().size();
 			packet.boardcast();
 			getPing().put(packet.getBody(), packet);
 			KeepAlivePacketGarbargeClean gc = new KeepAlivePacketGarbargeClean(getPing(), packet.getBody(),

src/main/resources/plugin.yml

@@ -5,3 +5,8 @@ author: ishland
 description: AsyncKeepAlive is a plugin that keep the players' connections alive
 depend: [ProtocolLib]
 softdepend: [PlaceholderAPI]
+commands:
+  asynckeepalive:
+    description: "The main command of AsyncKeepAlive"
+    usage: "[Error] Something went wrong"
+    aliases: [ak]