Cover tests for functions in ers

ers/amqp_it_test.go

@@ -129,3 +129,17 @@ func TestAMQPER(t *testing.T) {
 	}
 	close(rdrExit)
 }
+
+func TestAMQPERServeError(t *testing.T) {
+	cfg := config.NewDefaultCGRConfig()
+	cfgIdx := 0
+	expected := "AMQP scheme must be either 'amqp://' or 'amqps://'"
+	rdr, err := NewAMQPER(cfg, cfgIdx, nil, nil, nil, nil)
+	if err != nil {
+		t.Errorf("\nExpected <%+v>, \nReceived <%+v>", nil, err)
+	}
+	err2 := rdr.Serve()
+	if err2 == nil || err2.Error() != expected {
+		t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, err2)
+	}
+}

ers/readers_test.go

@@ -119,3 +119,20 @@ func TestNewSQLReader(t *testing.T) {
 		t.Errorf("Expecting: <%+v>, received: <%+v>", expected, rcv)
 	}
 }
+
+func TestNewSQLReaderError(t *testing.T) {
+	cfg := config.NewDefaultCGRConfig()
+	fltr := &engine.FilterS{}
+	reader := cfg.ERsCfg().Readers[0].Clone()
+	reader.Type = utils.MetaSQL
+	reader.ID = "file_reader"
+	reader.ConcurrentReqs = -1
+	reader.Opts = map[string]interface{}{"db_name": "cgrates2"}
+	reader.SourcePath = "#"
+	reader.ProcessedPath = ""
+	expected := "unknown db_type "
+	_, err := NewSQLEventReader(cfg, 0, nil, nil, fltr, nil)
+	if err == nil || err.Error() != expected {
+		t.Errorf("Expecting: <%+v>, received: <%+v>", expected, err)
+	}
+}

ers/sql_it_test.go

@@ -326,6 +326,17 @@ func testSQLStop(t *testing.T) {
 
 }
 
+func TestSQLReaderServeBadTypeErr(t *testing.T) {
+	rdr := &SQLEventReader{
+		connType: "badType",
+	}
+	expected := "db type <badType> not supported"
+	err := rdr.Serve()
+	if err == nil || err.Error() != expected {
+		t.Errorf("\nExpected: <%+v>, \nreceived: <%+v>", expected, err)
+	}
+}
+
 func TestSQLPostCDR(t *testing.T) {
 	cfg := config.NewDefaultCGRConfig()
 	rdr := &SQLEventReader{