From 95d98e70ad6855e1a12c6c91220f33242c02349d Mon Sep 17 00:00:00 2001 From: andronache Date: Thu, 25 Feb 2021 16:40:44 +0200 Subject: [PATCH] Started tests in ers --- ers/{ers_test.go => ers_it_test.go} | 37 +++++++++++++++++++++++++++++ 1 file changed, 37 insertions(+) rename ers/{ers_test.go => ers_it_test.go} (66%) 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) + } +}