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

feat: 添加ProtocolLib工具

Signed-off-by: 502647092 <admin@yumc.pw>
This commit is contained in:
502647092 2016-09-27 15:13:39 +08:00
parent 71b8f56e1e
commit 46359463b9
2 changed files with 228 additions and 0 deletions

View File

@ -0,0 +1,26 @@
package pw.yumc.YumCore.plugin.protocollib;
import org.bukkit.Bukkit;
import com.comphenix.protocol.ProtocolLibrary;
import com.comphenix.protocol.ProtocolManager;
import pw.yumc.YumCore.kit.PKit;
/**
* ProtocolLib基础
*
* @since 2016年9月27日 下午2:41:00
* @author
*/
public class ProtocolLibBase {
protected static ProtocolManager manager;
static {
if (Bukkit.getServer().getPluginManager().getPlugin("ProtocolLib") == null) {
PKit.disable("未找到 ProtocolLib 插件 停止加载...");
} else {
manager = ProtocolLibrary.getProtocolManager();
}
}
}

View File

@ -0,0 +1,202 @@
package pw.yumc.YumCore.plugin.protocollib;
import java.lang.reflect.InvocationTargetException;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.List;
import org.bukkit.Bukkit;
import org.bukkit.GameMode;
import org.bukkit.Location;
import org.bukkit.Material;
import org.bukkit.entity.Player;
import org.bukkit.event.Cancellable;
import org.bukkit.event.Event;
import org.bukkit.event.HandlerList;
import com.comphenix.protocol.PacketType;
import com.comphenix.protocol.PacketType.Play.Client;
import com.comphenix.protocol.PacketType.Play.Server;
import com.comphenix.protocol.events.PacketAdapter;
import com.comphenix.protocol.events.PacketContainer;
import com.comphenix.protocol.events.PacketEvent;
import com.comphenix.protocol.events.PacketListener;
import com.comphenix.protocol.wrappers.BlockPosition;
import com.comphenix.protocol.wrappers.WrappedBlockData;
import com.comphenix.protocol.wrappers.WrappedChatComponent;
import pw.yumc.YumCore.bukkit.P;
/**
* 木牌工具类
*
* @since 2016年7月7日 上午9:38:28
* @author
*/
public class SignKit extends ProtocolLibBase {
private static boolean newVer = true;
static {
try {
GameMode.SPECTATOR.name();
} catch (final Exception e) {
newVer = false;
}
}
/**
* 打开木牌
*
* @param player
* 玩家
* @param lines
* 木牌内容
* @throws InvocationTargetException
*/
public static void open(final Player player, final String[] lines) throws InvocationTargetException {
final Location loc = player.getLocation();
final int x = loc.getBlockX(), y = 0, z = loc.getBlockZ();
if (newVer) {
// Set
PacketContainer packet = manager.createPacket(Server.BLOCK_CHANGE);
packet.getBlockPositionModifier().write(0, new BlockPosition(x, y, z));
packet.getBlockData().write(0, WrappedBlockData.createData(Material.SIGN_POST));
manager.sendServerPacket(player, packet);
// Update
packet = manager.createPacket(Server.UPDATE_SIGN);
packet.getBlockPositionModifier().write(0, new BlockPosition(x, y, z));
packet.getChatComponentArrays().write(0,
new WrappedChatComponent[] { WrappedChatComponent.fromText(lines[0]), WrappedChatComponent.fromText(lines[1]), WrappedChatComponent.fromText(lines[2]), WrappedChatComponent.fromText(lines[3]) });
manager.sendServerPacket(player, packet);
// Edit
packet = manager.createPacket(Server.OPEN_SIGN_ENTITY);
packet.getBlockPositionModifier().write(0, new BlockPosition(x, y, z));
manager.sendServerPacket(player, packet);
} else {
// Set
PacketContainer packet = manager.createPacket(Server.BLOCK_CHANGE);
packet.getIntegers().write(0, x).write(1, y).write(2, z).write(3, 0);
packet.getBlocks().write(0, Material.SIGN_POST);
manager.sendServerPacket(player, packet);
// Update
packet = manager.createPacket(Server.UPDATE_SIGN);
packet.getIntegers().write(0, x).write(1, y).write(2, z);
packet.getStringArrays().write(0, lines);
manager.sendServerPacket(player, packet);
// Edit
packet = manager.createPacket(Server.OPEN_SIGN_ENTITY);
packet.getIntegers().write(0, x).write(1, y).write(2, z);
manager.sendServerPacket(player, packet);
}
}
/**
* 初始化监听器
*/
public void init() {
manager.addPacketListener(new SignUpdateListen());
}
/**
* 木牌更新事件
*
* @since 2016年7月7日 上午9:59:07
* @author
*/
public static class SignUpdateEvent extends Event implements Cancellable {
private static final HandlerList handlers = new HandlerList();
private final Player player;
private final String[] lines;
private boolean cancel = false;
public SignUpdateEvent(final Player player, final String[] lines) {
this.player = player;
this.lines = lines;
}
public static HandlerList getHandlerList() {
return handlers;
}
@Override
public HandlerList getHandlers() {
return handlers;
}
/**
* 木牌内容
*
* @return lines
*/
public String[] getLines() {
return lines;
}
/**
* 触发玩家
*
* @return player
*/
public Player getPlayer() {
return player;
}
/*
* @see org.bukkit.event.Cancellable#isCancelled()
*/
@Override
public boolean isCancelled() {
return cancel;
}
/*
* @see org.bukkit.event.Cancellable#setCancelled(boolean)
*/
@Override
public void setCancelled(final boolean cancel) {
this.cancel = cancel;
}
}
/**
* 木牌监听类
*
* @since 2016年7月7日 上午9:58:59
* @author
*/
public static class SignUpdateListen extends PacketAdapter implements PacketListener {
public SignUpdateListen() {
super(P.instance, new PacketType[] { Client.UPDATE_SIGN });
}
@Override
public void onPacketReceiving(final PacketEvent event) {
final Player player = event.getPlayer();
final PacketContainer packet = event.getPacket();
final List<String> lines = new ArrayList<>();
if (newVer) {
final WrappedChatComponent[] input1_8 = packet.getChatComponentArrays().read(0);
for (final WrappedChatComponent wrappedChatComponent : input1_8) {
lines.add(subString(wrappedChatComponent.getJson()));
}
} else {
final String[] input = packet.getStringArrays().getValues().get(0);
lines.addAll(Arrays.asList(input));
}
final SignUpdateEvent sue = new SignUpdateEvent(player, lines.toArray(new String[0]));
Bukkit.getPluginManager().callEvent(sue);
event.setCancelled(sue.isCancelled());
}
private String subString(final String string) {
return string.substring(1, string.length() - 1);
}
}
}