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

Call CacheSv1.ReloadCache instead of CacheDataFromDM from DataManager

Browse Source
This commit is contained in:
TeoV
2020-01-23 11:58:32 +02:00
parent 34d72b7bd3
commit c71699471f
1 changed files with 25 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

30
apier/v1/accounts.go
View File

@@ -135,7 +135,12 @@ func (api *ApierV1) RemoveActionTiming(attrs AttrRemoveActionTiming, reply *stri
if err != nil {
return 0, err
}
if err = api.DataManager.CacheDataFromDB(utils.ACTION_PLAN_PREFIX, []string{attrs.ActionPlanId}, true); err != nil {
if err := api.ConnMgr.Call(api.Config.ApierCfg().CachesConns, nil,
utils.CacheSv1ReloadCache, utils.AttrReloadCacheWithArgDispatcher{
AttrReloadCache: utils.AttrReloadCache{
ArgsCache: utils.ArgsCache{ActionPlanIDs: &[]string{attrs.ActionPlanId}},
},
}, reply); err != nil {
return 0, err
}
for _, acntID := range remAcntAPids {
@@ -144,8 +149,13 @@ func (api *ApierV1) RemoveActionTiming(attrs AttrRemoveActionTiming, reply *stri
}
}
if len(remAcntAPids) != 0 {
if err = api.DataManager.CacheDataFromDB(utils.AccountActionPlansPrefix, remAcntAPids, true); err != nil {
return 0, nil
if err := api.ConnMgr.Call(api.Config.ApierCfg().CachesConns, nil,
utils.CacheSv1ReloadCache, utils.AttrReloadCacheWithArgDispatcher{
AttrReloadCache: utils.AttrReloadCache{
ArgsCache: utils.ArgsCache{AccountActionPlanIDs: &remAcntAPids},
},
}, reply); err != nil {
return 0, err
}
}
return 0, nil
@@ -236,13 +246,23 @@ func (api *ApierV1) SetAccount(attr utils.AttrSetAccount, reply *string) (err er
apIDs[i] = actionPlanID
i++
}
if err := api.DataManager.CacheDataFromDB(utils.ACTION_PLAN_PREFIX, apIDs, true); err != nil {
if err := api.ConnMgr.Call(api.Config.ApierCfg().CachesConns, nil,
utils.CacheSv1ReloadCache, utils.AttrReloadCacheWithArgDispatcher{
AttrReloadCache: utils.AttrReloadCache{
ArgsCache: utils.ArgsCache{ActionPlanIDs: &apIDs},
},
}, reply); err != nil {
return 0, err
}
if err := api.DataManager.SetAccountActionPlans(accID, acntAPids, true); err != nil {
return 0, err
}
if err = api.DataManager.CacheDataFromDB(utils.AccountActionPlansPrefix, []string{accID}, true); err != nil {
if err := api.ConnMgr.Call(api.Config.ApierCfg().CachesConns, nil,
utils.CacheSv1ReloadCache, utils.AttrReloadCacheWithArgDispatcher{
AttrReloadCache: utils.AttrReloadCache{
ArgsCache: utils.ArgsCache{AccountActionPlanIDs: &[]string{accID}},
},
}, reply); err != nil {
return 0, err
}
return 0, nil