diff options
| -rw-r--r-- | cmd/dolmetschctl/dolmetschctl.go | 73 |
1 files changed, 59 insertions, 14 deletions
diff --git a/cmd/dolmetschctl/dolmetschctl.go b/cmd/dolmetschctl/dolmetschctl.go index bfe9a92..9e878a8 100644 --- a/cmd/dolmetschctl/dolmetschctl.go +++ b/cmd/dolmetschctl/dolmetschctl.go @@ -36,6 +36,12 @@ import ( "spreadspace.org/dolmetschctl/pkg/types" ) +const ( + blinkTime = 20 + lang1 = "en" + lang2 = "de" +) + func wsReader(ws *websocket.Conn, ch chan<- types.WebSocketResponseFull) { defer close(ch) @@ -67,6 +73,53 @@ func wsReader(ws *websocket.Conn, ch chan<- types.WebSocketResponseFull) { return } +func handleControllerEvent(ctrl *controller.Controller, ws *websocket.Conn, ev controller.Event) error { + if ev.Type != controller.ButtonPressed { + return nil + } + lang := "" + switch ev.Button { + case 0: + lang = "en" + case 1: + lang = "de" + default: + lang = "none" + } + return ws.WriteJSON(types.WebSocketRequest{Command: "language", Args: []string{lang}}) +} + +func ledOnOrBlink(ctrl *controller.Controller, num uint8, state types.State) { + if state == types.StateSettled { + ctrl.LedOn(num) + } else { + ctrl.LedBlink(num, blinkTime) + } +} + +func handleWebSocketMessage(ctrl *controller.Controller, ws *websocket.Conn, msg types.WebSocketResponseFull) error { + if msg.Type == "state" { + switch msg.Lang { + case lang1: + ledOnOrBlink(ctrl, 0, msg.State) + ctrl.LedOff(1) + ctrl.LedOff(2) + ctrl.LedOff(3) + case lang2: + ctrl.LedOff(0) + ledOnOrBlink(ctrl, 1, msg.State) + ctrl.LedOff(2) + ctrl.LedOff(3) + default: + ctrl.LedOff(0) + ctrl.LedOff(1) + ledOnOrBlink(ctrl, 2, msg.State) + ledOnOrBlink(ctrl, 3, msg.State) + } + } + return nil +} + func run(ctrl *controller.Controller, ws *websocket.Conn) error { ctrlCh := make(chan controller.Event, 100) ctrl.Subscribe(ctrlCh) @@ -77,6 +130,7 @@ func run(ctrl *controller.Controller, ws *websocket.Conn) error { if err := ws.WriteJSON(types.WebSocketRequest{Command: "subscribe"}); err != nil { return err } + log.Printf("subscribed to state changes!") for { select { @@ -84,26 +138,16 @@ func run(ctrl *controller.Controller, ws *websocket.Conn) error { if !ok { return fmt.Errorf("controller channel was closed.") } - if ev.Type != controller.ButtonPressed { - continue - } - lang := "" - switch ev.Button { - case 0: - lang = "en" - case 1: - lang = "de" - default: - lang = "none" - } - if err := ws.WriteJSON(types.WebSocketRequest{Command: "language", Args: []string{lang}}); err != nil { + if err := handleControllerEvent(ctrl, ws, ev); err != nil { return err } case msg, ok := <-wsCh: if !ok { return fmt.Errorf("websocket channel was closed.") } - log.Printf("got message from websocket: %v", msg) + if err := handleWebSocketMessage(ctrl, ws, msg); err != nil { + return err + } } } return nil @@ -130,6 +174,7 @@ func main() { if err != nil { log.Printf("Error connecting to daemon: %v", err) } else { + log.Printf("successfully conncted!") err := run(c, ws) log.Printf("run() returned: %v", err) } |