extern/netbird
1
0
Fork 0
mirror of https://github.com/netbirdio/netbird.git synced 2025-08-16 18:11:58 +02:00
Code Issues Packages Projects Releases Wiki Activity

Refactor router peer validation

Browse Source 
Signed-off-by: bcmmbaga <bethuelmbaga12@gmail.com>
This commit is contained in:
bcmmbaga
2024-12-17 18:11:24 +03:00
parent bcf32f215c
commit e8f7b7f23d
1 changed files with 7 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
management/server/types/account.go
View File

@ -1219,27 +1219,27 @@ func (a *Account) getRoutingPeerNetworkResourcesRoutes(ctx context.Context, peer
} }
for _, router := range a.NetworkRouters { for _, router := range a.NetworkRouters {
isMember := false
for _, groupID := range router.PeerGroups { for _, groupID := range router.PeerGroups {
group := a.GetGroup(groupID) group := a.GetGroup(groupID)
if group == nil { if group == nil {
log.WithContext(ctx).Errorf("router %s has peers group %s that doesn't exist under account %s", router.ID, groupID, a.Id) log.WithContext(ctx).Warnf("router %s has peers group %s that doesn't exist under account %s, will continue map generation", router.ID, groupID, a.Id)
continue continue
} }
for _, id := range group.Peers { for _, id := range group.Peers {
if id != peerID { if id == peerID {
continue isMember = true
break
} }
resources := a.getNetworkResources(router.NetworkID)
routes = append(routes, a.getNetworkResourcesRoutes(resources, router, peer)...)
} }
} }
if router.Peer == peerID { if isMember || router.Peer == peerID {
resources := a.getNetworkResources(router.NetworkID) resources := a.getNetworkResources(router.NetworkID)
routes = append(routes, a.getNetworkResourcesRoutes(resources, router, peer)...) routes = append(routes, a.getNetworkResourcesRoutes(resources, router, peer)...)
} }
} }
return routes return routes