command.go 2.86 KB
Newer Older
Matt Bell's avatar
Matt Bell committed
1 2 3
package commands

import (
Matt Bell's avatar
Matt Bell committed
4 5 6
	"fmt"
	"reflect"
	"strings"
Matt Bell's avatar
Matt Bell committed
7 8 9
)

type Command struct {
Matt Bell's avatar
Matt Bell committed
10 11 12 13
	Help        string
	Options     []Option
	f           func(*Request, *Response)
	subcommands map[string]*Command
Matt Bell's avatar
Matt Bell committed
14 15 16 17
}

// Register adds a subcommand
func (c *Command) Register(id string, sub *Command) error {
Matt Bell's avatar
Matt Bell committed
18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36
	if c.subcommands == nil {
		c.subcommands = make(map[string]*Command)
	}

	// check for duplicate option names (only checks downwards)
	names := make(map[string]bool)
	globalCommand.checkOptions(names)
	c.checkOptions(names)
	err := sub.checkOptions(names)
	if err != nil {
		return err
	}

	if _, ok := c.subcommands[id]; ok {
		return fmt.Errorf("There is already a subcommand registered with id '%s'", id)
	}

	c.subcommands[id] = sub
	return nil
Matt Bell's avatar
Matt Bell committed
37 38 39
}

// Call invokes the command at the given subcommand path
40
func (c *Command) Call(req *Request) *Response {
Matt Bell's avatar
Matt Bell committed
41 42 43
	cmd := c
	res := &Response{req: req}

44
  options, err := cmd.GetOptions(req.path)
45 46 47 48
  if err != nil {
    res.SetError(err, Client)
    return res
  }
Matt Bell's avatar
Matt Bell committed
49 50

	for k, v := range req.options {
51
		opt, ok := options[k]
Matt Bell's avatar
Matt Bell committed
52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76

		if !ok {
			res.SetError(fmt.Errorf("Unrecognized command option: '%s'", k), Client)
			return res
		}

		for _, name := range opt.Names {
			if _, ok = req.options[name]; name != k && ok {
				res.SetError(fmt.Errorf("Duplicate command options were provided ('%s' and '%s')",
					k, name), Client)
				return res
			}
		}

		kind := reflect.TypeOf(v).Kind()
		if kind != opt.Type {
			res.SetError(fmt.Errorf("Option '%s' should be type '%s', but got type '%s'",
				k, opt.Type.String(), kind.String()), Client)
			return res
		}
	}

	cmd.f(req, res)

	return res
Matt Bell's avatar
Matt Bell committed
77 78
}

79 80 81 82 83 84
// GetOptions gets the options in the given path of commands
func (c *Command) GetOptions(path []string) (map[string]Option, error) {
  options := make([]Option, len(c.Options))
  copy(options, c.Options)
  options = append(options, globalOptions...)

85
  // a nil path means this command, not a subcommand (same as an empty path)
86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108
  if path != nil {
    for i, id := range path {
      cmd := c.Sub(id)

      if cmd == nil {
        pathS := strings.Join(path[0:i], "/")
        return nil, fmt.Errorf("Undefined command: '%s'", pathS)
      }

      options = append(options, cmd.Options...)
    }
  }

  optionsMap := make(map[string]Option)
  for _, opt := range options {
    for _, name := range opt.Names {
      optionsMap[name] = opt
    }
  }

  return optionsMap, nil
}

Matt Bell's avatar
Matt Bell committed
109 110
// Sub returns the subcommand with the given id
func (c *Command) Sub(id string) *Command {
Matt Bell's avatar
Matt Bell committed
111
	return c.subcommands[id]
Matt Bell's avatar
Matt Bell committed
112
}
113 114

func (c *Command) checkOptions(names map[string]bool) error {
Matt Bell's avatar
Matt Bell committed
115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131
	for _, opt := range c.Options {
		for _, name := range opt.Names {
			if _, ok := names[name]; ok {
				return fmt.Errorf("Multiple options are using the same name ('%s')", name)
			}
			names[name] = true
		}
	}

	for _, cmd := range c.subcommands {
		err := cmd.checkOptions(names)
		if err != nil {
			return err
		}
	}

	return nil
132
}