From 9b6e32dd5a84010e94fc049d01fc54d61c7894b9 Mon Sep 17 00:00:00 2001 From: porosnicuadrian Date: Thu, 26 Aug 2021 17:12:12 +0300 Subject: [PATCH] Removed transaction from ComputeIndexesIDs --- apis/filter_indexes.go | 69 +----------------------------------------- 1 file changed, 1 insertion(+), 68 deletions(-) diff --git a/apis/filter_indexes.go b/apis/filter_indexes.go index dbef5bf3b..cd0f1c20a 100644 --- a/apis/filter_indexes.go +++ b/apis/filter_indexes.go @@ -486,7 +486,7 @@ func (adms *AdminSv1) ComputeFilterIndexes(ctx *context.Context, args *utils.Arg // ComputeFilterIndexIDs computes specific filter indexes func (adms *AdminSv1) ComputeFilterIndexIDs(ctx *context.Context, args *utils.ArgsComputeFilterIndexIDs, reply *string) (err error) { - transactionID := utils.GenUUID() + transactionID := utils.NonTransactional tnt := args.Tenant if tnt == utils.EmptyString { tnt = adms.cfg.GeneralCfg().DefaultTenant @@ -652,73 +652,6 @@ func (adms *AdminSv1) ComputeFilterIndexIDs(ctx *context.Context, args *utils.Ar if indexes.Size() != 0 { cacheIDs[utils.CacheDispatcherFilterIndexes] = indexes.AsSlice() } - //Now we move from tmpKey to the right key for each type - //ThresholdProfile Indexes - if len(args.ThresholdIDs) != 0 { - if err = adms.dm.SetIndexes(ctx, utils.CacheThresholdFilterIndexes, tnt, nil, true, transactionID); err != nil { - return - } - } - //AccountProfile Indexes - if len(args.AccountIDs) != 0 { - if err = adms.dm.SetIndexes(ctx, utils.CacheAccountsFilterIndexes, tnt, nil, true, transactionID); err != nil { - return - } - } - //ActionProfile Indexes - if len(args.ActionProfileIDs) != 0 { - if err = adms.dm.SetIndexes(ctx, utils.CacheActionProfilesFilterIndexes, tnt, nil, true, transactionID); err != nil { - return - } - } - //RateProfile Indexes - if len(args.RateProfileIDs) != 0 { - if err = adms.dm.SetIndexes(ctx, utils.CacheRateProfilesFilterIndexes, tnt, nil, true, transactionID); err != nil { - return err - } - for _, tntId := range ratePrf { - if err = adms.dm.SetIndexes(ctx, utils.CacheRateFilterIndexes, tntId, nil, true, transactionID); err != nil { - return err - } - - } - } - //StatQueueProfile Indexes - if len(args.StatIDs) != 0 { - if err = adms.dm.SetIndexes(ctx, utils.CacheStatFilterIndexes, tnt, nil, true, transactionID); err != nil { - return - } - } - //ResourceProfile Indexes - if len(args.ResourceIDs) != 0 { - if err = adms.dm.SetIndexes(ctx, utils.CacheResourceFilterIndexes, tnt, nil, true, transactionID); err != nil { - return - } - } - //RouteProfile Indexes - if len(args.RouteIDs) != 0 { - if err = adms.dm.SetIndexes(ctx, utils.CacheRouteFilterIndexes, tnt, nil, true, transactionID); err != nil { - return - } - } - //AttributeProfile Indexes - if len(args.AttributeIDs) != 0 { - if err = adms.dm.SetIndexes(ctx, utils.CacheAttributeFilterIndexes, tnt, nil, true, transactionID); err != nil { - return - } - } - //ChargerProfile Indexes - if len(args.ChargerIDs) != 0 { - if err = adms.dm.SetIndexes(ctx, utils.CacheChargerFilterIndexes, tnt, nil, true, transactionID); err != nil { - return - } - } - //DispatcherProfile Indexes - if len(args.DispatcherIDs) != 0 { - if err = adms.dm.SetIndexes(ctx, utils.CacheDispatcherFilterIndexes, tnt, nil, true, transactionID); err != nil { - return - } - } //generate a load //ID for CacheFilterIndexes and store it in database