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

Change the way context is passed

Browse Source
This commit is contained in:
ionutboangiu
2021-11-18 18:27:52 +02:00
committed by Dan Christian Bogos
parent a214c505de
commit baeb3f3c0a
5 changed files with 13 additions and 13 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
ees/ees.go
View File

@@ -108,7 +108,8 @@ func (eeS *EventExporterS) attrSProcessEvent(cgrEv *utils.CGREvent, attrIDs []st
}
cgrEv.APIOpts[utils.Subsys] = utils.MetaEEs
cgrEv.APIOpts[utils.OptsAttributesProfileIDs] = attrIDs
cgrEv.APIOpts[utils.OptsContext] = ctx
cgrEv.APIOpts[utils.OptsContext] = utils.FirstNonEmpty(ctx,
utils.IfaceAsString(cgrEv.APIOpts[utils.OptsContext]), utils.MetaEEs)
if err = eeS.connMgr.Call(eeS.cfg.EEsNoLksCfg().AttributeSConns, nil, utils.AttributeSv1ProcessEvent,
cgrEv, &rplyEv); err == nil && len(rplyEv.AlteredFields) != 0 {
*cgrEv = *rplyEv.CGREvent

6
engine/cdrs.go
View File

@@ -374,9 +374,9 @@ func (cdrS *CDRServer) attrSProcessEvent(cgrEv *utils.CGREvent) (err error) {
cgrEv.APIOpts = make(map[string]interface{})
}
cgrEv.APIOpts[utils.Subsys] = utils.MetaCDRs
if cgrEv.APIOpts[utils.OptsContext] == utils.EmptyString {
cgrEv.APIOpts[utils.OptsContext] = utils.MetaCDRs
}
cgrEv.APIOpts[utils.OptsContext] = utils.FirstNonEmpty(
utils.IfaceAsString(cgrEv.APIOpts[utils.OptsContext]),
utils.MetaCDRs)
if err = cdrS.connMgr.Call(cdrS.cgrCfg.CdrsCfg().AttributeSConns, nil,
utils.AttributeSv1ProcessEvent,
cgrEv, &rplyEv); err == nil && len(rplyEv.AlteredFields) != 0 {

6
engine/chargers.go
View File

@@ -124,9 +124,9 @@ func (cS *ChargerService) processEvent(tnt string, cgrEv *utils.CGREvent) (rply
continue // AttributeS disabled
}
clonedEv.APIOpts[utils.OptsAttributesProfileIDs] = cP.AttributeIDs
if clonedEv.APIOpts[utils.OptsContext] == utils.EmptyString {
clonedEv.APIOpts[utils.OptsContext] = utils.MetaChargers
}
clonedEv.APIOpts[utils.OptsContext] = utils.FirstNonEmpty(
utils.IfaceAsString(clonedEv.APIOpts[utils.OptsContext]),
utils.MetaChargers)
var evReply AttrSProcessEventReply
if err = cS.connMgr.Call(cS.cfg.ChargerSCfg().AttributeSConns, nil,
utils.AttributeSv1ProcessEvent, clonedEv, &evReply); err != nil {

5
engine/routes.go
View File

@@ -575,9 +575,8 @@ func (rpS *RouteService) V1GetRoutes(args *utils.CGREvent, reply *SortedRoutesLi
args.APIOpts = make(map[string]interface{})
}
args.APIOpts[utils.Subsys] = utils.MetaRoutes
if args.APIOpts[utils.OptsContext] == utils.EmptyString {
args.APIOpts[utils.OptsContext] = utils.MetaRoutes
}
context := utils.GetStringOpts(args, rpS.cgrcfg.RouteSCfg().Opts.Context, utils.OptsContext)
args.APIOpts[utils.OptsContext] = utils.FirstNonEmpty(context, utils.MetaRoutes)
var rplyEv AttrSProcessEventReply
if err := rpS.connMgr.Call(rpS.cgrcfg.RouteSCfg().AttributeSConns, nil,
utils.AttributeSv1ProcessEvent, args, &rplyEv); err == nil && len(rplyEv.AlteredFields) != 0 {

6
sessions/sessions.go
View File

@@ -3846,9 +3846,9 @@ func (sS *SessionS) processAttributes(cgrEv *utils.CGREvent, attrIDs []string,
}
cgrEv.APIOpts[utils.Subsys] = utils.MetaSessionS
cgrEv.APIOpts[utils.OptsAttributesProfileIDs] = attrIDs
if cgrEv.APIOpts[utils.OptsContext] == utils.EmptyString {
cgrEv.APIOpts[utils.OptsContext] = utils.MetaSessionS
}
cgrEv.APIOpts[utils.OptsContext] = utils.FirstNonEmpty(
utils.IfaceAsString(cgrEv.APIOpts[utils.OptsContext]),
utils.MetaSessionS)
cgrEv.SetCloneable(clnb)
err = sS.connMgr.Call(sS.cgrCfg.SessionSCfg().AttrSConns, nil, utils.AttributeSv1ProcessEvent,
cgrEv, &rplyEv)