mirror of
https://github.com/gravitl/netmaker.git
synced 2024-09-21 15:56:07 +08:00
added beginning of re sub logic
This commit is contained in:
parent
71ffa797d4
commit
8232d8b744
|
@ -115,7 +115,6 @@ var All mqtt.MessageHandler = func(client mqtt.Client, msg mqtt.Message) {
|
||||||
|
|
||||||
// NodeUpdate -- mqtt message handler for /update/<NodeID> topic
|
// NodeUpdate -- mqtt message handler for /update/<NodeID> topic
|
||||||
func NodeUpdate(client mqtt.Client, msg mqtt.Message) {
|
func NodeUpdate(client mqtt.Client, msg mqtt.Message) {
|
||||||
ncutils.Log("received message to update node " + string(msg.Payload()))
|
|
||||||
//potentiall blocking i/o so do this in a go routine
|
//potentiall blocking i/o so do this in a go routine
|
||||||
go func() {
|
go func() {
|
||||||
var newNode models.Node
|
var newNode models.Node
|
||||||
|
@ -125,6 +124,7 @@ func NodeUpdate(client mqtt.Client, msg mqtt.Message) {
|
||||||
ncutils.Log("error unmarshalling node update data" + err.Error())
|
ncutils.Log("error unmarshalling node update data" + err.Error())
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
ncutils.Log("received message to update node " + newNode.Name)
|
||||||
// see if cache hit, if so skip
|
// see if cache hit, if so skip
|
||||||
var currentMessage = read(newNode.Network, lastNodeUpdate)
|
var currentMessage = read(newNode.Network, lastNodeUpdate)
|
||||||
if currentMessage == string(msg.Payload()) {
|
if currentMessage == string(msg.Payload()) {
|
||||||
|
|
Loading…
Reference in a new issue