feat(api): 添加代理请求功能并优化日志记录

- 新增代理请求处理函数，支持自签名证书的 HTTPS 请求
- 添加日志工具类，实现不同级别的日志输出
- 在代理请求中使用日志工具记录请求和错误信息
- 移除仪表盘 SSE 监听相关代码
- 在 Tunnel 表中添加 lastEventTime 字段并创建索引

Author: yangtao

app/api/proxy/route.ts

@@ -0,0 +1,62 @@
+import { NextRequest, NextResponse } from 'next/server';
+import { logger } from '@/lib/logger';
+import { fetchWithSSLSupport } from '@/lib/utils/fetch';
+
+/**
+ * 代理请求处理函数
+ */
+export async function POST(request: NextRequest) {
+  try {
+    // 获取请求数据
+    const data = await request.json();
+    const { url, method = 'GET', headers = {}, body } = data;
+
+    if (!url) {
+      return NextResponse.json({ error: '缺少必要的URL参数' }, { status: 400 });
+    }
+
+    // 记录代理请求信息
+    logger.info('[代理请求]', method, url, {
+      headers,
+      '数据': body || '无'
+    });
+
+    // 准备请求选项
+    const fetchOptions: RequestInit = {
+      method,
+      headers: {
+        'Content-Type': 'application/json',
+        ...headers
+      }
+    };
+
+    // 如果有请求体，添加到选项中
+    if (body) {
+      fetchOptions.body = JSON.stringify(body);
+    }
+
+    // 使用支持自签名证书的fetch发送请求
+    const response = await fetchWithSSLSupport(url, fetchOptions);
+
+    // 获取响应数据
+    const responseData = await response.text();
+
+    // 返回响应
+    return new NextResponse(responseData, {
+      status: response.status,
+      headers: {
+        'Content-Type': response.headers.get('Content-Type') || 'application/json'
+      }
+    });
+
+  } catch (error) {
+    // 记录错误
+    logger.error('[代理请求错误]', error);
+    
+    // 返回错误响应
+    return NextResponse.json({ 
+      error: '代理请求失败',
+      message: error instanceof Error ? error.message : '未知错误'
+    }, { status: 500 });
+  }
+} 

app/bk/page.tsx

@@ -29,7 +29,7 @@ import { Icon } from "@iconify/react";
 import { FlowTrafficChart } from "@/components/ui/flow-traffic-chart";
 import { useRouter } from "next/navigation";
 import { EndpointStatus } from '@prisma/client';
-import { useGlobalSSE, useDashboardSSE } from '@/lib/hooks/use-sse';
+import { useGlobalSSE } from '@/lib/hooks/use-sse';
 import { motion } from 'framer-motion';
 import { FontAwesomeIcon } from '@fortawesome/react-fontawesome';
 import { 
@@ -300,23 +300,6 @@ export default function DashboardPage() {
       }
     }
   });
-  
-  // 使用仪表盘SSE监听流量趋势更新
-  useDashboardSSE({
-    onConnected: () => {
-      console.log('仪表盘SSE连接成功');
-    },
-    onMessage: (data) => {
-      if (data.type === 'dashboard_update') {
-        // 处理流量趋势更新
-        console.log('收到仪表盘更新:', data);
-        // 这里可以更新UI状态
-      }
-    },
-    onError: (error) => {
-      console.error('仪表盘SSE错误:', error);
-    }
-  });
 
   // 初始化数据
   useEffect(() => {

lib/logger.ts

@@ -0,0 +1,45 @@
+/**
+ * 日志级别枚举
+ */
+export enum LogLevel {
+  DEBUG = 'DEBUG',
+  INFO = 'INFO',
+  WARN = 'WARN',
+  ERROR = 'ERROR'
+}
+
+/**
+ * 日志工具类
+ */
+class Logger {
+  /**
+   * 输出调试日志
+   */
+  debug(...args: any[]) {
+    console.debug(`[${new Date().toISOString()}] [DEBUG]`, ...args);
+  }
+
+  /**
+   * 输出信息日志
+   */
+  info(...args: any[]) {
+    console.info(`[${new Date().toISOString()}] [INFO]`, ...args);
+  }
+
+  /**
+   * 输出警告日志
+   */
+  warn(...args: any[]) {
+    console.warn(`[${new Date().toISOString()}] [WARN]`, ...args);
+  }
+
+  /**
+   * 输出错误日志
+   */
+  error(...args: any[]) {
+    console.error(`[${new Date().toISOString()}] [ERROR]`, ...args);
+  }
+}
+
+// 导出单例实例
+export const logger = new Logger(); 

prisma/migrations/20250606111858_add_last_event_time_to_tunnel/migration.sql

@@ -0,0 +1,5 @@
+-- AlterTable
+ALTER TABLE "Tunnel" ADD COLUMN "lastEventTime" DATETIME;
+
+-- CreateIndex
+CREATE INDEX "Tunnel_lastEventTime_idx" ON "Tunnel"("lastEventTime");