|
@@ -3,6 +3,7 @@ package logic
|
|
import (
|
|
import (
|
|
"context"
|
|
"context"
|
|
"encoding/json"
|
|
"encoding/json"
|
|
|
|
+ "fmt"
|
|
"maps"
|
|
"maps"
|
|
"net"
|
|
"net"
|
|
|
|
|
|
@@ -45,6 +46,7 @@ func ValidateEgressReq(e *schema.Egress) bool {
|
|
// check if node is acting as egress gw already
|
|
// check if node is acting as egress gw already
|
|
GetNodeEgressInfo(&inetNode)
|
|
GetNodeEgressInfo(&inetNode)
|
|
if err := ValidateInetGwReq(inetNode, req, false); err != nil {
|
|
if err := ValidateInetGwReq(inetNode, req, false); err != nil {
|
|
|
|
+ fmt.Println("====> Failed to Validate Egress: ", err)
|
|
return false
|
|
return false
|
|
}
|
|
}
|
|
|
|
|
|
@@ -55,17 +57,14 @@ func ValidateEgressReq(e *schema.Egress) bool {
|
|
for k := range e.Nodes {
|
|
for k := range e.Nodes {
|
|
egressNode, err := GetNodeByID(k)
|
|
egressNode, err := GetNodeByID(k)
|
|
if err != nil {
|
|
if err != nil {
|
|
|
|
+ fmt.Println("hereee 1")
|
|
return false
|
|
return false
|
|
}
|
|
}
|
|
GetNodeEgressInfo(&egressNode)
|
|
GetNodeEgressInfo(&egressNode)
|
|
if egressNode.InternetGwID != "" {
|
|
if egressNode.InternetGwID != "" {
|
|
|
|
+ fmt.Println("hereee 2")
|
|
return false
|
|
return false
|
|
}
|
|
}
|
|
- if e.IsInetGw {
|
|
|
|
- if egressNode.IsInternetGateway {
|
|
|
|
- return false
|
|
|
|
- }
|
|
|
|
- }
|
|
|
|
}
|
|
}
|
|
}
|
|
}
|
|
return true
|
|
return true
|