guanghulab/server/proxy/service/protocol-mirror.js

#!/usr/bin/env node
// ═══════════════════════════════════════════════
// 🔺 Sovereign: TCS-0002∞ | Root: SYS-GLW-0001
// 📜 Copyright: 国作登字-2026-A-00037559
// ═══════════════════════════════════════════════
// server/proxy/service/protocol-mirror.js
// 🪞 铸渊专线 · 协议镜像引擎
//
// 核心概念: 镜像同步
//   - 上游协议 (Xray-core) 更新时自动检测
//   - 自动下载/备份/升级/验证/重启
//   - TLS/Reality 指纹一致性校验
//   - 对外呈现标准 Xray 行为 (伪装)
//
// 安全机制:
//   - LLM分析更新风险 (安全补丁/破坏性变更)
//   - 失败3次自动告警管理员
//   - 升级前备份，失败可回滚
//
// 运行方式: PM2 managed (zy-protocol-mirror)
// 检查间隔: 每30分钟 (GitHub API每6小时)
// ═══════════════════════════════════════════════

'use strict';

const { execSync, execFileSync } = require('child_process');
const fs = require('fs');
const path = require('path');
const https = require('https');

const DATA_DIR = process.env.ZY_PROXY_DATA_DIR || '/opt/zhuyuan-brain/proxy/data';
const LOG_DIR = process.env.ZY_PROXY_LOG_DIR || '/opt/zhuyuan-brain/proxy/logs';
const MIRROR_FILE = path.join(DATA_DIR, 'protocol-mirror-status.json');
const XRAY_BIN = process.env.ZY_XRAY_BIN || '/usr/local/bin/xray';
const XRAY_BACKUP_DIR = path.join(DATA_DIR, 'xray-backups');

const CHECK_INTERVAL = 30 * 60 * 1000;        // 30分钟
const GITHUB_CHECK_INTERVAL = 6 * 60 * 60 * 1000; // 6小时
const MAX_FAILED_UPDATES = 3;
const MAX_UPDATE_HISTORY = 20;

// ── 读取镜像状态 ─────────────────────────────
function readMirrorStatus() {
  try {
    return JSON.parse(fs.readFileSync(MIRROR_FILE, 'utf8'));
  } catch {
    return {
      installed_version: null,
      latest_version: null,
      update_available: false,
      last_github_check: null,
      last_fingerprint_check: null,
      update_history: [],
      failed_updates: 0,
      mirror_status: 'initializing',
      fingerprint: {
        tls_match: true,
        reality_match: true,
        protocol_version: 'unknown'
      }
    };
  }
}

// ── 保存镜像状态 ─────────────────────────────
function saveMirrorStatus(status) {
  if (!fs.existsSync(DATA_DIR)) {
    fs.mkdirSync(DATA_DIR, { recursive: true });
  }
  fs.writeFileSync(MIRROR_FILE, JSON.stringify(status, null, 2));
}

// ── 执行命令 ─────────────────────────────────
function runCmd(cmd, timeout = 10000) {
  try {
    return { ok: true, output: execSync(cmd, { encoding: 'utf8', timeout }).trim() };
  } catch (err) {
    return { ok: false, output: err.message };
  }
}

// ── HTTPS GET 请求 ───────────────────────────
function httpsGet(url, headers = {}) {
  return new Promise((resolve, reject) => {
    const urlObj = new URL(url);
    const options = {
      hostname: urlObj.hostname,
      path: urlObj.pathname + urlObj.search,
      method: 'GET',
      headers: {
        'User-Agent': 'ZY-Protocol-Mirror/1.0',
        ...headers
      },
      timeout: 15000
    };

    const req = https.request(options, (res) => {
      // 处理重定向
      if (res.statusCode >= 300 && res.statusCode < 400 && res.headers.location) {
        httpsGet(res.headers.location, headers).then(resolve).catch(reject);
        return;
      }

      let data = '';
      res.on('data', (d) => { data += d; });
      res.on('end', () => {
        resolve({ statusCode: res.statusCode, body: data, headers: res.headers });
      });
    });

    req.on('error', (err) => {
      reject(new Error(`HTTPS请求失败: ${err.message}`));
    });
    req.on('timeout', () => {
      req.destroy();
      reject(new Error('HTTPS请求超时'));
    });
    req.end();
  });
}

// ── 获取已安装的Xray版本 ────────────────────
function getInstalledVersion() {
  try {
    const output = execFileSync(XRAY_BIN, ['version'], {
      encoding: 'utf8',
      timeout: 5000
    }).trim();

    // Xray version output: "Xray 1.8.x (Xray, Penetrates Everything.) ..."
    const match = output.match(/Xray\s+(\d+\.\d+\.\d+)/i);
    if (match) {
      return match[1];
    }
    console.error('[协议镜像] 无法解析Xray版本号:', output.slice(0, 100));
    return null;
  } catch (err) {
    console.error('[协议镜像] 获取Xray版本失败:', err.message);
    return null;
  }
}

// ── 查询GitHub最新版本 ──────────────────────
async function fetchLatestRelease() {
  try {
    const resp = await httpsGet('https://api.github.com/repos/XTLS/Xray-core/releases/latest', {
      'Accept': 'application/vnd.github.v3+json'
    });

    if (resp.statusCode !== 200) {
      console.error(`[协议镜像] GitHub API返回 ${resp.statusCode}`);
      return null;
    }

    const release = JSON.parse(resp.body);
    const tagName = release.tag_name || '';
    // tag格式: "v1.8.x"
    const version = tagName.replace(/^v/, '');
    const body = release.body || '';
    const publishedAt = release.published_at || null;

    // 查找Linux AMD64二进制下载链接
    let downloadUrl = null;
    if (release.assets && Array.isArray(release.assets)) {
      const linuxAsset = release.assets.find(a =>
        a.name && a.name.includes('linux') && a.name.includes('64') && a.name.endsWith('.zip')
      );
      if (linuxAsset) {
        downloadUrl = linuxAsset.browser_download_url;
      }
    }

    return { version, body, publishedAt, downloadUrl, tagName };
  } catch (err) {
    console.error('[协议镜像] 获取GitHub release失败:', err.message);
    return null;
  }
}

// ── 版本比较 ─────────────────────────────────
function isNewer(latest, installed) {
  if (!latest || !installed) return false;
  const latestParts = latest.split('.').map(Number);
  const installedParts = installed.split('.').map(Number);

  for (let i = 0; i < 3; i++) {
    const l = latestParts[i] || 0;
    const c = installedParts[i] || 0;
    if (l > c) return true;
    if (l < c) return false;
  }
  return false;
}

// ── 协议指纹检查 ─────────────────────────────
function checkFingerprint() {
  console.log('[协议镜像] 检查协议指纹一致性...');
  const fingerprint = {
    tls_match: true,
    reality_match: true,
    protocol_version: 'unknown'
  };

  // 检查TLS配置是否符合标准Xray行为
  try {
    const configPath = process.env.ZY_XRAY_CONFIG || '/usr/local/etc/xray/config.json';
    if (fs.existsSync(configPath)) {
      const config = JSON.parse(fs.readFileSync(configPath, 'utf8'));

      // 验证Reality配置存在且结构完整
      const inbounds = config.inbounds || [];
      const realityInbound = inbounds.find(ib =>
        ib.streamSettings &&
        ib.streamSettings.realitySettings
      );

      if (realityInbound) {
        const reality = realityInbound.streamSettings.realitySettings;
        fingerprint.reality_match = !!(reality.privateKey && reality.shortIds);
        if (!fingerprint.reality_match) {
          console.log('[协议镜像] ⚠️ Reality配置不完整');
        }
      }

      // 验证TLS相关配置
      const tlsInbound = inbounds.find(ib =>
        ib.streamSettings &&
        ib.streamSettings.security === 'tls'
      );

      if (tlsInbound) {
        const tls = tlsInbound.streamSettings.tlsSettings || {};
        fingerprint.tls_match = !!(tls.certificates && tls.certificates.length > 0);
      }
    }
  } catch (err) {
    console.error('[协议镜像] 指纹检查异常:', err.message);
    fingerprint.tls_match = false;
  }

  // 确认Xray进程运行中的协议版本
  const installed = getInstalledVersion();
  if (installed) {
    fingerprint.protocol_version = 'matching';
  } else {
    fingerprint.protocol_version = 'unavailable';
  }

  return fingerprint;
}

// ── LLM更新风险分析 ─────────────────────────
async function consultLLMForUpdate(releaseInfo, installedVersion) {
  let llmRouter;
  try {
    llmRouter = require('./llm-router');
  } catch {
    console.log('[协议镜像] LLM路由器未加载，跳过风险分析');
    return null;
  }

  const prompt = `你是光湖语言世界VPN系统的协议镜像引擎。Xray-core 有新版本发布，请分析更新风险。

当前版本: v${installedVersion}
最新版本: v${releaseInfo.version}
发布时间: ${releaseInfo.publishedAt || '未知'}

更新日志 (前1500字):
${(releaseInfo.body || '无更新日志').slice(0, 1500)}

请回答以下问题 (JSON格式):
1. is_critical: 是否是安全修复 (true/false)
2. changes_summary: 主要变更摘要 (一句话)
3. risk_level: 更新风险等级 (low/medium/high)
4. recommend_auto_update: 是否推荐自动更新 (true/false)
5. reason: 推荐理由 (一句话)`;

  let result;
  try {
    result = await llmRouter.callLLM(prompt, {
      systemPrompt: '你是光湖语言世界VPN系统的协议分析AI。负责评估Xray-core更新的风险和必要性。请用JSON格式回答。',
      maxTokens: 500,
      timeout: 30000
    });
  } catch (err) {
    console.error('[协议镜像] LLM调用异常:', err.message);
    return null;
  }

  if (!result || !result.content) return null;

  // 尝试解析LLM返回的JSON
  try {
    const jsonMatch = result.content.match(/\{[\s\S]*\}/);
    if (jsonMatch) {
      return JSON.parse(jsonMatch[0]);
    }
  } catch {
    console.log('[协议镜像] LLM返回内容无法解析为JSON');
  }

  return { raw_analysis: result.content, model: result.model };
}

// ── 下载文件 ─────────────────────────────────
function downloadFile(url, destPath) {
  return new Promise((resolve, reject) => {
    const file = fs.createWriteStream(destPath);

    const cleanup = () => {
      file.close();
      if (fs.existsSync(destPath)) fs.unlinkSync(destPath);
    };

    const doRequest = (reqUrl) => {
      const urlObj = new URL(reqUrl);
      const options = {
        hostname: urlObj.hostname,
        path: urlObj.pathname + urlObj.search,
        method: 'GET',
        headers: { 'User-Agent': 'ZY-Protocol-Mirror/1.0' },
        timeout: 120000
      };

      const req = https.request(options, (res) => {
        if (res.statusCode >= 300 && res.statusCode < 400 && res.headers.location) {
          doRequest(res.headers.location);
          return;
        }
        if (res.statusCode !== 200) {
          cleanup();
          reject(new Error(`下载失败: HTTP ${res.statusCode}`));
          return;
        }
        res.pipe(file);
        file.on('finish', () => {
          file.close();
          resolve(destPath);
        });
      });

      req.on('error', (err) => {
        cleanup();
        reject(new Error(`下载错误: ${err.message}`));
      });
      req.on('timeout', () => {
        req.destroy();
        cleanup();
        reject(new Error('下载超时'));
      });
      req.end();
    };

    doRequest(url);
  });
}

// ── 执行更新 ─────────────────────────────────
async function performUpdate() {
  const status = readMirrorStatus();

  if (!status.update_available || !status.latest_version) {
    console.log('[协议镜像] 无可用更新');
    return { ok: false, detail: '无可用更新' };
  }

  if (status.failed_updates >= MAX_FAILED_UPDATES) {
    console.error('[协议镜像] 已连续失败3次，需人工介入');
    sendAlertEmail(
      '🪞 协议镜像更新失败 - 需人工介入',
      `Xray-core 更新已连续失败 ${status.failed_updates} 次。\n` +
      `目标版本: v${status.latest_version}\n` +
      `当前版本: v${status.installed_version}\n` +
      `请手动检查并更新。`
    );
    return { ok: false, detail: `连续失败${status.failed_updates}次，已通知管理员` };
  }

  console.log(`[协议镜像] 开始更新: v${status.installed_version} → v${status.latest_version}`);
  status.mirror_status = 'updating';
  saveMirrorStatus(status);

  const updateRecord = {
    from_version: status.installed_version,
    to_version: status.latest_version,
    started_at: new Date().toISOString(),
    completed_at: null,
    success: false,
    detail: ''
  };

  try {
    // 1. 获取下载链接
    const release = await fetchLatestRelease();
    if (!release || !release.downloadUrl) {
      throw new Error('无法获取下载链接');
    }

    // 2. 下载新版本
    console.log('[协议镜像] 下载新版本...');
    const downloadPath = path.join(DATA_DIR, `xray-${release.version}.zip`);
    await downloadFile(release.downloadUrl, downloadPath);

    // 3. 备份当前版本
    console.log('[协议镜像] 备份当前版本...');
    if (!fs.existsSync(XRAY_BACKUP_DIR)) {
      fs.mkdirSync(XRAY_BACKUP_DIR, { recursive: true });
    }
    const backupPath = path.join(XRAY_BACKUP_DIR, `xray-${status.installed_version}-${Date.now()}`);
    if (fs.existsSync(XRAY_BIN)) {
      fs.copyFileSync(XRAY_BIN, backupPath);
      console.log(`[协议镜像] 备份完成: ${backupPath}`);
    }

    // 4. 解压并安装
    console.log('[协议镜像] 解压并安装...');
    const extractDir = path.join(DATA_DIR, 'xray-extract');
    if (fs.existsSync(extractDir)) {
      execFileSync('rm', ['-rf', extractDir], { timeout: 10000 });
    }
    fs.mkdirSync(extractDir, { recursive: true });
    execFileSync('unzip', ['-o', downloadPath, '-d', extractDir], {
      encoding: 'utf8',
      timeout: 30000
    });

    const newBin = path.join(extractDir, 'xray');
    if (!fs.existsSync(newBin)) {
      throw new Error('解压后未找到xray二进制文件');
    }

    // 设置执行权限并安装
    fs.chmodSync(newBin, 0o755);
    execFileSync('cp', [newBin, XRAY_BIN], { timeout: 10000 });

    // 5. 验证安装
    console.log('[协议镜像] 验证安装...');
    const newVersion = getInstalledVersion();
    if (!newVersion) {
      throw new Error('安装后无法获取版本号');
    }
    console.log(`[协议镜像] 新版本已安装: v${newVersion}`);

    // 6. 重启Xray服务
    console.log('[协议镜像] 重启Xray服务...');
    try {
      execFileSync('systemctl', ['restart', 'xray'], { encoding: 'utf8', timeout: 30000 });
    } catch (err) {
      throw new Error(`重启失败: ${err.message}`);
    }

    // 等待2秒后验证进程
    await new Promise(r => setTimeout(r, 2000));
    try {
      execFileSync('pgrep', ['-x', 'xray'], { encoding: 'utf8', timeout: 5000 });
    } catch {
      throw new Error('Xray重启后进程未运行');
    }

    // 7. 清理下载文件
    if (fs.existsSync(downloadPath)) fs.unlinkSync(downloadPath);
    if (fs.existsSync(extractDir)) {
      execFileSync('rm', ['-rf', extractDir], { timeout: 10000 });
    }

    // 更新成功
    updateRecord.success = true;
    updateRecord.completed_at = new Date().toISOString();
    updateRecord.detail = `成功从 v${status.installed_version} 更新到 v${newVersion}`;

    status.installed_version = newVersion;
    status.update_available = false;
    status.failed_updates = 0;
    status.mirror_status = 'synced';
    status.update_history.push(updateRecord);

    if (status.update_history.length > MAX_UPDATE_HISTORY) {
      status.update_history = status.update_history.slice(-MAX_UPDATE_HISTORY);
    }

    saveMirrorStatus(status);
    console.log(`[协议镜像] ✅ 更新完成: v${newVersion}`);

    // 发送更新成功通知
    sendAlertEmail(
      `🪞 Xray-core 已更新至 v${newVersion}`,
      getUpdateSummary()
    );

    return { ok: true, detail: updateRecord.detail };
  } catch (err) {
    console.error('[协议镜像] ❌ 更新失败:', err.message);

    updateRecord.completed_at = new Date().toISOString();
    updateRecord.detail = `更新失败: ${err.message}`;

    status.failed_updates++;
    status.mirror_status = 'error';
    status.update_history.push(updateRecord);

    if (status.update_history.length > MAX_UPDATE_HISTORY) {
      status.update_history = status.update_history.slice(-MAX_UPDATE_HISTORY);
    }

    saveMirrorStatus(status);

    // 连续失败达到上限时告警
    if (status.failed_updates >= MAX_FAILED_UPDATES) {
      sendAlertEmail(
        '🪞 协议镜像更新失败 - 需人工介入',
        `Xray-core 更新已连续失败 ${status.failed_updates} 次。\n` +
        `目标版本: v${status.latest_version}\n` +
        `当前版本: v${status.installed_version}\n` +
        `最后错误: ${err.message}\n` +
        `请手动检查并更新。`
      );
    }

    return { ok: false, detail: `更新失败: ${err.message}` };
  }
}

// ── 发送告警邮件 ─────────────────────────────
function sendAlertEmail(subject, body) {
  try {
    const sendScript = path.join(__dirname, 'send-subscription.js');
    execFileSync('node', [sendScript, 'alert', `${subject}\n\n${body}`], {
      encoding: 'utf8',
      timeout: 30000
    });
    console.log('[协议镜像] 通知邮件已发送');
  } catch (err) {
    console.error('[协议镜像] 邮件发送失败:', err.message);
  }
}

// ── 获取更新摘要 ─────────────────────────────
function getUpdateSummary() {
  const status = readMirrorStatus();
  const lastUpdate = status.update_history.length > 0
    ? status.update_history[status.update_history.length - 1]
    : null;

  const lines = [
    '🪞 协议镜像引擎 · 状态报告',
    '─'.repeat(30),
    `当前版本: v${status.installed_version || '未知'}`,
    `最新版本: v${status.latest_version || '未知'}`,
    `镜像状态: ${status.mirror_status}`,
    `更新可用: ${status.update_available ? '是' : '否'}`,
    `失败次数: ${status.failed_updates}`,
    ''
  ];

  if (lastUpdate) {
    lines.push('最近更新:');
    lines.push(`  ${lastUpdate.from_version} → ${lastUpdate.to_version}`);
    lines.push(`  时间: ${lastUpdate.completed_at}`);
    lines.push(`  结果: ${lastUpdate.success ? '成功' : '失败'}`);
    lines.push(`  详情: ${lastUpdate.detail}`);
  }

  lines.push('');
  lines.push('指纹检查:');
  lines.push(`  TLS匹配: ${status.fingerprint.tls_match ? '✅' : '❌'}`);
  lines.push(`  Reality匹配: ${status.fingerprint.reality_match ? '✅' : '❌'}`);
  lines.push(`  协议版本: ${status.fingerprint.protocol_version}`);

  return lines.join('\n');
}

// ── 获取镜像状态 ─────────────────────────────
function getMirrorStatus() {
  return readMirrorStatus();
}

// ── 主检查流程 ───────────────────────────────
async function checkForUpdates() {
  console.log('[协议镜像] 开始检查...');
  const status = readMirrorStatus();

  // 1. 获取已安装版本
  const installedVersion = getInstalledVersion();
  if (installedVersion) {
    status.installed_version = installedVersion;
  }

  // 2. 指纹检查 (每次都执行)
  status.fingerprint = checkFingerprint();
  status.last_fingerprint_check = new Date().toISOString();

  if (!status.fingerprint.tls_match || !status.fingerprint.reality_match) {
    console.log('[协议镜像] ⚠️ 指纹不一致，可能被探测');
  }

  // 3. 检查GitHub最新版本 (受频率限制)
  const now = Date.now();
  const lastCheck = status.last_github_check ? new Date(status.last_github_check).getTime() : 0;
  const shouldCheckGitHub = (now - lastCheck) >= GITHUB_CHECK_INTERVAL;

  if (shouldCheckGitHub) {
    console.log('[协议镜像] 查询GitHub最新版本...');
    const release = await fetchLatestRelease();

    if (release && release.version) {
      status.latest_version = release.version;
      status.last_github_check = new Date().toISOString();

      if (installedVersion && isNewer(release.version, installedVersion)) {
        console.log(`[协议镜像] 🆕 发现新版本: v${release.version} (当前: v${installedVersion})`);
        status.update_available = true;
        status.mirror_status = 'outdated';

        // LLM风险分析
        const analysis = await consultLLMForUpdate(release, installedVersion);
        if (analysis) {
          console.log('[协议镜像] LLM分析结果:', JSON.stringify(analysis).slice(0, 200));
        }
      } else {
        status.update_available = false;
        if (status.mirror_status !== 'error') {
          status.mirror_status = 'synced';
        }
        console.log(`[协议镜像] ✅ 版本已同步: v${installedVersion || '未知'}`);
      }
    } else {
      console.log('[协议镜像] GitHub查询跳过 (API不可达或已限流)');
    }
  } else {
    const nextCheckMin = Math.round((GITHUB_CHECK_INTERVAL - (now - lastCheck)) / 60000);
    console.log(`[协议镜像] 使用缓存的GitHub结果 (下次查询: ${nextCheckMin}分钟后)`);
  }

  saveMirrorStatus(status);

  // 打印摘要
  console.log(`[协议镜像] 检查完成 | 版本: v${status.installed_version || '?'} | 最新: v${status.latest_version || '?'} | 状态: ${status.mirror_status}`);

  return status;
}

// ── 模块导出 ─────────────────────────────────
module.exports = { checkForUpdates, performUpdate, getMirrorStatus, getUpdateSummary };

// ── 启动协议镜像引擎 ────────────────────────
console.log('🪞 光湖语言世界 · 协议镜像引擎启动');
console.log(`  检查间隔: ${CHECK_INTERVAL / 1000}秒`);
console.log(`  GitHub API间隔: ${GITHUB_CHECK_INTERVAL / 3600000}小时`);
console.log(`  LLM路由器: 动态多模型 (通过llm-router.js)`);

// 立即执行一次
checkForUpdates().catch(console.error);

// 定期执行
setInterval(() => {
  checkForUpdates().catch(console.error);
}, CHECK_INTERVAL);