From c0e2cf63b565e9b69680f58da6eed6722f234568 Mon Sep 17 00:00:00 2001
From: yusing <yusing.wys@gmail.com>
Date: Sat, 31 Jan 2026 18:50:13 +0800
Subject: [PATCH] fix(health/check): validate URL port before dialing in Stream
 check

Add port validation to return an unhealthy result with descriptive
message when URL has no port specified, preventing potential dialing
errors on zero port.
---
 internal/health/check/stream.go | 8 ++++++++
 1 file changed, 8 insertions(+)

diff --git a/internal/health/check/stream.go b/internal/health/check/stream.go
index 6f4c9a16..8ccfa915 100644
--- a/internal/health/check/stream.go
+++ b/internal/health/check/stream.go
@@ -12,6 +12,14 @@ import (
 )
 
 func Stream(ctx context.Context, url *url.URL, timeout time.Duration) (types.HealthCheckResult, error) {
+	if port := url.Port(); port == "" || port == "0" {
+		return types.HealthCheckResult{
+			Latency: 0,
+			Healthy: false,
+			Detail:  "no port specified",
+		}, nil
+	}
+
 	dialer := net.Dialer{
 		Timeout:       timeout,
 		FallbackDelay: -1,