From 65b8c562569450c1ee7fb36cf875e1e5efc034ff Mon Sep 17 00:00:00 2001 From: TeoV Date: Mon, 4 Mar 2019 18:28:59 +0200 Subject: [PATCH] Use CompressFactor in SessionS.Refund --- sessions/sessions.go | 5 ++++- sessions/sessions_voice_it_test.go | 3 +-- 2 files changed, 5 insertions(+), 3 deletions(-) diff --git a/sessions/sessions.go b/sessions/sessions.go index 4125325d6..991d61ad1 100644 --- a/sessions/sessions.go +++ b/sessions/sessions.go @@ -575,7 +575,10 @@ func (sS *SessionS) refundSession(s *Session, sRunIdx int, rUsage time.Duration) incr.BalanceInfo.Monetary == nil) { continue // not enough information for refunds, most probably free units uncounted } - incrmts = append(incrmts, incr) + for i := 0; i < tmspn.CompressFactor; i++ { + incrmts = append(incrmts, incr) + + } } } cd := &engine.CallDescriptor{ diff --git a/sessions/sessions_voice_it_test.go b/sessions/sessions_voice_it_test.go index 406a4ae0b..4cb2c77b4 100644 --- a/sessions/sessions_voice_it_test.go +++ b/sessions/sessions_voice_it_test.go @@ -873,14 +873,13 @@ func TestSessionsVoiceSessionTTL(t *testing.T) { t.Errorf("Expected: %f, received: %f", eAcntVal, acnt.BalanceMap[utils.MONETARY].GetTotalValue()) } time.Sleep(100 * time.Millisecond) - eAcntVal = 4.0565 + eAcntVal = 4.0566 if err := sessionsRPC.Call("ApierV2.GetAccount", attrs, &acnt); err != nil { t.Error(err) } else if acnt.BalanceMap[utils.MONETARY].GetTotalValue() != eAcntVal { t.Errorf("Expected: %f, received: %f", eAcntVal, acnt.BalanceMap[utils.MONETARY].GetTotalValue()) } - time.Sleep(time.Duration(500 * time.Millisecond)) var cdrs []*engine.ExternalCDR req := utils.RPCCDRsFilter{RunIDs: []string{utils.META_DEFAULT}, DestinationPrefixes: []string{"1008"}} if err := sessionsRPC.Call(utils.ApierV2GetCDRs, req, &cdrs); err != nil {