package config import ( "alrm/alarm" "alrm/check" "bufio" "fmt" "os" "strings" ) const ( TK_NONE = iota TK_SET TK_MONITOR TK_GROUP TK_HOST TK_CHECK TK_ALARM ) type Parser struct { DebugLevel int Line int states []int lastHost *Host lastGroup *Group lastCheck check.Check lastAlarm alarm.Alarm lastAlarmName string } func (p *Parser) Parse(fn string) (*Config, error) { file, err := os.Open(fn) if err != nil { return nil, fmt.Errorf("cannot open config \"%s\": %s", fn, err.Error()) } defer file.Close() config := NewConfig() scan := bufio.NewScanner(file) scan.Split(p.Split) for scan.Scan() { tk := scan.Text() stateswitch: switch p.state() { case TK_NONE: switch strings.ToLower(tk) { case "monitor": p.setState(TK_MONITOR) case "set": p.setState(TK_SET) case "alarm": p.setState(TK_ALARM) default: return nil, fmt.Errorf("invalid token in %s, line %d: \"%s\"", fn, p.Line, tk) } case TK_SET: key := strings.ToLower(tk) if !scan.Scan() { return nil, fmt.Errorf("empty value name for set in %s, line %d", fn, p.Line) } value := scan.Text() switch key { case "interval": err := config.SetInterval(value) if err != nil { return nil, fmt.Errorf( "invalid number for interval in %s, line %d: \"%s\"", fn, p.Line, value, ) } default: return nil, fmt.Errorf("unknown key for set in %s, line %d: \"%s\"", fn, p.Line, tk, ) } p.prevState() case TK_MONITOR: switch strings.ToLower(tk) { case "host": p.setState(TK_HOST) case "group": p.setState(TK_GROUP) default: p.prevState() goto stateswitch } case TK_GROUP: if p.lastGroup == nil { p.lastGroup, err = config.NewGroup(tk) if err != nil { return nil, fmt.Errorf("%s in %s, line %d", err.Error(), fn, p.Line, ) } continue } switch strings.ToLower(tk) { case "host": p.setState(TK_HOST) default: p.prevState() goto stateswitch } case TK_HOST: // If a host has no group, inherit the host name if p.lastGroup == nil { p.lastGroup, err = config.NewGroup(tk) if err != nil { return nil, fmt.Errorf("%s in %s, line %d", err.Error(), fn, p.Line, ) } } if p.lastHost == nil { p.lastHost, err = p.lastGroup.NewHost(tk) if err != nil { return nil, fmt.Errorf("%s in %s, line %d", err.Error(), fn, p.Line, ) } continue } switch strings.ToLower(tk) { case "address": if !scan.Scan() { return nil, fmt.Errorf("empty address for host in %s, line %d", fn, p.Line) } p.lastHost.Address = scan.Text() case "check": p.setState(TK_CHECK) default: p.prevState() goto stateswitch } case TK_CHECK: if p.lastCheck == nil { p.lastCheck, err = p.lastHost.NewCheck(tk) if err != nil { return nil, fmt.Errorf("%s in %s, line %d", err.Error(), fn, p.Line) } continue } cont, err := p.lastCheck.Parse(tk) if err != nil { return nil, fmt.Errorf("%s in %s, line %d", err.Error(), fn, p.Line) } if !cont { p.lastCheck = nil p.prevState() goto stateswitch } case TK_ALARM: if p.lastAlarm == nil { if p.lastAlarmName == "" { p.lastAlarmName = tk continue } p.lastAlarm, err = config.NewAlarm(p.lastAlarmName, tk) if err != nil { return nil, fmt.Errorf("%s in %s, line %d", err.Error(), fn, p.Line) } p.lastAlarmName = "" continue } cont, err := p.lastAlarm.Parse(tk) if err != nil { return nil, fmt.Errorf("%s in %s, line %d", err.Error(), fn, p.Line) } if !cont { p.lastAlarm = nil p.prevState() goto stateswitch } default: return nil, fmt.Errorf("unknown parser state: %d", p.state()) } } if err := scan.Err(); err != nil { return nil, err } return config, nil } func (p *Parser) state() int { if len(p.states) < 1 { return TK_NONE } return p.states[len(p.states)-1] } func (p *Parser) setState(state int) { switch state { case TK_SET, TK_MONITOR: fallthrough case TK_GROUP: p.lastGroup = nil fallthrough case TK_HOST: p.lastHost = nil p.lastCheck = nil } if p.DebugLevel > 1 { fmt.Printf("Parser state: %s", p.stateName()) } p.states = append(p.states, state) if p.DebugLevel > 1 { fmt.Printf(" -> %s\n", p.stateName()) } } func (p *Parser) prevState() int { if len(p.states) > 0 { p.states = p.states[:len(p.states)-1] } return p.state() } func (p *Parser) stateName() string { switch p.state() { case TK_NONE: return "TK_NONE" case TK_SET: return "TK_SET" case TK_MONITOR: return "TK_MONTIOR" case TK_GROUP: return "TK_GROUP" case TK_HOST: return "TK_HOST" case TK_CHECK: return "TK_CHECK" case TK_ALARM: return "TK_ALARM" default: return "UNKNOWN" } } func (p *Parser) Split(data []byte, atEOF bool) (int, []byte, error) { if atEOF && len(data) == 0 { return 0, nil, nil } var ignoreline bool var started bool var startidx int var quote byte for i := 0; i < len(data); i++ { c := data[i] //fmt.Printf("%c (%t) (%t)\n", c, started, ignoreline) switch c { case '\f', '\n', '\r': p.Line++ if ignoreline { ignoreline = false continue } fallthrough case ' ', '\t', '\v': if started && quote == 0 { return i + 1, data[startidx:i], nil } case '\'', '"', '`': // When the quote ends if quote == c { // if we've gotten data, return it if started { return i + 1, data[startidx:i], nil } // if we haven't return nothing return i + 1, []byte{}, nil } // start a quoted string if !ignoreline && quote == 0 { quote = c } case '#': if !started { ignoreline = true } default: if !ignoreline && !started { started = true startidx = i } } } if atEOF { if quote != 0 { return 0, nil, fmt.Errorf("unterminated quote") } if ignoreline { return len(data), nil, nil } if started { return len(data), data[startidx:], nil } } return 0, nil, nil }