diff --git a/ers/ers_test.go b/ers/ers_test.go index 556558f3b..a8cad0386 100644 --- a/ers/ers_test.go +++ b/ers/ers_test.go @@ -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: , 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()) + } }