From 3e2d22a16b43a99984fdabfd18deac7c63cc0624 Mon Sep 17 00:00:00 2001 From: Abhishek Kondur Date: Mon, 9 Jan 2023 09:11:39 +0530 Subject: [PATCH] add proxy action to peer update --- logic/peers.go | 4 +++- mq/publishers.go | 1 - 2 files changed, 3 insertions(+), 2 deletions(-) diff --git a/logic/peers.go b/logic/peers.go index 4bb83ebb..5d1c3cd3 100644 --- a/logic/peers.go +++ b/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 diff --git a/mq/publishers.go b/mq/publishers.go index d2b99157..ce530dad 100644 --- a/mq/publishers.go +++ b/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 }