X-Git-Url: https://git.realraum.at/?a=blobdiff_plain;f=go%2Fdoor_daemon_zmq%2Fhandle_commands.go;h=0cfee8d491c01ddfada4418e5c0ec4f7626b6f7f;hb=845254e617b714552edbf860632f0e763a40d1a5;hp=d33070a50430a56c46972476b0954545087fd8d6;hpb=88e758b4025ef2a84acafc7b832a41028280c296;p=svn42.git diff --git a/go/door_daemon_zmq/handle_commands.go b/go/door_daemon_zmq/handle_commands.go index d33070a..0cfee8d 100644 --- a/go/door_daemon_zmq/handle_commands.go +++ b/go/door_daemon_zmq/handle_commands.go @@ -15,7 +15,7 @@ var cmdToDoorCmdHandler = map[string]DoorCmdHandler { "open": DoorCmdHandler{ checkCmdDoorControl, "o"}, "close": DoorCmdHandler{ checkCmdDoorControl, "c"}, "toggle": DoorCmdHandler{ checkCmdDoorControl, "t"}, - "status": DoorCmdHandler{ checkCmdDoorControl, "s"}, + "status": DoorCmdHandler{ checkCmdStatus, "s"}, } // ---------- Command Handling Code ------------- @@ -46,23 +46,20 @@ func checkCmdStatus(tokens [][]byte) (error) { return nil } -func HandleCommand(tokens [][]byte, topub chan <- [][]byte, serial_wr chan string, serial_rd chan [][]byte) ([][]byte, error){ +func HandleCommand(tokens [][]byte, serial_wr chan string, serial_rd chan [][]byte) error { if len(tokens) < 1 { - return nil, errors.New("No Command to handle") + return errors.New("No Command to handle") } - + dch, present := cmdToDoorCmdHandler[string(tokens[0])] if ! present { - return nil, errors.New("Unknown Command") + return errors.New("Unknown Command") } if err := dch.Checker(tokens); err != nil { - //return error to sender - return nil, err + return err } - - topub <- tokens + serial_wr <- dch.FirmwareChar - fw_reply := <- serial_rd - return fw_reply, nil + return nil }