mudhorn/meshmap.net
1
0
Fork 0
mirror of https://github.com/brianshea2/meshmap.net.git synced 2024-11-14 01:24:13 -08:00
Code Issues Actions Packages Projects Releases Wiki Activity

add optional Accept function

Browse source
This commit is contained in:
root 2024-11-09 18:34:47 +00:00
parent 98cb8c734c
commit 754f73fe8a
1 changed files with 5 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

5
internal/meshtastic/mqtt.go
View file

@ -33,6 +33,7 @@ func NewBlockCipher(key []byte) cipher.Block {
type MQTTClient struct { type MQTTClient struct {
TopicRegex *regexp.Regexp TopicRegex *regexp.Regexp
Accept func(from uint32) bool
BlockCipher cipher.Block BlockCipher cipher.Block
MessageHandler func(from uint32, topic string, portNum generated.PortNum, payload []byte) MessageHandler func(from uint32, topic string, portNum generated.PortNum, payload []byte)
topics []string topics []string
@ -105,6 +106,10 @@ func (c *MQTTClient) handleMessage(_ mqtt.Client, msg mqtt.Message) {
log.Printf("[warn] skipping MeshPacket from unknown on %v", topic) log.Printf("[warn] skipping MeshPacket from unknown on %v", topic)
return return
} }
// check sender
if c.Accept != nil && !c.Accept(from) {
return
}
// get Data, try decoded first // get Data, try decoded first
data := packet.GetDecoded() data := packet.GetDecoded()
if data == nil { if data == nil {