FilesExpand file tree

master

/

patterns.go

Copy path

Blame

More file actions

Blame

More file actions

Latest commit

 

History

History

History

79 lines (66 loc) · 1.67 KB

master

/

patterns.go

Copy path

Top

File metadata and controls

• Code
• Blame

79 lines (66 loc) · 1.67 KB

Raw

Copy raw file

Download raw file

Open symbols panel

Edit and raw actions

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

26

27

28

29

30

31

32

33

34

35

36

37

38

39

40

41

42

43

44

45

46

47

48

49

50

51

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

77

78

79

package main

import (

"bufio"

"fmt"

"os"

)

// readLines reads a whole file into memory

// and returns a slice of its lines.

func readLines(path string) ([]string, error) {

file, err := os.Open(path)

if err != nil {

return nil, err

}

defer file.Close()

var lines []string

scanner := bufio.NewScanner(file)

for scanner.Scan() {

lines = append(lines, scanner.Text())

}

return lines, scanner.Err()

}

// pattern looks for pattern matching regular expression re in the

// lines buffer. Returns the name of our next regular expression to

// look for.

func pattern(first string, lines []string) (maplist []map[string]string) {

var re RE

var fieldmap map[string]string

fmt.Printf("In pattern\n")

re, ok := conf.Res[first]

if !ok {

slog.Debug("Couldn't find first state.")

return

}

// Store away all the fields in a map.

fieldmap = make(map[string]string)

for _, line := range lines {

if debug > 1 {

slog.Debug("Looking at: " + line)

}

fields := re.RE.FindStringSubmatch(line)

if len(fields)-1 == len(re.Match.Fields) {

if debug > 0 {

line := fmt.Sprintf("Found match for a message of type '%v'", re.Match)

slog.Debug(line)

}

for key, name := range re.Match.Fields {

if debug > 0 {

slog.Debug("Got " + re.Match.Fields[key])

}

fieldmap[name] = fields[key+1]

}

if re.Match.Action == "send" {

// Finished for this item. Create a new field map and add this to the list.

maplist = append(maplist, fieldmap)

fieldmap = make(map[string]string)

}

// Go to the next state, if it exists. If it

// doesn't we're finished here.

re, ok = conf.Res[re.Match.Next]

if !ok {

break

}

}

}

return maplist

}