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

Tests in ers

Browse Source
This commit is contained in:
andronache
2021-02-26 14:03:30 +02:00
committed by Dan Christian Bogos
parent 7d4206f549
commit 6d538ac9fc
2 changed files with 64 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
ers/ers.go
View File

@@ -87,7 +87,6 @@ func (erS *ERService) ListenAndServe(stopChan, cfgRldChan chan struct{}) (err er
erS.closeAllRdrs()
return
case erEv := <-erS.rdrEvents:
fmt.Println("yay")
if err := erS.processEvent(erEv.cgrEvent, erEv.rdrCfg); err != nil {
utils.Logger.Warning(
fmt.Sprintf("<%s> reading event: <%s> got error: <%s>",

71
ers/ers_it_test.go
View File

@@ -231,7 +231,7 @@ func TestERsListenAndServeRdrErr(t *testing.T) {
cfgRldChan := make(chan struct{}, 1)
srv.rdrErr = make(chan error, 1)
srv.rdrErr <- utils.ErrNotFound
time.Sleep(30 * time.Millisecond)
time.Sleep(10 * time.Millisecond)
err := srv.ListenAndServe(stopChan, cfgRldChan)
if err == nil || err != utils.ErrNotFound {
t.Fatalf("\nExpecting <%+v>,\n Received <%+v>", utils.ErrNotFound, err)
@@ -269,14 +269,13 @@ func TestERsListenAndServeStopchan(t *testing.T) {
stopChan := make(chan struct{}, 1)
cfgRldChan := make(chan struct{}, 1)
stopChan <- struct{}{}
time.Sleep(30 * time.Millisecond)
time.Sleep(10 * time.Millisecond)
err := srv.ListenAndServe(stopChan, cfgRldChan)
if err != nil {
t.Fatalf("\nExpecting <%+v>,\n Received <%+v>", nil, err)
}
}
/*
func TestERsListenAndServeRdrEvents(t *testing.T) {
cfg := config.NewDefaultCGRConfig()
cfg.ERsCfg().Readers = []*config.EventReaderCfg{
@@ -307,6 +306,7 @@ func TestERsListenAndServeRdrEvents(t *testing.T) {
srv := NewERService(cfg, fltrS, nil)
stopChan := make(chan struct{}, 1)
cfgRldChan := make(chan struct{}, 1)
srv.rdrErr = make(chan error, 1)
srv.rdrEvents = make(chan *erEvent, 1)
srv.rdrEvents <- &erEvent{
cgrEvent: &utils.CGREvent{
@@ -339,10 +339,67 @@ func TestERsListenAndServeRdrEvents(t *testing.T) {
CacheDumpFields: nil,
},
}
time.Sleep(30 * time.Millisecond)
time.Sleep(10 * time.Millisecond)
srv.rdrErr <- utils.ErrNotFound
time.Sleep(15 * time.Millisecond)
err := srv.ListenAndServe(stopChan, cfgRldChan)
if err != nil {
t.Fatalf("\nExpecting <%+v>,\n Received <%+v>", nil, err)
if err == nil || err != utils.ErrNotFound {
t.Fatalf("\nExpecting <%+v>,\n Received <%+v>", utils.ErrNotFound, err)
}
}
func TestERsListenAndServeCfgRldChan(t *testing.T) {
cfg := config.NewDefaultCGRConfig()
cfg.ERsCfg().Readers = []*config.EventReaderCfg{
{
ID: "",
Type: utils.MetaNone,
},
}
fltrS := &engine.FilterS{}
srv := NewERService(cfg, fltrS, nil)
stopChan := make(chan struct{}, 1)
cfgRldChan := make(chan struct{}, 1)
srv.rdrErr = make(chan error, 1)
cfgRldChan <- struct{}{}
time.Sleep(10 * time.Millisecond)
srv.rdrErr <- utils.ErrNotFound
time.Sleep(15 * time.Millisecond)
err := srv.ListenAndServe(stopChan, cfgRldChan)
if err == nil || err != utils.ErrNotFound {
t.Fatalf("\nExpecting <%+v>,\n Received <%+v>", utils.ErrNotFound, err)
}
}
func TestERsListenAndServeCfgRldChan2(t *testing.T) {
cfg := config.NewDefaultCGRConfig()
cfg.ERsCfg().Readers = []*config.EventReaderCfg{
{
ID: "test",
Type: utils.MetaNone,
},
}
fltrS := &engine.FilterS{}
srv := NewERService(cfg, fltrS, nil)
exp := &CSVFileER{
cgrCfg: cfg,
cfgIdx: 0,
}
var expected EventReader = exp
srv.rdrs = map[string]EventReader{
"test": expected,
}
srv.stopLsn["test"] = make(chan struct{})
stopChan := make(chan struct{}, 1)
cfgRldChan := make(chan struct{}, 1)
srv.rdrErr = make(chan error, 1)
cfgRldChan <- struct{}{}
time.Sleep(10 * time.Millisecond)
srv.rdrErr <- utils.ErrNotFound
time.Sleep(15 * time.Millisecond)
err := srv.ListenAndServe(stopChan, cfgRldChan)
if err == nil || err != utils.ErrNotFound {
t.Fatalf("\nExpecting <%+v>,\n Received <%+v>", utils.ErrNotFound, err)
}
}
*/