diff --git a/apier/v1/filter_indexes.go b/apier/v1/filter_indexes.go index d620ff7d7..7e666e827 100644 --- a/apier/v1/filter_indexes.go +++ b/apier/v1/filter_indexes.go @@ -131,7 +131,7 @@ func (apierSv1 *APIerSv1) GetFilterIndexes(ctx *context.Context, arg *AttrGetFil tntCtx = utils.ConcatenatedKey(tnt, arg.Context) } if indexes, err = apierSv1.DataManager.GetIndexes( - arg.ItemType, tntCtx, utils.EmptyString, true, true); err != nil { + arg.ItemType, tntCtx, true, true); err != nil { return } if arg.FilterType != utils.EmptyString { diff --git a/apier/v1/libapier.go b/apier/v1/libapier.go index be2dc7f09..8461727c5 100644 --- a/apier/v1/libapier.go +++ b/apier/v1/libapier.go @@ -286,7 +286,7 @@ func composeCacheArgsForFilter(dm *engine.DataManager, fltr *engine.Filter, tnt, var rcvIndx map[string]utils.StringSet if rcvIndx, err = dm.GetIndexes(utils.CacheReverseFilterIndexes, tntID, - utils.EmptyString, true, true); err != nil && err != utils.ErrNotFound { // error when geting the revers + true, true); err != nil && err != utils.ErrNotFound { // error when geting the revers return } if err == utils.ErrNotFound || len(rcvIndx) == 0 { // no reverse index for this filter diff --git a/engine/datamanager.go b/engine/datamanager.go index 3aaa3b5eb..555ac4630 100644 --- a/engine/datamanager.go +++ b/engine/datamanager.go @@ -259,50 +259,50 @@ func (dm *DataManager) CacheDataFromDB(prfx string, ids []string, mustBeCached b if tntCtx, idxKey, err = splitFilterIndex(dataID); err != nil { return } - _, err = dm.GetIndexes(utils.CacheAttributeFilterIndexes, tntCtx, idxKey, false, true) + _, err = dm.GetIndexes(utils.CacheAttributeFilterIndexes, tntCtx, false, true, idxKey) case utils.ResourceFilterIndexes: var tntCtx, idxKey string if tntCtx, idxKey, err = splitFilterIndex(dataID); err != nil { return } - _, err = dm.GetIndexes(utils.CacheResourceFilterIndexes, tntCtx, idxKey, false, true) + _, err = dm.GetIndexes(utils.CacheResourceFilterIndexes, tntCtx, false, true, idxKey) case utils.StatFilterIndexes: var tntCtx, idxKey string if tntCtx, idxKey, err = splitFilterIndex(dataID); err != nil { return } - _, err = dm.GetIndexes(utils.CacheStatFilterIndexes, tntCtx, idxKey, false, true) + _, err = dm.GetIndexes(utils.CacheStatFilterIndexes, tntCtx, false, true, idxKey) case utils.ThresholdFilterIndexes: var tntCtx, idxKey string if tntCtx, idxKey, err = splitFilterIndex(dataID); err != nil { return } - _, err = dm.GetIndexes(utils.CacheThresholdFilterIndexes, tntCtx, idxKey, false, true) + _, err = dm.GetIndexes(utils.CacheThresholdFilterIndexes, tntCtx, false, true, idxKey) case utils.RouteFilterIndexes: var tntCtx, idxKey string if tntCtx, idxKey, err = splitFilterIndex(dataID); err != nil { return } - _, err = dm.GetIndexes(utils.CacheRouteFilterIndexes, tntCtx, idxKey, false, true) + _, err = dm.GetIndexes(utils.CacheRouteFilterIndexes, tntCtx, false, true, idxKey) case utils.ChargerFilterIndexes: var tntCtx, idxKey string if tntCtx, idxKey, err = splitFilterIndex(dataID); err != nil { return } - _, err = dm.GetIndexes(utils.CacheChargerFilterIndexes, tntCtx, idxKey, false, true) + _, err = dm.GetIndexes(utils.CacheChargerFilterIndexes, tntCtx, false, true, idxKey) case utils.DispatcherFilterIndexes: var tntCtx, idxKey string if tntCtx, idxKey, err = splitFilterIndex(dataID); err != nil { return } - _, err = dm.GetIndexes(utils.CacheDispatcherFilterIndexes, tntCtx, idxKey, false, true) + _, err = dm.GetIndexes(utils.CacheDispatcherFilterIndexes, tntCtx, false, true, idxKey) case utils.FilterIndexPrfx: idx := strings.LastIndexByte(dataID, utils.InInFieldSep[0]) if idx < 0 { err = fmt.Errorf("WRONG_IDX_KEY_FORMAT<%s>", dataID) return } - _, err = dm.GetIndexes(utils.CacheReverseFilterIndexes, dataID[:idx], dataID[idx+1:], false, true) + _, err = dm.GetIndexes(utils.CacheReverseFilterIndexes, dataID[:idx], false, true, dataID[idx+1:]) case utils.LoadIDPrefix: _, err = dm.GetItemLoadIDs(utils.EmptyString, true) case utils.MetaAPIBan: @@ -762,7 +762,7 @@ func (dm *DataManager) RemoveFilter(tenant, id string, withIndex bool) (err erro tntCtx = utils.ConcatenatedKey(tenant, id) var rcvIndx map[string]utils.StringSet if rcvIndx, err = dm.GetIndexes(utils.CacheReverseFilterIndexes, tntCtx, - utils.EmptyString, true, true); err != nil { + true, true); err != nil { if err != utils.ErrNotFound { return } @@ -3760,17 +3760,12 @@ func (dm *DataManager) Reconnect(marshaller string, newcfg *config.DataDbCfg, it return } -func (dm *DataManager) GetIndexes(idxItmType, tntCtx, idxKey string, - cacheRead, cacheWrite bool) (indexes map[string]utils.StringSet, err error) { - return dm.GetIndexesBatch(idxItmType, tntCtx, cacheRead, cacheWrite, idxKey) -} - // GetIndexesBatch supports retrieving multiple index keys in a single operation // When idxKeys is empty or contains only empty string, retrieves all indexes // Otherwise retrieves only the specified keys, returning only found keys (no error if some missing) // Returns ErrNotFound only if no keys found at all -func (dm *DataManager) GetIndexesBatch(idxItmType, tntCtx string, - cacheRead, cacheWrite bool, idxKeys ...string) (indexes map[string]utils.StringSet, err error) { +func (dm *DataManager) GetIndexes(idxItmType, tntCtx string, cacheRead, cacheWrite bool, + idxKeys ...string) (indexes map[string]utils.StringSet, err error) { if dm == nil { err = utils.ErrNoDatabaseConn return diff --git a/engine/datamanager_test.go b/engine/datamanager_test.go index 3395af1da..f81bbc972 100644 --- a/engine/datamanager_test.go +++ b/engine/datamanager_test.go @@ -3461,7 +3461,7 @@ func TestUpdateFilterIndexRouteIndex(t *testing.T) { "*string:*req.Cost:unRegVal2": {"ID": {}}, } - getindx, err := dm.GetIndexes(utils.CacheRouteFilterIndexes, cfg.GeneralCfg().DefaultTenant, utils.EmptyString, true, true) + getindx, err := dm.GetIndexes(utils.CacheRouteFilterIndexes, cfg.GeneralCfg().DefaultTenant, true, true) if err != nil { t.Error(err) } else if !reflect.DeepEqual(expindx, getindx) { @@ -3493,7 +3493,7 @@ func TestUpdateFilterIndexRouteIndex(t *testing.T) { expindxNew := map[string]utils.StringSet{ "*prefix:*req.Usage:10s": {"ID": {}}, } - getindxNew, err := dm.GetIndexes(utils.CacheRouteFilterIndexes, cfg.GeneralCfg().DefaultTenant, utils.EmptyString, true, true) + getindxNew, err := dm.GetIndexes(utils.CacheRouteFilterIndexes, cfg.GeneralCfg().DefaultTenant, true, true) if err != nil { t.Error(err) } else if !reflect.DeepEqual(expindxNew, getindxNew) { @@ -3565,7 +3565,7 @@ func TestUpdateFilterIndexStatIndex(t *testing.T) { "*string:*req.Stats:StatQueueProfile1": {"TEST_PROFILE1": {}}, } - if getindx, err := dm.GetIndexes(utils.CacheStatFilterIndexes, cfg.GeneralCfg().DefaultTenant, utils.EmptyString, true, true); err != nil { + if getindx, err := dm.GetIndexes(utils.CacheStatFilterIndexes, cfg.GeneralCfg().DefaultTenant, true, true); err != nil { t.Error(err) } else if !reflect.DeepEqual(expindx, getindx) { t.Errorf("Expected %v, Received %v", utils.ToJSON(expindx), utils.ToJSON(getindx)) @@ -3593,7 +3593,7 @@ func TestUpdateFilterIndexStatIndex(t *testing.T) { expindxNew := map[string]utils.StringSet{ "*prefix:*req.Usage:10s": {"TEST_PROFILE1": {}}, } - if getindx, err := dm.GetIndexes(utils.CacheStatFilterIndexes, cfg.GeneralCfg().DefaultTenant, utils.EmptyString, true, true); err != nil { + if getindx, err := dm.GetIndexes(utils.CacheStatFilterIndexes, cfg.GeneralCfg().DefaultTenant, true, true); err != nil { t.Error(err) } else if !reflect.DeepEqual(expindxNew, getindx) { t.Errorf("Expected %v, Received %v", utils.ToJSON(expindx), utils.ToJSON(getindx)) @@ -3728,7 +3728,7 @@ func TestUpdateFilterDispatcherIndex(t *testing.T) { "*string:*req.Destination:ACC1": {"Dsp": {}}, "*string:*req.Destination:ACC2": {"Dsp": {}}, } - if indx, err := dm.GetIndexes(utils.CacheDispatcherFilterIndexes, "cgrates.org:*any", utils.EmptyString, true, true); err != nil { + if indx, err := dm.GetIndexes(utils.CacheDispatcherFilterIndexes, "cgrates.org:*any", true, true); err != nil { t.Error(err) } else if !reflect.DeepEqual(exp, indx) { t.Errorf("Expected %v, Received %v", utils.ToJSON(exp), utils.ToJSON(indx)) @@ -3750,7 +3750,7 @@ func TestUpdateFilterDispatcherIndex(t *testing.T) { exp = map[string]utils.StringSet{ "*string:*req.Charger:ChargerProfile2": {"Dsp": {}}, } - if indx, err := dm.GetIndexes(utils.CacheDispatcherFilterIndexes, "cgrates.org:*any", utils.EmptyString, true, true); err != nil { + if indx, err := dm.GetIndexes(utils.CacheDispatcherFilterIndexes, "cgrates.org:*any", true, true); err != nil { t.Error(err) } else if !reflect.DeepEqual(exp, indx) { t.Errorf("Expected %v, Received %v", utils.ToJSON(exp), utils.ToJSON(indx)) @@ -5298,7 +5298,7 @@ func TestIndxFilterContains(t *testing.T) { } if rcvIdx, err := dm.GetIndexes( utils.CacheThresholdFilterIndexes, th.Tenant, - utils.EmptyString, false, false); err != nil { + false, false); err != nil { t.Error(err) } else if !reflect.DeepEqual(eIdxes, rcvIdx) { t.Errorf("Expecting %+v, received: %+v", eIdxes, rcvIdx) diff --git a/engine/filterhelpers.go b/engine/filterhelpers.go index 0f6c693ab..fac23a23c 100644 --- a/engine/filterhelpers.go +++ b/engine/filterhelpers.go @@ -71,7 +71,7 @@ func MatchingItemIDsForEvent(ev utils.MapStorage, stringFldIDs, prefixFldIDs, su if filterIndexTypes[i] == utils.MetaExists { var dbIndexes map[string]utils.StringSet // list of items matched in DB key := utils.ConcatenatedKey(filterIndexTypes[i], fldName) - if dbIndexes, err = dm.GetIndexes(cacheID, itemIDPrefix, key, true, true); err != nil { + if dbIndexes, err = dm.GetIndexes(cacheID, itemIDPrefix, true, true, key); err != nil { if err == utils.ErrNotFound { err = nil continue @@ -105,7 +105,7 @@ func MatchingItemIDsForEvent(ev utils.MapStorage, stringFldIDs, prefixFldIDs, su for _, val := range fldVals { var dbIndexes map[string]utils.StringSet // list of items matched in DB key := utils.ConcatenatedKey(filterIndexTypes[i], fldName, val) - if dbIndexes, err = dm.GetIndexes(cacheID, itemIDPrefix, key, true, true); err != nil { + if dbIndexes, err = dm.GetIndexes(cacheID, itemIDPrefix, true, true, key); err != nil { if err == utils.ErrNotFound { err = nil continue diff --git a/engine/libindex.go b/engine/libindex.go index 8b790393e..10a89d582 100644 --- a/engine/libindex.go +++ b/engine/libindex.go @@ -51,8 +51,7 @@ func newFilterIndex(dm *DataManager, idxItmType, tnt, ctx, itemID string, filter idxKey := utils.ConcatenatedKey(utils.MetaNone, utils.MetaAny, utils.MetaAny) var rcvIndx map[string]utils.StringSet if rcvIndx, err = dm.GetIndexes(idxItmType, tntCtx, - idxKey, - true, false); err != nil { + true, false, idxKey); err != nil { if err != utils.ErrNotFound { return } @@ -91,7 +90,7 @@ func newFilterIndex(dm *DataManager, idxItmType, tnt, ctx, itemID string, filter var rcvIndx map[string]utils.StringSet // only read from cache in case if we do not find the index to not cache the negative response if rcvIndx, err = dm.GetIndexes(idxItmType, tntCtx, - idxKey, true, false); err != nil { + true, false, idxKey); err != nil { if err != utils.ErrNotFound { return } @@ -122,7 +121,7 @@ func newFilterIndex(dm *DataManager, idxItmType, tnt, ctx, itemID string, filter var rcvIndx map[string]utils.StringSet // only read from cache in case if we do not find the index to not cache the negative response if rcvIndx, err = dm.GetIndexes(idxItmType, tntCtx, - idxKey, true, false); err != nil { + true, false, idxKey); err != nil { if err != utils.ErrNotFound { return } @@ -477,7 +476,7 @@ func addIndexFiltersItem(dm *DataManager, idxItmType, tnt, itemID string, filter config.CgrConfig().GeneralCfg().LockingTimeout, utils.CacheReverseFilterIndexes+tntCtx) var indexes map[string]utils.StringSet if indexes, err = dm.GetIndexes(utils.CacheReverseFilterIndexes, tntCtx, - idxItmType, true, false); err != nil { + true, false, idxItmType); err != nil { if err != utils.ErrNotFound { guardian.Guardian.UnguardIDs(refID) return @@ -514,7 +513,7 @@ func removeIndexFiltersItem(dm *DataManager, idxItmType, tnt, itemID string, fil config.CgrConfig().GeneralCfg().LockingTimeout, utils.CacheReverseFilterIndexes+tntCtx) var indexes map[string]utils.StringSet if indexes, err = dm.GetIndexes(utils.CacheReverseFilterIndexes, tntCtx, - idxItmType, true, false); err != nil { + true, false, idxItmType); err != nil { guardian.Guardian.UnguardIDs(refID) if err != utils.ErrNotFound { return @@ -624,7 +623,7 @@ func UpdateFilterIndex(dm *DataManager, oldFlt, newFlt *Filter) (err error) { var rcvIndx map[string]utils.StringSet // get all reverse indexes from DB if rcvIndx, err = dm.GetIndexes(utils.CacheReverseFilterIndexes, tntID, - utils.EmptyString, true, false); err != nil { + true, false); err != nil { if err != utils.ErrNotFound { return } @@ -813,7 +812,7 @@ func removeFilterIndexesForFilter(dm *DataManager, idxItmType, tnt string, for _, idxKey := range removeIndexKeys { fltrIdx, err := dm.GetIndexes(idxItmType, tnt, - idxKey, true, false) + true, false, idxKey) if err != nil { if err != utils.ErrNotFound { return err diff --git a/engine/libindex_health.go b/engine/libindex_health.go index 7d8ed6229..d5d67f5fb 100644 --- a/engine/libindex_health.go +++ b/engine/libindex_health.go @@ -424,7 +424,7 @@ func getIHFltrIdxFromCache(dm *DataManager, fltrIdxCache *ltcache.Cache, idxItmT return fltrVal.(utils.StringSet), nil } var indexes map[string]utils.StringSet - if indexes, err = dm.GetIndexes(idxItmType, tntCtx, idxKey, true, false); err != nil { + if indexes, err = dm.GetIndexes(idxItmType, tntCtx, true, false, idxKey); err != nil { if err == utils.ErrNotFound { fltrIdxCache.Set(cacheKey, nil, nil) } diff --git a/engine/libindex_test.go b/engine/libindex_test.go index 2f2286107..d7718735a 100644 --- a/engine/libindex_test.go +++ b/engine/libindex_test.go @@ -156,7 +156,7 @@ func TestLibIndexRemoveFilterIndexesForFilter(t *testing.T) { tntCtx, test.keys, test.itemIDs); err != nil { t.Fatalf("removeFilterIndexesForFilter() returned unexpected error: %v", err) } - got, err := dm.GetIndexes(utils.CacheAttributeFilterIndexes, tntCtx, "", true, false) + got, err := dm.GetIndexes(utils.CacheAttributeFilterIndexes, tntCtx, true, false) switch len(test.want) { case 0: if !errors.Is(err, utils.ErrNotFound) { @@ -301,7 +301,7 @@ func TestLibIndex_newFilterIndex(t *testing.T) { }, } tntCtx := utils.ConcatenatedKey("cgrates.org", utils.MetaCDRs) - gotIndexes, err := dm.GetIndexes(utils.CacheAttributeFilterIndexes, tntCtx, "", false, false) + gotIndexes, err := dm.GetIndexes(utils.CacheAttributeFilterIndexes, tntCtx, false, false) if err != nil { t.Fatal(err) } diff --git a/engine/z_attributes_test.go b/engine/z_attributes_test.go index e770e9f99..b79e733df 100644 --- a/engine/z_attributes_test.go +++ b/engine/z_attributes_test.go @@ -481,7 +481,7 @@ func TestAttributeIndexer(t *testing.T) { }, } if rcvIdx, err := dmAtr.GetIndexes(utils.CacheAttributeFilterIndexes, - utils.ConcatenatedKey(attrPrf.Tenant, utils.MetaAny), "", false, false); err != nil { + utils.ConcatenatedKey(attrPrf.Tenant, utils.MetaAny), false, false); err != nil { t.Error(err) } else { if !reflect.DeepEqual(eIdxes, rcvIdx) { @@ -496,7 +496,7 @@ func TestAttributeIndexer(t *testing.T) { t.Error(err) } if rcvIdx, err := dmAtr.GetIndexes(utils.CacheAttributeFilterIndexes, - utils.ConcatenatedKey(attrPrf.Tenant, utils.MetaSessionS), "", false, false); err != nil { + utils.ConcatenatedKey(attrPrf.Tenant, utils.MetaSessionS), false, false); err != nil { t.Error(err) } else { if !reflect.DeepEqual(eIdxes, rcvIdx) { @@ -505,7 +505,7 @@ func TestAttributeIndexer(t *testing.T) { } //verify if old index was deleted ( context *any) if _, err := dmAtr.GetIndexes(utils.CacheAttributeFilterIndexes, - utils.ConcatenatedKey(attrPrf.Tenant, utils.MetaAny), "", false, false); err != utils.ErrNotFound { + utils.ConcatenatedKey(attrPrf.Tenant, utils.MetaAny), false, false); err != utils.ErrNotFound { t.Error(err) } } diff --git a/engine/z_filterindexer_it_test.go b/engine/z_filterindexer_it_test.go index ba2fe6c5b..e862ea5ac 100644 --- a/engine/z_filterindexer_it_test.go +++ b/engine/z_filterindexer_it_test.go @@ -208,17 +208,16 @@ func testITGetFilterIndexes(t *testing.T) { } if exsbjDan, err := dataManager.GetIndexes( - utils.CacheResourceFilterIndexes, "cgrates.org", + utils.CacheResourceFilterIndexes, "cgrates.org", false, false, utils.ConcatenatedKey(utils.MetaString, "Subject", "dan"), - false, false); err != nil { + ); err != nil { t.Error(err) } else if !reflect.DeepEqual(expectedsbjDan, exsbjDan) { t.Errorf("Expecting: %+v, received: %+v", expectedsbjDan, exsbjDan) } if rcv, err := dataManager.GetIndexes( utils.CacheResourceFilterIndexes, - "cgrates.org", utils.EmptyString, - false, false); err != nil { + "cgrates.org", false, false); err != nil { t.Error(err) } else if !reflect.DeepEqual(eIdxes, rcv) { t.Errorf("Expecting: %+v, received: %+v", eIdxes, rcv) @@ -233,9 +232,9 @@ func testITMatchFilterIndex(t *testing.T) { }, } if rcvMp, err := dataManager.GetIndexes( - utils.CacheResourceFilterIndexes, "cgrates.org", + utils.CacheResourceFilterIndexes, "cgrates.org", false, true, utils.ConcatenatedKey(utils.MetaString, "Account", "1002"), - false, true); err != nil { + ); err != nil { t.Error(err) } else if !reflect.DeepEqual(eMp, rcvMp) { t.Errorf("Expecting: %+v, received: %+v", eMp, rcvMp) @@ -243,9 +242,9 @@ func testITMatchFilterIndex(t *testing.T) { //invalid tnt:context or index key if _, err := dataManager.GetIndexes( - utils.CacheResourceFilterIndexes, "cgrates.org", + utils.CacheResourceFilterIndexes, "cgrates.org", true, true, utils.ConcatenatedKey(utils.MetaString, "NonexistentField", "1002"), - true, true); err == nil || + ); err == nil || err != utils.ErrNotFound { t.Error(err) } @@ -306,7 +305,7 @@ func testITTestThresholdFilterIndexes(t *testing.T) { } if rcvIdx, err := dataManager.GetIndexes( utils.CacheThresholdFilterIndexes, th.Tenant, - utils.EmptyString, false, false); err != nil { + false, false); err != nil { t.Error(err) } else if !reflect.DeepEqual(eIdxes, rcvIdx) { t.Errorf("Expecting %+v, received: %+v", eIdxes, rcvIdx) @@ -349,7 +348,7 @@ func testITTestThresholdFilterIndexes(t *testing.T) { } if rcvIdx, err := dataManager.GetIndexes( utils.CacheThresholdFilterIndexes, th.Tenant, - utils.EmptyString, false, false); err != nil { + false, false); err != nil { t.Error(err) } else if !reflect.DeepEqual(eIdxes, rcvIdx) { t.Errorf("Expecting %+v, received: %+v", utils.ToJSON(eIdxes), utils.ToJSON(rcvIdx)) @@ -398,7 +397,7 @@ func testITTestThresholdFilterIndexes(t *testing.T) { } if rcvIdx, err := dataManager.GetIndexes( utils.CacheThresholdFilterIndexes, th.Tenant, - utils.EmptyString, false, false); err != nil { + false, false); err != nil { t.Error(err) } else if !reflect.DeepEqual(eIdxes, rcvIdx) { t.Errorf("Expecting %+v, received: %+v", utils.ToJSON(eIdxes), utils.ToJSON(rcvIdx)) @@ -431,7 +430,7 @@ func testITTestThresholdFilterIndexes(t *testing.T) { } if rcvIdx, err := dataManager.GetIndexes( utils.CacheReverseFilterIndexes, "cgrates.org:Filter3", - utils.EmptyString, false, false); err != nil { + false, false); err != nil { t.Error(err) } else if !reflect.DeepEqual(eIdxes, rcvIdx) { t.Errorf("Expecting %+v, received: %+v", utils.ToJSON(eIdxes), utils.ToJSON(rcvIdx)) @@ -455,7 +454,7 @@ func testITTestThresholdFilterIndexes(t *testing.T) { } if rcvIdx, err := dataManager.GetIndexes( utils.CacheThresholdFilterIndexes, th.Tenant, - utils.EmptyString, false, false); err != nil { + false, false); err != nil { t.Error(err) } else if !reflect.DeepEqual(eIdxes, rcvIdx) { t.Errorf("Expecting %+v, received: %+v", utils.ToJSON(eIdxes), utils.ToJSON(rcvIdx)) @@ -472,12 +471,12 @@ func testITTestThresholdFilterIndexes(t *testing.T) { } if _, err := dataManager.GetIndexes( utils.CacheThresholdFilterIndexes, th.Tenant, - utils.EmptyString, false, false); err != utils.ErrNotFound { + false, false); err != utils.ErrNotFound { t.Error(err) } if _, err := dataManager.GetIndexes( utils.CacheReverseFilterIndexes, "cgrates.org:Filter3", - utils.EmptyString, false, false); err != utils.ErrNotFound { + false, false); err != utils.ErrNotFound { t.Error(err) } } @@ -533,7 +532,7 @@ func testITTestAttributeProfileFilterIndexes(t *testing.T) { if rcvIdx, err := dataManager.GetIndexes( utils.CacheAttributeFilterIndexes, utils.ConcatenatedKey(attrProfile.Tenant, ctx), - utils.EmptyString, false, false); err != nil { + false, false); err != nil { t.Error(err) } else if !reflect.DeepEqual(eIdxes, rcvIdx) { t.Errorf("Expecting %+v, received: %+v", eIdxes, rcvIdx) @@ -563,7 +562,7 @@ func testITTestAttributeProfileFilterIndexes(t *testing.T) { if rcvIdx, err := dataManager.GetIndexes( utils.CacheAttributeFilterIndexes, utils.ConcatenatedKey(attrProfile.Tenant, "con3"), - utils.EmptyString, false, false); err != nil { + false, false); err != nil { t.Error(err) } else if !reflect.DeepEqual(eIdxes, rcvIdx) { t.Errorf("Expecting %+v, received: %+v", eIdxes, rcvIdx) @@ -573,7 +572,7 @@ func testITTestAttributeProfileFilterIndexes(t *testing.T) { if _, err = dataManager.GetIndexes( utils.CacheAttributeFilterIndexes, utils.ConcatenatedKey(attrProfile.Tenant, ctx), - utils.EmptyString, false, false); err == nil || + false, false); err == nil || err != utils.ErrNotFound { t.Error(err) } @@ -606,7 +605,7 @@ func testITTestAttributeProfileFilterIndexes(t *testing.T) { if rcvIdx, err := dataManager.GetIndexes( utils.CacheAttributeFilterIndexes, utils.ConcatenatedKey(attrProfile.Tenant, ctx), - utils.EmptyString, false, false); err != nil { + false, false); err != nil { t.Error(err) } else if !reflect.DeepEqual(eIdxes, rcvIdx) { t.Errorf("Expecting %+v, received: %+v", utils.ToJSON(eIdxes), rcvIdx) @@ -621,7 +620,7 @@ func testITTestAttributeProfileFilterIndexes(t *testing.T) { if rcvIdx, err := dataManager.GetIndexes( utils.CacheReverseFilterIndexes, fp.TenantID(), - utils.EmptyString, false, false); err != nil { + false, false); err != nil { t.Error(err) } else if !reflect.DeepEqual(eIdxes, rcvIdx) { t.Errorf("Expecting %+v, received: %+v", eIdxes, rcvIdx) @@ -635,14 +634,14 @@ func testITTestAttributeProfileFilterIndexes(t *testing.T) { if _, err := dataManager.GetIndexes( utils.CacheAttributeFilterIndexes, utils.ConcatenatedKey("cgrates.org", "con3"), - utils.MetaString, false, false); err != nil && err != utils.ErrNotFound { + false, false, utils.MetaString); err != nil && err != utils.ErrNotFound { t.Error(err) } if _, err := dataManager.GetIndexes( utils.CacheReverseFilterIndexes, fp.TenantID(), - utils.EmptyString, false, false); err != utils.ErrNotFound { + false, false); err != utils.ErrNotFound { t.Error(err) } } @@ -698,7 +697,7 @@ func testITTestAttributeProfileFilterIndexes2(t *testing.T) { if rcvIdx, err := dataManager.GetIndexes( utils.CacheAttributeFilterIndexes, utils.ConcatenatedKey(attrProfile.Tenant, ctx), - utils.EmptyString, false, false); err != nil { + false, false); err != nil { t.Error(err) } else if !reflect.DeepEqual(eIdxes, rcvIdx) { t.Errorf("Expecting %+v, received: %+v", eIdxes, rcvIdx) @@ -728,7 +727,7 @@ func testITTestAttributeProfileFilterIndexes2(t *testing.T) { if rcvIdx, err := dataManager.GetIndexes( utils.CacheAttributeFilterIndexes, utils.ConcatenatedKey(attrProfile.Tenant, "con3"), - utils.EmptyString, false, false); err != nil { + false, false); err != nil { t.Error(err) } else if !reflect.DeepEqual(eIdxes, rcvIdx) { t.Errorf("Expecting %+v, received: %+v", eIdxes, rcvIdx) @@ -738,7 +737,7 @@ func testITTestAttributeProfileFilterIndexes2(t *testing.T) { if _, err = dataManager.GetIndexes( utils.CacheAttributeFilterIndexes, utils.ConcatenatedKey(attrProfile.Tenant, ctx), - utils.EmptyString, false, false); err == nil || + false, false); err == nil || err != utils.ErrNotFound { t.Error(err) } @@ -771,7 +770,7 @@ func testITTestAttributeProfileFilterIndexes2(t *testing.T) { if rcvIdx, err := dataManager.GetIndexes( utils.CacheAttributeFilterIndexes, utils.ConcatenatedKey(attrProfile.Tenant, ctx), - utils.EmptyString, false, false); err != nil { + false, false); err != nil { t.Error(err) } else if !reflect.DeepEqual(eIdxes, rcvIdx) { t.Errorf("Expecting %+v, received: %+v", utils.ToJSON(eIdxes), rcvIdx) @@ -786,7 +785,7 @@ func testITTestAttributeProfileFilterIndexes2(t *testing.T) { if rcvIdx, err := dataManager.GetIndexes( utils.CacheReverseFilterIndexes, fp.TenantID(), - utils.EmptyString, false, false); err != nil { + false, false); err != nil { t.Error(err) } else if !reflect.DeepEqual(eIdxes, rcvIdx) { t.Errorf("Expecting %+v, received: %+v", eIdxes, rcvIdx) @@ -800,14 +799,14 @@ func testITTestAttributeProfileFilterIndexes2(t *testing.T) { if _, err := dataManager.GetIndexes( utils.CacheAttributeFilterIndexes, utils.ConcatenatedKey("cgrates.org", "con3"), - utils.MetaString, false, false); err != nil && err != utils.ErrNotFound { + false, false, utils.MetaString); err != nil && err != utils.ErrNotFound { t.Error(err) } if _, err := dataManager.GetIndexes( utils.CacheReverseFilterIndexes, fp.TenantID(), - utils.EmptyString, false, false); err != utils.ErrNotFound { + false, false); err != utils.ErrNotFound { t.Error(err) } } @@ -856,7 +855,7 @@ func testITTestThresholdInlineFilterIndexing(t *testing.T) { } if rcvIdx, err := dataManager.GetIndexes( utils.CacheThresholdFilterIndexes, th.Tenant, - utils.EmptyString, false, false); err != nil { + false, false); err != nil { t.Error(err) } else if !reflect.DeepEqual(eIdxes, rcvIdx) { t.Errorf("Expecting %+v, received: %+v", eIdxes, rcvIdx) @@ -889,7 +888,7 @@ func testITTestThresholdInlineFilterIndexing(t *testing.T) { } if rcvIdx, err := dataManager.GetIndexes( utils.CacheThresholdFilterIndexes, th.Tenant, - utils.EmptyString, false, false); err != nil { + false, false); err != nil { t.Error(err) } else if !reflect.DeepEqual(eIdxes, rcvIdx) { t.Errorf("Expecting %+v, received: %+v", utils.ToJSON(eIdxes), utils.ToJSON(rcvIdx)) @@ -901,7 +900,7 @@ func testITTestThresholdInlineFilterIndexing(t *testing.T) { } if _, err := dataManager.GetIndexes( utils.CacheThresholdFilterIndexes, th.Tenant, - utils.EmptyString, false, false); err != utils.ErrNotFound { + false, false); err != utils.ErrNotFound { t.Error(err) } } @@ -963,7 +962,7 @@ func testITTestStoreFilterIndexesWithTransID(t *testing.T) { //verify new key and check if data was moved if rcv, err := dataManager.GetIndexes( utils.CacheResourceFilterIndexes, "cgrates.org", - utils.EmptyString, false, false); err != nil { + false, false); err != nil { t.Error(err) } else if !reflect.DeepEqual(eIdx, rcv) { t.Errorf("Expecting: %+v, received: %+v", eIdx, rcv) @@ -1028,7 +1027,7 @@ func testITResourceProfileIndexes(t *testing.T) { }, } if rcvIDx, err := dataManager.GetIndexes(utils.CacheResourceFilterIndexes, - "cgrates.org", utils.EmptyString, false, false); err != nil { + "cgrates.org", false, false); err != nil { t.Error(err) } else if !reflect.DeepEqual(rcvIDx, eIdxes) { t.Errorf("Expected %+v, received %+v", utils.ToJSON(eIdxes), utils.ToJSON(rcvIDx)) @@ -1071,7 +1070,7 @@ func testITResourceProfileIndexes(t *testing.T) { }, } if rcvIDx, err := dataManager.GetIndexes(utils.CacheResourceFilterIndexes, - "cgrates.org", utils.EmptyString, false, false); err != nil { + "cgrates.org", false, false); err != nil { t.Error(err) } else if !reflect.DeepEqual(rcvIDx, eIdxes) { t.Errorf("Expected %+v, received %+v", utils.ToJSON(eIdxes), utils.ToJSON(rcvIDx)) @@ -1087,7 +1086,7 @@ func testITResourceProfileIndexes(t *testing.T) { }, } if rcvIDx, err := dataManager.GetIndexes(utils.CacheReverseFilterIndexes, - "cgrates.org:RES_FLTR1", utils.EmptyString, false, false); err != nil { + "cgrates.org:RES_FLTR1", false, false); err != nil { t.Error(err) } else if !reflect.DeepEqual(rcvIDx, eIdxes) { t.Errorf("Expected %+v, received %+v", utils.ToJSON(eIdxes), utils.ToJSON(rcvIDx)) @@ -1095,7 +1094,7 @@ func testITResourceProfileIndexes(t *testing.T) { //as we updated our filter, the old one is deleted if _, err := dataManager.GetIndexes(utils.CacheResourceFilterIndexes, - "cgrates.org", "*string:*req.Destinations:DEST_RES1", false, false); err == nil || err != utils.ErrNotFound { + "cgrates.org", false, false, "*string:*req.Destinations:DEST_RES1"); err == nil || err != utils.ErrNotFound { t.Errorf("Expected %+v, receive %+v", utils.ErrNotFound, err) } } @@ -1164,7 +1163,7 @@ func testITStatQueueProfileIndexes(t *testing.T) { }, } if rcvIDx, err := dataManager.GetIndexes(utils.CacheStatFilterIndexes, - "cgrates.org", utils.EmptyString, false, false); err != nil { + "cgrates.org", false, false); err != nil { t.Error(err) } else if !reflect.DeepEqual(rcvIDx, eIdxes) { t.Errorf("Expected %+v, received %+v", utils.ToJSON(eIdxes), utils.ToJSON(rcvIDx)) @@ -1178,7 +1177,7 @@ func testITStatQueueProfileIndexes(t *testing.T) { }, } if rcvIDx, err := dataManager.GetIndexes(utils.CacheReverseFilterIndexes, - "cgrates.org:SQUEUE1", utils.EmptyString, false, false); err != nil { + "cgrates.org:SQUEUE1", false, false); err != nil { t.Error(err) } else if !reflect.DeepEqual(rcvIDx, eIdxes) { t.Errorf("Expected %+v, received %+v", utils.ToJSON(eIdxes), utils.ToJSON(rcvIDx)) @@ -1191,7 +1190,7 @@ func testITStatQueueProfileIndexes(t *testing.T) { }, } if rcvIDx, err := dataManager.GetIndexes(utils.CacheReverseFilterIndexes, - "cgrates.org:SQUEUE2", utils.EmptyString, false, false); err != nil { + "cgrates.org:SQUEUE2", false, false); err != nil { t.Error(err) } else if !reflect.DeepEqual(rcvIDx, eIdxes) { t.Errorf("Expected %+v, received %+v", utils.ToJSON(eIdxes), utils.ToJSON(rcvIDx)) @@ -1200,7 +1199,7 @@ func testITStatQueueProfileIndexes(t *testing.T) { //invalid tnt:context or index key eIdxes = nil if rcvIDx, err := dataManager.GetIndexes(utils.CacheStatFilterIndexes, - "cgrates.org", "*string:~*opts.ToR:~*req.Usage", false, false); err == nil || err != utils.ErrNotFound { + "cgrates.org", false, false, "*string:~*opts.ToR:~*req.Usage"); err == nil || err != utils.ErrNotFound { t.Errorf("Expected %+v, receive %+v", utils.ErrNotFound, err) } else if !reflect.DeepEqual(rcvIDx, eIdxes) { t.Errorf("Expected %+v, received %+v", utils.ToJSON(eIdxes), utils.ToJSON(rcvIDx)) @@ -1246,7 +1245,7 @@ func testITChargerProfileIndexes(t *testing.T) { }, } if rcvIDx, err := dataManager.GetIndexes(utils.CacheChargerFilterIndexes, - "cgrates.org", utils.EmptyString, false, false); err != nil { + "cgrates.org", false, false); err != nil { t.Error(err) } else if !reflect.DeepEqual(rcvIDx, expIdx) { t.Errorf("Expected %+v, received %+v", utils.ToJSON(expIdx), utils.ToJSON(rcvIDx)) @@ -1278,7 +1277,7 @@ func testITChargerProfileIndexes(t *testing.T) { }, } if rcvIDx, err := dataManager.GetIndexes(utils.CacheChargerFilterIndexes, - "cgrates.org", utils.EmptyString, false, false); err != nil { + "cgrates.org", false, false); err != nil { t.Error(err) } else if !reflect.DeepEqual(rcvIDx, expIdx) { t.Errorf("Expected %+v, received %+v", utils.ToJSON(expIdx), utils.ToJSON(rcvIDx)) @@ -1294,7 +1293,7 @@ func testITChargerProfileIndexes(t *testing.T) { }, } if rcvIDx, err := dataManager.GetIndexes(utils.CacheReverseFilterIndexes, - "cgrates.org:CHARGER_FLTR", utils.EmptyString, false, false); err != nil { + "cgrates.org:CHARGER_FLTR", false, false); err != nil { t.Error(err) } else if !reflect.DeepEqual(rcvIDx, expIdx) { t.Errorf("Expected %+v, received %+v", utils.ToJSON(expIdx), utils.ToJSON(rcvIDx)) @@ -1303,7 +1302,7 @@ func testITChargerProfileIndexes(t *testing.T) { //the old filter is deleted expIdx = nil if rcvIDx, err := dataManager.GetIndexes(utils.CacheChargerFilterIndexes, - "cgrates.org", "*string:*req.Usage", false, false); err == nil || err != utils.ErrNotFound { + "cgrates.org", false, false, "*string:*req.Usage"); err == nil || err != utils.ErrNotFound { t.Errorf("Expected %+v, received %+v", utils.Error, err) } else if !reflect.DeepEqual(rcvIDx, expIdx) { t.Errorf("Expected %+v, received %+v", utils.ToJSON(expIdx), utils.ToJSON(rcvIDx)) @@ -1367,7 +1366,7 @@ func testITDispatcherProfileIndexes(t *testing.T) { }, } if rcvIDx, err := dataManager.GetIndexes(utils.CacheDispatcherFilterIndexes, - "cgrates.org:thresholds", utils.EmptyString, false, false); err != nil { + "cgrates.org:thresholds", false, false); err != nil { t.Error(err) } else if !reflect.DeepEqual(rcvIDx, expIdx) { t.Errorf("Expected %+v, received %+v", utils.ToJSON(expIdx), utils.ToJSON(rcvIDx)) @@ -1380,7 +1379,7 @@ func testITDispatcherProfileIndexes(t *testing.T) { }, } if rcvIDx, err := dataManager.GetIndexes(utils.CacheReverseFilterIndexes, - "cgrates.org:DISPATCHER_FLTR1", utils.EmptyString, false, false); err != nil { + "cgrates.org:DISPATCHER_FLTR1", false, false); err != nil { t.Error(err) } else if !reflect.DeepEqual(rcvIDx, expIdx) { t.Errorf("Expected %+v, received %+v", utils.ToJSON(expIdx), utils.ToJSON(rcvIDx)) @@ -1392,7 +1391,7 @@ func testITDispatcherProfileIndexes(t *testing.T) { }, } if rcvIDx, err := dataManager.GetIndexes(utils.CacheReverseFilterIndexes, - "cgrates.org:DISPATCHER_FLTR2", utils.EmptyString, false, false); err != nil { + "cgrates.org:DISPATCHER_FLTR2", false, false); err != nil { t.Error(err) } else if !reflect.DeepEqual(rcvIDx, expIdx) { t.Errorf("Expected %+v, received %+v", utils.ToJSON(expIdx), utils.ToJSON(rcvIDx)) @@ -1401,7 +1400,7 @@ func testITDispatcherProfileIndexes(t *testing.T) { //invalid tnt:context or index key expIdx = nil if rcvIDx, err := dataManager.GetIndexes(utils.CacheDispatcherFilterIndexes, - "cgrates.org:attributes", utils.EmptyString, false, false); err == nil || err != utils.ErrNotFound { + "cgrates.org:attributes", false, false); err == nil || err != utils.ErrNotFound { t.Errorf("Expectedd %+v, received %+v", utils.ErrNotFound, err) } else if !reflect.DeepEqual(rcvIDx, expIdx) { t.Errorf("Expected %+v, received %+v", utils.ToJSON(expIdx), utils.ToJSON(rcvIDx)) @@ -1438,7 +1437,7 @@ func testITTestStoreFilterIndexesWithTransID2(t *testing.T) { //verify new key and check if data was moved if rcv, err := dataManager.GetIndexes( utils.CacheResourceFilterIndexes, - "cgrates.org", utils.EmptyString, false, false); err != nil { + "cgrates.org", false, false); err != nil { t.Error(err) } else if !reflect.DeepEqual(idxes, rcv) { t.Errorf("Expecting: %+v, received: %+v", utils.ToJSON(idxes), utils.ToJSON(rcv)) @@ -1477,7 +1476,7 @@ func testITTestIndexingWithEmptyFltrID(t *testing.T) { } if rcvIdx, err := dataManager.GetIndexes( utils.CacheThresholdFilterIndexes, th.Tenant, - utils.EmptyString, false, false); err != nil { + false, false); err != nil { t.Error(err) } else if !reflect.DeepEqual(eIdxes, rcvIdx) { t.Errorf("Expecting %+v, received: %+v", eIdxes, rcvIdx) @@ -1490,8 +1489,9 @@ func testITTestIndexingWithEmptyFltrID(t *testing.T) { } if rcvMp, err := dataManager.GetIndexes( utils.CacheThresholdFilterIndexes, th.Tenant, + true, true, utils.ConcatenatedKey(utils.MetaNone, utils.MetaAny, utils.MetaAny), - true, true); err != nil { + ); err != nil { t.Error(err) } else if !reflect.DeepEqual(eMp, rcvMp) { t.Errorf("Expecting: %+v, received: %+v", eMp, rcvMp) @@ -1536,7 +1536,7 @@ func testITTestIndexingWithEmptyFltrID2(t *testing.T) { } if rcvIdx, err := dataManager.GetIndexes( utils.CacheRouteFilterIndexes, splProfile.Tenant, - utils.EmptyString, false, false); err != nil { + false, false); err != nil { t.Error(err) } else if !reflect.DeepEqual(eIdxes, rcvIdx) { t.Errorf("Expecting %+v, received: %+v", utils.ToJSON(eIdxes), utils.ToJSON(rcvIdx)) @@ -1549,8 +1549,9 @@ func testITTestIndexingWithEmptyFltrID2(t *testing.T) { } if rcvMp, err := dataManager.GetIndexes( utils.CacheRouteFilterIndexes, splProfile.Tenant, + true, true, utils.ConcatenatedKey(utils.MetaNone, utils.MetaAny, utils.MetaAny), - true, true); err != nil { + ); err != nil { t.Error(err) } else if !reflect.DeepEqual(eMp, rcvMp) { t.Errorf("Expecting: %+v, received: %+v", eMp, rcvMp) @@ -1600,7 +1601,7 @@ func testITTestIndexingWithEmptyFltrID2(t *testing.T) { }, } if rcvIdx, err := dataManager.GetIndexes(utils.CacheRouteFilterIndexes, - "cgrates.org", utils.EmptyString, false, false); err != nil { + "cgrates.org", false, false); err != nil { t.Error(err) } else if !reflect.DeepEqual(expIdx, rcvIdx) { t.Errorf("Expected %+v, received %+v", utils.ToJSON(expIdx), utils.ToJSON(rcvIdx)) @@ -1613,7 +1614,7 @@ func testITTestIndexingWithEmptyFltrID2(t *testing.T) { }, } if rcvIdx, err := dataManager.GetIndexes(utils.CacheRouteFilterIndexes, - "cgrates.org", "*string:*opts.CGRID:ORG_ID", false, false); err != nil { + "cgrates.org", false, false, "*string:*opts.CGRID:ORG_ID"); err != nil { t.Error(err) } else if !reflect.DeepEqual(expIdx, rcvIdx) { t.Errorf("Expected %+v, received %+v", utils.ToJSON(expIdx), utils.ToJSON(rcvIdx)) @@ -1627,7 +1628,7 @@ func testITTestIndexingWithEmptyFltrID2(t *testing.T) { }, } if rcvIdx, err := dataManager.GetIndexes(utils.CacheReverseFilterIndexes, - "cgrates.org:FIRST", utils.EmptyString, false, false); err != nil { + "cgrates.org:FIRST", false, false); err != nil { t.Error(err) } else if !reflect.DeepEqual(expIdx, rcvIdx) { t.Errorf("Expected %+v, received %+v", utils.ToJSON(expIdx), utils.ToJSON(rcvIdx)) @@ -1635,7 +1636,7 @@ func testITTestIndexingWithEmptyFltrID2(t *testing.T) { //invalid tnt:context or index key if _, err := dataManager.GetIndexes(utils.CacheRouteFilterIndexes, - "cgrates.org", "*string:DAN:ORG_ID", false, false); err == nil || err != utils.ErrNotFound { + "cgrates.org", false, false, "*string:DAN:ORG_ID"); err == nil || err != utils.ErrNotFound { t.Errorf("Expected %+v, received %+v", utils.ErrNotFound, err) } } @@ -1679,7 +1680,7 @@ func testITTestIndexingThresholds(t *testing.T) { } if rcvIdx, err := dataManager.GetIndexes( utils.CacheThresholdFilterIndexes, th.Tenant, - utils.EmptyString, false, false); err != nil { + false, false); err != nil { t.Error(err) } else if !reflect.DeepEqual(eIdxes, rcvIdx) { t.Errorf("Expecting %+v, received: %+v", eIdxes, rcvIdx) @@ -1692,8 +1693,8 @@ func testITTestIndexingThresholds(t *testing.T) { } if rcvMp, err := dataManager.GetIndexes( utils.CacheThresholdFilterIndexes, th.Tenant, - utils.ConcatenatedKey(utils.MetaString, utils.MetaReq+utils.NestingSep+utils.AccountField, "1001"), - true, true); err != nil { + true, true, + utils.ConcatenatedKey(utils.MetaString, utils.MetaReq+utils.NestingSep+utils.AccountField, "1001")); err != nil { t.Error(err) } else if !reflect.DeepEqual(eMp, rcvMp) { t.Errorf("Expecting: %+v, received: %+v", eMp, rcvMp) @@ -1702,7 +1703,7 @@ func testITTestIndexingThresholds(t *testing.T) { t.Error(err) } else if _, err := dataManager.GetIndexes( utils.CacheThresholdFilterIndexes, th.Tenant, - utils.EmptyString, false, false); err == nil || err != utils.ErrNotFound { + false, false); err == nil || err != utils.ErrNotFound { t.Error(err) } } @@ -1745,7 +1746,7 @@ func testITTestIndexingMetaNot(t *testing.T) { } if rcvIdx, err := dataManager.GetIndexes( utils.CacheThresholdFilterIndexes, th.Tenant, - utils.EmptyString, false, false); err != nil { + false, false); err != nil { t.Error(err) } else if !reflect.DeepEqual(eIdxes, rcvIdx) { t.Errorf("Expecting %+v, received: %+v", eIdxes, rcvIdx) @@ -1757,8 +1758,8 @@ func testITTestIndexingMetaNot(t *testing.T) { } if rcvMp, err := dataManager.GetIndexes( utils.CacheThresholdFilterIndexes, th.Tenant, - utils.ConcatenatedKey(utils.MetaString, utils.MetaReq+utils.NestingSep+utils.AccountField, "1001"), - true, true); err != nil { + true, true, + utils.ConcatenatedKey(utils.MetaString, utils.MetaReq+utils.NestingSep+utils.AccountField, "1001")); err != nil { t.Error(err) } else if !reflect.DeepEqual(eMp, rcvMp) { t.Errorf("Expecting: %+v, received: %+v", eMp, rcvMp) @@ -1816,7 +1817,7 @@ func testITTestIndexingMetaSuffix(t *testing.T) { } if rcvIdx, err := dataManager.GetIndexes( utils.CacheThresholdFilterIndexes, th.Tenant, - utils.EmptyString, false, false); err != nil { + false, false); err != nil { t.Error(err) } else if !reflect.DeepEqual(eIdxes, rcvIdx) { t.Errorf("Expecting %+v,\n received: %+v", utils.ToJSON(eIdxes), utils.ToJSON(rcvIdx)) diff --git a/engine/z_filterindexer_test.go b/engine/z_filterindexer_test.go index 6da955d6c..216612b4b 100644 --- a/engine/z_filterindexer_test.go +++ b/engine/z_filterindexer_test.go @@ -131,7 +131,7 @@ func TestFilterIndexesCheckingDynamicPathToNotIndex(t *testing.T) { }, } if fltrIDx, err := dm.GetIndexes(utils.CacheAttributeFilterIndexes, - "cgrates.org:*any", utils.EmptyString, true, true); err != nil { + "cgrates.org:*any", true, true); err != nil { t.Error(err) } else if !reflect.DeepEqual(expIDx, fltrIDx) { t.Errorf("Expected %+v, received %+v", utils.ToJSON(expIDx), utils.ToJSON(fltrIDx)) @@ -171,7 +171,7 @@ func TestFilterIndexesCheckingDynamicPathToNotIndexAsm(t *testing.T) { }, } if fltrIDx, err := dm.GetIndexes(utils.CacheChargerFilterIndexes, - "cgrates.org", utils.EmptyString, true, true); err != nil { + "cgrates.org", true, true); err != nil { t.Error(err) } else if !reflect.DeepEqual(expIDx, fltrIDx) { t.Errorf("Expected %+v, received %+v", utils.ToJSON(expIDx), utils.ToJSON(fltrIDx)) @@ -211,7 +211,7 @@ func TestFilterIndexesCheckingDynamicPathToNotIndexLibphNmbr(t *testing.T) { }, } if fltrIDx, err := dm.GetIndexes(utils.CacheChargerFilterIndexes, - "cgrates.org", utils.EmptyString, true, true); err != nil { + "cgrates.org", true, true); err != nil { t.Error(err) } else if !reflect.DeepEqual(expIDx, fltrIDx) { t.Errorf("Expected %+v, received %+v", utils.ToJSON(expIDx), utils.ToJSON(fltrIDx)) diff --git a/general_tests/filter_index_test.go b/general_tests/filter_index_test.go index 2d4d7e66f..64d8e88c0 100644 --- a/general_tests/filter_index_test.go +++ b/general_tests/filter_index_test.go @@ -91,7 +91,7 @@ func TestFilterIndexUpdates(t *testing.T) { } indexes, err := dm.GetIndexes(utils.CacheAttributeFilterIndexes, "cgrates.org:simpleauth", - "", true, false) + true, false) if err != nil { if len(want) == 0 && err == utils.ErrNotFound { return diff --git a/migrator/alias_it_test.go b/migrator/alias_it_test.go index 00458c525..0acdfc6bd 100644 --- a/migrator/alias_it_test.go +++ b/migrator/alias_it_test.go @@ -228,7 +228,7 @@ func testAlsITMigrateAndMove(t *testing.T) { } if alsidx, err := alsMigrator.dmOut.DataManager().GetIndexes( utils.CacheAttributeFilterIndexes, utils.ConcatenatedKey("cgrates.org", utils.MetaAny), - "", false, false); err != nil { + false, false); err != nil { t.Error(err) } else if !reflect.DeepEqual(expAlsIdx, alsidx) { t.Errorf("Expected %v, received: %v", utils.ToJSON(expAlsIdx), utils.ToJSON(alsidx)) diff --git a/migrator/derived_chargers_it_test.go b/migrator/derived_chargers_it_test.go index 3bc177051..1884e6852 100644 --- a/migrator/derived_chargers_it_test.go +++ b/migrator/derived_chargers_it_test.go @@ -243,7 +243,7 @@ func testDCITMigrateAndMove(t *testing.T) { if dcidx, err := dcMigrator.dmOut.DataManager().GetIndexes( utils.CacheAttributeFilterIndexes, utils.ConcatenatedKey("cgrates.org", utils.MetaChargers), - "", true, true); err != nil { + true, true); err != nil { t.Error(err) } else if !reflect.DeepEqual(expDcIdx, dcidx) { t.Errorf("Expected %v, received: %v", utils.ToJSON(expDcIdx), utils.ToJSON(dcidx)) @@ -256,7 +256,7 @@ func testDCITMigrateAndMove(t *testing.T) { if dcidx, err := dcMigrator.dmOut.DataManager().GetIndexes( utils.CacheChargerFilterIndexes, utils.ConcatenatedKey("cgrates.org", utils.MetaChargers), - "", true, true); err == nil || err.Error() != utils.ErrNotFound.Error() { + true, true); err == nil || err.Error() != utils.ErrNotFound.Error() { t.Errorf("Expected error %v, received: %v with reply: %v", utils.ErrNotFound, err, utils.ToJSON(dcidx)) } else if dcMigrator.stats[utils.DerivedChargersV] != 1 { t.Errorf("Expected 1, received: %v", dcMigrator.stats[utils.DerivedChargersV]) diff --git a/migrator/filters_it_test.go b/migrator/filters_it_test.go index 0d008768d..c1e4b400e 100644 --- a/migrator/filters_it_test.go +++ b/migrator/filters_it_test.go @@ -272,7 +272,7 @@ func testFltrITMigrateAndMove(t *testing.T) { if fltridx, err := fltrMigrator.dmOut.DataManager().GetIndexes( utils.CacheAttributeFilterIndexes, utils.ConcatenatedKey(attrProf.Tenant, utils.MetaAny), - "", false, false); err != nil { + false, false); err != nil { t.Error(err) } else if !reflect.DeepEqual(expFltrIdx, fltridx) { t.Errorf("Expected %v, received: %v", utils.ToJSON(expFltrIdx), utils.ToJSON(fltridx)) @@ -470,7 +470,7 @@ func testFltrITMigratev2(t *testing.T) { if fltridx, err := fltrMigrator.dmOut.DataManager().GetIndexes( utils.CacheAttributeFilterIndexes, utils.ConcatenatedKey(attrProf.Tenant, utils.MetaAny), - "", false, true); err != nil { + false, true); err != nil { t.Error(err) } else if !reflect.DeepEqual(expFltrIdx, fltridx) { t.Errorf("Expected %v, received: %v", utils.ToJSON(expFltrIdx), utils.ToJSON(fltridx)) diff --git a/migrator/user_it_test.go b/migrator/user_it_test.go index b8b4c62e0..10647544f 100644 --- a/migrator/user_it_test.go +++ b/migrator/user_it_test.go @@ -202,7 +202,7 @@ func testUsrITMigrateAndMove(t *testing.T) { if usridx, err := usrMigrator.dmOut.DataManager().GetIndexes( utils.CacheAttributeFilterIndexes, utils.ConcatenatedKey("cgrates.org", utils.MetaAny), - "", true, true); err != nil { + true, true); err != nil { t.Error(err) } else if !reflect.DeepEqual(expUsrIdx, usridx) { t.Errorf("Expected %v, received: %v", utils.ToJSON(expUsrIdx), utils.ToJSON(usridx))