Class FeishuEventHandler

src/feishu/handler.ts:20–325

}

export class FeishuEventHandler {
  private client: FeishuClient;
  private nativeClient: Lark.Client;
  private eventDispatcher: Lark.EventDispatcher;
  private wsClient: Lark.WSClient | null = null;
  private config: FeishuConfig;
  private options: FeishuEventHandlerOptions;
  private botOpenId: string | null = null;
  private processedMessageIds: Set<string> = new Set(); // 消息去重
  private readonly maxProcessedMessages = 5000; // 最多缓存 5000 条消息 ID
  private serviceStartTime: number = Date.now(); // 服务启动时间，用于忽略历史消息
  private processedIdsPath: string = './data/processed_ids.json';
  private saveInterval: NodeJS.Timeout | null = null;

  constructor(config: FeishuConfig, options: FeishuEventHandlerOptions = {}) {
    this.config = config;
    this.client = new FeishuClient(config);
    this.nativeClient = this.client.getNativeClient();
    this.options = options;
    this.eventDispatcher = new Lark.EventDispatcher({
      encryptKey: config.encryptKey,
      verificationToken: config.verificationToken,
    });

    // 加载已处理的消息 ID
    this.loadProcessedIds();

    this.setupEventHandlers();
  }

  /**
   * 从文件加载已处理的消息 ID
   */
  private loadProcessedIds(): void {
    try {
      if (fs.existsSync(this.processedIdsPath)) {
        const data = fs.readFileSync(this.processedIdsPath, 'utf-8');
        const ids = JSON.parse(data) as string[];
        for (const id of ids) {
          this.processedMessageIds.add(id);
        }
        logger.info(`Loaded ${this.processedMessageIds.size} processed message IDs from cache`);
      }
    } catch (error) {
      logger.warn('Failed to load processed message IDs', { error });
    }
  }

  /**
   * 保存已处理的消息 ID 到文件
   */
  private saveProcessedIds(): void {
    try {
      const dir = path.dirname(this.processedIdsPath);
      if (!fs.existsSync(dir)) {
        fs.mkdirSync(dir, { recursive: true });
      }
      const ids = Array.from(this.processedMessageIds);