|
|
@@ -364,7 +364,7 @@ func hostUpdateFallback(w http.ResponseWriter, r *http.Request) {
|
|
|
logic.ReturnErrorResponse(w, r, logic.FormatError(err, "internal"))
|
|
|
return
|
|
|
}
|
|
|
- fmt.Println("recieved host update", "name", hostUpdate.Host.Name, "id", hostUpdate.Host.ID, "action", hostUpdate.Action)
|
|
|
+ slog.Info("recieved host update", "name", hostUpdate.Host.Name, "id", hostUpdate.Host.ID, "action", hostUpdate.Action)
|
|
|
switch hostUpdate.Action {
|
|
|
case models.CheckIn:
|
|
|
sendPeerUpdate = mq.HandleHostCheckin(&hostUpdate.Host, currentHost)
|
|
|
@@ -385,7 +385,7 @@ func hostUpdateFallback(w http.ResponseWriter, r *http.Request) {
|
|
|
return
|
|
|
}
|
|
|
case models.UpdateNode:
|
|
|
- sendPeerUpdate, sendDeletedNodeUpdate = logic.UpdateHostNode(&hostUpdate.Host, &hostUpdate.Node)
|
|
|
+ sendDeletedNodeUpdate, sendPeerUpdate = logic.UpdateHostNode(&hostUpdate.Host, &hostUpdate.Node)
|
|
|
case models.UpdateMetrics:
|
|
|
mq.UpdateMetricsFallBack(hostUpdate.Node.ID.String(), hostUpdate.NewMetrics)
|
|
|
case models.EgressUpdate:
|
|
|
@@ -411,7 +411,6 @@ func hostUpdateFallback(w http.ResponseWriter, r *http.Request) {
|
|
|
mq.PublishDeletedNodePeerUpdate(&hostUpdate.Node)
|
|
|
}
|
|
|
if sendPeerUpdate {
|
|
|
- fmt.Println("=====> Sending PEER UPDATE: ", hostUpdate.Action)
|
|
|
err := mq.PublishPeerUpdate(replacePeers)
|
|
|
if err != nil {
|
|
|
slog.Error("failed to publish peer update", "error", err)
|
abhishek9686