uppal/cgrates
1
0
Fork 1
mirror of https://github.com/cgrates/cgrates.git synced 2026-02-21 07:08:45 +05:00
Code Issues Packages Projects Releases Wiki Activity

Added integration tests for apier/v1/actions.go

Browse Source
This commit is contained in:
andronache
2021-03-29 12:09:33 +03:00
committed by Dan Christian Bogos
parent a1001f2614
commit 912c3c3fc0
1 changed files with 68 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

68
apier/v1/actions_it_test.go
View File

@@ -54,6 +54,19 @@ var (
testActionSUpdateActionProfile,
testActionSRemoveActionProfile,
testActionSKillEngine,
//cache test
testActionSInitCfg,
testActionSInitDataDb,
testActionSResetStorDb,
testActionSStartEngine,
testActionSRPCConn,
testActionSCacheTestGetNotFound,
testActionSCacheTestSet,
testActionSCacheTestGetNotFound,
testActionSCacheReload,
testActionSCacheTestGetNotFound,
testActionSCacheTestGetFound,
testActionSKillEngine,
}
)
@@ -329,3 +342,58 @@ func testActionSKillEngine(t *testing.T) {
t.Error(err)
}
}
func testActionSCacheTestGetNotFound(t *testing.T) {
var reply *engine.ChargerProfile
if err := actSRPC.Call(utils.APIerSv1GetActionProfile,
&utils.TenantID{Tenant: "cgrates.org", ID: "ACTION_CACHE"}, &reply); err == nil ||
err.Error() != utils.ErrNotFound.Error() {
t.Fatal(err)
}
}
func testActionSCacheTestGetFound(t *testing.T) {
var reply *engine.ChargerProfile
if err := actSRPC.Call(utils.APIerSv1GetActionProfile,
&utils.TenantID{Tenant: "cgrates.org", ID: "ACTION_CACHE"}, &reply); err != nil {
t.Fatal(err)
}
}
func testActionSCacheTestSet(t *testing.T) {
actPrf = &engine.ActionProfileWithAPIOpts{
ActionProfile: &engine.ActionProfile{
Tenant: "cgrates.org",
ID: "ACTION_CACHE",
Actions: []*engine.APAction{
{
ID: "ACTION_CACHE",
Diktats: []*engine.APDiktat{{}},
},
},
},
APIOpts: map[string]interface{}{
utils.CacheOpt: utils.MetaNone,
},
}
var reply string
if err := actSRPC.Call(utils.APIerSv1SetActionProfile, actPrf, &reply); err != nil {
t.Error(err)
} else if reply != utils.OK {
t.Error("Unexpected reply returned", reply)
}
}
func testActionSCacheReload(t *testing.T) {
cache := &utils.AttrReloadCacheWithAPIOpts{
ArgsCache: map[string][]string{
utils.ActionProfileIDs: {"cgrates.org:ACTION_CACHE"},
},
}
var reply string
if err := actSRPC.Call(utils.CacheSv1ReloadCache, cache, &reply); err != nil {
t.Error("Got error on CacheSv1.ReloadCache: ", err.Error())
} else if reply != utils.OK {
t.Error("Calling CacheSv1.ReloadCache got reply: ", reply)
}
}