Discord.js 交互收集器的高效管理与“未知交互”错误规避

const filter = i => i.user.id === interaction.user.id && i.isButton();
const collector = interaction.channel.createMessageComponentCollector({ filter, time: 30000 }); // 30秒后自动结束

collector.on('collect', async i => {
  // 处理收集到的交互
  await i.update({ content: '你点击了按钮！', components: [] });
});

collector.on('end', collected => {
  console.log(`收集器结束，共收集到 ${collected.size} 个交互。`);
});

/**
 * 创建一个消息组件收集器，确保只处理一次指定 customId 的按钮交互。
 * @param {import('discord.js').Interaction} interaction - 触发此收集器的原始交互。
 * @param {string} customId - 收集器要监听的按钮的 customId。
 * @param {Function} executeFunction - 收集到交互时执行的函数。
 */
async function createSingleUseCollector(interaction, customId, executeFunction) {
  let hasRun = false; // 局部变量，标记此收集器是否已处理过交互

  const filter = i => 
    i.user.id === interaction.user.id && // 确保是同一用户
    i.isButton() && // 确保是按钮交互
    i.customId === customId && // 确保是指定按钮
    !hasRun; // 关键：只有在尚未执行过时才处理

  const collector = interaction.channel.createMessageComponentCollector({ filter, time: 30000 });

  collector.on('collect', async i => {
    if (!hasRun) { // 双重检查，确保只执行一次
      hasRun = true; // 标记为已执行
      // 在执行业务逻辑前，务必对交互进行延迟更新，以避免“未知交互”错误
      if (!i.deferred && !i.replied) {
        await i.deferUpdate(); 
      }
      await executeFunction(i); // 执行业务逻辑
      collector.stop(); // 收集到一次后立即停止此收集器
    }
  });

  collector.on('end', collected => {
    console.log(`单次收集器 for 按钮 ${customId} 结束。收集到 ${collected.size} 个元素。`);
  });
}

const { SlashCommandBuilder } = require('@discordjs/builders');
const {
  ActionRowBuilder,
  ButtonBuilder,
  EmbedBuilder,
  ButtonStyle,
} = require('discord.js');

// 导入你的按钮处理模块
const muteButton = require('../../buttons/moderates/muteButton.js');
// ... 其他按钮模块

// 使用 Map 来存储活跃的收集器，键可以是用户ID或频道ID+用户ID
// 这样可以确保每个用户或每个会话只有一个活跃的管理面板收集器
const activeCollectors = new Map(); 

module.exports = {
  data: new SlashCommandBuilder()
    .setName('moderate')
    .setDescription('提供一个管理员面板，包含禁言、解除禁言、警告等操作。'),
  async execute(interaction) {
    const member = interaction.member;
    const moderatorRole = member.roles.cache.find(r => r.name === 'Модератор');
    if (!moderatorRole) {
      return interaction.reply({ content: '您不是管理员，无权使用此命令。', ephemeral: true });
    }

    // --- 全局收集器管理逻辑 ---
    // 为当前交互定义一个唯一的收集器键，例如使用用户的ID
    const collectorKey = interaction.user.id; 

    // 如果该用户已经有一个活跃的收集器，则先停止它
    if (activeCollectors.has(collectorKey)) {
      const oldCollector = activeCollectors.get(collectorKey);
      if (!oldCollector.ended) { // 检查收集器是否已经结束
        oldCollector.stop('new_command_initiated'); // 停止旧收集器，提供一个原因
        console.log(`停止了用户 ${collectorKey} 的旧收集器。`);
      }
      activeCollectors.delete(collectorKey); // 从 Map 中移除
    }
    // --- 结束全局收集器管理逻辑 ---

    // 构建按钮和嵌入消息... (与你原代码相同)
    const row = new ActionRowBuilder()
      .addComponents(
        new ButtonBuilder().setCustomId('mute').setEmoji('?').setStyle(ButtonStyle.Secondary),
        new ButtonBuilder().setCustomId('unmute').setEmoji('?').setStyle(ButtonStyle.Secondary),
        new ButtonBuilder().setCustomId('warn').setEmoji('⚠️').setStyle(ButtonStyle.Secondary),
        new ButtonBuilder().setCustomId('unwarn').setEmoji('❌').setStyle(ButtonStyle.Secondary)
      );

    const row1 = new ActionRowBuilder()
      .addComponents(
        new ButtonBuilder().setCustomId('raiting').setEmoji('✅').setStyle(ButtonStyle.Secondary),
        new ButtonBuilder().setCustomId('unraiting').setEmoji('❎').setStyle(ButtonStyle.Secondary),
        new ButtonBuilder().setCustomId('listraiting').setEmoji('?').setStyle(ButtonStyle.Secondary),
        new ButtonBuilder().setCustomId('infractions').setEmoji('?').setStyle(ButtonStyle.Secondary)
      );

    const embed = new EmbedBuilder()
      .setColor(0x000000)
      .setTitle('管理员面板')
      .setDescription(`**服务器管理操作。**\n\n**第一行按钮：**\n\n? — 禁言成员\n? — 解除成员禁言\n⚠️ — 警告成员\n❌ — 撤销成员警告\n\n**第二行按钮：**\n\n✅ — 授予成员评分角色\n❎ — 移除成员评分角色\n? — 查看有评分角色的成员列表\n? — 查看成员违规历史`);

    // 延迟回复，确保在3秒内响应
    await interaction.deferReply({ ephemeral: false }); 
    const message = await interaction.followUp({ 
      embeds: [embed], 
      components: [row, row1], 
      ephemeral: false 
    });

    // 创建新的收集器并存储
    const filter = i => i.user.id === interaction.user.id;
    const currentPanelCollector = message.createMessageComponentCollector({ filter, time: 300000 }); // 延长收集器时间，例如5分钟

    activeCollectors.set(collectorKey, currentPanelCollector); // 将新收集器添加到 Map 中

    currentPanelCollector.on('collect', async i => {
      // 在处理按钮点击前，务必进行延迟更新
      // 这是为了防止按钮处理逻辑耗时过长导致“未知交互”
      if (!i.deferred && !i.replied) {
        await i.deferUpdate(); 
      }

      try {
        switch (i.customId) {
          case 'mute':
            await muteButton.execute(i);
            break;
          case 'unmute':
            await unMuteButton.execute(i);
            break;
          // ... 其他按钮的 case
          default:
            console.log(`未知按钮 customId: ${i.customId}`);
            break;
        }
      } catch (error) {
        console.error(`处理按钮 ${i.customId} 时发生错误:`, error);
        // 可以向用户发送一个错误消息
        if (!i.replied) {
          await i.followUp({ content: '处理您的请求时发生错误。', ephemeral: true });
        }
      }
    });

    currentPanelCollector.on('end', (collected