* 从文件加载已处理的消息 ID
()
| 51 | * 从文件加载已处理的消息 ID |
| 52 | */ |
| 53 | private loadProcessedIds(): void { |
| 54 | try { |
| 55 | if (fs.existsSync(this.processedIdsPath)) { |
| 56 | const data = fs.readFileSync(this.processedIdsPath, 'utf-8'); |
| 57 | const ids = JSON.parse(data) as string[]; |
| 58 | for (const id of ids) { |
| 59 | this.processedMessageIds.add(id); |
| 60 | } |
| 61 | logger.info(`Loaded ${this.processedMessageIds.size} processed message IDs from cache`); |
| 62 | } |
| 63 | } catch (error) { |
| 64 | logger.warn('Failed to load processed message IDs', { error }); |
| 65 | } |
| 66 | } |
| 67 | |
| 68 | /** |
| 69 | * 保存已处理的消息 ID 到文件 |