diff --git a/dispatchers/attributes_test.go b/dispatchers/attributes_test.go index d5f6645fc..5b0d114c9 100644 --- a/dispatchers/attributes_test.go +++ b/dispatchers/attributes_test.go @@ -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) } diff --git a/dispatchers/caches_test.go b/dispatchers/caches_test.go index 1b648f948..a33e31f4c 100644 --- a/dispatchers/caches_test.go +++ b/dispatchers/caches_test.go @@ -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) } diff --git a/dispatchers/cdrs_test.go b/dispatchers/cdrs_test.go index b45fac502..bf9e4bd6f 100644 --- a/dispatchers/cdrs_test.go +++ b/dispatchers/cdrs_test.go @@ -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) } @@ -304,7 +304,7 @@ func TestDspCDRsV1StoreSessionCostNil(t *testing.T) { } var reply *string result := dspSrv.CDRsV1StoreSessionCost(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) } @@ -331,7 +331,7 @@ func TestDspCDRsV2StoreSessionCostNil(t *testing.T) { } var reply *string result := dspSrv.CDRsV2StoreSessionCost(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) } diff --git a/dispatchers/chargers_test.go b/dispatchers/chargers_test.go index ae4638da1..df43e60e4 100644 --- a/dispatchers/chargers_test.go +++ b/dispatchers/chargers_test.go @@ -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) } diff --git a/dispatchers/config_test.go b/dispatchers/config_test.go index e4db6ac29..65007c8b8 100644 --- a/dispatchers/config_test.go +++ b/dispatchers/config_test.go @@ -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) } diff --git a/dispatchers/core_test.go b/dispatchers/core_test.go index de75f0c89..12c3363aa 100644 --- a/dispatchers/core_test.go +++ b/dispatchers/core_test.go @@ -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) } diff --git a/dispatchers/dispatchers_test.go b/dispatchers/dispatchers_test.go index ffdf6070b..72f1b8e12 100644 --- a/dispatchers/dispatchers_test.go +++ b/dispatchers/dispatchers_test.go @@ -93,7 +93,7 @@ func TestDispatcherV1GetProfileForEventErr(t *testing.T) { ev := &utils.CGREvent{} dPfl := &engine.DispatcherProfile{} err := dsp.V1GetProfileForEvent(ev, dPfl) - 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) } @@ -106,7 +106,7 @@ func TestDispatcherV1GetProfileForEvent(t *testing.T) { ev := &utils.CGREvent{} dPfl := &engine.DispatcherProfile{} err := dsp.V1GetProfileForEvent(ev, dPfl) - 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) } @@ -118,7 +118,7 @@ func TestDispatcherDispatch(t *testing.T) { dsp := NewDispatcherService(nil, cfg, nil, nil) ev := &utils.CGREvent{} err := dsp.Dispatch(ev, "", "", "", "") - 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) } @@ -542,7 +542,7 @@ func TestDispatcherV1GetProfileForEventReturn(t *testing.T) { } dPfl := &engine.DispatcherProfile{} err = dss.V1GetProfileForEvent(ev, dPfl) - expected := "DISPATCHER_ERROR:NOT_FOUND" + expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION" if err != nil { t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, err) } @@ -1006,12 +1006,16 @@ func TestDispatcherServiceDispatchDspErrHostNotFound2(t *testing.T) { engine.Cache = cacheInit } + +*/ + func TestDispatcherServiceDispatcherProfileForEventGetDispatcherError(t *testing.T) { cfg := config.NewDefaultCGRConfig() cfg.DispatcherSCfg().IndexedSelects = false rpcCl := map[string]chan rpcclient.ClientConnector{} connMng := engine.NewConnManager(cfg, rpcCl) - dm := engine.NewDataManager(&engine.DataDBMock{}, nil, connMng) + dataDB := engine.NewInternalDB(nil, nil, true) + dm := engine.NewDataManager(dataDB, nil, connMng) dsp := &engine.DispatcherProfile{ Tenant: "cgrates.org", ID: "123", @@ -1061,5 +1065,3 @@ func TestDispatcherServiceDispatcherProfileForEventGetDispatcherError(t *testing t.Errorf("\nExpected <%+v>, \nReceived <%+v>", "NOT_FOUND:filter", err) } } - -*/ diff --git a/dispatchers/guardian_test.go b/dispatchers/guardian_test.go index 0521a58a4..0025a7767 100644 --- a/dispatchers/guardian_test.go +++ b/dispatchers/guardian_test.go @@ -50,7 +50,7 @@ func TestGuardianGuardianSv1PingErr2(t *testing.T) { } var reply *string - expected := "DISPATCHER_ERROR:NOT_FOUND" + expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION" result := dspSrv.GuardianSv1Ping(CGREvent, reply) if result == nil || result.Error() != expected { @@ -64,7 +64,7 @@ func TestGuardianGuardianSv1PingErrNil(t *testing.T) { var CGREvent *utils.CGREvent var reply *string - expected := "DISPATCHER_ERROR:NOT_FOUND" + expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION" result := dspSrv.GuardianSv1Ping(CGREvent, reply) if result == nil || result.Error() != expected { @@ -97,7 +97,7 @@ func TestGuardianGuardianSv1RemoteLockErr2(t *testing.T) { } var reply *string - expected := "DISPATCHER_ERROR:NOT_FOUND" + expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION" result := dspSrv.GuardianSv1RemoteLock(CGREvent, reply) if result == nil || result.Error() != expected { @@ -130,7 +130,7 @@ func TestGuardianGuardianSv1RemoteUnlockErr2(t *testing.T) { } var reply *[]string - expected := "DISPATCHER_ERROR:NOT_FOUND" + expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION" result := dspSrv.GuardianSv1RemoteUnlock(CGREvent, reply) if result == nil || result.Error() != expected { diff --git a/dispatchers/rals_test.go b/dispatchers/rals_test.go index 7f08b335a..73d744890 100644 --- a/dispatchers/rals_test.go +++ b/dispatchers/rals_test.go @@ -50,7 +50,7 @@ func TestRALsRALsV1PingErr2(t *testing.T) { } var reply *string - expected := "DISPATCHER_ERROR:NOT_FOUND" + expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION" result := dspSrv.RALsV1Ping(CGREvent, reply) if result == nil || result.Error() != expected { @@ -94,7 +94,7 @@ func TestRALsRALsV1GetRatingPlansCostErr2(t *testing.T) { CGREvent := &utils.RatingPlanCostArg{} var reply *RatingPlanCost - expected := "DISPATCHER_ERROR:NOT_FOUND" + expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION" result := dspSrv.RALsV1GetRatingPlansCost(CGREvent, reply) if result == nil || result.Error() != expected { diff --git a/dispatchers/replicator_test.go b/dispatchers/replicator_test.go index dbf2b85a3..7e56d5338 100644 --- a/dispatchers/replicator_test.go +++ b/dispatchers/replicator_test.go @@ -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) } @@ -102,7 +102,7 @@ func TestDspReplicatorSv1GetAccountErrorNil(t *testing.T) { } var reply *engine.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) } @@ -144,7 +144,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) } @@ -185,7 +185,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) } @@ -218,7 +218,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) } @@ -251,7 +251,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) } @@ -284,7 +284,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) } @@ -317,7 +317,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) } @@ -350,7 +350,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) } @@ -391,7 +391,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) } @@ -424,7 +424,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) } @@ -457,7 +457,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) } @@ -498,7 +498,7 @@ func TestDspReplicatorSv1GetActionTriggersErrorNil(t *testing.T) { } var reply *engine.ActionTriggers result := dspSrv.ReplicatorSv1GetActionTriggers(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) } @@ -539,7 +539,7 @@ func TestDspReplicatorSv1GetSharedGroupErrorNil(t *testing.T) { } var reply *engine.SharedGroup result := dspSrv.ReplicatorSv1GetSharedGroup(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) } @@ -577,7 +577,7 @@ func TestDspReplicatorSv1GetActionsErrorNilEvent(t *testing.T) { dspSrv := NewDispatcherService(nil, cgrCfg, nil, nil) var reply *engine.Actions result := dspSrv.ReplicatorSv1GetActions(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) } @@ -591,7 +591,7 @@ func TestDspReplicatorSv1GetActionsErrorNil(t *testing.T) { } var reply *engine.Actions result := dspSrv.ReplicatorSv1GetActions(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) } @@ -617,7 +617,7 @@ func TestDspReplicatorSv1GetActionPlanErrorNilEvent(t *testing.T) { dspSrv := NewDispatcherService(nil, cgrCfg, nil, nil) var reply *engine.ActionPlan result := dspSrv.ReplicatorSv1GetActionPlan(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) } @@ -631,7 +631,7 @@ func TestDspReplicatorSv1GetActionPlanErrorNil(t *testing.T) { } var reply *engine.ActionPlan result := dspSrv.ReplicatorSv1GetActionPlan(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) } @@ -672,7 +672,7 @@ func TestDspReplicatorSv1GetAllActionPlansErrorNil(t *testing.T) { } var reply *map[string]*engine.ActionPlan result := dspSrv.ReplicatorSv1GetAllActionPlans(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) } @@ -713,7 +713,7 @@ func TestDspReplicatorSv1GetAccountActionPlansErrorNil(t *testing.T) { } var reply *[]string result := dspSrv.ReplicatorSv1GetAccountActionPlans(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) } @@ -755,7 +755,7 @@ func TestDspReplicatorSv1GetRatingPlanErrorNil(t *testing.T) { } var reply *engine.RatingPlan result := dspSrv.ReplicatorSv1GetRatingPlan(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) } @@ -796,7 +796,7 @@ func TestDspReplicatorSv1GetRatingProfileErrorNil(t *testing.T) { } var reply *engine.RatingProfile result := dspSrv.ReplicatorSv1GetRatingProfile(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) } @@ -829,7 +829,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) } @@ -862,7 +862,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) } @@ -895,7 +895,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) } @@ -928,7 +928,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) } @@ -961,7 +961,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) } @@ -1002,7 +1002,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) } @@ -1035,7 +1035,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) } @@ -1046,7 +1046,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) } @@ -1079,7 +1079,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) } @@ -1090,7 +1090,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) } @@ -1119,7 +1119,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) } @@ -1130,7 +1130,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) } @@ -1161,7 +1161,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) } @@ -1172,7 +1172,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) } @@ -1205,7 +1205,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) } @@ -1216,7 +1216,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) } @@ -1249,7 +1249,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) } @@ -1260,7 +1260,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) } @@ -1293,7 +1293,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) } @@ -1304,7 +1304,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) } @@ -1337,7 +1337,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) } @@ -1348,7 +1348,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) } @@ -1377,7 +1377,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) } @@ -1388,7 +1388,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) } @@ -1421,7 +1421,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) } @@ -1432,7 +1432,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) } @@ -1465,7 +1465,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) } @@ -1476,7 +1476,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) } @@ -1505,7 +1505,7 @@ func TestReplicatorSv1SetSharedGroupErrorNil(t *testing.T) { } var reply *string result := dspSrv.ReplicatorSv1SetSharedGroup(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) } @@ -1516,7 +1516,7 @@ func TestDspReplicatorSv1SetSharedGroupNilEvent(t *testing.T) { dspSrv := NewDispatcherService(nil, cgrCfg, nil, nil) var reply *string result := dspSrv.ReplicatorSv1SetSharedGroup(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) } @@ -1545,7 +1545,7 @@ func TestReplicatorSv1SetActionsErrorNil(t *testing.T) { } var reply *string result := dspSrv.ReplicatorSv1SetActions(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) } @@ -1556,7 +1556,7 @@ func TestDspReplicatorSv1SetActionsNilEvent(t *testing.T) { dspSrv := NewDispatcherService(nil, cgrCfg, nil, nil) var reply *string result := dspSrv.ReplicatorSv1SetActions(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) } @@ -1585,7 +1585,7 @@ func TestReplicatorSv1SetRatingProfileErrorNil(t *testing.T) { } var reply *string result := dspSrv.ReplicatorSv1SetRatingProfile(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) } @@ -1596,7 +1596,7 @@ func TestDspReplicatorSv1SetRatingProfileNilEvent(t *testing.T) { dspSrv := NewDispatcherService(nil, cgrCfg, nil, nil) var reply *string result := dspSrv.ReplicatorSv1SetRatingProfile(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) } @@ -1625,7 +1625,7 @@ func TestDspReplicatorSv1SetRatingPlanErrorNil(t *testing.T) { } var reply *string result := dspSrv.ReplicatorSv1SetRatingPlan(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) } @@ -1636,7 +1636,7 @@ func TestDspReplicatorSv1SetRatingPlanNilEvent(t *testing.T) { dspSrv := NewDispatcherService(nil, cgrCfg, nil, nil) var reply *string result := dspSrv.ReplicatorSv1SetRatingPlan(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) } @@ -1665,7 +1665,7 @@ func TestDspReplicatorSv1SetActionTriggersErrorNil(t *testing.T) { } var reply *string result := dspSrv.ReplicatorSv1SetActionTriggers(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) } @@ -1676,7 +1676,7 @@ func TestDspReplicatorSv1SetActionTriggersNilEvent(t *testing.T) { dspSrv := NewDispatcherService(nil, cgrCfg, nil, nil) var reply *string result := dspSrv.ReplicatorSv1SetActionTriggers(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) } @@ -1709,7 +1709,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) } @@ -1720,7 +1720,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) } @@ -1753,7 +1753,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) } @@ -1764,7 +1764,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) } @@ -1797,7 +1797,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) } @@ -1808,7 +1808,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) } @@ -1841,7 +1841,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) } @@ -1852,7 +1852,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) } @@ -1881,7 +1881,7 @@ func TestDspReplicatorSv1SetActionPlanErrorNil(t *testing.T) { } var reply *string result := dspSrv.ReplicatorSv1SetActionPlan(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) } @@ -1892,7 +1892,7 @@ func TestDspReplicatorSv1SetActionPlanNilEvent(t *testing.T) { dspSrv := NewDispatcherService(nil, cgrCfg, nil, nil) var reply *string result := dspSrv.ReplicatorSv1SetActionPlan(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) } @@ -1921,7 +1921,7 @@ func TestDspReplicatorSv1SetAccountActionPlansErrorNil(t *testing.T) { } var reply *string result := dspSrv.ReplicatorSv1SetAccountActionPlans(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) } @@ -1932,7 +1932,7 @@ func TestDspReplicatorSv1SetAccountActionPlansNilEvent(t *testing.T) { dspSrv := NewDispatcherService(nil, cgrCfg, nil, nil) var reply *string result := dspSrv.ReplicatorSv1SetAccountActionPlans(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) } @@ -1965,7 +1965,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) } @@ -1976,7 +1976,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) } @@ -2009,7 +2009,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) } @@ -2020,7 +2020,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) } @@ -2049,7 +2049,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) } @@ -2078,7 +2078,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) } @@ -2089,7 +2089,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) } @@ -2118,7 +2118,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) } @@ -2129,7 +2129,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) } @@ -2162,7 +2162,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) } @@ -2173,7 +2173,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) } @@ -2184,7 +2184,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) } @@ -2217,7 +2217,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) } @@ -2228,7 +2228,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) } @@ -2261,7 +2261,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) } @@ -2272,7 +2272,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) } @@ -2305,7 +2305,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) } @@ -2316,7 +2316,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) } @@ -2349,7 +2349,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) } @@ -2360,7 +2360,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) } @@ -2393,7 +2393,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) } @@ -2404,7 +2404,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) } @@ -2433,7 +2433,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) } @@ -2444,7 +2444,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) } @@ -2473,7 +2473,7 @@ func TestDspReplicatorSv1RemoveActionTriggersErrorNil(t *testing.T) { } var reply *string result := dspSrv.ReplicatorSv1RemoveActionTriggers(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) } @@ -2484,7 +2484,7 @@ func TestDspReplicatorSv1RemoveActionTriggersNilEvent(t *testing.T) { dspSrv := NewDispatcherService(nil, cgrCfg, nil, nil) var reply *string result := dspSrv.ReplicatorSv1RemoveActionTriggers(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) } @@ -2513,7 +2513,7 @@ func TestDspReplicatorSv1RemoveSharedGroupErrorNil(t *testing.T) { } var reply *string result := dspSrv.ReplicatorSv1RemoveSharedGroup(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) } @@ -2524,7 +2524,7 @@ func TestDspReplicatorSv1RemoveSharedGroupNilEvent(t *testing.T) { dspSrv := NewDispatcherService(nil, cgrCfg, nil, nil) var reply *string result := dspSrv.ReplicatorSv1RemoveSharedGroup(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) } @@ -2553,7 +2553,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) } @@ -2564,7 +2564,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) } @@ -2593,7 +2593,7 @@ func TestDspReplicatorSv1RemoveActionPlanErrorNil(t *testing.T) { } var reply *string result := dspSrv.ReplicatorSv1RemoveActionPlan(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) } @@ -2604,7 +2604,7 @@ func TestDspReplicatorSv1RemoveActionPlanNilEvent(t *testing.T) { dspSrv := NewDispatcherService(nil, cgrCfg, nil, nil) var reply *string result := dspSrv.ReplicatorSv1RemoveActionPlan(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) } @@ -2632,7 +2632,7 @@ func TestDspReplicatorSv1RemAccountActionPlansErrorNil(t *testing.T) { } var reply *string result := dspSrv.ReplicatorSv1RemAccountActionPlans(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) } @@ -2643,7 +2643,7 @@ func TestDspReplicatorSv1RemAccountActionPlansNilEvent(t *testing.T) { dspSrv := NewDispatcherService(nil, cgrCfg, nil, nil) var reply *string result := dspSrv.ReplicatorSv1RemAccountActionPlans(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) } @@ -2672,7 +2672,7 @@ func TestDspReplicatorSv1RemoveRatingPlanErrorNil(t *testing.T) { } var reply *string result := dspSrv.ReplicatorSv1RemoveRatingPlan(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) } @@ -2683,7 +2683,7 @@ func TestDspReplicatorSv1RemoveRatingPlanNilEvent(t *testing.T) { dspSrv := NewDispatcherService(nil, cgrCfg, nil, nil) var reply *string result := dspSrv.ReplicatorSv1RemoveRatingPlan(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) } @@ -2712,7 +2712,7 @@ func TestDspReplicatorSv1RemoveRatingProfileErrorNil(t *testing.T) { } var reply *string result := dspSrv.ReplicatorSv1RemoveRatingProfile(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) } @@ -2723,7 +2723,7 @@ func TestDspReplicatorSv1RemoveRatingProfileNilEvent(t *testing.T) { dspSrv := NewDispatcherService(nil, cgrCfg, nil, nil) var reply *string result := dspSrv.ReplicatorSv1RemoveRatingProfile(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) } @@ -2756,7 +2756,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) } @@ -2767,7 +2767,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) } @@ -2800,7 +2800,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) } @@ -2811,7 +2811,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) } @@ -2844,7 +2844,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) } @@ -2855,7 +2855,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) } @@ -2888,7 +2888,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) } @@ -2899,7 +2899,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) } @@ -2932,7 +2932,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) } @@ -2943,7 +2943,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) } @@ -2972,7 +2972,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) } @@ -2983,7 +2983,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) } @@ -3012,7 +3012,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) } @@ -3023,7 +3023,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) } @@ -3052,7 +3052,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) } @@ -3063,7 +3063,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) } diff --git a/dispatchers/resources_test.go b/dispatchers/resources_test.go index e73a719fc..135e51863 100644 --- a/dispatchers/resources_test.go +++ b/dispatchers/resources_test.go @@ -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) } diff --git a/dispatchers/responder_test.go b/dispatchers/responder_test.go index f4baa4218..6362e2fab 100644 --- a/dispatchers/responder_test.go +++ b/dispatchers/responder_test.go @@ -62,7 +62,7 @@ func TestDspResponderPingErrorNil(t *testing.T) { } var reply *string result := dspSrv.ResponderPing(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) } @@ -95,7 +95,7 @@ func TestDspResponderDebitErrorNil(t *testing.T) { } var reply *engine.CallCost result := dspSrv.ResponderDebit(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) } @@ -128,7 +128,7 @@ func TestDspResponderGetCostErrorNil(t *testing.T) { } var reply *engine.CallCost result := dspSrv.ResponderGetCost(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) } @@ -161,7 +161,7 @@ func TestDspResponderMaxDebitErrorNil(t *testing.T) { } var reply *engine.CallCost result := dspSrv.ResponderMaxDebit(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) } @@ -194,7 +194,7 @@ func TestDspResponderRefundIncrementsErrorNil(t *testing.T) { } var reply *engine.Account result := dspSrv.ResponderRefundIncrements(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) } @@ -227,7 +227,7 @@ func TestDspResponderRefundRoundingErrorNil(t *testing.T) { } var reply *float64 result := dspSrv.ResponderRefundRounding(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) } @@ -260,7 +260,7 @@ func TestDspResponderGetMaxSessionTimeErrorNil(t *testing.T) { } var reply *time.Duration result := dspSrv.ResponderGetMaxSessionTime(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) } @@ -289,7 +289,7 @@ func TestDspResponderShutdownErrorNil(t *testing.T) { } var reply *string result := dspSrv.ResponderShutdown(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) } diff --git a/dispatchers/routes_test.go b/dispatchers/routes_test.go index 79423cf0e..967a2085a 100644 --- a/dispatchers/routes_test.go +++ b/dispatchers/routes_test.go @@ -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) } diff --git a/dispatchers/scheduler_test.go b/dispatchers/scheduler_test.go index 6fbd7a253..a892ffa04 100644 --- a/dispatchers/scheduler_test.go +++ b/dispatchers/scheduler_test.go @@ -60,7 +60,7 @@ func TestDspSchedulerSv1PingNil(t *testing.T) { } var reply *string result := dspSrv.SchedulerSv1Ping(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) } @@ -89,7 +89,7 @@ func TestDspSchedulerSv1ReloadPingNil(t *testing.T) { } var reply *string result := dspSrv.SchedulerSv1Reload(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) } @@ -118,7 +118,7 @@ func TestDspSchedulerSv1ExecuteActionsNil(t *testing.T) { } var reply *string result := dspSrv.SchedulerSv1ExecuteActions(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) } @@ -147,7 +147,7 @@ func TestDspSchedulerSv1ExecuteActionPlansNil(t *testing.T) { } var reply *string result := dspSrv.SchedulerSv1ExecuteActionPlans(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) } diff --git a/dispatchers/servicemanager_test.go b/dispatchers/servicemanager_test.go index 4e1828ad4..cedd0c59b 100644 --- a/dispatchers/servicemanager_test.go +++ b/dispatchers/servicemanager_test.go @@ -60,7 +60,7 @@ func TestDspServiceManagerV1PingNil(t *testing.T) { } var reply *string result := dspSrv.ServiceManagerV1Ping(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) } @@ -89,7 +89,7 @@ func TestDspServiceManagerV1StartServiceNil(t *testing.T) { } var reply *string result := dspSrv.ServiceManagerV1StartService(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) } @@ -118,7 +118,7 @@ func TestDspServiceManagerV1StopServiceNil(t *testing.T) { } var reply *string result := dspSrv.ServiceManagerV1StopService(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) } @@ -147,7 +147,7 @@ func TestDspServiceManagerV1ServiceStatusErrorNil(t *testing.T) { } var reply *string result := dspSrv.ServiceManagerV1ServiceStatus(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) } diff --git a/dispatchers/sessions_test.go b/dispatchers/sessions_test.go index 50610eb8d..3727ed657 100644 --- a/dispatchers/sessions_test.go +++ b/dispatchers/sessions_test.go @@ -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) } @@ -387,7 +387,7 @@ func TestDspSessionSv1GetCostNil(t *testing.T) { } var reply *sessions.V1GetCostReply result := dspSrv.SessionSv1GetCost(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) } @@ -418,7 +418,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) } @@ -447,7 +447,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) } @@ -476,7 +476,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) } @@ -505,7 +505,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) } @@ -534,7 +534,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) } @@ -563,7 +563,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) } @@ -592,7 +592,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) } @@ -621,7 +621,7 @@ func TestDspSessionSv1ActivateSessionsNil(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) } @@ -650,7 +650,7 @@ func TestDspSessionSv1DeactivateSessionsNil(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) } @@ -677,7 +677,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) } @@ -702,7 +702,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) } diff --git a/dispatchers/stats_test.go b/dispatchers/stats_test.go index ff0fb2990..e183299c2 100644 --- a/dispatchers/stats_test.go +++ b/dispatchers/stats_test.go @@ -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) } diff --git a/dispatchers/thresholds_test.go b/dispatchers/thresholds_test.go index e6f51207b..19a3f049f 100644 --- a/dispatchers/thresholds_test.go +++ b/dispatchers/thresholds_test.go @@ -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) } diff --git a/engine/chargers_test.go b/engine/chargers_test.go index c3553ddab..e90788abb 100644 --- a/engine/chargers_test.go +++ b/engine/chargers_test.go @@ -646,10 +646,10 @@ func TestChargersprocessEvent(t *testing.T) { }, } - experr := utils.ErrNotFound + experr := "NO_DATABASE_CONNECTION" rcv, err := cS.processEvent(cgrEv.Tenant, cgrEv) - if err == nil || err != experr { + if err == nil || err.Error() != experr { t.Fatalf("\nexpected: <%+v>, \nreceived: <%+v>", experr, err) } diff --git a/engine/filterhelpers.go b/engine/filterhelpers.go index 9507f9341..8ca5b5bd9 100644 --- a/engine/filterhelpers.go +++ b/engine/filterhelpers.go @@ -97,6 +97,9 @@ func MatchingItemIDsForEvent(ev utils.MapStorage, stringFldIDs, prefixFldIDs, su } return }, config.CgrConfig().GeneralCfg().LockingTimeout, lockID) + if err != nil { + return nil, err + } if len(itemIDs) == 0 { return nil, utils.ErrNotFound }