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

Updated tests in migrator

Browse Source
This commit is contained in:
adragusin
2020-06-18 18:03:54 +03:00
committed by Dan Christian Bogos
parent 224d2c9c36
commit 35e3893a8d
6 changed files with 53 additions and 23 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
migrator/rating_profile_it_test.go
View File

@@ -140,9 +140,13 @@ func testRtPrfITConnect(t *testing.T) {
if err != nil {
log.Fatal(err)
}
rtprflMigrator, err = NewMigrator(dataDBIn, dataDBOut,
nil, nil,
false, false, false, false)
if reflect.DeepEqual(rtprflPathIn, rtprflPathOut) {
rtprflMigrator, err = NewMigrator(dataDBIn, dataDBOut, nil, nil,
false, true, false, false)
} else {
rtprflMigrator, err = NewMigrator(dataDBIn, dataDBOut, nil, nil,
false, false, false, false)
}
if err != nil {
log.Fatal(err)
}

10
migrator/resource_it_test.go
View File

@@ -140,9 +140,13 @@ func testResITConnect(t *testing.T) {
if err != nil {
log.Fatal(err)
}
resMigrator, err = NewMigrator(dataDBIn, dataDBOut,
nil, nil,
false, false, false, false)
if reflect.DeepEqual(resPathIn, resPathOut) {
resMigrator, err = NewMigrator(dataDBIn, dataDBOut, nil, nil,
false, true, false, false)
} else {
resMigrator, err = NewMigrator(dataDBIn, dataDBOut, nil, nil,
false, false, false, false)
}
if err != nil {
log.Fatal(err)
}

10
migrator/routes_it_test.go
View File

@@ -139,9 +139,13 @@ func testSupITConnect(t *testing.T) {
if err != nil {
log.Fatal(err)
}
supMigrator, err = NewMigrator(dataDBIn, dataDBOut,
nil, nil,
false, false, false, false)
if reflect.DeepEqual(supPathIn, supPathOut) {
supMigrator, err = NewMigrator(dataDBIn, dataDBOut, nil, nil,
false, true, false, false)
} else {
supMigrator, err = NewMigrator(dataDBIn, dataDBOut, nil, nil,
false, false, false, false)
}
if err != nil {
log.Fatal(err)
}

15
migrator/session_costs_it_test.go
View File

@@ -49,11 +49,11 @@ var sTestssCostIT = []func(t *testing.T){
func TestSessionCostITMongo(t *testing.T) {
var err error
sCostPathIn = path.Join(*dataDir, "conf", "samples", "tutmongo")
sCostPathOut = path.Join(*dataDir, "conf", "samples", "tutmongojson")
sCostCfgIn, err = config.NewCGRConfigFromPath(sCostPathIn)
if err != nil {
t.Error(err)
}
sCostPathOut = path.Join(*dataDir, "conf", "samples", "tutmongojson")
sCostCfgOut, err = config.NewCGRConfigFromPath(sCostPathOut)
if err != nil {
t.Error(err)
@@ -71,7 +71,8 @@ func TestSessionCostITMySql(t *testing.T) {
if err != nil {
t.Error(err)
}
sCostCfgOut, err = config.NewCGRConfigFromPath(sCostPathIn)
sCostPathOut = path.Join(*dataDir, "conf", "samples", "tutmysql")
sCostCfgOut, err = config.NewCGRConfigFromPath(sCostPathOut)
if err != nil {
t.Error(err)
}
@@ -102,9 +103,13 @@ func testSessionCostITConnect(t *testing.T) {
if err != nil {
t.Error(err)
}
sCostMigrator, err = NewMigrator(nil, nil,
storDBIn, storDBOut,
false, false, false, false)
if actTrgPathIn == actTrgPathOut {
sCostMigrator, err = NewMigrator(nil, nil, storDBIn, storDBOut,
false, false, true, false)
} else {
sCostMigrator, err = NewMigrator(nil, nil, storDBIn, storDBOut,
false, false, false, false)
}
if err != nil {
t.Error(err)
}

16
migrator/sharedgroup_it_test.go
View File

@@ -53,7 +53,8 @@ func TestSharedGroupITRedis(t *testing.T) {
if err != nil {
t.Fatal(err)
}
shrGrpCfgOut, err = config.NewCGRConfigFromPath(shrGrpPathIn)
shrGrpPathOut = path.Join(*dataDir, "conf", "samples", "tutmysql")
shrGrpCfgOut, err = config.NewCGRConfigFromPath(shrGrpPathOut)
if err != nil {
t.Fatal(err)
}
@@ -71,7 +72,8 @@ func TestSharedGroupITMongo(t *testing.T) {
if err != nil {
t.Fatal(err)
}
shrGrpCfgOut, err = config.NewCGRConfigFromPath(shrGrpPathIn)
shrGrpPathOut = path.Join(*dataDir, "conf", "samples", "tutmongo")
shrGrpCfgOut, err = config.NewCGRConfigFromPath(shrGrpPathOut)
if err != nil {
t.Fatal(err)
}
@@ -156,9 +158,13 @@ func testShrGrpITConnect(t *testing.T) {
if err != nil {
log.Fatal(err)
}
shrGrpMigrator, err = NewMigrator(dataDBIn, dataDBOut,
nil, nil,
false, false, false, false)
if reflect.DeepEqual(shrGrpPathIn, shrGrpPathOut) {
shrGrpMigrator, err = NewMigrator(dataDBIn, dataDBOut, nil, nil,
false, true, false, false)
} else {
shrGrpMigrator, err = NewMigrator(dataDBIn, dataDBOut, nil, nil,
false, false, false, false)
}
if err != nil {
log.Fatal(err)
}

15
migrator/stats_it_test.go
View File

@@ -55,7 +55,8 @@ func TestStatsQueueITRedis(t *testing.T) {
if err != nil {
t.Fatal(err)
}
stsCfgOut, err = config.NewCGRConfigFromPath(stsPathIn)
stsPathOut = path.Join(*dataDir, "conf", "samples", "tutmysql")
stsCfgOut, err = config.NewCGRConfigFromPath(stsPathOut)
if err != nil {
t.Fatal(err)
}
@@ -73,7 +74,8 @@ func TestStatsQueueITMongo(t *testing.T) {
if err != nil {
t.Fatal(err)
}
stsCfgOut, err = config.NewCGRConfigFromPath(stsPathIn)
stsPathOut = path.Join(*dataDir, "conf", "samples", "tutmongo")
stsCfgOut, err = config.NewCGRConfigFromPath(stsPathOut)
if err != nil {
t.Fatal(err)
}
@@ -120,8 +122,13 @@ func testStsITConnect(t *testing.T) {
if err != nil {
log.Fatal(err)
}
stsMigrator, err = NewMigrator(dataDBIn, dataDBOut, nil, nil,
false, false, false, false)
if stsPathIn == stsPathOut {
stsMigrator, err = NewMigrator(dataDBIn, dataDBOut, nil, nil,
false, true, false, false)
} else {
stsMigrator, err = NewMigrator(dataDBIn, dataDBOut, nil, nil,
false, false, false, false)
}
if err != nil {
log.Fatal(err)
}