From 676900b4c3ed456b72568018238520dac2008b41 Mon Sep 17 00:00:00 2001 From: ionutboangiu Date: Mon, 26 May 2025 20:51:14 +0300 Subject: [PATCH] update DB casing for InitDB helpers --- agents/diam_empty_ce_it_test.go | 2 +- agents/diam_it_test.go | 6 +++--- agents/dnsagent_it_test.go | 2 +- agents/httpagent_it_test.go | 2 +- agents/janusagent_it_test.go | 2 +- agents/radagent_it_test.go | 4 ++-- agents/radius_coa_it_test.go | 2 +- agents/sipagent_it_test.go | 2 +- analyzers/analyzers_it_test.go | 2 +- apier/v1/accounts_it_test.go | 2 +- apier/v1/apier2_it_test.go | 2 +- apier/v1/apier_it_test.go | 4 ++-- apier/v1/attributes_it_test.go | 2 +- apier/v1/cache_replication_it_test.go | 4 ++-- apier/v1/caches_it_test.go | 2 +- apier/v1/cdrs_it_test.go | 2 +- apier/v1/chargers_it_test.go | 2 +- apier/v1/config_it_test.go | 2 +- apier/v1/core_it_test.go | 2 +- apier/v1/costs_it_test.go | 2 +- apier/v1/dispatcher_it_test.go | 2 +- apier/v1/dispatchersv1_it_test.go | 2 +- apier/v1/ees_it_test.go | 2 +- apier/v1/filter_indexes_health_it_test.go | 2 +- apier/v1/filter_indexes_it_test.go | 2 +- apier/v1/filterindexecache_it_test.go | 2 +- apier/v1/filters_it_test.go | 2 +- apier/v1/full_remote_it_test.go | 2 +- apier/v1/guardian_it_test.go | 2 +- apier/v1/precache_it_test.go | 2 +- apier/v1/rankings_it_test.go | 2 +- apier/v1/rating_profile_late_it_test.go | 2 +- apier/v1/remote_it_test.go | 4 ++-- apier/v1/replicate_it_test.go | 5 +++-- apier/v1/resourcesv1_it_test.go | 2 +- apier/v1/routes_it_test.go | 2 +- apier/v1/schedulers_it_test.go | 2 +- apier/v1/sessions_thresholds_it_test.go | 2 +- apier/v1/sessionsv1_it_test.go | 2 +- apier/v1/stats_it_test.go | 2 +- apier/v1/thresholds_it_test.go | 2 +- apier/v1/timing_it_test.go | 2 +- apier/v1/trends_it_test.go | 2 +- apier/v2/accounts_it_test.go | 2 +- apier/v2/apierv2_it_test.go | 2 +- apier/v2/attributes_it_test.go | 2 +- apier/v2/cdrs_it_test.go | 2 +- apier/v2/cdrs_offline_it_test.go | 2 +- apier/v2/tp_it_test.go | 2 +- cmd/cgr-console/cgr-console_it_test.go | 2 +- cmd/cgr-loader/cgr-loader_it_test.go | 2 +- cmd/cgr-loader/cgr-loader_remove_it_test.go | 2 +- dispatchers/lib_test.go | 2 +- ees/amqp_it_test.go | 2 +- ees/amqpv1_it_test.go | 2 +- ees/filecsv_it_test.go | 2 +- ees/filefwv_it_test.go | 2 +- ees/httppost_it_test.go | 2 +- ees/kafka_it_test.go | 2 +- ees/posterjsonmap_it_test.go | 2 +- ees/s3_it_test.go | 2 +- ees/sql_it_test.go | 2 +- ees/sqs_it_test.go | 2 +- ees/virtual_ee_it_test.go | 2 +- engine/libtest.go | 4 ++-- engine/z_actions2_it_test.go | 2 +- engine/z_actions_it_test.go | 2 +- ers/ers_reload_it_test.go | 2 +- ers/filecsv_it_test.go | 2 +- ers/filefwv_it_test.go | 2 +- ers/filejson_it_test.go | 2 +- ers/filexml_it_test.go | 2 +- ers/flatstore_it_test.go | 2 +- ers/partial_csv_it_test.go | 2 +- general_tests/a1_it_test.go | 2 +- general_tests/accounts_it_test.go | 2 +- general_tests/accountswiththresholds_it_test.go | 2 +- general_tests/all_cfg_sect_rld_it_test.go | 2 +- general_tests/attributes_filters_index_it_test.go | 2 +- general_tests/attributes_it_test.go | 2 +- general_tests/attributeswithdataconverters_it_test.go | 2 +- general_tests/birpc_benchmark_test.go | 2 +- general_tests/broadcast_client_it_test.go | 2 +- general_tests/cacherpl_filter_update_it_test.go | 2 +- general_tests/cacherpl_it_test.go | 4 ++-- general_tests/cdrs_exp_it_test.go | 2 +- general_tests/cdrs_it_test.go | 2 +- general_tests/cdrs_onlexp_it_test.go | 4 ++-- general_tests/cdrs_post_failover_it_test.go | 2 +- general_tests/cdrs_processevent_it_test.go | 2 +- general_tests/cgrloader_it_test.go | 2 +- general_tests/data_it_test.go | 2 +- general_tests/destination_combined_it_test.go | 2 +- general_tests/doubleremove_it_test.go | 2 +- general_tests/dynamic_thresholds_it_test.go | 2 +- general_tests/export_it_test.go | 2 +- general_tests/filtered_replication_it_test.go | 4 ++-- general_tests/filters_it_test.go | 2 +- general_tests/fltr_sep_it_test.go | 2 +- general_tests/fraud_detection_it_test.go | 2 +- general_tests/gocs_it_test.go | 6 +++--- general_tests/libengine_it_test.go | 2 +- general_tests/loader_nocontext_it_test.go | 2 +- general_tests/loaders_internal_indexes_it_test.go | 2 +- general_tests/poster_it_test.go | 2 +- general_tests/redis_cluster_it_test.go | 2 +- general_tests/redis_tls_it_test.go | 2 +- general_tests/reproc_cdrs_for_stats_it_test.go | 2 +- general_tests/rerate_ers_cdrs_it_test.go | 2 +- general_tests/rerate_exp_it_test.go | 4 ++-- general_tests/resourcesv1_it_test.go | 2 +- general_tests/route_it_test.go | 2 +- general_tests/routes_cases_it_test.go | 2 +- general_tests/rpccaching_it_test.go | 2 +- general_tests/rpcclient_it_test.go | 2 +- general_tests/sentinel_it_test.go | 2 +- general_tests/session2_it_test.go | 2 +- general_tests/session3_it_test.go | 2 +- general_tests/session4_it_test.go | 2 +- general_tests/session_bkup_interval_it_test.go | 2 +- general_tests/session_graceful_shutdown_it_test.go | 2 +- general_tests/session_it_test.go | 2 +- general_tests/session_money_rating_subject_it_test.go | 2 +- general_tests/session_nonereq_it_test.go | 2 +- general_tests/session_refund_expired_it_test.go | 2 +- .../session_replications_automaticdebit_it_test.go | 2 +- general_tests/session_rounding_it_test.go | 2 +- general_tests/session_rpl_prepaid_it_test.go | 2 +- general_tests/sessionpause_it_test.go | 2 +- general_tests/sessionrefund_it_test.go | 2 +- general_tests/sessionroutes_it_test.go | 2 +- general_tests/sessions_benchmark_it_test.go | 2 +- general_tests/sessions_message_it_test.go | 2 +- general_tests/sessions_tnt_change_cdr_it_test.go | 2 +- general_tests/sessions_tnt_change_it_test.go | 2 +- general_tests/shared_client_lock_it_test.go | 2 +- general_tests/tls_it_test.go | 2 +- general_tests/tp_it_test.go | 2 +- general_tests/trends_aut_it_test.go | 2 +- general_tests/tut_smgeneric_it_test.go | 2 +- general_tests/tutorial2_it_test.go | 2 +- general_tests/tutorial_calls_test.go | 2 +- general_tests/tutorial_it_test.go | 2 +- general_tests/twoengines_it_test.go | 2 +- loaders/loader_it_test.go | 2 +- registrarc/registarc_defaultid_it_test.go | 2 +- registrarc/registrarcrpc_it_test.go | 2 +- sessions/sessions_bench_test.go | 2 +- sessions/sessions_birpc_it_test.go | 2 +- sessions/sessions_bkup_rpl_it_test.go | 4 ++-- sessions/sessions_data_it_test.go | 2 +- sessions/sessions_it_test.go | 2 +- sessions/sessions_rpl_it_test.go | 2 +- sessions/sessions_total_usage_it_test.go | 2 +- sessions/sessions_voice_it_test.go | 2 +- 155 files changed, 171 insertions(+), 170 deletions(-) diff --git a/agents/diam_empty_ce_it_test.go b/agents/diam_empty_ce_it_test.go index 98f270214..4ee44c084 100644 --- a/agents/diam_empty_ce_it_test.go +++ b/agents/diam_empty_ce_it_test.go @@ -77,7 +77,7 @@ func testDiamEmptyCEItInitCfg(t *testing.T) { // Remove data in both rating and accounting db func testDiamEmptyCEItDataDb(t *testing.T) { - if err := engine.InitDataDb(daCfgND); err != nil { + if err := engine.InitDataDB(daCfgND); err != nil { t.Fatal(err) } } diff --git a/agents/diam_it_test.go b/agents/diam_it_test.go index 5bdf47dde..afb3de868 100644 --- a/agents/diam_it_test.go +++ b/agents/diam_it_test.go @@ -215,7 +215,7 @@ func testDiamItResetAllDB(t *testing.T) { if err != nil { t.Fatal(err) } - if err := engine.InitDataDb(allCfg); err != nil { + if err := engine.InitDataDB(allCfg); err != nil { t.Fatal(err) } if err := engine.InitStorDb(allCfg); err != nil { @@ -227,7 +227,7 @@ func testDiamItResetAllDB(t *testing.T) { if err != nil { t.Fatal(err) } - if err := engine.InitDataDb(allCfg2); err != nil { + if err := engine.InitDataDB(allCfg2); err != nil { t.Fatal(err) } if err := engine.InitStorDb(allCfg2); err != nil { @@ -237,7 +237,7 @@ func testDiamItResetAllDB(t *testing.T) { // Remove data in both rating and accounting db func testDiamItResetDataDb(t *testing.T) { - if err := engine.InitDataDb(daCfg); err != nil { + if err := engine.InitDataDB(daCfg); err != nil { t.Fatal(err) } } diff --git a/agents/dnsagent_it_test.go b/agents/dnsagent_it_test.go index 3e0e99988..716efb01b 100644 --- a/agents/dnsagent_it_test.go +++ b/agents/dnsagent_it_test.go @@ -104,7 +104,7 @@ func testDNSitInitCfg(t *testing.T) { // Remove data in both rating and accounting db func testDNSitResetDB(t *testing.T) { - if err := engine.InitDataDb(dnsCfg); err != nil { + if err := engine.InitDataDB(dnsCfg); err != nil { t.Fatal(err) } if err := engine.InitStorDb(dnsCfg); err != nil { diff --git a/agents/httpagent_it_test.go b/agents/httpagent_it_test.go index 8ec619ba4..af970498d 100644 --- a/agents/httpagent_it_test.go +++ b/agents/httpagent_it_test.go @@ -156,7 +156,7 @@ func testHAitHttp(t *testing.T) { // Remove data in both rating and accounting db func testHAitResetDB(t *testing.T) { - if err := engine.InitDataDb(haCfg); err != nil { + if err := engine.InitDataDB(haCfg); err != nil { t.Fatal(err) } if err := engine.InitStorDb(haCfg); err != nil { diff --git a/agents/janusagent_it_test.go b/agents/janusagent_it_test.go index fa77b7c77..eb3a629ae 100644 --- a/agents/janusagent_it_test.go +++ b/agents/janusagent_it_test.go @@ -92,7 +92,7 @@ func testJanitInitCfg(t *testing.T) { } func testJanitResetDB(t *testing.T) { - if err := engine.InitDataDb(janCfg); err != nil { + if err := engine.InitDataDB(janCfg); err != nil { t.Fatal(err) } if err := engine.InitStorDb(janCfg); err != nil { diff --git a/agents/radagent_it_test.go b/agents/radagent_it_test.go index b89154389..fe2577321 100644 --- a/agents/radagent_it_test.go +++ b/agents/radagent_it_test.go @@ -139,7 +139,7 @@ func testRadiusitResetAllDB(t *testing.T) { if err != nil { t.Fatal(err) } - if err := engine.InitDataDb(allCfg); err != nil { + if err := engine.InitDataDB(allCfg); err != nil { t.Fatal(err) } if err := engine.InitStorDb(allCfg); err != nil { @@ -149,7 +149,7 @@ func testRadiusitResetAllDB(t *testing.T) { // Remove data in both rating and accounting db func testRAitResetDataDb(t *testing.T) { - if err := engine.InitDataDb(raCfg); err != nil { + if err := engine.InitDataDB(raCfg); err != nil { t.Fatal(err) } } diff --git a/agents/radius_coa_it_test.go b/agents/radius_coa_it_test.go index a263f032a..d61a4f82c 100644 --- a/agents/radius_coa_it_test.go +++ b/agents/radius_coa_it_test.go @@ -73,7 +73,7 @@ func TestRadiusCoADisconnect(t *testing.T) { if err != nil { t.Fatal(err) } - if err := engine.InitDataDb(raDiscCfg); err != nil { + if err := engine.InitDataDB(raDiscCfg); err != nil { t.Fatal(err) } if err := engine.InitStorDb(raDiscCfg); err != nil { diff --git a/agents/sipagent_it_test.go b/agents/sipagent_it_test.go index b923d9222..a650a386a 100644 --- a/agents/sipagent_it_test.go +++ b/agents/sipagent_it_test.go @@ -92,7 +92,7 @@ func testSAitInitCfg(t *testing.T) { // Remove data in both rating and accounting db func testSAitResetDataDb(t *testing.T) { - if err := engine.InitDataDb(saCfg); err != nil { + if err := engine.InitDataDB(saCfg); err != nil { t.Fatal(err) } } diff --git a/analyzers/analyzers_it_test.go b/analyzers/analyzers_it_test.go index bf1f25f83..05e2c6bb1 100644 --- a/analyzers/analyzers_it_test.go +++ b/analyzers/analyzers_it_test.go @@ -103,7 +103,7 @@ func testAnalyzerSInitCfg(t *testing.T) { } func testAnalyzerSInitDataDb(t *testing.T) { - if err := engine.InitDataDb(anzCfg); err != nil { + if err := engine.InitDataDB(anzCfg); err != nil { t.Fatal(err) } } diff --git a/apier/v1/accounts_it_test.go b/apier/v1/accounts_it_test.go index 66a711d59..5fef3f371 100644 --- a/apier/v1/accounts_it_test.go +++ b/apier/v1/accounts_it_test.go @@ -137,7 +137,7 @@ func testAccITLoadConfig(t *testing.T) { } func testAccITResetDataDB(t *testing.T) { - if err := engine.InitDataDb(accCfg); err != nil { + if err := engine.InitDataDB(accCfg); err != nil { t.Fatal(err) } } diff --git a/apier/v1/apier2_it_test.go b/apier/v1/apier2_it_test.go index 0d294de0c..ed6ad860d 100644 --- a/apier/v1/apier2_it_test.go +++ b/apier/v1/apier2_it_test.go @@ -109,7 +109,7 @@ func testAPIerInitCfg(t *testing.T) { } func testAPIerInitDataDb(t *testing.T) { - if err := engine.InitDataDb(apierCfg); err != nil { + if err := engine.InitDataDB(apierCfg); err != nil { t.Fatal(err) } } diff --git a/apier/v1/apier_it_test.go b/apier/v1/apier_it_test.go index 103acb335..bda846253 100644 --- a/apier/v1/apier_it_test.go +++ b/apier/v1/apier_it_test.go @@ -212,7 +212,7 @@ func testApierCreateDirs(t *testing.T) { } func testApierInitDataDb(t *testing.T) { - if err := engine.InitDataDb(cfg); err != nil { + if err := engine.InitDataDB(cfg); err != nil { t.Fatal(err) } } @@ -2001,7 +2001,7 @@ func testApierITGetCost(t *testing.T) { // Test LoadTPFromStorDb func testApierInitDataDb2(t *testing.T) { - if err := engine.InitDataDb(cfg); err != nil { + if err := engine.InitDataDB(cfg); err != nil { t.Fatal(err) } } diff --git a/apier/v1/attributes_it_test.go b/apier/v1/attributes_it_test.go index ecc8c6d01..a3d62188c 100644 --- a/apier/v1/attributes_it_test.go +++ b/apier/v1/attributes_it_test.go @@ -137,7 +137,7 @@ func testAttributeSInitCfg(t *testing.T) { } func testAttributeSInitDataDb(t *testing.T) { - if err := engine.InitDataDb(alsPrfCfg); err != nil { + if err := engine.InitDataDB(alsPrfCfg); err != nil { t.Fatal(err) } } diff --git a/apier/v1/cache_replication_it_test.go b/apier/v1/cache_replication_it_test.go index 1a031662c..d83c214b4 100644 --- a/apier/v1/cache_replication_it_test.go +++ b/apier/v1/cache_replication_it_test.go @@ -75,10 +75,10 @@ func testCacheSReplicateLoadConfig(t *testing.T) { } func testCacheSReplicateInitDataDb(t *testing.T) { - if err := engine.InitDataDb(engine1Cfg); err != nil { + if err := engine.InitDataDB(engine1Cfg); err != nil { t.Fatal(err) } - if err := engine.InitDataDb(engine2Cfg); err != nil { + if err := engine.InitDataDB(engine2Cfg); err != nil { t.Fatal(err) } } diff --git a/apier/v1/caches_it_test.go b/apier/v1/caches_it_test.go index 62378d323..6095b63ba 100644 --- a/apier/v1/caches_it_test.go +++ b/apier/v1/caches_it_test.go @@ -92,7 +92,7 @@ func testCacheSLoadConfig(t *testing.T) { } func testCacheSInitDataDb(t *testing.T) { - if err := engine.InitDataDb(chcCfg); err != nil { + if err := engine.InitDataDB(chcCfg); err != nil { t.Fatal(err) } } diff --git a/apier/v1/cdrs_it_test.go b/apier/v1/cdrs_it_test.go index d7c23579b..2943a63de 100644 --- a/apier/v1/cdrs_it_test.go +++ b/apier/v1/cdrs_it_test.go @@ -89,7 +89,7 @@ func testV1CDRsInitConfig(t *testing.T) { } func testV1CDRsInitDataDb(t *testing.T) { - if err := engine.InitDataDb(cdrsCfg); err != nil { + if err := engine.InitDataDB(cdrsCfg); err != nil { t.Fatal(err) } } diff --git a/apier/v1/chargers_it_test.go b/apier/v1/chargers_it_test.go index eec66d029..3d07b93b9 100644 --- a/apier/v1/chargers_it_test.go +++ b/apier/v1/chargers_it_test.go @@ -136,7 +136,7 @@ func testChargerSInitCfg(t *testing.T) { } func testChargerSInitDataDb(t *testing.T) { - if err := engine.InitDataDb(chargerCfg); err != nil { + if err := engine.InitDataDB(chargerCfg); err != nil { t.Fatal(err) } } diff --git a/apier/v1/config_it_test.go b/apier/v1/config_it_test.go index a949c8bed..13937782d 100644 --- a/apier/v1/config_it_test.go +++ b/apier/v1/config_it_test.go @@ -96,7 +96,7 @@ func testConfigSInitCfg(t *testing.T) { } func testConfigSInitDataDb(t *testing.T) { - if err := engine.InitDataDb(configCfg); err != nil { + if err := engine.InitDataDB(configCfg); err != nil { t.Fatal(err) } } diff --git a/apier/v1/core_it_test.go b/apier/v1/core_it_test.go index 1119da975..d1c6d1cb9 100644 --- a/apier/v1/core_it_test.go +++ b/apier/v1/core_it_test.go @@ -117,7 +117,7 @@ func testCoreSv1LoadCofig(t *testing.T) { } func testCoreSv1InitDataDB(t *testing.T) { - if err := engine.InitDataDb(coreV1Cfg); err != nil { + if err := engine.InitDataDB(coreV1Cfg); err != nil { t.Error(err) } } diff --git a/apier/v1/costs_it_test.go b/apier/v1/costs_it_test.go index 39aeed79d..f899d7b31 100644 --- a/apier/v1/costs_it_test.go +++ b/apier/v1/costs_it_test.go @@ -80,7 +80,7 @@ func testCostInitCfg(t *testing.T) { } func testCostInitDataDb(t *testing.T) { - if err := engine.InitDataDb(costCfg); err != nil { + if err := engine.InitDataDB(costCfg); err != nil { t.Fatal(err) } } diff --git a/apier/v1/dispatcher_it_test.go b/apier/v1/dispatcher_it_test.go index f76b44a15..d6041a5c9 100644 --- a/apier/v1/dispatcher_it_test.go +++ b/apier/v1/dispatcher_it_test.go @@ -120,7 +120,7 @@ func testDispatcherSInitCfg(t *testing.T) { } func testDispatcherSInitDataDb(t *testing.T) { - if err := engine.InitDataDb(dispatcherCfg); err != nil { + if err := engine.InitDataDB(dispatcherCfg); err != nil { t.Fatal(err) } } diff --git a/apier/v1/dispatchersv1_it_test.go b/apier/v1/dispatchersv1_it_test.go index 58f9d3b10..a3be7494e 100644 --- a/apier/v1/dispatchersv1_it_test.go +++ b/apier/v1/dispatchersv1_it_test.go @@ -85,7 +85,7 @@ func testDspITLoadConfig(t *testing.T) { } func testDspITResetDataDB(t *testing.T) { - if err := engine.InitDataDb(dspCfg); err != nil { + if err := engine.InitDataDB(dspCfg); err != nil { t.Fatal(err) } } diff --git a/apier/v1/ees_it_test.go b/apier/v1/ees_it_test.go index f5827fc85..ebce209b4 100644 --- a/apier/v1/ees_it_test.go +++ b/apier/v1/ees_it_test.go @@ -99,7 +99,7 @@ func testEEsInitCfg(t *testing.T) { } func testEEsInitDataDb(t *testing.T) { - if err := engine.InitDataDb(eeSCfg); err != nil { + if err := engine.InitDataDB(eeSCfg); err != nil { t.Fatal(err) } } diff --git a/apier/v1/filter_indexes_health_it_test.go b/apier/v1/filter_indexes_health_it_test.go index 98658b629..a718c0aad 100644 --- a/apier/v1/filter_indexes_health_it_test.go +++ b/apier/v1/filter_indexes_health_it_test.go @@ -105,7 +105,7 @@ func testV1FIdxHdxInitDataDb(t *testing.T) { return } tSv1InternalRestart = true - if err := engine.InitDataDb(tSv1Cfg); err != nil { + if err := engine.InitDataDB(tSv1Cfg); err != nil { t.Fatal(err) } } diff --git a/apier/v1/filter_indexes_it_test.go b/apier/v1/filter_indexes_it_test.go index 2ee738a73..99495c8d8 100644 --- a/apier/v1/filter_indexes_it_test.go +++ b/apier/v1/filter_indexes_it_test.go @@ -152,7 +152,7 @@ func testV1FIdxdxInitDataDb(t *testing.T) { return } tSv1InternalRestart = true - if err := engine.InitDataDb(tSv1Cfg); err != nil { + if err := engine.InitDataDB(tSv1Cfg); err != nil { t.Fatal(err) } } diff --git a/apier/v1/filterindexecache_it_test.go b/apier/v1/filterindexecache_it_test.go index 5a157ebfa..556a8169b 100644 --- a/apier/v1/filterindexecache_it_test.go +++ b/apier/v1/filterindexecache_it_test.go @@ -108,7 +108,7 @@ func testV1FIdxCaLoadConfig(t *testing.T) { } func testV1FIdxCaInitDataDb(t *testing.T) { - if err := engine.InitDataDb(tSv1Cfg); err != nil { + if err := engine.InitDataDB(tSv1Cfg); err != nil { t.Fatal(err) } } diff --git a/apier/v1/filters_it_test.go b/apier/v1/filters_it_test.go index f6acf4ae2..012317b58 100644 --- a/apier/v1/filters_it_test.go +++ b/apier/v1/filters_it_test.go @@ -93,7 +93,7 @@ func testFilterInitCfg(t *testing.T) { // Wipe out the cdr database func testFilterResetDataDB(t *testing.T) { - if err := engine.InitDataDb(filterCfg); err != nil { + if err := engine.InitDataDB(filterCfg); err != nil { t.Fatal(err) } } diff --git a/apier/v1/full_remote_it_test.go b/apier/v1/full_remote_it_test.go index 084214c7f..7d75c98fb 100644 --- a/apier/v1/full_remote_it_test.go +++ b/apier/v1/full_remote_it_test.go @@ -91,7 +91,7 @@ func testFullRemoteITInitCfg(t *testing.T) { } func testFullRemoteITDataFlush(t *testing.T) { - if err := engine.InitDataDb(fullRemEngineOneCfg); err != nil { + if err := engine.InitDataDB(fullRemEngineOneCfg); err != nil { t.Fatal(err) } time.Sleep(100 * time.Millisecond) diff --git a/apier/v1/guardian_it_test.go b/apier/v1/guardian_it_test.go index d79b3bf08..466df0145 100644 --- a/apier/v1/guardian_it_test.go +++ b/apier/v1/guardian_it_test.go @@ -55,7 +55,7 @@ func TestGuardianSIT(t *testing.T) { t.Error(err) } - if err = engine.InitDataDb(guardianCfg); err != nil { + if err = engine.InitDataDB(guardianCfg); err != nil { t.Fatal(err) } diff --git a/apier/v1/precache_it_test.go b/apier/v1/precache_it_test.go index d0767ea7a..1fcec9d83 100644 --- a/apier/v1/precache_it_test.go +++ b/apier/v1/precache_it_test.go @@ -92,7 +92,7 @@ func testPrecacheInitCfg(t *testing.T) { } func testPrecacheResetDataDB(t *testing.T) { - if err := engine.InitDataDb(precacheCfg); err != nil { + if err := engine.InitDataDB(precacheCfg); err != nil { t.Fatal(err) } } diff --git a/apier/v1/rankings_it_test.go b/apier/v1/rankings_it_test.go index ec339ea5a..601f6adaf 100644 --- a/apier/v1/rankings_it_test.go +++ b/apier/v1/rankings_it_test.go @@ -95,7 +95,7 @@ func testRankingSInitCfg(t *testing.T) { } func testRankingSInitDataDb(t *testing.T) { - if err := engine.InitDataDb(rankingCfg); err != nil { + if err := engine.InitDataDB(rankingCfg); err != nil { t.Fatal(err) } } diff --git a/apier/v1/rating_profile_late_it_test.go b/apier/v1/rating_profile_late_it_test.go index b5fc5f3be..e51c0af28 100644 --- a/apier/v1/rating_profile_late_it_test.go +++ b/apier/v1/rating_profile_late_it_test.go @@ -81,7 +81,7 @@ func testRpLateInitCfg(t *testing.T) { } func testRpLateInitDataDb(t *testing.T) { - if err := engine.InitDataDb(rpLateCfg); err != nil { + if err := engine.InitDataDB(rpLateCfg); err != nil { t.Fatal(err) } } diff --git a/apier/v1/remote_it_test.go b/apier/v1/remote_it_test.go index 2ecf5ccbe..aa98b59d0 100644 --- a/apier/v1/remote_it_test.go +++ b/apier/v1/remote_it_test.go @@ -139,10 +139,10 @@ func testInternalRemoteITInitCfg(t *testing.T) { } func testInternalRemoteITDataFlush(t *testing.T) { - if err := engine.InitDataDb(engineOneCfg); err != nil { + if err := engine.InitDataDB(engineOneCfg); err != nil { t.Fatal(err) } - if err := engine.InitDataDb(engineTwoCfg); err != nil { + if err := engine.InitDataDB(engineTwoCfg); err != nil { t.Fatal(err) } time.Sleep(100 * time.Millisecond) diff --git a/apier/v1/replicate_it_test.go b/apier/v1/replicate_it_test.go index 79cde19c4..03659abea 100644 --- a/apier/v1/replicate_it_test.go +++ b/apier/v1/replicate_it_test.go @@ -26,6 +26,7 @@ import ( "testing" "time" + "github.com/blevesearch/goleveldb/leveldb/filter" "github.com/cgrates/birpc/context" "github.com/cgrates/cgrates/config" "github.com/cgrates/cgrates/engine" @@ -110,10 +111,10 @@ func testInternalReplicateITInitCfg(t *testing.T) { } func testInternalReplicateITDataFlush(t *testing.T) { - if err := engine.InitDataDb(engineOneCfg); err != nil { + if err := engine.InitDataDB(engineOneCfg); err != nil { t.Fatal(err) } - if err := engine.InitDataDb(engineTwoCfg); err != nil { + if err := engine.InitDataDB(engineTwoCfg); err != nil { t.Fatal(err) } } diff --git a/apier/v1/resourcesv1_it_test.go b/apier/v1/resourcesv1_it_test.go index c5f900dd9..5382577b9 100644 --- a/apier/v1/resourcesv1_it_test.go +++ b/apier/v1/resourcesv1_it_test.go @@ -136,7 +136,7 @@ func testV1RsLoadConfig(t *testing.T) { } func testV1RsInitDataDb(t *testing.T) { - if err := engine.InitDataDb(rlsV1Cfg); err != nil { + if err := engine.InitDataDB(rlsV1Cfg); err != nil { t.Fatal(err) } } diff --git a/apier/v1/routes_it_test.go b/apier/v1/routes_it_test.go index ea045a7bc..4c13ae81b 100644 --- a/apier/v1/routes_it_test.go +++ b/apier/v1/routes_it_test.go @@ -125,7 +125,7 @@ func testV1RouteLoadConfig(t *testing.T) { } func testV1RouteInitDataDb(t *testing.T) { - if err := engine.InitDataDb(routeSv1Cfg); err != nil { + if err := engine.InitDataDB(routeSv1Cfg); err != nil { t.Fatal(err) } } diff --git a/apier/v1/schedulers_it_test.go b/apier/v1/schedulers_it_test.go index bd0ca03a4..0a49fcdc0 100644 --- a/apier/v1/schedulers_it_test.go +++ b/apier/v1/schedulers_it_test.go @@ -122,7 +122,7 @@ func testSchedLoadConfig(t *testing.T) { } func testSchedInitDataDb(t *testing.T) { - if err := engine.InitDataDb(schedCfg); err != nil { + if err := engine.InitDataDB(schedCfg); err != nil { t.Fatal(err) } } diff --git a/apier/v1/sessions_thresholds_it_test.go b/apier/v1/sessions_thresholds_it_test.go index 15f015c02..b1358e09a 100644 --- a/apier/v1/sessions_thresholds_it_test.go +++ b/apier/v1/sessions_thresholds_it_test.go @@ -104,7 +104,7 @@ func testSessionSv1ItInitCfg(t *testing.T) { } func testSessionSv1ItResetDataDb(t *testing.T) { - if err := engine.InitDataDb(sSv1Cfg2); err != nil { + if err := engine.InitDataDB(sSv1Cfg2); err != nil { t.Fatal(err) } } diff --git a/apier/v1/sessionsv1_it_test.go b/apier/v1/sessionsv1_it_test.go index 8901394e2..eb83c1542 100644 --- a/apier/v1/sessionsv1_it_test.go +++ b/apier/v1/sessionsv1_it_test.go @@ -156,7 +156,7 @@ func TestSSv1ItWithPseudoPrepaid(t *testing.T) { } func testSSv1ItResetDataDb(t *testing.T) { - if err := engine.InitDataDb(sSv1Cfg); err != nil { + if err := engine.InitDataDB(sSv1Cfg); err != nil { t.Fatal(err) } } diff --git a/apier/v1/stats_it_test.go b/apier/v1/stats_it_test.go index b1917f42c..bf0aea564 100644 --- a/apier/v1/stats_it_test.go +++ b/apier/v1/stats_it_test.go @@ -152,7 +152,7 @@ func testV1STSLoadConfig(t *testing.T) { } func testV1STSInitDataDb(t *testing.T) { - if err := engine.InitDataDb(stsV1Cfg); err != nil { + if err := engine.InitDataDB(stsV1Cfg); err != nil { t.Fatal(err) } } diff --git a/apier/v1/thresholds_it_test.go b/apier/v1/thresholds_it_test.go index 67b0b347b..e35216df0 100644 --- a/apier/v1/thresholds_it_test.go +++ b/apier/v1/thresholds_it_test.go @@ -270,7 +270,7 @@ func testV1TSLoadConfig(t *testing.T) { } func testV1TSInitDataDb(t *testing.T) { - if err := engine.InitDataDb(tSv1Cfg); err != nil { + if err := engine.InitDataDB(tSv1Cfg); err != nil { t.Fatal(err) } } diff --git a/apier/v1/timing_it_test.go b/apier/v1/timing_it_test.go index 8631efd15..25e88e2e2 100644 --- a/apier/v1/timing_it_test.go +++ b/apier/v1/timing_it_test.go @@ -84,7 +84,7 @@ func testTimingInitCfg(t *testing.T) { } func testTimingInitDataDb(t *testing.T) { - if err := engine.InitDataDb(timCfg); err != nil { + if err := engine.InitDataDB(timCfg); err != nil { t.Fatal(err) } } diff --git a/apier/v1/trends_it_test.go b/apier/v1/trends_it_test.go index 098aea595..162216269 100644 --- a/apier/v1/trends_it_test.go +++ b/apier/v1/trends_it_test.go @@ -83,7 +83,7 @@ func testTrendSInitCfg(t *testing.T) { } func testTrendSInitDataDb(t *testing.T) { - if err := engine.InitDataDb(trendCfg); err != nil { + if err := engine.InitDataDB(trendCfg); err != nil { t.Fatal(err) } } diff --git a/apier/v2/accounts_it_test.go b/apier/v2/accounts_it_test.go index 290f3174b..8b7df9a7b 100644 --- a/apier/v2/accounts_it_test.go +++ b/apier/v2/accounts_it_test.go @@ -93,7 +93,7 @@ func testAccountsInitCfg(t *testing.T) { } func testAccountsInitDataDb(t *testing.T) { - if err := engine.InitDataDb(accCfg); err != nil { + if err := engine.InitDataDB(accCfg); err != nil { t.Fatal(err) } } diff --git a/apier/v2/apierv2_it_test.go b/apier/v2/apierv2_it_test.go index 439353743..90fedd320 100644 --- a/apier/v2/apierv2_it_test.go +++ b/apier/v2/apierv2_it_test.go @@ -92,7 +92,7 @@ func testAPIerSv2itLoadConfig(t *testing.T) { // Remove data in both rating and accounting db func testAPIerSv2itResetDataDb(t *testing.T) { - if err := engine.InitDataDb(apierCfg); err != nil { + if err := engine.InitDataDB(apierCfg); err != nil { t.Fatal(err) } } diff --git a/apier/v2/attributes_it_test.go b/apier/v2/attributes_it_test.go index 0b390ed2c..42e86313b 100644 --- a/apier/v2/attributes_it_test.go +++ b/apier/v2/attributes_it_test.go @@ -85,7 +85,7 @@ func testAttributeSInitCfg(t *testing.T) { } func testAttributeSInitDataDb(t *testing.T) { - if err := engine.InitDataDb(alsPrfCfg); err != nil { + if err := engine.InitDataDB(alsPrfCfg); err != nil { t.Fatal(err) } } diff --git a/apier/v2/cdrs_it_test.go b/apier/v2/cdrs_it_test.go index 25f99aa20..19956cdff 100644 --- a/apier/v2/cdrs_it_test.go +++ b/apier/v2/cdrs_it_test.go @@ -112,7 +112,7 @@ func testV2CDRsInitConfig(t *testing.T) { } func testV2CDRsInitDataDb(t *testing.T) { - if err := engine.InitDataDb(cdrsCfg); err != nil { + if err := engine.InitDataDB(cdrsCfg); err != nil { t.Fatal(err) } } diff --git a/apier/v2/cdrs_offline_it_test.go b/apier/v2/cdrs_offline_it_test.go index 8d7b760c7..3f3fa610b 100644 --- a/apier/v2/cdrs_offline_it_test.go +++ b/apier/v2/cdrs_offline_it_test.go @@ -84,7 +84,7 @@ func testV2CDRsOfflineInitConfig(t *testing.T) { } func testV2CDRsOfflineInitDataDb(t *testing.T) { - if err := engine.InitDataDb(cdrsOfflineCfg); err != nil { + if err := engine.InitDataDB(cdrsOfflineCfg); err != nil { t.Fatal(err) } } diff --git a/apier/v2/tp_it_test.go b/apier/v2/tp_it_test.go index 4de3f28ed..734052b6a 100644 --- a/apier/v2/tp_it_test.go +++ b/apier/v2/tp_it_test.go @@ -94,7 +94,7 @@ func testTPitLoadConfig(t *testing.T) { // Remove data in both rating and accounting db func testTPitResetDataDb(t *testing.T) { - if err := engine.InitDataDb(tpCfg); err != nil { + if err := engine.InitDataDB(tpCfg); err != nil { t.Fatal(err) } } diff --git a/cmd/cgr-console/cgr-console_it_test.go b/cmd/cgr-console/cgr-console_it_test.go index 814572d69..1d8b6ef32 100644 --- a/cmd/cgr-console/cgr-console_it_test.go +++ b/cmd/cgr-console/cgr-console_it_test.go @@ -290,7 +290,7 @@ func testConsoleItLoadersLoadConfig(t *testing.T) { } func testConsoleItInitDataDB(t *testing.T) { - if err := engine.InitDataDb(cnslItCfg); err != nil { + if err := engine.InitDataDB(cnslItCfg); err != nil { t.Fatal(err) } } diff --git a/cmd/cgr-loader/cgr-loader_it_test.go b/cmd/cgr-loader/cgr-loader_it_test.go index 80fd8bcb1..365ab67ea 100644 --- a/cmd/cgr-loader/cgr-loader_it_test.go +++ b/cmd/cgr-loader/cgr-loader_it_test.go @@ -267,7 +267,7 @@ func testLoadItLoadConfig(t *testing.T) { } func testLoadItResetDataDB(t *testing.T) { - if err := engine.InitDataDb(ldrItCfg); err != nil { + if err := engine.InitDataDB(ldrItCfg); err != nil { t.Fatal(err) } } diff --git a/cmd/cgr-loader/cgr-loader_remove_it_test.go b/cmd/cgr-loader/cgr-loader_remove_it_test.go index 1c72601da..72a7fd9f4 100644 --- a/cmd/cgr-loader/cgr-loader_remove_it_test.go +++ b/cmd/cgr-loader/cgr-loader_remove_it_test.go @@ -99,7 +99,7 @@ func testCgrLdrInitCfg(t *testing.T) { } func testCgrLdrInitDataDB(t *testing.T) { - if err := engine.InitDataDb(cgrLdrCfg); err != nil { + if err := engine.InitDataDB(cgrLdrCfg); err != nil { t.Fatal(err) } } diff --git a/dispatchers/lib_test.go b/dispatchers/lib_test.go index 385e0417a..aad9c0848 100644 --- a/dispatchers/lib_test.go +++ b/dispatchers/lib_test.go @@ -103,7 +103,7 @@ func (d *testDispatcher) stopEngine(t *testing.T) { } func (d *testDispatcher) initDataDb(t *testing.T) { - if err := engine.InitDataDb(d.Cfg); err != nil { + if err := engine.InitDataDB(d.Cfg); err != nil { t.Fatalf("Error at DataDB init:%v\n", err) } } diff --git a/ees/amqp_it_test.go b/ees/amqp_it_test.go index 2dcaab9d2..34c87e32c 100644 --- a/ees/amqp_it_test.go +++ b/ees/amqp_it_test.go @@ -80,7 +80,7 @@ func testAMQPLoadConfig(t *testing.T) { } func testAMQPResetDataDB(t *testing.T) { - if err := engine.InitDataDb(amqpCfg); err != nil { + if err := engine.InitDataDB(amqpCfg); err != nil { t.Fatal(err) } } diff --git a/ees/amqpv1_it_test.go b/ees/amqpv1_it_test.go index 7702ed237..2d34e842b 100644 --- a/ees/amqpv1_it_test.go +++ b/ees/amqpv1_it_test.go @@ -85,7 +85,7 @@ func testAMQPv1LoadConfig(t *testing.T) { } func testAMQPv1ResetDataDB(t *testing.T) { - if err := engine.InitDataDb(amqpv1Cfg); err != nil { + if err := engine.InitDataDB(amqpv1Cfg); err != nil { t.Fatal(err) } } diff --git a/ees/filecsv_it_test.go b/ees/filecsv_it_test.go index 687a90e60..4746b2024 100644 --- a/ees/filecsv_it_test.go +++ b/ees/filecsv_it_test.go @@ -82,7 +82,7 @@ func testCsvLoadConfig(t *testing.T) { } func testCsvResetDataDB(t *testing.T) { - if err := engine.InitDataDb(csvCfg); err != nil { + if err := engine.InitDataDB(csvCfg); err != nil { t.Fatal(err) } } diff --git a/ees/filefwv_it_test.go b/ees/filefwv_it_test.go index 23df3571a..b4dcc309b 100644 --- a/ees/filefwv_it_test.go +++ b/ees/filefwv_it_test.go @@ -73,7 +73,7 @@ func testFwvLoadConfig(t *testing.T) { } func testFwvResetDataDB(t *testing.T) { - if err := engine.InitDataDb(fwvCfg); err != nil { + if err := engine.InitDataDB(fwvCfg); err != nil { t.Fatal(err) } } diff --git a/ees/httppost_it_test.go b/ees/httppost_it_test.go index e5fc96aa7..e69e0db8f 100644 --- a/ees/httppost_it_test.go +++ b/ees/httppost_it_test.go @@ -75,7 +75,7 @@ func testHTTPPostLoadConfig(t *testing.T) { } func testHTTPPostResetDataDB(t *testing.T) { - if err := engine.InitDataDb(httpPostCfg); err != nil { + if err := engine.InitDataDB(httpPostCfg); err != nil { t.Fatal(err) } } diff --git a/ees/kafka_it_test.go b/ees/kafka_it_test.go index 4223d7e4c..c170c136b 100644 --- a/ees/kafka_it_test.go +++ b/ees/kafka_it_test.go @@ -78,7 +78,7 @@ func testKafkaLoadConfig(t *testing.T) { } func testKafkaResetDataDB(t *testing.T) { - if err := engine.InitDataDb(kafkaCfg); err != nil { + if err := engine.InitDataDB(kafkaCfg); err != nil { t.Fatal(err) } } diff --git a/ees/posterjsonmap_it_test.go b/ees/posterjsonmap_it_test.go index 3593fb638..ecd126901 100644 --- a/ees/posterjsonmap_it_test.go +++ b/ees/posterjsonmap_it_test.go @@ -75,7 +75,7 @@ func testHTTPJsonMapLoadConfig(t *testing.T) { } func testHTTPJsonMapResetDataDB(t *testing.T) { - if err := engine.InitDataDb(httpJSONMapCfg); err != nil { + if err := engine.InitDataDB(httpJSONMapCfg); err != nil { t.Fatal(err) } } diff --git a/ees/s3_it_test.go b/ees/s3_it_test.go index e593f8f02..b542efd24 100644 --- a/ees/s3_it_test.go +++ b/ees/s3_it_test.go @@ -86,7 +86,7 @@ func testS3LoadConfig(t *testing.T) { } func testS3ResetDataDB(t *testing.T) { - if err := engine.InitDataDb(s3Cfg); err != nil { + if err := engine.InitDataDB(s3Cfg); err != nil { t.Fatal(err) } } diff --git a/ees/sql_it_test.go b/ees/sql_it_test.go index f3355191f..61062a58d 100644 --- a/ees/sql_it_test.go +++ b/ees/sql_it_test.go @@ -126,7 +126,7 @@ func testSqlEeLoadConfig(t *testing.T) { } func testSqlEeResetDataDB(t *testing.T) { - if err := engine.InitDataDb(sqlEeCfg); err != nil { + if err := engine.InitDataDB(sqlEeCfg); err != nil { t.Fatal(err) } } diff --git a/ees/sqs_it_test.go b/ees/sqs_it_test.go index a4a40922c..18efbc001 100644 --- a/ees/sqs_it_test.go +++ b/ees/sqs_it_test.go @@ -86,7 +86,7 @@ func testSQSLoadConfig(t *testing.T) { } func testSQSResetDataDB(t *testing.T) { - if err := engine.InitDataDb(sqsCfg); err != nil { + if err := engine.InitDataDB(sqsCfg); err != nil { t.Fatal(err) } } diff --git a/ees/virtual_ee_it_test.go b/ees/virtual_ee_it_test.go index 88ef0d590..384227c18 100644 --- a/ees/virtual_ee_it_test.go +++ b/ees/virtual_ee_it_test.go @@ -75,7 +75,7 @@ func testVirtLoadConfig(t *testing.T) { } func testVirtResetDataDB(t *testing.T) { - if err := engine.InitDataDb(virtCfg); err != nil { + if err := engine.InitDataDB(virtCfg); err != nil { t.Fatal(err) } } diff --git a/engine/libtest.go b/engine/libtest.go index d849674a0..1160248ba 100644 --- a/engine/libtest.go +++ b/engine/libtest.go @@ -44,7 +44,7 @@ import ( "github.com/creack/pty" ) -func InitDataDb(cfg *config.CGRConfig) error { +func InitDataDB(cfg *config.CGRConfig) error { dataDB, err := NewDataDBConn(cfg.DataDbCfg().Type, cfg.DataDbCfg().Host, cfg.DataDbCfg().Port, cfg.DataDbCfg().Name, cfg.DataDbCfg().User, @@ -536,7 +536,7 @@ func LoadCSVs(t testing.TB, client *birpc.Client, tpPath string, csvFiles map[st func FlushDBs(t testing.TB, cfg *config.CGRConfig, flushDataDB, flushStorDB bool) { t.Helper() if flushDataDB { - if err := InitDataDb(cfg); err != nil { + if err := InitDataDB(cfg); err != nil { t.Fatalf("failed to flush %s dataDB: %v", cfg.DataDbCfg().Type, err) } } diff --git a/engine/z_actions2_it_test.go b/engine/z_actions2_it_test.go index 48258e8b9..f5a50289a 100644 --- a/engine/z_actions2_it_test.go +++ b/engine/z_actions2_it_test.go @@ -116,7 +116,7 @@ func testActionsInitCdrsStore(t *testing.T) { } func testActionsInitDataDb(t *testing.T) { - if err := InitDataDb(actsCfg); err != nil { + if err := InitDataDB(actsCfg); err != nil { t.Fatal(err) } } diff --git a/engine/z_actions_it_test.go b/engine/z_actions_it_test.go index 292b4061e..b87421218 100644 --- a/engine/z_actions_it_test.go +++ b/engine/z_actions_it_test.go @@ -97,7 +97,7 @@ func testActionsitInitCfg(t *testing.T) { } func testActionsitInitCdrDb(t *testing.T) { - if err := InitDataDb(actsLclCfg); err != nil { // need it for versions + if err := InitDataDB(actsLclCfg); err != nil { // need it for versions t.Fatal(err) } if err := InitStorDb(actsLclCfg); err != nil { diff --git a/ers/ers_reload_it_test.go b/ers/ers_reload_it_test.go index 20bc7fdac..b0d858bc3 100644 --- a/ers/ers_reload_it_test.go +++ b/ers/ers_reload_it_test.go @@ -90,7 +90,7 @@ func testReloadITInitCdrDb(t *testing.T) { // Remove data in both rating and accounting db func testReloadITResetDataDb(t *testing.T) { - if err := engine.InitDataDb(reloadCfg); err != nil { + if err := engine.InitDataDB(reloadCfg); err != nil { t.Fatal(err) } } diff --git a/ers/filecsv_it_test.go b/ers/filecsv_it_test.go index f9b96097e..6f6efd9de 100644 --- a/ers/filecsv_it_test.go +++ b/ers/filecsv_it_test.go @@ -121,7 +121,7 @@ func testCsvITInitCdrDb(t *testing.T) { // Remove data in both rating and accounting db func testCsvITResetDataDb(t *testing.T) { - if err := engine.InitDataDb(csvCfg); err != nil { + if err := engine.InitDataDB(csvCfg); err != nil { t.Fatal(err) } } diff --git a/ers/filefwv_it_test.go b/ers/filefwv_it_test.go index 5e945f472..7ace31bdd 100644 --- a/ers/filefwv_it_test.go +++ b/ers/filefwv_it_test.go @@ -94,7 +94,7 @@ func testFWVITInitCdrDb(t *testing.T) { // Remove data in both rating and accounting db func testFWVITResetDataDb(t *testing.T) { - if err := engine.InitDataDb(fwvCfg); err != nil { + if err := engine.InitDataDB(fwvCfg); err != nil { t.Fatal(err) } } diff --git a/ers/filejson_it_test.go b/ers/filejson_it_test.go index 09bb6f166..d6783dedc 100644 --- a/ers/filejson_it_test.go +++ b/ers/filejson_it_test.go @@ -110,7 +110,7 @@ func testJSONInitCdrDb(t *testing.T) { // Remove data in both rating and accounting db func testJSONResetDataDb(t *testing.T) { - if err := engine.InitDataDb(jsonCfg); err != nil { + if err := engine.InitDataDB(jsonCfg); err != nil { t.Fatal(err) } } diff --git a/ers/filexml_it_test.go b/ers/filexml_it_test.go index 9aa9068e4..6ba286d01 100644 --- a/ers/filexml_it_test.go +++ b/ers/filexml_it_test.go @@ -95,7 +95,7 @@ func testXMLITInitCdrDb(t *testing.T) { // Remove data in both rating and accounting db func testXMLITResetDataDb(t *testing.T) { - if err := engine.InitDataDb(xmlCfg); err != nil { + if err := engine.InitDataDB(xmlCfg); err != nil { t.Fatal(err) } } diff --git a/ers/flatstore_it_test.go b/ers/flatstore_it_test.go index fd2a70f61..cde397b83 100644 --- a/ers/flatstore_it_test.go +++ b/ers/flatstore_it_test.go @@ -136,7 +136,7 @@ func testFlatstoreITInitCdrDb(t *testing.T) { // Remove data in both rating and accounting db func testFlatstoreITResetDataDb(t *testing.T) { - if err := engine.InitDataDb(flatstoreCfg); err != nil { + if err := engine.InitDataDB(flatstoreCfg); err != nil { t.Fatal(err) } } diff --git a/ers/partial_csv_it_test.go b/ers/partial_csv_it_test.go index 876de4dc0..7adaa9ddc 100644 --- a/ers/partial_csv_it_test.go +++ b/ers/partial_csv_it_test.go @@ -105,7 +105,7 @@ func testPartITInitCdrDb(t *testing.T) { // Remove data in both rating and accounting db func testPartITResetDataDb(t *testing.T) { - if err := engine.InitDataDb(partCfg); err != nil { + if err := engine.InitDataDB(partCfg); err != nil { t.Fatal(err) } } diff --git a/general_tests/a1_it_test.go b/general_tests/a1_it_test.go index 3a49b9e50..0e78dd008 100644 --- a/general_tests/a1_it_test.go +++ b/general_tests/a1_it_test.go @@ -85,7 +85,7 @@ func testA1itLoadConfig(t *testing.T) { } func testA1itResetDataDB(t *testing.T) { - if err := engine.InitDataDb(a1Cfg); err != nil { + if err := engine.InitDataDB(a1Cfg); err != nil { t.Fatal(err) } } diff --git a/general_tests/accounts_it_test.go b/general_tests/accounts_it_test.go index e508764d2..62b976c37 100644 --- a/general_tests/accounts_it_test.go +++ b/general_tests/accounts_it_test.go @@ -92,7 +92,7 @@ func testV1AccLoadConfig(t *testing.T) { } func testV1AccInitDataDb(t *testing.T) { - if err := engine.InitDataDb(accCfg); err != nil { + if err := engine.InitDataDB(accCfg); err != nil { t.Fatal(err) } } diff --git a/general_tests/accountswiththresholds_it_test.go b/general_tests/accountswiththresholds_it_test.go index 9993cdcc6..9de662de5 100644 --- a/general_tests/accountswiththresholds_it_test.go +++ b/general_tests/accountswiththresholds_it_test.go @@ -89,7 +89,7 @@ func testAccWThdLoadConfig(t *testing.T) { } func testAccWThdInitDataDb(t *testing.T) { - if err := engine.InitDataDb(accWThdCfg); err != nil { + if err := engine.InitDataDB(accWThdCfg); err != nil { t.Fatal(err) } } diff --git a/general_tests/all_cfg_sect_rld_it_test.go b/general_tests/all_cfg_sect_rld_it_test.go index 1b2c09b05..f5de32672 100644 --- a/general_tests/all_cfg_sect_rld_it_test.go +++ b/general_tests/all_cfg_sect_rld_it_test.go @@ -128,7 +128,7 @@ func testSectLoadConfig(t *testing.T) { } func testSectResetDataDB(t *testing.T) { - if err := engine.InitDataDb(testSectCfg); err != nil { + if err := engine.InitDataDB(testSectCfg); err != nil { t.Fatal(err) } } diff --git a/general_tests/attributes_filters_index_it_test.go b/general_tests/attributes_filters_index_it_test.go index 6f45ec96a..d2bff5245 100644 --- a/general_tests/attributes_filters_index_it_test.go +++ b/general_tests/attributes_filters_index_it_test.go @@ -83,7 +83,7 @@ func testAttributeFltrSInitCfg(t *testing.T) { } func testAttributeFltrSInitDataDb(t *testing.T) { - if err := engine.InitDataDb(attrFltrCfg); err != nil { + if err := engine.InitDataDB(attrFltrCfg); err != nil { t.Fatal(err) } } diff --git a/general_tests/attributes_it_test.go b/general_tests/attributes_it_test.go index 1b1198770..1c792777f 100644 --- a/general_tests/attributes_it_test.go +++ b/general_tests/attributes_it_test.go @@ -90,7 +90,7 @@ func testAttributeSInitCfg(t *testing.T) { } func testAttributeSInitDataDb(t *testing.T) { - if err := engine.InitDataDb(attrCfg); err != nil { + if err := engine.InitDataDB(attrCfg); err != nil { t.Fatal(err) } } diff --git a/general_tests/attributeswithdataconverters_it_test.go b/general_tests/attributeswithdataconverters_it_test.go index 17fc26104..c3f72d073 100644 --- a/general_tests/attributeswithdataconverters_it_test.go +++ b/general_tests/attributeswithdataconverters_it_test.go @@ -84,7 +84,7 @@ func testAttrWDcInitCfg(t *testing.T) { } func testAttrWDcInitDataDb(t *testing.T) { - if err := engine.InitDataDb(attrWDcCfg); err != nil { + if err := engine.InitDataDB(attrWDcCfg); err != nil { t.Fatal(err) } } diff --git a/general_tests/birpc_benchmark_test.go b/general_tests/birpc_benchmark_test.go index af4c729dd..bc7da46da 100644 --- a/general_tests/birpc_benchmark_test.go +++ b/general_tests/birpc_benchmark_test.go @@ -50,7 +50,7 @@ func BenchmarkRPCCalls(b *testing.B) { b.Fatal(err) } benchDelay := 1000 - if err := engine.InitDataDb(benchCfg); err != nil { + if err := engine.InitDataDB(benchCfg); err != nil { b.Fatal(err) } if err := engine.InitStorDb(benchCfg); err != nil { diff --git a/general_tests/broadcast_client_it_test.go b/general_tests/broadcast_client_it_test.go index 9de60d90e..6da2cb6c3 100644 --- a/general_tests/broadcast_client_it_test.go +++ b/general_tests/broadcast_client_it_test.go @@ -90,7 +90,7 @@ func testbrodcastItLoadConfig(t *testing.T) { } func testbrodcastItResetDataDB(t *testing.T) { - if err := engine.InitDataDb(brodcastInternalCfg); err != nil { + if err := engine.InitDataDB(brodcastInternalCfg); err != nil { t.Fatal(err) } } diff --git a/general_tests/cacherpl_filter_update_it_test.go b/general_tests/cacherpl_filter_update_it_test.go index e689c629e..322fb9b7c 100644 --- a/general_tests/cacherpl_filter_update_it_test.go +++ b/general_tests/cacherpl_filter_update_it_test.go @@ -116,7 +116,7 @@ func testFilterUpdateInitCfg(t *testing.T) { // Remove data in both rating and accounting db func testFilterUpdateResetDB(t *testing.T) { - if err := engine.InitDataDb(fltrUpdateCfg1); err != nil { + if err := engine.InitDataDB(fltrUpdateCfg1); err != nil { t.Fatal(err) } if err := engine.InitStorDb(fltrUpdateCfg1); err != nil { diff --git a/general_tests/cacherpl_it_test.go b/general_tests/cacherpl_it_test.go index d6c81b195..1f526f0b0 100644 --- a/general_tests/cacherpl_it_test.go +++ b/general_tests/cacherpl_it_test.go @@ -153,10 +153,10 @@ func testCacheRplAAInitCfg(t *testing.T) { } func testCacheRplInitDataDb(t *testing.T) { - if err := engine.InitDataDb(dspEngine1Cfg); err != nil { + if err := engine.InitDataDB(dspEngine1Cfg); err != nil { t.Fatal(err) } - if err := engine.InitDataDb(dspEngine2Cfg); err != nil { + if err := engine.InitDataDB(dspEngine2Cfg); err != nil { t.Fatal(err) } } diff --git a/general_tests/cdrs_exp_it_test.go b/general_tests/cdrs_exp_it_test.go index cd51ad671..2b89b951f 100644 --- a/general_tests/cdrs_exp_it_test.go +++ b/general_tests/cdrs_exp_it_test.go @@ -140,7 +140,7 @@ func testCDRsExpInitConfig(t *testing.T) { } func testCDRsExpInitDB(t *testing.T) { - if err := engine.InitDataDb(cdrsExpCfg); err != nil { + if err := engine.InitDataDB(cdrsExpCfg); err != nil { t.Fatal(err) } if err := engine.InitStorDb(cdrsExpCfg); err != nil { diff --git a/general_tests/cdrs_it_test.go b/general_tests/cdrs_it_test.go index d33d61316..079524802 100644 --- a/general_tests/cdrs_it_test.go +++ b/general_tests/cdrs_it_test.go @@ -110,7 +110,7 @@ func testV2CDRsInitConfig(t *testing.T) { } func testV2CDRsInitDataDb(t *testing.T) { - if err := engine.InitDataDb(cdrsCfg); err != nil { + if err := engine.InitDataDB(cdrsCfg); err != nil { t.Fatal(err) } } diff --git a/general_tests/cdrs_onlexp_it_test.go b/general_tests/cdrs_onlexp_it_test.go index e7fd4e02d..cf954be02 100644 --- a/general_tests/cdrs_onlexp_it_test.go +++ b/general_tests/cdrs_onlexp_it_test.go @@ -101,10 +101,10 @@ func testCDRsOnExpInitConfig(t *testing.T) { // InitDb so we can rely on count func testCDRsOnExpInitCdrDb(t *testing.T) { - if err := engine.InitDataDb(cdrsMasterCfg); err != nil { + if err := engine.InitDataDB(cdrsMasterCfg); err != nil { t.Fatal(err) } - if err := engine.InitDataDb(cdrsSlaveCfg); err != nil { + if err := engine.InitDataDB(cdrsSlaveCfg); err != nil { t.Fatal(err) } if err := engine.InitStorDb(cdrsMasterCfg); err != nil { diff --git a/general_tests/cdrs_post_failover_it_test.go b/general_tests/cdrs_post_failover_it_test.go index 6d1854614..75e651fc1 100644 --- a/general_tests/cdrs_post_failover_it_test.go +++ b/general_tests/cdrs_post_failover_it_test.go @@ -90,7 +90,7 @@ func testCDRsPostFailoverInitConfig(t *testing.T) { } func testCDRsPostFailoverInitDataDb(t *testing.T) { - if err := engine.InitDataDb(cdrsPostFailCfg); err != nil { + if err := engine.InitDataDB(cdrsPostFailCfg); err != nil { t.Fatal(err) } } diff --git a/general_tests/cdrs_processevent_it_test.go b/general_tests/cdrs_processevent_it_test.go index cd1c5bf9c..09f7c1ede 100644 --- a/general_tests/cdrs_processevent_it_test.go +++ b/general_tests/cdrs_processevent_it_test.go @@ -93,7 +93,7 @@ func testV1CDRsInitConfig(t *testing.T) { } func testV1CDRsInitDataDb(t *testing.T) { - if err := engine.InitDataDb(pecdrsCfg); err != nil { + if err := engine.InitDataDB(pecdrsCfg); err != nil { t.Fatal(err) } } diff --git a/general_tests/cgrloader_it_test.go b/general_tests/cgrloader_it_test.go index ccefe0ff3..b2ffa1eef 100644 --- a/general_tests/cgrloader_it_test.go +++ b/general_tests/cgrloader_it_test.go @@ -85,7 +85,7 @@ func testCGRLoaderInitConfig(t *testing.T) { } func testCGRLoaderInitDataDb(t *testing.T) { - if err := engine.InitDataDb(cgrloaderCfg); err != nil { + if err := engine.InitDataDB(cgrloaderCfg); err != nil { t.Fatal(err) } } diff --git a/general_tests/data_it_test.go b/general_tests/data_it_test.go index eba5eef88..1abca7db8 100644 --- a/general_tests/data_it_test.go +++ b/general_tests/data_it_test.go @@ -90,7 +90,7 @@ func testV1DataLoadConfig(t *testing.T) { } func testV1DataInitDataDb(t *testing.T) { - if err := engine.InitDataDb(dataCfg); err != nil { + if err := engine.InitDataDB(dataCfg); err != nil { t.Fatal(err) } } diff --git a/general_tests/destination_combined_it_test.go b/general_tests/destination_combined_it_test.go index f01f867c6..6fa3046a4 100644 --- a/general_tests/destination_combined_it_test.go +++ b/general_tests/destination_combined_it_test.go @@ -77,7 +77,7 @@ func testDestinationLoadConfig(t *testing.T) { } func testDestinationResetDB(t *testing.T) { - if err := engine.InitDataDb(tutorialCfg); err != nil { + if err := engine.InitDataDB(tutorialCfg); err != nil { t.Fatal(err) } if err := engine.InitStorDb(tutorialCfg); err != nil { diff --git a/general_tests/doubleremove_it_test.go b/general_tests/doubleremove_it_test.go index 6fd0d5deb..794ee732f 100644 --- a/general_tests/doubleremove_it_test.go +++ b/general_tests/doubleremove_it_test.go @@ -84,7 +84,7 @@ func testdoubleRemoveLoadConfig(t *testing.T) { } func testdoubleRemoveInitDataDb(t *testing.T) { - if err := engine.InitDataDb(doubleRemove); err != nil { + if err := engine.InitDataDB(doubleRemove); err != nil { t.Fatal(err) } } diff --git a/general_tests/dynamic_thresholds_it_test.go b/general_tests/dynamic_thresholds_it_test.go index e65364141..274fb5f61 100644 --- a/general_tests/dynamic_thresholds_it_test.go +++ b/general_tests/dynamic_thresholds_it_test.go @@ -92,7 +92,7 @@ func testDynThdLoadConfig(t *testing.T) { } func testDynThdInitDataDb(t *testing.T) { - if err := engine.InitDataDb(dynThdCfg); err != nil { + if err := engine.InitDataDB(dynThdCfg); err != nil { t.Fatal(err) } } diff --git a/general_tests/export_it_test.go b/general_tests/export_it_test.go index 24252b4d9..1e6c734ac 100644 --- a/general_tests/export_it_test.go +++ b/general_tests/export_it_test.go @@ -94,7 +94,7 @@ func testExpLoadConfig(t *testing.T) { } func testExpResetDataDB(t *testing.T) { - if err := engine.InitDataDb(expCfg); err != nil { + if err := engine.InitDataDB(expCfg); err != nil { t.Fatal(err) } } diff --git a/general_tests/filtered_replication_it_test.go b/general_tests/filtered_replication_it_test.go index 734ab6b52..b13930b8c 100644 --- a/general_tests/filtered_replication_it_test.go +++ b/general_tests/filtered_replication_it_test.go @@ -107,7 +107,7 @@ func testFltrRplInitCfg(t *testing.T) { } func testFltrRplInitDBs(t *testing.T) { - if err := engine.InitDataDb(fltrRplEngine1Cfg); err != nil { + if err := engine.InitDataDB(fltrRplEngine1Cfg); err != nil { t.Fatal(err) } @@ -115,7 +115,7 @@ func testFltrRplInitDBs(t *testing.T) { t.Fatal(err) } - if err := engine.InitDataDb(fltrRplEngine2Cfg); err != nil { + if err := engine.InitDataDB(fltrRplEngine2Cfg); err != nil { t.Fatal(err) } diff --git a/general_tests/filters_it_test.go b/general_tests/filters_it_test.go index b2922a3d2..fe3016c41 100644 --- a/general_tests/filters_it_test.go +++ b/general_tests/filters_it_test.go @@ -107,7 +107,7 @@ func testV1FltrInitDataDb(t *testing.T) { return } fltrInternalRestart = true - if err := engine.InitDataDb(fltrCfg); err != nil { + if err := engine.InitDataDB(fltrCfg); err != nil { t.Fatal(err) } } diff --git a/general_tests/fltr_sep_it_test.go b/general_tests/fltr_sep_it_test.go index 49f4c1d94..ae26a5405 100644 --- a/general_tests/fltr_sep_it_test.go +++ b/general_tests/fltr_sep_it_test.go @@ -84,7 +84,7 @@ func testFltrSepLoadConfig(t *testing.T) { } func testFltrSepInitDataDb(t *testing.T) { - if err := engine.InitDataDb(fltrSepCfg); err != nil { + if err := engine.InitDataDB(fltrSepCfg); err != nil { t.Fatal(err) } } diff --git a/general_tests/fraud_detection_it_test.go b/general_tests/fraud_detection_it_test.go index 771125742..2cc589e21 100644 --- a/general_tests/fraud_detection_it_test.go +++ b/general_tests/fraud_detection_it_test.go @@ -104,7 +104,7 @@ func testFraudLoadConfig(t *testing.T) { } func testFraudInitDataDb(t *testing.T) { - if err := engine.InitDataDb(fraudCfg); err != nil { + if err := engine.InitDataDB(fraudCfg); err != nil { t.Fatal(err) } } diff --git a/general_tests/gocs_it_test.go b/general_tests/gocs_it_test.go index 5a82ba119..dbc9395a6 100644 --- a/general_tests/gocs_it_test.go +++ b/general_tests/gocs_it_test.go @@ -88,13 +88,13 @@ func testGOCSInitCfg(t *testing.T) { // Remove data in both rating and accounting db func testGOCSResetDB(t *testing.T) { - if err := engine.InitDataDb(auCfg); err != nil { + if err := engine.InitDataDB(auCfg); err != nil { t.Fatal(err) } - if err := engine.InitDataDb(usCfg); err != nil { + if err := engine.InitDataDB(usCfg); err != nil { t.Fatal(err) } - if err := engine.InitDataDb(dspCfg); err != nil { + if err := engine.InitDataDB(dspCfg); err != nil { t.Fatal(err) } if err := engine.InitStorDb(auCfg); err != nil { diff --git a/general_tests/libengine_it_test.go b/general_tests/libengine_it_test.go index d7b9f001a..21bbe0b00 100644 --- a/general_tests/libengine_it_test.go +++ b/general_tests/libengine_it_test.go @@ -77,7 +77,7 @@ func testLibengITInitCfg(t *testing.T) { } func testLibengITInitDataDb(t *testing.T) { - if err := engine.InitDataDb(libengCfg); err != nil { + if err := engine.InitDataDB(libengCfg); err != nil { t.Fatal(err) } } diff --git a/general_tests/loader_nocontext_it_test.go b/general_tests/loader_nocontext_it_test.go index fd2a16306..18bcfcd0f 100644 --- a/general_tests/loader_nocontext_it_test.go +++ b/general_tests/loader_nocontext_it_test.go @@ -94,7 +94,7 @@ func testLoaderNoContextLoadConfig(t *testing.T) { } func testLoaderNoContextInitDataDb(t *testing.T) { - if err := engine.InitDataDb(ldrCtxCfg); err != nil { + if err := engine.InitDataDB(ldrCtxCfg); err != nil { t.Fatal(err) } } diff --git a/general_tests/loaders_internal_indexes_it_test.go b/general_tests/loaders_internal_indexes_it_test.go index 157e4d5f5..14631f4e5 100644 --- a/general_tests/loaders_internal_indexes_it_test.go +++ b/general_tests/loaders_internal_indexes_it_test.go @@ -84,7 +84,7 @@ func testLoadersIDBIdxItLoadConfig(t *testing.T) { } func testLoadersIDBIdxItDB(t *testing.T) { - if err := engine.InitDataDb(loadersIDBIdxCfg); err != nil { + if err := engine.InitDataDB(loadersIDBIdxCfg); err != nil { t.Fatal(err) } if err := engine.InitStorDb(loadersIDBIdxCfg); err != nil { diff --git a/general_tests/poster_it_test.go b/general_tests/poster_it_test.go index 484c331be..9c5af1f0d 100644 --- a/general_tests/poster_it_test.go +++ b/general_tests/poster_it_test.go @@ -92,7 +92,7 @@ func testPosterITInitCfg(t *testing.T) { } func testPosterITInitCdrDb(t *testing.T) { - if err := engine.InitDataDb(pstrCfg); err != nil { // need it for versions + if err := engine.InitDataDB(pstrCfg); err != nil { // need it for versions t.Fatal(err) } if err := engine.InitStorDb(pstrCfg); err != nil { diff --git a/general_tests/redis_cluster_it_test.go b/general_tests/redis_cluster_it_test.go index daff05a19..5c9ee8dd3 100644 --- a/general_tests/redis_cluster_it_test.go +++ b/general_tests/redis_cluster_it_test.go @@ -169,7 +169,7 @@ func testClsrInitConfig(t *testing.T) { } func testClsrFlushDb(t *testing.T) { - if err := engine.InitDataDb(clsrConfig); err != nil { + if err := engine.InitDataDB(clsrConfig); err != nil { t.Fatal(err) } } diff --git a/general_tests/redis_tls_it_test.go b/general_tests/redis_tls_it_test.go index b12af7164..5c4b232a8 100644 --- a/general_tests/redis_tls_it_test.go +++ b/general_tests/redis_tls_it_test.go @@ -85,7 +85,7 @@ func testRedisTLSInitConfig(t *testing.T) { } func testRedisTLSFlushDb(t *testing.T) { - if err := engine.InitDataDb(redisTLSCfg); err != nil { + if err := engine.InitDataDB(redisTLSCfg); err != nil { t.Fatal(err) } } diff --git a/general_tests/reproc_cdrs_for_stats_it_test.go b/general_tests/reproc_cdrs_for_stats_it_test.go index 641236a07..a8803c493 100644 --- a/general_tests/reproc_cdrs_for_stats_it_test.go +++ b/general_tests/reproc_cdrs_for_stats_it_test.go @@ -110,7 +110,7 @@ func testRpcdrsLoadConfig1(t *testing.T) { } func testRpcdrsInitDataDb(t *testing.T) { - if err := engine.InitDataDb(rpcdrsCfg); err != nil { + if err := engine.InitDataDB(rpcdrsCfg); err != nil { t.Fatal(err) } } diff --git a/general_tests/rerate_ers_cdrs_it_test.go b/general_tests/rerate_ers_cdrs_it_test.go index a4f62adf7..f92320445 100644 --- a/general_tests/rerate_ers_cdrs_it_test.go +++ b/general_tests/rerate_ers_cdrs_it_test.go @@ -103,7 +103,7 @@ func testRerateCDRsERsLoadConfig(t *testing.T) { } func testRerateCDRsERsInitDataDb(t *testing.T) { - if err := engine.InitDataDb(rrErsCdrsCfg); err != nil { + if err := engine.InitDataDB(rrErsCdrsCfg); err != nil { t.Fatal(err) } } diff --git a/general_tests/rerate_exp_it_test.go b/general_tests/rerate_exp_it_test.go index 50e386288..b032a51b0 100644 --- a/general_tests/rerate_exp_it_test.go +++ b/general_tests/rerate_exp_it_test.go @@ -108,10 +108,10 @@ func testRerateExpLoadConfig(t *testing.T) { } func testRerateExpInitDataDb(t *testing.T) { - if err := engine.InitDataDb(ng1Cfg); err != nil { + if err := engine.InitDataDB(ng1Cfg); err != nil { t.Fatal(err) } - if err := engine.InitDataDb(ng2Cfg); err != nil { + if err := engine.InitDataDB(ng2Cfg); err != nil { t.Fatal(err) } } diff --git a/general_tests/resourcesv1_it_test.go b/general_tests/resourcesv1_it_test.go index 26f18700f..af1e3d768 100644 --- a/general_tests/resourcesv1_it_test.go +++ b/general_tests/resourcesv1_it_test.go @@ -80,7 +80,7 @@ func testV1RsLoadConfig(t *testing.T) { } func testV1RsInitDataDb(t *testing.T) { - if err := engine.InitDataDb(rlsV1Cfg); err != nil { + if err := engine.InitDataDB(rlsV1Cfg); err != nil { t.Fatal(err) } } diff --git a/general_tests/route_it_test.go b/general_tests/route_it_test.go index 9e7742134..39137728b 100644 --- a/general_tests/route_it_test.go +++ b/general_tests/route_it_test.go @@ -93,7 +93,7 @@ func testV1SplSLoadConfig(t *testing.T) { } func testV1SplSInitDataDb(t *testing.T) { - if err := engine.InitDataDb(splSv1Cfg); err != nil { + if err := engine.InitDataDB(splSv1Cfg); err != nil { t.Fatal(err) } } diff --git a/general_tests/routes_cases_it_test.go b/general_tests/routes_cases_it_test.go index 514e12232..76738c679 100644 --- a/general_tests/routes_cases_it_test.go +++ b/general_tests/routes_cases_it_test.go @@ -107,7 +107,7 @@ func testV1RtsCaseLoadConfig(t *testing.T) { } func testV1RtsCaseInitDataDb(t *testing.T) { - if err := engine.InitDataDb(rtsCaseSv1Cfg); err != nil { + if err := engine.InitDataDB(rtsCaseSv1Cfg); err != nil { t.Fatal(err) } } diff --git a/general_tests/rpccaching_it_test.go b/general_tests/rpccaching_it_test.go index 854d7abc3..549d6d04e 100644 --- a/general_tests/rpccaching_it_test.go +++ b/general_tests/rpccaching_it_test.go @@ -99,7 +99,7 @@ func testRPCMethodsLoadConfig(t *testing.T) { } func testRPCMethodsInitDataDb(t *testing.T) { - if err := engine.InitDataDb(rpcCfg); err != nil { + if err := engine.InitDataDB(rpcCfg); err != nil { t.Fatal(err) } } diff --git a/general_tests/rpcclient_it_test.go b/general_tests/rpcclient_it_test.go index a32f09614..5de642b6c 100644 --- a/general_tests/rpcclient_it_test.go +++ b/general_tests/rpcclient_it_test.go @@ -107,7 +107,7 @@ func testRPCITLclInitCfg(t *testing.T) { if err != nil { t.Error(err) } - if err := engine.InitDataDb(rpcITCfg1); err != nil { + if err := engine.InitDataDB(rpcITCfg1); err != nil { t.Fatal(err) } } diff --git a/general_tests/sentinel_it_test.go b/general_tests/sentinel_it_test.go index 5728af8b1..e647476b7 100644 --- a/general_tests/sentinel_it_test.go +++ b/general_tests/sentinel_it_test.go @@ -120,7 +120,7 @@ func testRedisSentinelInitConfig(t *testing.T) { } func testRedisSentinelFlushDb(t *testing.T) { - if err := engine.InitDataDb(sentinelConfig); err != nil { + if err := engine.InitDataDB(sentinelConfig); err != nil { t.Fatal(err) } } diff --git a/general_tests/session2_it_test.go b/general_tests/session2_it_test.go index b4c4f1afa..fb5b29e08 100644 --- a/general_tests/session2_it_test.go +++ b/general_tests/session2_it_test.go @@ -84,7 +84,7 @@ func testSes2ItLoadConfig(t *testing.T) { } func testSes2ItResetDataDB(t *testing.T) { - if err := engine.InitDataDb(ses2Cfg); err != nil { + if err := engine.InitDataDB(ses2Cfg); err != nil { t.Fatal(err) } } diff --git a/general_tests/session3_it_test.go b/general_tests/session3_it_test.go index e85ad6a61..428c2bbc1 100644 --- a/general_tests/session3_it_test.go +++ b/general_tests/session3_it_test.go @@ -91,7 +91,7 @@ func testSes3ItLoadConfig(t *testing.T) { } func testSes3ItResetDataDB(t *testing.T) { - if err := engine.InitDataDb(ses3Cfg); err != nil { + if err := engine.InitDataDB(ses3Cfg); err != nil { t.Fatal(err) } } diff --git a/general_tests/session4_it_test.go b/general_tests/session4_it_test.go index 06f54a982..1838c43ef 100644 --- a/general_tests/session4_it_test.go +++ b/general_tests/session4_it_test.go @@ -81,7 +81,7 @@ func testSes4ItLoadConfig(t *testing.T) { } func testSes4ItResetDataDB(t *testing.T) { - if err := engine.InitDataDb(ses4Cfg); err != nil { + if err := engine.InitDataDB(ses4Cfg); err != nil { t.Fatal(err) } } diff --git a/general_tests/session_bkup_interval_it_test.go b/general_tests/session_bkup_interval_it_test.go index 715837a63..45bf3fd15 100644 --- a/general_tests/session_bkup_interval_it_test.go +++ b/general_tests/session_bkup_interval_it_test.go @@ -111,7 +111,7 @@ func testSessionSBkupIntrvlResetDB(t *testing.T) { t.Fatal("Error creating folder: ", sBkupCfg.StorDbCfg().Opts.InternalDBDumpPath, err) } } else { - if err := engine.InitDataDb(sBkupCfg); err != nil { + if err := engine.InitDataDB(sBkupCfg); err != nil { t.Fatal(err) } if err := engine.InitStorDb(sBkupCfg); err != nil { diff --git a/general_tests/session_graceful_shutdown_it_test.go b/general_tests/session_graceful_shutdown_it_test.go index b7b0a7a63..c64085618 100644 --- a/general_tests/session_graceful_shutdown_it_test.go +++ b/general_tests/session_graceful_shutdown_it_test.go @@ -99,7 +99,7 @@ func testSessionSRplcInitCfg(t *testing.T) { // Remove data in both rating and accounting db func testSessionSRplcResetDB(t *testing.T) { - if err := engine.InitDataDb(smgRplCfg1); err != nil { + if err := engine.InitDataDB(smgRplCfg1); err != nil { t.Fatal(err) } if err := engine.InitStorDb(smgRplCfg1); err != nil { diff --git a/general_tests/session_it_test.go b/general_tests/session_it_test.go index 2a618d4f8..b389b1f6c 100644 --- a/general_tests/session_it_test.go +++ b/general_tests/session_it_test.go @@ -83,7 +83,7 @@ func testSesItLoadConfig(t *testing.T) { } func testSesItResetDataDB(t *testing.T) { - if err := engine.InitDataDb(sesCfg); err != nil { + if err := engine.InitDataDB(sesCfg); err != nil { t.Fatal(err) } } diff --git a/general_tests/session_money_rating_subject_it_test.go b/general_tests/session_money_rating_subject_it_test.go index 70dc7d7bc..73391a5f0 100644 --- a/general_tests/session_money_rating_subject_it_test.go +++ b/general_tests/session_money_rating_subject_it_test.go @@ -102,7 +102,7 @@ func testSesMRSItLoadConfig(t *testing.T) { } func testSesMRSItResetDataDB(t *testing.T) { - if err := engine.InitDataDb(sesMRSCfg); err != nil { + if err := engine.InitDataDB(sesMRSCfg); err != nil { t.Fatal(err) } } diff --git a/general_tests/session_nonereq_it_test.go b/general_tests/session_nonereq_it_test.go index 6c6ca8b4f..ccb25dab3 100644 --- a/general_tests/session_nonereq_it_test.go +++ b/general_tests/session_nonereq_it_test.go @@ -82,7 +82,7 @@ func testSesNoneReqTypeItLoadConfig(t *testing.T) { } func testSesNoneReqTypeItResetDataDB(t *testing.T) { - if err := engine.InitDataDb(sesNoneReqTypeCfg); err != nil { + if err := engine.InitDataDB(sesNoneReqTypeCfg); err != nil { t.Fatal(err) } } diff --git a/general_tests/session_refund_expired_it_test.go b/general_tests/session_refund_expired_it_test.go index 6f9588d83..61eb79c97 100644 --- a/general_tests/session_refund_expired_it_test.go +++ b/general_tests/session_refund_expired_it_test.go @@ -105,7 +105,7 @@ func testSesExpItLoadConfig(t *testing.T) { } func testSesExpItResetDataDB(t *testing.T) { - if err := engine.InitDataDb(sesExpCfg); err != nil { + if err := engine.InitDataDB(sesExpCfg); err != nil { t.Fatal(err) } } diff --git a/general_tests/session_replications_automaticdebit_it_test.go b/general_tests/session_replications_automaticdebit_it_test.go index 7549328c9..d1a86099b 100644 --- a/general_tests/session_replications_automaticdebit_it_test.go +++ b/general_tests/session_replications_automaticdebit_it_test.go @@ -123,7 +123,7 @@ func testSessionSRplInitCfg(t *testing.T) { // Remove data in both rating and accounting db func testSessionSRplResetDB(t *testing.T) { - if err := engine.InitDataDb(smgRplcMasterCfg); err != nil { + if err := engine.InitDataDB(smgRplcMasterCfg); err != nil { t.Fatal(err) } if err := engine.InitStorDb(smgRplcMasterCfg); err != nil { diff --git a/general_tests/session_rounding_it_test.go b/general_tests/session_rounding_it_test.go index 806f5f3f9..8caad0148 100644 --- a/general_tests/session_rounding_it_test.go +++ b/general_tests/session_rounding_it_test.go @@ -161,7 +161,7 @@ func testSesRndItLoadConfig(t *testing.T) { } func testSesRndItResetDataDB(t *testing.T) { - if err := engine.InitDataDb(sesRndCfg); err != nil { + if err := engine.InitDataDB(sesRndCfg); err != nil { t.Fatal(err) } } diff --git a/general_tests/session_rpl_prepaid_it_test.go b/general_tests/session_rpl_prepaid_it_test.go index 85eea4037..5cdb9ffd3 100644 --- a/general_tests/session_rpl_prepaid_it_test.go +++ b/general_tests/session_rpl_prepaid_it_test.go @@ -76,7 +76,7 @@ func testSeSRplPrepaidInitCfg(t *testing.T) { // Remove data in both rating and accounting db func testSeSRplPrepaidResetDB(t *testing.T) { - if err := engine.InitDataDb(sesRplPrePaidCfg); err != nil { + if err := engine.InitDataDB(sesRplPrePaidCfg); err != nil { t.Fatal(err) } if err := engine.InitStorDb(sesRplPrePaidCfg); err != nil { diff --git a/general_tests/sessionpause_it_test.go b/general_tests/sessionpause_it_test.go index 33c1f2e85..7c1f7fb94 100644 --- a/general_tests/sessionpause_it_test.go +++ b/general_tests/sessionpause_it_test.go @@ -86,7 +86,7 @@ func testSesPauseItLoadConfig(t *testing.T) { } func testSesPauseItResetDataDB(t *testing.T) { - if err := engine.InitDataDb(sesPauseCfg); err != nil { + if err := engine.InitDataDB(sesPauseCfg); err != nil { t.Fatal(err) } } diff --git a/general_tests/sessionrefund_it_test.go b/general_tests/sessionrefund_it_test.go index cb258fc3c..0bbc7544b 100644 --- a/general_tests/sessionrefund_it_test.go +++ b/general_tests/sessionrefund_it_test.go @@ -85,7 +85,7 @@ func testSrItLoadConfig(t *testing.T) { } func testSrItResetDataDB(t *testing.T) { - if err := engine.InitDataDb(srCfg); err != nil { + if err := engine.InitDataDB(srCfg); err != nil { t.Fatal(err) } } diff --git a/general_tests/sessionroutes_it_test.go b/general_tests/sessionroutes_it_test.go index 612d1f74d..ab9e6872c 100644 --- a/general_tests/sessionroutes_it_test.go +++ b/general_tests/sessionroutes_it_test.go @@ -84,7 +84,7 @@ func testSesRoutesItLoadConfig(t *testing.T) { } func testSesRoutesItResetDataDB(t *testing.T) { - if err := engine.InitDataDb(sesRoutesCfg); err != nil { + if err := engine.InitDataDB(sesRoutesCfg); err != nil { t.Fatal(err) } } diff --git a/general_tests/sessions_benchmark_it_test.go b/general_tests/sessions_benchmark_it_test.go index a288a177f..063c7fb57 100644 --- a/general_tests/sessions_benchmark_it_test.go +++ b/general_tests/sessions_benchmark_it_test.go @@ -83,7 +83,7 @@ func testSesPItLoadConfig(t *testing.T) { } func testSesPItResetDataDB(t *testing.T) { - if err := engine.InitDataDb(sesPCfg); err != nil { + if err := engine.InitDataDB(sesPCfg); err != nil { t.Fatal(err) } } diff --git a/general_tests/sessions_message_it_test.go b/general_tests/sessions_message_it_test.go index 86d48e806..e674cc31d 100644 --- a/general_tests/sessions_message_it_test.go +++ b/general_tests/sessions_message_it_test.go @@ -81,7 +81,7 @@ func testSesMFDItLoadConfig(t *testing.T) { } func testSesMFDItResetDataDB(t *testing.T) { - if err := engine.InitDataDb(sesMFDCfg); err != nil { + if err := engine.InitDataDB(sesMFDCfg); err != nil { t.Fatal(err) } } diff --git a/general_tests/sessions_tnt_change_cdr_it_test.go b/general_tests/sessions_tnt_change_cdr_it_test.go index 3241b7e86..810c1700f 100644 --- a/general_tests/sessions_tnt_change_cdr_it_test.go +++ b/general_tests/sessions_tnt_change_cdr_it_test.go @@ -82,7 +82,7 @@ func testSesTntChngCdrsLoadConfig(t *testing.T) { } func testSesTntChngCdrsResetDataDB(t *testing.T) { - if err := engine.InitDataDb(sesTntChngCfg); err != nil { + if err := engine.InitDataDB(sesTntChngCfg); err != nil { t.Fatal(err) } } diff --git a/general_tests/sessions_tnt_change_it_test.go b/general_tests/sessions_tnt_change_it_test.go index a744e5155..b08d25b5e 100644 --- a/general_tests/sessions_tnt_change_it_test.go +++ b/general_tests/sessions_tnt_change_it_test.go @@ -82,7 +82,7 @@ func testSesTntChngLoadConfig(t *testing.T) { } func testSesTntChngResetDataDB(t *testing.T) { - if err := engine.InitDataDb(sesTntChngCfg); err != nil { + if err := engine.InitDataDB(sesTntChngCfg); err != nil { t.Fatal(err) } } diff --git a/general_tests/shared_client_lock_it_test.go b/general_tests/shared_client_lock_it_test.go index 3feafefcd..508711974 100644 --- a/general_tests/shared_client_lock_it_test.go +++ b/general_tests/shared_client_lock_it_test.go @@ -122,7 +122,7 @@ func testSharedClientLockLoadConfig(t *testing.T) { } func testSharedClientLockInitDataDb(t *testing.T) { - if err := engine.InitDataDb(clntLockCfg); err != nil { + if err := engine.InitDataDB(clntLockCfg); err != nil { t.Fatal(err) } } diff --git a/general_tests/tls_it_test.go b/general_tests/tls_it_test.go index b1115f2cc..63994c96e 100644 --- a/general_tests/tls_it_test.go +++ b/general_tests/tls_it_test.go @@ -73,7 +73,7 @@ func testTLSLoadConfig(t *testing.T) { } func testTLSInitDataDb(t *testing.T) { - if err := engine.InitDataDb(tlsCfg); err != nil { + if err := engine.InitDataDB(tlsCfg); err != nil { t.Fatal(err) } } diff --git a/general_tests/tp_it_test.go b/general_tests/tp_it_test.go index 602bb1ff6..bf11f81ca 100644 --- a/general_tests/tp_it_test.go +++ b/general_tests/tp_it_test.go @@ -93,7 +93,7 @@ func testTpInitCfg(t *testing.T) { // Remove data in both rating and accounting db func testTpResetDataDb(t *testing.T) { - if err := engine.InitDataDb(tpCfg); err != nil { + if err := engine.InitDataDB(tpCfg); err != nil { t.Fatal(err) } } diff --git a/general_tests/trends_aut_it_test.go b/general_tests/trends_aut_it_test.go index d90a205d4..c2e31abc9 100644 --- a/general_tests/trends_aut_it_test.go +++ b/general_tests/trends_aut_it_test.go @@ -104,7 +104,7 @@ func testtrendAuQLoadConfig(t *testing.T) { } func testtrendAuQInitDataDb(t *testing.T) { - if err := engine.InitDataDb(trendAuQCfg); err != nil { + if err := engine.InitDataDB(trendAuQCfg); err != nil { t.Fatal(err) } } diff --git a/general_tests/tut_smgeneric_it_test.go b/general_tests/tut_smgeneric_it_test.go index 089888cad..93a3e7b99 100644 --- a/general_tests/tut_smgeneric_it_test.go +++ b/general_tests/tut_smgeneric_it_test.go @@ -85,7 +85,7 @@ func testTutSMGInitCfg(t *testing.T) { // Remove data in both rating and accounting db func testTutSMGResetDataDb(t *testing.T) { - if err := engine.InitDataDb(tutSMGCfg); err != nil { + if err := engine.InitDataDB(tutSMGCfg); err != nil { t.Fatal(err) } } diff --git a/general_tests/tutorial2_it_test.go b/general_tests/tutorial2_it_test.go index 5150a07bd..e34886258 100644 --- a/general_tests/tutorial2_it_test.go +++ b/general_tests/tutorial2_it_test.go @@ -86,7 +86,7 @@ func testTutLoadConfig(t *testing.T) { } func testTutResetDB(t *testing.T) { - if err := engine.InitDataDb(tutCfg); err != nil { + if err := engine.InitDataDB(tutCfg); err != nil { t.Fatal(err) } if err := engine.InitStorDb(tutCfg); err != nil { diff --git a/general_tests/tutorial_calls_test.go b/general_tests/tutorial_calls_test.go index 5df0c6faf..a995f508c 100644 --- a/general_tests/tutorial_calls_test.go +++ b/general_tests/tutorial_calls_test.go @@ -148,7 +148,7 @@ func testCallInitCfg(t *testing.T) { // Remove data in both rating and accounting db func testCallResetDataDb(t *testing.T) { - if err := engine.InitDataDb(tutorialCallsCfg); err != nil { + if err := engine.InitDataDB(tutorialCallsCfg); err != nil { t.Fatal(err) } } diff --git a/general_tests/tutorial_it_test.go b/general_tests/tutorial_it_test.go index e1c540e1f..b7de81b0d 100644 --- a/general_tests/tutorial_it_test.go +++ b/general_tests/tutorial_it_test.go @@ -98,7 +98,7 @@ func testTutorialLoadConfig(t *testing.T) { } func testTutorialResetDB(t *testing.T) { - if err := engine.InitDataDb(tutorialCfg); err != nil { + if err := engine.InitDataDB(tutorialCfg); err != nil { t.Fatal(err) } if err := engine.InitStorDb(tutorialCfg); err != nil { diff --git a/general_tests/twoengines_it_test.go b/general_tests/twoengines_it_test.go index 185887950..065a5c665 100644 --- a/general_tests/twoengines_it_test.go +++ b/general_tests/twoengines_it_test.go @@ -78,7 +78,7 @@ func testTwoEnginesInitConfig(t *testing.T) { } func testTwoEnginesInitDataDB(t *testing.T) { - if err := engine.InitDataDb(engineOneCfg); err != nil { + if err := engine.InitDataDB(engineOneCfg); err != nil { t.Fatal(err) } } diff --git a/loaders/loader_it_test.go b/loaders/loader_it_test.go index d4d8281b7..1e208206a 100644 --- a/loaders/loader_it_test.go +++ b/loaders/loader_it_test.go @@ -137,7 +137,7 @@ func testLoaderMakeFolders(t *testing.T) { // Wipe out the cdr database func testLoaderResetDataDB(t *testing.T) { - if err := engine.InitDataDb(loaderCfg); err != nil { + if err := engine.InitDataDB(loaderCfg); err != nil { t.Fatal(err) } engine.Cache.Clear(nil) diff --git a/registrarc/registarc_defaultid_it_test.go b/registrarc/registarc_defaultid_it_test.go index 2c549c8a9..59c257313 100644 --- a/registrarc/registarc_defaultid_it_test.go +++ b/registrarc/registarc_defaultid_it_test.go @@ -84,7 +84,7 @@ func testDsphNodeInitCfg(t *testing.T) { } func testDsphNodeInitDB(t *testing.T) { - if err := engine.InitDataDb(dspNodeCfg); err != nil { + if err := engine.InitDataDB(dspNodeCfg); err != nil { t.Fatal(err) } if err := engine.InitStorDb(dspNodeCfg); err != nil { diff --git a/registrarc/registrarcrpc_it_test.go b/registrarc/registrarcrpc_it_test.go index fc8e3f2c7..2b8a300c0 100644 --- a/registrarc/registrarcrpc_it_test.go +++ b/registrarc/registrarcrpc_it_test.go @@ -91,7 +91,7 @@ func testRPCInitCfg(t *testing.T) { } func testRPCInitDB(t *testing.T) { - if err := engine.InitDataDb(rpcsCfg); err != nil { + if err := engine.InitDataDB(rpcsCfg); err != nil { t.Fatal(err) } if err := engine.InitStorDb(rpcsCfg); err != nil { diff --git a/sessions/sessions_bench_test.go b/sessions/sessions_bench_test.go index 6ca6e880b..af4879f7a 100644 --- a/sessions/sessions_bench_test.go +++ b/sessions/sessions_bench_test.go @@ -63,7 +63,7 @@ func loadTP() { for i := 0; i < *cps; i++ { // init CPS limitation maxCps <- struct{}{} } - if err := engine.InitDataDb(sBenchCfg); err != nil { + if err := engine.InitDataDB(sBenchCfg); err != nil { log.Fatal(err) } attrs := &utils.AttrLoadTpFromFolder{ diff --git a/sessions/sessions_birpc_it_test.go b/sessions/sessions_birpc_it_test.go index 6915bce47..2c85ec786 100644 --- a/sessions/sessions_birpc_it_test.go +++ b/sessions/sessions_birpc_it_test.go @@ -94,7 +94,7 @@ func testSessionsBiRPCInitCfg(t *testing.T) { // Remove data in both rating and accounting db func testSessionsBiRPCResetDataDb(t *testing.T) { - if err := engine.InitDataDb(sessionsBiRPCCfg); err != nil { + if err := engine.InitDataDB(sessionsBiRPCCfg); err != nil { t.Fatal(err) } } diff --git a/sessions/sessions_bkup_rpl_it_test.go b/sessions/sessions_bkup_rpl_it_test.go index a02a34b85..4bfac724e 100644 --- a/sessions/sessions_bkup_rpl_it_test.go +++ b/sessions/sessions_bkup_rpl_it_test.go @@ -101,13 +101,13 @@ func testSessionSBkupRplcInitCfg(t *testing.T) { // Remove data in both rating and accounting db func testSessionSBkupRplcResetDB(t *testing.T) { - if err := engine.InitDataDb(sBRplcEng1Cfg); err != nil { + if err := engine.InitDataDB(sBRplcEng1Cfg); err != nil { t.Fatal(err) } if err := engine.InitStorDb(sBRplcEng1Cfg); err != nil { t.Fatal(err) } - if err := engine.InitDataDb(sBRplcEng2Cfg); err != nil { + if err := engine.InitDataDB(sBRplcEng2Cfg); err != nil { t.Fatal(err) } if err := engine.InitStorDb(sBRplcEng2Cfg); err != nil { diff --git a/sessions/sessions_data_it_test.go b/sessions/sessions_data_it_test.go index d1283684e..0112e2c68 100644 --- a/sessions/sessions_data_it_test.go +++ b/sessions/sessions_data_it_test.go @@ -87,7 +87,7 @@ func testSessionsDataInitCfg(t *testing.T) { // Remove data in both rating and accounting db func testSessionsDataResetDataDb(t *testing.T) { - if err := engine.InitDataDb(dataCfg); err != nil { + if err := engine.InitDataDB(dataCfg); err != nil { t.Fatal(err) } } diff --git a/sessions/sessions_it_test.go b/sessions/sessions_it_test.go index 8531a28c8..942f2ad94 100644 --- a/sessions/sessions_it_test.go +++ b/sessions/sessions_it_test.go @@ -84,7 +84,7 @@ func testSessionsItInitCfg(t *testing.T) { // Remove data in both rating and accounting db func testSessionsItResetDataDb(t *testing.T) { - if err := engine.InitDataDb(sItCfg); err != nil { + if err := engine.InitDataDB(sItCfg); err != nil { t.Fatal(err) } } diff --git a/sessions/sessions_rpl_it_test.go b/sessions/sessions_rpl_it_test.go index 2b952e26a..ff55fd70e 100644 --- a/sessions/sessions_rpl_it_test.go +++ b/sessions/sessions_rpl_it_test.go @@ -91,7 +91,7 @@ func testSessionSRplInitCfg(t *testing.T) { // Remove data in both rating and accounting db func testSessionSRplResetDB(t *testing.T) { - if err := engine.InitDataDb(smgRplcMasterCfg); err != nil { + if err := engine.InitDataDB(smgRplcMasterCfg); err != nil { t.Fatal(err) } if err := engine.InitStorDb(smgRplcMasterCfg); err != nil { diff --git a/sessions/sessions_total_usage_it_test.go b/sessions/sessions_total_usage_it_test.go index e0afac9df..3f7d01ef6 100644 --- a/sessions/sessions_total_usage_it_test.go +++ b/sessions/sessions_total_usage_it_test.go @@ -84,7 +84,7 @@ func testSessionsTUsageInitCfg(t *testing.T) { // Remove data in both rating and accounting db func testSessionsTUsageResetDataDb(t *testing.T) { - if err := engine.InitDataDb(tUsageCfg); err != nil { + if err := engine.InitDataDB(tUsageCfg); err != nil { t.Fatal(err) } } diff --git a/sessions/sessions_voice_it_test.go b/sessions/sessions_voice_it_test.go index e5d61024e..5e97e4451 100644 --- a/sessions/sessions_voice_it_test.go +++ b/sessions/sessions_voice_it_test.go @@ -89,7 +89,7 @@ func testSessionsVoiceInitCfg(t *testing.T) { // Remove data in both rating and accounting db func testSessionsVoiceResetDataDb(t *testing.T) { - if err := engine.InitDataDb(voiceCfg); err != nil { + if err := engine.InitDataDB(voiceCfg); err != nil { t.Fatal(err) } }