Add mirror management and selection UI

Introduces backend API and router for mirror management, including latency testing and custom mirror setting. Adds frontend components and controllers for mirror selection, speed testing, and integration into system info and plugin store pages, allowing users to select and test download/list mirrors interactively.

packages/napcat-webui-backend/src/api/Mirror.ts

@@ -0,0 +1,230 @@
+import { RequestHandler } from 'express';
+import { sendSuccess, sendError } from '@/napcat-webui-backend/src/utils/response';
+import {
+  GITHUB_FILE_MIRRORS,
+  GITHUB_RAW_MIRRORS,
+  buildMirrorUrl,
+  getMirrorConfig,
+  setCustomMirror,
+  clearMirrorCache
+} from 'napcat-common/src/mirror';
+import https from 'https';
+import http from 'http';
+
+export interface MirrorTestResult {
+  mirror: string;
+  latency: number;
+  success: boolean;
+  error?: string;
+}
+
+/**
+ * 测试单个镜像的延迟
+ */
+async function testMirrorLatency (mirror: string, testUrl: string, timeout: number = 5000): Promise<MirrorTestResult> {
+  const url = mirror ? buildMirrorUrl(testUrl, mirror) : testUrl;
+  const start = Date.now();
+
+  return new Promise<MirrorTestResult>((resolve) => {
+    try {
+      const urlObj = new URL(url);
+      const isHttps = urlObj.protocol === 'https:';
+      const client = isHttps ? https : http;
+
+      const req = client.request({
+        hostname: urlObj.hostname,
+        port: urlObj.port || (isHttps ? 443 : 80),
+        path: urlObj.pathname + urlObj.search,
+        method: 'HEAD',
+        timeout,
+        headers: {
+          'User-Agent': 'NapCat-Mirror-Test',
+        },
+      }, (res) => {
+        const statusCode = res.statusCode || 0;
+        const isValid = statusCode >= 200 && statusCode < 400;
+        resolve({
+          mirror: mirror || 'https://github.com',
+          latency: Date.now() - start,
+          success: isValid,
+        });
+      });
+
+      req.on('error', (e) => {
+        resolve({
+          mirror: mirror || 'https://github.com',
+          latency: Date.now() - start,
+          success: false,
+          error: e.message,
+        });
+      });
+
+      req.on('timeout', () => {
+        req.destroy();
+        resolve({
+          mirror: mirror || 'https://github.com',
+          latency: timeout,
+          success: false,
+          error: 'Timeout',
+        });
+      });
+
+      req.end();
+    } catch (e: any) {
+      resolve({
+        mirror: mirror || 'https://github.com',
+        latency: Date.now() - start,
+        success: false,
+        error: e.message,
+      });
+    }
+  });
+}
+
+/**
+ * 获取所有可用的镜像列表
+ */
+export const GetMirrorListHandler: RequestHandler = async (_req, res) => {
+  try {
+    const config = getMirrorConfig();
+    return sendSuccess(res, {
+      fileMirrors: GITHUB_FILE_MIRRORS.filter(m => m),
+      rawMirrors: GITHUB_RAW_MIRRORS,
+      customMirror: config.customMirror,
+      timeout: config.timeout,
+    });
+  } catch (e: any) {
+    return sendError(res, e.message);
+  }
+};
+
+/**
+ * 设置自定义镜像
+ */
+export const SetCustomMirrorHandler: RequestHandler = async (req, res) => {
+  try {
+    const { mirror } = req.body;
+    setCustomMirror(mirror || '');
+    clearMirrorCache();
+    return sendSuccess(res, { message: 'Mirror set successfully' });
+  } catch (e: any) {
+    return sendError(res, e.message);
+  }
+};
+
+/**
+ * SSE 实时测速所有镜像
+ */
+export const TestMirrorsSSEHandler: RequestHandler = async (req, res) => {
+  const { type = 'file' } = req.query;
+
+  // 设置 SSE 响应头
+  res.setHeader('Content-Type', 'text/event-stream');
+  res.setHeader('Cache-Control', 'no-cache');
+  res.setHeader('Connection', 'keep-alive');
+  res.flushHeaders();
+
+  const sendProgress = (data: any) => {
+    res.write(`data: ${JSON.stringify(data)}\n\n`);
+  };
+
+  try {
+    // 选择镜像列表
+    let mirrors: string[];
+    let testUrl: string;
+
+    if (type === 'raw') {
+      mirrors = GITHUB_RAW_MIRRORS;
+      testUrl = 'https://raw.githubusercontent.com/NapNeko/NapCatQQ/main/README.md';
+    } else {
+      mirrors = GITHUB_FILE_MIRRORS.filter(m => m);
+      testUrl = 'https://github.com/NapNeko/NapCatQQ/releases/latest';
+    }
+
+    // 添加原始 URL 测试
+    if (!mirrors.includes('')) {
+      mirrors = ['', ...mirrors];
+    }
+
+    sendProgress({
+      type: 'start',
+      total: mirrors.length,
+      message: `开始测试 ${mirrors.length} 个镜像源...`,
+    });
+
+    const results: MirrorTestResult[] = [];
+    const timeout = 5000;
+
+    // 逐个测试并实时推送结果
+    for (let i = 0; i < mirrors.length; i++) {
+      const mirror = mirrors[i] ?? '';
+      const displayName = mirror || 'https://github.com (原始)';
+
+      sendProgress({
+        type: 'testing',
+        index: i,
+        total: mirrors.length,
+        mirror: displayName,
+        message: `正在测试: ${displayName}`,
+      });
+
+      const result = await testMirrorLatency(mirror, testUrl, timeout);
+      results.push(result);
+
+      sendProgress({
+        type: 'result',
+        index: i,
+        total: mirrors.length,
+        result: {
+          ...result,
+          mirror: result.mirror || 'https://github.com (原始)',
+        },
+      });
+    }
+
+    // 按延迟排序
+    const sortedResults = results
+      .filter(r => r.success)
+      .sort((a, b) => a.latency - b.latency);
+
+    const failedResults = results.filter(r => !r.success);
+
+    sendProgress({
+      type: 'complete',
+      results: sortedResults,
+      failed: failedResults,
+      fastest: sortedResults[0] || null,
+      message: `测试完成！${sortedResults.length} 个可用，${failedResults.length} 个失败`,
+    });
+
+    res.end();
+  } catch (e: any) {
+    sendProgress({
+      type: 'error',
+      error: e.message,
+    });
+    res.end();
+  }
+};
+
+/**
+ * 快速测试单个镜像
+ */
+export const TestSingleMirrorHandler: RequestHandler = async (req, res) => {
+  try {
+    const { mirror, type = 'file' } = req.body;
+
+    let testUrl: string;
+    if (type === 'raw') {
+      testUrl = 'https://raw.githubusercontent.com/NapNeko/NapCatQQ/main/README.md';
+    } else {
+      testUrl = 'https://github.com/NapNeko/NapCatQQ/releases/latest';
+    }
+
+    const result = await testMirrorLatency(mirror || '', testUrl, 5000);
+
+    return sendSuccess(res, result);
+  } catch (e: any) {
+    return sendError(res, e.message);
+  }
+};

packages/napcat-webui-backend/src/router/Mirror.ts

@@ -0,0 +1,23 @@
+import { Router } from 'express';
+import {
+  GetMirrorListHandler,
+  SetCustomMirrorHandler,
+  TestMirrorsSSEHandler,
+  TestSingleMirrorHandler
+} from '@/napcat-webui-backend/src/api/Mirror';
+
+const router: Router = Router();
+
+// 获取镜像列表
+router.get('/List', GetMirrorListHandler);
+
+// 设置自定义镜像
+router.post('/SetCustom', SetCustomMirrorHandler);
+
+// SSE 实时测速
+router.get('/Test/SSE', TestMirrorsSSEHandler);
+
+// 测试单个镜像
+router.post('/Test', TestSingleMirrorHandler);
+
+export { router as MirrorRouter };

packages/napcat-webui-backend/src/router/index.ts

@@ -18,6 +18,7 @@ import { UpdateNapCatRouter } from './UpdateNapCat';
 import DebugRouter from '@/napcat-webui-backend/src/api/Debug';
 import { ProcessRouter } from './Process';
 import { PluginRouter } from './Plugin';
+import { MirrorRouter } from './Mirror';
 
 const router: Router = Router();
 
@@ -50,5 +51,7 @@ router.use('/Debug', DebugRouter);
 router.use('/Process', ProcessRouter);
 // router:插件管理相关路由
 router.use('/Plugin', PluginRouter);
+// router:镜像管理相关路由
+router.use('/Mirror', MirrorRouter);
 
 export { router as ALLRouter };