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

SessionS.Authorize querying Suppliers with 1 Minute duration

Browse Source
This commit is contained in:
DanB
2018-02-12 18:37:25 +01:00
parent 6bcdbee46c
commit 0a94cd76f0
2 changed files with 11 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
engine/cdrs.go
View File

@@ -238,12 +238,15 @@ func (self *CdrServer) deriveRateStoreStatsReplicate(cdr *CDR, store, cdrstats,
for _, cdrRun := range cdrRuns {
if self.attrS != nil {
var rplyEv AttrSProcessEventReply
cgrEv := cdrRun.AsCGREvent()
cgrEv.Context = utils.StringPointer(utils.MetaCDRs)
if err = self.attrS.Call(utils.AttributeSv1ProcessEvent,
cdrRun.AsCGREvent(), &rplyEv); err != nil {
return
}
if err = cdrRun.UpdateFromCGREvent(rplyEv.CGREvent,
rplyEv.AlteredFields); err != nil {
cgrEv, &rplyEv); err == nil {
if err = cdrRun.UpdateFromCGREvent(rplyEv.CGREvent,
rplyEv.AlteredFields); err != nil {
return
}
} else if err.Error() != utils.ErrNotFound.Error() {
return
}
}

4
sessions/sessions.go
View File

@@ -1383,9 +1383,11 @@ func (smg *SMGeneric) BiRPCv1AuthorizeEvent(clnt rpcclient.RpcClientConnection,
if smg.splS == nil {
return utils.NewErrNotConnected(utils.SupplierS)
}
cgrEv := args.CGREvent.Clone()
cgrEv.Event[utils.Usage] = time.Duration(time.Minute)
var splsReply engine.SortedSuppliers
sArgs := &engine.ArgsGetSuppliers{
CGREvent: args.CGREvent,
CGREvent: *cgrEv,
Paginator: args.Paginator,
}
if err = smg.splS.Call(utils.SupplierSv1GetSuppliers,