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

Updated AcionPlans

Browse Source
This commit is contained in:
Trial97
2021-06-03 17:09:01 +03:00
committed by Dan Christian Bogos
parent aaae648ef3
commit 6e9664f503
21 changed files with 382 additions and 519 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
migrator/action_plan.go
View File

@@ -53,7 +53,7 @@ func (m *Migrator) migrateCurrentActionPlans() (err error) {
for _, id := range ids {
idg := strings.TrimPrefix(id, utils.ActionPlanPrefix)
var acts *engine.ActionPlan
if acts, err = m.dmIN.DataManager().GetActionPlan(idg, true, utils.NonTransactional); err != nil {
if acts, err = m.dmIN.DataManager().GetActionPlan(idg, false, false, utils.NonTransactional); err != nil {
return
}
if acts == nil || m.dryRun {

6
migrator/action_plan_it_test.go
View File

@@ -251,7 +251,7 @@ func testActPlnITMigrateAndMove(t *testing.T) {
if err != nil {
t.Error("Error when migrating ActionPlan ", err.Error())
}
result, err := actPlnMigrator.dmOut.DataManager().GetActionPlan((*v1actPln)[0].Id, true, utils.NonTransactional)
result, err := actPlnMigrator.dmOut.DataManager().GetActionPlan((*v1actPln)[0].Id, false, false, utils.NonTransactional)
if err != nil {
t.Fatal("Error when getting ActionPlan ", err.Error())
}
@@ -278,7 +278,7 @@ func testActPlnITMigrateAndMove(t *testing.T) {
if err != nil {
t.Error("Error when migrating ActionPlan ", err.Error())
}
result, err := actPlnMigrator.dmOut.DataManager().GetActionPlan((*v1actPln)[0].Id, true, utils.NonTransactional)
result, err := actPlnMigrator.dmOut.DataManager().GetActionPlan((*v1actPln)[0].Id, false, false, utils.NonTransactional)
if err != nil {
t.Error("Error when getting ActionPlan ", err.Error())
}
@@ -290,7 +290,7 @@ func testActPlnITMigrateAndMove(t *testing.T) {
} else if !reflect.DeepEqual(actPln.ActionTimings[0].Timing, result.ActionTimings[0].Timing) {
t.Errorf("Expecting: %+v, received: %+v", actPln.ActionTimings[0].Timing, result.ActionTimings[0].Timing)
}
result, err = actPlnMigrator.dmIN.DataManager().GetActionPlan((*v1actPln)[0].Id, true, utils.NonTransactional)
result, err = actPlnMigrator.dmIN.DataManager().GetActionPlan((*v1actPln)[0].Id, false, false, utils.NonTransactional)
if err != utils.ErrNotFound {
t.Error(err)
} else if actPlnMigrator.stats[utils.ActionPlans] != 1 {