uppal/cgrates
1
0
Fork 1
mirror of https://github.com/cgrates/cgrates.git synced 2026-02-15 05:09:54 +05:00
Code Issues Packages Projects Releases Wiki Activity

Finished tests for ProfileIgnoreFilters option

Browse Source
This commit is contained in:
andronache
2021-10-21 17:50:00 +03:00
committed by Dan Christian Bogos
parent 2af41dd937
commit 1b7108eb7a
2 changed files with 184 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

48
engine/thresholds_test.go
View File

@@ -2981,7 +2981,7 @@ func TestThresholdsProcessEventIgnoreFilters(t *testing.T) {
dm := NewDataManager(data, cfg.CacheCfg(), nil)
filterS := NewFilterS(cfg, nil, dm)
tS := NewThresholdService(dm, cfg, filterS, nil)
cfg.StatSCfg().Opts.ProfileIgnoreFilters = []*utils.DynamicBoolOpt{
cfg.ThresholdSCfg().Opts.ProfileIgnoreFilters = []*utils.DynamicBoolOpt{
{
Value: true,
},
@@ -3040,3 +3040,49 @@ func TestThresholdsProcessEventIgnoreFilters(t *testing.T) {
t.Errorf("expected: <%+v>, \nreceived: <%+v>", exp2, rcv2)
}
}
func TestThresholdsProcessEventIgnoreFiltersErr(t *testing.T) {
cfg := config.NewDefaultCGRConfig()
data := NewInternalDB(nil, nil, true)
dm := NewDataManager(data, cfg.CacheCfg(), nil)
filterS := NewFilterS(cfg, nil, dm)
tS := NewThresholdService(dm, cfg, filterS, nil)
cfg.ThresholdSCfg().Opts.ProfileIgnoreFilters = []*utils.DynamicBoolOpt{
{
Value: true,
},
}
thPrf := &ThresholdProfile{
Tenant: "cgrates.org",
ID: "TH",
FilterIDs: []string{"*string:~*req.Threshold:testThresholdValue"},
}
th := &Threshold{
Tenant: "cgrates.org",
ID: "TH",
tPrfl: thPrf,
}
if err := dm.SetThresholdProfile(context.Background(), thPrf, true); err != nil {
t.Error(err)
}
if err := dm.SetThreshold(context.Background(), th); err != nil {
t.Error(err)
}
args := &utils.CGREvent{
Tenant: "cgrates.org",
ID: "ThdProcessEvent",
Event: map[string]interface{}{
"Threshold": "testThresholdValue",
},
APIOpts: map[string]interface{}{
utils.OptsThresholdsProfileIDs: []string{"TH"},
utils.MetaProfileIgnoreFilters: time.Second,
},
}
if _, err := tS.processEvent(context.Background(), args.Tenant, args); err == nil || err.Error() != "cannot convert field: 1s to bool" {
t.Errorf("expected: <%+v>, \nreceived: <%+v>", nil, err)
}
}

137
rates/rates_test.go
View File

@@ -1181,3 +1181,140 @@ func TestCDRProcessRatesCostForEvent(t *testing.T) {
engine.Cache = cache
}
func TestRateProfileCostForEventProfileIgnoreFilters(t *testing.T) {
defaultCfg := config.NewDefaultCGRConfig()
defaultCfg.RateSCfg().Opts.ProfileIgnoreFilters = []*utils.DynamicBoolOpt{
{
Value: true,
},
}
data := engine.NewInternalDB(nil, nil, true)
dm := engine.NewDataManager(data, config.CgrConfig().CacheCfg(), nil)
filters := engine.NewFilterS(defaultCfg, nil, dm)
rateS := NewRateS(defaultCfg, filters, dm)
minDecimal, err := utils.NewDecimalFromUsage("1m")
if err != nil {
t.Error(err)
}
rPrf := &utils.RateProfile{
Tenant: "cgrates.org",
ID: "RATE_1",
FilterIDs: []string{"*string:~*req.Account:1001",
"*string:~*req.TestField:testValue"},
Weights: utils.DynamicWeights{
{
Weight: 50,
},
},
Rates: map[string]*utils.Rate{
"RATE1": {
ID: "RATE1",
Weights: utils.DynamicWeights{
{
Weight: 0,
},
},
ActivationTimes: "* * * * *",
IntervalRates: []*utils.IntervalRate{
{
IntervalStart: utils.NewDecimal(0, 0),
RecurrentFee: utils.NewDecimal(2, 1),
Unit: minDecimal,
Increment: minDecimal,
},
},
},
},
}
//MatchItmID before setting
if _, err := rateS.rateProfileCostForEvent(context.Background(), rPrf, &utils.CGREvent{
Tenant: "cgrates.org",
ID: "RATE_1",
Event: map[string]interface{}{
utils.AccountField: "1001"}}, rateS.cfg.RateSCfg().Verbosity); err == nil || err != utils.ErrNotFound {
t.Error(err)
}
if err := rateS.dm.SetRateProfile(context.Background(), rPrf, true); err != nil {
t.Error(err)
}
expectedRPCost := &utils.RateProfileCost{
ID: "RATE_1",
Cost: utils.NewDecimal(2, 1),
CostIntervals: []*utils.RateSIntervalCost{
{
Increments: []*utils.RateSIncrementCost{
{
RateIntervalIndex: 0,
RateID: "RATE1",
CompressFactor: 1,
Usage: utils.NewDecimal(int64(time.Minute), 0),
},
},
CompressFactor: 1,
},
},
Rates: map[string]*utils.IntervalRate{
"RATE1": {
IntervalStart: utils.NewDecimal(0, 0),
RecurrentFee: utils.NewDecimal(2, 1),
Unit: minDecimal,
Increment: minDecimal,
},
},
}
if rcv, err := rateS.rateProfileCostForEvent(context.Background(), rPrf, &utils.CGREvent{
Tenant: "cgrates.org",
ID: "RATE_1",
Event: map[string]interface{}{
utils.AccountField: "1001"}}, rateS.cfg.RateSCfg().Verbosity); err != nil {
t.Error(err)
} else {
rtsIntrvl := []*utils.RateSInterval{
{
Increments: []*utils.RateSIncrement{
{
RateIntervalIndex: 0,
RateID: "RATE1",
CompressFactor: 1,
Usage: utils.NewDecimal(int64(time.Minute), 0),
},
},
CompressFactor: 1,
},
}
rtsIntrvl[0].Cost(expectedRPCost.Rates)
expectedRPCost.CostIntervals[0] = rtsIntrvl[0].AsRatesIntervalsCost()
if !rcv.Equals(expectedRPCost) {
t.Errorf("Expected %+v\n, received %+v", utils.ToJSON(expectedRPCost), utils.ToJSON(rcv))
}
}
event := &utils.CGREvent{
Tenant: "cgrates.org",
ID: "RATE_1",
Event: map[string]interface{}{
utils.AccountField: "1001",
"TestField": "testValue1",
},
APIOpts: map[string]interface{}{
utils.OptsRatesProfileIDs: []string{"RATE_1"},
utils.MetaProfileIgnoreFilters: true,
},
}
expRpCostAfterV1 := expectedRPCost
if err := rateS.V1CostForEvent(context.Background(), event, expectedRPCost); err != nil {
t.Error(err)
} else if !reflect.DeepEqual(expectedRPCost, expRpCostAfterV1) {
t.Errorf("Expected %+v, received %+v", utils.ToJSON(expRpCostAfterV1), utils.ToJSON(expectedRPCost))
}
//fmt.Printf("received costV1: \n%s\n", utils.ToIJSON(expectedRPCost))
if err := dm.RemoveRateProfile(context.Background(), rPrf.Tenant, rPrf.ID, true); err != nil {
t.Error(err)
}
}