@@ -3,7 +3,6 @@ package parsefield
3
3
import (
4
4
"bytes"
5
5
"encoding/json"
6
- "fmt"
7
6
"github.com/MonaxGT/parsefields/storage"
8
7
"io/ioutil"
9
8
"net/http"
@@ -26,6 +25,8 @@ type Body struct {
26
25
type MockReindexer struct {
27
26
mockInsertFields func () error
28
27
mockRestoreEvents func () error
28
+ mockRestoreFields func () error
29
+ mockGetByEvent func () error
29
30
}
30
31
31
32
func (s * MockReindexer ) Open (url string ) error {
@@ -37,7 +38,10 @@ func (s *MockReindexer) InsertEvents(event *storage.Events) error {
37
38
}
38
39
39
40
func (s * MockReindexer ) RestoreFields () ([]* storage.Fields , error ) {
40
- panic ("implement me" )
41
+ if s .mockRestoreFields != nil {
42
+ return nil ,s .mockRestoreFields ()
43
+ }
44
+ return nil ,nil
41
45
}
42
46
43
47
func (s * MockReindexer ) RestoreEvents () ([]* storage.Events , error ) {
@@ -56,7 +60,10 @@ func (s *MockReindexer) DeleteFields(field string) error {
56
60
}
57
61
58
62
func (s * MockReindexer ) GetByEvent (logname string , eventid int32 ) ([]byte , error ) {
59
- panic ("implement me" )
63
+ if s .mockGetByEvent != nil {
64
+ return nil ,s .mockGetByEvent ()
65
+ }
66
+ return nil ,nil
60
67
}
61
68
62
69
func (s * MockReindexer ) InsertFields (field * storage.Fields ) error {
@@ -145,7 +152,6 @@ func TestMJSONHandler(t *testing.T) {
145
152
Name : "tester" ,
146
153
},
147
154
}
148
- fmt .Println (body )
149
155
b := new (bytes.Buffer )
150
156
err := json .NewEncoder (b ).Encode (body )
151
157
if err != nil {
@@ -185,6 +191,7 @@ func TestMJSONHandler(t *testing.T) {
185
191
if rbody == nil {
186
192
t .Errorf ("server return nil data" )
187
193
}
194
+
188
195
}
189
196
190
197
func TestEventHandler (t * testing.T ) {
@@ -408,7 +415,7 @@ func TestServe(t *testing.T) {
408
415
409
416
}
410
417
411
- func TestDB (t * testing.T ) {
418
+ func TestDB (t * testing.T ) {
412
419
var db storage.Database
413
420
var fields sync.Map
414
421
var events sync.Map
@@ -434,5 +441,17 @@ func TestDB (t *testing.T) {
434
441
if err != nil {
435
442
t .Error (err )
436
443
}
444
+ _ , err = c .DB .RestoreFields ()
445
+ if err != nil {
446
+ t .Error (err )
447
+ }
448
+ _ , err = c .DB .RestoreFields ()
449
+ if err != nil {
450
+ t .Error (err )
451
+ }
452
+ _ , err = c .DB .GetByEvent ("sysmon" ,1 )
453
+ if err != nil {
454
+ t .Error (err )
455
+ }
437
456
438
- }
457
+ }
0 commit comments