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
|
package spool
import (
"bytes"
"io"
"reflect"
"testing"
"testing/iotest"
"git.adyxax.org/adyxax/bareos-zabbix-check/pkg/job"
)
func TestParse(t *testing.T) {
readerError := iotest.TimeoutReader(bytes.NewReader([]byte("\n")))
readerCorruptedTimestamp := bytes.NewReader([]byte("test,x"))
readerOneJob := bytes.NewReader([]byte("test,1"))
type args struct {
handle io.Reader
}
tests := []struct {
name string
args args
wantJobs []job.Job
wantErr bool
}{
{"empty", args{readerError}, nil, true},
{"corrupted timestamp", args{readerCorruptedTimestamp}, nil, true},
{"one job", args{readerOneJob}, []job.Job{{Name: "test", Timestamp: 1, Success: true}}, false},
}
for _, tt := range tests {
t.Run(tt.name, func(t *testing.T) {
gotJobs, err := Parse(tt.args.handle)
if (err != nil) != tt.wantErr {
t.Errorf("Parse() error = %v, wantErr %v", err, tt.wantErr)
return
}
if !reflect.DeepEqual(gotJobs, tt.wantJobs) {
t.Errorf("Parse() = %v, want %v", gotJobs, tt.wantJobs)
}
})
}
}
|
