Parcourir la source

peerUpdate for default host after new network created

Max Ma il y a 1 an
Parent
commit
1ed932abc9
1 fichiers modifiés avec 6 ajouts et 0 suppressions
  1. 6 0
      controllers/network.go

+ 6 - 0
controllers/network.go

@@ -490,6 +490,12 @@ func createNetwork(w http.ResponseWriter, r *http.Request) {
 			// make host remote access gateway
 			logic.CreateIngressGateway(network.NetID, newNode.ID.String(), models.IngressRequest{})
 		}
+		// send peer updates
+		if servercfg.IsMessageQueueBackend() {
+			if err = mq.PublishPeerUpdate(false); err != nil {
+				logger.Log(1, "failed to publish peer update for default hosts after network is added")
+			}
+		}
 	}()
 
 	logger.Log(1, r.Header.Get("user"), "created network", network.NetID)