Class ImageMonitorPlugin

im/im.ts:183–593

// ==================== 主插件类 ====================
class ImageMonitorPlugin extends Plugin {
  description: string = HELP_TEXT;

  cmdHandlers: Record<string, (msg: Api.Message) => Promise<void>> = {
    im: this.handleConfigCommand.bind(this),
  };

  constructor() {
    super();
    this.initialize();
  }

  private async initialize() {
    await ConfigManager.init();
    console.log("[image_monitor] Plugin initialized");
  }

  // 消息监听器 - TeleBox会自动调用这个方法
  listenMessageHandler = async (msg: Api.Message, options?: { isEdited?: boolean }) => {
    const client = await getGlobalClient();
    if (!client) return;

    // 获取有效的命令前缀
    const prefixes = getPrefixes();
    const text = msg.text || "";
    const commandParts = text.split(" ");
    const command = commandParts[0].toLowerCase();
    const subCommand = commandParts[1]?.toLowerCase();

    // 检查是否为有效的.im命令（必须以正确前缀开头）
    const isValidImCommand = prefixes.some(prefix => command === `${prefix}im`);
    
    if (msg.isReply && isValidImCommand) {
        const repliedMsg = await msg.getReplyMessage();
        if (!repliedMsg) {
            await MessageManager.edit(msg, "❌ 未找到被回复的消息。");
            return;
        }

        const config = await ConfigManager.getConfig();
        if (!config.bannedStickerIds) config.bannedStickerIds = {};
        const action = (subCommand === 'ban' || subCommand === 'delete') ? subCommand as Action : config.defaultAction;

        const media = repliedMsg.media;
        if (!media) {
            await MessageManager.edit(msg, "❌ 该回复不是图片、媒体或贴纸。请回复包含图片/媒体/贴纸的消息后再使用 <code>.im</code>。");
            return;
        }

        try {
            if (media instanceof Api.MessageMediaDocument) {
                const docRaw = media.document;
                if (docRaw instanceof Api.Document) {
                    const isSticker = Array.isArray(docRaw.attributes) && docRaw.attributes.some(a => a instanceof Api.DocumentAttributeSticker);
                    if (isSticker) {
                        const stickerId = String(docRaw.id);
                        config.bannedStickerIds[stickerId] = action;
                        await ConfigManager.saveConfig();
                        await MessageManager.edit(msg, `✅ 已添加贴纸ID: <code>${htmlEscape(stickerId)}</code>，操作: <code>${action}</code>`);