diff --git a/apier/v1/apier.go b/apier/v1/apier.go index d42aa1e07..c6645d366 100644 --- a/apier/v1/apier.go +++ b/apier/v1/apier.go @@ -151,14 +151,24 @@ func (apiv1 *ApierV1) SetDestination(attrs utils.AttrSetDestination, reply *stri if err := apiv1.DataManager.SetDestination(dest, utils.NonTransactional); err != nil { return utils.NewErrServerError(err) } - if err = apiv1.DataManager.CacheDataFromDB(utils.DESTINATION_PREFIX, []string{attrs.Id}, true); err != nil { - return + if err := apiv1.ConnMgr.Call(apiv1.Config.ApierCfg().CachesConns, nil, + utils.CacheSv1ReloadCache, utils.AttrReloadCacheWithArgDispatcher{ + AttrReloadCache: utils.AttrReloadCache{ + ArgsCache: utils.ArgsCache{DestinationIDs: &[]string{attrs.Id}}, + }, + }, reply); err != nil { + return err } if err = apiv1.DataManager.UpdateReverseDestination(oldDest, dest, utils.NonTransactional); err != nil { return } - if err = apiv1.DataManager.CacheDataFromDB(utils.REVERSE_DESTINATION_PREFIX, dest.Prefixes, true); err != nil { - return + if err := apiv1.ConnMgr.Call(apiv1.Config.ApierCfg().CachesConns, nil, + utils.CacheSv1ReloadCache, utils.AttrReloadCacheWithArgDispatcher{ + AttrReloadCache: utils.AttrReloadCache{ + ArgsCache: utils.ArgsCache{ReverseDestinationIDs: &dest.Prefixes}, + }, + }, reply); err != nil { + return err } *reply = utils.OK return nil diff --git a/apier/v2/accounts.go b/apier/v2/accounts.go index a2bae1427..dc3fc4628 100644 --- a/apier/v2/accounts.go +++ b/apier/v2/accounts.go @@ -186,13 +186,23 @@ func (apiv2 *ApierV2) SetAccount(attr AttrSetAccount, reply *string) error { apIDs[i] = actionPlanID i++ } - if err := apiv2.DataManager.CacheDataFromDB(utils.ACTION_PLAN_PREFIX, apIDs, true); err != nil { + if err := apiv2.ConnMgr.Call(apiv2.Config.ApierCfg().CachesConns, nil, + utils.CacheSv1ReloadCache, utils.AttrReloadCacheWithArgDispatcher{ + AttrReloadCache: utils.AttrReloadCache{ + ArgsCache: utils.ArgsCache{ActionPlanIDs: &apIDs}, + }, + }, reply); err != nil { return 0, err } if err := apiv2.DataManager.SetAccountActionPlans(accID, acntAPids, true); err != nil { return 0, err } - return 0, apiv2.DataManager.CacheDataFromDB(utils.AccountActionPlansPrefix, []string{accID}, true) + return 0, apiv2.ConnMgr.Call(apiv2.Config.ApierCfg().CachesConns, nil, + utils.CacheSv1ReloadCache, utils.AttrReloadCacheWithArgDispatcher{ + AttrReloadCache: utils.AttrReloadCache{ + ArgsCache: utils.ArgsCache{AccountActionPlanIDs: &[]string{accID}}, + }, + }, reply) }, config.CgrConfig().GeneralCfg().LockingTimeout, utils.ACTION_PLAN_PREFIX) if err != nil { return 0, err