Class TmpAdminPlugin

tmp_admin/tmp_admin.ts:350–1001

  constructor() {
    super();
    this.restorePromise = this.restoreJobs().catch((error) => {
      if (String(error?.message || error).includes("runtime is not initialized")) return;
      console.error("[tmp_admin] 恢复临时管理员任务失败:", error);
    });
  }

  cleanup(): void {
    for (const job of this.jobs.values()) {
      if (job.timer) clearTimeout(job.timer);
    }
    this.jobs.clear();
  }

  description: string = `\n临时管理员\n\n${helpText}`;

  cmdHandlers: Record<
    string,
    (msg: Api.Message, trigger?: Api.Message) => Promise<void>
  > = {
    tmp_admin: async (msg: Api.Message, trigger?: Api.Message) => {
      await this.restorePromise;
      const parts = (msg.message || "").trim().split(/\s+/).filter(Boolean);
      const sub = (parts[1] || "").toLowerCase();

      if (["help", "h"].includes(sub)) {
        await respondToCommand(msg, trigger, { text: helpText, parseMode: "html" });
        return;
      }

      const isInChannel = (msg as any).isChannel;
      if (!isInChannel) {
        await respondToCommand(msg, trigger, {
          text: `请在超级群/频道中使用 <code>${commandName}</code> 命令`,
          parseMode: "html",
        });
        return;
      }

      const channel = await msg.getInputChat();
      const chatEntity = await msg.getChat();
      if (!channel || !(chatEntity instanceof Api.Channel)) {
        await respondToCommand(msg, trigger, { text: "无法获取当前超级群/频道实体" });
        return;
      }
      const chatKey = getChatKey(chatEntity, msg);

      if (["ls", "list"].includes(sub)) {
        await this.listJobs(msg, trigger, chatKey);
        return;
      }

      if (["rm", "remove", "del"].includes(sub)) {
        const targetSourceMsg = getTargetSourceMessage(msg, trigger);
        const targetArg = messageHasReply(targetSourceMsg) ? undefined : parts[2];
        await this.removeTemporaryAdmin({
          msg,
          targetSourceMsg,