diff --git a/engine/loader_it_test.go b/engine/loader_it_test.go index df05b04dc..2d8cb739b 100644 --- a/engine/loader_it_test.go +++ b/engine/loader_it_test.go @@ -33,9 +33,9 @@ import ( var dataDbCsv, dataDbStor, dataDbApier DataDB // Each dataDb will have it's own sources to collect data var storDb LoadStorage var lCfg *config.CGRConfig +var loader *TpReader var tpCsvScenario = flag.String("tp_scenario", "testtp", "Use this scenario folder to import tp csv data from") -var tpTutFilesDir = "tutorial" // Create connection to dataDb // Will use 3 different datadbs in order to be able to see differences in data loaded @@ -87,7 +87,7 @@ func TestLoaderITLoadFromCSV(t *testing.T) { t.Error("Failed validating data: ", err.Error()) } }*/ - loader := NewTpReader(dataDbCsv, NewFileCSVStorage(utils.CSV_SEP, + loader = NewTpReader(dataDbCsv, NewFileCSVStorage(utils.CSV_SEP, path.Join(*dataDir, "tariffplans", *tpCsvScenario, utils.DESTINATIONS_CSV), path.Join(*dataDir, "tariffplans", *tpCsvScenario, utils.TIMINGS_CSV), path.Join(*dataDir, "tariffplans", *tpCsvScenario, utils.RATES_CSV), @@ -158,30 +158,6 @@ func TestLoaderITLoadFromCSV(t *testing.T) { } func TestLoaderITWriteToDatabase(t *testing.T) { - loader := NewTpReader(dataDbCsv, NewFileCSVStorage(utils.CSV_SEP, - path.Join(*dataDir, "tariffplans", *tpTutFilesDir, utils.DESTINATIONS_CSV), - path.Join(*dataDir, "tariffplans", *tpTutFilesDir, utils.TIMINGS_CSV), - path.Join(*dataDir, "tariffplans", *tpTutFilesDir, utils.RATES_CSV), - path.Join(*dataDir, "tariffplans", *tpTutFilesDir, utils.DESTINATION_RATES_CSV), - path.Join(*dataDir, "tariffplans", *tpTutFilesDir, utils.RATING_PLANS_CSV), - path.Join(*dataDir, "tariffplans", *tpTutFilesDir, utils.RATING_PROFILES_CSV), - path.Join(*dataDir, "tariffplans", *tpTutFilesDir, utils.SHARED_GROUPS_CSV), - path.Join(*dataDir, "tariffplans", *tpTutFilesDir, utils.LCRS_CSV), - path.Join(*dataDir, "tariffplans", *tpTutFilesDir, utils.ACTIONS_CSV), - path.Join(*dataDir, "tariffplans", *tpTutFilesDir, utils.ACTION_PLANS_CSV), - path.Join(*dataDir, "tariffplans", *tpTutFilesDir, utils.ACTION_TRIGGERS_CSV), - path.Join(*dataDir, "tariffplans", *tpTutFilesDir, utils.ACCOUNT_ACTIONS_CSV), - path.Join(*dataDir, "tariffplans", *tpTutFilesDir, utils.DERIVED_CHARGERS_CSV), - path.Join(*dataDir, "tariffplans", *tpTutFilesDir, utils.CDR_STATS_CSV), - path.Join(*dataDir, "tariffplans", *tpTutFilesDir, utils.USERS_CSV), - path.Join(*dataDir, "tariffplans", *tpTutFilesDir, utils.ALIASES_CSV), - path.Join(*dataDir, "tariffplans", *tpTutFilesDir, utils.ResourceLimitsCsv), - ), "", "") - - if err := loader.LoadAll(); err != nil { - t.Error("Failed loading: ", err.Error()) - } - for k, as := range loader.actions { rcv, err := loader.dataStorage.GetActions(k, true, utils.NonTransactional) if err != nil {