From 5fe5c76375f30dc045e8da0cb9b1411a51bdafb1 Mon Sep 17 00:00:00 2001
From: openclaw <openclaw@yang.nyc.mn>
Date: Tue, 3 Mar 2026 20:35:38 +0800
Subject: [PATCH] node: return observable metrics for ip change
 broadcast/reconnect

---
 internal/server/node_api.go | 35 ++++++++++++++++++++++++++++++++++-
 1 file changed, 34 insertions(+), 1 deletion(-)

diff --git a/internal/server/node_api.go b/internal/server/node_api.go
index 63b9674..73ef6ee 100644
--- a/internal/server/node_api.go
+++ b/internal/server/node_api.go
@@ -4,6 +4,8 @@ import (
 	"encoding/json"
 	"net/http"
 	"strings"
+
+	"github.com/openp2p-cn/inp2p/pkg/protocol"
 )
 
 func (s *Server) HandleNodeMeta(w http.ResponseWriter, r *http.Request) {
@@ -51,7 +53,38 @@ func (s *Server) HandleNodeMeta(w http.ResponseWriter, r *http.Request) {
 			writeJSON(w, http.StatusBadRequest, `{"error":1,"message":"`+err.Error()+`"}`)
 			return
 		}
-		writeJSON(w, http.StatusOK, `{"error":0,"message":"ok"}`)
+
+		nodes := s.GetOnlineNodesByTenant(ac.TenantID)
+		affectedNode := ""
+		reconnectTriggered := false
+		broadcastCount := 0
+		for _, n := range nodes {
+			nc, err := s.store.GetNodeCredentialByName(ac.TenantID, n.Name)
+			if err != nil || nc == nil {
+				continue
+			}
+			peer := map[string]any{"node": n.Name, "ip": nc.VirtualIP, "online": n.IsOnline()}
+			if nc.NodeUUID == req.NodeUUID {
+				affectedNode = n.Name
+				_ = n.Conn.Write(protocol.MsgPush, protocol.SubPushSDWANDel, peer)
+				n.Conn.Close()
+				reconnectTriggered = true
+				continue
+			}
+			_ = n.Conn.Write(protocol.MsgPush, protocol.SubPushSDWANPeer, peer)
+			broadcastCount++
+		}
+
+		resp, _ := json.Marshal(map[string]any{
+			"error":               0,
+			"message":             "ok",
+			"affected_node":       affectedNode,
+			"target_node_uuid":    req.NodeUUID,
+			"new_virtual_ip":      req.VirtualIP,
+			"broadcast_count":     broadcastCount,
+			"reconnect_triggered": reconnectTriggered,
+		})
+		writeJSON(w, http.StatusOK, string(resp))
 		return
 	}