Class DataPersistence

src/utils/data-persistence.js:14–354

const STATS_PERSIST_DEBOUNCE_MS = 5000
// 备份（data.json.bak）最小刷新间隔——不必每次落盘都多写一份
const BACKUP_MIN_INTERVAL_MS = 5 * 60 * 1000
// rename 重试间隔：Windows / 网络盘上目标文件被占用时可能短暂 EPERM / EBUSY
const RENAME_RETRY_DELAYS_MS = [20, 50, 100]

// 进程内串行化：所有对 data.json 的 read-modify-write 排队执行。
// 队列必须是模块级的——进程里存在多个 DataPersistence 实例
// （utils/account.js 一个、routes/settings.js 一个），实例级的锁挡不住并发。
// 注：PM2 cluster（PM2_INSTANCES > 1）下跨进程仍可能「后写覆盖先写」丢一次统计，
// 但原子 rename 保证任何时刻文件都是完整 JSON，不会再出现半截内容。
let fileWriteQueue = Promise.resolve()
let tmpFileCounter = 0
let lastBackupAt = 0

/**
 * 把一次文件读写排入串行队列
 * @param {Function} task - 返回 Promise 的任务
 * @returns {Promise<*>} 任务结果
 */
const enqueueFileTask = (task) => {
  const result = fileWriteQueue.then(task, task)
  // 队列本身不能因为单次失败而中断
  fileWriteQueue = result.then(() => { }, () => { })
  return result
}

const sleep = (ms) => new Promise(resolve => setTimeout(resolve, ms))

class DataPersistence {
  constructor() {
    this.dataFilePath = path.join(__dirname, '../../data/data.json')
    // 最近一次「解析成功」的快照，用于文件损坏时自愈
    this.backupFilePath = `${this.dataFilePath}.bak`
    // 每个 email 的待持久化 stats 与定时器（debounce）
    this._statsPersistTimers = new Map()
    this._statsPendingPayload = new Map()
  }

  /**
   * 加载所有账户数据
   * @returns {Promise<Array>} 账户列表
   */
  async loadAccounts() {
    try {
      switch (config.dataSaveMode) {
        case 'redis':
          return await this._loadFromRedis()
        case 'file':
          return await this._loadFromFile()
        case 'none':
          return await this._loadFromEnv()
        default:
          logger.error(`不支持的数据保存模式: ${config.dataSaveMode}`, 'DATA')
          throw new Error(`不支持的数据保存模式: ${config.dataSaveMode}`)
      }
    } catch (error) {
      logger.error('加载账户数据失败', 'DATA', '', error)
      throw error
    }