<!-- pom.xml -->
<repository>
    <id>dmulloy2-repo</id>
    <url>https://repo.dmulloy2.net/repository/public/</url>
</repository>

<dependency>
    <groupId>com.comphenix.protocol</groupId>
    <artifactId>ProtocolLib</artifactId>
    <version>5.3.0</version>
    <scope>provided</scope>
</dependency>

depend:
  - ProtocolLib

import com.comphenix.protocol.PacketType;
import com.comphenix.protocol.ProtocolLibrary;
import com.comphenix.protocol.ProtocolManager;
import com.comphenix.protocol.events.*;

public class PacketListener {

    private final ProtocolManager protocolManager;

    public PacketListener(MyPlugin plugin) {
        this.protocolManager = ProtocolLibrary.getProtocolManager();

        // 监听客户端发送的聊天包
        protocolManager.addPacketListener(
            new PacketAdapter(plugin, PacketType.Play.Client.CHAT) {
                @Override
                public void onPacketReceiving(PacketEvent event) {
                    // 获取玩家
                    Player player = event.getPlayer();

                    // 获取聊天内容
                    String message = event.getPacket().getStrings().read(0);

                    // 日志记录
                    plugin.getLogger().info("[Chat] " + player.getName() + ": " + message);
                }
            }
        );
    }
}

// 监听服务端发送的聊天消息包
protocolManager.addPacketListener(
    new PacketAdapter(plugin,
        PacketType.Play.Server.SYSTEM_CHAT_MESSAGE) {
        @Override
        public void onPacketSending(PacketEvent event) {
            Player player = event.getPlayer();

            // 读取消息内容
            var packet = event.getPacket();
            // Paper 的消息内容可能使用 Component 或 String

            // 修改消息（例如添加前缀）
            // packet.getStrings().modify(0, original -> "[PREFIX] " + original);
        }
    }
);

protocolManager.addPacketListener(
    new PacketAdapter(plugin, PacketType.Play.Client.CHAT) {
        @Override
        public void onPacketReceiving(PacketEvent event) {
            String message = event.getPacket().getStrings().read(0);

            // 禁止发送包含敏感词的消息
            if (message.contains("广告")) {
                event.setCancelled(true); // 取消数据包
                event.getPlayer().sendMessage("§c消息包含敏感内容！");
            }
        }
    }
);

protocolManager.addPacketListener(
    new PacketAdapter(plugin, PacketType.Play.Client.CHAT) {
        @Override
        public void onPacketReceiving(PacketEvent event) {
            // 异步延迟处理
            event.setReadOnly(false); // 允许修改

            Bukkit.getScheduler().runTaskAsynchronously(plugin, () -> {
                // 异步验证（如数据库检查）
                boolean allowed = checkMessage(event.getPlayer(), message);
                if (!allowed) {
                    // 在异步线程中取消
                    event.setCancelled(true);
                }
            });
        }
    }
);

protocolManager.addPacketListener(
    new PacketAdapter(plugin, PacketType.Play.Server.CHAT_MESSAGE) {
        @Override
        public void onPacketSending(PacketEvent event) {
            var packet = event.getPacket();

            // 读取原始消息
            String original = packet.getStrings().read(0);

            // 修改消息（如敏感词替换）
            String modified = original.replace("敏感词", "***");

            // 写回数据包
            packet.getStrings().write(0, modified);
        }
    }
);

// 修改实体生成包中的实体类型
protocolManager.addPacketListener(
    new PacketAdapter(plugin, PacketType.Play.Server.SPAWN_ENTITY) {
        @Override
        public void onPacketSending(PacketEvent event) {
            var packet = event.getPacket();

            // 读取实体类型
            int entityId = packet.getIntegers().read(0);

            // 修改元数据
            // ...
        }
    }
);

import com.comphenix.protocol.PacketType;
import com.comphenix.protocol.events.PacketContainer;
import com.comphenix.protocol.wrappers.WrappedChatComponent;

public class PacketSender {

    /**
     * 发送自定义标题
     */
    public static void sendTitle(Player player, String title, String subtitle,
                                  int fadeIn, int stay, int fadeOut) {
        ProtocolManager manager = ProtocolLibrary.getProtocolManager();

        // 发送淡入淡出时间
        PacketContainer times = new PacketContainer(
            PacketType.Play.Server.SET_TITLE_TIME
        );
        times.getIntegers().write(0, fadeIn);
        times.getIntegers().write(1, stay);
        times.getIntegers().write(2, fadeOut);

        // 发送标题文字
        PacketContainer titlePacket = new PacketContainer(
            PacketType.Play.Server.SET_TITLE_TEXT
        );
        titlePacket.getChatComponents().write(0,
            WrappedChatComponent.fromJson("{\"text\":\"" + title + "\"}"));

        // 发送副标题
        PacketContainer subtitlePacket = new PacketContainer(
            PacketType.Play.Server.SET_SUBTITLE_TEXT
        );
        subtitlePacket.getChatComponents().write(0,
            WrappedChatComponent.fromJson("{\"text\":\"" + subtitle + "\"}"));

        try {
            manager.sendServerPacket(player, times);
            manager.sendServerPacket(player, titlePacket);
            manager.sendServerPacket(player, subtitlePacket);
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

protocolManager.addPacketListener(
    new PacketAdapter(plugin, PacketType.Play.Server.ENTITY_METADATA) {
        @Override
        public void onPacketSending(PacketEvent event) {
            var packet = event.getPacket();

            // 获取实体 ID
            int entityId = packet.getIntegers().read(0);

            // 获取元数据
            List<WrappedDataValue> dataValues = packet.getDataValueCollectionModifier()
                .read(0);

            // 修改元数据（如自定义名称）
            for (WrappedDataValue value : dataValues) {
                if (value.getIndex() == 2) { // 自定义名称
                    // 修改名称
                }
            }
        }
    }
);

// Paper 的原生方式（有限功能）
import com.destroystokyo.paper.event.player.PlayerArmorChangeEvent;

@EventHandler
public void onArmorChange(PlayerArmorChangeEvent event) {
    // Paper 原生事件，不需要 ProtocolLib
}

public class TabListManager {

    private final ProtocolManager protocolManager;

    public TabListManager(MyPlugin plugin) {
        this.protocolManager = ProtocolLibrary.getProtocolManager();
    }

    /**
     * 发送自定义 Tab 列表头部和底部
     */
    public void sendTabHeaderFooter(Player player, String header, String footer) {
        PacketContainer packet = new PacketContainer(
            PacketType.Play.Server.PLAYER_LIST_HEADER_FOOTER
        );

        packet.getChatComponents().write(0,
            WrappedChatComponent.fromJson(
                "{\"text\":\"" + header + "\"}"));
        packet.getChatComponents().write(1,
            WrappedChatComponent.fromJson(
                "{\"text\":\"" + footer + "\"}"));

        try {
            protocolManager.sendServerPacket(player, packet);
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}