Move GetRelays to pro package

This commit is contained in:
gabrielseibel1 2023-09-28 13:55:43 -03:00
parent bf12675274
commit 682059c948
4 changed files with 23 additions and 18 deletions

View file

@ -11,21 +11,6 @@ import (
"github.com/gravitl/netmaker/servercfg"
)
// GetRelays - gets all the nodes that are relays
func GetRelays() ([]models.Node, error) {
nodes, err := GetAllNodes()
if err != nil {
return nil, err
}
relays := make([]models.Node, 0)
for _, node := range nodes {
if node.IsRelay {
relays = append(relays, node)
}
}
return relays, nil
}
// GetInternetGateways - gets all the nodes that are internet gateways
func GetInternetGateways() ([]models.Node, error) {
nodes, err := GetAllNodes()

View file

@ -5,6 +5,10 @@ import (
"net"
)
var GetRelays = func() ([]models.Node, error) {
return []models.Node{}, nil
}
var RelayedAllowedIPs = func(peer, node *models.Node) []net.IPNet {
return []net.IPNet{}
}

View file

@ -52,6 +52,7 @@ func InitPro() {
logic.GetMetrics = proLogic.GetMetrics
logic.UpdateMetrics = proLogic.UpdateMetrics
logic.DeleteMetrics = proLogic.DeleteMetrics
logic.GetRelays = proLogic.GetRelays
logic.GetAllowedIpsForRelayed = proLogic.GetAllowedIpsForRelayed
logic.RelayedAllowedIPs = proLogic.RelayedAllowedIPs
logic.UpdateRelayed = proLogic.UpdateRelayed

View file

@ -12,6 +12,21 @@ import (
"net"
)
// GetRelays - gets all the nodes that are relays
func GetRelays() ([]models.Node, error) {
nodes, err := logic.GetAllNodes()
if err != nil {
return nil, err
}
relays := make([]models.Node, 0)
for _, node := range nodes {
if node.IsRelay {
relays = append(relays, node)
}
}
return relays, nil
}
// CreateRelay - creates a relay
func CreateRelay(relay models.RelayRequest) ([]models.Node, models.Node, error) {
var returnnodes []models.Node
@ -67,7 +82,7 @@ func SetRelayedNodes(setRelayed bool, relay string, relayed []string) []models.N
return returnnodes
}
//func GetRelayedNodes(relayNode *models.Node) (models.Node, error) {
// func GetRelayedNodes(relayNode *models.Node) (models.Node, error) {
// var returnnodes []models.Node
// networkNodes, err := GetNetworkNodes(relayNode.Network)
// if err != nil {
@ -81,12 +96,12 @@ func SetRelayedNodes(setRelayed bool, relay string, relayed []string) []models.N
// }
// }
// return returnnodes, nil
//}
// }
// ValidateRelay - checks if relay is valid
func ValidateRelay(relay models.RelayRequest) error {
var err error
//isIp := functions.IsIpCIDR(gateway.RangeString)
// isIp := functions.IsIpCIDR(gateway.RangeString)
empty := len(relay.RelayedNodes) == 0
if empty {
return errors.New("IP Ranges Cannot Be Empty")