dhcgn/hm2mqtt

package cmdhandler

import (
    "log"
    "strings"

    "github.com/dhcgn/hm2mqtt/hmclient"
    mqtt "github.com/eclipse/paho.mqtt.golang"
)

// CmdHandler can send new
type CmdHandler interface {
    SendNewStateToHomematic(msg mqtt.Message)
}

type cmdHandler struct {
    homematicURL string
}

// NewCmdHandler creates a CmdHandler
func NewCmdHandler(homematicURL string) CmdHandler {
    return &cmdHandler{
        homematicURL: homematicURL,
    }
}

func (c *cmdHandler) SendNewStateToHomematic(msg mqtt.Message) {
    log.Println("cmd receiver got msg", msg.Topic(), string(msg.Payload()))

    segments := strings.Split(msg.Topic(), "/")
    if len(segments) != 5 {
        log.Println("cmd receiver got invalid msg, should be e.g. hm/set/JEQ0000000:1/Level/ with value: 1")
    }

    valueKey := segments[len(segments)-2]
    address := segments[len(segments)-3]
    value := string(msg.Payload())

    // TODO should be an interface
    hmclient.SetState(address, valueKey, value, c.homematicURL)
}