Browse Source

publish peer update on adding host to a network

Abhishek Kondur 2 years ago
parent
commit
944e425e91
1 changed files with 5 additions and 0 deletions
  1. 5 0
      controllers/hosts.go

+ 5 - 0
controllers/hosts.go

@@ -224,6 +224,11 @@ func addHostToNetwork(w http.ResponseWriter, r *http.Request) {
 	}); err != nil {
 		logger.Log(0, r.Header.Get("user"), "failed to update host to join network:", hostid, network, err.Error())
 	}
+	go func() { // notify of peer change
+		if err := mq.PublishPeerUpdate(); err != nil {
+			logger.Log(1, "error publishing peer update ", err.Error())
+		}
+	}()
 
 	logger.Log(2, r.Header.Get("user"), fmt.Sprintf("added host %s to network %s", currHost.Name, network))
 	w.WriteHeader(http.StatusOK)