From cd2d026fc85feafb5ab421444f80c4dfbda50fe0 Mon Sep 17 00:00:00 2001 From: abhishek9686 Date: Mon, 21 Oct 2024 12:52:02 +0400 Subject: [PATCH] add ingress id to model --- logic/peers.go | 3 ++- models/mqtt.go | 3 ++- 2 files changed, 4 insertions(+), 2 deletions(-) diff --git a/logic/peers.go b/logic/peers.go index 1ca77184..c65861ea 100644 --- a/logic/peers.go +++ b/logic/peers.go @@ -293,7 +293,8 @@ func GetPeerUpdateForHost(network string, host *models.Host, allNodes []models.N extPeers, extPeerIDAndAddrs, egressRoutes, extUserIps, err = GetExtPeers(&node, &node) if err == nil { hostPeerUpdate.FwUpdate.IngressInfo[node.ID.String()] = models.IngressInfo{ - UserIps: extUserIps, + IngressID: node.ID.String(), + UserIps: extUserIps, } hostPeerUpdate.EgressRoutes = append(hostPeerUpdate.EgressRoutes, egressRoutes...) hostPeerUpdate.Peers = append(hostPeerUpdate.Peers, extPeers...) diff --git a/models/mqtt.go b/models/mqtt.go index 3463afe8..504c9859 100644 --- a/models/mqtt.go +++ b/models/mqtt.go @@ -28,7 +28,8 @@ type HostPeerUpdate struct { // IngressInfo - struct for ingress info type IngressInfo struct { - UserIps []net.IP + IngressID string `json:"ingress_id"` + UserIps []net.IP `json:"user_ips"` } // EgressInfo - struct for egress info