123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657 |
- package data
- import (
- "testing"
- "time"
- "gopkg.in/mcuadros/go-syslog.v2/format"
- )
- var mandatoryKeys = []string{
- "prog",
- "client",
- "host",
- "msg",
- "sev",
- "time",
- "proc_id",
- }
- var msgRFC5424 = format.LogParts{
- "version": 1,
- "app_name": "test_app",
- "client": "test_client",
- "hostname": "my_machine",
- "proc_id": "spam_process",
- "message": "test message",
- "facility": "hell",
- "timestamp": time.Now(),
- "severity": 3,
- }
- var msgRFC3164 = format.LogParts{
- "tag": "test_tag",
- "client": "test_client",
- "hostname": "my_machine",
- "content": "test message",
- "severity": 3,
- "timestamp": time.Now(),
- "proc_id": "spam_process",
- }
- var testMessages = []format.LogParts{
- msgRFC5424,
- msgRFC3164,
- }
- func TestLogEntryToMessage(t *testing.T) {
- for _, msg := range testMessages {
- parsedMsg := LogEntryToMessage(msg)
- for _, key := range mandatoryKeys {
- if data, ok := parsedMsg[key]; !ok || data == nil {
- t.Errorf("Missing key: %s\nmsg: %s\nparsed msg: %s\n", key, msg, parsedMsg)
- }
- }
- }
- }
|