5e5d6e1fd0d98e085f5bb2af45366001f090ccb8
[svn42.git] / go / door_daemon_zmq / handle_commands.go
1 // (c) Bernhard Tittelbach, 2013
2
3 package main
4
5 import (
6     "errors"
7 )
8
9 type DoorCmdHandler struct {
10     Checker func([][]byte)(error)
11     FirmwareChar string
12 }
13
14 var cmdToDoorCmdHandler = map[string]DoorCmdHandler {
15   "open": DoorCmdHandler{ checkCmdDoorControl, "o"},
16   "close": DoorCmdHandler{ checkCmdDoorControl, "c"},
17   "toggle": DoorCmdHandler{ checkCmdDoorControl, "t"},
18   "status": DoorCmdHandler{ checkCmdDoorControl, "s"},
19 }
20
21 // ---------- Command Handling Code -------------
22
23 func checkCmdDoorControl(tokens [][]byte) (error) {
24     doorctrl_usage := "syntax: <open|close|toggle> <method> <nickname>"
25     if len(tokens) != 3 {
26         return errors.New(doorctrl_usage)
27     }
28     cmd := string(tokens[0])
29     if ! (cmd == "open" || cmd == "close" || cmd == "toggle") {
30         return errors.New(doorctrl_usage)
31     }
32     method := string(tokens[1])
33     if ! (method == "Button" || method == "ssh" || method == "SSH" || method == "Phone") {
34         return errors.New("method must be one either Button, SSH or Phone")
35     }
36     if len(tokens[2]) == 0 && method != "Button" {
37         return errors.New("Operator nickname must be given")
38     }
39     return nil
40 }
41
42 func checkCmdStatus(tokens [][]byte) (error) {
43     if len(tokens) != 1 {
44         return errors.New("status command does not accept arguments")
45     }
46     return nil
47 }
48
49 func HandleCommand(tokens [][]byte, topub chan <- [][]byte, serial_wr chan string) ([][]byte, error){
50     if len(tokens) < 1 {
51         return nil, errors.New("No Command to handle")
52     }
53
54     dch, present := cmdToDoorCmdHandler[string(tokens[0])]
55     if ! present {
56         return nil, errors.New("Unknown Command")
57     }
58
59     if err := dch.Checker(tokens); err != nil {
60         //return error to sender
61         return nil, err
62     }
63
64     topub <- tokens
65     serial_wr <- dch.FirmwareChar
66     fw_reply := GetLastSerialLine()
67     return fw_reply, nil
68 }