From 0b229e5c3ce45f87e783337fb2b31883c2459807 Mon Sep 17 00:00:00 2001
From: andronache <andrei.andronache@itsyscom.com>
Date: Wed, 10 Mar 2021 14:37:00 +0200
Subject: [PATCH] Test for NewAMQPv1ER function in ers/amqpv1.go

---
 ers/amqpv1_it_test.go | 69 +++++++++++++++++++++++++++++++++++++++++++
 1 file changed, 69 insertions(+)

diff --git a/ers/amqpv1_it_test.go b/ers/amqpv1_it_test.go
index c128798fc..cd9763064 100644
--- a/ers/amqpv1_it_test.go
+++ b/ers/amqpv1_it_test.go
@@ -129,3 +129,72 @@ func TestAMQPERv1(t *testing.T) {
 
 	close(rdrExit)
 }
+
+func TestAmqpv1NewAMQPv1ER(t *testing.T) {
+	cfg := config.NewDefaultCGRConfig()
+	cfgIdx := 0
+	expected := &AMQPv1ER{
+		cgrCfg: cfg,
+		cfgIdx: cfgIdx,
+		poster: nil,
+	}
+	cfg.ERsCfg().Readers = []*config.EventReaderCfg{
+		{
+			ID:               utils.MetaDefault,
+			Type:             utils.MetaNone,
+			RowLength:        0,
+			FieldSep:         ",",
+			HeaderDefineChar: ":",
+			RunDelay:         0,
+			ConcurrentReqs:   -1,
+			SourcePath:       "/var/spool/cgrates/ers/in",
+			ProcessedPath:    "/var/spool/cgrates/ers/out",
+			Filters:          []string{},
+			Opts:             make(map[string]interface{}),
+		},
+	}
+
+	result, err := NewAMQPv1ER(cfg, cfgIdx, nil, nil, nil, nil)
+	if err != nil {
+		t.Errorf("\nExpected <%+v>, \nReceived <%+v>", nil, err)
+	}
+	expected.poster = result.(*AMQPv1ER).poster
+	if !reflect.DeepEqual(result, expected) {
+		t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
+	}
+}
+
+func TestAmqpv1NewAMQPv1ER2(t *testing.T) {
+	cfg := config.NewDefaultCGRConfig()
+	cfgIdx := 0
+	expected := &AMQPv1ER{
+		cgrCfg: cfg,
+		cfgIdx: cfgIdx,
+		poster: nil,
+	}
+	cfg.ERsCfg().Readers = []*config.EventReaderCfg{
+		{
+			ID:               utils.MetaDefault,
+			Type:             utils.MetaNone,
+			RowLength:        0,
+			FieldSep:         ",",
+			HeaderDefineChar: ":",
+			RunDelay:         0,
+			ConcurrentReqs:   1,
+			SourcePath:       "/var/spool/cgrates/ers/in",
+			ProcessedPath:    "/var/spool/cgrates/ers/out",
+			Filters:          []string{},
+			Opts:             make(map[string]interface{}),
+		},
+	}
+
+	result, err := NewAMQPv1ER(cfg, cfgIdx, nil, nil, nil, nil)
+	if err != nil {
+		t.Errorf("\nExpected <%+v>, \nReceived <%+v>", nil, err)
+	}
+	expected.poster = result.(*AMQPv1ER).poster
+	expected.cap = result.(*AMQPv1ER).cap
+	if !reflect.DeepEqual(result, expected) {
+		t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
+	}
+}