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

Add integration test for passTimings in general_tests/filters_it_test.go

Browse Source
This commit is contained in:
ionutboangiu
2021-04-29 15:36:13 +03:00
committed by Dan Christian Bogos
parent 5c7abd097b
commit c628bc6c8a
1 changed files with 109 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

109
general_tests/filters_it_test.go
View File

@@ -24,6 +24,7 @@ import (
"net/rpc"
"path"
"reflect"
"sort"
"testing"
"time"
@@ -58,6 +59,7 @@ var (
testV1FltrAttributesPrefix,
testV1FltrInitDataDb,
testV1FltrChargerSuffix,
testV1FltrPopulateTimings,
testV1FltrStopEngine,
}
)
@@ -1063,6 +1065,113 @@ func testV1FltrAttributesPrefix(t *testing.T) {
}
func testV1FltrPopulateTimings(t *testing.T) {
timing := &utils.TPTimingWithAPIOpts{
TPTiming: &utils.TPTiming{
ID: "TM_MORNING",
WeekDays: utils.WeekDays{1, 2, 3, 4, 5},
StartTime: "08:00:00",
EndTime: "09:00:00",
},
}
var reply string
if err := fltrRpc.Call(utils.APIerSv1SetTiming, timing, &reply); err != nil {
t.Error(err)
} else if reply != utils.OK {
t.Error("Unexpected reply returned", reply)
}
filter := &engine.FilterWithAPIOpts{
Filter: &engine.Filter{
Tenant: "cgrates.org",
ID: "FLTR_TM_1",
Rules: []*engine.FilterRule{
{
Type: utils.MetaTimings,
Element: "~*req.AnswerTime",
Values: []string{"TM_MORNING"},
},
},
},
}
var result string
if err := fltrRpc.Call(utils.APIerSv1SetFilter, filter, &result); err != nil {
t.Error(err)
} else if result != utils.OK {
t.Error("Unexpected reply returned", result)
}
attrPrf := &engine.AttributeProfileWithAPIOpts{
AttributeProfile: &engine.AttributeProfile{
Tenant: "cgrates.org",
ID: "FltrTest",
Contexts: []string{utils.MetaAny},
FilterIDs: []string{"FLTR_TM_1"},
Attributes: []*engine.Attribute{
{
Path: utils.MetaReq + utils.NestingSep + utils.AnswerTime,
Value: config.NewRSRParsersMustCompile("2021-04-29T10:45:00Z", utils.InfieldSep),
},
},
Weight: 10,
},
}
attrPrf.Compile()
if err := fltrRpc.Call(utils.APIerSv1SetAttributeProfile, attrPrf, &result); err != nil {
t.Error(err)
} else if result != utils.OK {
t.Error("Unexpected reply returned", result)
}
ev := &engine.AttrArgsProcessEvent{
AttributeIDs: []string{"FltrTest"},
Context: utils.StringPointer(utils.MetaAny),
CGREvent: &utils.CGREvent{
Tenant: "cgrates.org",
ID: "testV1FltrPopulateTimings",
Event: map[string]interface{}{
utils.AnswerTime: "2021-04-29T08:35:00Z",
},
},
}
eRply := &engine.AttrSProcessEventReply{
MatchedProfiles: []string{"FltrTest"},
AlteredFields: []string{utils.MetaReq + utils.NestingSep + utils.AnswerTime},
CGREvent: &utils.CGREvent{
Tenant: "cgrates.org",
ID: "testV1FltrPopulateTimings",
Event: map[string]interface{}{
utils.AnswerTime: "2021-04-29T10:45:00Z",
},
APIOpts: make(map[string]interface{}),
},
}
var rplyEv1 engine.AttrSProcessEventReply
if err := fltrRpc.Call(utils.AttributeSv1ProcessEvent,
ev, &rplyEv1); err != nil {
t.Error(err)
} else {
sort.Strings(eRply.AlteredFields)
sort.Strings(rplyEv1.AlteredFields)
if !reflect.DeepEqual(eRply, &rplyEv1) {
t.Errorf("\nexpected: %s, \nreceived: %s",
utils.ToJSON(eRply), utils.ToJSON(rplyEv1))
}
}
ev.CGREvent.Event[utils.AnswerTime] = "2021-04-29T13:35:00Z"
var rplyEv2 engine.AttrSProcessEventReply
if err := fltrRpc.Call(utils.AttributeSv1ProcessEvent,
ev, &rplyEv2); err == nil || err.Error() != utils.ErrNotFound.Error() {
t.Errorf("Expected error: %+v,%+v", err, utils.ErrNotFound)
}
}
func testV1FltrStopEngine(t *testing.T) {
if err := engine.KillEngine(accDelay); err != nil {
t.Error(err)