gravitl/netmaker
1
1
Fork 0
mirror of https://github.com/gravitl/netmaker.git synced 2025-11-09 16:21:01 +08:00
Code Issues Projects Releases Packages Wiki Activity

fix ext-ext comms

Browse source
This commit is contained in:
abhishek9686 2025-03-06 03:45:09 +04:00
parent 9a1c1c281b
commit 6e1b16a6ea
1 changed files with 6 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

8
logic/extpeers.go
View file

@ -685,10 +685,14 @@ func GetFwRulesOnIngressGateway(node models.Node) (rules []models.FwRule) {
if peer.StaticNode.ClientID == nodeI.StaticNode.ClientID || peer.IsUserNode { if peer.StaticNode.ClientID == nodeI.StaticNode.ClientID || peer.IsUserNode {
continue continue
} }
if nodeI.StaticNode.IngressGatewayID != node.ID.String() && peer.ID.String() != node.ID.String() { if nodeI.StaticNode.IngressGatewayID != node.ID.String() &&
((!peer.IsStatic && peer.ID.String() != node.ID.String()) ||
(peer.IsStatic && peer.StaticNode.IngressGatewayID != node.ID.String())) {
continue continue
} }
if peer.IsStatic {
peer = peer.StaticNode.ConvertToStaticNode()
}
if ok, allowedPolicies := IsNodeAllowedToCommunicateV1(nodeI.StaticNode.ConvertToStaticNode(), peer, true); ok { if ok, allowedPolicies := IsNodeAllowedToCommunicateV1(nodeI.StaticNode.ConvertToStaticNode(), peer, true); ok {
rules = append(rules, getFwRulesForNodeAndPeerOnGw(nodeI.StaticNode.ConvertToStaticNode(), peer, allowedPolicies)...) rules = append(rules, getFwRulesForNodeAndPeerOnGw(nodeI.StaticNode.ConvertToStaticNode(), peer, allowedPolicies)...)
} }