uppal/cgrates
1
0
Fork 1
mirror of https://github.com/cgrates/cgrates.git synced 2026-02-11 18:16:24 +05:00
Code Issues Packages Projects Releases Wiki Activity

Add test for ERs addReader

Browse Source
This commit is contained in:
TeoV
2019-09-13 10:29:36 +03:00
committed by Dan Christian Bogos
parent ab21f698d6
commit 9b790b2be4
1 changed files with 20 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

21
ers/ers_test.go
View File

@@ -21,9 +21,11 @@ package ers
import (
"reflect"
"testing"
"time"
"github.com/cgrates/cgrates/config"
"github.com/cgrates/cgrates/engine"
"github.com/cgrates/cgrates/utils"
)
func TestERsNewERService(t *testing.T) {
@@ -48,5 +50,22 @@ func TestERsNewERService(t *testing.T) {
}
func TestERsAddReader(t *testing.T) {
cfg, _ := config.NewDefaultCGRConfig()
fltrS := &engine.FilterS{}
erS := NewERService(cfg, fltrS, nil, nil)
reader := cfg.ERsCfg().Readers[0]
reader.Type = utils.MetaFileCSV
reader.ID = "file_reader"
reader.RunDelay = time.Duration(0)
cfg.ERsCfg().Readers = append(cfg.ERsCfg().Readers, reader)
if len(cfg.ERsCfg().Readers) != 2 {
t.Errorf("Expecting: <2>, received: <%+v>", len(cfg.ERsCfg().Readers))
}
if err := erS.addReader("file_reader", 1); err != nil {
t.Errorf("Expecting: <nil>, received: <%+v>", len(cfg.ERsCfg().Readers))
} else if len(erS.rdrs) != 1 {
t.Errorf("Expecting: <2>, received: <%+v>", len(erS.rdrs))
} else if !reflect.DeepEqual(erS.rdrs["file_reader"].Config(), reader) {
t.Errorf("Expecting: <%+v>, received: <%+v>", reader, erS.rdrs["file_reader"].Config())
}
}