diff options
| -rw-r--r-- | shelly.go | 35 |
1 files changed, 34 insertions, 1 deletions
@@ -5,6 +5,8 @@ import ( "log" "net" "strings" + + "github.com/gorilla/websocket" ) func ShellyRun(config ShellyConfigs, route Route) { @@ -15,7 +17,10 @@ func ShellyRun(config ShellyConfigs, route Route) { continue } - log.Printf("Send '%s' to '%s'.", command, ip) + err = shellySendCommand(ip, command) + if err != nil { + log.Printf("Could not send command '%s' to %v: %v", command, ip, err) + } } } @@ -55,3 +60,31 @@ func parseMessage(config ShellyConfigs, m MQTTMessage) (ip *net.IP, command stri return nil, "", fmt.Errorf("Got message for unknown cover '%s'", id) } + +func shellySendCommand(ip *net.IP, command string) error { + template := ` +{ + "jsonrpc":"2.0", + "id": 1, + "src":"user_1", + "method":"%s", + "params": { + "id":0 + } +} +` + message := fmt.Appendf([]byte{}, template, command) + + c, _, err := websocket.DefaultDialer.Dial("ws://" + ip.String() + "/rpc", nil) + if err != nil { + return fmt.Errorf("Could not connect to Shelly: %w", err) + } + defer c.Close() + + err = c.WriteMessage(websocket.TextMessage, message) + if err != nil { + return fmt.Errorf("Failed writing websocket message to Shelly: %w", err) + } + + return nil +} |