fix egress domain update

controllers/egress.go

@@ -4,6 +4,7 @@ import (
 	"context"
 	"encoding/json"
 	"errors"
+	"fmt"
 	"net/http"
 	"time"
 
@@ -122,13 +123,14 @@ func createEgress(w http.ResponseWriter, r *http.Request) {
 		if req.Nodes != nil {
 			for nodeID := range req.Nodes {
 				node, err := logic.GetNodeByID(nodeID)
-				if err == nil {
+				if err != nil {
 					continue
 				}
-				host := logic.GetHostByNodeID(nodeID)
+				host, _ := logic.GetHost(node.HostID.String())
 				if host == nil {
 					continue
 				}
+				fmt.Println("=======> Sending Host Update: ", host.Name)
 				mq.HostUpdate(&models.HostUpdate{
 					Action:   models.EgressUpdate,
 					Host:     *host,

controllers/hosts.go

@@ -391,6 +391,7 @@ func hostUpdateFallback(w http.ResponseWriter, r *http.Request) {
 	case models.UpdateMetrics:
 		mq.UpdateMetricsFallBack(hostUpdate.Node.ID.String(), hostUpdate.NewMetrics)
 	case models.EgressUpdate:
+		fmt.Println("=====> Recv Egress Update: ", hostUpdate.Node.EgressGatewayRanges)
 		e := schema.Egress{ID: hostUpdate.EgressID}
 		err = e.Get(db.WithContext(r.Context()))
 		if err != nil {