Tests for sql.go and partial_csv.go in ers

This commit is contained in:
andronache
2021-03-25 15:50:29 +02:00
committed by Dan Christian Bogos
parent 67ce25cdb5
commit 65320aa4ff
2 changed files with 50 additions and 3 deletions

View File

@@ -525,8 +525,6 @@ func TestPartialCSVProcessFile2(t *testing.T) {
}
}
/*
func TestPartialCSVServe2(t *testing.T) {
cfg := config.NewDefaultCGRConfig()
cfg.ERsCfg().Readers = []*config.EventReaderCfg{
@@ -568,4 +566,3 @@ func TestPartialCSVServe2(t *testing.T) {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", "no such file or directory", err)
}
}
*/

View File

@@ -585,3 +585,53 @@ func testSQLStop2(t *testing.T) {
}
}
func TestSQLProcessMessageError(t *testing.T) {
cfg := config.NewDefaultCGRConfig()
testSQLEventReader := &SQLEventReader{
cgrCfg: cfg,
cfgIdx: 0,
fltrS: &engine.FilterS{},
connString: "",
connType: "",
tableName: "testName",
expConnString: "",
expConnType: utils.Postgres,
expTableName: "",
rdrEvents: nil,
rdrExit: nil,
rdrErr: nil,
cap: nil,
}
msgTest := map[string]interface{}{}
err := testSQLEventReader.processMessage(msgTest)
expected := "NOT_FOUND:ToR"
if err == nil || err.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, err)
}
}
func TestSQLSetURLError(t *testing.T) {
cfg := config.NewDefaultCGRConfig()
testSQLEventReader := &SQLEventReader{
cgrCfg: cfg,
cfgIdx: 0,
fltrS: &engine.FilterS{},
connString: "",
connType: "",
tableName: "testName",
expConnString: "",
expConnType: utils.Postgres,
expTableName: "",
rdrEvents: nil,
rdrExit: nil,
rdrErr: nil,
cap: nil,
}
err := testSQLEventReader.setURL("http://user^:passwo^rd@foo.com/", "", nil)
expected := `parse "http://user^:passwo^rd@foo.com/": net/url: invalid userinfo`
if err == nil || err.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, err)
}
}