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

Applied fix and repaired tests in Dispatchers

Browse Source
This commit is contained in:
andronache
2021-04-27 15:54:29 +03:00
committed by Dan Christian Bogos
parent 14e65ecec0
commit a2748e846d
17 changed files with 211 additions and 208 deletions
Download Patch File Download Diff File Expand all files Collapse all files

18
dispatchers/accounts_test.go
View File

@@ -33,7 +33,7 @@ func TestDspAccountSv1PingNil(t *testing.T) {
}
var reply *string
result := dspSrv.AccountSv1Ping(CGREvent, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -44,7 +44,7 @@ func TestDspAccountSv1PingNilArgs(t *testing.T) {
dspSrv := NewDispatcherService(nil, cgrCfg, nil, nil)
var reply *string
result := dspSrv.AccountSv1Ping(nil, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -75,7 +75,7 @@ func TestDspAAccountsForEventNil(t *testing.T) {
}
var reply *[]*utils.Account
result := dspSrv.AccountsForEvent(CGREvent, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -108,7 +108,7 @@ func TestDspMaxAbstractsNil(t *testing.T) {
}
var reply *utils.ExtEventCharges
result := dspSrv.MaxAbstracts(CGREvent, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -141,7 +141,7 @@ func TestDspDebitAbstractsNil(t *testing.T) {
}
var reply *utils.ExtEventCharges
result := dspSrv.DebitAbstracts(CGREvent, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -174,7 +174,7 @@ func TestDspMaxConcretesNil(t *testing.T) {
}
var reply *utils.ExtEventCharges
result := dspSrv.MaxConcretes(CGREvent, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -207,7 +207,7 @@ func TestDspDebitConcretesNil(t *testing.T) {
}
var reply *utils.ExtEventCharges
result := dspSrv.DebitConcretes(CGREvent, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -238,7 +238,7 @@ func TestDspAccountSv1ActionSetBalanceNil(t *testing.T) {
}
var reply *string
result := dspSrv.AccountSv1ActionSetBalance(CGREvent, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -267,7 +267,7 @@ func TestDspAAccountSv1ActionRemoveBalanceNil(t *testing.T) {
}
var reply *string
result := dspSrv.AccountSv1ActionRemoveBalance(CGREvent, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}

8
dispatchers/actions_test.go
View File

@@ -33,7 +33,7 @@ func TestDspActionSv1PingNil(t *testing.T) {
}
var reply *string
result := dspSrv.ActionSv1Ping(CGREvent, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -44,7 +44,7 @@ func TestDspActionSv1PingNilArgs(t *testing.T) {
dspSrv := NewDispatcherService(nil, cgrCfg, nil, nil)
var reply *string
result := dspSrv.ActionSv1Ping(nil, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -75,7 +75,7 @@ func TestDspActionSv1ScheduleActionsNil(t *testing.T) {
}
var reply *string
result := dspSrv.ActionSv1ScheduleActions(CGREvent, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -120,7 +120,7 @@ func TestDspActionSv1ExecuteActionsNil(t *testing.T) {
}
var reply *string
result := dspSrv.ActionSv1ExecuteActions(CGREvent, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}

10
dispatchers/attributes_test.go
View File

@@ -33,7 +33,7 @@ func TestDspAttributeSv1PingError(t *testing.T) {
cgrEvent := &utils.CGREvent{}
var reply *string
err := dspSrv.AttributeSv1Ping(cgrEvent, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if err == nil || err.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, err)
}
@@ -51,7 +51,7 @@ func TestDspAttributeSv1PingErrorTenant(t *testing.T) {
}
var reply *string
err := dspSrv.AttributeSv1Ping(cgrEvent, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if err == nil || err.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, err)
}
@@ -62,7 +62,7 @@ func TestDspAttributeSv1PingErrorNil(t *testing.T) {
dspSrv := NewDispatcherService(nil, cgrCfg, nil, nil)
var reply *string
err := dspSrv.AttributeSv1Ping(nil, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if err == nil || err.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, err)
}
@@ -153,7 +153,7 @@ func TestDspAttributeSv1GetAttributeForEventErrorAttributeS(t *testing.T) {
var reply *engine.AttributeProfile
err := dspSrv.AttributeSv1GetAttributeForEvent(processEvent, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if err == nil || err.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, err)
}
@@ -177,7 +177,7 @@ func TestDspAttributeSv1ProcessEventError(t *testing.T) {
var reply *engine.AttrSProcessEventReply
err := dspSrv.AttributeSv1ProcessEvent(processEvent, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if err == nil || err.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, err)
}

34
dispatchers/caches_test.go
View File

@@ -39,7 +39,7 @@ func TestDspCacheSv1PingError(t *testing.T) {
}
var reply *string
result := dspSrv.CacheSv1Ping(CGREvent, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -50,7 +50,7 @@ func TestDspCacheSv1PingErrorArgs(t *testing.T) {
dspSrv := NewDispatcherService(nil, cgrCfg, nil, nil)
var reply *string
result := dspSrv.CacheSv1Ping(nil, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -96,7 +96,7 @@ func TestDspCacheSv1GetItemIDsErrorArgsNil(t *testing.T) {
}
var reply *[]string
result := dspSrv.CacheSv1GetItemIDs(CGREvent, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -123,7 +123,7 @@ func TestDspCacheSv1HasItemErrorArgsNil(t *testing.T) {
}
var reply *bool
result := dspSrv.CacheSv1HasItem(CGREvent, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -150,7 +150,7 @@ func TestDspCacheSv1GetItemExpiryTimeCacheSv1GetItemExpiryTimeErrorArgsNil(t *te
}
var reply *time.Time
result := dspSrv.CacheSv1GetItemExpiryTime(CGREvent, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -177,7 +177,7 @@ func TestDspCacheSv1RemoveItemArgsNil(t *testing.T) {
}
var reply *string
result := dspSrv.CacheSv1RemoveItem(CGREvent, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -204,7 +204,7 @@ func TestDspCacheSv1RemoveItemsArgsNil(t *testing.T) {
}
var reply *string
result := dspSrv.CacheSv1RemoveItems(CGREvent, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -231,7 +231,7 @@ func TestDspCacheSv1ClearArgsNil(t *testing.T) {
}
var reply *string
result := dspSrv.CacheSv1Clear(CGREvent, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -258,7 +258,7 @@ func TestDspCacheSv1GetCacheStatsArgsNil(t *testing.T) {
}
var reply *map[string]*ltcache.CacheStats
result := dspSrv.CacheSv1GetCacheStats(CGREvent, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -285,7 +285,7 @@ func TestDspCacheSv1PrecacheStatusArgsNil(t *testing.T) {
}
var reply *map[string]string
result := dspSrv.CacheSv1PrecacheStatus(CGREvent, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -312,7 +312,7 @@ func TestDspCacheSv1HasGroupArgsNil(t *testing.T) {
}
var reply *bool
result := dspSrv.CacheSv1HasGroup(CGREvent, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -339,7 +339,7 @@ func TestDspCacheSv1GetGroupItemIDsArgsNil(t *testing.T) {
}
var reply *[]string
result := dspSrv.CacheSv1GetGroupItemIDs(CGREvent, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -366,7 +366,7 @@ func TestDspCacheSv1RemoveGroupArgsNil(t *testing.T) {
}
var reply *string
result := dspSrv.CacheSv1RemoveGroup(CGREvent, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -393,7 +393,7 @@ func TestDspCacheSv1ReloadCacheNil(t *testing.T) {
}
var reply *string
result := dspSrv.CacheSv1ReloadCache(CGREvent, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -420,7 +420,7 @@ func TestDspCacheSv1LoadCacheNil(t *testing.T) {
}
var reply *string
result := dspSrv.CacheSv1LoadCache(CGREvent, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -447,7 +447,7 @@ func TestDspCacheSv1ReplicateRemoveNil(t *testing.T) {
}
var reply *string
result := dspSrv.CacheSv1ReplicateRemove(CGREvent, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -474,7 +474,7 @@ func TestDspCacheSv1ReplicateSetNil(t *testing.T) {
}
var reply *string
result := dspSrv.CacheSv1ReplicateSet(CGREvent, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}

16
dispatchers/cdrs_test.go
View File

@@ -47,7 +47,7 @@ func TestDspCDRsV1PingNil(t *testing.T) {
}
var reply *string
result := dspSrv.CDRsV1Ping(CGREvent, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -86,7 +86,7 @@ func TestDspCDRsV1GetCDRsNil(t *testing.T) {
}
var reply *[]*engine.CDR
result := dspSrv.CDRsV1GetCDRs(CGREvent, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -113,7 +113,7 @@ func TestDspCDRsV1GetCDRsCountNil(t *testing.T) {
}
var reply *int64
result := dspSrv.CDRsV1GetCDRsCount(CGREvent, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -140,7 +140,7 @@ func TestDspCDRsV1RateCDRsNil(t *testing.T) {
}
var reply *string
result := dspSrv.CDRsV1RateCDRs(CGREvent, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -173,7 +173,7 @@ func TestDspCDRsV1ProcessExternalCDRNil(t *testing.T) {
}
var reply *string
result := dspSrv.CDRsV1ProcessExternalCDR(CGREvent, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -206,7 +206,7 @@ func TestDspCDRsV1ProcessEventNil(t *testing.T) {
}
var reply *string
result := dspSrv.CDRsV1ProcessEvent(CGREvent, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -239,7 +239,7 @@ func TestDspCDRsV1ProcessCDRNil(t *testing.T) {
}
var reply *string
result := dspSrv.CDRsV1ProcessCDR(CGREvent, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -274,7 +274,7 @@ func TestDspCDRsV2ProcessEventNil(t *testing.T) {
}
var reply *[]*utils.EventWithFlags
result := dspSrv.CDRsV2ProcessEvent(CGREvent, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}

8
dispatchers/chargers_test.go
View File

@@ -31,7 +31,7 @@ func TestDspChargerSv1PingNilStruct(t *testing.T) {
dspSrv := NewDispatcherService(nil, cgrCfg, nil, nil)
var reply *string
result := dspSrv.ChargerSv1Ping(nil, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -45,7 +45,7 @@ func TestDspChargerSv1PingNil(t *testing.T) {
}
var reply *string
result := dspSrv.ChargerSv1Ping(CGREvent, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -72,7 +72,7 @@ func TestDspChargerSv1GetChargersForEventNil(t *testing.T) {
}
var reply *engine.ChargerProfiles
result := dspSrv.ChargerSv1GetChargersForEvent(CGREvent, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -99,7 +99,7 @@ func TestDspChargerSv1ProcessEventNil(t *testing.T) {
}
var reply *[]*engine.ChrgSProcessEventReply
result := dspSrv.ChargerSv1ProcessEvent(CGREvent, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}

10
dispatchers/config_test.go
View File

@@ -32,7 +32,7 @@ func TestDspConfigSv1GetConfigNil(t *testing.T) {
}
var reply *map[string]interface{}
result := dspSrv.ConfigSv1GetConfig(CGREvent, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -59,7 +59,7 @@ func TestDspConfigSv1ReloadConfigNil(t *testing.T) {
}
var reply *string
result := dspSrv.ConfigSv1ReloadConfig(CGREvent, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -86,7 +86,7 @@ func TestDspConfigSv1SetConfigNil(t *testing.T) {
}
var reply *string
result := dspSrv.ConfigSv1SetConfig(CGREvent, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -113,7 +113,7 @@ func TestDspConfigSv1SetConfigFromJSONNil(t *testing.T) {
}
var reply *string
result := dspSrv.ConfigSv1SetConfigFromJSON(CGREvent, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -140,7 +140,7 @@ func TestDspConfigSv1GetConfigAsJSONNil(t *testing.T) {
}
var reply *string
result := dspSrv.ConfigSv1GetConfigAsJSON(CGREvent, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}

6
dispatchers/core_test.go
View File

@@ -33,7 +33,7 @@ func TestDspCoreSv1StatusNil(t *testing.T) {
}
var reply *map[string]interface{}
result := dspSrv.CoreSv1Status(CGREvent, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -60,7 +60,7 @@ func TestDspCoreSv1PingNil(t *testing.T) {
}
var reply *string
result := dspSrv.CoreSv1Ping(CGREvent, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -87,7 +87,7 @@ func TestDspCoreSv1SleepNil(t *testing.T) {
}
var reply *string
result := dspSrv.CoreSv1Sleep(CGREvent, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}

8
dispatchers/guardian_test.go
View File

@@ -33,7 +33,7 @@ func TestDspRateSv1CostForEventCase(t *testing.T) {
}
var reply *string
result := dspSrv.GuardianSv1Ping(CGREvent, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -44,7 +44,7 @@ func TestDspGuardianSv1PingNil(t *testing.T) {
dspSrv := NewDispatcherService(nil, cgrCfg, nil, nil)
var reply *string
result := dspSrv.GuardianSv1Ping(nil, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -73,7 +73,7 @@ func TestDspGuardianSv1RemoteLockCase(t *testing.T) {
}
var reply *string
result := dspSrv.GuardianSv1RemoteLock(CGREvent, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -102,7 +102,7 @@ func TestDspGuardianSv1RemoteUnlockCase(t *testing.T) {
}
var reply *[]string
result := dspSrv.GuardianSv1RemoteUnlock(CGREvent, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}

8
dispatchers/rates_test.go
View File

@@ -33,7 +33,7 @@ func TestDspRateSv1PingErrorCase2(t *testing.T) {
}
var reply *string
result := dspSrv.RateSv1Ping(CGREvent, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -59,7 +59,7 @@ func TestDspRateSv1CostForEventCaseNil(t *testing.T) {
dspSrv := NewDispatcherService(nil, cgrCfg, nil, nil)
var reply *string
result := dspSrv.RateSv1Ping(nil, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -75,7 +75,7 @@ func TestDspRateSv1CostForEventCase2(t *testing.T) {
}
var reply *utils.RateProfileCost
result := dspSrv.RateSv1CostForEvent(CGREvent, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -86,7 +86,7 @@ func TestDspRateSv1PingNil(t *testing.T) {
dspSrv := NewDispatcherService(nil, cgrCfg, nil, nil)
var reply *utils.RateProfileCost
result := dspSrv.RateSv1CostForEvent(nil, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}

196
dispatchers/replicator_test.go
View File

@@ -61,7 +61,7 @@ func TestDspReplicatorSv1PingErrorNil(t *testing.T) {
}
var reply *string
result := dspSrv.ReplicatorSv1Ping(CGREvent, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -103,7 +103,7 @@ func TestDspReplicatorSv1GetDestinationErrorNil(t *testing.T) {
}
var reply *engine.Destination
result := dspSrv.ReplicatorSv1GetDestination(CGREvent, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -144,7 +144,7 @@ func TestDspReplicatorSv1GetReverseDestinationErrorNil(t *testing.T) {
}
var reply *[]string
result := dspSrv.ReplicatorSv1GetReverseDestination(CGREvent, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -177,7 +177,7 @@ func TestDspReplicatorSv1GetStatQueueErrorNil(t *testing.T) {
}
var reply *engine.StatQueue
result := dspSrv.ReplicatorSv1GetStatQueue(CGREvent, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -210,7 +210,7 @@ func TestDspReplicatorSv1GetFilterErrorNil(t *testing.T) {
}
var reply *engine.Filter
result := dspSrv.ReplicatorSv1GetFilter(CGREvent, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -243,7 +243,7 @@ func TestDspReplicatorSv1GetThresholdErrorNil(t *testing.T) {
}
var reply *engine.Threshold
result := dspSrv.ReplicatorSv1GetThreshold(CGREvent, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -276,7 +276,7 @@ func TestDspReplicatorSv1GetThresholdProfileErrorNil(t *testing.T) {
}
var reply *engine.ThresholdProfile
result := dspSrv.ReplicatorSv1GetThresholdProfile(CGREvent, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -309,7 +309,7 @@ func TestDspReplicatorSv1GetStatQueueProfileErrorNil(t *testing.T) {
}
var reply *engine.StatQueueProfile
result := dspSrv.ReplicatorSv1GetStatQueueProfile(CGREvent, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -350,7 +350,7 @@ func TestDspReplicatorSv1GetTimingErrorNil(t *testing.T) {
}
var reply *utils.TPTiming
result := dspSrv.ReplicatorSv1GetTiming(CGREvent, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -383,7 +383,7 @@ func TestDspReplicatorSv1GetResourceErrorNil(t *testing.T) {
}
var reply *engine.Resource
result := dspSrv.ReplicatorSv1GetResource(CGREvent, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -416,7 +416,7 @@ func TestDspReplicatorSv1GetResourceProfileErrorNil(t *testing.T) {
}
var reply *engine.ResourceProfile
result := dspSrv.ReplicatorSv1GetResourceProfile(CGREvent, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -449,7 +449,7 @@ func TestDspReplicatorSv1GetRouteProfileErrorNil(t *testing.T) {
}
var reply *engine.RouteProfile
result := dspSrv.ReplicatorSv1GetRouteProfile(CGREvent, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -482,7 +482,7 @@ func TestDspReplicatorSv1GetAttributeProfileErrorNil(t *testing.T) {
}
var reply *engine.AttributeProfile
result := dspSrv.ReplicatorSv1GetAttributeProfile(CGREvent, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -515,7 +515,7 @@ func TestDspReplicatorSv1GetChargerProfileErrorNil(t *testing.T) {
}
var reply *engine.ChargerProfile
result := dspSrv.ReplicatorSv1GetChargerProfile(CGREvent, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -548,7 +548,7 @@ func TestDspReplicatorSv1GetDispatcherProfileErrorNil(t *testing.T) {
}
var reply *engine.DispatcherProfile
result := dspSrv.ReplicatorSv1GetDispatcherProfile(CGREvent, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -581,7 +581,7 @@ func TestDspReplicatorSv1GetDispatcherHostErrorNil(t *testing.T) {
}
var reply *engine.DispatcherHost
result := dspSrv.ReplicatorSv1GetDispatcherHost(CGREvent, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -622,7 +622,7 @@ func TestDspReplicatorSv1GetItemLoadIDsErrorNil(t *testing.T) {
}
var reply *map[string]int64
result := dspSrv.ReplicatorSv1GetItemLoadIDs(CGREvent, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -655,7 +655,7 @@ func TestDspReplicatorSv1SetThresholdProfileErrorNil(t *testing.T) {
}
var reply *string
result := dspSrv.ReplicatorSv1SetThresholdProfile(CGREvent, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -688,7 +688,7 @@ func TestDspReplicatorSv1RemoveFilterErrorNil(t *testing.T) {
}
var reply *string
result := dspSrv.ReplicatorSv1RemoveFilter(CGREvent, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -699,7 +699,7 @@ func TestDspReplicatorSv1RemoveFilterNilEvent(t *testing.T) {
dspSrv := NewDispatcherService(nil, cgrCfg, nil, nil)
var reply *string
result := dspSrv.ReplicatorSv1RemoveFilter(nil, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -732,7 +732,7 @@ func TestDspReplicatorSv1RemoveThresholdProfileErrorNil(t *testing.T) {
}
var reply *string
result := dspSrv.ReplicatorSv1RemoveThresholdProfile(CGREvent, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -743,7 +743,7 @@ func TestDspReplicatorSv1RemoveThresholdProfileNilEvent(t *testing.T) {
dspSrv := NewDispatcherService(nil, cgrCfg, nil, nil)
var reply *string
result := dspSrv.ReplicatorSv1RemoveThresholdProfile(nil, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -776,7 +776,7 @@ func TestDspReplicatorSv1RemoveStatQueueProfileErrorNil(t *testing.T) {
}
var reply *string
result := dspSrv.ReplicatorSv1RemoveStatQueueProfile(CGREvent, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -787,7 +787,7 @@ func TestDspReplicatorSv1RemoveStatQueueProfileNilEvent(t *testing.T) {
dspSrv := NewDispatcherService(nil, cgrCfg, nil, nil)
var reply *string
result := dspSrv.ReplicatorSv1RemoveStatQueueProfile(nil, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -820,7 +820,7 @@ func TestDspReplicatorSv1RemoveResourceErrorNil(t *testing.T) {
}
var reply *string
result := dspSrv.ReplicatorSv1RemoveResource(CGREvent, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -831,7 +831,7 @@ func TestDspReplicatorSv1RemoveResourceNilEvent(t *testing.T) {
dspSrv := NewDispatcherService(nil, cgrCfg, nil, nil)
var reply *string
result := dspSrv.ReplicatorSv1RemoveResource(nil, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -864,7 +864,7 @@ func TestDspReplicatorSv1RemoveResourceProfileErrorNil(t *testing.T) {
}
var reply *string
result := dspSrv.ReplicatorSv1RemoveResourceProfile(CGREvent, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -875,7 +875,7 @@ func TestDspReplicatorSv1RemoveResourceProfileNilEvent(t *testing.T) {
dspSrv := NewDispatcherService(nil, cgrCfg, nil, nil)
var reply *string
result := dspSrv.ReplicatorSv1RemoveResourceProfile(nil, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -904,7 +904,7 @@ func TestDspReplicatorSv1RemoveTimingErrorNil(t *testing.T) {
}
var reply *string
result := dspSrv.ReplicatorSv1RemoveTiming(CGREvent, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -915,7 +915,7 @@ func TestDspReplicatorSv1RemoveTimingNilEvent(t *testing.T) {
dspSrv := NewDispatcherService(nil, cgrCfg, nil, nil)
var reply *string
result := dspSrv.ReplicatorSv1RemoveTiming(nil, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -944,7 +944,7 @@ func TestDspReplicatorSv1RemoveActionsErrorNil(t *testing.T) {
}
var reply *string
result := dspSrv.ReplicatorSv1RemoveActions(CGREvent, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -955,7 +955,7 @@ func TestDspReplicatorSv1RemoveActionsEvent(t *testing.T) {
dspSrv := NewDispatcherService(nil, cgrCfg, nil, nil)
var reply *string
result := dspSrv.ReplicatorSv1RemoveActions(nil, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -988,7 +988,7 @@ func TestDspReplicatorSv1RemoveRouteProfileErrorNil(t *testing.T) {
}
var reply *string
result := dspSrv.ReplicatorSv1RemoveRouteProfile(CGREvent, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -999,7 +999,7 @@ func TestDspReplicatorSv1RemoveRouteProfileNilEvent(t *testing.T) {
dspSrv := NewDispatcherService(nil, cgrCfg, nil, nil)
var reply *string
result := dspSrv.ReplicatorSv1RemoveRouteProfile(nil, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -1032,7 +1032,7 @@ func TestDspReplicatorSv1RemoveAttributeProfileErrorNil(t *testing.T) {
}
var reply *string
result := dspSrv.ReplicatorSv1RemoveAttributeProfile(CGREvent, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -1043,7 +1043,7 @@ func TestDspReplicatorSv1RemoveAttributeProfileNilEvent(t *testing.T) {
dspSrv := NewDispatcherService(nil, cgrCfg, nil, nil)
var reply *string
result := dspSrv.ReplicatorSv1RemoveAttributeProfile(nil, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -1076,7 +1076,7 @@ func TestDspReplicatorSv1RemoveChargerProfileErrorNil(t *testing.T) {
}
var reply *string
result := dspSrv.ReplicatorSv1RemoveChargerProfile(CGREvent, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -1087,7 +1087,7 @@ func TestDspReplicatorSv1RemoveChargerProfileNilEvent(t *testing.T) {
dspSrv := NewDispatcherService(nil, cgrCfg, nil, nil)
var reply *string
result := dspSrv.ReplicatorSv1RemoveChargerProfile(nil, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -1120,7 +1120,7 @@ func TestDspReplicatorSv1RemoveDispatcherHostErrorNil(t *testing.T) {
}
var reply *string
result := dspSrv.ReplicatorSv1RemoveDispatcherHost(CGREvent, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -1131,7 +1131,7 @@ func TestDspReplicatorSv1RemoveDispatcherHostNilEvent(t *testing.T) {
dspSrv := NewDispatcherService(nil, cgrCfg, nil, nil)
var reply *string
result := dspSrv.ReplicatorSv1RemoveDispatcherHost(nil, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -1164,7 +1164,7 @@ func TestDspReplicatorSv1RemoveDispatcherProfileErrorNil(t *testing.T) {
}
var reply *string
result := dspSrv.ReplicatorSv1RemoveDispatcherProfile(CGREvent, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -1175,7 +1175,7 @@ func TestDspReplicatorSv1RemoveDispatcherProfileNilEvent(t *testing.T) {
dspSrv := NewDispatcherService(nil, cgrCfg, nil, nil)
var reply *string
result := dspSrv.ReplicatorSv1RemoveDispatcherProfile(nil, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -1204,7 +1204,7 @@ func TestDspReplicatorSv1GetIndexesErrorNil(t *testing.T) {
}
var reply *map[string]utils.StringSet
result := dspSrv.ReplicatorSv1GetIndexes(CGREvent, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -1215,7 +1215,7 @@ func TestDspReplicatorSv1GetIndexesNilEvent(t *testing.T) {
dspSrv := NewDispatcherService(nil, cgrCfg, nil, nil)
var reply *map[string]utils.StringSet
result := dspSrv.ReplicatorSv1GetIndexes(nil, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -1244,7 +1244,7 @@ func TestDspReplicatorSv1SetIndexesErrorNil(t *testing.T) {
}
var reply *string
result := dspSrv.ReplicatorSv1SetIndexes(CGREvent, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -1255,7 +1255,7 @@ func TestDspReplicatorSv1SetIndexesNilEvent(t *testing.T) {
dspSrv := NewDispatcherService(nil, cgrCfg, nil, nil)
var reply *string
result := dspSrv.ReplicatorSv1SetIndexes(nil, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -1281,7 +1281,7 @@ func TestDspReplicatorSv1RemoveDestinationNilEvent(t *testing.T) {
dspSrv := NewDispatcherService(nil, cgrCfg, nil, nil)
var reply *string
result := dspSrv.ReplicatorSv1RemoveDestination(nil, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -1310,7 +1310,7 @@ func TestReplicatorSv1RemoveDestinationErrorNil(t *testing.T) {
}
var reply *string
result := dspSrv.ReplicatorSv1RemoveDestination(CGREvent, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -1339,7 +1339,7 @@ func TestDspReplicatorSv1SetLoadIDsErrorNil(t *testing.T) {
}
var reply *string
result := dspSrv.ReplicatorSv1SetLoadIDs(CGREvent, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -1350,7 +1350,7 @@ func TestDspReplicatorSv1SetLoadIDsNilEvent(t *testing.T) {
dspSrv := NewDispatcherService(nil, cgrCfg, nil, nil)
var reply *string
result := dspSrv.ReplicatorSv1SetLoadIDs(nil, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -1383,7 +1383,7 @@ func TestDspReplicatorSv1RemoveAccountErrorNil(t *testing.T) {
}
var reply *string
result := dspSrv.ReplicatorSv1RemoveAccount(CGREvent, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -1394,7 +1394,7 @@ func TestDspReplicatorSv1RemoveAccountNilEvent(t *testing.T) {
dspSrv := NewDispatcherService(nil, cgrCfg, nil, nil)
var reply *string
result := dspSrv.ReplicatorSv1RemoveAccount(nil, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -1427,7 +1427,7 @@ func TestDspReplicatorSv1RemoveStatQueueErrorNil(t *testing.T) {
}
var reply *string
result := dspSrv.ReplicatorSv1RemoveStatQueue(CGREvent, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -1438,7 +1438,7 @@ func TestDspReplicatorSv1RemoveStatQueueNilEvent(t *testing.T) {
dspSrv := NewDispatcherService(nil, cgrCfg, nil, nil)
var reply *string
result := dspSrv.ReplicatorSv1RemoveStatQueue(nil, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -1452,7 +1452,7 @@ func TestDspReplicatorSv1RemoveIndexesErrorNil(t *testing.T) {
}
var reply *string
result := dspSrv.ReplicatorSv1RemoveIndexes(CGREvent, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -1463,7 +1463,7 @@ func TestDspReplicatorSv1RemoveIndexesNilEvent(t *testing.T) {
dspSrv := NewDispatcherService(nil, cgrCfg, nil, nil)
var reply *string
result := dspSrv.ReplicatorSv1RemoveIndexes(nil, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -1474,7 +1474,7 @@ func TestDspReplicatorSv1SetThresholdProfileNilEvent(t *testing.T) {
dspSrv := NewDispatcherService(nil, cgrCfg, nil, nil)
var reply *string
result := dspSrv.ReplicatorSv1SetThresholdProfile(nil, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -1507,7 +1507,7 @@ func TestDspReplicatorSv1SetThresholdErrorNil(t *testing.T) {
}
var reply *string
result := dspSrv.ReplicatorSv1SetThreshold(CGREvent, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -1518,7 +1518,7 @@ func TestDspReplicatorSv1SetThresholdNilEvent(t *testing.T) {
dspSrv := NewDispatcherService(nil, cgrCfg, nil, nil)
var reply *string
result := dspSrv.ReplicatorSv1SetThreshold(nil, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -1547,7 +1547,7 @@ func TestDspReplicatorSv1SetDestinationErrorNil(t *testing.T) {
}
var reply *string
result := dspSrv.ReplicatorSv1SetDestination(CGREvent, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -1558,7 +1558,7 @@ func TestDspReplicatorSv1SetDestinationNilEvent(t *testing.T) {
dspSrv := NewDispatcherService(nil, cgrCfg, nil, nil)
var reply *string
result := dspSrv.ReplicatorSv1SetDestination(nil, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -1589,7 +1589,7 @@ func TestDspReplicatorSv1SetAccountErrorNil(t *testing.T) {
}
var reply *string
result := dspSrv.ReplicatorSv1SetAccount(CGREvent, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -1600,7 +1600,7 @@ func TestDspReplicatorSv1SetAccountNilEvent(t *testing.T) {
dspSrv := NewDispatcherService(nil, cgrCfg, nil, nil)
var reply *string
result := dspSrv.ReplicatorSv1SetAccount(nil, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -1633,7 +1633,7 @@ func TestDspReplicatorSv1SetReverseDestinationErrorNil(t *testing.T) {
}
var reply *string
result := dspSrv.ReplicatorSv1SetReverseDestination(CGREvent, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -1644,7 +1644,7 @@ func TestDspReplicatorSv1SetReverseDestinationNilEvent(t *testing.T) {
dspSrv := NewDispatcherService(nil, cgrCfg, nil, nil)
var reply *string
result := dspSrv.ReplicatorSv1SetReverseDestination(nil, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -1677,7 +1677,7 @@ func TestDspReplicatorSv1SetStatQueueErrorNil(t *testing.T) {
}
var reply *string
result := dspSrv.ReplicatorSv1SetStatQueue(CGREvent, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -1688,7 +1688,7 @@ func TestDspReplicatorSv1SetStatQueueNilEvent(t *testing.T) {
dspSrv := NewDispatcherService(nil, cgrCfg, nil, nil)
var reply *string
result := dspSrv.ReplicatorSv1SetStatQueue(nil, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -1721,7 +1721,7 @@ func TestDspReplicatorSv1SetFilterErrorNil(t *testing.T) {
}
var reply *string
result := dspSrv.ReplicatorSv1SetFilter(CGREvent, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -1732,7 +1732,7 @@ func TestDspReplicatorSv1SetFilterNilEvent(t *testing.T) {
dspSrv := NewDispatcherService(nil, cgrCfg, nil, nil)
var reply *string
result := dspSrv.ReplicatorSv1SetFilter(nil, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -1765,7 +1765,7 @@ func TestDspReplicatorSv1SetStatQueueProfileErrorNil(t *testing.T) {
}
var reply *string
result := dspSrv.ReplicatorSv1SetStatQueueProfile(CGREvent, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -1776,7 +1776,7 @@ func TestDspReplicatorSv1SetStatQueueProfileNilEvent(t *testing.T) {
dspSrv := NewDispatcherService(nil, cgrCfg, nil, nil)
var reply *string
result := dspSrv.ReplicatorSv1SetStatQueueProfile(nil, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -1805,7 +1805,7 @@ func TestDspReplicatorSv1SetTimingErrorNil(t *testing.T) {
}
var reply *string
result := dspSrv.ReplicatorSv1SetTiming(CGREvent, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -1816,7 +1816,7 @@ func TestDspReplicatorSv1SetTimingNilEvent(t *testing.T) {
dspSrv := NewDispatcherService(nil, cgrCfg, nil, nil)
var reply *string
result := dspSrv.ReplicatorSv1SetTiming(nil, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -1849,7 +1849,7 @@ func TestDspReplicatorSv1SetResourceErrorNil(t *testing.T) {
}
var reply *string
result := dspSrv.ReplicatorSv1SetResource(CGREvent, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -1860,7 +1860,7 @@ func TestDspReplicatorSv1SetResourceNilEvent(t *testing.T) {
dspSrv := NewDispatcherService(nil, cgrCfg, nil, nil)
var reply *string
result := dspSrv.ReplicatorSv1SetResource(nil, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -1893,7 +1893,7 @@ func TestReplicatorSv1SetResourceProfileErrorNil(t *testing.T) {
}
var reply *string
result := dspSrv.ReplicatorSv1SetResourceProfile(CGREvent, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -1904,7 +1904,7 @@ func TestDspReplicatorSv1SetResourceProfileNilEvent(t *testing.T) {
dspSrv := NewDispatcherService(nil, cgrCfg, nil, nil)
var reply *string
result := dspSrv.ReplicatorSv1SetResourceProfile(nil, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -1937,7 +1937,7 @@ func TestDspReplicatorSv1SetRouteProfileErrorNil(t *testing.T) {
}
var reply *string
result := dspSrv.ReplicatorSv1SetRouteProfile(CGREvent, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -1948,7 +1948,7 @@ func TestDspReplicatorSv1SetRouteProfileNilEvent(t *testing.T) {
dspSrv := NewDispatcherService(nil, cgrCfg, nil, nil)
var reply *string
result := dspSrv.ReplicatorSv1SetRouteProfile(nil, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -1981,7 +1981,7 @@ func TestDspReplicatorSv1SetAttributeProfileErrorNil(t *testing.T) {
}
var reply *string
result := dspSrv.ReplicatorSv1SetAttributeProfile(CGREvent, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -1992,7 +1992,7 @@ func TestDspReplicatorSv1SetAttributeProfileNilEvent(t *testing.T) {
dspSrv := NewDispatcherService(nil, cgrCfg, nil, nil)
var reply *string
result := dspSrv.ReplicatorSv1SetAttributeProfile(nil, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -2025,7 +2025,7 @@ func TestDspReplicatorSv1SetChargerProfileErrorNil(t *testing.T) {
}
var reply *string
result := dspSrv.ReplicatorSv1SetChargerProfile(CGREvent, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -2036,7 +2036,7 @@ func TestDspReplicatorSv1SetChargerProfileNilEvent(t *testing.T) {
dspSrv := NewDispatcherService(nil, cgrCfg, nil, nil)
var reply *string
result := dspSrv.ReplicatorSv1SetChargerProfile(nil, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -2069,7 +2069,7 @@ func TestDspReplicatorSv1SetDispatcherProfileErrorNil(t *testing.T) {
}
var reply *string
result := dspSrv.ReplicatorSv1SetDispatcherProfile(CGREvent, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -2080,7 +2080,7 @@ func TestDspReplicatorSv1SetDispatcherProfileNilEvent(t *testing.T) {
dspSrv := NewDispatcherService(nil, cgrCfg, nil, nil)
var reply *string
result := dspSrv.ReplicatorSv1SetDispatcherProfile(nil, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -2113,7 +2113,7 @@ func TestReplicatorSv1SetDispatcherHostErrorNil(t *testing.T) {
}
var reply *string
result := dspSrv.ReplicatorSv1SetDispatcherHost(CGREvent, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -2124,7 +2124,7 @@ func TestDspReplicatorSv1SetDispatcherHostNilEvent(t *testing.T) {
dspSrv := NewDispatcherService(nil, cgrCfg, nil, nil)
var reply *string
result := dspSrv.ReplicatorSv1SetDispatcherHost(nil, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -2157,7 +2157,7 @@ func TestReplicatorSv1RemoveThresholdErrorNil(t *testing.T) {
}
var reply *string
result := dspSrv.ReplicatorSv1RemoveThreshold(CGREvent, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -2168,7 +2168,7 @@ func TestDspReplicatorSv1RemoveThresholdNilEvent(t *testing.T) {
dspSrv := NewDispatcherService(nil, cgrCfg, nil, nil)
var reply *string
result := dspSrv.ReplicatorSv1RemoveThreshold(nil, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -2184,7 +2184,7 @@ func TestDspReplicatorSv1GetRateProfileNil(t *testing.T) {
}
var reply *utils.RateProfile
result := dspSrv.ReplicatorSv1GetRateProfile(CGREvent, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -2200,7 +2200,7 @@ func TestDspReplicatorSv1GetRateProfileErrorTenant(t *testing.T) {
}
var reply *utils.RateProfile
result := dspSrv.ReplicatorSv1GetRateProfile(CGREvent, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -2229,7 +2229,7 @@ func TestDspReplicatorSv1GetActionProfileNil(t *testing.T) {
}
var reply *engine.ActionProfile
result := dspSrv.ReplicatorSv1GetActionProfile(CGREvent, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -2245,7 +2245,7 @@ func TestDspReplicatorSv1GetActionProfileErrorTenant(t *testing.T) {
}
var reply *engine.ActionProfile
result := dspSrv.ReplicatorSv1GetActionProfile(CGREvent, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -2278,7 +2278,7 @@ func TestDspReplicatorSv1SetActionProfileNil(t *testing.T) {
}
var reply *string
result := dspSrv.ReplicatorSv1SetActionProfile(CGREvent, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -2323,7 +2323,7 @@ func TestDspReplicatorSv1SetRateProfileNil(t *testing.T) {
}
var reply *string
result := dspSrv.ReplicatorSv1SetRateProfile(CGREvent, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -2368,7 +2368,7 @@ func TestDspReplicatorSv1RemoveRateProfileNil(t *testing.T) {
}
var reply *string
result := dspSrv.ReplicatorSv1RemoveRateProfile(CGREvent, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -2413,7 +2413,7 @@ func TestDspReplicatorSv1RemoveActionProfileNil(t *testing.T) {
}
var reply *string
result := dspSrv.ReplicatorSv1RemoveActionProfile(CGREvent, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -2475,7 +2475,7 @@ func TestDspReplicatorSv1GetAccountErrorCase2(t *testing.T) {
}
var reply *utils.Account
result := dspSrv.ReplicatorSv1GetAccount(CGREvent, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}

14
dispatchers/resources_test.go
View File

@@ -61,7 +61,7 @@ func TestDspResourceSv1PingErrorNil(t *testing.T) {
}
var reply *string
result := dspSrv.ResourceSv1Ping(CGREvent, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -94,7 +94,7 @@ func TestDspResourceSv1GetResourcesForEventErrorNil(t *testing.T) {
}
var reply *engine.Resources
result := dspSrv.ResourceSv1GetResourcesForEvent(CGREvent, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -127,7 +127,7 @@ func TestDspResourceSv1AuthorizeResourcesErrorNil(t *testing.T) {
}
var reply *string
result := dspSrv.ResourceSv1AuthorizeResources(CGREvent, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -160,7 +160,7 @@ func TestDspResourceSv1ReleaseResourcesErrorNil(t *testing.T) {
}
var reply *string
result := dspSrv.ResourceSv1ReleaseResources(CGREvent, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -193,7 +193,7 @@ func TestDspResourceSv1GetResourceErrorNil(t *testing.T) {
}
var reply *engine.Resource
result := dspSrv.ResourceSv1GetResource(CGREvent, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -226,7 +226,7 @@ func TestDspResourceSv1AllocateResourcesErrorNil(t *testing.T) {
}
var reply *string
result := dspSrv.ResourceSv1AllocateResources(CGREvent, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -259,7 +259,7 @@ func TestDspResourceSv1GetResourceWithConfigErrorNil(t *testing.T) {
}
var reply *engine.ResourceWithConfig
result := dspSrv.ResourceSv1GetResourceWithConfig(CGREvent, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}

8
dispatchers/routes_test.go
View File

@@ -61,7 +61,7 @@ func TestDspRouteSv1PingErrorNil(t *testing.T) {
}
var reply *string
result := dspSrv.RouteSv1Ping(CGREvent, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -94,7 +94,7 @@ func TestDspRouteSv1GetRoutesErrorNil(t *testing.T) {
}
var reply *engine.SortedRoutesList
result := dspSrv.RouteSv1GetRoutes(CGREvent, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -127,7 +127,7 @@ func TestDspRouteSv1GetRoutesListErrorNil(t *testing.T) {
}
var reply *[]string
result := dspSrv.RouteSv1GetRoutesList(CGREvent, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -156,7 +156,7 @@ func TestDspRouteSv1GetRouteProfilesForEventErrorNil(t *testing.T) {
}
var reply *[]*engine.RouteProfile
result := dspSrv.RouteSv1GetRouteProfilesForEvent(CGREvent, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}

48
dispatchers/sessions_test.go
View File

@@ -34,7 +34,7 @@ func TestDspSessionSv1PingNil(t *testing.T) {
}
var reply *string
result := dspSrv.SessionSv1Ping(CGREvent, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -65,7 +65,7 @@ func TestDspSessionSv1AuthorizeEventNil(t *testing.T) {
}
var reply *sessions.V1AuthorizeReply
result := dspSrv.SessionSv1AuthorizeEvent(CGREvent, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -98,7 +98,7 @@ func TestDspSessionSv1AuthorizeEventWithDigestNil(t *testing.T) {
}
var reply *sessions.V1AuthorizeReplyWithDigest
result := dspSrv.SessionSv1AuthorizeEventWithDigest(CGREvent, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -131,7 +131,7 @@ func TestDspSessionSv1InitiateSessionNil(t *testing.T) {
}
var reply *sessions.V1InitSessionReply
result := dspSrv.SessionSv1InitiateSession(CGREvent, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -164,7 +164,7 @@ func TestDspSessionSv1InitiateSessionWithDigestNil(t *testing.T) {
}
var reply *sessions.V1InitReplyWithDigest
result := dspSrv.SessionSv1InitiateSessionWithDigest(CGREvent, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -197,7 +197,7 @@ func TestDspSessionSv1UpdateSessionNil(t *testing.T) {
}
var reply *sessions.V1UpdateSessionReply
result := dspSrv.SessionSv1UpdateSession(CGREvent, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -228,7 +228,7 @@ func TestDspSessionSv1SyncSessionsNil(t *testing.T) {
}
var reply *string
result := dspSrv.SessionSv1SyncSessions(CGREvent, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -259,7 +259,7 @@ func TestDspSessionSv1TerminateSessionNil(t *testing.T) {
}
var reply *string
result := dspSrv.SessionSv1TerminateSession(CGREvent, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -290,7 +290,7 @@ func TestDspSessionSv1ProcessCDRNil(t *testing.T) {
}
var reply *string
result := dspSrv.SessionSv1ProcessCDR(CGREvent, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -321,7 +321,7 @@ func TestDspSessionSv1ProcessMessageNil(t *testing.T) {
}
var reply *sessions.V1ProcessMessageReply
result := dspSrv.SessionSv1ProcessMessage(CGREvent, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -354,7 +354,7 @@ func TestDspSessionSv1ProcessEventNil(t *testing.T) {
}
var reply *sessions.V1ProcessEventReply
result := dspSrv.SessionSv1ProcessEvent(CGREvent, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -385,7 +385,7 @@ func TestDspSessionSv1GetActiveSessionsNil(t *testing.T) {
}
var reply *[]*sessions.ExternalSession
result := dspSrv.SessionSv1GetActiveSessions(CGREvent, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -414,7 +414,7 @@ func TestDspSessionSv1GetActiveSessionsCountNil(t *testing.T) {
}
var reply *int
result := dspSrv.SessionSv1GetActiveSessionsCount(CGREvent, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -443,7 +443,7 @@ func TestDspSessionSv1ForceDisconnectNil(t *testing.T) {
}
var reply *string
result := dspSrv.SessionSv1ForceDisconnect(CGREvent, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -472,7 +472,7 @@ func TestDspSessionSv1GetPassiveSessionsNil(t *testing.T) {
}
var reply *[]*sessions.ExternalSession
result := dspSrv.SessionSv1GetPassiveSessions(CGREvent, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -501,7 +501,7 @@ func TestDspSessionSv1ReplicateSessionsNil(t *testing.T) {
}
var reply *string
result := dspSrv.SessionSv1ReplicateSessions(CGREvent, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -530,7 +530,7 @@ func TestDspSessionSv1GetPassiveSessionsCountNil(t *testing.T) {
}
var reply *int
result := dspSrv.SessionSv1GetPassiveSessionsCount(CGREvent, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -559,7 +559,7 @@ func TestDspSessionSv1SetPassiveSessionNil(t *testing.T) {
}
var reply *string
result := dspSrv.SessionSv1SetPassiveSession(CGREvent, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -586,7 +586,7 @@ func TestDspSessionSv1STIRAuthenticateNil(t *testing.T) {
CGREvent := &sessions.V1STIRAuthenticateArgs{}
var reply *string
result := dspSrv.SessionSv1STIRAuthenticate(CGREvent, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -611,7 +611,7 @@ func TestDspSessionSv1STIRIdentityNil(t *testing.T) {
CGREvent := &sessions.V1STIRIdentityArgs{}
var reply *string
result := dspSrv.SessionSv1STIRIdentity(CGREvent, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -636,7 +636,7 @@ func TestDspSessionSv1ActivateSessionsNil(t *testing.T) {
CGREvent := &utils.SessionIDsWithAPIOpts{}
var reply *string
result := dspSrv.SessionSv1ActivateSessions(CGREvent, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -650,7 +650,7 @@ func TestDspSessionSv1ActivateSessionsErrorTenant(t *testing.T) {
}
var reply *string
result := dspSrv.SessionSv1ActivateSessions(CGREvent, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -675,7 +675,7 @@ func TestDspSessionSv1DeactivateSessionsNil(t *testing.T) {
CGREvent := &utils.SessionIDsWithAPIOpts{}
var reply *string
result := dspSrv.SessionSv1DeactivateSessions(CGREvent, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -689,7 +689,7 @@ func TestDspSessionSv1DeactivateSessionsErrorTenant(t *testing.T) {
}
var reply *string
result := dspSrv.SessionSv1DeactivateSessions(CGREvent, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}

12
dispatchers/stats_test.go
View File

@@ -34,7 +34,7 @@ func TestDspStatSv1PingNil(t *testing.T) {
}
var reply *string
result := dspSrv.StatSv1Ping(CGREvent, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -77,7 +77,7 @@ func TestDspStatSv1GetStatQueuesForEventNil(t *testing.T) {
}
var reply *[]string
result := dspSrv.StatSv1GetStatQueuesForEvent(CGREvent, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -110,7 +110,7 @@ func TestDspStatSv1GetQueueStringMetricsNil(t *testing.T) {
}
var reply *map[string]string
result := dspSrv.StatSv1GetQueueStringMetrics(CGREvent, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -143,7 +143,7 @@ func TestDspStatSv1ProcessEventNil(t *testing.T) {
}
var reply *[]string
result := dspSrv.StatSv1ProcessEvent(CGREvent, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -176,7 +176,7 @@ func TestDspStatSv1GetQueueFloatMetricsNil(t *testing.T) {
}
var reply *map[string]float64
result := dspSrv.StatSv1GetQueueFloatMetrics(CGREvent, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -207,7 +207,7 @@ func TestDspStatSv1GetQueueIDsNil(t *testing.T) {
}
var reply *[]string
result := dspSrv.StatSv1GetQueueIDs(CGREvent, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}

12
dispatchers/thresholds_test.go
View File

@@ -31,7 +31,7 @@ func TestDspThresholdSv1PingNilEvent(t *testing.T) {
dspSrv := NewDispatcherService(nil, cgrCfg, nil, nil)
var reply *string
result := dspSrv.ThresholdSv1Ping(nil, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -45,7 +45,7 @@ func TestDspThresholdSv1PingNil(t *testing.T) {
}
var reply *string
result := dspSrv.ThresholdSv1Ping(CGREvent, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -74,7 +74,7 @@ func TestDspThresholdSv1GetThresholdsForEventNil(t *testing.T) {
}
var reply *engine.Thresholds
result := dspSrv.ThresholdSv1GetThresholdsForEvent(CGREvent, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -107,7 +107,7 @@ func TestDspThresholdSv1ProcessEventNil(t *testing.T) {
}
var reply *[]string
result := dspSrv.ThresholdSv1ProcessEvent(CGREvent, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -138,7 +138,7 @@ func TestDspThresholdSv1GetThresholdIDsNil(t *testing.T) {
}
var reply *[]string
result := dspSrv.ThresholdSv1GetThresholdIDs(CGREvent, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}
@@ -169,7 +169,7 @@ func TestDspThresholdSv1GetThresholdNil(t *testing.T) {
}
var reply *engine.Threshold
result := dspSrv.ThresholdSv1GetThreshold(CGREvent, reply)
expected := "DISPATCHER_ERROR:NOT_FOUND"
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if result == nil || result.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
}

3
engine/filterhelpers.go
View File

@@ -99,6 +99,9 @@ func MatchingItemIDsForEvent(ctx *context.Context, ev utils.MapStorage, stringFl
return
},
config.CgrConfig().GeneralCfg().LockingTimeout, lockID)
if err != nil {
return nil, err
}
if len(itemIDs) == 0 {
return nil, utils.ErrNotFound
}