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 index health tests

Browse Source
This commit is contained in:
Trial97
2021-06-16 19:34:04 +03:00
committed by Dan Christian Bogos
parent 1fc27c2d5b
commit 6ec3dc01bc
3 changed files with 122 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
apier/v1/filter_indexes_health_it_test.go
View File

@@ -118,7 +118,11 @@ func testV1FIdxHAccountActionPlansHealth(t *testing.T) {
}, &reply); err != nil {
t.Error(err)
}
exp := engine.IndexHealthReply{}
exp := engine.IndexHealthReply{
MissingObjects: []string{},
MissingIndexes: map[string][]string{},
BrokenReferences: map[string][]string{},
}
if !reflect.DeepEqual(exp, reply) {
t.Errorf("Expecting: %+v, received: %+v", utils.ToJSON(exp), utils.ToJSON(reply))
}

2
engine/libindex.go
View File

@@ -934,7 +934,7 @@ func GetAccountActionPlanIndexHealth(dm *DataManager, objLimit, indexLimit int,
return
}
err = nil
brokenRef[apID] = append(brokenRef[apID], acntID)
missingIndex[apID] = append(missingIndex[apID], acntID)
continue
}
if !utils.IsSliceMember(ids, apID) { // the index doesn't exits for this actionPlan

120
engine/z_libindex_health_test.go
View File

@@ -18,7 +18,14 @@ along with this program. If not, see <http://www.gnu.org/licenses/>
package engine
/*
import (
"reflect"
"testing"
"github.com/cgrates/cgrates/config"
"github.com/cgrates/cgrates/utils"
)
func TestHealthAccountAction(t *testing.T) {
Cache.Clear(nil)
cfg := config.NewDefaultCGRConfig()
@@ -35,11 +42,116 @@ func TestHealthAccountAction(t *testing.T) {
}, true, utils.NonTransactional); err != nil {
t.Fatal(err)
}
exp := &IndexHealthReply{
MissingObjects: []string{"AP1"},
MissingIndexes: map[string][]string{"AP2": {"1002"}},
BrokenReferences: map[string][]string{"AP2": {"1001"}},
}
if rply, err := GetAccountActionPlanIndexHealth(dm, -1, -1, -1, -1, false, false); err != nil {
t.Fatal(err)
} else {
t.Error(utils.ToJSON(rply))
} else if !reflect.DeepEqual(exp, rply) {
t.Errorf("Expecting: %+v, received: %+v", utils.ToJSON(exp), utils.ToJSON(rply))
}
}
func TestHealthAccountAction2(t *testing.T) {
Cache.Clear(nil)
cfg := config.NewDefaultCGRConfig()
db := NewInternalDB(nil, nil, true)
dm := NewDataManager(db, cfg.CacheCfg(), nil)
if err := dm.SetAccountActionPlans("1001", []string{"AP1", "AP2"}, true); err != nil {
t.Fatal(err)
}
if err := dm.SetActionPlan("AP2", &ActionPlan{
Id: "AP2",
AccountIDs: utils.NewStringMap("1001"),
ActionTimings: []*ActionTiming{{}},
}, true, utils.NonTransactional); err != nil {
t.Fatal(err)
}
exp := &IndexHealthReply{
MissingObjects: []string{"AP1"},
MissingIndexes: map[string][]string{},
BrokenReferences: map[string][]string{},
}
if rply, err := GetAccountActionPlanIndexHealth(dm, -1, -1, -1, -1, false, false); err != nil {
t.Fatal(err)
} else if !reflect.DeepEqual(exp, rply) {
t.Errorf("Expecting: %+v, received: %+v", utils.ToJSON(exp), utils.ToJSON(rply))
}
}
func TestHealthAccountAction3(t *testing.T) {
Cache.Clear(nil)
cfg := config.NewDefaultCGRConfig()
db := NewInternalDB(nil, nil, true)
dm := NewDataManager(db, cfg.CacheCfg(), nil)
if err := dm.SetAccountActionPlans("1002", []string{"AP1"}, true); err != nil {
t.Fatal(err)
}
if err := dm.SetActionPlan("AP1", &ActionPlan{
Id: "AP1",
AccountIDs: utils.NewStringMap("1002"),
ActionTimings: []*ActionTiming{{}},
}, true, utils.NonTransactional); err != nil {
t.Fatal(err)
}
if err := dm.SetActionPlan("AP2", &ActionPlan{
Id: "AP2",
AccountIDs: utils.NewStringMap("1002"),
ActionTimings: []*ActionTiming{{}},
}, true, utils.NonTransactional); err != nil {
t.Fatal(err)
}
exp := &IndexHealthReply{
MissingObjects: []string{},
MissingIndexes: map[string][]string{"AP2": {"1002"}},
BrokenReferences: map[string][]string{},
}
if rply, err := GetAccountActionPlanIndexHealth(dm, -1, -1, -1, -1, false, false); err != nil {
t.Fatal(err)
} else if !reflect.DeepEqual(exp, rply) {
t.Errorf("Expecting: %+v, received: %+v", utils.ToJSON(exp), utils.ToJSON(rply))
}
}
func TestHealthAccountAction4(t *testing.T) {
Cache.Clear(nil)
cfg := config.NewDefaultCGRConfig()
db := NewInternalDB(nil, nil, true)
dm := NewDataManager(db, cfg.CacheCfg(), nil)
if err := dm.SetAccountActionPlans("1002", []string{"AP2"}, true); err != nil {
t.Fatal(err)
}
if err := dm.SetActionPlan("AP1", &ActionPlan{
Id: "AP1",
AccountIDs: utils.NewStringMap("1002"),
ActionTimings: []*ActionTiming{{}},
}, true, utils.NonTransactional); err != nil {
t.Fatal(err)
}
if err := dm.SetActionPlan("AP2", &ActionPlan{
Id: "AP2",
AccountIDs: utils.NewStringMap("1001"),
ActionTimings: []*ActionTiming{{}},
}, true, utils.NonTransactional); err != nil {
t.Fatal(err)
}
exp := &IndexHealthReply{
MissingObjects: []string{},
MissingIndexes: map[string][]string{},
BrokenReferences: map[string][]string{"AP2": {"1001"}, "AP1": {"1002"}},
}
if rply, err := GetAccountActionPlanIndexHealth(dm, -1, -1, -1, -1, false, false); err != nil {
t.Fatal(err)
} else if !reflect.DeepEqual(exp, rply) {
t.Errorf("Expecting: %+v, received: %+v", utils.ToJSON(exp), utils.ToJSON(rply))
}
}
*/