From 0efff562be940006ed30ef7c39c01cd156b95e6a Mon Sep 17 00:00:00 2001 From: Abhishek Kondur Date: Thu, 9 Feb 2023 21:58:50 +0400 Subject: [PATCH] add other ext clients as peers --- logic/peers.go | 23 ++++++++++------------- 1 file changed, 10 insertions(+), 13 deletions(-) diff --git a/logic/peers.go b/logic/peers.go index ffb9a897..cff02df6 100644 --- a/logic/peers.go +++ b/logic/peers.go @@ -434,6 +434,16 @@ func GetPeerUpdateForHost(host *models.Host) (models.HostPeerUpdate, error) { if node.IsIngressGateway { extPeers, extPeerIDAndAddrs, err = getExtPeers(&node) if err == nil { + for _, extPeerIdAndAddr := range extPeerIDAndAddrs { + nodePeerMap[extPeerIdAndAddr.ID] = models.PeerRouteInfo{ + PeerAddr: net.IPNet{ + IP: net.ParseIP(extPeerIdAndAddr.Address), + Mask: getCIDRMaskFromAddr(extPeerIdAndAddr.Address), + }, + PeerKey: extPeerIdAndAddr.ID, + Allow: true, + } + } hostPeerUpdate.Peers = append(hostPeerUpdate.Peers, extPeers...) for _, extPeerIdAndAddr := range extPeerIDAndAddrs { hostPeerUpdate.PeerIDs[extPeerIdAndAddr.ID] = make(map[string]models.IDandAddr) @@ -464,19 +474,6 @@ func GetPeerUpdateForHost(host *models.Host) (models.HostPeerUpdate, error) { } } if node.IsEgressGateway { - if node.IsIngressGateway { - for _, extPeerIdAndAddr := range extPeerIDAndAddrs { - nodePeerMap[extPeerIdAndAddr.ID] = models.PeerRouteInfo{ - PeerAddr: net.IPNet{ - IP: net.ParseIP(extPeerIdAndAddr.Address), - Mask: getCIDRMaskFromAddr(extPeerIdAndAddr.Address), - }, - PeerKey: extPeerIdAndAddr.ID, - Allow: true, - } - } - - } hostPeerUpdate.EgressInfo[node.ID.String()] = models.EgressInfo{ EgressID: node.ID.String(), Network: node.PrimaryNetworkRange(),