Compare commits

...
29 Commits
Author SHA1 Message Date
Retrooper 636e246c70 attempt to fix error 2020-07-20 16:09:18 +08:00
Retrooper 0d5c7b5250 uninject exception error handled 2020-07-20 15:39:39 +08:00
Retrooper 1b5f066eb0 small error fix, this build will be 1.5.4.1 release 2020-07-20 14:33:18 +08:00
Retrooper ffe224c4bf 1.5.4.1 release
* PlayerUninjectEvent#isSync now documented
* Shutdown bugs fixed(unending shutdown)
* Code cleanup & Imports optimized
2020-07-20 14:20:45 +08:00
Retrooper 792fe16124 1.5.4 release, shutdown bug fix attempt 2020-07-19 19:23:31 +08:00
terrarier2111 3c92108c44 Replaced loop 2020-07-16 13:43:29 +02:00
retrooper 3b71327245 Merge pull request #17 from rbuh/patch-2
Someone forgot something -_-
2020-07-16 08:34:31 +02:00
rbuh 6d70978285 Someone forgot something -_-
ur welcome bud!
2020-07-15 21:20:10 -04:00
terrarier2111 953ad680ee Update ClientVersion.java 2020-07-15 17:42:23 +02:00
terrarier2111 765f2fad92 Prepared lookup 2020-07-15 17:23:16 +02:00
terrarier2111 bede734af7 Update ClientVersion.java 2020-07-15 17:22:10 +02:00
retrooper 31853376d6 Merge pull request #14 from terrarier2111/patch-7
Added missing return
2020-07-15 17:14:19 +02:00
terrarier2111 3a100ce325 Added missing return 2020-07-15 16:54:05 +02:00
retrooper bbb2ef0668 Merge pull request #13 from terrarier2111/patch-6
Fixed stupid bug
2020-07-15 16:33:25 +02:00
terrarier2111 9f697673c0 Fixed stupid bug 2020-07-15 16:28:14 +02:00
retrooper b1deb8629b Merge pull request #12 from terrarier2111/patch-5
Finally added AutoResolveClientProtocolVersion
2020-07-15 16:24:41 +02:00
terrarier2111 70d0400c67 Finally added AutoResolveClientProtocolVersion 2020-07-15 16:19:54 +02:00
retrooper b0c08ce813 Merge pull request #11 from terrarier2111/patch-4
Added autoResolveClientProtocolVersion setting
2020-07-15 16:14:50 +02:00
retrooper 3af91fcac9 Merge pull request #10 from terrarier2111/patch-3
Added Server Protocol Version Mapping
2020-07-15 16:13:40 +02:00
terrarier2111 d1c2fe4169 Update Settings.java 2020-07-15 16:11:34 +02:00
terrarier2111 1900d37c94 Added Server Protocol Version Mapping 2020-07-15 15:37:35 +02:00
retrooper 5d17a2a613 Merge pull request #8 from rbuh/patch-1
Bro wheres 1.7 my guy
2020-07-15 15:21:16 +02:00
rbuh 4a93603614 Bro wheres 1.7 my guy
how u forget the most import part!?!?!?!
2020-07-15 08:33:34 -04:00
retrooper 9a1a59f15f Merge pull request #7 from terrarier2111/patch-1
Update ClientVersion.java
2020-07-15 14:22:54 +02:00
terrarier2111 0c350a3f27 Update ClientVersion.java
Changed to correct protocolversion
2020-07-15 13:17:16 +02:00
Retrooper c3d75f1e8d 1.5.3 Stable release!!!! 2020-07-12 05:08:47 +08:00
Retrooper b847e53221 1.5.2 pre release 2020-07-12 02:46:52 +08:00
Retrooper c9570b0ad7 1.5.1 pre release 2020-07-11 18:52:07 +08:00
Retrooper ee5caaa81c Started on player infondo not use 2020-07-08 20:21:42 +08:00
29 changed files with 527 additions and 225 deletions

No files matched your search

+29 -27
View File
@@ -6,7 +6,7 @@
<groupId>io.github.retrooper</groupId>
<artifactId>packetevents</artifactId>
<version>1.5</version>
<version>1.5.4.1</version>
<packaging>jar</packaging>
<name>packetevents</name>
@@ -15,35 +15,28 @@
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
</properties>
<!-- You can build the project with this: "mvn clean compile assembly:single" -->
<build>
<defaultGoal>clean package</defaultGoal>
<plugins>
<plugin>
<artifactId>maven-compiler-plugin</artifactId>
<version>3.7.0</version>
<artifactId>maven-assembly-plugin</artifactId>
<configuration>
<source>1.8</source>
<target>1.8</target>
<descriptorRefs>
<descriptorRef>jar-with-dependencies</descriptorRef>
</descriptorRefs>
</configuration>
</plugin>
<plugin>
<groupId>org.apache.maven.plugins</groupId>
<artifactId>maven-compiler-plugin</artifactId>
<version>3.7.0</version>
<configuration>
<source>${java.version}</source>
<target>${java.version}</target>
<source>8</source>
<target>8</target>
</configuration>
</plugin>
</plugins>
<resources>
<resource>
<directory>src/main/resources</directory>
<filtering>true</filtering>
</resource>
</resources>
</build>
<repositories>
<repository>
<id>spigot-repo</id>
@@ -69,19 +62,21 @@
<dependencies>
<dependency>
<groupId>org.github.spigot</groupId>
<artifactId>1.7.10</artifactId>
<version>1.7.10</version>
<scope>provided</scope>
</dependency>
<dependency>
<groupId>org.github.spigot</groupId>
<artifactId>1.8.8</artifactId>
<version>1.8.8</version>
<scope>provided</scope>
</dependency>
<groupId>org.github.spigot</groupId>
<artifactId>1.8.8</artifactId>
<version>1.8.8</version>
<scope>provided</scope>
</dependency>
<dependency>
<groupId>org.github.spigot</groupId>
<artifactId>1.7.10</artifactId>
<version>1.7.10</version>
<scope>provided</scope>
</dependency>
<dependency>
<groupId>com.comphenix.protocol</groupId>
<artifactId>ProtocolLib</artifactId>
@@ -104,6 +99,13 @@
<scope>provided</scope>
</dependency>
<dependency>
<groupId>org.spigotmc</groupId>
<artifactId>spigot-api</artifactId>
<version>1.8.8-R0.1-SNAPSHOT</version>
<scope>provided</scope>
</dependency>
<dependency>
<groupId>org.bukkit</groupId>
<artifactId>bukkit</artifactId>
@@ -1,13 +1,14 @@
package io.github.retrooper.packetevents;
import io.github.retrooper.packetevents.annotations.PacketHandler;
import io.github.retrooper.packetevents.api.PacketEventsAPI;
import io.github.retrooper.packetevents.enums.ClientVersion;
import io.github.retrooper.packetevents.event.PacketListener;
import io.github.retrooper.packetevents.event.impl.BukkitMoveEvent;
import io.github.retrooper.packetevents.event.impl.PacketReceiveEvent;
import io.github.retrooper.packetevents.event.impl.PlayerInjectEvent;
import io.github.retrooper.packetevents.packet.PacketType;
import io.github.retrooper.packetevents.packet.PacketTypeClasses;
import io.github.retrooper.packetevents.settings.Settings;
import io.github.retrooper.packetevents.utils.onlineplayers.OnlinePlayerUtilities;
import io.github.retrooper.packetevents.utils.versionlookup.VersionLookupUtils;
import org.bukkit.Bukkit;
import org.bukkit.entity.Player;
import org.bukkit.event.EventHandler;
@@ -17,17 +18,11 @@ import org.bukkit.event.player.PlayerMoveEvent;
import org.bukkit.event.player.PlayerQuitEvent;
import org.bukkit.plugin.Plugin;
import java.util.HashMap;
public final class PacketEvents implements PacketListener, Listener {
public static HashMap<Plugin, Integer> plugins = new HashMap<Plugin, Integer>();
public PacketEvents(final Plugin plugin) {
this.plugin = plugin;
plugins.put(plugin, plugins.size());
}
private final Plugin plugin;
private final PacketEventsAPI packetEventsAPI = new PacketEventsAPI();
private static boolean hasLoaded;
private static Plugin plugin;
private static final PacketEventsAPI packetEventsAPI = new PacketEventsAPI();
private static final PacketEvents instance = new PacketEvents();
private static boolean hasLoaded, hasStarted;
private static final Settings settings = new Settings();
/**
@@ -36,77 +31,88 @@ public final class PacketEvents implements PacketListener, Listener {
public static void load() {
PacketTypeClasses.Client.load();
PacketTypeClasses.Server.load();
ClientVersion.prepareLookUp();
hasLoaded = true;
}
/**
*Loads PacketEvents if you haven't already, Sets everything up, injects all players
* Loads PacketEvents if you haven't already, Sets everything up, injects all players
*/
public void start() {
public static void start(final Plugin pl) {
if (!hasLoaded) {
load();
}
if (!hasStarted) {
plugin = pl;
//Register Bukkit and PacketListener
getAPI().getEventManager().registerListener(this);
getAPI().getEventManager().registerListener(instance);
Bukkit.getPluginManager().registerEvents(this, plugin);
Bukkit.getPluginManager().registerEvents(instance, plugin);
for(final Player p : Bukkit.getServer().getOnlinePlayers()) {
getAPI().getPlayerUtilities().injectPlayer(p, this);
for (final Player p : OnlinePlayerUtilities.getOnlinePlayers()) {
getAPI().getPlayerUtils().injectPlayer(p);
}
hasStarted = true;
}
}
/**
* Stop all tasks and unregisters all PacketEvents' listeners
*/
public void stop() {
getAPI().getEventManager().unregisterAllListeners();
public static void stop() {
if (hasStarted) {
for (final Player p : OnlinePlayerUtilities.getOnlinePlayers()) {
PacketType.Client.packetIds.clear();
PacketType.Server.packetIds.clear();
for(final Player p : Bukkit.getServer().getOnlinePlayers()) {
getAPI().getPlayerUtilities().uninjectPlayer(p, this);
getAPI().getPlayerUtils().uninjectPlayerNow(p);
}
getAPI().getEventManager().unregisterAllListeners();
PacketType.Client.packetIds.clear();
PacketType.Server.packetIds.clear();
}
}
public PacketEventsAPI getAPI() {
public static boolean hasLoaded() {
return hasLoaded;
}
public static boolean hasStarted() {
return hasStarted;
}
public static PacketEventsAPI getAPI() {
return packetEventsAPI;
}
public Plugin getPlugin() {
public static Plugin getPlugin() {
return plugin;
}
public String getHandlerName() {
return "packetevents_" + plugins.get(plugin);
public static String getHandlerName(final String name) {
return "pe-" + getSettings().getIdentifier() + "-" + name;
}
public static Settings getSettings() {
return settings;
}
@PacketHandler
public void onInject(final PlayerInjectEvent e) {
getAPI().getPlayerUtilities().setClientVersion(e.getPlayer(), e.getClientVersion());
}
@PacketHandler
public void onReceive(final PacketReceiveEvent e) {
}
@EventHandler
public void onJoin(final PlayerJoinEvent e) {
getAPI().getPlayerUtilities().injectPlayer(e.getPlayer(), this);
getAPI().getPlayerUtils().injectPlayer(e.getPlayer());
getAPI().getPlayerUtils().setClientVersion(e.getPlayer(), ClientVersion.fromProtocolVersion(VersionLookupUtils.getProtocolVersion(e.getPlayer())));
}
@EventHandler
public void onQuit(final PlayerQuitEvent e) {
getAPI().getPlayerUtilities().clearClientVersion(e.getPlayer());
getAPI().getPlayerUtilities().uninjectPlayer(e.getPlayer(), this);
getAPI().getPlayerUtils().clearClientVersion(e.getPlayer());
getAPI().getPlayerUtils().uninjectPlayerNow(e.getPlayer());
}
@EventHandler
public void onMove(final PlayerMoveEvent e) {
getAPI().getEventManager().callEvent(new BukkitMoveEvent(e), getPlugin());
BukkitMoveEvent moveEvent = new BukkitMoveEvent(e);
getAPI().getEventManager().callEvent(moveEvent);
e.setCancelled(moveEvent.isCancelled());
}
}
@@ -1,15 +1,13 @@
package io.github.retrooper.packetevents;
package io.github.retrooper.packetevents.api;
import io.github.retrooper.packetevents.event.manager.EventManager;
import io.github.retrooper.packetevents.settings.Settings;
import io.github.retrooper.packetevents.utils.api.PlayerUtils;
import io.github.retrooper.packetevents.utils.api.ServerUtils;
import org.bukkit.scheduler.BukkitTask;
public final class PacketEventsAPI {
private final EventManager eventManager = new EventManager();
private final PlayerUtils playerUtils = new PlayerUtils();
private final ServerUtils serverUtils = new ServerUtils();;
private final ServerUtils serverUtils = new ServerUtils();
/**
* Not thread safe
@@ -40,6 +38,16 @@ public final class PacketEventsAPI {
*
* @return Player Utilities
*/
public PlayerUtils getPlayerUtils() {
return playerUtils;
}
/**
* Use {@link #getPlayerUtils()}
*
* @return
*/
@Deprecated
public PlayerUtils getPlayerUtilities() {
return playerUtils;
}
@@ -49,6 +57,16 @@ public final class PacketEventsAPI {
*
* @return Server Utilities
*/
public ServerUtils getServerUtils() {
return serverUtils;
}
/**
* Please use {@link #getServerUtils()}
*
* @return
*/
@Deprecated
public ServerUtils getServerUtilities() {
return serverUtils;
}
@@ -64,5 +82,4 @@ public final class PacketEventsAPI {
}
}
@@ -1,74 +1,75 @@
package io.github.retrooper.packetevents.enums;
import io.github.retrooper.packetevents.PacketEvents;
import java.util.HashMap;
import java.util.Map;
public enum ClientVersion {
LESS_THAN_V_1_7_10, v_1_7_10, v_1_8, v_1_9, v_1_9_1, v_1_9_2, v_1_9_3, v_1_10, v_1_11, v_1_11_1, v_1_12, v_1_12_1, v_1_12_2,
v_1_13, v_1_13_1, v_1_13_2, v_1_14, v_1_14_1, v_1_14_2, v_1_14_3, v_1_14_4, v_1_15, v_1_15_1, v_1_15_2, v_1_16, v_1_16_1, HIGHER_THAN_V_1_16_1, INVALID, ACCESS_FAILURE;
v_1_13, v_1_13_1, v_1_13_2, v_1_14, v_1_14_1, v_1_14_2, v_1_14_3, v_1_14_4, v_1_15_PRE_1, v_1_15_PRE_2, v_1_15_PRE_3, v_1_15_PRE_4, v_1_15_PRE_5, v_1_15_PRE_6, v_1_15_PRE_7,
v_1_15, v_1_15_1, v_1_15_2, v_1_16, v_1_16_PRE_1, v_1_16_PRE_2, v_1_16_PRE_3, v_1_16_PRE_4, v_1_16_PRE_5, v_1_16_PRE_6, v_1_16_PRE_7, v_1_16_PRE_8, v_1_16_RC_1, v_1_16_1, HIGHER_THAN_V_1_16_1, INVALID, ACCESS_FAILURE;
public static ClientVersion fromProtocolVersion(final int protocolVersion) {
int remainder = -1;
switch (protocolVersion) {
case -1:
return ACCESS_FAILURE;
case 1:
case 2:
case 3:
case 4:
return LESS_THAN_V_1_7_10;
case 47://ranging from 1.8->1.8.9
return v_1_8;
case 107:
return v_1_9;
case 108:
return v_1_9_1;
case 109:
return v_1_9_2;
case 110:
return v_1_9_3; //can be 1.9.3 or 1.9.4
case 210:
return v_1_10; //could be 1.10,1.10.1, 1.10.2
case 315:
return v_1_11;
case 316: //could be 11.1 or 11.2
return v_1_11_1;
case 335:
return v_1_12;
case 338:
return v_1_12_1;
case 340:
return v_1_12_2;
case 393:
return v_1_13;
case 401:
return v_1_13_1;
case 404:
return v_1_13_2;
case 477:
return v_1_14;
case 480:
return v_1_14_1;
case 485:
return v_1_14_2;
case 490:
return v_1_14_3;
case 498:
return v_1_14_4;
case 573:
return v_1_15;
case 575:
return v_1_15_1;
case 578:
return v_1_15_2;
case 735:
return v_1_16;
case 736:
return v_1_16_1;
default:
remainder = protocolVersion;
private static final Map<Integer, ClientVersion> VERSION_LOOKUP = new HashMap<>();
public static void prepareLookUp() {
VERSION_LOOKUP.put(-1, ACCESS_FAILURE);
VERSION_LOOKUP.put(1, LESS_THAN_V_1_7_10);
VERSION_LOOKUP.put(2, LESS_THAN_V_1_7_10);
VERSION_LOOKUP.put(3, LESS_THAN_V_1_7_10);
VERSION_LOOKUP.put(4, LESS_THAN_V_1_7_10);
VERSION_LOOKUP.put(5, v_1_7_10);
VERSION_LOOKUP.put(47, v_1_8);
VERSION_LOOKUP.put(107, v_1_9);
VERSION_LOOKUP.put(108, v_1_9_1);
VERSION_LOOKUP.put(109, v_1_9_2);
VERSION_LOOKUP.put(110, v_1_9_3);
VERSION_LOOKUP.put(210, v_1_10);
VERSION_LOOKUP.put(315, v_1_11);
VERSION_LOOKUP.put(316, v_1_11_1);
VERSION_LOOKUP.put(335, v_1_12);
VERSION_LOOKUP.put(338, v_1_12_1);
VERSION_LOOKUP.put(340, v_1_12_2);
VERSION_LOOKUP.put(393, v_1_13);
VERSION_LOOKUP.put(401, v_1_13_1);
VERSION_LOOKUP.put(404, v_1_13_2);
VERSION_LOOKUP.put(477, v_1_14);
VERSION_LOOKUP.put(480, v_1_14_1);
VERSION_LOOKUP.put(485, v_1_14_2);
VERSION_LOOKUP.put(490, v_1_14_3);
VERSION_LOOKUP.put(498, v_1_14_4);
VERSION_LOOKUP.put(565, v_1_15_PRE_1);
VERSION_LOOKUP.put(566, v_1_15_PRE_2);
VERSION_LOOKUP.put(567, v_1_15_PRE_3);
VERSION_LOOKUP.put(569, v_1_15_PRE_4);
VERSION_LOOKUP.put(570, v_1_15_PRE_5);
VERSION_LOOKUP.put(571, v_1_15_PRE_6);
VERSION_LOOKUP.put(572, v_1_15_PRE_7);
VERSION_LOOKUP.put(573, v_1_15);
VERSION_LOOKUP.put(575, v_1_15_1);
VERSION_LOOKUP.put(578, v_1_15_2);
VERSION_LOOKUP.put(721, v_1_16_PRE_1);
VERSION_LOOKUP.put(722, v_1_16_PRE_2);
VERSION_LOOKUP.put(725, v_1_16_PRE_3);
VERSION_LOOKUP.put(727, v_1_16_PRE_4);
VERSION_LOOKUP.put(729, v_1_16_PRE_5);
VERSION_LOOKUP.put(730, v_1_16_PRE_6);
VERSION_LOOKUP.put(732, v_1_16_PRE_7);
VERSION_LOOKUP.put(733, v_1_16_PRE_8);
VERSION_LOOKUP.put(734, v_1_16_RC_1);
VERSION_LOOKUP.put(735, v_1_16);
VERSION_LOOKUP.put(736, v_1_16_1);
}
public static ClientVersion fromProtocolVersion(int protocolVersion) {
if (protocolVersion == -1 && PacketEvents.getSettings().doAutoResolveClientProtocolVersion()) {
protocolVersion = ServerVersion.getVersion().toProtocolVersion();
}
if (remainder > 578) {
return HIGHER_THAN_V_1_16_1;
final ClientVersion lookedUp = VERSION_LOOKUP.get(protocolVersion);
if (lookedUp != null) {
return lookedUp;
}
return INVALID;
return protocolVersion > 736 ? HIGHER_THAN_V_1_16_1 : INVALID;
}
/**
@@ -23,8 +23,7 @@ public enum ServerVersion {
String valName = val.name().substring(2).replace("_", ".");
if (Bukkit.getBukkitVersion().contains(valName)) {
return val;
}
else if(PacketEvents.getSettings().getDefaultServerVersion() != null) {
} else if (PacketEvents.getSettings().getDefaultServerVersion() != null) {
return PacketEvents.getSettings().getDefaultServerVersion();
}
}
@@ -100,4 +99,47 @@ public enum ServerVersion {
return false;
}
public int toProtocolVersion() {
if (this.equals(ServerVersion.v_1_7_10)) {
return 5;
}
if (this.name().startsWith("v_1_8")) {
return 47;
}
if (this.equals(ServerVersion.v_1_9)) {
return 107;
}
if (this.equals(ServerVersion.v_1_9_4)) {
return 110;
}
if (this.equals(ServerVersion.v_1_10)) {
return 210;
}
if (this.equals(ServerVersion.v_1_11)) {
return 315;
}
if (this.equals(ServerVersion.v_1_11)) {
return 315;
}
if (this.equals(ServerVersion.v_1_12)) {
return 335;
}
if (this.equals(ServerVersion.v_1_13)) {
return 393;
}
if (this.equals(ServerVersion.v_1_13_2)) {
return 404;
}
if (this.equals(ServerVersion.v_1_14)) {
return 477;
}
if (this.equals(ServerVersion.v_1_15)) {
return 573;
}
if (this.equals(ServerVersion.v_1_16_1)) {
return 735;
}
return -1;
}
}
@@ -0,0 +1,25 @@
package io.github.retrooper.packetevents.enums.minecraft;
public enum Gamemode {
NOT_SET(-1, ""),
SURVIVAL(0, "survival"),
CREATIVE(1, "creative"),
ADVENTURE(2, "adventure"),
SPECTATOR(3, "spectator");
int f;
String g;
Gamemode(int var3, String var4) {
this.f = var3;
this.g = var4;
}
public int getId() {
return this.f;
}
public String b() {
return this.g;
}
}
@@ -0,0 +1,8 @@
package io.github.retrooper.packetevents.enums.minecraft;
public enum PlayerInfoAction {
ADD_PLAYER, UPDATE_GAME_MODE, UPDATE_LATENCY, UPDATE_DISPLAY_NAME, REMOVE_PLAYER;
PlayerInfoAction() {
}
}
@@ -1,7 +1,6 @@
package io.github.retrooper.packetevents.event;
import io.github.retrooper.packetevents.PacketEvents;
import io.github.retrooper.packetevents.enums.ServerVersion;
public class PacketEvent {
@@ -8,6 +8,7 @@ import org.bukkit.event.player.PlayerMoveEvent;
public final class BukkitMoveEvent extends PacketEvent {
private final Player player;
private final Location to, from;
private boolean cancelled;
public BukkitMoveEvent(final Player player, final Location to, final Location from) {
this.player = player;
@@ -32,4 +33,16 @@ public final class BukkitMoveEvent extends PacketEvent {
public Location getTo() {
return to;
}
public void setCancelled(final boolean val) {
this.cancelled = val;
}
public boolean isCancelled() {
return cancelled;
}
public void cancel() {
setCancelled(true);
}
}
@@ -1,18 +1,14 @@
package io.github.retrooper.packetevents.event.impl;
import io.github.retrooper.packetevents.enums.ClientVersion;
import io.github.retrooper.packetevents.event.PacketEvent;
import io.github.retrooper.packetevents.utils.versionlookup.VersionLookupUtils;
import org.bukkit.entity.Player;
public final class PlayerInjectEvent extends PacketEvent {
private final Player player;
private final ClientVersion clientVersion;
private boolean cancelled;
public PlayerInjectEvent(final Player player) {
this.player = player;
this.clientVersion = ClientVersion.fromProtocolVersion(VersionLookupUtils.getProtocolVersion(player));
}
public boolean isCancelled() {
@@ -27,10 +23,6 @@ public final class PlayerInjectEvent extends PacketEvent {
setCancelled(true);
}
public ClientVersion getClientVersion() {
return clientVersion;
}
public Player getPlayer() {
return player;
}
@@ -6,9 +6,11 @@ import org.bukkit.entity.Player;
public final class PlayerUninjectEvent extends PacketEvent {
private final Player player;
private boolean cancelled;
private final boolean sync;
public PlayerUninjectEvent(final Player player) {
public PlayerUninjectEvent(final Player player, final boolean sync) {
this.player = player;
this.sync = sync;
}
public void cancel() {
@@ -23,6 +25,16 @@ public final class PlayerUninjectEvent extends PacketEvent {
this.cancelled = val;
}
/**
* Whether the uninjection was called synchronously or asynchronously.
* The event is still called synchronously.
* By default all uninjections are called aynchronously in this build.
* @return If the uninjection was done async or sync
*/
public boolean isSync() {
return sync;
}
public Player getPlayer() {
return player;
}
@@ -6,7 +6,6 @@ import io.github.retrooper.packetevents.annotations.data.EventSynchronization;
import io.github.retrooper.packetevents.event.PacketEvent;
import io.github.retrooper.packetevents.event.PacketListener;
import org.bukkit.Bukkit;
import org.bukkit.plugin.Plugin;
import java.lang.reflect.InvocationTargetException;
import java.lang.reflect.Method;
@@ -28,7 +27,7 @@ public final class EventManager {
this(Runtime.getRuntime().availableProcessors());
}
public void callEvent(final PacketEvent e, final Plugin plugin) {
public void callEvent(final PacketEvent e) {
for (final PacketListener listener : registeredMethods.keySet()) {
//Annotated methods
final List<Method> methods = registeredMethods.get(listener);
@@ -50,7 +49,7 @@ public final class EventManager {
if (annotation.synchronization() == EventSynchronization.FORCE_ASYNC) {
executorService.execute(invokeMethod);
} else if (annotation.synchronization() == EventSynchronization.FORCE_SYNC) {
Bukkit.getScheduler().runTask(plugin, invokeMethod);
Bukkit.getScheduler().runTask(PacketEvents.getPlugin(), invokeMethod);
} else {
invokeMethod.run();
}
@@ -1,13 +1,11 @@
package io.github.retrooper.packetevents.example;
import io.github.retrooper.packetevents.PacketEvents;
import io.github.retrooper.packetevents.annotations.PacketHandler;
import io.github.retrooper.packetevents.event.PacketListener;
import io.github.retrooper.packetevents.event.impl.PlayerInjectEvent;
import org.bukkit.plugin.java.JavaPlugin;
public class MainExample extends JavaPlugin implements PacketListener {
private final PacketEvents pe = new PacketEvents(this);
@Override
public void onLoad() {
PacketEvents.load();
@@ -15,21 +13,20 @@ public class MainExample extends JavaPlugin implements PacketListener {
@Override
public void onEnable() {
pe.start();
//If packetevents cannot detect your server version, it will use the recommended version
//Make sure you set a unique identifier, if another present plugin has the same identifier, you could run into issues
PacketEvents.getSettings().setIdentifier("official_api");
PacketEvents.start(this);
//If packetevents cannot detect your server version, it will use the default you specify version
// getAPI().getSettings().setDefaultServerVersion(ServerVersion.v_1_7_10);
pe.getAPI().getEventManager().registerListeners(this);
PacketEvents.getAPI().getEventManager().registerListeners(this);
}
@Override
public void onDisable() {
pe.stop();
PacketEvents.stop();
}
@PacketHandler
public void onInject(PlayerInjectEvent e) {
e.getPlayer().sendMessage("you have been injected");
System.out.println("he has been injected");
}
}
@@ -7,10 +7,10 @@ import io.github.retrooper.packetevents.event.impl.PlayerInjectEvent;
import io.github.retrooper.packetevents.event.impl.PlayerUninjectEvent;
import org.bukkit.entity.Player;
import java.util.NoSuchElementException;
import java.util.concurrent.Future;
public class NettyPacketHandler {
public static final String handlerName = "packet_handler";
private static boolean v1_7_nettyMode = false;
static {
@@ -21,45 +21,67 @@ public class NettyPacketHandler {
}
}
public static void injectPlayer(final Player player, PacketEvents pe) {
public static void injectPlayer(final Player player) {
final PlayerInjectEvent injectEvent = new PlayerInjectEvent(player);
pe.getAPI().getEventManager().callEvent(injectEvent, pe.getPlugin());
PacketEvents.getAPI().getEventManager().callEvent(injectEvent);
if (!injectEvent.isCancelled()) {
if (v1_7_nettyMode) {
NettyPacketHandler_7.injectPlayer(player, pe);
NettyPacketHandler_7.injectPlayer(player);
} else {
NettyPacketHandler_8.injectPlayer(player, pe);
NettyPacketHandler_8.injectPlayer(player);
}
}
}
public static Future<?> uninjectPlayer(final Player player, PacketEvents pe) {
final PlayerUninjectEvent uninjectEvent = new PlayerUninjectEvent(player);
pe.getAPI().getEventManager().callEvent(uninjectEvent, pe.getPlugin());
if (!uninjectEvent.isCancelled()) {
if (v1_7_nettyMode) {
return NettyPacketHandler_7.uninjectPlayer(player);
} else {
return NettyPacketHandler_8.uninjectPlayer(player);
public static Future<?> uninjectPlayer(final Player player) {
try {
final PlayerUninjectEvent uninjectEvent = new PlayerUninjectEvent(player, false);
PacketEvents.getAPI().getEventManager().callEvent(uninjectEvent);
if (!uninjectEvent.isCancelled()) {
if (v1_7_nettyMode) {
return NettyPacketHandler_7.uninjectPlayer(player);
} else {
return NettyPacketHandler_8.uninjectPlayer(player);
}
}
} catch(Exception e) {
}
return null;
}
public static Object write(final Player sender, final Object packet, PacketEvents pe) {
public static void uninjectPlayerNow(final Player player) {
try {
final PlayerUninjectEvent uninjectEvent = new PlayerUninjectEvent(player, true);
PacketEvents.getAPI().getEventManager().callEvent(uninjectEvent);
if (!uninjectEvent.isCancelled()) {
if (v1_7_nettyMode) {
NettyPacketHandler_7.uninjectPlayerNow(player);
} else {
NettyPacketHandler_8.uninjectPlayerNow(player);
}
}
}
catch(Exception e)
{
}
}
public static Object write(final Player sender, final Object packet) {
final String packetName = packet.getClass().getSimpleName();
final PacketSendEvent packetSendEvent = new PacketSendEvent(sender, packetName, packet);
pe.getAPI().getEventManager().callEvent(packetSendEvent, pe.getPlugin());
PacketEvents.getAPI().getEventManager().callEvent(packetSendEvent);
if (!packetSendEvent.isCancelled()) {
return packet;
}
return null;
}
public static Object read(final Player receiver, final Object packet, PacketEvents pe) {
public static Object read(final Player receiver, final Object packet) {
final String packetName = packet.getClass().getSimpleName();
final PacketReceiveEvent packetReceiveEvent = new PacketReceiveEvent(receiver, packetName, packet);
pe.getAPI().getEventManager().callEvent(packetReceiveEvent, pe.getPlugin());
PacketEvents.getAPI().getEventManager().callEvent(packetReceiveEvent);
if (!packetReceiveEvent.isCancelled()) {
return packet;
}
@@ -9,11 +9,11 @@ import java.util.concurrent.Future;
final class NettyPacketHandler_7 {
public static void injectPlayer(final Player player, final PacketEvents pe) {
public static void injectPlayer(final Player player) {
final ChannelDuplexHandler channelDuplexHandler = new ChannelDuplexHandler() {
@Override
public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
Object packet = NettyPacketHandler.read(player, msg, pe);
Object packet = NettyPacketHandler.read(player, msg);
if (packet == null) {
return;
}
@@ -22,7 +22,7 @@ final class NettyPacketHandler_7 {
@Override
public void write(ChannelHandlerContext ctx, Object msg, ChannelPromise promise) throws Exception {
Object packet = NettyPacketHandler.write(player, msg, pe);
Object packet = NettyPacketHandler.write(player, msg);
if (packet == null) {
return;
}
@@ -30,7 +30,7 @@ final class NettyPacketHandler_7 {
}
};
final ChannelPipeline pipeline = ((Channel) NMSUtils.getChannel(player)).pipeline();
pipeline.addBefore(pe.getHandlerName(), player.getName(), channelDuplexHandler);
pipeline.addBefore("packet_handler", PacketEvents.getHandlerName(player.getName()), channelDuplexHandler);
}
public static Future<?> uninjectPlayer(final Player player) {
@@ -38,8 +38,13 @@ final class NettyPacketHandler_7 {
return channel.eventLoop().submit(new Runnable() {
@Override
public void run() {
channel.pipeline().remove(player.getName());
channel.pipeline().remove(PacketEvents.getHandlerName(player.getName()));
}
});
}
public static void uninjectPlayerNow(final Player player) {
final Channel channel = (Channel) NMSUtils.getChannel(player);
channel.pipeline().remove(PacketEvents.getHandlerName(player.getName()));
}
}
@@ -1,7 +1,6 @@
package io.github.retrooper.packetevents.handler;
import io.github.retrooper.packetevents.PacketEvents;
import io.github.retrooper.packetevents.enums.ServerVersion;
import io.github.retrooper.packetevents.utils.NMSUtils;
import io.netty.channel.*;
import org.bukkit.entity.Player;
@@ -10,11 +9,11 @@ import java.util.concurrent.Future;
final class NettyPacketHandler_8 {
public static void injectPlayer(final Player player, final PacketEvents pe) {
public static void injectPlayer(final Player player) {
final ChannelDuplexHandler channelDuplexHandler = new ChannelDuplexHandler() {
@Override
public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
Object packet = NettyPacketHandler.read(player, msg, pe);
Object packet = NettyPacketHandler.read(player, msg);
if (packet == null) {
return;
}
@@ -23,7 +22,7 @@ final class NettyPacketHandler_8 {
@Override
public void write(ChannelHandlerContext ctx, Object msg, ChannelPromise promise) throws Exception {
Object packet = NettyPacketHandler.write(player, msg, pe);
Object packet = NettyPacketHandler.write(player, msg);
if (packet == null) {
return;
}
@@ -31,7 +30,7 @@ final class NettyPacketHandler_8 {
}
};
final ChannelPipeline pipeline = ((Channel) NMSUtils.getChannel(player)).pipeline();
pipeline.addBefore(pe.getHandlerName(), player.getName(), channelDuplexHandler);
pipeline.addBefore("packet_handler", PacketEvents.getHandlerName(player.getName()), channelDuplexHandler);
}
public static Future<?> uninjectPlayer(final Player player) {
@@ -39,8 +38,13 @@ final class NettyPacketHandler_8 {
return channel.eventLoop().submit(new Runnable() {
@Override
public void run() {
channel.pipeline().remove(player.getName());
channel.pipeline().remove(PacketEvents.getHandlerName(player.getName()));
}
});
}
public static void uninjectPlayerNow(final Player player) {
final Channel channel = (Channel) NMSUtils.getChannel(player);
channel.pipeline().remove(PacketEvents.getHandlerName(player.getName()));
}
}
@@ -1,16 +1,15 @@
package io.github.retrooper.packetevents.packetwrappers.in.keepalive;
import io.github.retrooper.packetevents.enums.ServerVersion;
import io.github.retrooper.packetevents.packetwrappers.api.WrappedPacket;
import io.github.retrooper.packetevents.reflectionutils.Reflection;
import io.github.retrooper.packetevents.utils.NMSUtils;
public final class WrappedPacketInKeepAlive extends WrappedPacket {
private static Class<?> keepAliveClass;
private static Class<?> packetClass;
static {
try {
keepAliveClass = NMSUtils.getNMSClass("PacketPlayInKeepAlive");
packetClass = NMSUtils.getNMSClass("PacketPlayInKeepAlive");
} catch (ClassNotFoundException e) {
e.printStackTrace();
}
@@ -24,22 +23,26 @@ public final class WrappedPacketInKeepAlive extends WrappedPacket {
@Override
protected void setup() {
try {
if (version.isHigherThan(ServerVersion.v_1_12)) {
this.id = Reflection.getField(keepAliveClass, long.class, 0).getLong(packet);
} else {
this.id = Reflection.getField(keepAliveClass, int.class, 0).getInt(packet);
if (Reflection.getField(packetClass, int.class, 0) == null) {
try {
this.id = Reflection.getField(packetClass, long.class, 0).getLong(packet);
} catch (IllegalAccessException e) {
e.printStackTrace();
}
} else {
try {
this.id = Reflection.getField(packetClass, int.class, 0).getInt(packet);
} catch (IllegalAccessException e) {
e.printStackTrace();
}
} catch (IllegalAccessException e) {
e.printStackTrace();
}
}
/**
* Cast this long to an integer if you are using 1.7.10->1.12.2!
* In 1.13.2->1.15.2 a long is sent
* Optionally Cast this long to an integer if you are using 1.7.10->1.12.2!
* In 1.13.2->1.16.1 a long is sent
*
* @return
* @return response is
*/
public long getId() {
return id;
@@ -0,0 +1,52 @@
package io.github.retrooper.packetevents.packetwrappers.out.keepalive;
import io.github.retrooper.packetevents.packetwrappers.api.WrappedPacket;
import io.github.retrooper.packetevents.reflectionutils.Reflection;
import io.github.retrooper.packetevents.utils.NMSUtils;
import net.minecraft.server.v1_8_R3.PacketPlayOutKeepAlive;
public class WrappedPacketOutKeepAlive extends WrappedPacket {
private long id;
public WrappedPacketOutKeepAlive(Object packet) {
super(packet);
}
/**
* Optionally Cast this long to an integer if you are using 1.7.10->1.12.2!
* In 1.13.2->1.16.1 a long is sent
*
* @return response is
*/
public long getId() {
return id;
}
@Override
protected void setup() {
if (Reflection.getField(packetClass, int.class, 0) == null) {
try {
this.id = Reflection.getField(packetClass, long.class, 0).getLong(packet);
} catch (IllegalAccessException e) {
e.printStackTrace();
}
} else {
try {
this.id = Reflection.getField(packetClass, int.class, 0).getInt(packet);
} catch (IllegalAccessException e) {
e.printStackTrace();
}
}
}
private static Class<?> packetClass;
static {
try {
packetClass = NMSUtils.getNMSClass("PacketPlayOutKeepAlive");
} catch (ClassNotFoundException e) {
e.printStackTrace();
}
PacketPlayOutKeepAlive p;
}
}
@@ -0,0 +1,44 @@
package io.github.retrooper.packetevents.packetwrappers.out.playerinfo;
import io.github.retrooper.packetevents.enums.minecraft.Gamemode;
import io.github.retrooper.packetevents.enums.minecraft.PlayerInfoAction;
import io.github.retrooper.packetevents.packetwrappers.api.WrappedPacket;
import io.github.retrooper.packetevents.reflectionutils.Reflection;
import io.github.retrooper.packetevents.utils.NMSUtils;
import net.minecraft.server.v1_8_R3.PacketPlayOutPlayerInfo;
public class WrappedPacketOutPlayerInfo extends WrappedPacket {
private PlayerInfoAction action;
public WrappedPacketOutPlayerInfo(Object packet) {
super(packet);
}
@Override
protected void setup() {
PacketPlayOutPlayerInfo.PlayerInfoData dl;
}
private static Class<?> packetClass, enumPlayerInfoActionClass;
static {
try {
packetClass = NMSUtils.getNMSClass("PacketPlayOutPlayerInfo");
} catch (ClassNotFoundException e) {
e.printStackTrace();
}
try {
enumPlayerInfoActionClass = NMSUtils.getNMSClass("EnumPLayerInfoAction");
} catch (ClassNotFoundException e) {
enumPlayerInfoActionClass = Reflection.getSubClass(packetClass, "EnumPlayerInfoAction");
}
}
public class PlayerDataInfo {
public PlayerDataInfo(Object gameProfile, int var, Gamemode gamemode, String s) {
}
}
}
@@ -75,17 +75,16 @@ public final class Reflection {
public static Field getField(final Class<?> cls, final int index) {
final FieldWithIndex fwi = new FieldWithIndex(cls, index);
if (!fieldWithIndexHashMap.containsKey(fwi)) {
int i = 0;
for (final Field f : getFields(cls)) {
if (index == i++) {
fieldWithIndexHashMap.put(fwi, f);
return f;
}
final Field[] fields = getFields(cls);
if (fields.length <= index) {
return null;
}
final Field field = fields[index];
fieldWithIndexHashMap.put(fwi, field);
return field;
} else {
return fieldWithIndexHashMap.get(fwi);
}
return null;
}
//METHODS
@@ -187,4 +186,4 @@ public final class Reflection {
}
return null;
}
}
}
@@ -4,6 +4,8 @@ import io.github.retrooper.packetevents.enums.ServerVersion;
public class Settings {
private ServerVersion defaultServerVersion;
private String identifier = "";
private boolean autoResolveClientProtocolVersion;
/**
* If PacketEvents fails to detect your server version, it will use the recommended version
@@ -22,4 +24,21 @@ public class Settings {
public void setDefaultServerVersion(final ServerVersion version) {
defaultServerVersion = version;
}
public String getIdentifier() {
return identifier;
}
public void setIdentifier(final String identifier) {
this.identifier = identifier;
}
public boolean doAutoResolveClientProtocolVersion() {
return autoResolveClientProtocolVersion;
}
public void setDoAutoResolveClientProtocolVersion(boolean autoResolveClientProtocolVersion) {
this.autoResolveClientProtocolVersion = autoResolveClientProtocolVersion;
}
}
@@ -15,4 +15,4 @@ public class BlockIteratorUtils {
}
return block;
}
}
}
@@ -1,6 +1,5 @@
package io.github.retrooper.packetevents.utils;
import io.github.retrooper.packetevents.PacketEvents;
import io.github.retrooper.packetevents.annotations.Nullable;
import io.github.retrooper.packetevents.enums.ServerVersion;
import io.github.retrooper.packetevents.packetwrappers.Sendable;
@@ -16,7 +15,7 @@ import java.lang.reflect.InvocationTargetException;
import java.lang.reflect.Method;
public final class NMSUtils {
private static final ServerVersion version =ServerVersion.getVersion();
private static final ServerVersion version = ServerVersion.getVersion();
public static String nettyPrefix;
private static final String nmsDir = ServerVersion.getNMSDirectory();
private static final String obcDir = ServerVersion.getOBCDirectory();
@@ -1,6 +1,5 @@
package io.github.retrooper.packetevents.utils.api;
import io.github.retrooper.packetevents.PacketEvents;
import io.github.retrooper.packetevents.enums.ClientVersion;
import io.github.retrooper.packetevents.handler.NettyPacketHandler;
import io.github.retrooper.packetevents.packetwrappers.Sendable;
@@ -41,12 +40,16 @@ public final class PlayerUtils {
clearClientVersion(player.getUniqueId());
}
public void injectPlayer(final Player player, final PacketEvents pe) {
NettyPacketHandler.injectPlayer(player,pe);
public void injectPlayer(final Player player) {
NettyPacketHandler.injectPlayer(player);
}
public void uninjectPlayer(final Player player, final PacketEvents pe) {
NettyPacketHandler.uninjectPlayer(player, pe);
public void uninjectPlayer(final Player player) {
NettyPacketHandler.uninjectPlayer(player);
}
public void uninjectPlayerNow(final Player player) {
NettyPacketHandler.uninjectPlayerNow(player);
}
public void sendPacket(final Player player, final Sendable sendable) {
@@ -11,10 +11,12 @@ public final class ServerUtils {
public ServerVersion getServerVersion() {
return getVersion();
}
@Deprecated
public double[] getRecentServerTPS() {
return getRecentTPS();
return getRecentTPS();
}
@Deprecated
public double getCurrentServerTPS() {
return getCurrentTPS();
@@ -1,6 +1,5 @@
package io.github.retrooper.packetevents.utils.nms_entityfinder;
import io.github.retrooper.packetevents.PacketEvents;
import io.github.retrooper.packetevents.annotations.Nullable;
import io.github.retrooper.packetevents.enums.ServerVersion;
import io.github.retrooper.packetevents.utils.NMSUtils;
@@ -13,7 +12,7 @@ import java.lang.reflect.Method;
public final class EntityFinderUtils {
@Nullable
private static final ServerVersion version =ServerVersion.getVersion();
private static final ServerVersion version = ServerVersion.getVersion();
private static Class<?> worldServerClass;
private static Class<?> craftWorldClass;
private static Class<?> entityClass;
@@ -0,0 +1,16 @@
package io.github.retrooper.packetevents.utils.onlineplayers;
import io.github.retrooper.packetevents.enums.ServerVersion;
import org.bukkit.entity.Player;
public class OnlinePlayerUtilities {
private static final ServerVersion version = ServerVersion.getVersion();
public static Player[] getOnlinePlayers() {
if (version.isLowerThan(ServerVersion.v_1_9)) {
return OnlinePlayerUtils_8.getOnlinePlayers();
} else {
return OnlinePlayerUtils_9.getOnlinePlayers();
}
}
}
@@ -0,0 +1,12 @@
package io.github.retrooper.packetevents.utils.onlineplayers;
import org.bukkit.Bukkit;
import org.bukkit.entity.Player;
public class OnlinePlayerUtils_8 {
public static Player[] getOnlinePlayers() {
return Bukkit.getServer().getOnlinePlayers().toArray(new Player[0]);
}
}
@@ -0,0 +1,10 @@
package io.github.retrooper.packetevents.utils.onlineplayers;
import org.bukkit.Bukkit;
import org.bukkit.entity.Player;
public class OnlinePlayerUtils_9 {
public static Player[] getOnlinePlayers() {
return Bukkit.getOnlinePlayers().toArray(new Player[0]);
}
}