浏览代码

publish proxy for ext peers

Abhishek Kondur 2 年之前
父节点
当前提交
8cf3144013
共有 1 个文件被更改,包括 4 次插入0 次删除
  1. 4 0
      mq/publishers.go

+ 4 - 0
mq/publishers.go

@@ -110,6 +110,10 @@ func PublishExtPeerUpdate(node *models.Node) error {
 	if err != nil {
 	if err != nil {
 		return err
 		return err
 	}
 	}
+	proxyUpdate, err := logic.GetPeersForProxy(node, false)
+	if err == nil {
+		peerUpdate.ProxyUpdate = proxyUpdate
+	}
 	if err = publish(node, fmt.Sprintf("peers/%s/%s", node.Network, node.ID), data); err != nil {
 	if err = publish(node, fmt.Sprintf("peers/%s/%s", node.Network, node.ID), data); err != nil {
 		return err
 		return err
 	}
 	}