diff --git a/ers/ers_test.go b/ers/ers_it_test.go similarity index 66% rename from ers/ers_test.go rename to ers/ers_it_test.go index bfe2220a1..5fc6e01c2 100644 --- a/ers/ers_test.go +++ b/ers/ers_it_test.go @@ -1,3 +1,4 @@ +// +build integration /* Real-time Online/Offline Charging System (OCS) for Telecom & ISP environments Copyright (C) ITsysCOM GmbH @@ -67,3 +68,39 @@ func TestERsAddReader(t *testing.T) { t.Errorf("Expecting: <%+v>, received: <%+v>", reader, erS.rdrs["file_reader"].Config()) } } + +func TestERsListenAndServeErr(t *testing.T) { + cfg := config.NewDefaultCGRConfig() + cfg.ERsCfg().Readers = []*config.EventReaderCfg{ + { + ID: "", + Type: "", + RowLength: 0, + FieldSep: "", + HeaderDefineChar: "", + RunDelay: 0, + ConcurrentReqs: 0, + SourcePath: "", + ProcessedPath: "", + Opts: nil, + XMLRootPath: nil, + Tenant: nil, + Timezone: "", + Filters: nil, + Flags: nil, + FailedCallsPrefix: "", + PartialRecordCache: 0, + PartialCacheExpiryAction: "", + Fields: nil, + CacheDumpFields: nil, + }, + } + fltrS := &engine.FilterS{} + srv := NewERService(cfg, fltrS, nil) + stopChan := make(chan struct{}, 1) + cfgRldChan := make(chan struct{}, 1) + err := srv.ListenAndServe(stopChan, cfgRldChan) + if err == nil || err.Error() != "unsupported reader type: <>" { + t.Fatalf("\nExpecting <%+v>,\n Received <%+v>", "unsupported reader type: <>", err) + } +}