File size: 4,018 Bytes
3c5c286 0fadeb3 4bf0fdd 1560bc2 3c5c286 4bf0fdd 1560bc2 3c5c286 4bf0fdd 3c5c286 4bf0fdd 0fadeb3 3c5c286 0fadeb3 3c5c286 0fadeb3 3c5c286 | 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 140 141 142 143 144 145 146 147 148 149 150 151 | import fs from 'fs';
import path from 'path';
import { log } from '../utils/logger.js';
import memoryManager, { MemoryPressure } from '../utils/memoryManager.js';
import { getDataDir } from '../utils/paths.js';
import { QUOTA_CACHE_TTL, QUOTA_CLEANUP_INTERVAL } from '../constants/index.js';
class QuotaManager {
/**
* @param {string} filePath - 额度数据文件路径
*/
constructor(filePath = path.join(getDataDir(), 'quotas.json')) {
this.filePath = filePath;
/** @type {Map<string, {lastUpdated: number, models: Object}>} */
this.cache = new Map();
this.CACHE_TTL = QUOTA_CACHE_TTL;
this.CLEANUP_INTERVAL = QUOTA_CLEANUP_INTERVAL;
this.cleanupTimer = null;
this.ensureFileExists();
this.loadFromFile();
this.startCleanupTimer();
this.registerMemoryCleanup();
}
ensureFileExists() {
const dir = path.dirname(this.filePath);
if (!fs.existsSync(dir)) {
fs.mkdirSync(dir, { recursive: true });
}
if (!fs.existsSync(this.filePath)) {
fs.writeFileSync(this.filePath, JSON.stringify({ meta: { lastCleanup: Date.now(), ttl: this.CLEANUP_INTERVAL }, quotas: {} }, null, 2), 'utf8');
}
}
loadFromFile() {
try {
const data = fs.readFileSync(this.filePath, 'utf8');
const parsed = JSON.parse(data);
Object.entries(parsed.quotas || {}).forEach(([key, value]) => {
this.cache.set(key, value);
});
} catch (error) {
log.error('加载额度文件失败:', error.message);
}
}
saveToFile() {
try {
const quotas = {};
this.cache.forEach((value, key) => {
quotas[key] = value;
});
const data = {
meta: { lastCleanup: Date.now(), ttl: this.CLEANUP_INTERVAL },
quotas
};
fs.writeFileSync(this.filePath, JSON.stringify(data, null, 2), 'utf8');
} catch (error) {
log.error('保存额度文件失败:', error.message);
}
}
updateQuota(refreshToken, quotas) {
this.cache.set(refreshToken, {
lastUpdated: Date.now(),
models: quotas
});
this.saveToFile();
}
getQuota(refreshToken) {
const data = this.cache.get(refreshToken);
if (!data) return null;
// 检查缓存是否过期
if (Date.now() - data.lastUpdated > this.CACHE_TTL) {
return null;
}
return data;
}
cleanup() {
const now = Date.now();
let cleaned = 0;
this.cache.forEach((value, key) => {
if (now - value.lastUpdated > this.CLEANUP_INTERVAL) {
this.cache.delete(key);
cleaned++;
}
});
if (cleaned > 0) {
log.info(`清理了 ${cleaned} 个过期的额度记录`);
this.saveToFile();
}
}
startCleanupTimer() {
if (this.cleanupTimer) {
clearInterval(this.cleanupTimer);
}
this.cleanupTimer = setInterval(() => this.cleanup(), this.CLEANUP_INTERVAL);
}
stopCleanupTimer() {
if (this.cleanupTimer) {
clearInterval(this.cleanupTimer);
this.cleanupTimer = null;
}
}
// 注册内存清理回调
registerMemoryCleanup() {
memoryManager.registerCleanup((pressure) => {
// 根据压力级别调整缓存 TTL
if (pressure === MemoryPressure.CRITICAL) {
// 紧急时清理所有缓存
const size = this.cache.size;
if (size > 0) {
this.cache.clear();
log.info(`紧急清理 ${size} 个额度缓存`);
}
} else if (pressure === MemoryPressure.HIGH) {
// 高压力时清理过期缓存
this.cleanup();
}
});
}
convertToBeijingTime(utcTimeStr) {
if (!utcTimeStr) return 'N/A';
try {
const utcDate = new Date(utcTimeStr);
return utcDate.toLocaleString('zh-CN', {
month: '2-digit',
day: '2-digit',
hour: '2-digit',
minute: '2-digit',
timeZone: 'Asia/Shanghai'
});
} catch (error) {
return 'N/A';
}
}
}
const quotaManager = new QuotaManager();
export default quotaManager;
|