Compare commits
2 commits
c5eee0ea22
...
2e1ab137ea
Author | SHA1 | Date | |
---|---|---|---|
2e1ab137ea | |||
02b41aa661 |
1 changed files with 58 additions and 0 deletions
58
data/data_test.go
Normal file
58
data/data_test.go
Normal file
|
@ -0,0 +1,58 @@
|
||||||
|
package data
|
||||||
|
|
||||||
|
import (
|
||||||
|
"testing"
|
||||||
|
"time"
|
||||||
|
|
||||||
|
"gopkg.in/mcuadros/go-syslog.v2/format"
|
||||||
|
)
|
||||||
|
|
||||||
|
var timeNow = time.Now()
|
||||||
|
|
||||||
|
var returnValues = map[string]interface{}{
|
||||||
|
"prog": "test_app",
|
||||||
|
"client": "test_client",
|
||||||
|
"host": "my_machine",
|
||||||
|
"msg": "test message",
|
||||||
|
"sev": 3,
|
||||||
|
"time": timeNow,
|
||||||
|
}
|
||||||
|
|
||||||
|
var msgRFC5424 = format.LogParts{
|
||||||
|
"version": 1,
|
||||||
|
"app_name": returnValues["prog"],
|
||||||
|
"client": returnValues["client"],
|
||||||
|
"hostname": returnValues["host"],
|
||||||
|
"proc_id": "spam_process",
|
||||||
|
"message": returnValues["msg"],
|
||||||
|
"facility": "hell",
|
||||||
|
"timestamp": returnValues["time"],
|
||||||
|
"severity": returnValues["sev"],
|
||||||
|
}
|
||||||
|
|
||||||
|
var msgRFC3164 = format.LogParts{
|
||||||
|
"tag": returnValues["prog"],
|
||||||
|
"client": returnValues["client"],
|
||||||
|
"hostname": returnValues["host"],
|
||||||
|
"content": returnValues["msg"],
|
||||||
|
"severity": returnValues["sev"],
|
||||||
|
"timestamp": returnValues["time"],
|
||||||
|
"proc_id": "spam_process",
|
||||||
|
}
|
||||||
|
|
||||||
|
var testMessages = []format.LogParts{
|
||||||
|
msgRFC5424,
|
||||||
|
msgRFC3164,
|
||||||
|
}
|
||||||
|
|
||||||
|
func TestLogEntryToMessage(t *testing.T) {
|
||||||
|
for _, msg := range testMessages {
|
||||||
|
parsedMsg := LogEntryToMessage(msg)
|
||||||
|
|
||||||
|
for key, value := range returnValues {
|
||||||
|
if data, ok := parsedMsg[key]; !ok || data != value {
|
||||||
|
t.Errorf("Missing/wrong key: %s\nmsg: %s\nparsed msg: %s\n", key, value, data)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
Loading…
Reference in a new issue