bingshuo
/
zhizhi
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Merge pull request #315 from qinfendebingshuo/copilot/fix-vpn-mail-sending-error 

Fix VPN email sending, add acceleration status panel, Claude专线 dropdown, and subscription refresh UX
This commit is contained in:
冰朔 2026-04-08 11:48:42 +08:00 committed by GitHub
parent 4a2b1c94c5 ca1d75494d
commit 5e690e6132
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
2 changed files with 228 additions and 90 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

140
server/proxy/service/email-hub.js
View File

@ -176,96 +176,94 @@ async function sendEmail(to, subject, htmlBody) {
return new Promise((resolve, reject) => { return new Promise((resolve, reject) => {
let settled = false; let settled = false;
let socket;
const settle = (fn, val) => {
if (settled) return;
settled = true;
clearTimeout(timeoutId);
try { if (socket) socket.destroy(); } catch { /* ignore */ }
fn(val);
};
const timeoutId = setTimeout(() => { const timeoutId = setTimeout(() => {
if (!settled) { settle(reject, new Error(`SMTP超时(30s) → ${smtpHost}:${smtpPort}`));
settled = true;
try { socket.destroy(); } catch { /* ignore */ }
reject(new Error('SMTP超时(30s)'));
}
}, 30000); }, 30000);
const socket = tls.connect(smtpPort, smtpHost, {}, () => { try {
let step = 0; socket = tls.connect(smtpPort, smtpHost, {}, () => {
let buffer = ''; let step = 0;
const from = config.smtp_user; let buffer = '';
const from = config.smtp_user;
const commands = [ const commands = [
`EHLO zy-proxy\r\n`, `EHLO zy-proxy\r\n`,
`AUTH LOGIN\r\n`, `AUTH LOGIN\r\n`,
`${Buffer.from(from).toString('base64')}\r\n`, `${Buffer.from(from).toString('base64')}\r\n`,
`${Buffer.from(config.smtp_pass).toString('base64')}\r\n`, `${Buffer.from(config.smtp_pass).toString('base64')}\r\n`,
`MAIL FROM:<${from}>\r\n`, `MAIL FROM:<${from}>\r\n`,
`RCPT TO:<${to}>\r\n`, `RCPT TO:<${to}>\r\n`,
`DATA\r\n`, `DATA\r\n`,
`From: =?UTF-8?B?${Buffer.from('光湖语言世界').toString('base64')}?= <${from}>\r\nTo: <${to}>\r\nSubject: =?UTF-8?B?${Buffer.from(subject).toString('base64')}?=\r\nContent-Type: text/html; charset=utf-8\r\nMIME-Version: 1.0\r\n\r\n${htmlBody}\r\n.\r\n`, `From: =?UTF-8?B?${Buffer.from('光湖语言世界').toString('base64')}?= <${from}>\r\nTo: <${to}>\r\nSubject: =?UTF-8?B?${Buffer.from(subject).toString('base64')}?=\r\nContent-Type: text/html; charset=utf-8\r\nMIME-Version: 1.0\r\n\r\n${htmlBody}\r\n.\r\n`,
`QUIT\r\n` `QUIT\r\n`
]; ];
// SMTP多行响应正确处理: // SMTP多行响应正确处理:
// 多行响应格式: "250-xxx\r\n" (中间行用减号), 最终行: "250 xxx\r\n" (用空格) // 多行响应格式: "250-xxx\r\n" (中间行用减号), 最终行: "250 xxx\r\n" (用空格)
// 只有收到最终行(NNN + 空格)时才发送下一条命令 // 只有收到最终行(NNN + 空格)时才发送下一条命令
socket.on('data', (chunk) => { socket.on('data', (chunk) => {
buffer += chunk.toString(); buffer += chunk.toString();
// 逐行处理完整的SMTP响应 // 逐行处理完整的SMTP响应
while (buffer.includes('\r\n')) { while (buffer.includes('\r\n')) {
const lineEnd = buffer.indexOf('\r\n'); const lineEnd = buffer.indexOf('\r\n');
const line = buffer.substring(0, lineEnd); const line = buffer.substring(0, lineEnd);
buffer = buffer.substring(lineEnd + 2); buffer = buffer.substring(lineEnd + 2);
// 检查是否为最终响应行 (NNN + 空格 或 NNN 结束) // 检查是否为最终响应行 (NNN + 空格 或 NNN 结束)
const match = line.match(/^(\d{3})([ -])/); const match = line.match(/^(\d{3})([ -])/);
if (!match) continue; if (!match) continue;
const statusCode = parseInt(match[1], 10); const statusCode = parseInt(match[1], 10);
const isFinal = match[2] === ' '; // 空格=最终行, 减号=还有后续行 const isFinal = match[2] === ' '; // 空格=最终行, 减号=还有后续行
if (!isFinal) continue; // 多行响应中间行，等待最终行 if (!isFinal) continue; // 多行响应中间行，等待最终行
// 检查错误响应 (4xx/5xx) // 检查错误响应 (4xx/5xx)
if (statusCode >= 400) { if (statusCode >= 400) {
if (!settled) { settle(reject, new Error(`SMTP错误(${statusCode}): ${line}`));
settled = true; return;
clearTimeout(timeoutId);
try { socket.destroy(); } catch { /* ignore */ }
reject(new Error(`SMTP错误(${statusCode}): ${line}`));
} }
return;
}
// 发送下一条命令 // 发送下一条命令
if (step < commands.length) { if (step < commands.length) {
socket.write(commands[step]); socket.write(commands[step]);
step++; step++;
} }
// 所有命令已发送且收到最终响应 // 所有命令已发送且收到最终响应
if (step >= commands.length && !settled) { if (step >= commands.length) {
settled = true; settle(resolve, true);
clearTimeout(timeoutId); return;
try { socket.destroy(); } catch { /* ignore */ } }
resolve(true);
return;
} }
} });
}); });
// 连接级错误 (DNS解析失败/连接拒绝/TLS握手失败)
// 必须在connect callback外部注册，否则连接失败时handler不触发
socket.on('error', (err) => { socket.on('error', (err) => {
settle(reject, new Error(`SMTP连接失败(${smtpHost}): ${err.message}`));
});
socket.on('close', () => {
if (!settled) { if (!settled) {
settled = true; settle(reject, new Error(`SMTP连接被关闭(${smtpHost})`));
clearTimeout(timeoutId);
reject(err);
} }
}); });
}); } catch (err) {
settle(reject, new Error(`SMTP初始化失败: ${err.message}`));
socket.on('error', (err) => { }
if (!settled) {
settled = true;
clearTimeout(timeoutId);
reject(err);
}
});
}); });
} }
@ -1064,7 +1062,7 @@ async function sendBandwidthAuthEmail(email, code) {
} catch (err) { } catch (err) {
console.error(`[邮件中枢] ❌ 带宽验证码发送失败: ${err.message}`); console.error(`[邮件中枢] ❌ 带宽验证码发送失败: ${err.message}`);
logEmail('bandwidth-auth', email, false, err.message); logEmail('bandwidth-auth', email, false, err.message);
return { sent: 0, failed: 1 }; return { sent: 0, failed: 1, error: err.message };
} }
} }

178
server/proxy/service/subscription-server-v3.js
View File

@ -307,19 +307,20 @@ ${nodeNames}
: ` - "♻️ 自动选择"\n${nodeNames}`) : ` - "♻️ 自动选择"\n${nodeNames}`)
: nodeNames; : nodeNames;
// Claude专线独立代理组: 只包含SV节点 + 备选 // Claude专线独立代理组: 始终显示为下拉菜单 (select类型)
// 用户可以在VPN软件中手动下拉选择，精准定位Claude专线 // 无论是否有硅谷节点，都创建Claude专线组，让用户手动选择
// 有SV节点时优先SV，无SV节点时使用现有节点
const claudeProxies = svNode const claudeProxies = svNode
? ` - "${svNode.name}"\n${nodes.length > 1 ? ' - "♻️ 自动选择"\n' : ''}${nodeNames}` ? ` - "${svNode.name}"\n${nodes.length > 1 ? ' - "♻️ 自动选择"\n' : ''}${nodeNames}`
: toolProxies; : (nodes.length > 1 ? ` - "♻️ 自动选择"\n${nodeNames}` : nodeNames);
// Claude专线代理组YAML块 // Claude专线代理组YAML块 — 始终生成 (下拉选择·select类型)
const claudeGroupBlock = svNode ? ` const claudeGroupBlock = `
- name: "🇺🇸 Claude专线" - name: "🇺🇸 Claude专线"
type: select type: select
proxies: proxies:
${claudeProxies} ${claudeProxies}
` : ''; `;
return `# 光湖语言世界 · ${user.label} 的独立专线 — 冰朔开发维护 return `# 光湖语言世界 · ${user.label} 的独立专线 — 冰朔开发维护
# 自动生成 · ${new Date().toISOString()} # 自动生成 · ${new Date().toISOString()}
@ -451,9 +452,9 @@ ${toolProxies}
# ── 路由规则 ────────────────────────────── # ── 路由规则 ──────────────────────────────
rules: rules:
# Claude专线 (独立代理组·手动选择·精准定位) # Claude专线 (独立代理组·下拉选择·始终可选)
- DOMAIN-SUFFIX,claude.ai,${svNode ? '🇺🇸 Claude专线' : '🤖 AI服务'} - DOMAIN-SUFFIX,claude.ai,🇺🇸 Claude专线
- DOMAIN-SUFFIX,anthropic.com,${svNode ? '🇺🇸 Claude专线' : '🤖 AI服务'} - DOMAIN-SUFFIX,anthropic.com,🇺🇸 Claude专线
# AI服务 (其他AI) # AI服务 (其他AI)
- DOMAIN-SUFFIX,openai.com,🤖 AI服务 - DOMAIN-SUFFIX,openai.com,🤖 AI服务
@ -803,18 +804,28 @@ mode: direct
boostStatus = bs.current?.bbr?.is_bbr ? '✅ BBR加速中' : '⚠️ 未加速'; boostStatus = bs.current?.bbr?.is_bbr ? '✅ BBR加速中' : '⚠️ 未加速';
} catch { /* ignore */ } } catch { /* ignore */ }
// 读取用户带宽共享状态 // 读取用户带宽共享状态 (系统内部状态)
let bwContribStatus = '未加入'; let bwContribStatus = '未加入';
let bwContribActive = false; let bwContribActive = false;
let bwContribAuthTime = '';
let bwIpAuthorized = false;
try { try {
const bwPool = require('./bandwidth-pool-agent'); const bwPool = require('./bandwidth-pool-agent');
const contribInfo = bwPool.isContributor(user.email); const contribInfo = bwPool.isContributor(user.email);
if (contribInfo.is_contributor) { if (contribInfo.is_contributor) {
bwContribActive = contribInfo.status === 'active'; bwContribActive = contribInfo.status === 'active';
bwIpAuthorized = true;
bwContribStatus = bwContribActive ? '🚀 加速已生效' : '⚠️ 已暂停'; bwContribStatus = bwContribActive ? '🚀 加速已生效' : '⚠️ 已暂停';
bwContribAuthTime = contribInfo.authorized_at || '';
} }
} catch { /* ignore */ } } catch { /* ignore */ }
// 读取带宽池状态 (加速池整体数据)
let bwPoolInfo = { total_contributors: 0, active_contributors: 0, total_contributed_gb: 0, pool_status: 'idle' };
try {
bwPoolInfo = JSON.parse(fs.readFileSync(path.join(DATA_DIR, 'bandwidth-pool-status.json'), 'utf8'));
} catch { /* ignore */ }
// 读取今日流量快照 // 读取今日流量快照
let todayGB = '—'; let todayGB = '—';
try { try {
@ -825,6 +836,9 @@ mode: direct
} }
} catch { /* ignore */ } } catch { /* ignore */ }
// Claude专线节点检测
const svNode = nodes.find(n => n.region === 'us-sv');
const poolBarColor = poolPct > 90 ? '#e74c3c' : poolPct > 70 ? '#f39c12' : '#2ecc71'; const poolBarColor = poolPct > 90 ? '#e74c3c' : poolPct > 70 ? '#f39c12' : '#2ecc71';
// HTML转义防止XSS // HTML转义防止XSS
@ -853,6 +867,12 @@ mode: direct
.node:last-child { border-bottom: none; } .node:last-child { border-bottom: none; }
.online { color: #2ecc71; } .online { color: #2ecc71; }
.footer { text-align: center; padding: 20px 0; color: #555; font-size: 0.75em; } .footer { text-align: center; padding: 20px 0; color: #555; font-size: 0.75em; }
.accel-badge { display: inline-block; padding: 3px 10px; border-radius: 6px; font-size: 0.8em; font-weight: 600; }
.accel-on { background: rgba(46,204,113,0.15); color: #2ecc71; border: 1px solid rgba(46,204,113,0.3); }
.accel-off { background: rgba(241,196,15,0.1); color: #f1c40f; border: 1px solid rgba(241,196,15,0.2); }
.refresh-btn { display: inline-block; padding: 8px 16px; background: linear-gradient(135deg,#667eea,#764ba2); color: #fff; border: none; border-radius: 8px; font-size: 0.85em; font-weight: 600; cursor: pointer; text-decoration: none; }
.refresh-btn:active { opacity: 0.8; }
.sub-btn { display: block; width: 100%; padding: 12px; background: linear-gradient(135deg,#f093fb,#f5576c); color: #fff; border: none; border-radius: 10px; font-size: 0.95em; font-weight: 600; cursor: pointer; margin-top: 8px; text-decoration: none; text-align: center; }
</style> </style>
</head> </head>
<body> <body>
@ -861,6 +881,20 @@ mode: direct
<p>${esc(user.label)} 的专属仪表盘 — 冰朔开发维护</p> <p>${esc(user.label)} 的专属仪表盘 — 冰朔开发维护</p>
</div> </div>
<!-- ═══ 加速状态面板 (系统内部状态 → 用户可见) ═══ -->
<div class="card" style="border: 1px solid ${bwContribActive ? 'rgba(46,204,113,0.3)' : '#1e2448'};">
<h3>🔥 加速状态 <span class="accel-badge ${bwContribActive ? 'accel-on' : 'accel-off'}" id="accelBadge">${bwContribActive ? '加速中' : '未加速'}</span></h3>
<div class="stat-row"><span class="stat-label">IP授权</span><span class="stat-value" id="ipAuthStatus">${bwIpAuthorized ? '✅ 已授权' : '❌ 未授权'}</span></div>
<div class="stat-row"><span class="stat-label">带宽加速</span><span class="stat-value" id="bwAccelStatus">${bwContribStatus}</span></div>
<div class="stat-row"><span class="stat-label">网速增强</span><span class="stat-value" id="speedBoostStatus">${bwContribActive ? '✅ 已开启' : '⚠️ 未开启'}</span></div>
<div class="stat-row"><span class="stat-label">反向加速</span><span class="stat-value">${boostStatus}</span></div>
<div class="stat-row"><span class="stat-label">加速池人数</span><span class="stat-value" id="poolContributors">${bwPoolInfo.active_contributors}人在线 / ${bwPoolInfo.total_contributors}人</span></div>
${bwContribAuthTime ? '<div class="stat-row"><span class="stat-label">授权时间</span><span class="stat-value" style="font-size:0.8em;color:#aaa;">' + new Date(bwContribAuthTime).toLocaleString('zh-CN', { timeZone: 'Asia/Shanghai' }) + '</span></div>' : ''}
<div style="margin-top: 10px; text-align: center;">
<button class="refresh-btn" onclick="refreshAccelStatus(event)">🔄 刷新加速状态</button>
</div>
</div>
<div class="card"> <div class="card">
<h3>📊 流量概览</h3> <h3>📊 流量概览</h3>
<div class="stat-row"><span class="stat-label">今日用量</span><span class="stat-value">${todayGB} GB</span></div> <div class="stat-row"><span class="stat-label">今日用量</span><span class="stat-value">${todayGB} GB</span></div>
@ -875,15 +909,28 @@ mode: direct
<div class="card"> <div class="card">
<h3>🔌 节点状态 (${nodes.length}个)</h3> <h3>🔌 节点状态 (${nodes.length}个)</h3>
${nodes.map(n => `<div class="node"><span>${esc(n.name)}</span><span class="online">${n.latency_ms ? n.latency_ms + 'ms' : '在线'}</span></div>`).join('\n ')} ${nodes.map(n => `<div class="node"><span>${esc(n.name)}</span><span class="online">${n.latency_ms ? n.latency_ms + 'ms' : '在线'}</span></div>`).join('\n ')}
${svNode ? '<div style="margin-top:8px;padding:8px 12px;background:#1a1f3d;border-radius:8px;font-size:0.82em;color:#22d3ee;">🇺🇸 Claude专线可用 · 在VPN软件中选择「Claude专线」分组即可精准切换</div>' : ''}
</div> </div>
<div class="card"> <div class="card">
<h3>⚡ 系统状态</h3> <h3>⚡ 系统状态</h3>
<div class="stat-row"><span class="stat-label">服务版本</span><span class="stat-value">V3.0</span></div> <div class="stat-row"><span class="stat-label">服务版本</span><span class="stat-value">V3.0</span></div>
<div class="stat-row"><span class="stat-label">反向加速</span><span class="stat-value">${boostStatus}</span></div>
<div class="stat-row"><span class="stat-label">带宽共享</span><span class="stat-value" id="bwAccelStatus">${bwContribStatus}</span></div>
<div class="stat-row"><span class="stat-label">在线用户</span><span class="stat-value">${poolStatus.users_count}</span></div> <div class="stat-row"><span class="stat-label">在线用户</span><span class="stat-value">${poolStatus.users_count}</span></div>
<div class="stat-row"><span class="stat-label">智能选路</span><span class="stat-value">${nodes.length > 1 ? '✅ url-test' : '单节点'}</span></div> <div class="stat-row"><span class="stat-label">智能选路</span><span class="stat-value">${nodes.length > 1 ? '✅ url-test' : '单节点'}</span></div>
<div class="stat-row"><span class="stat-label">Claude专线</span><span class="stat-value">${svNode ? '✅ 硅谷节点在线' : '⚠️ 暂不可用'}</span></div>
</div>
<!-- ═══ VPN订阅更新入口 ═══ -->
<div class="card">
<h3>🔄 更新VPN配置</h3>
<p style="font-size:0.82em;color:#888;line-height:1.7;margin-bottom:10px;">
合并代码后，VPN配置自动更新。您只需在VPN软件中<strong style="color:#22d3ee;">刷新订阅</strong>即可获取最新配置。
</p>
<div style="background:#1a1f3d;border-radius:8px;padding:12px;font-size:0.82em;color:#aaa;line-height:1.8;">
<strong style="color:#667eea;">📱 Shadowrocket:</strong> 首页 → 长按订阅链接 → 更新<br>
<strong style="color:#667eea;">💻 Clash Verge:</strong> 订阅页 → 点击刷新图标<br>
<strong style="color:#667eea;">📱 ClashMi:</strong> 配置 → 点击更新按钮
</div>
</div> </div>
<div class="card"> <div class="card">
@ -922,6 +969,24 @@ mode: direct
var dashIdx = window.location.pathname.indexOf('/dashboard/'); var dashIdx = window.location.pathname.indexOf('/dashboard/');
var bwBasePath = dashIdx >= 0 ? window.location.pathname.substring(0, dashIdx) : ''; var bwBasePath = dashIdx >= 0 ? window.location.pathname.substring(0, dashIdx) : '';
// 刷新加速状态 (从带宽池API获取最新数据)
function refreshAccelStatus(e) {
var btn = e.target;
btn.textContent = '⏳ 刷新中...';
btn.disabled = true;
fetch(bwBasePath + '/bandwidth-pool-status').then(function(r) { return r.json(); }).then(function(data) {
if (data.success) {
document.getElementById('poolContributors').textContent = (data.active_contributors || 0) + '人在线 / ' + (data.total_contributors || 0) + '人';
}
// 刷新整个页面以获取最新的用户授权状态
window.location.reload();
}).catch(function() {
btn.textContent = '🔄 刷新加速状态';
btn.disabled = false;
});
}
function bwSendCode() { function bwSendCode() {
var email = document.getElementById('bwEmail').value.trim().toLowerCase(); var email = document.getElementById('bwEmail').value.trim().toLowerCase();
var btn = document.getElementById('bwSendBtn'); var btn = document.getElementById('bwSendBtn');
@ -1020,16 +1085,27 @@ function bwVerifyCode() {
result.style.background = '#1a3a2a'; result.style.background = '#1a3a2a';
result.style.color = '#2ecc71'; result.style.color = '#2ecc71';
btn.textContent = '✅ 授权成功'; btn.textContent = '✅ 授权成功';
// 更新系统状态中的加速状态 // 授权成功 → 自动更新加速状态面板
var accelEl = document.getElementById('bwAccelStatus'); document.getElementById('bwAccelStatus').textContent = '🚀 加速已生效';
if (accelEl) accelEl.textContent = '🚀 加速已生效'; document.getElementById('ipAuthStatus').textContent = '✅ 已授权';
document.getElementById('speedBoostStatus').textContent = '✅ 已开启';
var badge = document.getElementById('accelBadge');
if (badge) { badge.textContent = '加速中'; badge.className = 'accel-badge accel-on'; }
result.textContent = (data.message || '授权成功！') + ' 3秒后自动刷新...';
// 3秒后自动刷新页面，加载最新服务器状态
var cd2 = 3;
var reloadTimer = setInterval(function() {
cd2--;
result.textContent = '✅ 授权成功！' + cd2 + '秒后自动刷新...';
if (cd2 <= 0) { clearInterval(reloadTimer); window.location.reload(); }
}, 1000);
} else { } else {
result.style.background = '#3a1a1a'; result.style.background = '#3a1a1a';
result.style.color = '#e74c3c'; result.style.color = '#e74c3c';
btn.disabled = false; btn.disabled = false;
btn.textContent = '🔑 提交验证码'; btn.textContent = '🔑 提交验证码';
result.textContent = data.message || '验证失败';
} }
result.textContent = data.message || (data.success ? '授权成功！' : '验证失败');
}).catch(function() { }).catch(function() {
btn.disabled = false; btn.disabled = false;
btn.textContent = '🔑 提交验证码'; btn.textContent = '🔑 提交验证码';
@ -1972,13 +2048,15 @@ async function submitCode(e) {
res.writeHead(200, { 'Content-Type': 'application/json; charset=utf-8' }); res.writeHead(200, { 'Content-Type': 'application/json; charset=utf-8' });
res.end(JSON.stringify({ success: true, message: '验证码已发送到您的邮箱，请查收（15分钟内有效）' })); res.end(JSON.stringify({ success: true, message: '验证码已发送到您的邮箱，请查收（15分钟内有效）' }));
} else { } else {
const errDetail = result.error || '未知原因';
console.error('[bandwidth-send-code] 邮件发送失败:', errDetail);
res.writeHead(200, { 'Content-Type': 'application/json; charset=utf-8' }); res.writeHead(200, { 'Content-Type': 'application/json; charset=utf-8' });
res.end(JSON.stringify({ success: false, message: '📧 邮件发送失败，请稍后重试或联系冰朔获取验证码' })); res.end(JSON.stringify({ success: false, message: `📧 邮件发送失败(${errDetail})，请稍后重试或联系冰朔获取验证码` }));
} }
}).catch((err) => { }).catch((err) => {
console.error('[bandwidth-send-code] 邮件发送异常:', err.message || err); console.error('[bandwidth-send-code] 邮件发送异常:', err.message || err);
res.writeHead(200, { 'Content-Type': 'application/json; charset=utf-8' }); res.writeHead(200, { 'Content-Type': 'application/json; charset=utf-8' });
res.end(JSON.stringify({ success: false, message: '📧 邮件发送失败，请稍后重试或联系冰朔获取验证码' })); res.end(JSON.stringify({ success: false, message: `📧 邮件发送异常(${err.message})，请稍后重试或联系冰朔获取验证码` }));
}); });
} catch { } catch {
// Email module not available - code was still created // Email module not available - code was still created
@ -2105,11 +2183,73 @@ async function submitCode(e) {
return; return;
} }
// ═══════════════════════════════════════════════
// ∞+1 公开API: /bandwidth-user-status (无需token·用户加速状态)
// 系统内部状态关联 → 用户刷新后自动展示授权/加速/网速状态
// ═══════════════════════════════════════════════
if (pathname === '/bandwidth-user-status' && req.method === 'POST') {
res.setHeader('Access-Control-Allow-Origin', '*');
res.setHeader('Access-Control-Allow-Methods', 'POST, OPTIONS');
res.setHeader('Access-Control-Allow-Headers', 'Content-Type');
let body = '';
req.on('data', chunk => { body += chunk; if (body.length > 1024) req.destroy(); });
req.on('end', () => {
try {
let email = '';
if (req.headers['content-type']?.includes('application/json')) {
const json = JSON.parse(body);
email = String(json.email || '').trim().toLowerCase();
} else {
const params = new URLSearchParams(body);
email = String(params.get('email') || '').trim().toLowerCase();
}
if (!email || !email.includes('@')) {
res.writeHead(400, { 'Content-Type': 'application/json; charset=utf-8' });
res.end(JSON.stringify({ success: false, message: '请输入有效的邮箱地址' }));
return;
}
const bwPool = require('./bandwidth-pool-agent');
const contribInfo = bwPool.isContributor(email);
const poolStatus = bwPool.getPoolStatus();
// 读取反向加速状态
let bbrActive = false;
try {
const bs = JSON.parse(fs.readFileSync(path.join(DATA_DIR, 'reverse-boost-status.json'), 'utf8'));
bbrActive = !!(bs.current?.bbr?.is_bbr);
} catch { /* ignore */ }
res.writeHead(200, { 'Content-Type': 'application/json; charset=utf-8' });
res.end(JSON.stringify({
success: true,
ip_authorized: contribInfo.is_contributor,
bandwidth_accelerated: contribInfo.is_contributor && contribInfo.status === 'active',
speed_boosted: contribInfo.is_contributor && contribInfo.status === 'active',
bbr_active: bbrActive,
contributor_status: contribInfo.status,
authorized_at: contribInfo.authorized_at,
pool_active_contributors: poolStatus.active_contributors,
pool_total_contributors: poolStatus.total_contributors,
pool_contributed_gb: poolStatus.total_contributed_gb,
pool_status: poolStatus.pool_status
}));
} catch (err) {
res.writeHead(500, { 'Content-Type': 'application/json; charset=utf-8' });
res.end(JSON.stringify({ success: false, message: '系统异常' }));
}
});
return;
}
// ═══ CORS预检 (OPTIONS) 支持 ═══ // ═══ CORS预检 (OPTIONS) 支持 ═══
if (req.method === 'OPTIONS' && ( if (req.method === 'OPTIONS' && (
pathname === '/bandwidth-send-code' || pathname === '/bandwidth-send-code' ||
pathname === '/bandwidth-verify-code' || pathname === '/bandwidth-verify-code' ||
pathname === '/bandwidth-pool-status' pathname === '/bandwidth-pool-status' ||
pathname === '/bandwidth-user-status'
)) { )) {
res.writeHead(204, { res.writeHead(204, {
'Access-Control-Allow-Origin': '*', 'Access-Control-Allow-Origin': '*',