From 03bd4cac6e47da8fbc97fea6aba2c59d9d954fb3 Mon Sep 17 00:00:00 2001 From: andronache98 Date: Mon, 17 Jan 2022 10:07:00 +0200 Subject: [PATCH] Changed integration test --- apis/routes_it_test.go | 204 +++++++++++++++++++++-------------------- 1 file changed, 103 insertions(+), 101 deletions(-) diff --git a/apis/routes_it_test.go b/apis/routes_it_test.go index ccf16b5d8..8c14eb3b5 100644 --- a/apis/routes_it_test.go +++ b/apis/routes_it_test.go @@ -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) {