From 4bcafed33fd7d2686c8e6d2b80e348599d1c58db Mon Sep 17 00:00:00 2001 From: Trial97 Date: Mon, 9 Dec 2019 18:04:01 +0200 Subject: [PATCH] Updated refundEventCost --- engine/cdrs.go | 4 +++- sessions/sessions.go | 1 + sessions/sessions_data_it_test.go | 2 +- 3 files changed, 5 insertions(+), 2 deletions(-) diff --git a/engine/cdrs.go b/engine/cdrs.go index f65314c43..35688559e 100644 --- a/engine/cdrs.go +++ b/engine/cdrs.go @@ -289,6 +289,9 @@ func (cdrS *CDRServer) rateCDRWithErr(cdr *CDRWithArgDispatcher) (ratedCDRs []*C // refundEventCost will refund the EventCost using RefundIncrements func (cdrS *CDRServer) refundEventCost(ec *EventCost, reqType, tor string) (err error) { + if cdrS.rals == nil { + return utils.NewErrNotConnected(utils.RALService) + } if ec == nil || !utils.AccountableRequestTypes.Has(reqType) { return // non refundable } @@ -754,7 +757,6 @@ func (cdrS *CDRServer) V1ProcessEvent(arg *ArgV1ProcessEvent, reply *string) (er chrgS = flgs.GetBool(utils.MetaChargers) } var ralS bool // activate single rating for the CDR - fmt.Printf("flags: %s HasKeyRALs: %v\n", utils.ToIJSON(flgs), flgs.GetBool(utils.MetaRALs)) if flgs.HasKey(utils.MetaRALs) { ralS = flgs.GetBool(utils.MetaRALs) } diff --git a/sessions/sessions.go b/sessions/sessions.go index 094d6a9b6..6d6f7e98d 100644 --- a/sessions/sessions.go +++ b/sessions/sessions.go @@ -2627,6 +2627,7 @@ func (sS *SessionS) BiRPCv1ProcessCDR(clnt rpcclient.ClientConnector, } else { // no cached session, CDR will be handled by CDRs return sS.cdrS.Call(utils.CDRsV1ProcessEvent, &engine.ArgV1ProcessEvent{ + Flags: []string{utils.MetaRALs}, CGREvent: *cgrEvWithArgDisp.CGREvent, ArgDispatcher: cgrEvWithArgDisp.ArgDispatcher}, rply) } diff --git a/sessions/sessions_data_it_test.go b/sessions/sessions_data_it_test.go index 492829903..98f13e151 100644 --- a/sessions/sessions_data_it_test.go +++ b/sessions/sessions_data_it_test.go @@ -976,7 +976,7 @@ func TestSessionsDataTTLUsageProtection(t *testing.T) { time.Sleep(60 * time.Millisecond) if err := sDataRPC.Call(utils.SessionSv1GetActiveSessions, new(utils.SessionFilter), &aSessions); err == nil || err.Error() != utils.ErrNotFound.Error() { - t.Error(err, aSessions) + t.Error(err, utils.ToJSON(aSessions)) } }