diff --git a/ers/filexml_test.go b/ers/filexml_test.go new file mode 100644 index 000000000..ac9ae8490 --- /dev/null +++ b/ers/filexml_test.go @@ -0,0 +1,47 @@ +/* +Real-time Online/Offline Charging System (OCS) for Telecom & ISP environments +Copyright (C) ITsysCOM GmbH + +This program is free software: you can redistribute it and/or modify +it under the terms of the GNU General Public License as published by +the Free Software Foundation, either version 3 of the License, or +(at your option) any later version. + +This program is distributed in the hope that it will be useful, +but WITHOUT ANY WARRANTY; without even the implied warranty of +MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the +GNU General Public License for more details. + +You should have received a copy of the GNU General Public License +along with this program. If not, see +*/ +package ers + +import ( + "reflect" + "testing" + + "github.com/cgrates/cgrates/config" +) + +func TestERSNewXMLFileER(t *testing.T) { + cfg := config.NewDefaultCGRConfig() + expected := &XMLFileER{ + cgrCfg: cfg, + cfgIdx: 0, + fltrS: nil, + rdrDir: "/var/spool/cgrates/ers/in", + rdrEvents: nil, + rdrError: nil, + rdrExit: nil, + conReqs: nil, + } + result, err := NewXMLFileER(cfg, 0, nil, nil, nil, nil) + if err != nil { + t.Errorf("\nExpected: <%+v>, \nreceived: <%+v>", nil, err) + } + expected.conReqs = result.(*XMLFileER).conReqs + if !reflect.DeepEqual(result, expected) { + t.Errorf("\nExpected: <%+v>, \nreceived: <%+v>", expected, result) + } +} diff --git a/ers/sql_test.go b/ers/sql_test.go index 972a93b0a..3f2b8f600 100644 --- a/ers/sql_test.go +++ b/ers/sql_test.go @@ -200,3 +200,57 @@ func TestSQLReaderServeBadType(t *testing.T) { } logger.Default = tmp } + +func TestSQLPostCDRMySQLError(t *testing.T) { + tmp := logger.Default + logger.Default = logger.Default.LogMode(logger.Silent) + cfg := config.NewDefaultCGRConfig() + testSQLEventReader := &SQLEventReader{ + cgrCfg: cfg, + cfgIdx: 0, + fltrS: nil, + connString: "", + connType: "", + tableName: "testName", + expConnString: "", + expConnType: utils.MySQL, + expTableName: "", + rdrEvents: nil, + rdrExit: nil, + rdrErr: nil, + cap: nil, + } + err := testSQLEventReader.postCDR([]interface{}{}) + expected := "Error 1045: Access denied for user ''@'localhost' (using password: NO)" + if err == nil { + t.Errorf("\nExpected: <%+v>, \nreceived: <%+v>", expected, err) + } + logger.Default = tmp +} + +func TestSQLPostCDRPostgresError(t *testing.T) { + tmp := logger.Default + logger.Default = logger.Default.LogMode(logger.Silent) + cfg := config.NewDefaultCGRConfig() + testSQLEventReader := &SQLEventReader{ + cgrCfg: cfg, + cfgIdx: 0, + fltrS: nil, + connString: "", + connType: "", + tableName: "testName", + expConnString: "", + expConnType: utils.Postgres, + expTableName: "", + rdrEvents: nil, + rdrExit: nil, + rdrErr: nil, + cap: nil, + } + err := testSQLEventReader.postCDR([]interface{}{}) + expected := "Error 1045: Access denied for user ''@'localhost' (using password: NO)" + if err == nil { + t.Errorf("\nExpected: <%+v>, \nreceived: <%+v>", expected, err) + } + logger.Default = tmp +}