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 }