From 9bce1e1232398cf3061246458c9c2adcc9b51a4b Mon Sep 17 00:00:00 2001
From: kangxiang <kangxiang@yunshan.net>
Date: Fri, 28 Feb 2025 14:24:50 +0800
Subject: [PATCH] feat: verify node internal address

---
 server/controller/cloud/common/net.go                 | 2 ++
 server/controller/cloud/kubernetes_gather/pod_node.go | 4 ++++
 2 files changed, 6 insertions(+)

diff --git a/server/controller/cloud/common/net.go b/server/controller/cloud/common/net.go
index 7b120c7197c..b58a5e5bfca 100644
--- a/server/controller/cloud/common/net.go
+++ b/server/controller/cloud/common/net.go
@@ -66,6 +66,8 @@ func TidyIPString(ipsString []string) (v4Prefix, v6Prefix []netaddr.IPPrefix, er
 				ipS = ipS + "/32"
 			case strings.Contains(ipS, ":"):
 				ipS = ipS + "/128"
+			default:
+				continue
 			}
 		}
 		ipPrefix, prefixErr := netaddr.ParseIPPrefix(ipS)
diff --git a/server/controller/cloud/kubernetes_gather/pod_node.go b/server/controller/cloud/kubernetes_gather/pod_node.go
index 8ed4d9a54f7..f8276fb2b6f 100644
--- a/server/controller/cloud/kubernetes_gather/pod_node.go
+++ b/server/controller/cloud/kubernetes_gather/pod_node.go
@@ -64,6 +64,10 @@ func (k *KubernetesGather) getPodNodes() (podNodes []model.PodNode, nodeNetwork,
 				continue
 			}
 			nIP := nodeIPitem.Get("address").MustString()
+			if nIP == "" {
+				log.Warningf("invalid node internal address (%s)", nIP, logger.NewORGPrefix(k.orgID))
+				continue
+			}
 			nodeIPs = append(nodeIPs, nIP)
 		}
 		if len(nodeIPs) == 0 {