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

Updated tests

Browse Source
This commit is contained in:
Trial97
2021-06-15 12:16:51 +03:00
committed by Dan Christian Bogos
parent 34e093f98e
commit cc1e6a0b92
24 changed files with 185 additions and 166 deletions
Download Patch File Download Diff File Expand all files Collapse all files

17
dispatchers/accounts.go
View File

@@ -19,6 +19,7 @@ along with this program. If not, see <http://www.gnu.org/licenses/>
package dispatchers
import (
"github.com/cgrates/birpc/context"
"github.com/cgrates/cgrates/utils"
)
@@ -33,7 +34,7 @@ func (dS *DispatcherService) AccountSv1Ping(args *utils.CGREvent, rpl *string) (
return
}
}
return dS.Dispatch(args, utils.MetaAccounts, utils.AccountSv1Ping, args, rpl)
return dS.Dispatch(context.TODO(), args, utils.MetaAccounts, utils.AccountSv1Ping, args, rpl)
}
func (dS *DispatcherService) AccountsForEvent(args *utils.ArgsAccountsForEvent, reply *[]*utils.Account) (err error) {
@@ -47,7 +48,7 @@ func (dS *DispatcherService) AccountsForEvent(args *utils.ArgsAccountsForEvent,
return
}
}
return dS.Dispatch(args.CGREvent, utils.MetaAccounts, utils.AccountSv1AccountsForEvent, args, reply)
return dS.Dispatch(context.TODO(), args.CGREvent, utils.MetaAccounts, utils.AccountSv1AccountsForEvent, args, reply)
}
func (dS *DispatcherService) MaxAbstracts(args *utils.ArgsAccountsForEvent, reply *utils.ExtEventCharges) (err error) {
@@ -61,7 +62,7 @@ func (dS *DispatcherService) MaxAbstracts(args *utils.ArgsAccountsForEvent, repl
return
}
}
return dS.Dispatch(args.CGREvent, utils.MetaAccounts, utils.AccountSv1MaxAbstracts, args, reply)
return dS.Dispatch(context.TODO(), args.CGREvent, utils.MetaAccounts, utils.AccountSv1MaxAbstracts, args, reply)
}
func (dS *DispatcherService) DebitAbstracts(args *utils.ArgsAccountsForEvent, reply *utils.ExtEventCharges) (err error) {
@@ -75,7 +76,7 @@ func (dS *DispatcherService) DebitAbstracts(args *utils.ArgsAccountsForEvent, re
return
}
}
return dS.Dispatch(args.CGREvent, utils.MetaAccounts, utils.AccountSv1DebitAbstracts, args, reply)
return dS.Dispatch(context.TODO(), args.CGREvent, utils.MetaAccounts, utils.AccountSv1DebitAbstracts, args, reply)
}
func (dS *DispatcherService) MaxConcretes(args *utils.ArgsAccountsForEvent, reply *utils.ExtEventCharges) (err error) {
@@ -89,7 +90,7 @@ func (dS *DispatcherService) MaxConcretes(args *utils.ArgsAccountsForEvent, repl
return
}
}
return dS.Dispatch(args.CGREvent, utils.MetaAccounts, utils.AccountSv1MaxConcretes, args, reply)
return dS.Dispatch(context.TODO(), args.CGREvent, utils.MetaAccounts, utils.AccountSv1MaxConcretes, args, reply)
}
func (dS *DispatcherService) DebitConcretes(args *utils.ArgsAccountsForEvent, reply *utils.ExtEventCharges) (err error) {
@@ -103,7 +104,7 @@ func (dS *DispatcherService) DebitConcretes(args *utils.ArgsAccountsForEvent, re
return
}
}
return dS.Dispatch(args.CGREvent, utils.MetaAccounts, utils.AccountSv1DebitConcretes, args, reply)
return dS.Dispatch(context.TODO(), args.CGREvent, utils.MetaAccounts, utils.AccountSv1DebitConcretes, args, reply)
}
func (dS *DispatcherService) AccountSv1ActionSetBalance(args *utils.ArgsActSetBalance, reply *string) (err error) {
@@ -117,7 +118,7 @@ func (dS *DispatcherService) AccountSv1ActionSetBalance(args *utils.ArgsActSetBa
return
}
}
return dS.Dispatch(&utils.CGREvent{
return dS.Dispatch(context.TODO(), &utils.CGREvent{
Tenant: tnt,
APIOpts: args.APIOpts,
}, utils.MetaAccounts, utils.AccountSv1ActionSetBalance, args, reply)
@@ -134,7 +135,7 @@ func (dS *DispatcherService) AccountSv1ActionRemoveBalance(args *utils.ArgsActRe
return
}
}
return dS.Dispatch(&utils.CGREvent{
return dS.Dispatch(context.TODO(), &utils.CGREvent{
Tenant: tnt,
APIOpts: args.APIOpts,
}, utils.MetaAccounts, utils.AccountSv1ActionRemoveBalance, args, reply)

11
dispatchers/actions.go
View File

@@ -18,7 +18,10 @@ along with this program. If not, see <http://www.gnu.org/licenses/>
package dispatchers
import "github.com/cgrates/cgrates/utils"
import (
"github.com/cgrates/birpc/context"
"github.com/cgrates/cgrates/utils"
)
func (dS *DispatcherService) ActionSv1Ping(args *utils.CGREvent, rpl *string) (err error) {
if args == nil {
@@ -31,7 +34,7 @@ func (dS *DispatcherService) ActionSv1Ping(args *utils.CGREvent, rpl *string) (e
return
}
}
return dS.Dispatch(args, utils.MetaActions, utils.ActionSv1Ping, args, rpl)
return dS.Dispatch(context.TODO(), args, utils.MetaActions, utils.ActionSv1Ping, args, rpl)
}
func (dS *DispatcherService) ActionSv1ScheduleActions(args *utils.ArgActionSv1ScheduleActions, rpl *string) (err error) {
@@ -50,7 +53,7 @@ func (dS *DispatcherService) ActionSv1ScheduleActions(args *utils.ArgActionSv1Sc
return
}
}
return dS.Dispatch(args.CGREvent, utils.MetaActions, utils.ActionSv1ScheduleActions, args, rpl)
return dS.Dispatch(context.TODO(), args.CGREvent, utils.MetaActions, utils.ActionSv1ScheduleActions, args, rpl)
}
func (dS *DispatcherService) ActionSv1ExecuteActions(args *utils.ArgActionSv1ScheduleActions, rpl *string) (err error) {
@@ -69,5 +72,5 @@ func (dS *DispatcherService) ActionSv1ExecuteActions(args *utils.ArgActionSv1Sch
return
}
}
return dS.Dispatch(args.CGREvent, utils.MetaActions, utils.ActionSv1Ping, args, rpl)
return dS.Dispatch(context.TODO(), args.CGREvent, utils.MetaActions, utils.ActionSv1Ping, args, rpl)
}

4
dispatchers/attributes.go
View File

@@ -43,7 +43,7 @@ func (dS *DispatcherService) AttributeSv1GetAttributeForEvent(ctx *context.Conte
return
}
}
return dS.Dispatch(args.CGREvent, utils.MetaAttributes, utils.AttributeSv1GetAttributeForEvent, args, reply)
return dS.Dispatch(ctx, args.CGREvent, utils.MetaAttributes, utils.AttributeSv1GetAttributeForEvent, args, reply)
}
// AttributeSv1ProcessEvent .
@@ -60,5 +60,5 @@ func (dS *DispatcherService) AttributeSv1ProcessEvent(ctx *context.Context, args
}
}
return dS.Dispatch(args.CGREvent, utils.MetaAttributes, utils.AttributeSv1ProcessEvent, args, reply)
return dS.Dispatch(ctx, args.CGREvent, utils.MetaAttributes, utils.AttributeSv1ProcessEvent, args, reply)
}

33
dispatchers/caches.go
View File

@@ -21,6 +21,7 @@ package dispatchers
import (
"time"
"github.com/cgrates/birpc/context"
"github.com/cgrates/cgrates/utils"
"github.com/cgrates/ltcache"
)
@@ -41,7 +42,7 @@ func (dS *DispatcherService) CacheSv1Ping(args *utils.CGREvent,
return
}
}
return dS.Dispatch(args, utils.MetaCaches, utils.CacheSv1Ping, args, reply)
return dS.Dispatch(context.TODO(), args, utils.MetaCaches, utils.CacheSv1Ping, args, reply)
}
// CacheSv1GetItemIDs returns the IDs for cacheID with given prefix
@@ -57,7 +58,7 @@ func (dS *DispatcherService) CacheSv1GetItemIDs(args *utils.ArgsGetCacheItemIDsW
return
}
}
return dS.Dispatch(&utils.CGREvent{
return dS.Dispatch(context.TODO(), &utils.CGREvent{
Tenant: tnt,
APIOpts: args.APIOpts,
}, utils.MetaCaches, utils.CacheSv1GetItemIDs, args, reply)
@@ -77,7 +78,7 @@ func (dS *DispatcherService) CacheSv1HasItem(args *utils.ArgsGetCacheItemWithAPI
}
}
return dS.Dispatch(&utils.CGREvent{
return dS.Dispatch(context.TODO(), &utils.CGREvent{
Tenant: tnt,
APIOpts: args.APIOpts,
},
@@ -98,7 +99,7 @@ func (dS *DispatcherService) CacheSv1GetItemExpiryTime(args *utils.ArgsGetCacheI
}
}
return dS.Dispatch(&utils.CGREvent{
return dS.Dispatch(context.TODO(), &utils.CGREvent{
Tenant: tnt,
APIOpts: args.APIOpts,
}, utils.MetaCaches, utils.CacheSv1GetItemExpiryTime, args, reply)
@@ -117,7 +118,7 @@ func (dS *DispatcherService) CacheSv1RemoveItem(args *utils.ArgsGetCacheItemWith
return
}
}
return dS.Dispatch(&utils.CGREvent{
return dS.Dispatch(context.TODO(), &utils.CGREvent{
Tenant: tnt,
APIOpts: args.APIOpts,
}, utils.MetaCaches, utils.CacheSv1RemoveItem, args, reply)
@@ -136,7 +137,7 @@ func (dS *DispatcherService) CacheSv1RemoveItems(args *utils.AttrReloadCacheWith
return
}
}
return dS.Dispatch(&utils.CGREvent{
return dS.Dispatch(context.TODO(), &utils.CGREvent{
Tenant: tnt,
APIOpts: args.APIOpts,
}, utils.MetaCaches, utils.CacheSv1RemoveItems, args, reply)
@@ -155,7 +156,7 @@ func (dS *DispatcherService) CacheSv1Clear(args *utils.AttrCacheIDsWithAPIOpts,
return
}
}
return dS.Dispatch(&utils.CGREvent{
return dS.Dispatch(context.TODO(), &utils.CGREvent{
Tenant: tnt,
APIOpts: args.APIOpts,
}, utils.MetaCaches, utils.CacheSv1Clear, args, reply)
@@ -174,7 +175,7 @@ func (dS *DispatcherService) CacheSv1GetCacheStats(args *utils.AttrCacheIDsWithA
return
}
}
return dS.Dispatch(&utils.CGREvent{
return dS.Dispatch(context.TODO(), &utils.CGREvent{
Tenant: tnt,
APIOpts: args.APIOpts,
}, utils.MetaCaches, utils.CacheSv1GetCacheStats, args, reply)
@@ -192,7 +193,7 @@ func (dS *DispatcherService) CacheSv1PrecacheStatus(args *utils.AttrCacheIDsWith
return
}
}
return dS.Dispatch(&utils.CGREvent{
return dS.Dispatch(context.TODO(), &utils.CGREvent{
Tenant: tnt,
APIOpts: args.APIOpts,
}, utils.MetaCaches, utils.CacheSv1PrecacheStatus, args, reply)
@@ -211,7 +212,7 @@ func (dS *DispatcherService) CacheSv1HasGroup(args *utils.ArgsGetGroupWithAPIOpt
return
}
}
return dS.Dispatch(&utils.CGREvent{
return dS.Dispatch(context.TODO(), &utils.CGREvent{
Tenant: tnt,
APIOpts: args.APIOpts,
}, utils.MetaCaches, utils.CacheSv1HasGroup, args, reply)
@@ -230,7 +231,7 @@ func (dS *DispatcherService) CacheSv1GetGroupItemIDs(args *utils.ArgsGetGroupWit
return
}
}
return dS.Dispatch(&utils.CGREvent{
return dS.Dispatch(context.TODO(), &utils.CGREvent{
Tenant: tnt,
APIOpts: args.APIOpts,
}, utils.MetaCaches, utils.CacheSv1GetGroupItemIDs, args, reply)
@@ -248,7 +249,7 @@ func (dS *DispatcherService) CacheSv1RemoveGroup(args *utils.ArgsGetGroupWithAPI
return
}
}
return dS.Dispatch(&utils.CGREvent{
return dS.Dispatch(context.TODO(), &utils.CGREvent{
Tenant: tnt,
APIOpts: args.APIOpts,
}, utils.MetaCaches, utils.CacheSv1RemoveGroup, args, reply)
@@ -266,7 +267,7 @@ func (dS *DispatcherService) CacheSv1ReloadCache(args *utils.AttrReloadCacheWith
return
}
}
return dS.Dispatch(&utils.CGREvent{
return dS.Dispatch(context.TODO(), &utils.CGREvent{
Tenant: tnt,
APIOpts: args.APIOpts,
}, utils.MetaCaches, utils.CacheSv1ReloadCache, args, reply)
@@ -284,7 +285,7 @@ func (dS *DispatcherService) CacheSv1LoadCache(args *utils.AttrReloadCacheWithAP
return
}
}
return dS.Dispatch(&utils.CGREvent{
return dS.Dispatch(context.TODO(), &utils.CGREvent{
Tenant: tnt,
APIOpts: args.APIOpts,
}, utils.MetaCaches, utils.CacheSv1LoadCache, args, reply)
@@ -302,7 +303,7 @@ func (dS *DispatcherService) CacheSv1ReplicateRemove(args *utils.ArgCacheReplica
return
}
}
return dS.Dispatch(&utils.CGREvent{
return dS.Dispatch(context.TODO(), &utils.CGREvent{
Tenant: tnt,
APIOpts: args.APIOpts,
}, utils.MetaCaches, utils.CacheSv1ReplicateRemove, args, reply)
@@ -320,7 +321,7 @@ func (dS *DispatcherService) CacheSv1ReplicateSet(args *utils.ArgCacheReplicateS
return
}
}
return dS.Dispatch(&utils.CGREvent{
return dS.Dispatch(context.TODO(), &utils.CGREvent{
Tenant: tnt,
APIOpts: args.APIOpts,
}, utils.MetaCaches, utils.CacheSv1ReplicateSet, args, reply)

17
dispatchers/cdrs.go
View File

@@ -19,6 +19,7 @@ along with this program. If not, see <http://www.gnu.org/licenses/>
package dispatchers
import (
"github.com/cgrates/birpc/context"
"github.com/cgrates/cgrates/engine"
"github.com/cgrates/cgrates/utils"
)
@@ -39,7 +40,7 @@ func (dS *DispatcherService) CDRsV1Ping(args *utils.CGREvent,
return
}
}
return dS.Dispatch(args, utils.MetaCDRs,
return dS.Dispatch(context.TODO(), args, utils.MetaCDRs,
utils.CDRsV1Ping, args, reply)
}
@@ -55,7 +56,7 @@ func (dS *DispatcherService) CDRsV1GetCDRs(args *utils.RPCCDRsFilterWithAPIOpts,
return
}
}
return dS.Dispatch(&utils.CGREvent{
return dS.Dispatch(context.TODO(), &utils.CGREvent{
Tenant: tnt,
APIOpts: args.APIOpts,
}, utils.MetaCDRs, utils.CDRsV1GetCDRs, args, reply)
@@ -73,7 +74,7 @@ func (dS *DispatcherService) CDRsV1GetCDRsCount(args *utils.RPCCDRsFilterWithAPI
return
}
}
return dS.Dispatch(&utils.CGREvent{
return dS.Dispatch(context.TODO(), &utils.CGREvent{
Tenant: tnt,
APIOpts: args.APIOpts,
}, utils.MetaCDRs, utils.CDRsV1GetCDRsCount, args, reply)
@@ -90,7 +91,7 @@ func (dS *DispatcherService) CDRsV1RateCDRs(args *engine.ArgRateCDRs, reply *str
return
}
}
return dS.Dispatch(&utils.CGREvent{
return dS.Dispatch(context.TODO(), &utils.CGREvent{
Tenant: tnt,
APIOpts: args.APIOpts,
}, utils.MetaCDRs, utils.CDRsV1RateCDRs, args, reply)
@@ -107,7 +108,7 @@ func (dS *DispatcherService) CDRsV1ProcessExternalCDR(args *engine.ExternalCDRWi
return
}
}
return dS.Dispatch(&utils.CGREvent{
return dS.Dispatch(context.TODO(), &utils.CGREvent{
Tenant: tnt,
APIOpts: args.APIOpts,
}, utils.MetaCDRs, utils.CDRsV1ProcessExternalCDR, args, reply)
@@ -124,7 +125,7 @@ func (dS *DispatcherService) CDRsV1ProcessEvent(args *engine.ArgV1ProcessEvent,
return
}
}
return dS.Dispatch(&args.CGREvent, utils.MetaCDRs,
return dS.Dispatch(context.TODO(), &args.CGREvent, utils.MetaCDRs,
utils.CDRsV1ProcessEvent, args, reply)
}
@@ -139,7 +140,7 @@ func (dS *DispatcherService) CDRsV1ProcessCDR(args *engine.CDRWithAPIOpts, reply
return
}
}
return dS.Dispatch(&utils.CGREvent{
return dS.Dispatch(context.TODO(), &utils.CGREvent{
Tenant: tnt,
APIOpts: args.APIOpts,
}, utils.MetaCDRs, utils.CDRsV1ProcessCDR, args, reply)
@@ -156,6 +157,6 @@ func (dS *DispatcherService) CDRsV2ProcessEvent(args *engine.ArgV1ProcessEvent,
return
}
}
return dS.Dispatch(&args.CGREvent, utils.MetaCDRs,
return dS.Dispatch(context.TODO(), &args.CGREvent, utils.MetaCDRs,
utils.CDRsV2ProcessEvent, args, reply)
}

7
dispatchers/chargers.go
View File

@@ -19,6 +19,7 @@ along with this program. If not, see <http://www.gnu.org/licenses/>
package dispatchers
import (
"github.com/cgrates/birpc/context"
"github.com/cgrates/cgrates/engine"
"github.com/cgrates/cgrates/utils"
)
@@ -37,7 +38,7 @@ func (dS *DispatcherService) ChargerSv1Ping(args *utils.CGREvent, reply *string)
return
}
}
return dS.Dispatch(args, utils.MetaChargers, utils.ChargerSv1Ping, args, reply)
return dS.Dispatch(context.TODO(), args, utils.MetaChargers, utils.ChargerSv1Ping, args, reply)
}
func (dS *DispatcherService) ChargerSv1GetChargersForEvent(args *utils.CGREvent,
@@ -52,7 +53,7 @@ func (dS *DispatcherService) ChargerSv1GetChargersForEvent(args *utils.CGREvent,
return
}
}
return dS.Dispatch(args, utils.MetaChargers, utils.ChargerSv1GetChargersForEvent, args, reply)
return dS.Dispatch(context.TODO(), args, utils.MetaChargers, utils.ChargerSv1GetChargersForEvent, args, reply)
}
func (dS *DispatcherService) ChargerSv1ProcessEvent(args *utils.CGREvent,
@@ -67,5 +68,5 @@ func (dS *DispatcherService) ChargerSv1ProcessEvent(args *utils.CGREvent,
return
}
}
return dS.Dispatch(args, utils.MetaChargers, utils.ChargerSv1ProcessEvent, args, reply)
return dS.Dispatch(context.TODO(), args, utils.MetaChargers, utils.ChargerSv1ProcessEvent, args, reply)
}

11
dispatchers/config.go
View File

@@ -19,6 +19,7 @@ along with this program. If not, see <http://www.gnu.org/licenses/>
package dispatchers
import (
"github.com/cgrates/birpc/context"
"github.com/cgrates/cgrates/config"
"github.com/cgrates/cgrates/utils"
)
@@ -34,7 +35,7 @@ func (dS *DispatcherService) ConfigSv1GetConfig(args *config.SectionWithAPIOpts,
return
}
}
return dS.Dispatch(&utils.CGREvent{
return dS.Dispatch(context.TODO(), &utils.CGREvent{
Tenant: tnt,
APIOpts: args.APIOpts,
}, utils.MetaConfig, utils.ConfigSv1GetConfig, args, reply)
@@ -51,7 +52,7 @@ func (dS *DispatcherService) ConfigSv1ReloadConfig(args *config.ReloadArgs, repl
return
}
}
return dS.Dispatch(&utils.CGREvent{
return dS.Dispatch(context.TODO(), &utils.CGREvent{
Tenant: tnt,
APIOpts: args.APIOpts,
}, utils.MetaConfig, utils.ConfigSv1ReloadConfig, args, reply)
@@ -68,7 +69,7 @@ func (dS *DispatcherService) ConfigSv1SetConfig(args *config.SetConfigArgs, repl
return
}
}
return dS.Dispatch(&utils.CGREvent{
return dS.Dispatch(context.TODO(), &utils.CGREvent{
Tenant: tnt,
APIOpts: args.APIOpts,
}, utils.MetaConfig, utils.ConfigSv1SetConfig, args, reply)
@@ -85,7 +86,7 @@ func (dS *DispatcherService) ConfigSv1SetConfigFromJSON(args *config.SetConfigFr
return
}
}
return dS.Dispatch(&utils.CGREvent{
return dS.Dispatch(context.TODO(), &utils.CGREvent{
Tenant: tnt,
APIOpts: args.APIOpts,
}, utils.MetaConfig, utils.ConfigSv1SetConfigFromJSON, args, reply)
@@ -102,7 +103,7 @@ func (dS *DispatcherService) ConfigSv1GetConfigAsJSON(args *config.SectionWithAP
return
}
}
return dS.Dispatch(&utils.CGREvent{
return dS.Dispatch(context.TODO(), &utils.CGREvent{
Tenant: tnt,
APIOpts: args.APIOpts,
}, utils.MetaConfig, utils.ConfigSv1GetConfigAsJSON, args, reply)

7
dispatchers/core.go
View File

@@ -19,6 +19,7 @@ along with this program. If not, see <http://www.gnu.org/licenses/>
package dispatchers
import (
"github.com/cgrates/birpc/context"
"github.com/cgrates/cgrates/utils"
)
@@ -34,7 +35,7 @@ func (dS *DispatcherService) CoreSv1Status(args *utils.TenantWithAPIOpts,
return
}
}
return dS.Dispatch(&utils.CGREvent{
return dS.Dispatch(context.TODO(), &utils.CGREvent{
Tenant: tnt,
APIOpts: args.APIOpts,
}, utils.MetaCore, utils.CoreSv1Status, args, reply)
@@ -51,7 +52,7 @@ func (dS *DispatcherService) CoreSv1Ping(args *utils.CGREvent, reply *string) (e
return
}
}
return dS.Dispatch(args, utils.MetaCore, utils.CoreSv1Ping, args, reply)
return dS.Dispatch(context.TODO(), args, utils.MetaCore, utils.CoreSv1Ping, args, reply)
}
func (dS *DispatcherService) CoreSv1Sleep(args *utils.DurationArgs,
@@ -66,7 +67,7 @@ func (dS *DispatcherService) CoreSv1Sleep(args *utils.DurationArgs,
return
}
}
return dS.Dispatch(&utils.CGREvent{
return dS.Dispatch(context.TODO(), &utils.CGREvent{
Tenant: tnt,
APIOpts: args.APIOpts,
}, utils.MetaCore, utils.CoreSv1Sleep, args, reply)

11
dispatchers/dispatchers.go
View File

@@ -150,7 +150,7 @@ func (dS *DispatcherService) dispatcherProfilesForEvent(ctx *context.Context, tn
}
// Dispatch is the method forwarding the request towards the right connection
func (dS *DispatcherService) Dispatch(ev *utils.CGREvent, subsys string,
func (dS *DispatcherService) Dispatch(ctx *context.Context, ev *utils.CGREvent, subsys string,
serviceMethod string, args interface{}, reply interface{}) (err error) {
tnt := ev.Tenant
if tnt == utils.EmptyString {
@@ -165,7 +165,7 @@ func (dS *DispatcherService) Dispatch(ev *utils.CGREvent, subsys string,
},
}
var dPrfls engine.DispatcherProfiles
if dPrfls, err = dS.dispatcherProfilesForEvent(context.TODO(), tnt, ev, evNm); err != nil {
if dPrfls, err = dS.dispatcherProfilesForEvent(ctx, tnt, ev, evNm); err != nil {
return utils.NewErrDispatcherS(err)
}
for _, dPrfl := range dPrfls {
@@ -178,10 +178,11 @@ func (dS *DispatcherService) Dispatch(ev *utils.CGREvent, subsys string,
} else if d, err = newDispatcher(dPrfl); err != nil {
return utils.NewErrDispatcherS(err)
}
if err = engine.Cache.Set(context.TODO(), utils.CacheDispatchers, tntID, d, nil, true, utils.EmptyString); err != nil {
if err = engine.Cache.Set(ctx, utils.CacheDispatchers, tntID, d, nil, true, utils.EmptyString); err != nil {
return utils.NewErrDispatcherS(err)
}
if err = d.Dispatch(dS.dm, dS.fltrS, context.TODO(), evNm, tnt, utils.IfaceAsString(ev.APIOpts[utils.OptsRouteID]), subsys, serviceMethod, args, reply); !rpcclient.IsNetworkError(err) {
if err = d.Dispatch(dS.dm, dS.fltrS, ctx, evNm, tnt, utils.IfaceAsString(ev.APIOpts[utils.OptsRouteID]),
subsys, serviceMethod, args, reply); !rpcclient.IsNetworkError(err) {
return
}
}
@@ -224,5 +225,5 @@ func (dS *DispatcherService) ping(ctx *context.Context, subsys, method string, a
return
}
}
return dS.Dispatch(args, subsys, method, args, reply)
return dS.Dispatch(ctx, args, subsys, method, args, reply)
}

10
dispatchers/dispatchers_test.go
View File

@@ -181,7 +181,7 @@ func TestDispatcherDispatch(t *testing.T) {
cfg.GeneralCfg().DefaultTenant = utils.EmptyString
dsp := NewDispatcherService(nil, cfg, nil, nil)
ev := &utils.CGREvent{}
err := dsp.Dispatch(ev, "", "", "", "")
err := dsp.Dispatch(context.TODO(), ev, "", "", "", "")
expected := "DISPATCHER_ERROR:NO_DATABASE_CONNECTION"
if err == nil || err.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, err)
@@ -768,7 +768,7 @@ func TestDispatcherServiceDispatchDspErr(t *testing.T) {
},
}
subsys := utils.IfaceAsString(ev.APIOpts[utils.Subsys])
err = dss.Dispatch(ev, subsys, "", "", "")
err = dss.Dispatch(context.TODO(), ev, subsys, "", "", "")
expected := "DISPATCHER_ERROR:unsupported dispatch strategy: <>"
if err == nil || err.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, err)
@@ -820,7 +820,7 @@ func TestDispatcherServiceDispatchDspErrHostNotFound(t *testing.T) {
},
}
subsys := utils.IfaceAsString(ev.APIOpts[utils.Subsys])
err = dss.Dispatch(ev, subsys, "", "", "")
err = dss.Dispatch(context.TODO(), ev, subsys, "", "", "")
expected := "HOST_NOT_FOUND"
if err == nil || err.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, err)
@@ -1015,7 +1015,7 @@ func TestDispatcherServiceDispatchDspErrHostNotFound2(t *testing.T) {
},
}
subsys := utils.IfaceAsString(ev.APIOpts[utils.Subsys])
err = dss.Dispatch(ev, subsys, "", "", "")
err = dss.Dispatch(context.TODO(), ev, subsys, "", "", "")
expected := "HOST_NOT_FOUND"
if err == nil || err.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, err)
@@ -1075,7 +1075,7 @@ func TestDispatcherServiceDispatchDspErrHostNotFound3(t *testing.T) {
},
}
subsys := utils.IfaceAsString(ev.APIOpts[utils.Subsys])
err = dss.Dispatch(ev, subsys, "", "", "")
err = dss.Dispatch(context.TODO(), ev, subsys, "", "", "")
expected := "DISPATCHER_ERROR:NOT_IMPLEMENTED"
if err == nil || err.Error() != expected {
t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, err)

7
dispatchers/guardian.go
View File

@@ -19,6 +19,7 @@ along with this program. If not, see <http://www.gnu.org/licenses/>
package dispatchers
import (
"github.com/cgrates/birpc/context"
"github.com/cgrates/cgrates/utils"
)
@@ -35,7 +36,7 @@ func (dS *DispatcherService) GuardianSv1Ping(args *utils.CGREvent,
return
}
}
return dS.Dispatch(args, utils.MetaGuardian, utils.GuardianSv1Ping, args, reply)
return dS.Dispatch(context.TODO(), args, utils.MetaGuardian, utils.GuardianSv1Ping, args, reply)
}
// GuardianSv1RemoteLock will lock a key from remote
@@ -51,7 +52,7 @@ func (dS *DispatcherService) GuardianSv1RemoteLock(args AttrRemoteLockWithAPIOpt
return
}
}
return dS.Dispatch(&utils.CGREvent{
return dS.Dispatch(context.TODO(), &utils.CGREvent{
Tenant: tnt,
APIOpts: args.APIOpts,
}, utils.MetaGuardian, utils.GuardianSv1RemoteLock, args, reply)
@@ -70,7 +71,7 @@ func (dS *DispatcherService) GuardianSv1RemoteUnlock(args AttrRemoteUnlockWithAP
return
}
}
return dS.Dispatch(&utils.CGREvent{
return dS.Dispatch(context.TODO(), &utils.CGREvent{
Tenant: tnt,
APIOpts: args.APIOpts,
}, utils.MetaGuardian, utils.GuardianSv1RemoteUnlock, args, reply)

5
dispatchers/rates.go
View File

@@ -19,6 +19,7 @@ along with this program. If not, see <http://www.gnu.org/licenses/>
package dispatchers
import (
"github.com/cgrates/birpc/context"
"github.com/cgrates/cgrates/utils"
)
@@ -33,7 +34,7 @@ func (dS *DispatcherService) RateSv1Ping(args *utils.CGREvent, rpl *string) (err
return
}
}
return dS.Dispatch(args, utils.RateS, utils.RateSv1Ping, args, rpl)
return dS.Dispatch(context.TODO(), args, utils.RateS, utils.RateSv1Ping, args, rpl)
}
func (dS *DispatcherService) RateSv1CostForEvent(args *utils.ArgsCostForEvent, rpCost *utils.RateProfileCost) (err error) {
@@ -49,5 +50,5 @@ func (dS *DispatcherService) RateSv1CostForEvent(args *utils.ArgsCostForEvent, r
return
}
}
return dS.Dispatch(args.CGREvent, utils.RateS, utils.RateSv1CostForEvent, args, rpCost)
return dS.Dispatch(context.TODO(), args.CGREvent, utils.RateS, utils.RateSv1CostForEvent, args, rpCost)
}

105
dispatchers/replicator.go
View File

@@ -19,6 +19,7 @@ along with this program. If not, see <http://www.gnu.org/licenses/>
package dispatchers
import (
"github.com/cgrates/birpc/context"
"github.com/cgrates/cgrates/engine"
"github.com/cgrates/cgrates/utils"
)
@@ -34,7 +35,7 @@ func (dS *DispatcherService) ReplicatorSv1Ping(args *utils.CGREvent, rpl *string
return
}
}
return dS.Dispatch(args, utils.MetaReplicator, utils.ReplicatorSv1Ping, args, rpl)
return dS.Dispatch(context.TODO(), args, utils.MetaReplicator, utils.ReplicatorSv1Ping, args, rpl)
}
func (dS *DispatcherService) ReplicatorSv1GetStatQueue(args *utils.TenantIDWithAPIOpts, reply *engine.StatQueue) (err error) {
@@ -48,7 +49,7 @@ func (dS *DispatcherService) ReplicatorSv1GetStatQueue(args *utils.TenantIDWithA
return
}
}
return dS.Dispatch(&utils.CGREvent{
return dS.Dispatch(context.TODO(), &utils.CGREvent{
Tenant: tnt,
ID: args.ID,
APIOpts: args.APIOpts,
@@ -66,7 +67,7 @@ func (dS *DispatcherService) ReplicatorSv1GetFilter(args *utils.TenantIDWithAPIO
return
}
}
return dS.Dispatch(&utils.CGREvent{
return dS.Dispatch(context.TODO(), &utils.CGREvent{
Tenant: tnt,
ID: args.ID,
APIOpts: args.APIOpts,
@@ -84,7 +85,7 @@ func (dS *DispatcherService) ReplicatorSv1GetThreshold(args *utils.TenantIDWithA
return
}
}
return dS.Dispatch(&utils.CGREvent{
return dS.Dispatch(context.TODO(), &utils.CGREvent{
Tenant: tnt,
ID: args.ID,
APIOpts: args.APIOpts,
@@ -102,7 +103,7 @@ func (dS *DispatcherService) ReplicatorSv1GetThresholdProfile(args *utils.Tenant
return
}
}
return dS.Dispatch(&utils.CGREvent{
return dS.Dispatch(context.TODO(), &utils.CGREvent{
Tenant: tnt,
ID: args.ID,
APIOpts: args.APIOpts,
@@ -120,7 +121,7 @@ func (dS *DispatcherService) ReplicatorSv1GetStatQueueProfile(args *utils.Tenant
return
}
}
return dS.Dispatch(&utils.CGREvent{
return dS.Dispatch(context.TODO(), &utils.CGREvent{
Tenant: tnt,
ID: args.ID,
APIOpts: args.APIOpts,
@@ -138,7 +139,7 @@ func (dS *DispatcherService) ReplicatorSv1GetResource(args *utils.TenantIDWithAP
return
}
}
return dS.Dispatch(&utils.CGREvent{
return dS.Dispatch(context.TODO(), &utils.CGREvent{
Tenant: tnt,
ID: args.ID,
APIOpts: args.APIOpts,
@@ -156,7 +157,7 @@ func (dS *DispatcherService) ReplicatorSv1GetResourceProfile(args *utils.TenantI
return
}
}
return dS.Dispatch(&utils.CGREvent{
return dS.Dispatch(context.TODO(), &utils.CGREvent{
Tenant: tnt,
ID: args.ID,
APIOpts: args.APIOpts,
@@ -174,7 +175,7 @@ func (dS *DispatcherService) ReplicatorSv1GetRouteProfile(args *utils.TenantIDWi
return
}
}
return dS.Dispatch(&utils.CGREvent{
return dS.Dispatch(context.TODO(), &utils.CGREvent{
Tenant: tnt,
ID: args.ID,
APIOpts: args.APIOpts,
@@ -192,7 +193,7 @@ func (dS *DispatcherService) ReplicatorSv1GetAttributeProfile(args *utils.Tenant
return
}
}
return dS.Dispatch(&utils.CGREvent{
return dS.Dispatch(context.TODO(), &utils.CGREvent{
Tenant: tnt,
ID: args.ID,
APIOpts: args.APIOpts,
@@ -210,7 +211,7 @@ func (dS *DispatcherService) ReplicatorSv1GetChargerProfile(args *utils.TenantID
return
}
}
return dS.Dispatch(&utils.CGREvent{
return dS.Dispatch(context.TODO(), &utils.CGREvent{
Tenant: tnt,
ID: args.ID,
APIOpts: args.APIOpts,
@@ -228,7 +229,7 @@ func (dS *DispatcherService) ReplicatorSv1GetDispatcherProfile(args *utils.Tenan
return
}
}
return dS.Dispatch(&utils.CGREvent{
return dS.Dispatch(context.TODO(), &utils.CGREvent{
Tenant: tnt,
ID: args.ID,
APIOpts: args.APIOpts,
@@ -246,7 +247,7 @@ func (dS *DispatcherService) ReplicatorSv1GetDispatcherHost(args *utils.TenantID
return
}
}
return dS.Dispatch(&utils.CGREvent{
return dS.Dispatch(context.TODO(), &utils.CGREvent{
Tenant: tnt,
ID: args.ID,
APIOpts: args.APIOpts,
@@ -264,7 +265,7 @@ func (dS *DispatcherService) ReplicatorSv1GetRateProfile(args *utils.TenantIDWit
return
}
}
return dS.Dispatch(&utils.CGREvent{
return dS.Dispatch(context.TODO(), &utils.CGREvent{
Tenant: tnt,
ID: args.ID,
APIOpts: args.APIOpts,
@@ -282,7 +283,7 @@ func (dS *DispatcherService) ReplicatorSv1GetActionProfile(args *utils.TenantIDW
return
}
}
return dS.Dispatch(&utils.CGREvent{
return dS.Dispatch(context.TODO(), &utils.CGREvent{
Tenant: tnt,
ID: args.ID,
APIOpts: args.APIOpts,
@@ -300,7 +301,7 @@ func (dS *DispatcherService) ReplicatorSv1GetItemLoadIDs(args *utils.StringWithA
return
}
}
return dS.Dispatch(&utils.CGREvent{
return dS.Dispatch(context.TODO(), &utils.CGREvent{
Tenant: args.Tenant,
APIOpts: args.APIOpts,
}, utils.MetaReplicator, utils.ReplicatorSv1GetItemLoadIDs, args, rpl)
@@ -319,7 +320,7 @@ func (dS *DispatcherService) ReplicatorSv1SetThresholdProfile(args *engine.Thres
return
}
}
return dS.Dispatch(&utils.CGREvent{
return dS.Dispatch(context.TODO(), &utils.CGREvent{
Tenant: args.ThresholdProfile.Tenant,
APIOpts: args.APIOpts,
}, utils.MetaReplicator, utils.ReplicatorSv1SetThresholdProfile, args, rpl)
@@ -338,7 +339,7 @@ func (dS *DispatcherService) ReplicatorSv1SetThreshold(args *engine.ThresholdWit
return
}
}
return dS.Dispatch(&utils.CGREvent{
return dS.Dispatch(context.TODO(), &utils.CGREvent{
Tenant: args.Tenant,
APIOpts: args.APIOpts,
}, utils.MetaReplicator, utils.ReplicatorSv1SetThreshold, args, rpl)
@@ -357,7 +358,7 @@ func (dS *DispatcherService) ReplicatorSv1SetStatQueue(args *engine.StatQueueWit
return
}
}
return dS.Dispatch(&utils.CGREvent{
return dS.Dispatch(context.TODO(), &utils.CGREvent{
Tenant: args.Tenant,
APIOpts: args.APIOpts,
}, utils.MetaReplicator, utils.ReplicatorSv1SetStatQueue, args, rpl)
@@ -376,7 +377,7 @@ func (dS *DispatcherService) ReplicatorSv1SetFilter(args *engine.FilterWithAPIOp
return
}
}
return dS.Dispatch(&utils.CGREvent{
return dS.Dispatch(context.TODO(), &utils.CGREvent{
Tenant: args.Tenant,
APIOpts: args.APIOpts,
}, utils.MetaReplicator, utils.ReplicatorSv1SetFilter, args, rpl)
@@ -396,7 +397,7 @@ func (dS *DispatcherService) ReplicatorSv1SetStatQueueProfile(args *engine.StatQ
return
}
}
return dS.Dispatch(&utils.CGREvent{
return dS.Dispatch(context.TODO(), &utils.CGREvent{
Tenant: args.Tenant,
APIOpts: args.APIOpts,
}, utils.MetaReplicator, utils.ReplicatorSv1SetStatQueueProfile, args, rpl)
@@ -416,7 +417,7 @@ func (dS *DispatcherService) ReplicatorSv1SetResource(args *engine.ResourceWithA
return
}
}
return dS.Dispatch(&utils.CGREvent{
return dS.Dispatch(context.TODO(), &utils.CGREvent{
Tenant: args.Tenant,
APIOpts: args.APIOpts,
}, utils.MetaReplicator, utils.ReplicatorSv1SetResource, args, rpl)
@@ -435,7 +436,7 @@ func (dS *DispatcherService) ReplicatorSv1SetResourceProfile(args *engine.Resour
return
}
}
return dS.Dispatch(&utils.CGREvent{
return dS.Dispatch(context.TODO(), &utils.CGREvent{
Tenant: args.Tenant,
APIOpts: args.APIOpts,
}, utils.MetaReplicator, utils.ReplicatorSv1SetResourceProfile, args, rpl)
@@ -454,7 +455,7 @@ func (dS *DispatcherService) ReplicatorSv1SetRouteProfile(args *engine.RouteProf
return
}
}
return dS.Dispatch(&utils.CGREvent{
return dS.Dispatch(context.TODO(), &utils.CGREvent{
Tenant: args.Tenant,
APIOpts: args.APIOpts,
}, utils.MetaReplicator, utils.ReplicatorSv1SetRouteProfile, args, rpl)
@@ -473,7 +474,7 @@ func (dS *DispatcherService) ReplicatorSv1SetAttributeProfile(args *engine.Attri
return
}
}
return dS.Dispatch(&utils.CGREvent{
return dS.Dispatch(context.TODO(), &utils.CGREvent{
Tenant: args.Tenant,
APIOpts: args.APIOpts,
}, utils.MetaReplicator, utils.ReplicatorSv1SetAttributeProfile, args, rpl)
@@ -492,7 +493,7 @@ func (dS *DispatcherService) ReplicatorSv1SetChargerProfile(args *engine.Charger
return
}
}
return dS.Dispatch(&utils.CGREvent{
return dS.Dispatch(context.TODO(), &utils.CGREvent{
Tenant: args.Tenant,
APIOpts: args.APIOpts,
}, utils.MetaReplicator, utils.ReplicatorSv1SetChargerProfile, args, rpl)
@@ -511,7 +512,7 @@ func (dS *DispatcherService) ReplicatorSv1SetDispatcherProfile(args *engine.Disp
return
}
}
return dS.Dispatch(&utils.CGREvent{
return dS.Dispatch(context.TODO(), &utils.CGREvent{
Tenant: args.Tenant,
APIOpts: args.APIOpts,
}, utils.MetaReplicator, utils.ReplicatorSv1SetDispatcherProfile, args, rpl)
@@ -530,7 +531,7 @@ func (dS *DispatcherService) ReplicatorSv1SetRateProfile(args *utils.RateProfile
return
}
}
return dS.Dispatch(&utils.CGREvent{
return dS.Dispatch(context.TODO(), &utils.CGREvent{
Tenant: args.Tenant,
APIOpts: args.APIOpts,
}, utils.MetaReplicator, utils.ReplicatorSv1SetRateProfile, args, rpl)
@@ -549,7 +550,7 @@ func (dS *DispatcherService) ReplicatorSv1SetActionProfile(args *engine.ActionPr
return
}
}
return dS.Dispatch(&utils.CGREvent{
return dS.Dispatch(context.TODO(), &utils.CGREvent{
Tenant: args.Tenant,
APIOpts: args.APIOpts,
}, utils.MetaReplicator, utils.ReplicatorSv1SetActionProfile, args, rpl)
@@ -568,7 +569,7 @@ func (dS *DispatcherService) ReplicatorSv1SetDispatcherHost(args *engine.Dispatc
return
}
}
return dS.Dispatch(&utils.CGREvent{
return dS.Dispatch(context.TODO(), &utils.CGREvent{
Tenant: args.Tenant,
APIOpts: args.APIOpts,
}, utils.MetaReplicator, utils.ReplicatorSv1SetDispatcherHost, args, rpl)
@@ -588,7 +589,7 @@ func (dS *DispatcherService) ReplicatorSv1RemoveThreshold(args *utils.TenantIDWi
return
}
}
return dS.Dispatch(&utils.CGREvent{
return dS.Dispatch(context.TODO(), &utils.CGREvent{
Tenant: args.Tenant,
APIOpts: args.APIOpts,
}, utils.MetaReplicator, utils.ReplicatorSv1RemoveThreshold, args, rpl)
@@ -605,7 +606,7 @@ func (dS *DispatcherService) ReplicatorSv1SetLoadIDs(args *utils.LoadIDsWithAPIO
return
}
}
return dS.Dispatch(&utils.CGREvent{
return dS.Dispatch(context.TODO(), &utils.CGREvent{
Tenant: args.Tenant,
APIOpts: args.APIOpts,
}, utils.MetaReplicator, utils.ReplicatorSv1SetLoadIDs, args, rpl)
@@ -624,7 +625,7 @@ func (dS *DispatcherService) ReplicatorSv1RemoveStatQueue(args *utils.TenantIDWi
return
}
}
return dS.Dispatch(&utils.CGREvent{
return dS.Dispatch(context.TODO(), &utils.CGREvent{
Tenant: args.Tenant,
APIOpts: args.APIOpts,
}, utils.MetaReplicator, utils.ReplicatorSv1RemoveStatQueue, args, rpl)
@@ -643,7 +644,7 @@ func (dS *DispatcherService) ReplicatorSv1RemoveFilter(args *utils.TenantIDWithA
return
}
}
return dS.Dispatch(&utils.CGREvent{
return dS.Dispatch(context.TODO(), &utils.CGREvent{
Tenant: args.Tenant,
APIOpts: args.APIOpts,
}, utils.MetaReplicator, utils.ReplicatorSv1RemoveFilter, args, rpl)
@@ -662,7 +663,7 @@ func (dS *DispatcherService) ReplicatorSv1RemoveThresholdProfile(args *utils.Ten
return
}
}
return dS.Dispatch(&utils.CGREvent{
return dS.Dispatch(context.TODO(), &utils.CGREvent{
Tenant: args.Tenant,
APIOpts: args.APIOpts,
}, utils.MetaReplicator, utils.ReplicatorSv1RemoveThresholdProfile, args, rpl)
@@ -681,7 +682,7 @@ func (dS *DispatcherService) ReplicatorSv1RemoveStatQueueProfile(args *utils.Ten
return
}
}
return dS.Dispatch(&utils.CGREvent{
return dS.Dispatch(context.TODO(), &utils.CGREvent{
Tenant: args.Tenant,
APIOpts: args.APIOpts,
}, utils.MetaReplicator, utils.ReplicatorSv1RemoveStatQueueProfile, args, rpl)
@@ -701,7 +702,7 @@ func (dS *DispatcherService) ReplicatorSv1RemoveResource(args *utils.TenantIDWit
return
}
}
return dS.Dispatch(&utils.CGREvent{
return dS.Dispatch(context.TODO(), &utils.CGREvent{
Tenant: args.Tenant,
APIOpts: args.APIOpts,
}, utils.MetaReplicator, utils.ReplicatorSv1RemoveResource, args, rpl)
@@ -720,7 +721,7 @@ func (dS *DispatcherService) ReplicatorSv1RemoveResourceProfile(args *utils.Tena
return
}
}
return dS.Dispatch(&utils.CGREvent{
return dS.Dispatch(context.TODO(), &utils.CGREvent{
Tenant: args.Tenant,
APIOpts: args.APIOpts,
}, utils.MetaReplicator, utils.ReplicatorSv1RemoveResourceProfile, args, rpl)
@@ -737,7 +738,7 @@ func (dS *DispatcherService) ReplicatorSv1RemoveActions(args *utils.StringWithAP
return
}
}
return dS.Dispatch(&utils.CGREvent{
return dS.Dispatch(context.TODO(), &utils.CGREvent{
Tenant: args.Tenant,
APIOpts: args.APIOpts,
}, utils.MetaReplicator, utils.ReplicatorSv1RemoveActions, args, rpl)
@@ -757,7 +758,7 @@ func (dS *DispatcherService) ReplicatorSv1RemoveRouteProfile(args *utils.TenantI
return
}
}
return dS.Dispatch(&utils.CGREvent{
return dS.Dispatch(context.TODO(), &utils.CGREvent{
Tenant: args.Tenant,
APIOpts: args.APIOpts,
}, utils.MetaReplicator, utils.ReplicatorSv1RemoveRouteProfile, args, rpl)
@@ -776,7 +777,7 @@ func (dS *DispatcherService) ReplicatorSv1RemoveAttributeProfile(args *utils.Ten
return
}
}
return dS.Dispatch(&utils.CGREvent{
return dS.Dispatch(context.TODO(), &utils.CGREvent{
Tenant: args.Tenant,
APIOpts: args.APIOpts,
}, utils.MetaReplicator, utils.ReplicatorSv1RemoveAttributeProfile, args, rpl)
@@ -795,7 +796,7 @@ func (dS *DispatcherService) ReplicatorSv1RemoveChargerProfile(args *utils.Tenan
return
}
}
return dS.Dispatch(&utils.CGREvent{
return dS.Dispatch(context.TODO(), &utils.CGREvent{
Tenant: args.Tenant,
APIOpts: args.APIOpts,
}, utils.MetaReplicator, utils.ReplicatorSv1RemoveChargerProfile, args, rpl)
@@ -814,7 +815,7 @@ func (dS *DispatcherService) ReplicatorSv1RemoveDispatcherProfile(args *utils.Te
return
}
}
return dS.Dispatch(&utils.CGREvent{
return dS.Dispatch(context.TODO(), &utils.CGREvent{
Tenant: args.Tenant,
APIOpts: args.APIOpts,
}, utils.MetaReplicator, utils.ReplicatorSv1RemoveDispatcherProfile, args, rpl)
@@ -833,7 +834,7 @@ func (dS *DispatcherService) ReplicatorSv1RemoveDispatcherHost(args *utils.Tenan
return
}
}
return dS.Dispatch(&utils.CGREvent{
return dS.Dispatch(context.TODO(), &utils.CGREvent{
Tenant: args.Tenant,
APIOpts: args.APIOpts,
}, utils.MetaReplicator, utils.ReplicatorSv1RemoveDispatcherHost, args, rpl)
@@ -852,7 +853,7 @@ func (dS *DispatcherService) ReplicatorSv1RemoveRateProfile(args *utils.TenantID
return
}
}
return dS.Dispatch(&utils.CGREvent{
return dS.Dispatch(context.TODO(), &utils.CGREvent{
Tenant: args.Tenant,
APIOpts: args.APIOpts,
}, utils.MetaReplicator, utils.ReplicatorSv1RemoveRateProfile, args, rpl)
@@ -871,7 +872,7 @@ func (dS *DispatcherService) ReplicatorSv1RemoveActionProfile(args *utils.Tenant
return
}
}
return dS.Dispatch(&utils.CGREvent{
return dS.Dispatch(context.TODO(), &utils.CGREvent{
Tenant: args.Tenant,
APIOpts: args.APIOpts,
}, utils.MetaReplicator, utils.ReplicatorSv1RemoveActionProfile, args, rpl)
@@ -889,7 +890,7 @@ func (dS *DispatcherService) ReplicatorSv1GetIndexes(args *utils.GetIndexesArg,
return
}
}
return dS.Dispatch(&utils.CGREvent{
return dS.Dispatch(context.TODO(), &utils.CGREvent{
Tenant: args.Tenant,
APIOpts: args.APIOpts,
}, utils.MetaReplicator, utils.ReplicatorSv1GetIndexes, args, reply)
@@ -907,7 +908,7 @@ func (dS *DispatcherService) ReplicatorSv1SetIndexes(args *utils.SetIndexesArg,
return
}
}
return dS.Dispatch(&utils.CGREvent{
return dS.Dispatch(context.TODO(), &utils.CGREvent{
Tenant: args.Tenant,
APIOpts: args.APIOpts,
}, utils.MetaReplicator, utils.ReplicatorSv1SetIndexes, args, reply)
@@ -925,7 +926,7 @@ func (dS *DispatcherService) ReplicatorSv1RemoveIndexes(args *utils.GetIndexesAr
return
}
}
return dS.Dispatch(&utils.CGREvent{
return dS.Dispatch(context.TODO(), &utils.CGREvent{
Tenant: args.Tenant,
APIOpts: args.APIOpts,
}, utils.MetaReplicator, utils.ReplicatorSv1RemoveIndexes, args, reply)
@@ -942,7 +943,7 @@ func (dS *DispatcherService) ReplicatorSv1GetAccount(args *utils.TenantIDWithAPI
return
}
}
return dS.Dispatch(&utils.CGREvent{
return dS.Dispatch(context.TODO(), &utils.CGREvent{
Tenant: tnt,
ID: args.ID,
APIOpts: args.APIOpts,
@@ -962,7 +963,7 @@ func (dS *DispatcherService) ReplicatorSv1SetAccount(args *utils.AccountWithAPIO
return
}
}
return dS.Dispatch(&utils.CGREvent{
return dS.Dispatch(context.TODO(), &utils.CGREvent{
Tenant: args.Tenant,
APIOpts: args.APIOpts,
}, utils.MetaReplicator, utils.ReplicatorSv1SetAccount, args, rpl)
@@ -981,7 +982,7 @@ func (dS *DispatcherService) ReplicatorSv1RemoveAccount(args *utils.TenantIDWith
return
}
}
return dS.Dispatch(&utils.CGREvent{
return dS.Dispatch(context.TODO(), &utils.CGREvent{
Tenant: args.Tenant,
APIOpts: args.APIOpts,
}, utils.MetaReplicator, utils.ReplicatorSv1RemoveAccount, args, rpl)

15
dispatchers/resources.go
View File

@@ -19,6 +19,7 @@ along with this program. If not, see <http://www.gnu.org/licenses/>
package dispatchers
import (
"github.com/cgrates/birpc/context"
"github.com/cgrates/cgrates/engine"
"github.com/cgrates/cgrates/utils"
)
@@ -34,7 +35,7 @@ func (dS *DispatcherService) ResourceSv1Ping(args *utils.CGREvent, rpl *string)
return
}
}
return dS.Dispatch(args, utils.MetaResources, utils.ResourceSv1Ping, args, rpl)
return dS.Dispatch(context.TODO(), args, utils.MetaResources, utils.ResourceSv1Ping, args, rpl)
}
func (dS *DispatcherService) ResourceSv1GetResourcesForEvent(args utils.ArgRSv1ResourceUsage,
@@ -49,7 +50,7 @@ func (dS *DispatcherService) ResourceSv1GetResourcesForEvent(args utils.ArgRSv1R
return
}
}
return dS.Dispatch(args.CGREvent, utils.MetaResources, utils.ResourceSv1GetResourcesForEvent, args, reply)
return dS.Dispatch(context.TODO(), args.CGREvent, utils.MetaResources, utils.ResourceSv1GetResourcesForEvent, args, reply)
}
func (dS *DispatcherService) ResourceSv1AuthorizeResources(args utils.ArgRSv1ResourceUsage,
@@ -64,7 +65,7 @@ func (dS *DispatcherService) ResourceSv1AuthorizeResources(args utils.ArgRSv1Res
return
}
}
return dS.Dispatch(args.CGREvent, utils.MetaResources, utils.ResourceSv1AuthorizeResources, args, reply)
return dS.Dispatch(context.TODO(), args.CGREvent, utils.MetaResources, utils.ResourceSv1AuthorizeResources, args, reply)
}
func (dS *DispatcherService) ResourceSv1AllocateResources(args utils.ArgRSv1ResourceUsage,
@@ -79,7 +80,7 @@ func (dS *DispatcherService) ResourceSv1AllocateResources(args utils.ArgRSv1Reso
return
}
}
return dS.Dispatch(args.CGREvent, utils.MetaResources, utils.ResourceSv1AllocateResources, args, reply)
return dS.Dispatch(context.TODO(), args.CGREvent, utils.MetaResources, utils.ResourceSv1AllocateResources, args, reply)
}
func (dS *DispatcherService) ResourceSv1ReleaseResources(args utils.ArgRSv1ResourceUsage,
@@ -94,7 +95,7 @@ func (dS *DispatcherService) ResourceSv1ReleaseResources(args utils.ArgRSv1Resou
return
}
}
return dS.Dispatch(args.CGREvent, utils.MetaResources, utils.ResourceSv1ReleaseResources, args, reply)
return dS.Dispatch(context.TODO(), args.CGREvent, utils.MetaResources, utils.ResourceSv1ReleaseResources, args, reply)
}
func (dS *DispatcherService) ResourceSv1GetResource(args *utils.TenantIDWithAPIOpts, reply *engine.Resource) (err error) {
@@ -108,7 +109,7 @@ func (dS *DispatcherService) ResourceSv1GetResource(args *utils.TenantIDWithAPIO
return
}
}
return dS.Dispatch(&utils.CGREvent{
return dS.Dispatch(context.TODO(), &utils.CGREvent{
Tenant: tnt,
ID: args.ID,
APIOpts: args.APIOpts,
@@ -126,7 +127,7 @@ func (dS *DispatcherService) ResourceSv1GetResourceWithConfig(args *utils.Tenant
return
}
}
return dS.Dispatch(&utils.CGREvent{
return dS.Dispatch(context.TODO(), &utils.CGREvent{
Tenant: tnt,
ID: args.ID,
APIOpts: args.APIOpts,

9
dispatchers/routes.go
View File

@@ -19,6 +19,7 @@ along with this program. If not, see <http://www.gnu.org/licenses/>
package dispatchers
import (
"github.com/cgrates/birpc/context"
"github.com/cgrates/cgrates/engine"
"github.com/cgrates/cgrates/utils"
)
@@ -35,7 +36,7 @@ func (dS *DispatcherService) RouteSv1Ping(args *utils.CGREvent, reply *string) (
return
}
}
return dS.Dispatch(args, utils.MetaRoutes, utils.RouteSv1Ping, args, reply)
return dS.Dispatch(context.TODO(), args, utils.MetaRoutes, utils.RouteSv1Ping, args, reply)
}
func (dS *DispatcherService) RouteSv1GetRoutes(args *engine.ArgsGetRoutes, reply *engine.SortedRoutesList) (err error) {
@@ -47,7 +48,7 @@ func (dS *DispatcherService) RouteSv1GetRoutes(args *engine.ArgsGetRoutes, reply
return
}
}
return dS.Dispatch(args.CGREvent, utils.MetaRoutes, utils.RouteSv1GetRoutes, args, reply)
return dS.Dispatch(context.TODO(), args.CGREvent, utils.MetaRoutes, utils.RouteSv1GetRoutes, args, reply)
}
func (dS *DispatcherService) RouteSv1GetRoutesList(args *engine.ArgsGetRoutes, reply *[]string) (err error) {
@@ -59,7 +60,7 @@ func (dS *DispatcherService) RouteSv1GetRoutesList(args *engine.ArgsGetRoutes, r
return
}
}
return dS.Dispatch(args.CGREvent, utils.MetaRoutes, utils.RouteSv1GetRoutesList, args, reply)
return dS.Dispatch(context.TODO(), args.CGREvent, utils.MetaRoutes, utils.RouteSv1GetRoutesList, args, reply)
}
func (dS *DispatcherService) RouteSv1GetRouteProfilesForEvent(args *utils.CGREvent, reply *[]*engine.RouteProfile) (err error) {
@@ -71,5 +72,5 @@ func (dS *DispatcherService) RouteSv1GetRouteProfilesForEvent(args *utils.CGREve
return
}
}
return dS.Dispatch(args, utils.MetaRoutes, utils.RouteSv1GetRouteProfilesForEvent, args, reply)
return dS.Dispatch(context.TODO(), args, utils.MetaRoutes, utils.RouteSv1GetRouteProfilesForEvent, args, reply)
}

3
dispatchers/servicemanager.go
View File

@@ -19,6 +19,7 @@ along with this program. If not, see <http://www.gnu.org/licenses/>
package dispatchers
import (
"github.com/cgrates/birpc/context"
"github.com/cgrates/cgrates/utils"
)
@@ -35,5 +36,5 @@ func (dS *DispatcherService) ServiceManagerV1Ping(args *utils.CGREvent,
return
}
}
return dS.Dispatch(args, utils.MetaServiceManager, utils.ServiceManagerV1Ping, args, reply)
return dS.Dispatch(context.TODO(), args, utils.MetaServiceManager, utils.ServiceManagerV1Ping, args, reply)
}

45
dispatchers/sessions.go
View File

@@ -19,6 +19,7 @@ along with this program. If not, see <http://www.gnu.org/licenses/>
package dispatchers
import (
"github.com/cgrates/birpc/context"
"github.com/cgrates/cgrates/sessions"
"github.com/cgrates/cgrates/utils"
)
@@ -31,7 +32,7 @@ func (dS *DispatcherService) SessionSv1Ping(args *utils.CGREvent, reply *string)
return
}
}
return dS.Dispatch(args, utils.MetaSessionS, utils.SessionSv1Ping, args, reply)
return dS.Dispatch(context.TODO(), args, utils.MetaSessionS, utils.SessionSv1Ping, args, reply)
}
func (dS *DispatcherService) SessionSv1AuthorizeEvent(args *sessions.V1AuthorizeArgs,
@@ -43,7 +44,7 @@ func (dS *DispatcherService) SessionSv1AuthorizeEvent(args *sessions.V1Authorize
return
}
}
return dS.Dispatch(args.CGREvent, utils.MetaSessionS, utils.SessionSv1AuthorizeEvent, args, reply)
return dS.Dispatch(context.TODO(), args.CGREvent, utils.MetaSessionS, utils.SessionSv1AuthorizeEvent, args, reply)
}
func (dS *DispatcherService) SessionSv1AuthorizeEventWithDigest(args *sessions.V1AuthorizeArgs,
@@ -55,7 +56,7 @@ func (dS *DispatcherService) SessionSv1AuthorizeEventWithDigest(args *sessions.V
return
}
}
return dS.Dispatch(args.CGREvent, utils.MetaSessionS, utils.SessionSv1AuthorizeEventWithDigest, args, reply)
return dS.Dispatch(context.TODO(), args.CGREvent, utils.MetaSessionS, utils.SessionSv1AuthorizeEventWithDigest, args, reply)
}
func (dS *DispatcherService) SessionSv1InitiateSession(args *sessions.V1InitSessionArgs,
@@ -67,7 +68,7 @@ func (dS *DispatcherService) SessionSv1InitiateSession(args *sessions.V1InitSess
return
}
}
return dS.Dispatch(args.CGREvent, utils.MetaSessionS, utils.SessionSv1InitiateSession, args, reply)
return dS.Dispatch(context.TODO(), args.CGREvent, utils.MetaSessionS, utils.SessionSv1InitiateSession, args, reply)
}
func (dS *DispatcherService) SessionSv1InitiateSessionWithDigest(args *sessions.V1InitSessionArgs,
@@ -79,7 +80,7 @@ func (dS *DispatcherService) SessionSv1InitiateSessionWithDigest(args *sessions.
return
}
}
return dS.Dispatch(args.CGREvent, utils.MetaSessionS, utils.SessionSv1InitiateSessionWithDigest, args, reply)
return dS.Dispatch(context.TODO(), args.CGREvent, utils.MetaSessionS, utils.SessionSv1InitiateSessionWithDigest, args, reply)
}
func (dS *DispatcherService) SessionSv1UpdateSession(args *sessions.V1UpdateSessionArgs,
@@ -91,7 +92,7 @@ func (dS *DispatcherService) SessionSv1UpdateSession(args *sessions.V1UpdateSess
return
}
}
return dS.Dispatch(args.CGREvent, utils.MetaSessionS, utils.SessionSv1UpdateSession, args, reply)
return dS.Dispatch(context.TODO(), args.CGREvent, utils.MetaSessionS, utils.SessionSv1UpdateSession, args, reply)
}
func (dS *DispatcherService) SessionSv1SyncSessions(args *utils.TenantWithAPIOpts,
@@ -106,7 +107,7 @@ func (dS *DispatcherService) SessionSv1SyncSessions(args *utils.TenantWithAPIOpt
return
}
}
return dS.Dispatch(&utils.CGREvent{
return dS.Dispatch(context.TODO(), &utils.CGREvent{
Tenant: tnt,
APIOpts: args.APIOpts,
}, utils.MetaSessionS, utils.SessionSv1SyncSessions, args, reply)
@@ -121,7 +122,7 @@ func (dS *DispatcherService) SessionSv1TerminateSession(args *sessions.V1Termina
return
}
}
return dS.Dispatch(args.CGREvent, utils.MetaSessionS, utils.SessionSv1TerminateSession, args, reply)
return dS.Dispatch(context.TODO(), args.CGREvent, utils.MetaSessionS, utils.SessionSv1TerminateSession, args, reply)
}
func (dS *DispatcherService) SessionSv1ProcessCDR(args *utils.CGREvent,
@@ -133,7 +134,7 @@ func (dS *DispatcherService) SessionSv1ProcessCDR(args *utils.CGREvent,
return
}
}
return dS.Dispatch(args, utils.MetaSessionS, utils.SessionSv1ProcessCDR, args, reply)
return dS.Dispatch(context.TODO(), args, utils.MetaSessionS, utils.SessionSv1ProcessCDR, args, reply)
}
func (dS *DispatcherService) SessionSv1ProcessMessage(args *sessions.V1ProcessMessageArgs,
@@ -145,7 +146,7 @@ func (dS *DispatcherService) SessionSv1ProcessMessage(args *sessions.V1ProcessMe
return
}
}
return dS.Dispatch(args.CGREvent, utils.MetaSessionS, utils.SessionSv1ProcessMessage, args, reply)
return dS.Dispatch(context.TODO(), args.CGREvent, utils.MetaSessionS, utils.SessionSv1ProcessMessage, args, reply)
}
func (dS *DispatcherService) SessionSv1ProcessEvent(args *sessions.V1ProcessEventArgs,
@@ -157,7 +158,7 @@ func (dS *DispatcherService) SessionSv1ProcessEvent(args *sessions.V1ProcessEven
return
}
}
return dS.Dispatch(args.CGREvent, utils.MetaSessionS, utils.SessionSv1ProcessEvent, args, reply)
return dS.Dispatch(context.TODO(), args.CGREvent, utils.MetaSessionS, utils.SessionSv1ProcessEvent, args, reply)
}
func (dS *DispatcherService) SessionSv1GetActiveSessions(args *utils.SessionFilter,
@@ -172,7 +173,7 @@ func (dS *DispatcherService) SessionSv1GetActiveSessions(args *utils.SessionFilt
return
}
}
return dS.Dispatch(&utils.CGREvent{
return dS.Dispatch(context.TODO(), &utils.CGREvent{
Tenant: tnt,
APIOpts: args.APIOpts,
}, utils.MetaSessionS, utils.SessionSv1GetActiveSessions, args, reply)
@@ -190,7 +191,7 @@ func (dS *DispatcherService) SessionSv1GetActiveSessionsCount(args *utils.Sessio
return
}
}
return dS.Dispatch(&utils.CGREvent{
return dS.Dispatch(context.TODO(), &utils.CGREvent{
Tenant: tnt,
APIOpts: args.APIOpts,
}, utils.MetaSessionS, utils.SessionSv1GetActiveSessionsCount, args, reply)
@@ -208,7 +209,7 @@ func (dS *DispatcherService) SessionSv1ForceDisconnect(args *utils.SessionFilter
return
}
}
return dS.Dispatch(&utils.CGREvent{
return dS.Dispatch(context.TODO(), &utils.CGREvent{
Tenant: tnt,
APIOpts: args.APIOpts,
}, utils.MetaSessionS, utils.SessionSv1ForceDisconnect, args, reply)
@@ -226,7 +227,7 @@ func (dS *DispatcherService) SessionSv1GetPassiveSessions(args *utils.SessionFil
return
}
}
return dS.Dispatch(&utils.CGREvent{
return dS.Dispatch(context.TODO(), &utils.CGREvent{
Tenant: tnt,
APIOpts: args.APIOpts,
}, utils.MetaSessionS, utils.SessionSv1GetPassiveSessions, args, reply)
@@ -244,7 +245,7 @@ func (dS *DispatcherService) SessionSv1GetPassiveSessionsCount(args *utils.Sessi
return
}
}
return dS.Dispatch(&utils.CGREvent{
return dS.Dispatch(context.TODO(), &utils.CGREvent{
Tenant: tnt,
APIOpts: args.APIOpts,
}, utils.MetaSessionS, utils.SessionSv1GetPassiveSessionsCount, args, reply)
@@ -262,7 +263,7 @@ func (dS *DispatcherService) SessionSv1ReplicateSessions(args ArgsReplicateSessi
return
}
}
return dS.Dispatch(&utils.CGREvent{
return dS.Dispatch(context.TODO(), &utils.CGREvent{
Tenant: tnt,
APIOpts: args.APIOpts,
}, utils.MetaSessionS, utils.SessionSv1ReplicateSessions, args, reply)
@@ -280,7 +281,7 @@ func (dS *DispatcherService) SessionSv1SetPassiveSession(args *sessions.Session,
return
}
}
return dS.Dispatch(&utils.CGREvent{
return dS.Dispatch(context.TODO(), &utils.CGREvent{
Tenant: tnt,
APIOpts: args.OptsStart,
}, utils.MetaSessionS, utils.SessionSv1SetPassiveSession, args, reply)
@@ -297,7 +298,7 @@ func (dS *DispatcherService) SessionSv1ActivateSessions(args *utils.SessionIDsWi
return
}
}
return dS.Dispatch(&utils.CGREvent{
return dS.Dispatch(context.TODO(), &utils.CGREvent{
Tenant: tnt,
APIOpts: args.APIOpts,
}, utils.MetaSessionS, utils.SessionSv1ActivateSessions, args, reply)
@@ -314,7 +315,7 @@ func (dS *DispatcherService) SessionSv1DeactivateSessions(args *utils.SessionIDs
return
}
}
return dS.Dispatch(&utils.CGREvent{
return dS.Dispatch(context.TODO(), &utils.CGREvent{
Tenant: tnt,
APIOpts: args.APIOpts,
}, utils.MetaSessionS, utils.SessionSv1DeactivateSessions, args, reply)
@@ -328,7 +329,7 @@ func (dS *DispatcherService) SessionSv1STIRAuthenticate(args *sessions.V1STIRAut
return
}
}
return dS.Dispatch(&utils.CGREvent{
return dS.Dispatch(context.TODO(), &utils.CGREvent{
Tenant: tnt,
APIOpts: args.APIOpts,
}, utils.MetaSessionS, utils.SessionSv1STIRAuthenticate, args, reply)
@@ -342,7 +343,7 @@ func (dS *DispatcherService) SessionSv1STIRIdentity(args *sessions.V1STIRIdentit
return
}
}
return dS.Dispatch(&utils.CGREvent{
return dS.Dispatch(context.TODO(), &utils.CGREvent{
Tenant: tnt,
APIOpts: args.APIOpts,
}, utils.MetaSessionS, utils.SessionSv1STIRIdentity, args, reply)

13
dispatchers/stats.go
View File

@@ -19,6 +19,7 @@ along with this program. If not, see <http://www.gnu.org/licenses/>
package dispatchers
import (
"github.com/cgrates/birpc/context"
"github.com/cgrates/cgrates/engine"
"github.com/cgrates/cgrates/utils"
)
@@ -35,7 +36,7 @@ func (dS *DispatcherService) StatSv1Ping(args *utils.CGREvent, reply *string) (e
return
}
}
return dS.Dispatch(args, utils.MetaStats, utils.StatSv1Ping, args, reply)
return dS.Dispatch(context.TODO(), args, utils.MetaStats, utils.StatSv1Ping, args, reply)
}
func (dS *DispatcherService) StatSv1GetStatQueuesForEvent(args *engine.StatsArgsProcessEvent,
@@ -48,7 +49,7 @@ func (dS *DispatcherService) StatSv1GetStatQueuesForEvent(args *engine.StatsArgs
return
}
}
return dS.Dispatch(args.CGREvent, utils.MetaStats, utils.StatSv1GetStatQueuesForEvent, args, reply)
return dS.Dispatch(context.TODO(), args.CGREvent, utils.MetaStats, utils.StatSv1GetStatQueuesForEvent, args, reply)
}
func (dS *DispatcherService) StatSv1GetQueueStringMetrics(args *utils.TenantIDWithAPIOpts,
@@ -61,7 +62,7 @@ func (dS *DispatcherService) StatSv1GetQueueStringMetrics(args *utils.TenantIDWi
return
}
}
return dS.Dispatch(&utils.CGREvent{
return dS.Dispatch(context.TODO(), &utils.CGREvent{
Tenant: args.Tenant,
ID: args.ID,
APIOpts: args.APIOpts,
@@ -78,7 +79,7 @@ func (dS *DispatcherService) StatSv1ProcessEvent(args *engine.StatsArgsProcessEv
return
}
}
return dS.Dispatch(args.CGREvent, utils.MetaStats, utils.StatSv1ProcessEvent, args, reply)
return dS.Dispatch(context.TODO(), args.CGREvent, utils.MetaStats, utils.StatSv1ProcessEvent, args, reply)
}
func (dS *DispatcherService) StatSv1GetQueueFloatMetrics(args *utils.TenantIDWithAPIOpts,
@@ -90,7 +91,7 @@ func (dS *DispatcherService) StatSv1GetQueueFloatMetrics(args *utils.TenantIDWit
return
}
}
return dS.Dispatch(&utils.CGREvent{
return dS.Dispatch(context.TODO(), &utils.CGREvent{
Tenant: args.Tenant,
ID: args.ID,
APIOpts: args.APIOpts,
@@ -109,7 +110,7 @@ func (dS *DispatcherService) StatSv1GetQueueIDs(args *utils.TenantWithAPIOpts,
return
}
}
return dS.Dispatch(&utils.CGREvent{
return dS.Dispatch(context.TODO(), &utils.CGREvent{
Tenant: tnt,
APIOpts: args.APIOpts,
}, utils.MetaStats, utils.StatSv1GetQueueIDs, args, reply)

11
dispatchers/thresholds.go
View File

@@ -19,6 +19,7 @@ along with this program. If not, see <http://www.gnu.org/licenses/>
package dispatchers
import (
"github.com/cgrates/birpc/context"
"github.com/cgrates/cgrates/engine"
"github.com/cgrates/cgrates/utils"
)
@@ -34,7 +35,7 @@ func (dS *DispatcherService) ThresholdSv1Ping(args *utils.CGREvent, reply *strin
return
}
}
return dS.Dispatch(args, utils.MetaThresholds, utils.ThresholdSv1Ping, args, reply)
return dS.Dispatch(context.TODO(), args, utils.MetaThresholds, utils.ThresholdSv1Ping, args, reply)
}
func (dS *DispatcherService) ThresholdSv1GetThresholdsForEvent(args *engine.ThresholdsArgsProcessEvent,
@@ -47,7 +48,7 @@ func (dS *DispatcherService) ThresholdSv1GetThresholdsForEvent(args *engine.Thre
return
}
}
return dS.Dispatch(args.CGREvent, utils.MetaThresholds, utils.ThresholdSv1GetThresholdsForEvent, args, t)
return dS.Dispatch(context.TODO(), args.CGREvent, utils.MetaThresholds, utils.ThresholdSv1GetThresholdsForEvent, args, t)
}
func (dS *DispatcherService) ThresholdSv1ProcessEvent(args *engine.ThresholdsArgsProcessEvent,
@@ -60,7 +61,7 @@ func (dS *DispatcherService) ThresholdSv1ProcessEvent(args *engine.ThresholdsArg
return
}
}
return dS.Dispatch(args.CGREvent, utils.MetaThresholds, utils.ThresholdSv1ProcessEvent, args, tIDs)
return dS.Dispatch(context.TODO(), args.CGREvent, utils.MetaThresholds, utils.ThresholdSv1ProcessEvent, args, tIDs)
}
func (dS *DispatcherService) ThresholdSv1GetThresholdIDs(args *utils.TenantWithAPIOpts, tIDs *[]string) (err error) {
@@ -74,7 +75,7 @@ func (dS *DispatcherService) ThresholdSv1GetThresholdIDs(args *utils.TenantWithA
return
}
}
return dS.Dispatch(&utils.CGREvent{
return dS.Dispatch(context.TODO(), &utils.CGREvent{
Tenant: tnt,
APIOpts: args.APIOpts,
}, utils.MetaThresholds, utils.ThresholdSv1GetThresholdIDs, args, tIDs)
@@ -91,7 +92,7 @@ func (dS *DispatcherService) ThresholdSv1GetThreshold(args *utils.TenantIDWithAP
return
}
}
return dS.Dispatch(&utils.CGREvent{
return dS.Dispatch(context.TODO(), &utils.CGREvent{
Tenant: tnt,
ID: args.ID,
APIOpts: args.APIOpts,

2
services/attributes_it_test.go
View File

@@ -55,7 +55,7 @@ func TestAttributeSReload(t *testing.T) {
anz := NewAnalyzerService(cfg, server, filterSChan, shdChan, make(chan birpc.ClientConnector, 1), srvDep)
attrS := NewAttributeService(cfg, db,
chS, filterSChan, server, attrRPC,
anz, srvDep)
anz, &DispatcherService{srvsReload: make(map[string]chan struct{})}, srvDep)
engine.NewConnManager(cfg, nil)
srvMngr.AddServices(attrS,
NewLoaderService(cfg, db, filterSChan, server, make(chan birpc.ClientConnector, 1), nil, anz, srvDep), db)

2
services/chargers_it_test.go
View File

@@ -54,7 +54,7 @@ func TestChargerSReload(t *testing.T) {
srvMngr := servmanager.NewServiceManager(cfg, shdChan, shdWg, nil)
db := NewDataDBService(cfg, nil, srvDep)
anz := NewAnalyzerService(cfg, server, filterSChan, shdChan, make(chan birpc.ClientConnector, 1), srvDep)
attrS := NewAttributeService(cfg, db, chS, filterSChan, server, make(chan birpc.ClientConnector, 1), anz, srvDep)
attrS := NewAttributeService(cfg, db, chS, filterSChan, server, make(chan birpc.ClientConnector, 1), anz, &DispatcherService{srvsReload: make(map[string]chan struct{})}, srvDep)
chrS := NewChargerService(cfg, db, chS, filterSChan, server, make(chan birpc.ClientConnector, 1), nil, anz, srvDep)
engine.NewConnManager(cfg, nil)
srvMngr.AddServices(attrS, chrS,

2
services/datadb_it_test.go
View File

@@ -55,7 +55,7 @@ func TestDataDBReload(t *testing.T) {
db := NewDataDBService(cfg, cM, srvDep)
anz := NewAnalyzerService(cfg, server, filterSChan, shdChan, make(chan birpc.ClientConnector, 1), srvDep)
srvMngr.AddServices(NewAttributeService(cfg, db,
chS, filterSChan, server, make(chan birpc.ClientConnector, 1), anz, srvDep),
chS, filterSChan, server, make(chan birpc.ClientConnector, 1), anz, &DispatcherService{srvsReload: make(map[string]chan struct{})}, srvDep),
NewLoaderService(cfg, db, filterSChan, server, make(chan birpc.ClientConnector, 1), nil, anz, srvDep), db)
if err := srvMngr.StartServices(); err != nil {
t.Error(err)

2
services/dispatchers_it_test.go
View File

@@ -55,9 +55,9 @@ func TestDispatcherSReload(t *testing.T) {
srvDep := map[string]*sync.WaitGroup{utils.DataDB: new(sync.WaitGroup)}
db := NewDataDBService(cfg, nil, srvDep)
anz := NewAnalyzerService(cfg, server, filterSChan, shdChan, make(chan birpc.ClientConnector, 1), srvDep)
attrS := NewAttributeService(cfg, db, chS, filterSChan, server, make(chan birpc.ClientConnector, 1), anz, srvDep)
srv := NewDispatcherService(cfg, db, chS, filterSChan, server,
make(chan birpc.ClientConnector, 1), nil, anz, srvDep)
attrS := NewAttributeService(cfg, db, chS, filterSChan, server, make(chan birpc.ClientConnector, 1), anz, srv, srvDep)
engine.NewConnManager(cfg, nil)
srvMngr.AddServices(attrS, srv,
NewLoaderService(cfg, db, filterSChan, server,

2
services/ees_it_test.go
View File

@@ -64,7 +64,7 @@ func TestEventExporterSReload(t *testing.T) {
anz := NewAnalyzerService(cfg, server, filterSChan, shdChan, make(chan birpc.ClientConnector, 1), srvDep)
attrS := NewAttributeService(cfg, db,
chS, filterSChan, server, make(chan birpc.ClientConnector, 1),
anz, srvDep)
anz, &DispatcherService{srvsReload: make(map[string]chan struct{})}, srvDep)
ees := NewEventExporterService(cfg, filterSChan, engine.NewConnManager(cfg, nil),
server, make(chan birpc.ClientConnector, 2), anz, srvDep)
srvMngr.AddServices(ees, attrS,