@@ -91,7 +91,6 @@ func DeleteNode(node *models.Node, purge bool) error {
if err := UpdateNode(node, &newnode); err != nil {
return err
}
- return nil
host, err := GetHost(node.HostID.String())
if err != nil {
@@ -178,6 +178,24 @@ func fetchHostAcls(hostID string) []Acl {
Priority: -1,
Allow: true,
},
+ {
+ AclType: "publishClientReceive",
+ Topic: fmt.Sprintf("update/%s/#", hostID),
+ Priority: -1,
+ Allow: true,
+ },
+ AclType: "subscribePattern",
+ Topic: "#",
+ AclType: "unsubscribePattern",