src/utils/cacheMonitor.js

/**
 * 缓存监控和管理工具
 * 提供统一的缓存监控、统计和安全清理功能
 */

const logger = require('./logger')
const crypto = require('crypto')

class CacheMonitor {
  constructor() {
    this.monitors = new Map() // 存储所有被监控的缓存实例
    this.startTime = Date.now()
    this.totalHits = 0
    this.totalMisses = 0
    this.totalEvictions = 0

    // 🔒 安全配置
    this.securityConfig = {
      maxCacheAge: 15 * 60 * 1000, // 最大缓存年龄 15 分钟
      forceCleanupInterval: 30 * 60 * 1000, // 强制清理间隔 30 分钟
      memoryThreshold: 100 * 1024 * 1024, // 内存阈值 100MB
      sensitiveDataPatterns: [/password/i, /token/i, /secret/i, /key/i, /credential/i]
    }

    // 🧹 定期执行安全清理
    this.setupSecurityCleanup()

    // 📊 定期报告统计信息
    this.setupPeriodicReporting()
  }

  /**
   * 注册缓存实例进行监控
   * @param {string} name - 缓存名称
   * @param {LRUCache} cache - 缓存实例
   */
  registerCache(name, cache) {
    if (this.monitors.has(name)) {
      logger.warn(`⚠️ Cache ${name} is already registered, updating reference`)
    }

    this.monitors.set(name, {
      cache,
      registeredAt: Date.now(),
      lastCleanup: Date.now(),
      totalCleanups: 0
    })

    logger.info(`📦 Registered cache for monitoring: ${name}`)
  }

  /**
   * 获取所有缓存的综合统计
   */
  getGlobalStats() {
    const stats = {
      uptime: Math.floor((Date.now() - this.startTime) / 1000), // 秒
      cacheCount: this.monitors.size,
      totalSize: 0,
      totalHits: 0,
      totalMisses: 0,
      totalEvictions: 0,
      averageHitRate: 0,
      caches: {}
    }

    for (const [name, monitor] of this.monitors) {
      const cacheStats = monitor.cache.getStats()
      stats.totalSize += cacheStats.size
      stats.totalHits += cacheStats.hits
      stats.totalMisses += cacheStats.misses
      stats.totalEvictions += cacheStats.evictions

      stats.caches[name] = {
        ...cacheStats,
        lastCleanup: new Date(monitor.lastCleanup).toISOString(),
        totalCleanups: monitor.totalCleanups,
        age: Math.floor((Date.now() - monitor.registeredAt) / 1000) // 秒
      }
    }

    const totalRequests = stats.totalHits + stats.totalMisses
    stats.averageHitRate =
      totalRequests > 0 ? `${((stats.totalHits / totalRequests) * 100).toFixed(2)}%` : '0%'

    return stats
  }

  /**
   * 🔒 执行安全清理
   * 清理过期数据和潜在的敏感信息
   */
  performSecurityCleanup() {
    logger.info('🔒 Starting security cleanup for all caches')

    for (const [name, monitor] of this.monitors) {
      try {
        const { cache } = monitor
        const beforeSize = cache.cache.size

        // 执行常规清理
        cache.cleanup()

        // 检查缓存年龄，如果太老则完全清空
        const cacheAge = Date.now() - monitor.registeredAt
        if (cacheAge > this.securityConfig.maxCacheAge * 2) {
          logger.warn(
            `⚠️ Cache ${name} is too old (${Math.floor(cacheAge / 60000)}min), performing full clear`
          )
          cache.clear()
        }

        monitor.lastCleanup = Date.now()
        monitor.totalCleanups++

        const afterSize = cache.cache.size
        if (beforeSize !== afterSize) {
          logger.info(`🧹 Cache ${name}: Cleaned ${beforeSize - afterSize} items`)
        }
      } catch (error) {
        logger.error(`❌ Error cleaning cache ${name}:`, error)
      }
    }
  }

  /**
   * 📊 生成详细报告
   */
  generateReport() {
    const stats = this.getGlobalStats()

    logger.info('═══════════════════════════════════════════')
    logger.info('📊 Cache System Performance Report')
    logger.info('═══════════════════════════════════════════')
    logger.info(`⏱️  Uptime: ${this.formatUptime(stats.uptime)}`)
    logger.info(`📦 Active Caches: ${stats.cacheCount}`)
    logger.info(`📈 Total Cache Size: ${stats.totalSize} items`)
    logger.info(`🎯 Global Hit Rate: ${stats.averageHitRate}`)
    logger.info(`✅ Total Hits: ${stats.totalHits.toLocaleString()}`)
    logger.info(`❌ Total Misses: ${stats.totalMisses.toLocaleString()}`)
    logger.info(`🗑️  Total Evictions: ${stats.totalEvictions.toLocaleString()}`)
    logger.info('───────────────────────────────────────────')

    // 详细的每个缓存统计
    for (const [name, cacheStats] of Object.entries(stats.caches)) {
      logger.info(`\n📦 ${name}:`)
      logger.info(
        `   Size: ${cacheStats.size}/${cacheStats.maxSize} | Hit Rate: ${cacheStats.hitRate}`
      )
      logger.info(
        `   Hits: ${cacheStats.hits} | Misses: ${cacheStats.misses} | Evictions: ${cacheStats.evictions}`
      )
      logger.info(
        `   Age: ${this.formatUptime(cacheStats.age)} | Cleanups: ${cacheStats.totalCleanups}`
      )
    }
    logger.info('═══════════════════════════════════════════')
  }

  /**
   * 🧹 设置定期安全清理
   */
  setupSecurityCleanup() {
    // 每 10 分钟执行一次安全清理
    setInterval(
      () => {
        this.performSecurityCleanup()
      },
      10 * 60 * 1000
    )

    // 每 30 分钟强制完整清理
    setInterval(() => {
      logger.warn('⚠️ Performing forced complete cleanup for security')
      for (const [name, monitor] of this.monitors) {
        monitor.cache.clear()
        logger.info(`🗑️ Force cleared cache: ${name}`)
      }
    }, this.securityConfig.forceCleanupInterval)
  }

  /**
   * 📊 设置定期报告
   */
  setupPeriodicReporting() {
    // 每 5 分钟生成一次简单统计
    setInterval(
      () => {
        const stats = this.getGlobalStats()
        logger.info(
          `📊 Quick Stats - Caches: ${stats.cacheCount}, Size: ${stats.totalSize}, Hit Rate: ${stats.averageHitRate}`
        )
      },
      5 * 60 * 1000
    )

    // 每 30 分钟生成一次详细报告
    setInterval(
      () => {
        this.generateReport()
      },
      30 * 60 * 1000
    )
  }

  /**
   * 格式化运行时间
   */
  formatUptime(seconds) {
    const hours = Math.floor(seconds / 3600)
    const minutes = Math.floor((seconds % 3600) / 60)
    const secs = seconds % 60

    if (hours > 0) {
      return `${hours}h ${minutes}m ${secs}s`
    } else if (minutes > 0) {
      return `${minutes}m ${secs}s`
    } else {
      return `${secs}s`
    }
  }

  /**
   * 🔐 生成安全的缓存键
   * 使用 SHA-256 哈希避免暴露原始数据
   */
  static generateSecureCacheKey(data) {
    return crypto.createHash('sha256').update(data).digest('hex')
  }

  /**
   * 🛡️ 验证缓存数据安全性
   * 检查是否包含敏感信息
   */
  validateCacheSecurity(data) {
    const dataStr = typeof data === 'string' ? data : JSON.stringify(data)

    for (const pattern of this.securityConfig.sensitiveDataPatterns) {
      if (pattern.test(dataStr)) {
        logger.warn('⚠️ Potential sensitive data detected in cache')
        return false
      }
    }

    return true
  }

  /**
   * 💾 获取内存使用估算
   */
  estimateMemoryUsage() {
    let totalBytes = 0

    for (const [, monitor] of this.monitors) {
      const { cache } = monitor.cache
      for (const [key, item] of cache) {
        // 粗略估算：key 长度 + value 序列化长度
        totalBytes += key.length * 2 // UTF-16
        totalBytes += JSON.stringify(item).length * 2
      }
    }

    return {
      bytes: totalBytes,
      mb: (totalBytes / (1024 * 1024)).toFixed(2),
      warning: totalBytes > this.securityConfig.memoryThreshold
    }
  }

  /**
   * 🚨 紧急清理
   * 在内存压力大时使用
   */
  emergencyCleanup() {
    logger.error('🚨 EMERGENCY CLEANUP INITIATED')

    for (const [name, monitor] of this.monitors) {
      const { cache } = monitor
      const beforeSize = cache.cache.size

      // 清理一半的缓存项（LRU 会保留最近使用的）
      const targetSize = Math.floor(cache.maxSize / 2)
      while (cache.cache.size > targetSize) {
        const firstKey = cache.cache.keys().next().value
        cache.cache.delete(firstKey)
      }

      logger.warn(`🚨 Emergency cleaned ${name}: ${beforeSize} -> ${cache.cache.size} items`)
    }
  }
}

// 导出单例
module.exports = new CacheMonitor()