From 0a94cd76f0836daa68eb7f4c06cf152fe71e6a91 Mon Sep 17 00:00:00 2001 From: DanB Date: Mon, 12 Feb 2018 18:37:25 +0100 Subject: [PATCH] SessionS.Authorize querying Suppliers with 1 Minute duration --- engine/cdrs.go | 13 ++++++++----- sessions/sessions.go | 4 +++- 2 files changed, 11 insertions(+), 6 deletions(-) diff --git a/engine/cdrs.go b/engine/cdrs.go index 9170c7db5..21d2bdbef 100644 --- a/engine/cdrs.go +++ b/engine/cdrs.go @@ -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 } } diff --git a/sessions/sessions.go b/sessions/sessions.go index f16d16b33..851e5fc58 100644 --- a/sessions/sessions.go +++ b/sessions/sessions.go @@ -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,