diff --git a/controllers/hosts.go b/controllers/hosts.go index 52187c5e..722994b6 100644 --- a/controllers/hosts.go +++ b/controllers/hosts.go @@ -94,6 +94,13 @@ func pull(w http.ResponseWriter, r *http.Request) { if servercfg.GetBrokerType() == servercfg.EmqxBrokerType { serverConf.MQUserName = hostID } + key, keyErr := logic.RetrievePublicTrafficKey() + if keyErr != nil { + logger.Log(0, "error retrieving key:", keyErr.Error()) + logic.ReturnErrorResponse(w, r, logic.FormatError(err, "internal")) + return + } + serverConf.TrafficKey = key response := models.HostPull{ Host: *host, ServerConfig: serverConf,