build: version 3.0.0

Author: Mecozea

internal/api/tunnel.go

@@ -179,7 +179,7 @@ func (h *TunnelHandler) HandleCreateTunnel(c *gin.Context) {
 		Min            json.RawMessage `json:"min"`
 		Max            json.RawMessage `json:"max"`
 		Slot           json.RawMessage `json:"slot"`                       // 新增：最大连接数限制
-		Mode           *string         `json:"mode,omitempty"`             // 新增：运行模式 (0, 1, 2)
+		Mode           *int            `json:"mode,omitempty"`             // 新增：运行模式 (0, 1, 2)
 		Read           *string         `json:"read,omitempty"`             // 新增：数据读取超时时间
 		Rate           *string         `json:"rate,omitempty"`             // 新增：带宽速率限制
 		EnableSSEStore *bool           `json:"enable_sse_store,omitempty"` // 新增：是否启用SSE存储
@@ -582,7 +582,7 @@ func (h *TunnelHandler) HandleUpdateTunnel(c *gin.Context) {
 		Min            json.RawMessage `json:"min"`
 		Max            json.RawMessage `json:"max"`
 		Slot           json.RawMessage `json:"slot"`                       // 新增：最大连接数限制
-		Mode           *string         `json:"mode,omitempty"`             // 新增：运行模式
+		Mode           *int            `json:"mode,omitempty"`             // 新增：运行模式
 		Read           *string         `json:"read,omitempty"`             // 新增：数据读取超时时间
 		Rate           *string         `json:"rate,omitempty"`             // 新增：带宽速率限制
 		EnableSSEStore *bool           `json:"enable_sse_store,omitempty"` // 新增：是否启用SSE存储
@@ -662,8 +662,7 @@ func (h *TunnelHandler) HandleUpdateTunnel(c *gin.Context) {
 		// 处理Mode字段的类型转换
 		var modePtr *tunnel.TunnelMode
 		if rawCreate.Mode != nil {
-			mode := tunnel.TunnelMode(*rawCreate.Mode)
-			modePtr = &mode
+			modePtr = (*tunnel.TunnelMode)(rawCreate.Mode)
 		}
 
 		createReq := tunnel.CreateTunnelRequest{
@@ -1153,9 +1152,16 @@ func (h *TunnelHandler) HandleGetTunnelDetails(c *gin.Context) {
 	targetPort, _ := strconv.Atoi(tunnelRecord.TargetPort)
 
 	// 处理新字段的NULL值
-	mode := ""
+	var mode interface{}
 	if tunnelRecord.Mode.Valid {
-		mode = tunnelRecord.Mode.String
+		modeInt, err := strconv.Atoi(tunnelRecord.Mode.String)
+		if err != nil {
+			mode = nil
+		} else {
+			mode = modeInt
+		}
+	} else {
+		mode = nil
 	}
 	read := ""
 	if tunnelRecord.Read.Valid {
@@ -3006,7 +3012,7 @@ func (h *TunnelHandler) HandleUpdateTunnelV2(c *gin.Context) {
 		Min            json.RawMessage `json:"min"`
 		Max            json.RawMessage `json:"max"`
 		Slot           json.RawMessage `json:"slot"`                       // 新增：最大连接数限制
-		Mode           *string         `json:"mode,omitempty"`             // 新增：运行模式
+		Mode           *int            `json:"mode,omitempty"`             // 新增：运行模式
 		Read           *string         `json:"read,omitempty"`             // 新增：数据读取超时时间
 		Rate           *string         `json:"rate,omitempty"`             // 新增：带宽速率限制
 		EnableSSEStore *bool           `json:"enable_sse_store,omitempty"` // 新增：是否启用SSE存储
@@ -3155,8 +3161,7 @@ func (h *TunnelHandler) HandleUpdateTunnelV2(c *gin.Context) {
 			// 处理Mode字段的类型转换
 			var modePtr *tunnel.TunnelMode
 			if raw.Mode != nil {
-				mode := tunnel.TunnelMode(*raw.Mode)
-				modePtr = &mode
+				modePtr = (*tunnel.TunnelMode)(raw.Mode)
 			}
 
 			createReq := tunnel.CreateTunnelRequest{

internal/endpoint/service.go

@@ -250,7 +250,7 @@ func (s *Service) UpdateEndpoint(req UpdateEndpointRequest) (*Endpoint, error) {
 		// 修改配置：更新名称、URL、API路径，可选的API密钥
 		updates := make(map[string]interface{})
 		needUpdateCache := false
-
+		
 		if req.Name != "" {
 			// 检查新名称是否已存在
 			var count int64
@@ -262,7 +262,7 @@ func (s *Service) UpdateEndpoint(req UpdateEndpointRequest) (*Endpoint, error) {
 			}
 			updates["name"] = req.Name
 		}
-
+		
 		if req.URL != "" && req.URL != endpoint.URL {
 			// 检查URL是否重复
 			var count int64
@@ -279,17 +279,17 @@ func (s *Service) UpdateEndpoint(req UpdateEndpointRequest) (*Endpoint, error) {
 			}
 			needUpdateCache = true
 		}
-
+		
 		if req.APIPath != "" && req.APIPath != endpoint.APIPath {
 			updates["api_path"] = req.APIPath
 			needUpdateCache = true
 		}
-
+		
 		if req.APIKey != "" && req.APIKey != endpoint.APIKey {
 			updates["api_key"] = req.APIKey
 			needUpdateCache = true
 		}
-
+		
 		updates["updated_at"] = time.Now()
 
 		if err := s.db.Model(&endpoint).Updates(updates).Error; err != nil {
@@ -311,7 +311,7 @@ func (s *Service) UpdateEndpoint(req UpdateEndpointRequest) (*Endpoint, error) {
 		if req.APIKey == "" {
 			return nil, errors.New("API密钥不能为空")
 		}
-
+		
 		updates := map[string]interface{}{
 			"api_key":    req.APIKey,
 			"updated_at": time.Now(),

internal/models/enums.go

@@ -51,12 +51,12 @@ const (
 )
 
 // TLSMode TLS模式枚举
-type TunnelMode string
+type TunnelMode int
 
 const (
-	Mode0 TunnelMode = "0"
-	Mode1 TunnelMode = "1"
-	Mode2 TunnelMode = "2"
+	Mode0 TunnelMode = 0
+	Mode1 TunnelMode = 1
+	Mode2 TunnelMode = 2
 )
 
 // LogLevel 日志级别枚举

internal/sse/service.go

@@ -284,6 +284,11 @@ func buildTunnel(payload SSEResp) *models.Tunnel {
 	tunnel.Restart = payload.Instance.Restart
 	tunnel.Name = *payload.Instance.Alias
 	tunnel.Status = models.TunnelStatus(payload.Instance.Status)
+	log.Infof("%v解析mode=%v", tunnel.InstanceID, tunnel.Mode)
+	if tunnel.Mode == nil {
+		log.Infof("%v url未显式模式，尝试使用mode字段", tunnel.InstanceID)
+		tunnel.Mode = (*models.TunnelMode)(payload.Instance.Mode)
+	}
 	return tunnel
 }
 

internal/websocket/service.go

@@ -252,7 +252,7 @@ func (s *Service) endpointMonitorWorker(ctx context.Context, endpointID int64) {
 
 // instanceMonitorWorker instance监控worker，每2秒查询一次instance接口
 func (s *Service) instanceMonitorWorker(ctx context.Context, instanceID string) {
-	ticker := time.NewTicker(2 * time.Second)
+	ticker := time.NewTicker(4 * time.Second)
 	defer ticker.Stop()
 
 	log.Infof("Instance %s 监控worker已启动，开始每2秒查询instance接口", instanceID)