From 1dbab4542e8735ca783bcae4470f5a2e6cd34bbb Mon Sep 17 00:00:00 2001
From: andronache <andrei.andronache@itsyscom.com>
Date: Thu, 25 Feb 2021 16:54:03 +0200
Subject: [PATCH] Started tests in ers

---
 ers/ers_it_test.go | 63 ++++++++++++++++++++++++++++++++++++++++++++++
 1 file changed, 63 insertions(+)

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)
+	}
+}