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

Updated ers reader tests

Browse Source
This commit is contained in:
Trial97
2020-01-06 10:00:46 +02:00
parent df1ff276b7
commit 4c337ee467
1 changed files with 23 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

24
ers/readers_test.go
View File

@@ -58,7 +58,6 @@ func TestNewCsvReader(t *testing.T) {
if rcv, err := NewEventReader(cfg, 1, nil, nil, fltr, nil); err != nil {
t.Errorf("Expecting: <nil>, received: <%+v>", err)
} else if !reflect.DeepEqual(expected, rcv) {
t.Errorf("Expecting: <%+v>, received: <%+v>", expected, rcv)
}
}
@@ -84,3 +83,26 @@ func TestNewKafkaReader(t *testing.T) {
t.Errorf("Expecting: <%+v>, received: <%+v>", expected, rcv)
}
}
func TestNewSQLReader(t *testing.T) {
cfg, _ := config.NewDefaultCGRConfig()
fltr := &engine.FilterS{}
reader := cfg.ERsCfg().Readers[0]
reader.Type = utils.MetaSQL
reader.ID = "file_reader"
reader.ConcurrentReqs = -1
reader.SourcePath = "*mysql://cgrates:CGRateS.org@127.0.0.1:3306?db_name=cgrates2"
cfg.ERsCfg().Readers = append(cfg.ERsCfg().Readers, reader)
if len(cfg.ERsCfg().Readers) != 2 {
t.Errorf("Expecting: <2>, received: <%+v>", len(cfg.ERsCfg().Readers))
}
expected, err := NewSQLEventReader(cfg, 1, nil, nil, fltr, nil)
if err != nil {
t.Errorf("Expecting: <nil>, received: <%+v>", err)
}
if rcv, err := NewEventReader(cfg, 1, nil, nil, fltr, nil); err != nil {
t.Errorf("Expecting: <nil>, received: <%+v>", err)
} else if !reflect.DeepEqual(expected, rcv) {
t.Errorf("Expecting: <%+v>, received: <%+v>", expected, rcv)
}
}