mirror of
https://github.com/Luzifer/culmqtt.git
synced 2024-11-09 22:40:07 +00:00
47 lines
1 KiB
Go
47 lines
1 KiB
Go
|
package main
|
||
|
|
|
||
|
|
import (
|
||
|
|
"fmt"
|
||
|
|
"strings"
|
||
|
|
|
||
|
|
mqtt "github.com/eclipse/paho.mqtt.golang"
|
||
|
|
log "github.com/sirupsen/logrus"
|
||
|
|
)
|
||
|
|
|
||
|
|
func processFS20Message(housecode, device, command string) error {
|
||
|
|
log.WithFields(log.Fields{
|
||
|
|
"housecode": housecode,
|
||
|
|
"device": device,
|
||
|
|
"command": command,
|
||
|
|
}).Info("FS20 status received")
|
||
|
|
|
||
|
|
return publishFS20ToMQTT(housecode, device, command)
|
||
|
|
}
|
||
|
|
|
||
|
|
func publishFS20ToCUL(client mqtt.Client, msg mqtt.Message) {
|
||
|
|
addr := strings.Split(msg.Topic(), "/")[1]
|
||
|
|
cmd := string(msg.Payload())
|
||
|
|
|
||
|
|
logger := log.WithFields(log.Fields{
|
||
|
|
"address": addr,
|
||
|
|
"command": cmd,
|
||
|
|
})
|
||
|
|
|
||
|
|
if _, err := fmt.Fprintf(port, "F%s%s\n", addr, cmd); err != nil {
|
||
|
|
logger.WithError(err).Error("Unable to send message through CUL")
|
||
|
|
}
|
||
|
|
logger.Info("Message sent")
|
||
|
|
}
|
||
|
|
|
||
|
|
func publishFS20ToMQTT(housecode, device, command string) error {
|
||
|
|
tok := brokerClient.Publish(
|
||
|
|
strings.Join([]string{"culmqtt", fmt.Sprintf("%s%s", housecode, device), "state"}, "/"),
|
||
|
|
0x01, // QOS Level 1: At least once
|
||
|
|
true,
|
||
|
|
command,
|
||
|
|
)
|
||
|
|
|
||
|
|
tok.Wait()
|
||
|
|
return tok.Error()
|
||
|
|
}
|