diff --git a/ers/ers_it_test.go b/ers/ers_it_test.go index 5fc6e01c2..351798d54 100644 --- a/ers/ers_it_test.go +++ b/ers/ers_it_test.go @@ -104,3 +104,66 @@ func TestERsListenAndServeErr(t *testing.T) { t.Fatalf("\nExpecting <%+v>,\n Received <%+v>", "unsupported reader type: <>", err) } } + +func TestERsProcessEventErr(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) + rdrCfg := &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, + } + cgrEvent := &utils.CGREvent{ + Tenant: "", + ID: "", + Time: nil, + Event: nil, + Opts: nil, + } + err := srv.processEvent(cgrEvent, rdrCfg) + if err == nil || err.Error() != "unsupported reqType: <>" { + t.Fatalf("\nExpecting <%+v>,\n Received <%+v>", "unsupported reqType: <>", err) + } +}