Explorar o código

Merge pull request #3515 from gravitl/master

Master
Abhishek K hai 2 meses
pai
achega
0197de24f1
Modificáronse 4 ficheiros con 5 adicións e 3 borrados
  1. 1 1
      controllers/node.go
  2. 2 1
      logic/peers.go
  3. 1 1
      migrate/migrate.go
  4. 1 0
      pro/logic/failover.go

+ 1 - 1
controllers/node.go

@@ -178,7 +178,7 @@ func Authorize(
 			// check if host instead of user
 			if hostAllowed {
 				// TODO --- should ensure that node is only operating on itself
-				if hostID, macAddr, _, err := logic.VerifyHostToken(authToken); err == nil && macAddr != "" {
+				if hostID, _, _, err := logic.VerifyHostToken(authToken); err == nil {
 					r.Header.Set(hostIDHeader, hostID)
 					// this indicates request is from a node
 					// used for failover - if a getNode comes from node, this will trigger a metrics wipe

+ 2 - 1
logic/peers.go

@@ -194,7 +194,8 @@ func GetPeerUpdateForHost(network string, host *models.Host, allNodes []models.N
 			continue
 		}
 
-		if !node.Connected || node.PendingDelete || node.Action == models.NODE_DELETE || time.Since(node.LastCheckIn) > time.Hour {
+		if !node.Connected || node.PendingDelete || node.Action == models.NODE_DELETE ||
+			(!node.LastCheckIn.IsZero() && time.Since(node.LastCheckIn) > time.Hour) {
 			continue
 		}
 		acls, _ := ListAclsByNetwork(models.NetworkID(node.Network))

+ 1 - 1
migrate/migrate.go

@@ -581,7 +581,7 @@ func settings() {
 	}
 	settings := logic.GetServerSettings()
 	if settings.AuditLogsRetentionPeriodInDays == 0 {
-		settings.AuditLogsRetentionPeriodInDays = 30
+		settings.AuditLogsRetentionPeriodInDays = 7
 	}
 	if settings.DefaultDomain == "" {
 		settings.DefaultDomain = servercfg.GetDefaultDomain()

+ 1 - 0
pro/logic/failover.go

@@ -191,6 +191,7 @@ func GetFailOverPeerIps(peer, node *models.Node) []net.IPNet {
 			if failOverpeer.IsRelay {
 				for _, id := range failOverpeer.RelayedNodes {
 					rNode, _ := logic.GetNodeByID(id)
+					logic.GetNodeEgressInfo(&rNode, eli, acls)
 					if rNode.Address.IP != nil {
 						allowed := net.IPNet{
 							IP:   rNode.Address.IP,