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

Add routes case in fullRemote integration tests

Browse Source
This commit is contained in:
TeoV
2021-02-04 10:28:46 +02:00
committed by Dan Christian Bogos
parent 8014c9dffb
commit 0e2f343c5f
1 changed files with 63 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

63
apier/v1/full_remote_it_test.go
View File

@@ -54,6 +54,7 @@ var (
testFullRemoteITStatQueue,
testFullRemoteITThreshold,
testFullRemoteITResource,
testFullRemoteITRoutes,
testFullRemoteITKillEngine,
}
@@ -364,6 +365,68 @@ func testFullRemoteITResource(t *testing.T) {
}
}
func testFullRemoteITRoutes(t *testing.T) {
// verify for not found in internal
var reply *engine.RouteProfile
if err := fullRemInternalRPC.Call(utils.APIerSv1GetRouteProfile,
utils.TenantIDWithOpts{TenantID: &utils.TenantID{Tenant: "cgrates.org", ID: "ROUTE_ACNT_1001"}},
&reply); err == nil || err.Error() != utils.ErrNotFound.Error() {
t.Fatal(err)
}
var replySet string
routePrf := &engine.RouteProfile{
Tenant: "cgrates.org",
ID: "ROUTE_ACNT_1001",
FilterIDs: []string{"*string:~*req.Account:1001"},
ActivationInterval: &utils.ActivationInterval{
ActivationTime: time.Date(2017, 11, 27, 0, 0, 0, 0, time.UTC),
},
Sorting: utils.MetaWeight,
SortingParameters: []string{},
Routes: []*engine.Route{
{
ID: "route1",
Weight: 10,
},
{
ID: "route2",
Weight: 20,
},
},
Weight: 20,
}
// add a threshold profile in engine1 and verify it internal
if err := fullRemEngineOneRPC.Call(utils.APIerSv1SetRouteProfile, routePrf, &replySet); err != nil {
t.Error(err)
} else if replySet != utils.OK {
t.Error("Unexpected reply returned", replySet)
}
if err := fullRemInternalRPC.Call(utils.APIerSv1GetRouteProfile,
utils.TenantIDWithOpts{TenantID: &utils.TenantID{Tenant: "cgrates.org", ID: "ROUTE_ACNT_1001"}},
&reply); err != nil {
t.Fatal(err)
} else if !reflect.DeepEqual(routePrf, reply) {
t.Errorf("Expecting : %+v, received: %+v", utils.ToJSON(routePrf), utils.ToJSON(reply))
}
// update the threshold profile and verify it to be updated
routePrf.FilterIDs = []string{"*string:~*req.Account:1001", "*string:~*req.Destination:1002"}
if err := fullRemEngineOneRPC.Call(utils.APIerSv1SetRouteProfile, routePrf, &replySet); err != nil {
t.Error(err)
} else if replySet != utils.OK {
t.Error("Unexpected reply returned", replySet)
}
if err := fullRemInternalRPC.Call(utils.APIerSv1GetRouteProfile,
utils.TenantIDWithOpts{TenantID: &utils.TenantID{Tenant: "cgrates.org", ID: "ROUTE_ACNT_1001"}},
&reply); err != nil {
t.Fatal(err)
} else if !reflect.DeepEqual(routePrf, reply) {
t.Errorf("Expecting : %+v, received: %+v", utils.ToJSON(routePrf), utils.ToJSON(reply))
}
}
func testFullRemoteITKillEngine(t *testing.T) {
if err := engine.KillEngine(100); err != nil {
t.Error(err)