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

Added integration tests used in apier/v1/stats.go

Browse Source
This commit is contained in:
andronache
2021-03-26 15:20:45 +02:00
committed by Dan Christian Bogos
parent 9d75f25958
commit 1bde6449b6
2 changed files with 129 additions and 49 deletions
Download Patch File Download Diff File Expand all files Collapse all files

96
apier/v1/attributes_it_test.go
View File

@@ -41,55 +41,53 @@ var (
alsPrfConfigDIR string //run tests for specific configuration
sTestsAlsPrf = []func(t *testing.T){
/*
testAttributeSInitCfg,
testAttributeSInitDataDb,
testAttributeSResetStorDb,
testAttributeSStartEngine,
testAttributeSRPCConn,
testAttributeSLoadFromFolder,
testAttributeSGetAttributeForEvent,
testAttributeSGetAttributeForEventNotFound,
testAttributeSGetAttributeForEventWithMetaAnyContext,
testAttributeSProcessEvent,
testAttributeSProcessEventNotFound,
testAttributeSProcessEventMissing,
testAttributeSProcessEventWithNoneSubstitute,
testAttributeSProcessEventWithNoneSubstitute2,
testAttributeSProcessEventWithNoneSubstitute3,
testAttributeSProcessEventWithHeader,
testAttributeSGetAttPrfIDs,
testAttributeSSetAlsPrfBrokenReference,
testAttributeSGetAlsPrfBeforeSet,
testAttributeSSetAlsPrf,
testAttributeSUpdateAlsPrf,
testAttributeSRemAlsPrf,
testAttributeSSetAlsPrf2,
testAttributeSSetAlsPrf3,
testAttributeSSetAlsPrf4,
testAttributeSPing,
testAttributeSProcessEventWithSearchAndReplace,
testAttributeSProcessWithMultipleRuns,
testAttributeSProcessWithMultipleRuns2,
testAttributeSGetAttributeProfileIDsCount,
testAttributeSSetAttributeWithEmptyPath,
testAttributeSSetAlsPrfWithoutTenant,
testAttributeSRmvAlsPrfWithoutTenant,
testAttributeSKillEngine,
//start test for cache options
testAttributeSInitCfg,
testAttributeSInitDataDb,
testAttributeSResetStorDb,
testAttributeSStartEngine,
testAttributeSRPCConn,
testAttributeSCachingMetaNone,
testAttributeSCachingMetaLoad,
testAttributeSCachingMetaReload1,
testAttributeSCachingMetaReload2,
testAttributeSCachingMetaRemove,
testAttributeSCacheOpts,
testAttributeSKillEngine,
*/
testAttributeSInitCfg,
testAttributeSInitDataDb,
testAttributeSResetStorDb,
testAttributeSStartEngine,
testAttributeSRPCConn,
testAttributeSLoadFromFolder,
testAttributeSGetAttributeForEvent,
testAttributeSGetAttributeForEventNotFound,
testAttributeSGetAttributeForEventWithMetaAnyContext,
testAttributeSProcessEvent,
testAttributeSProcessEventNotFound,
testAttributeSProcessEventMissing,
testAttributeSProcessEventWithNoneSubstitute,
testAttributeSProcessEventWithNoneSubstitute2,
testAttributeSProcessEventWithNoneSubstitute3,
testAttributeSProcessEventWithHeader,
testAttributeSGetAttPrfIDs,
testAttributeSSetAlsPrfBrokenReference,
testAttributeSGetAlsPrfBeforeSet,
testAttributeSSetAlsPrf,
testAttributeSUpdateAlsPrf,
testAttributeSRemAlsPrf,
testAttributeSSetAlsPrf2,
testAttributeSSetAlsPrf3,
testAttributeSSetAlsPrf4,
testAttributeSPing,
testAttributeSProcessEventWithSearchAndReplace,
testAttributeSProcessWithMultipleRuns,
testAttributeSProcessWithMultipleRuns2,
testAttributeSGetAttributeProfileIDsCount,
testAttributeSSetAttributeWithEmptyPath,
testAttributeSSetAlsPrfWithoutTenant,
testAttributeSRmvAlsPrfWithoutTenant,
testAttributeSKillEngine,
//start test for cache options
testAttributeSInitCfg,
testAttributeSInitDataDb,
testAttributeSResetStorDb,
testAttributeSStartEngine,
testAttributeSRPCConn,
testAttributeSCachingMetaNone,
testAttributeSCachingMetaLoad,
testAttributeSCachingMetaReload1,
testAttributeSCachingMetaReload2,
testAttributeSCachingMetaRemove,
testAttributeSCacheOpts,
testAttributeSKillEngine,
//cache test
testAttributeSInitCfg,
testAttributeSInitDataDb,

82
apier/v1/stats_it_test.go
View File

@@ -99,6 +99,17 @@ var (
testV1STSRpcConn,
testV1STSCheckMetricsAfterRestart,
testV1STSStopEngine,
//cache test
testV1STSLoadConfig,
testV1STSInitDataDb,
testV1STSStartEngine,
testV1STSRpcConn,
testStatSCacheProcessEventNotFound,
testStatSCacheSet,
testStatSCacheProcessEventNotFound,
testStatSCacheReload,
testStatSCacheProcessEventFound,
testV1STSStopEngine,
}
)
@@ -1651,3 +1662,74 @@ func testV1STSCheckMetricsAfterRestart(t *testing.T) {
t.Errorf("expecting: %+v, received reply: %s", expectedMetrics, metrics)
}
}
func testStatSCacheProcessEventNotFound(t *testing.T) {
var reply []string
args := engine.StatsArgsProcessEvent{
CGREvent: &utils.CGREvent{
Tenant: "cgrates.org",
ID: "STAT_CACHE",
Event: map[string]interface{}{
utils.AccountField: "1001",
utils.AnswerTime: time.Date(2014, 7, 14, 14, 25, 0, 0, time.UTC),
utils.Usage: 135 * time.Second,
utils.Cost: 123.0,
utils.PDD: 12 * time.Second,
},
},
StatIDs: []string{"STAT_CACHE"},
}
if err := stsV1Rpc.Call(utils.StatSv1ProcessEvent, &args, &reply); err == nil || err.Error() != utils.ErrNotFound.Error() {
t.Error(err)
}
}
func testStatSCacheProcessEventFound(t *testing.T) {
var reply []string
args := engine.StatsArgsProcessEvent{
CGREvent: &utils.CGREvent{
Tenant: "cgrates.org",
ID: "STAT_CACHE",
Event: map[string]interface{}{
utils.AccountField: "1001",
utils.AnswerTime: time.Date(2014, 7, 14, 14, 25, 0, 0, time.UTC),
utils.Usage: 135 * time.Second,
utils.Cost: 123.0,
utils.PDD: 12 * time.Second,
},
},
StatIDs: []string{"STAT_CACHE"},
}
if err := stsV1Rpc.Call(utils.StatSv1ProcessEvent, &args, &reply); err != nil {
t.Error(err)
}
}
func testStatSCacheSet(t *testing.T) {
var result string
statConfig = &engine.StatQueueProfileWithAPIOpts{
StatQueueProfile: &engine.StatQueueProfile{
Tenant: "cgrates.org",
ID: "STAT_CACHE",
},
APIOpts: map[string]interface{}{
utils.CacheOpt: utils.MetaNone,
},
}
if err := stsV1Rpc.Call(utils.APIerSv1SetStatQueueProfile, statConfig, &result); err != nil {
t.Fatalf("Expected error: %+v, received: %+v", nil, err)
}
}
func testStatSCacheReload(t *testing.T) {
cache := &utils.AttrReloadCacheWithAPIOpts{
ArgsCache: map[string][]string{
utils.StatsQueueProfileIDs: {"cgrates.org:STAT_CACHE"},
},
}
var reply string
if err := stsV1Rpc.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)
}
}