原创 娱乐 MC-BngeuitBridge —— Bngeuit QQ 机器人 ↔ Minecraft 服务器的双向通信桥 1.0.0

MC服务器-1 (client-id:1) ──┐
MC服务器-2 (client-id:2) ──┤──→ BngeuitBridge (ws://ip:8765) ──→ QQ群
MC服务器-3 (client-id:3) ──┘

const plugin = {
    name: 'BridgeEventListener',
    version: '1.0.0',
    description: '监听 MC-BngeuitBridge 消息：玩家加入/退出通知、状态查询',
    author: 'bngeuit',
    depend: ['BngeuitBridge'],
    softdepend: [],
};

const BridgeMessageReceiveEvent = Packages.cn.org.bukkit.bngeuit.bridge.event.BridgeMessageReceiveEvent;
const BngeuitBridge = Packages.cn.org.bukkit.bngeuit.bridge.BngeuitBridge;

const GroupAtMessageEvent = Packages.cn.org.bukkit.bngeuit.event.receive.GroupAtMessageEvent;

// 在此填写要接收信息的group_openid
// 若不知道，可以在群内 @机器人 后在控制台查看 log 中 (群: xxxx) 字眼
const GROUP_ID = '';

function onLoad() {
    // lifecycle start
}

function onEnable() {
    bngeuit.info('[BngeuitBridge] 事件监听已启用');

    bngeuit.on(BridgeMessageReceiveEvent, (event) => {
        var type = String(event.getType());
        var action = event.getAction() ? String(event.getAction()) : '';

        if (type === 'bridge') {
            handleBridgeStatus(event, action);
        } else if (type === 'mc_event') {
            handleMcEvent(event, action);
        }
    });

    // 群聊 @ 事件，若不需要，可删除 37~42 行
    bngeuit.on(GroupAtMessageEvent, (e) => {
        const text = String(e.getContent()).trim();
        bngeuit.info('GroupAtMessageEvent: ' + text + ' (群: ' + e.getGroupOpenid() + ')');

    });
}

function handleBridgeStatus(event, action) {
    if (action !== 'status') return;

    var msg = event.getMessage();
    var requestId = msg.getRequestId();
    if (!requestId) {
        bngeuit.warn('[BngeuitBridge] 收到 bridge/status 请求但 requestId 为 null，跳过回复');
        return;
    }

    var instance = BngeuitBridge.getInstance();
    var uptimeMs = java.lang.System.currentTimeMillis() - instance.getStartTime();
    var uptimeSec = Math.floor(uptimeMs / 1000);

    var status = new java.util.LinkedHashMap();
    status.put('version', instance.getDescription().getVersion());
    status.put('uptimeSeconds', uptimeSec);
    status.put('connectedClients', instance.getChannel().getConnectedClients().size());
    status.put('clientIds', instance.getChannel().getConnectedClients());

    instance.getChannel().send(event.getClientId(), msg.reply(status));
    bngeuit.info('[BngeuitBridge] 已回复状态查询: clientId=' + event.getClientId() + ', requestId=' + requestId + ', uptime=' + uptimeSec + 's');
}

function handleMcEvent(event, action) {
    var data = event.getData();
    if (!(data instanceof java.util.Map)) {
        bngeuit.warn('[BngeuitBridge] mc_event 的 data 不是 Map: ' + data);
        return;
    }

    var playerName = data.get('player') ? String(data.get('player')) : '未知玩家';
    var uuid = data.get('uuid') ? String(data.get('uuid')) : '';

    if (action === 'player_join') {
        var msg = playerName + ' 加入了游戏';
        bngeuit.info('[BngeuitBridge] 发送加入游戏信息: ' + msg + ' (uuid=' + uuid + ')');
        Bngeuit.sendGroupText(GROUP_ID, msg);
    } else if (action === 'player_quit') {
        var msg = playerName + ' 离开了游戏';
        bngeuit.info('[BngeuitBridge] 发送离开游戏信息: ' + msg + ' (uuid=' + uuid + ')');
        Bngeuit.sendGroupText(GROUP_ID, msg);
    } else {
        bngeuit.info('[BngeuitBridge] 未知 mc_event action: ' + action);
    }
}

function onDisable() {
    bngeuit.info('BridgeEventListener unloaded');
}

const MCBngeuitBridge = Packages.cn.org.bukkit.bngeuit.bridge.MCBngeuitBridge.INSTANCE

function enable() {
    ListenerUtils.registerListener("MCBngeuitBridge:加入信息", "org.bukkit.event.player.PlayerJoinEvent", "HIGHEST", false, function (event) {
        let channel = MCBngeuitBridge.getChannel();
        if (channel == null || !channel.isConnected()) return
        let player = event.getPlayer();
        let data = new java.util.HashMap()
        data.put("player", player.getName())
        channel.send("mc_event", "player_join", data)
    })
    ListenerUtils.registerListener("MCBngeuitBridge:离开信息", "org.bukkit.event.player.PlayerQuitEvent", "HIGHEST", false, function (event) {
        let channel = MCBngeuitBridge.getChannel();
        if (channel == null || !channel.isConnected()) return
        let player = event.getPlayer();
        let data = new java.util.HashMap()
        data.put("player", player.getName())
        channel.send("mc_event", "player_quit", data)
    })
}

function disable() {
    ListenerUtils.unregisterListener("MCBngeuitBridge:加入信息")
    ListenerUtils.unregisterListener("MCBngeuitBridge:离开信息")
}