Class LuBsPlugin

lu_bs/lu_bs.ts:38–374

    this.db = null;
    this.stickerSet = null;
  }

  async setup(): Promise<void> {
    await this.initDB();
    await this.loadStickerSet();
  }

  private db: any = null;
  private stickerSet: any = null;
  private readonly PLUGIN_NAME = "lu_bs";
  
  description = HELP_TEXT;
  
  // 定时任务 - 每小时整点执行
  cronTasks = {
    hourlyReport: {
      cron: "0 * * * *", // 每小时整点
      description: "鲁小迅整点报时",
      handler: async (client: any) => {
        await this.sendHourlyStickers(client);
      }
    }
  };

  constructor() {
    super();
  }

  // 初始化数据库
  private async initDB() {
    const dbPath = path.join(createDirectoryInAssets(this.PLUGIN_NAME), "subscriptions.json");
    this.db = await JSONFilePreset(dbPath, { 
      subscriptions: [],
      lastMessages: {} // 存储最后发送的消息ID，用于删除
    });
  }

  // 加载贴纸包
  private async loadStickerSet() {
    try {
      const client = await getGlobalClient();
      if (!client) return;

      // 使用Telegram原始API获取贴纸包
      this.stickerSet = await client.invoke(
        new Api.messages.GetStickerSet({
          stickerset: new Api.InputStickerSetShortName({
            shortName: "luxiaoxunbs"
          }),
          hash: 0
        })
      );
      
      console.log(`[${this.PLUGIN_NAME}] 贴纸包加载成功`);
    } catch (error) {
      console.error(`[${this.PLUGIN_NAME}] 贴纸包加载失败:`, error);
      this.stickerSet = null;
    }