incoming_ping_processor.go

package protocol

import (
	"github.com/iotaledger/goshimmer/packages/events"
	"github.com/iotaledger/goshimmer/packages/node"
	"github.com/iotaledger/goshimmer/plugins/autopeering/instances/knownpeers"
	"github.com/iotaledger/goshimmer/plugins/autopeering/types/ping"
)

func createIncomingPingProcessor(plugin *node.Plugin) *events.Closure {
	return events.NewClosure(func(ping *ping.Ping) {
		plugin.LogDebug("received ping from " + ping.Issuer.String())

		knownpeers.INSTANCE.AddOrUpdate(ping.Issuer)
		for _, neighbor := range ping.Neighbors {
			knownpeers.INSTANCE.AddOrUpdate(neighbor)
		}
	})
}