From 0b49cd720f2192f774e8c25e58ea43ea3a389218 Mon Sep 17 00:00:00 2001 From: sagitchu Date: Wed, 22 Apr 2026 14:02:59 +0800 Subject: [PATCH] fix(backend): use proper protocol for chain hop diagnosis and tcp for external targets --- .../internal/http/handler/control_plane.go | 28 +++++++++---------- 1 file changed, 14 insertions(+), 14 deletions(-) diff --git a/go-backend/internal/http/handler/control_plane.go b/go-backend/internal/http/handler/control_plane.go index d3f62ec..baec361 100644 --- a/go-backend/internal/http/handler/control_plane.go +++ b/go-backend/internal/http/handler/control_plane.go @@ -711,7 +711,7 @@ func (h *Handler) prepareForwardDiagnosis(forward *forwardRecord) (string, []dia targetIP: target.IP, targetPort: target.Port, description: description, - protocol: protocol, + protocol: "tcp", metadata: map[string]interface{}{ "fromChainType": 1, }, @@ -729,7 +729,7 @@ func (h *Handler) prepareForwardDiagnosis(forward *forwardRecord) (string, []dia hasChainHop: true, ipPreference: ipPreference, description: description, - protocol: protocol, + protocol: defaultString(strings.ToLower(strings.TrimSpace(firstNode.Protocol)), protocol), metadata: map[string]interface{}{ "fromChainType": 1, "toChainType": 2, @@ -746,7 +746,7 @@ func (h *Handler) prepareForwardDiagnosis(forward *forwardRecord) (string, []dia hasChainHop: true, ipPreference: ipPreference, description: description, - protocol: protocol, + protocol: defaultString(strings.ToLower(strings.TrimSpace(outNode.Protocol)), protocol), metadata: map[string]interface{}{ "fromChainType": 1, "toChainType": 3, @@ -767,7 +767,7 @@ func (h *Handler) prepareForwardDiagnosis(forward *forwardRecord) (string, []dia hasChainHop: true, ipPreference: ipPreference, description: description, - protocol: protocol, + protocol: defaultString(strings.ToLower(strings.TrimSpace(nextNode.Protocol)), protocol), metadata: map[string]interface{}{ "fromChainType": 2, "fromInx": currentNode.Inx, @@ -785,7 +785,7 @@ func (h *Handler) prepareForwardDiagnosis(forward *forwardRecord) (string, []dia hasChainHop: true, ipPreference: ipPreference, description: description, - protocol: protocol, + protocol: defaultString(strings.ToLower(strings.TrimSpace(outNode.Protocol)), protocol), metadata: map[string]interface{}{ "fromChainType": 2, "fromInx": currentNode.Inx, @@ -805,7 +805,7 @@ func (h *Handler) prepareForwardDiagnosis(forward *forwardRecord) (string, []dia targetIP: target.IP, targetPort: target.Port, description: description, - protocol: protocol, + protocol: "tcp", metadata: map[string]interface{}{ "fromChainType": 3, }, @@ -821,7 +821,7 @@ func (h *Handler) prepareForwardDiagnosis(forward *forwardRecord) (string, []dia targetIP: target.IP, targetPort: target.Port, description: description, - protocol: protocol, + protocol: "tcp", metadata: map[string]interface{}{ "fromChainType": 1, }, @@ -889,7 +889,7 @@ func (h *Handler) prepareTunnelDiagnosis(tunnelID int64) (string, string, []diag targetIP: "www.bing.com", targetPort: 443, description: description, - protocol: protocol, + protocol: "tcp", metadata: map[string]interface{}{ "fromChainType": 1, }, @@ -906,7 +906,7 @@ func (h *Handler) prepareTunnelDiagnosis(tunnelID int64) (string, string, []diag hasChainHop: true, ipPreference: ipPreference, description: description, - protocol: protocol, + protocol: defaultString(strings.ToLower(strings.TrimSpace(firstNode.Protocol)), protocol), metadata: map[string]interface{}{ "fromChainType": 1, "toChainType": 2, @@ -923,7 +923,7 @@ func (h *Handler) prepareTunnelDiagnosis(tunnelID int64) (string, string, []diag hasChainHop: true, ipPreference: ipPreference, description: description, - protocol: protocol, + protocol: defaultString(strings.ToLower(strings.TrimSpace(outNode.Protocol)), protocol), metadata: map[string]interface{}{ "fromChainType": 1, "toChainType": 3, @@ -944,7 +944,7 @@ func (h *Handler) prepareTunnelDiagnosis(tunnelID int64) (string, string, []diag hasChainHop: true, ipPreference: ipPreference, description: description, - protocol: protocol, + protocol: defaultString(strings.ToLower(strings.TrimSpace(nextNode.Protocol)), protocol), metadata: map[string]interface{}{ "fromChainType": 2, "fromInx": currentNode.Inx, @@ -962,7 +962,7 @@ func (h *Handler) prepareTunnelDiagnosis(tunnelID int64) (string, string, []diag hasChainHop: true, ipPreference: ipPreference, description: description, - protocol: protocol, + protocol: defaultString(strings.ToLower(strings.TrimSpace(outNode.Protocol)), protocol), metadata: map[string]interface{}{ "fromChainType": 2, "fromInx": currentNode.Inx, @@ -981,7 +981,7 @@ func (h *Handler) prepareTunnelDiagnosis(tunnelID int64) (string, string, []diag targetIP: "www.bing.com", targetPort: 443, description: description, - protocol: protocol, + protocol: "tcp", metadata: map[string]interface{}{ "fromChainType": 3, }, @@ -995,7 +995,7 @@ func (h *Handler) prepareTunnelDiagnosis(tunnelID int64) (string, string, []diag targetIP: "www.bing.com", targetPort: 443, description: description, - protocol: protocol, + protocol: "tcp", metadata: map[string]interface{}{ "fromChainType": 1, },