add config to check for reset peer udpate

This commit is contained in:
abhishek9686 2025-01-20 17:56:33 +05:30
parent 26300dc9ed
commit 557270acdb

View file

@ -5,6 +5,7 @@ import (
"errors"
"fmt"
"net/http"
"os"
"github.com/google/uuid"
"github.com/gorilla/mux"
@ -181,7 +182,11 @@ func pull(w http.ResponseWriter, r *http.Request) {
}
}
if sendPeerUpdate {
if err := mq.PublishPeerUpdate(true); err != nil {
reset := true
if os.Getenv("RESET_PEER_UPDATE") != "" {
reset = os.Getenv("RESET_PEER_UPDATE") == "true"
}
if err := mq.PublishPeerUpdate(reset); err != nil {
logger.Log(0, "fail to publish peer update: ", err.Error())
}
}