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

Changed integration test

Browse Source
This commit is contained in:
andronache98
2022-01-17 10:07:00 +02:00
committed by Dan Christian Bogos
parent 82255dd6ff
commit 03bd4cac6e
1 changed files with 103 additions and 101 deletions
Download Patch File Download Diff File Expand all files Collapse all files

204
apis/routes_it_test.go
View File

@@ -24,6 +24,7 @@ package apis
import (
"path"
"reflect"
"sort"
"testing"
"github.com/cgrates/birpc"
@@ -51,8 +52,8 @@ var (
testRouteSSetRoute,
testRouteSSetRoute2,
testRouteSSetRoute3,
// testFilterSGetRoutes,
// testFilterSGetRoutesWithPrefix,
testFilterSGetRoutes,
testFilterSGetRoutesWithPrefix,
testRouteSKillEngine,
}
)
@@ -331,105 +332,106 @@ func testRouteSSetRoute3(t *testing.T) {
}
}
// func testFilterSGetRoutes(t *testing.T) {
// var reply []*engine.RouteProfile
// args := &utils.ArgsItemIDs{}
// expected := []*engine.RouteProfile{
// {
// ID: "ROUTE_ACNT_1001",
// Tenant: "cgrates.org",
// Weights: ";10",
// Sorting: utils.MetaWeight,
// SortingParameters: []string{},
// Routes: []*engine.Route{
// {
// ID: "route1",
// Weights: ";20",
// },
// },
// },
// {
// ID: "PrefixROUTE_ACNT_1002",
// Tenant: "cgrates.org",
// Weights: ";10",
// Sorting: utils.MetaWeight,
// SortingParameters: []string{},
// Routes: []*engine.Route{
// {
// ID: "route1",
// Weights: ";20",
// },
// },
// },
// {
// ID: "PrefixROUTE_ACNT_1003",
// Tenant: "cgrates.org",
// Weights: ";10",
// Sorting: utils.MetaWeight,
// SortingParameters: []string{},
// Routes: []*engine.Route{
// {
// ID: "route1",
// Weights: ";20",
// },
// },
// },
// }
// if err := roRPC.Call(context.Background(), utils.AdminSv1GetRouteProfiles,
// args, &reply); err != nil {
// t.Error(err)
// }
// sort.Slice(reply, func(i, j int) bool {
// return (reply)[i].ID < (reply)[j].ID
// })
// if !reflect.DeepEqual(reply, expected) {
// t.Errorf("Expected %+v \n, received %+v", utils.ToJSON(expected), utils.ToJSON(reply))
// }
// }
// func testFilterSGetRoutesWithPrefix(t *testing.T) {
// var reply []*engine.RouteProfile
// args := &utils.ArgsItemIDs{
// ItemsPrefix: "PrefixROUTE",
// }
// expected := []*engine.RouteProfile{
// {
// ID: "PrefixROUTE_ACNT_1002",
// Tenant: "cgrates.org",
// Weights: ";10",
// Sorting: utils.MetaWeight,
// SortingParameters: []string{},
// Routes: []*engine.Route{
// {
// ID: "route1",
// Weights: ";20",
// },
// },
// },
// {
// ID: "PrefixROUTE_ACNT_1003",
// Tenant: "cgrates.org",
// Weights: ";10",
// Sorting: utils.MetaWeight,
// SortingParameters: []string{},
// Routes: []*engine.Route{
// {
// ID: "route1",
// Weights: ";20",
// },
// },
// },
// }
// if err := roRPC.Call(context.Background(), utils.AdminSv1GetRouteProfiles,
// args, &reply); err != nil {
// t.Error(err)
// }
// sort.Slice(reply, func(i, j int) bool {
// return (reply)[i].ID < (reply)[j].ID
// })
// if !reflect.DeepEqual(reply, expected) {
// t.Errorf("Expected %+v \n, received %+v", utils.ToJSON(expected), utils.ToJSON(reply))
// }
// }
func testFilterSGetRoutes(t *testing.T) {
var reply []*engine.APIRouteProfile
args := &utils.ArgsItemIDs{}
expected := []*engine.APIRouteProfile{
{
ID: "PrefixROUTE_ACNT_1002",
Tenant: "cgrates.org",
Weights: ";10",
Sorting: utils.MetaWeight,
SortingParameters: []string{},
Routes: []*engine.ExternalRoute{
{
ID: "route1",
Weights: ";20",
},
},
},
{
ID: "PrefixROUTE_ACNT_1003",
Tenant: "cgrates.org",
Weights: ";10",
Sorting: utils.MetaWeight,
SortingParameters: []string{},
Routes: []*engine.ExternalRoute{
{
ID: "route1",
Weights: ";20",
},
},
},
{
ID: "ROUTE_ACNT_1001",
Tenant: "cgrates.org",
Weights: ";10",
Sorting: utils.MetaWeight,
SortingParameters: []string{},
Routes: []*engine.ExternalRoute{
{
ID: "route1",
Weights: ";20",
},
},
},
}
if err := roRPC.Call(context.Background(), utils.AdminSv1GetRouteProfiles,
args, &reply); err != nil {
t.Error(err)
}
sort.Slice(reply, func(i, j int) bool {
return (reply)[i].ID < (reply)[j].ID
})
if !reflect.DeepEqual(reply, expected) {
t.Errorf("Expected %+v \n, received %+v", utils.ToJSON(expected), utils.ToJSON(reply))
}
}
func testFilterSGetRoutesWithPrefix(t *testing.T) {
var reply []*engine.APIRouteProfile
args := &utils.ArgsItemIDs{
ItemsPrefix: "PrefixROUTE",
}
expected := []*engine.APIRouteProfile{
{
ID: "PrefixROUTE_ACNT_1002",
Tenant: "cgrates.org",
Weights: ";10",
Sorting: utils.MetaWeight,
SortingParameters: []string{},
Routes: []*engine.ExternalRoute{
{
ID: "route1",
Weights: ";20",
},
},
},
{
ID: "PrefixROUTE_ACNT_1003",
Tenant: "cgrates.org",
Weights: ";10",
Sorting: utils.MetaWeight,
SortingParameters: []string{},
Routes: []*engine.ExternalRoute{
{
ID: "route1",
Weights: ";20",
},
},
},
}
if err := roRPC.Call(context.Background(), utils.AdminSv1GetRouteProfiles,
args, &reply); err != nil {
t.Error(err)
}
sort.Slice(reply, func(i, j int) bool {
return (reply)[i].ID < (reply)[j].ID
})
if !reflect.DeepEqual(reply, expected) {
t.Errorf("Expected %+v \n, received %+v", utils.ToJSON(expected), utils.ToJSON(reply))
}
}
//Kill the engine when it is about to be finished
func testRouteSKillEngine(t *testing.T) {