From 0f7e4e19e007bd2f5fe82a43a7e112e244e6992d Mon Sep 17 00:00:00 2001 From: axibayuit Date: Mon, 29 Dec 2025 23:23:21 +0800 Subject: [PATCH] =?UTF-8?q?refactor:=20=E7=A7=BB=E9=99=A4=E4=B8=8D?= =?UTF-8?q?=E5=86=8D=E4=BD=BF=E7=94=A8=E7=9A=84=20updateQuotaCounter=20?= =?UTF-8?q?=E5=87=BD=E6=95=B0?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- functions/upload/uploadTools.js | 33 --------------------------------- 1 file changed, 33 deletions(-) diff --git a/functions/upload/uploadTools.js b/functions/upload/uploadTools.js index 252e4c6..87a15f0 100644 --- a/functions/upload/uploadTools.js +++ b/functions/upload/uploadTools.js @@ -191,39 +191,6 @@ export async function endUpload(context, fileId, metadata) { await addFileToIndex(context, fileId, metadata); } -/** - * 更新渠道容量计数器 - * @param {Object} env - 环境变量 - * @param {string} channelName - 渠道名称 - * @param {string|number} fileSizeMB - 文件大小(MB) - * @param {string} operation - 操作类型: 'add' 或 'subtract' - */ -export async function updateQuotaCounter(env, channelName, fileSizeMB, operation) { - if (!channelName) return; - - try { - const db = getDatabase(env); - const quotaKey = `manage@quota@${channelName}`; - const quotaData = await db.get(quotaKey); - const quota = quotaData ? JSON.parse(quotaData) : { usedMB: 0, fileCount: 0 }; - - const sizeMB = parseFloat(fileSizeMB) || 0; - - if (operation === 'add') { - quota.usedMB += sizeMB; - quota.fileCount += 1; - } else if (operation === 'subtract') { - quota.usedMB = Math.max(0, quota.usedMB - sizeMB); - quota.fileCount = Math.max(0, quota.fileCount - 1); - } - - quota.lastUpdated = Date.now(); - await db.put(quotaKey, JSON.stringify(quota)); - } catch (error) { - console.error(`Failed to update quota counter for ${channelName}:`, error); - } -} - // 从 request 中解析 ip 地址 export function getUploadIp(request) { const ip = request.headers.get("cf-connecting-ip") || request.headers.get("x-real-ip") || request.headers.get("x-forwarded-for") || request.headers.get("x-client-ip") || request.headers.get("x-host") || request.headers.get("x-originating-ip") || request.headers.get("x-cluster-client-ip") || request.headers.get("forwarded-for") || request.headers.get("forwarded") || request.headers.get("via") || request.headers.get("requester") || request.headers.get("true-client-ip") || request.headers.get("client-ip") || request.headers.get("x-remote-ip") || request.headers.get("x-originating-ip") || request.headers.get("fastly-client-ip") || request.headers.get("akamai-origin-hop") || request.headers.get("x-remote-addr") || request.headers.get("x-remote-host") || request.headers.get("x-client-ips")