uppal/cgrates
1
0
Fork 1
mirror of https://github.com/cgrates/cgrates.git synced 2026-02-23 08:08:45 +05:00
Code Issues Packages Projects Releases Wiki Activity

Revise integration tests after StorDB addition

Browse Source
This commit is contained in:
ionutboangiu
2023-04-27 15:05:08 -04:00
committed by Dan Christian Bogos
parent 5227b4d447
commit 3e22cef9cb
305 changed files with 4055 additions and 3148 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
ees/amqp_it_test.go
View File

@@ -45,7 +45,7 @@ var (
sTestsAMQP = []func(t *testing.T){
testCreateDirectory,
testAMQPLoadConfig,
testAMQPResetDataDB,
testAMQPResetDBs,
testAMQPStartEngine,
testAMQPRPCConn,
@@ -78,10 +78,13 @@ func testAMQPLoadConfig(t *testing.T) {
}
}
func testAMQPResetDataDB(t *testing.T) {
func testAMQPResetDBs(t *testing.T) {
if err := engine.InitDataDB(amqpCfg); err != nil {
t.Fatal(err)
}
if err := engine.InitStorDB(amqpCfg); err != nil {
t.Fatal(err)
}
}
func testAMQPStartEngine(t *testing.T) {

7
ees/amqpv1_it_test.go
View File

@@ -43,7 +43,7 @@ var (
sTestsAMQPv1 = []func(t *testing.T){
testAMQPv1LoadConfig,
testAMQPv1ResetDataDB,
testAMQPv1ResetDBs,
testAMQPv1StartEngine,
testAMQPv1RPCConn,
@@ -82,10 +82,13 @@ func testAMQPv1LoadConfig(t *testing.T) {
}
}
func testAMQPv1ResetDataDB(t *testing.T) {
func testAMQPv1ResetDBs(t *testing.T) {
if err := engine.InitDataDB(amqpv1Cfg); err != nil {
t.Fatal(err)
}
if err := engine.InitStorDB(amqpv1Cfg); err != nil {
t.Fatal(err)
}
}
func testAMQPv1StartEngine(t *testing.T) {

7
ees/elastic_it_test.go
View File

@@ -50,7 +50,7 @@ var (
sTestsElastic = []func(t *testing.T){
testCreateDirectory,
testElasticLoadConfig,
testElasticResetDataDB,
testElasticResetDBs,
testElasticStartEngine,
testElasticRPCConn,
@@ -84,10 +84,13 @@ func testElasticLoadConfig(t *testing.T) {
}
}
func testElasticResetDataDB(t *testing.T) {
func testElasticResetDBs(t *testing.T) {
if err := engine.InitDataDB(elasticCfg); err != nil {
t.Fatal(err)
}
if err := engine.InitStorDB(elasticCfg); err != nil {
t.Fatal(err)
}
}
func testElasticStartEngine(t *testing.T) {

7
ees/filecsv_it_test.go
View File

@@ -51,7 +51,7 @@ var (
sTestsCsv = []func(t *testing.T){
testCreateDirectory,
testCsvLoadConfig,
testCsvResetDataDB,
testCsvResetDBs,
testCsvStartEngine,
testCsvRPCConn,
@@ -84,10 +84,13 @@ func testCsvLoadConfig(t *testing.T) {
}
}
func testCsvResetDataDB(t *testing.T) {
func testCsvResetDBs(t *testing.T) {
if err := engine.InitDataDB(csvCfg); err != nil {
t.Fatal(err)
}
if err := engine.InitStorDB(csvCfg); err != nil {
t.Fatal(err)
}
}
func testCsvStartEngine(t *testing.T) {

7
ees/filefwv_it_test.go
View File

@@ -46,7 +46,7 @@ var (
sTestsFwv = []func(t *testing.T){
testCreateDirectory,
testFwvLoadConfig,
testFwvResetDataDB,
testFwvResetDBs,
testFwvStartEngine,
testFwvRPCConn,
@@ -72,10 +72,13 @@ func testFwvLoadConfig(t *testing.T) {
}
}
func testFwvResetDataDB(t *testing.T) {
func testFwvResetDBs(t *testing.T) {
if err := engine.InitDataDB(fwvCfg); err != nil {
t.Fatal(err)
}
if err := engine.InitStorDB(fwvCfg); err != nil {
t.Fatal(err)
}
}
func testFwvStartEngine(t *testing.T) {

7
ees/httppost_it_test.go
View File

@@ -47,7 +47,7 @@ var (
sTestsHTTPPost = []func(t *testing.T){
testCreateDirectory,
testHTTPPostLoadConfig,
testHTTPPostResetDataDB,
testHTTPPostResetDBs,
testHTTPPostStartEngine,
testHTTPPostRPCConn,
@@ -73,10 +73,13 @@ func testHTTPPostLoadConfig(t *testing.T) {
}
}
func testHTTPPostResetDataDB(t *testing.T) {
func testHTTPPostResetDBs(t *testing.T) {
if err := engine.InitDataDB(httpPostCfg); err != nil {
t.Fatal(err)
}
if err := engine.InitStorDB(httpPostCfg); err != nil {
t.Fatal(err)
}
}
func testHTTPPostStartEngine(t *testing.T) {

7
ees/kafka_it_test.go
View File

@@ -46,7 +46,7 @@ var (
sTestsKafka = []func(t *testing.T){
testCreateDirectory,
testKafkaLoadConfig,
testKafkaResetDataDB,
testKafkaResetDBs,
testKafkaStartEngine,
testKafkaRPCConn,
@@ -74,10 +74,13 @@ func testKafkaLoadConfig(t *testing.T) {
}
}
func testKafkaResetDataDB(t *testing.T) {
func testKafkaResetDBs(t *testing.T) {
if err := engine.InitDataDB(kafkaCfg); err != nil {
t.Fatal(err)
}
if err := engine.InitStorDB(kafkaCfg); err != nil {
t.Fatal(err)
}
}
func testKafkaStartEngine(t *testing.T) {

7
ees/posterjsonmap_it_test.go
View File

@@ -47,7 +47,7 @@ var (
sTestsHTTPJsonMap = []func(t *testing.T){
testCreateDirectory,
testHTTPJsonMapLoadConfig,
testHTTPJsonMapResetDataDB,
testHTTPJsonMapResetDBs,
testHTTPJsonMapStartEngine,
testHTTPJsonMapRPCConn,
testHTTPJsonMapStartHTTPServer,
@@ -72,10 +72,13 @@ func testHTTPJsonMapLoadConfig(t *testing.T) {
}
}
func testHTTPJsonMapResetDataDB(t *testing.T) {
func testHTTPJsonMapResetDBs(t *testing.T) {
if err := engine.InitDataDB(httpJSONMapCfg); err != nil {
t.Fatal(err)
}
if err := engine.InitStorDB(httpJSONMapCfg); err != nil {
t.Fatal(err)
}
}
func testHTTPJsonMapStartEngine(t *testing.T) {

7
ees/sql_it_test.go
View File

@@ -51,7 +51,7 @@ var (
testCreateDirectory,
testSqlEeCreateTable,
testSqlEeLoadConfig,
testSqlEeResetDataDB,
testSqlEeResetDBs,
testSqlEeStartEngine,
testSqlEeRPCConn,
testSqlEeExportEventFull,
@@ -123,10 +123,13 @@ func testSqlEeLoadConfig(t *testing.T) {
}
}
func testSqlEeResetDataDB(t *testing.T) {
func testSqlEeResetDBs(t *testing.T) {
if err := engine.InitDataDB(sqlEeCfg); err != nil {
t.Fatal(err)
}
if err := engine.InitStorDB(sqlEeCfg); err != nil {
t.Fatal(err)
}
}
func testSqlEeStartEngine(t *testing.T) {

7
ees/sqs_it_test.go
View File

@@ -47,7 +47,7 @@ var (
sTestsSQS = []func(t *testing.T){
testSQSLoadConfig,
testSQSResetDataDB,
testSQSResetDBs,
testSQSStartEngine,
testSQSRPCConn,
testSQSExportEvent,
@@ -80,10 +80,13 @@ func testSQSLoadConfig(t *testing.T) {
}
}
func testSQSResetDataDB(t *testing.T) {
func testSQSResetDBs(t *testing.T) {
if err := engine.InitDataDB(sqsCfg); err != nil {
t.Fatal(err)
}
if err := engine.InitStorDB(sqsCfg); err != nil {
t.Fatal(err)
}
}
func testSQSStartEngine(t *testing.T) {

7
ees/virtual_ee_it_test.go
View File

@@ -46,7 +46,7 @@ var (
sTestsVirt = []func(t *testing.T){
testCreateDirectory,
testVirtLoadConfig,
testVirtResetDataDB,
testVirtResetDBs,
testVirtStartEngine,
testVirtRPCConn,
testVirtExportSupplierEvent,
@@ -72,10 +72,13 @@ func testVirtLoadConfig(t *testing.T) {
}
}
func testVirtResetDataDB(t *testing.T) {
func testVirtResetDBs(t *testing.T) {
if err := engine.InitDataDB(virtCfg); err != nil {
t.Fatal(err)
}
if err := engine.InitStorDB(virtCfg); err != nil {
t.Fatal(err)
}
}
func testVirtStartEngine(t *testing.T) {