Browse Source

add proxy action to peer update

Abhishek Kondur 2 years ago
parent
commit
3e2d22a16b
2 changed files with 3 additions and 2 deletions
  1. 3 1
      logic/peers.go
  2. 0 1
      mq/publishers.go

+ 3 - 1
logic/peers.go

@@ -194,7 +194,9 @@ func GetPeersForProxy(node *models.Node, onlyPeers bool) (proxy_models.ProxyMana
 }
 
 func GetProxyUpdateForHost(host *models.Host) (proxy_models.ProxyManagerPayload, error) {
-	proxyPayload := proxy_models.ProxyManagerPayload{}
+	proxyPayload := proxy_models.ProxyManagerPayload{
+		Action: proxy_models.ProxyUpdate,
+	}
 	peerConfMap := make(map[string]proxy_models.PeerConf)
 
 	// ** TODO - RELAY NEEDS TO BE FIXED

+ 0 - 1
mq/publishers.go

@@ -61,7 +61,6 @@ func PublishSingleHostUpdate(host *models.Host) error {
 			return err
 		}
 		proxyUpdate.Action = proxy_models.ProxyUpdate
-		proxyUpdate.Peers = peerUpdate.Peers
 		peerUpdate.ProxyUpdate = proxyUpdate
 	}