package gost import ( "errors" "fmt" "strconv" "strings" glob "github.com/ryanuber/go-glob" ) type Permission struct { Actions StringSet Hosts StringSet Ports PortSet } type Permissions []Permission func minint(x, y int) int { if x < y { return x } return y } func maxint(x, y int) int { if x > y { return x } return y } type PortRange struct { Min, Max int } func (ir *PortRange) Contains(value int) bool { return value >= ir.Min && value <= ir.Max } func ParsePortRange(s string) (*PortRange, error) { if s == "*" { return &PortRange{Min: 0, Max: 65535}, nil } minmax := strings.Split(s, "-") switch len(minmax) { case 1: port, err := strconv.Atoi(s) if err != nil { return nil, err } if port < 0 || port > 65535 { return nil, fmt.Errorf("invalid port: %s", s) } return &PortRange{Min: port, Max: port}, nil case 2: min, err := strconv.Atoi(minmax[0]) if err != nil { return nil, err } max, err := strconv.Atoi(minmax[1]) if err != nil { return nil, err } realmin := maxint(0, minint(min, max)) realmax := minint(65535, maxint(min, max)) return &PortRange{Min: realmin, Max: realmax}, nil default: return nil, fmt.Errorf("invalid range: %s", s) } } func (ps *PortSet) Contains(value int) bool { for _, portRange := range *ps { if portRange.Contains(value) { return true } } return false } type PortSet []PortRange func ParsePortSet(s string) (*PortSet, error) { ps := &PortSet{} if s == "" { return nil, errors.New("must specify at least one port") } ranges := strings.Split(s, ",") for _, r := range ranges { portRange, err := ParsePortRange(r) if err != nil { return nil, err } *ps = append(*ps, *portRange) } return ps, nil } func (ss *StringSet) Contains(subj string) bool { for _, s := range *ss { if glob.Glob(s, subj) { return true } } return false } type StringSet []string func ParseStringSet(s string) (*StringSet, error) { ss := &StringSet{} if s == "" { return nil, errors.New("cannot be empty") } *ss = strings.Split(s, ",") return ss, nil } func (ps *Permissions) Can(action string, host string, port int) bool { for _, p := range *ps { if p.Actions.Contains(action) && p.Hosts.Contains(host) && p.Ports.Contains(port) { return true } } return false } func ParsePermissions(s string) (*Permissions, error) { ps := &Permissions{} if s == "" { return &Permissions{}, nil } perms := strings.Split(s, " ") for _, perm := range perms { parts := strings.Split(perm, ":") switch len(parts) { case 3: actions, err := ParseStringSet(parts[0]) if err != nil { return nil, fmt.Errorf("action list must look like connect,bind given: %s", parts[0]) } hosts, err := ParseStringSet(parts[1]) if err != nil { return nil, fmt.Errorf("hosts list must look like google.pl,*.google.com given: %s", parts[1]) } ports, err := ParsePortSet(parts[2]) if err != nil { return nil, fmt.Errorf("ports list must look like 80,8000-9000, given: %s", parts[2]) } permission := Permission{Actions: *actions, Hosts: *hosts, Ports: *ports} *ps = append(*ps, permission) default: return nil, fmt.Errorf("permission must have format [actions]:[hosts]:[ports] given: %s", perm) } } return ps, nil }