* 保存已处理的消息 ID 到文件
()
| 69 | * 保存已处理的消息 ID 到文件 |
| 70 | */ |
| 71 | private saveProcessedIds(): void { |
| 72 | try { |
| 73 | const dir = path.dirname(this.processedIdsPath); |
| 74 | if (!fs.existsSync(dir)) { |
| 75 | fs.mkdirSync(dir, { recursive: true }); |
| 76 | } |
| 77 | const ids = Array.from(this.processedMessageIds); |
| 78 | fs.writeFileSync(this.processedIdsPath, JSON.stringify(ids, null, 2)); |
| 79 | } catch (error) { |
| 80 | logger.error('Failed to save processed message IDs', { error }); |
| 81 | } |
| 82 | } |
| 83 | |
| 84 | /** |
| 85 | * 获取事件处理器 |
no outgoing calls
no test coverage detected