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

Fix TestLoaderIT

Browse Source
This commit is contained in:
DanB
2017-07-09 17:00:23 +02:00
parent a86ca35ff8
commit 0b73792437
1 changed files with 2 additions and 26 deletions
Download Patch File Download Diff File Expand all files Collapse all files

28
engine/loader_it_test.go
View File

@@ -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 {