From 65b0e0f60860e67edd0a0b81b9f571a95c0f552d Mon Sep 17 00:00:00 2001 From: TeoV Date: Thu, 11 Jul 2019 10:05:18 +0300 Subject: [PATCH] Move populating source after RPC caching --- sessions/sessions.go | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) diff --git a/sessions/sessions.go b/sessions/sessions.go index 460c5c7bb..5f05e9374 100644 --- a/sessions/sessions.go +++ b/sessions/sessions.go @@ -2550,9 +2550,6 @@ func (sS *SessionS) BiRPCv1ProcessCDR(clnt rpcclient.RpcClientConnection, if cgrEvWithArgDisp.ID == "" { cgrEvWithArgDisp.ID = utils.GenUUID() } - if _, has := cgrEvWithArgDisp.Event[utils.Source]; !has { - cgrEvWithArgDisp.Event[utils.Source] = utils.MetaSessionS - } // RPC caching if sS.cgrCfg.CacheCfg()[utils.CacheRPCResponses].Limit != 0 { @@ -2573,6 +2570,10 @@ func (sS *SessionS) BiRPCv1ProcessCDR(clnt rpcclient.RpcClientConnection, nil, true, utils.NonTransactional) } // end of RPC caching + // in case that source don't exist add it + if _, has := cgrEvWithArgDisp.Event[utils.Source]; !has { + cgrEvWithArgDisp.Event[utils.Source] = utils.MetaSessionS + } ev := engine.NewSafEvent(cgrEvWithArgDisp.Event) cgrID := GetSetCGRID(ev)