1
0
mirror of https://e.coding.net/circlecloud/YumCore.git synced 2024-11-21 01:38:51 +00:00

feat: 兼容 1.17

Signed-off-by: MiaoWoo <admin@yumc.pw>
This commit is contained in:
MiaoWoo 2021-06-22 05:30:05 +00:00
parent f130cfed60
commit 834f3d7d58
2 changed files with 446 additions and 437 deletions

View File

@ -4,7 +4,7 @@
<modelVersion>4.0.0</modelVersion>
<groupId>pw.yumc</groupId>
<artifactId>YumCore</artifactId>
<version>1.9.1</version>
<version>1.9.2</version>
<build>
<finalName>${project.artifactId}</finalName>
<plugins>
@ -92,7 +92,7 @@
<dependency>
<groupId>me.clip</groupId>
<artifactId>placeholderapi</artifactId>
<version>2.9.2</version>
<version>2.10.9</version>
<exclusions>
<exclusion>
<artifactId>spigot-api</artifactId>

View File

@ -1,436 +1,445 @@
package pw.yumc.YumCore.bukkit.compatible;
import com.google.common.base.Charsets;
import org.bukkit.*;
import org.bukkit.scheduler.BukkitRunnable;
import org.json.simple.JSONObject;
import pw.yumc.YumCore.annotation.NotProguard;
import pw.yumc.YumCore.bukkit.Log;
import pw.yumc.YumCore.bukkit.P;
import java.lang.reflect.Constructor;
import java.lang.reflect.Field;
import java.lang.reflect.Method;
import java.util.Arrays;
import java.util.Collection;
import java.util.UUID;
/**
* Bukkit兼容类
*
* @author
* @since 2016年7月23日 下午1:04:56
*/
public class C {
public static boolean init;
private static boolean above_1_16 = false;
private static Class<?> nmsIChatBaseComponent;
private static Constructor<?> packetTypeConstructor;
private static Method chatSerializer;
private static Method getHandle;
private static Method nmsChatMessageTypeClassValueOf;
private static String version;
private static boolean newversion;
private static Field playerConnection;
private static Method sendPacket;
private static Object[] chatMessageTypes;
static {
try {
version = getNMSVersion();
newversion = Integer.parseInt(version.split("_")[1]) > 7;
Class<?> nmsChatSerializer = Class.forName(a(newversion ? "IChatBaseComponent$ChatSerializer" : "ChatSerializer"));
chatSerializer = nmsChatSerializer.getMethod("a", String.class);
nmsIChatBaseComponent = Class.forName(a("IChatBaseComponent"));
Class<?> packetType = Class.forName(a("PacketPlayOutChat"));
Arrays.stream(packetType.getConstructors()).forEach(c -> {
if (c.getParameterTypes().length == 2) {
packetTypeConstructor = c;
}
if (c.getParameterTypes().length == 3) {
packetTypeConstructor = c;
above_1_16 = true;
}
});
Class<?> nmsChatMessageTypeClass = packetTypeConstructor.getParameterTypes()[1];
if (nmsChatMessageTypeClass.isEnum()) {
chatMessageTypes = nmsChatMessageTypeClass.getEnumConstants();
} else {
switch (nmsChatMessageTypeClass.getName()) {
case "int":
nmsChatMessageTypeClass = Integer.class;
break;
case "byte":
nmsChatMessageTypeClass = Byte.class;
break;
}
nmsChatMessageTypeClassValueOf = nmsChatMessageTypeClass.getDeclaredMethod("valueOf", String.class);
}
Class<?> typeCraftPlayer = Class.forName(b("entity.CraftPlayer"));
Class<?> typeNMSPlayer = Class.forName(a("EntityPlayer"));
Class<?> typePlayerConnection = Class.forName(a("PlayerConnection"));
getHandle = typeCraftPlayer.getMethod("getHandle");
playerConnection = typeNMSPlayer.getField("playerConnection");
sendPacket = typePlayerConnection.getMethod("sendPacket", Class.forName(a("Packet")));
init = true;
} catch (Exception e) {
Log.w("C 兼容性工具初始化失败 可能造成部分功能不可用!");
Log.d(e);
}
}
private C() {
}
public static String a(String str) {
return "net.minecraft.server." + version + "." + str;
}
public static String b(String str) {
return "org.bukkit.craftbukkit." + version + "." + str;
}
/**
* 获得NMS版本号
*
* @return NMS版本号
*/
public static String getNMSVersion() {
return Bukkit.getServer().getClass().getPackage().getName().replace(".", ",").split(",")[3];
}
/**
* 给玩家发送Json消息
*
* @param receivingPacket 接受信息的玩家
* @param json Json信息
* @param type 类型
* 0. 消息
* 2. ActionBar
*/
public static void sendJson(org.bukkit.entity.Player receivingPacket, String json, int type) {
try {
Object serialized = chatSerializer.invoke(null, json);
Object player = getHandle.invoke(receivingPacket);
Object connection = playerConnection.get(player);
Object typeObj = chatMessageTypes == null ? nmsChatMessageTypeClassValueOf.invoke(null, String.valueOf(type)) : chatMessageTypes[type];
sendPacket.invoke(connection, above_1_16
? packetTypeConstructor.newInstance(serialized, typeObj, receivingPacket.getUniqueId())
: packetTypeConstructor.newInstance(serialized, typeObj));
} catch (Exception ex) {
Log.d("Json发包错误 " + version, ex);
}
}
public static class ActionBar {
private ActionBar() {
}
/**
* 公告发送ActionBar
*
* @param message 需要发送的消息
*/
@NotProguard
public static void broadcast(String message) {
for (org.bukkit.entity.Player player : C.Player.getOnlinePlayers()) {
send(player, message);
}
}
/**
* 公告发送ActionBar
*
* @param message 需要发送的消息
* @param times 需要显示的时间
*/
@NotProguard
public static void broadcast(final String message, final int times) {
new BukkitRunnable() {
int time = times;
@Override
public void run() {
C.Player.getOnlinePlayers().forEach(player -> send(player, message));
time--;
if (time <= 0) {
cancel();
}
}
}.runTaskTimerAsynchronously(P.instance, 0, 20);
}
/**
* 公告发送ActionBar(分世界)
*
* @param world 需要发送的世界
* @param message 需要发送的消息
* @param times 需要显示的时间
*/
@NotProguard
public static void broadcast(final World world, final String message, final int times) {
new BukkitRunnable() {
int time = times;
@Override
public void run() {
C.Player.getOnlinePlayers().stream().filter(player -> player.getWorld().getName().equalsIgnoreCase(world.getName())).forEach(player -> send(player, message));
time--;
if (time <= 0) {
cancel();
}
}
}.runTaskTimerAsynchronously(P.instance, 0, 20);
}
/**
* 给玩家发送ActionBar消息
*
* @param receivingPacket 接受信息的玩家
* @param msg ActionBar信息
*/
@NotProguard
public static void send(org.bukkit.entity.Player receivingPacket, String msg) {
sendJson(receivingPacket, "{\"text\":\"" + ChatColor.translateAlternateColorCodes('&', JSONObject.escape(msg)) + "\"}", 2);
}
/**
* 给玩家发送ActionBar消息
*
* @param receivingPacket 接受信息的玩家
* @param msg 需要发送的消息
* @param times 需要显示的时间
*/
@NotProguard
public static void send(final org.bukkit.entity.Player receivingPacket, final String msg, final int times) {
new BukkitRunnable() {
int time = times;
@Override
public void run() {
send(receivingPacket, msg);
time--;
if (time <= 0) {
cancel();
}
}
}.runTaskTimerAsynchronously(P.instance, 0, 20);
}
}
/**
* Bukkit Player兼容类
*
* @author
* @since 2016年7月23日 下午4:33:40
*/
public static class Player {
private static Class<?> gameProfileClass;
private static Constructor<?> gameProfileConstructor;
private static Constructor<?> craftOfflinePlayerConstructor;
private static Method getOnlinePlayers;
static {
try {
// getOnlinePlayers start
getOnlinePlayers = Bukkit.class.getDeclaredMethod("getOnlinePlayers");
if (getOnlinePlayers.getReturnType() != org.bukkit.entity.Player[].class) {
for (Method method : Bukkit.class.getDeclaredMethods()) {
if (method.getReturnType() == org.bukkit.entity.Player[].class && method.getName().endsWith("getOnlinePlayers")) {
getOnlinePlayers = method;
}
}
}
// getOnlinePlayers end
} catch (Exception e) {
Log.w("Player 兼容性工具初始化失败 可能造成部分功能不可用!");
}
try {
// getOfflinePlayer start
try {
gameProfileClass = Class.forName("net.minecraft.util.com.mojang.authlib.GameProfile");
} catch (Exception e) {
try {
gameProfileClass = Class.forName("com.mojang.authlib.GameProfile");
} catch (Exception ignored) {
}
}
gameProfileConstructor = gameProfileClass.getDeclaredConstructor(UUID.class, String.class);
gameProfileConstructor.setAccessible(true);
Class<? extends Server> craftServer = Bukkit.getServer().getClass();
Class<?> craftOfflinePlayer = Class.forName(craftServer.getName().replace("CraftServer", "CraftOfflinePlayer"));
craftOfflinePlayerConstructor = craftOfflinePlayer.getDeclaredConstructor(craftServer, gameProfileClass);
craftOfflinePlayerConstructor.setAccessible(true);
// getOfflinePlayer end
} catch (Exception e) {
Log.d(e);
}
}
private Player() {
}
/**
* 获取离线玩家(跳过网络获取)
*
* @param playerName 玩家名称
* @return {@link OfflinePlayer}
*/
@NotProguard
public static OfflinePlayer getOfflinePlayer(String playerName) {
try {
Object gameProfile = gameProfileConstructor.newInstance(UUID.nameUUIDFromBytes(("OfflinePlayer:" + playerName).getBytes(Charsets.UTF_8)), playerName);
Object offlinePlayer = craftOfflinePlayerConstructor.newInstance(Bukkit.getServer(), gameProfile);
return (OfflinePlayer) offlinePlayer;
} catch (Exception e) {
return Bukkit.getOfflinePlayer(playerName);
}
}
/**
* 获取在线玩家
*
* @return 在线玩家
*/
@NotProguard
public static Collection<? extends org.bukkit.entity.Player> getOnlinePlayers() {
try {
return Arrays.asList((org.bukkit.entity.Player[]) getOnlinePlayers.invoke(null));
} catch (Exception e) {
return Bukkit.getOnlinePlayers();
}
}
}
public static class Title {
private static Class<?> packetActions;
private static Class<?> packetTitle;
private static Constructor<?> packetTitleSendConstructor;
private static Constructor<?> packetTitleSetTimeConstructor;
private static Object[] actions;
static {
try {
packetActions = Class.forName(a(newversion ? "PacketPlayOutTitle$EnumTitleAction" : "EnumTitleAction"));
packetTitle = Class.forName(a("PacketPlayOutTitle"));
packetTitleSendConstructor = packetTitle.getConstructor(packetActions, nmsIChatBaseComponent);
packetTitleSetTimeConstructor = packetTitle.getConstructor(packetActions, nmsIChatBaseComponent, Integer.TYPE, Integer.TYPE, Integer.TYPE);
actions = packetActions.getEnumConstants();
} catch (Exception ignore) {
Log.w("Title 兼容性工具初始化失败 可能造成部分功能不可用!");
}
}
private Title() {
}
/**
* 发送Title公告
*
* @param title 标题
* @param subtitle 子标题
*/
@NotProguard
public static void broadcast(String title, String subtitle) {
for (org.bukkit.entity.Player player : Player.getOnlinePlayers()) {
send(player, title, subtitle);
}
}
/**
* 发送Title公告
*
* @param title 标题
* @param subtitle 子标题
* @param fadeInTime 淡入时间
* @param stayTime 持续时间
* @param fadeOutTime 淡出时间
*/
@NotProguard
public static void broadcast(String title, String subtitle, int fadeInTime, int stayTime, int fadeOutTime) {
for (org.bukkit.entity.Player player : Player.getOnlinePlayers()) {
send(player, title, subtitle, fadeInTime, stayTime, fadeOutTime);
}
}
/**
* 发送Title公告
*
* @param world 世界
* @param title 标题
* @param subtitle 子标题
*/
@NotProguard
public static void broadcast(World world, String title, String subtitle) {
C.Player.getOnlinePlayers().stream().filter(player -> player.getWorld().getName().equalsIgnoreCase(world.getName())).forEach(player -> send(player, title, subtitle));
}
/**
* 重置玩家的Title
*
* @param recoverPlayer 接受的玩家
* @throws Exception 异常
*/
@NotProguard
public static void reset(org.bukkit.entity.Player recoverPlayer) throws Exception {
// Send timings first
Object player = getHandle.invoke(recoverPlayer);
Object connection = playerConnection.get(player);
Object packet = packetTitleSendConstructor.newInstance(actions[4], null);
sendPacket.invoke(connection, packet);
}
/**
* 发送Titile(默认时间 1 2 1)
*
* @param receivingPacket 接受信息的玩家
* @param title 标题
* @param subtitle 子标题
*/
@NotProguard
public static void send(org.bukkit.entity.Player receivingPacket, String title, String subtitle) {
send(receivingPacket, title, subtitle, 1, 2, 1);
}
/**
* 发送Titile
*
* @param receivingPacket 接受信息的玩家
* @param title 标题
* @param subtitle 子标题
* @param fadeInTime 淡入时间
* @param stayTime 持续时间
* @param fadeOutTime 淡出时间
*/
@NotProguard
public static void send(org.bukkit.entity.Player receivingPacket, String title, String subtitle, int fadeInTime, int stayTime, int fadeOutTime) {
if (packetTitle != null) {
try {
// First reset previous settings
reset(receivingPacket);
// Send timings first
Object player = getHandle.invoke(receivingPacket);
Object connection = playerConnection.get(player);
Object packet;
// Send if set
if ((fadeInTime != -1) && (fadeOutTime != -1) && (stayTime != -1)) {
packet = packetTitleSetTimeConstructor.newInstance(actions[2], null, fadeInTime * 20, stayTime * 20, fadeOutTime * 20);
sendPacket.invoke(connection, packet);
}
// Send title
Object serialized = chatSerializer.invoke(null, "{\"text\":\"" + ChatColor.translateAlternateColorCodes('&', title) + "\"}");
packet = packetTitleSendConstructor.newInstance(actions[0], serialized);
sendPacket.invoke(connection, packet);
if (!"".equals(subtitle)) {
// Send subtitle if present
serialized = chatSerializer.invoke(null, "{\"text\":\"" + ChatColor.translateAlternateColorCodes('&', subtitle) + "\"}");
packet = packetTitleSendConstructor.newInstance(actions[1], serialized);
sendPacket.invoke(connection, packet);
}
} catch (Exception e) {
Log.d(e);
}
}
}
}
package pw.yumc.YumCore.bukkit.compatible;
import com.google.common.base.Charsets;
import org.bukkit.*;
import org.bukkit.scheduler.BukkitRunnable;
import org.json.simple.JSONObject;
import pw.yumc.YumCore.annotation.NotProguard;
import pw.yumc.YumCore.bukkit.Log;
import pw.yumc.YumCore.bukkit.P;
import java.lang.reflect.Constructor;
import java.lang.reflect.Field;
import java.lang.reflect.Method;
import java.util.Arrays;
import java.util.Collection;
import java.util.UUID;
/**
* Bukkit兼容类
*
* @author
* @since 2016年7月23日 下午1:04:56
*/
public class C {
public static boolean init;
private static boolean above_1_16 = false;
private static Class<?> nmsIChatBaseComponent;
private static Constructor<?> packetTypeConstructor;
private static Method chatSerializer;
private static Method getHandle;
private static Method nmsChatMessageTypeClassValueOf;
private static String version;
private static boolean newversion;
private static Field playerConnection;
private static Method sendPacket;
private static Object[] chatMessageTypes;
static {
try {
version = getNMSVersion();
Integer subVersion = Integer.parseInt(version.split("_")[1]);
newversion = subVersion > 7;
Class<?> nmsChatSerializer = subVersion < 17 ?
Class.forName(a(newversion ? "IChatBaseComponent$ChatSerializer" : "ChatSerializer")) :
Class.forName("net.minecraft.network.chat.IChatBaseComponent$ChatSerializer");
chatSerializer = nmsChatSerializer.getMethod("a", String.class);
nmsIChatBaseComponent = subVersion < 17 ?
Class.forName(a("IChatBaseComponent")) :
Class.forName("net.minecraft.network.chat.IChatBaseComponent");
Class<?> packetType = subVersion < 17 ?
Class.forName(a("PacketPlayOutChat")) :
Class.forName("net.minecraft.network.protocol.game.PacketPlayOutChat");
Arrays.stream(packetType.getConstructors()).forEach(c -> {
if (c.getParameterTypes().length == 2) {
packetTypeConstructor = c;
}
if (c.getParameterTypes().length == 3) {
packetTypeConstructor = c;
above_1_16 = true;
}
});
Class<?> nmsChatMessageTypeClass = packetTypeConstructor.getParameterTypes()[1];
if (nmsChatMessageTypeClass.isEnum()) {
chatMessageTypes = nmsChatMessageTypeClass.getEnumConstants();
} else {
switch (nmsChatMessageTypeClass.getName()) {
case "int":
nmsChatMessageTypeClass = Integer.class;
break;
case "byte":
nmsChatMessageTypeClass = Byte.class;
break;
}
nmsChatMessageTypeClassValueOf = nmsChatMessageTypeClass.getDeclaredMethod("valueOf", String.class);
}
Class<?> typeCraftPlayer = Class.forName(b("entity.CraftPlayer"));
Class<?> typeNMSPlayer = subVersion < 17 ? Class.forName(a("EntityPlayer")) : Class.forName("net.minecraft.server.level.EntityPlayer");
Class<?> typePlayerConnection = subVersion < 17 ? Class.forName(a("PlayerConnection")) : Class.forName("net.minecraft.server.network.PlayerConnection");
getHandle = typeCraftPlayer.getMethod("getHandle");
playerConnection = subVersion < 17 ? typeNMSPlayer.getField("playerConnection") : typeNMSPlayer.getField("b");
sendPacket = typePlayerConnection.getMethod("sendPacket", subVersion < 17 ?
Class.forName(a("Packet")) :
Class.forName("net.minecraft.network.protocol.Packet"));
init = true;
} catch (Exception e) {
Log.w("C 兼容性工具初始化失败 可能造成部分功能不可用!");
Log.d(e);
}
}
private C() {
}
public static String a(String str) {
return "net.minecraft.server." + version + "." + str;
}
public static String b(String str) {
return "org.bukkit.craftbukkit." + version + "." + str;
}
/**
* 获得NMS版本号
*
* @return NMS版本号
*/
public static String getNMSVersion() {
return Bukkit.getServer().getClass().getPackage().getName().replace(".", ",").split(",")[3];
}
/**
* 给玩家发送Json消息
*
* @param receivingPacket 接受信息的玩家
* @param json Json信息
* @param type 类型
* 0. 消息
* 2. ActionBar
*/
public static void sendJson(org.bukkit.entity.Player receivingPacket, String json, int type) {
try {
Object serialized = chatSerializer.invoke(null, json);
Object player = getHandle.invoke(receivingPacket);
Object connection = playerConnection.get(player);
Object typeObj = chatMessageTypes == null ? nmsChatMessageTypeClassValueOf.invoke(null, String.valueOf(type)) : chatMessageTypes[type];
sendPacket.invoke(connection, above_1_16
? packetTypeConstructor.newInstance(serialized, typeObj, receivingPacket.getUniqueId())
: packetTypeConstructor.newInstance(serialized, typeObj));
} catch (Exception ex) {
Log.d("Json发包错误 " + version, ex);
}
}
public static class ActionBar {
private ActionBar() {
}
/**
* 公告发送ActionBar
*
* @param message 需要发送的消息
*/
@NotProguard
public static void broadcast(String message) {
for (org.bukkit.entity.Player player : C.Player.getOnlinePlayers()) {
send(player, message);
}
}
/**
* 公告发送ActionBar
*
* @param message 需要发送的消息
* @param times 需要显示的时间
*/
@NotProguard
public static void broadcast(final String message, final int times) {
new BukkitRunnable() {
int time = times;
@Override
public void run() {
C.Player.getOnlinePlayers().forEach(player -> send(player, message));
time--;
if (time <= 0) {
cancel();
}
}
}.runTaskTimerAsynchronously(P.instance, 0, 20);
}
/**
* 公告发送ActionBar(分世界)
*
* @param world 需要发送的世界
* @param message 需要发送的消息
* @param times 需要显示的时间
*/
@NotProguard
public static void broadcast(final World world, final String message, final int times) {
new BukkitRunnable() {
int time = times;
@Override
public void run() {
C.Player.getOnlinePlayers().stream().filter(player -> player.getWorld().getName().equalsIgnoreCase(world.getName())).forEach(player -> send(player, message));
time--;
if (time <= 0) {
cancel();
}
}
}.runTaskTimerAsynchronously(P.instance, 0, 20);
}
/**
* 给玩家发送ActionBar消息
*
* @param receivingPacket 接受信息的玩家
* @param msg ActionBar信息
*/
@NotProguard
public static void send(org.bukkit.entity.Player receivingPacket, String msg) {
sendJson(receivingPacket, "{\"text\":\"" + ChatColor.translateAlternateColorCodes('&', JSONObject.escape(msg)) + "\"}", 2);
}
/**
* 给玩家发送ActionBar消息
*
* @param receivingPacket 接受信息的玩家
* @param msg 需要发送的消息
* @param times 需要显示的时间
*/
@NotProguard
public static void send(final org.bukkit.entity.Player receivingPacket, final String msg, final int times) {
new BukkitRunnable() {
int time = times;
@Override
public void run() {
send(receivingPacket, msg);
time--;
if (time <= 0) {
cancel();
}
}
}.runTaskTimerAsynchronously(P.instance, 0, 20);
}
}
/**
* Bukkit Player兼容类
*
* @author
* @since 2016年7月23日 下午4:33:40
*/
public static class Player {
private static Class<?> gameProfileClass;
private static Constructor<?> gameProfileConstructor;
private static Constructor<?> craftOfflinePlayerConstructor;
private static Method getOnlinePlayers;
static {
try {
// getOnlinePlayers start
getOnlinePlayers = Bukkit.class.getDeclaredMethod("getOnlinePlayers");
if (getOnlinePlayers.getReturnType() != org.bukkit.entity.Player[].class) {
for (Method method : Bukkit.class.getDeclaredMethods()) {
if (method.getReturnType() == org.bukkit.entity.Player[].class && method.getName().endsWith("getOnlinePlayers")) {
getOnlinePlayers = method;
}
}
}
// getOnlinePlayers end
} catch (Exception e) {
Log.w("Player 兼容性工具初始化失败 可能造成部分功能不可用!");
}
try {
// getOfflinePlayer start
try {
gameProfileClass = Class.forName("net.minecraft.util.com.mojang.authlib.GameProfile");
} catch (Exception e) {
try {
gameProfileClass = Class.forName("com.mojang.authlib.GameProfile");
} catch (Exception ignored) {
}
}
gameProfileConstructor = gameProfileClass.getDeclaredConstructor(UUID.class, String.class);
gameProfileConstructor.setAccessible(true);
Class<? extends Server> craftServer = Bukkit.getServer().getClass();
Class<?> craftOfflinePlayer = Class.forName(craftServer.getName().replace("CraftServer", "CraftOfflinePlayer"));
craftOfflinePlayerConstructor = craftOfflinePlayer.getDeclaredConstructor(craftServer, gameProfileClass);
craftOfflinePlayerConstructor.setAccessible(true);
// getOfflinePlayer end
} catch (Exception e) {
Log.d(e);
}
}
private Player() {
}
/**
* 获取离线玩家(跳过网络获取)
*
* @param playerName 玩家名称
* @return {@link OfflinePlayer}
*/
@NotProguard
public static OfflinePlayer getOfflinePlayer(String playerName) {
try {
Object gameProfile = gameProfileConstructor.newInstance(UUID.nameUUIDFromBytes(("OfflinePlayer:" + playerName).getBytes(Charsets.UTF_8)), playerName);
Object offlinePlayer = craftOfflinePlayerConstructor.newInstance(Bukkit.getServer(), gameProfile);
return (OfflinePlayer) offlinePlayer;
} catch (Exception e) {
return Bukkit.getOfflinePlayer(playerName);
}
}
/**
* 获取在线玩家
*
* @return 在线玩家
*/
@NotProguard
public static Collection<? extends org.bukkit.entity.Player> getOnlinePlayers() {
try {
return Arrays.asList((org.bukkit.entity.Player[]) getOnlinePlayers.invoke(null));
} catch (Exception e) {
return Bukkit.getOnlinePlayers();
}
}
}
public static class Title {
private static Class<?> packetActions;
private static Class<?> packetTitle;
private static Constructor<?> packetTitleSendConstructor;
private static Constructor<?> packetTitleSetTimeConstructor;
private static Object[] actions;
static {
try {
packetActions = Class.forName(a(newversion ? "PacketPlayOutTitle$EnumTitleAction" : "EnumTitleAction"));
packetTitle = Class.forName(a("PacketPlayOutTitle"));
packetTitleSendConstructor = packetTitle.getConstructor(packetActions, nmsIChatBaseComponent);
packetTitleSetTimeConstructor = packetTitle.getConstructor(packetActions, nmsIChatBaseComponent, Integer.TYPE, Integer.TYPE, Integer.TYPE);
actions = packetActions.getEnumConstants();
} catch (Exception ignore) {
Log.w("Title 兼容性工具初始化失败 可能造成部分功能不可用!");
}
}
private Title() {
}
/**
* 发送Title公告
*
* @param title 标题
* @param subtitle 子标题
*/
@NotProguard
public static void broadcast(String title, String subtitle) {
for (org.bukkit.entity.Player player : Player.getOnlinePlayers()) {
send(player, title, subtitle);
}
}
/**
* 发送Title公告
*
* @param title 标题
* @param subtitle 子标题
* @param fadeInTime 淡入时间
* @param stayTime 持续时间
* @param fadeOutTime 淡出时间
*/
@NotProguard
public static void broadcast(String title, String subtitle, int fadeInTime, int stayTime, int fadeOutTime) {
for (org.bukkit.entity.Player player : Player.getOnlinePlayers()) {
send(player, title, subtitle, fadeInTime, stayTime, fadeOutTime);
}
}
/**
* 发送Title公告
*
* @param world 世界
* @param title 标题
* @param subtitle 子标题
*/
@NotProguard
public static void broadcast(World world, String title, String subtitle) {
C.Player.getOnlinePlayers().stream().filter(player -> player.getWorld().getName().equalsIgnoreCase(world.getName())).forEach(player -> send(player, title, subtitle));
}
/**
* 重置玩家的Title
*
* @param recoverPlayer 接受的玩家
* @throws Exception 异常
*/
@NotProguard
public static void reset(org.bukkit.entity.Player recoverPlayer) throws Exception {
// Send timings first
Object player = getHandle.invoke(recoverPlayer);
Object connection = playerConnection.get(player);
Object packet = packetTitleSendConstructor.newInstance(actions[4], null);
sendPacket.invoke(connection, packet);
}
/**
* 发送Titile(默认时间 1 2 1)
*
* @param receivingPacket 接受信息的玩家
* @param title 标题
* @param subtitle 子标题
*/
@NotProguard
public static void send(org.bukkit.entity.Player receivingPacket, String title, String subtitle) {
send(receivingPacket, title, subtitle, 1, 2, 1);
}
/**
* 发送Titile
*
* @param receivingPacket 接受信息的玩家
* @param title 标题
* @param subtitle 子标题
* @param fadeInTime 淡入时间
* @param stayTime 持续时间
* @param fadeOutTime 淡出时间
*/
@NotProguard
public static void send(org.bukkit.entity.Player receivingPacket, String title, String subtitle, int fadeInTime, int stayTime, int fadeOutTime) {
if (packetTitle != null) {
try {
// First reset previous settings
reset(receivingPacket);
// Send timings first
Object player = getHandle.invoke(receivingPacket);
Object connection = playerConnection.get(player);
Object packet;
// Send if set
if ((fadeInTime != -1) && (fadeOutTime != -1) && (stayTime != -1)) {
packet = packetTitleSetTimeConstructor.newInstance(actions[2], null, fadeInTime * 20, stayTime * 20, fadeOutTime * 20);
sendPacket.invoke(connection, packet);
}
// Send title
Object serialized = chatSerializer.invoke(null, "{\"text\":\"" + ChatColor.translateAlternateColorCodes('&', title) + "\"}");
packet = packetTitleSendConstructor.newInstance(actions[0], serialized);
sendPacket.invoke(connection, packet);
if (!"".equals(subtitle)) {
// Send subtitle if present
serialized = chatSerializer.invoke(null, "{\"text\":\"" + ChatColor.translateAlternateColorCodes('&', subtitle) + "\"}");
packet = packetTitleSendConstructor.newInstance(actions[1], serialized);
sendPacket.invoke(connection, packet);
}
} catch (Exception e) {
Log.d(e);
}
}
}
}
}