diff --git a/general_tests/filtered_replication_it_test.go b/general_tests/filtered_replication_it_test.go index a34686e99..500ae7693 100644 --- a/general_tests/filtered_replication_it_test.go +++ b/general_tests/filtered_replication_it_test.go @@ -21,526 +21,526 @@ along with this program. If not, see package general_tests -// import ( -// "path" -// "reflect" -// "testing" -// "time" +import ( + "path" + "reflect" + "testing" -// "github.com/cgrates/birpc" -// "github.com/cgrates/birpc/context" -// "github.com/cgrates/cgrates/config" -// "github.com/cgrates/cgrates/engine" -// "github.com/cgrates/cgrates/utils" -// ) + "github.com/cgrates/birpc" + "github.com/cgrates/birpc/context" + "github.com/cgrates/cgrates/config" + "github.com/cgrates/cgrates/engine" + "github.com/cgrates/cgrates/utils" +) -// var ( -// fltrRplDB string +var ( + fltrRplDB string -// fltrRplInternalCfgPath string -// fltrRplInternalCfg *config.CGRConfig -// fltrRplInternalRPC birpc.ClientConnector + fltrRplInternalCfgPath string + fltrRplInternalCfg *config.CGRConfig + fltrRplInternalRPC birpc.ClientConnector -// fltrRplEngine1CfgPath string -// fltrRplEngine1Cfg *config.CGRConfig -// fltrRplEngine1RPC birpc.ClientConnector + fltrRplEngine1CfgPath string + fltrRplEngine1Cfg *config.CGRConfig + fltrRplEngine1RPC birpc.ClientConnector -// fltrRplEngine2CfgPath string -// fltrRplEngine2Cfg *config.CGRConfig -// fltrRplEngine2RPC birpc.ClientConnector + fltrRplEngine2CfgPath string + fltrRplEngine2Cfg *config.CGRConfig + fltrRplEngine2RPC birpc.ClientConnector -// sTestsFltrRpl = []func(t *testing.T){ -// testFltrRplInitCfg, -// testFltrRplInitDBs, -// testFltrRplStartEngine, -// testFltrRplRPCConn, + sTestsFltrRpl = []func(t *testing.T){ + testFltrRplInitCfg, + testFltrRplInitDBs, + testFltrRplStartEngine, + testFltrRplRPCConn, -// testFltrRplAttributeProfile, -// testFltrRplFilters, -// testFltrRplThresholdProfile, -// testFltrRplStatQueueProfile, -// testFltrRplResourceProfile, -// testFltrRplRouteProfile, -// testFltrRplChargerProfile, -// testFltrRplDispatcherProfile, -// testFltrRplDispatcherHost, -// testFltrRplRateProfile, -// testFltrRplActionProfile, -// testFltrRplAccount1, -// testFltrRplAccount, -// testFltrRplDestination, + // testFltrRplAttributeProfile, + // testFltrRplFilters, + // testFltrRplThresholdProfile, + // testFltrRplStatQueueProfile, + // testFltrRplResourceProfile, + // testFltrRplRouteProfile, + // testFltrRplChargerProfile, + // testFltrRplDispatcherProfile, + // testFltrRplDispatcherHost, + // testFltrRplRateProfile, + // testFltrRplActionProfile, + // testFltrRplAccount1, + // testFltrRplAccount, + //testFltrRplDestination, -// testFltrRplKillEngine, -// } -// ) + testFltrRplKillEngine, + } +) -// //Test start here -// func TestFilteredReplication(t *testing.T) { -// switch *dbType { -// case utils.MetaMySQL: -// fltrRplDB = "redis" -// case utils.MetaMongo: -// fltrRplDB = "mongo" -// case utils.MetaPostgres, utils.MetaInternal: -// t.SkipNow() -// default: -// t.Fatal("Unknown Database type") -// } -// for _, stest := range sTestsFltrRpl { -// t.Run("TestFilteredReplication_"+fltrRplDB, stest) -// } -// } +//Test start here +func TestFilteredReplication(t *testing.T) { + switch *dbType { + case utils.MetaMySQL: + fltrRplDB = "redis" + case utils.MetaMongo: + fltrRplDB = "mongo" + case utils.MetaPostgres, utils.MetaInternal: + t.SkipNow() + default: + t.Fatal("Unknown Database type") + } + for _, stest := range sTestsFltrRpl { + t.Run("TestFilteredReplication_"+fltrRplDB, stest) + } +} -// func testFltrRplInitCfg(t *testing.T) { -// var err error +func testFltrRplInitCfg(t *testing.T) { + var err error -// fltrRplInternalCfgPath = path.Join(*dataDir, "conf", "samples", "filtered_replication", "internal") -// fltrRplEngine1CfgPath = path.Join(*dataDir, "conf", "samples", "filtered_replication", "engine1_"+fltrRplDB) -// fltrRplEngine2CfgPath = path.Join(*dataDir, "conf", "samples", "filtered_replication", "engine2_"+fltrRplDB) + fltrRplInternalCfgPath = path.Join(*dataDir, "conf", "samples", "filtered_replication", "internal") + fltrRplEngine1CfgPath = path.Join(*dataDir, "conf", "samples", "filtered_replication", "engine1_"+fltrRplDB) + fltrRplEngine2CfgPath = path.Join(*dataDir, "conf", "samples", "filtered_replication", "engine2_"+fltrRplDB) -// if fltrRplInternalCfg, err = config.NewCGRConfigFromPath(context.Background(), fltrRplInternalCfgPath); err != nil { -// t.Fatal(err) -// } -// if fltrRplEngine1Cfg, err = config.NewCGRConfigFromPath(context.Background(), fltrRplEngine1CfgPath); err != nil { -// t.Fatal(err) -// } -// if fltrRplEngine2Cfg, err = config.NewCGRConfigFromPath(context.Background(), fltrRplEngine2CfgPath); err != nil { -// t.Fatal(err) -// } -// } + if fltrRplInternalCfg, err = config.NewCGRConfigFromPath(context.Background(), fltrRplInternalCfgPath); err != nil { + t.Fatal(err) + } + if fltrRplEngine1Cfg, err = config.NewCGRConfigFromPath(context.Background(), fltrRplEngine1CfgPath); err != nil { + t.Fatal(err) + } + if fltrRplEngine2Cfg, err = config.NewCGRConfigFromPath(context.Background(), fltrRplEngine2CfgPath); err != nil { + t.Fatal(err) + } +} -// func testFltrRplInitDBs(t *testing.T) { -// if err := engine.InitDataDB(fltrRplEngine1Cfg); err != nil { -// t.Fatal(err) -// } +func testFltrRplInitDBs(t *testing.T) { + if err := engine.InitDataDB(fltrRplEngine1Cfg); err != nil { + t.Fatal(err) + } -// if err := engine.InitStorDB(fltrRplEngine1Cfg); err != nil { -// t.Fatal(err) -// } + if err := engine.InitStorDB(fltrRplEngine1Cfg); err != nil { + t.Fatal(err) + } -// if err := engine.InitDataDB(fltrRplEngine2Cfg); err != nil { -// t.Fatal(err) -// } + if err := engine.InitDataDB(fltrRplEngine2Cfg); err != nil { + t.Fatal(err) + } -// if err := engine.InitStorDB(fltrRplEngine2Cfg); err != nil { -// t.Fatal(err) -// } -// } + if err := engine.InitStorDB(fltrRplEngine2Cfg); err != nil { + t.Fatal(err) + } +} -// func testFltrRplStartEngine(t *testing.T) { -// if _, err := engine.StopStartEngine(fltrRplInternalCfgPath, *waitRater); err != nil { -// t.Fatal(err) -// } -// if _, err := engine.StartEngine(fltrRplEngine1CfgPath, *waitRater); err != nil { -// t.Fatal(err) -// } -// if _, err := engine.StartEngine(fltrRplEngine2CfgPath, *waitRater); err != nil { -// t.Fatal(err) -// } -// } +func testFltrRplStartEngine(t *testing.T) { + if _, err := engine.StopStartEngine(fltrRplInternalCfgPath, *waitRater); err != nil { + t.Fatal(err) + } + if _, err := engine.StartEngine(fltrRplEngine1CfgPath, *waitRater); err != nil { + t.Fatal(err) + } + if _, err := engine.StartEngine(fltrRplEngine2CfgPath, *waitRater); err != nil { + t.Fatal(err) + } +} -// func testFltrRplRPCConn(t *testing.T) { -// var err error -// tmp := *encoding -// // run only under *gob encoding -// *encoding = utils.MetaGOB -// if fltrRplInternalRPC, err = newRPCClient(fltrRplInternalCfg.ListenCfg()); err != nil { -// t.Fatal(err) -// } -// if fltrRplEngine1RPC, err = newRPCClient(fltrRplEngine1Cfg.ListenCfg()); err != nil { -// t.Fatal(err) -// } -// if fltrRplEngine2RPC, err = newRPCClient(fltrRplEngine2Cfg.ListenCfg()); err != nil { -// t.Fatal(err) -// } -// *encoding = tmp -// } +func testFltrRplRPCConn(t *testing.T) { + var err error + tmp := *encoding + // run only under *gob encoding + *encoding = utils.MetaGOB + if fltrRplInternalRPC, err = newRPCClient(fltrRplInternalCfg.ListenCfg()); err != nil { + t.Fatal(err) + } + if fltrRplEngine1RPC, err = newRPCClient(fltrRplEngine1Cfg.ListenCfg()); err != nil { + t.Fatal(err) + } + if fltrRplEngine2RPC, err = newRPCClient(fltrRplEngine2Cfg.ListenCfg()); err != nil { + t.Fatal(err) + } + *encoding = tmp +} -// func testFltrRplAttributeProfile(t *testing.T) { -// attrID := "ATTR1" -// attrPrf := &engine.AttributeProfileWithAPIOpts{ -// AttributeProfile: &engine.AttributeProfile{ -// Tenant: "cgrates.org", -// ID: attrID, -// FilterIDs: []string{"*string:~*req.Account:dan"}, -// Attributes: []*engine.Attribute{ -// { -// Path: "*req.Category", -// Value: config.NewRSRParsersMustCompile(utils.MetaVoice, utils.InfieldSep), -// }, -// }, -// Weight: 10, -// }, -// } -// var result string -// var replyPrfl *engine.AttributeProfile -// var rplyIDs []string -// // empty -// if err := fltrRplEngine1RPC.Call(context.Background(), utils.APIerSv1GetAttributeProfileIDs, &utils.PaginatorWithTenant{}, &rplyIDs); err == nil || -// err.Error() != utils.ErrNotFound.Error() { -// t.Fatalf("Unexpected error: %v", err) -// } -// if err := fltrRplEngine2RPC.Call(utils.APIerSv1GetAttributeProfileIDs, &utils.PaginatorWithTenant{}, &rplyIDs); err == nil || -// err.Error() != utils.ErrNotFound.Error() { -// t.Fatalf("Unexpected error: %v", err) -// } +func testFltrRplAttributeProfile(t *testing.T) { + attrID := "ATTR1" + attrPrf := &engine.APIAttributeProfileWithAPIOpts{ + APIAttributeProfile: &engine.APIAttributeProfile{ + Tenant: "cgrates.org", + ID: attrID, + FilterIDs: []string{"*string:~*req.Account:dan"}, + Attributes: []*engine.ExternalAttribute{ + { + Path: "*req.Category", + Type: utils.MetaVoice, + Value: utils.InfieldSep, + }, + }, + Weight: 10, + }, + } + var result string + var replyPrfl *engine.APIAttributeProfile + var rplyIDs []string + // empty + if err := fltrRplEngine1RPC.Call(context.Background(), utils.AdminSv1GetAttributeProfileIDs, &utils.PaginatorWithTenant{}, &rplyIDs); err == nil || + err.Error() != utils.ErrNotFound.Error() { + t.Fatalf("Unexpected error: %v", err) + } + if err := fltrRplEngine2RPC.Call(context.Background(), utils.AdminSv1GetAttributeProfileIDs, &utils.PaginatorWithTenant{}, &rplyIDs); err == nil || + err.Error() != utils.ErrNotFound.Error() { + t.Fatalf("Unexpected error: %v", err) + } -// if err := fltrRplInternalRPC.Call(utils.APIerSv1SetAttributeProfile, attrPrf, &result); err != nil { -// t.Fatal(err) -// } else if result != utils.OK { -// t.Error("Unexpected reply returned", result) -// } -// if err := fltrRplInternalRPC.Call(utils.APIerSv1GetAttributeProfile, -// utils.TenantIDWithAPIOpts{TenantID: &utils.TenantID{Tenant: "cgrates.org", ID: attrID}}, &replyPrfl); err != nil { -// t.Fatal(err) -// } -// replyPrfl.Compile() -// if !reflect.DeepEqual(attrPrf.AttributeProfile, replyPrfl) { -// t.Errorf("Expecting : %s, received: %s", utils.ToJSON(attrPrf.AttributeProfile), utils.ToJSON(replyPrfl)) -// } -// replyPrfl = nil + if err := fltrRplInternalRPC.Call(context.Background(), utils.AdminSv1SetAttributeProfile, attrPrf, &result); err != nil { + t.Fatal(err) + } else if result != utils.OK { + t.Error("Unexpected reply returned", result) + } + if err := fltrRplInternalRPC.Call(context.Background(), utils.AdminSv1GetAttributeProfile, + utils.TenantIDWithAPIOpts{TenantID: &utils.TenantID{Tenant: "cgrates.org", ID: attrID}}, &replyPrfl); err != nil { + t.Fatal(err) + } -// if err := fltrRplEngine1RPC.Call(context.Background(), utils.APIerSv1GetAttributeProfileIDs, &utils.PaginatorWithTenant{}, &rplyIDs); err == nil || -// err.Error() != utils.ErrNotFound.Error() { -// t.Fatalf("Unexpected error: %v", err) -// } -// if err := fltrRplEngine2RPC.Call(utils.APIerSv1GetAttributeProfileIDs, &utils.PaginatorWithTenant{}, &rplyIDs); err == nil || -// err.Error() != utils.ErrNotFound.Error() { -// t.Fatalf("Unexpected error: %v", err) -// } + if !reflect.DeepEqual(attrPrf.APIAttributeProfile, replyPrfl) { + t.Errorf("Expecting : %s, received: %s", utils.ToJSON(attrPrf.APIAttributeProfile), utils.ToJSON(replyPrfl)) + } + replyPrfl = nil -// if err := fltrRplEngine1RPC.Call(context.Background(), utils.APIerSv1GetAttributeProfile, -// utils.TenantIDWithAPIOpts{TenantID: &utils.TenantID{Tenant: "cgrates.org", ID: attrID}}, &replyPrfl); err != nil { -// t.Fatal(err) -// } -// replyPrfl.Compile() -// if !reflect.DeepEqual(attrPrf.AttributeProfile, replyPrfl) { -// t.Errorf("Expecting : %s, received: %s", utils.ToJSON(attrPrf.AttributeProfile), utils.ToJSON(replyPrfl)) -// } -// replyPrfl = nil -// attrPrf.Weight = 15 -// if err := fltrRplInternalRPC.Call(utils.APIerSv1SetAttributeProfile, attrPrf, &result); err != nil { -// t.Fatal(err) -// } else if result != utils.OK { -// t.Error("Unexpected reply returned", result) -// } -// if err := fltrRplInternalRPC.Call(utils.APIerSv1GetAttributeProfile, -// utils.TenantIDWithAPIOpts{TenantID: &utils.TenantID{Tenant: "cgrates.org", ID: attrID}}, &replyPrfl); err != nil { -// t.Fatal(err) -// } -// replyPrfl.Compile() -// if !reflect.DeepEqual(attrPrf.AttributeProfile, replyPrfl) { -// t.Errorf("Expecting : %s, received: %s", utils.ToJSON(attrPrf.AttributeProfile), utils.ToJSON(replyPrfl)) -// } -// replyPrfl = nil + if err := fltrRplEngine1RPC.Call(context.Background(), utils.AdminSv1GetAttributeProfileIDs, &utils.PaginatorWithTenant{}, &rplyIDs); err == nil || + err.Error() != utils.ErrNotFound.Error() { + t.Fatalf("Unexpected error: %v", err) + } + if err := fltrRplEngine2RPC.Call(context.Background(), utils.AdminSv1GetAttributeProfileIDs, &utils.PaginatorWithTenant{}, &rplyIDs); err == nil || + err.Error() != utils.ErrNotFound.Error() { + t.Fatalf("Unexpected error: %v", err) + } -// // use replicator to see if the attribute was changed in the DB -// if err := fltrRplEngine1RPC.Call(context.Background(), utils.ReplicatorSv1GetAttributeProfile, -// utils.TenantIDWithAPIOpts{TenantID: &utils.TenantID{Tenant: "cgrates.org", ID: attrID}}, &replyPrfl); err != nil { -// t.Fatal(err) -// } -// replyPrfl.Compile() -// if !reflect.DeepEqual(attrPrf.AttributeProfile, replyPrfl) { -// t.Errorf("Expecting : %s, received: %s", utils.ToJSON(attrPrf.AttributeProfile), utils.ToJSON(replyPrfl)) -// } + if err := fltrRplEngine1RPC.Call(context.Background(), utils.AdminSv1GetAttributeProfile, + utils.TenantIDWithAPIOpts{TenantID: &utils.TenantID{Tenant: "cgrates.org", ID: attrID}}, &replyPrfl); err != nil { + t.Fatal(err) + } -// if err := fltrRplEngine2RPC.Call(utils.APIerSv1GetAttributeProfileIDs, &utils.PaginatorWithTenant{}, &rplyIDs); err == nil || -// err.Error() != utils.ErrNotFound.Error() { -// t.Fatalf("Unexpected error: %v", err) -// } + if !reflect.DeepEqual(attrPrf.APIAttributeProfile, replyPrfl) { + t.Errorf("Expecting : %s, received: %s", utils.ToJSON(attrPrf.APIAttributeProfile), utils.ToJSON(replyPrfl)) + } + replyPrfl = nil + attrPrf.Weight = 15 + if err := fltrRplInternalRPC.Call(context.Background(), utils.AdminSv1SetAttributeProfile, attrPrf, &result); err != nil { + t.Fatal(err) + } else if result != utils.OK { + t.Error("Unexpected reply returned", result) + } + if err := fltrRplInternalRPC.Call(context.Background(), utils.AdminSv1GetAttributeProfile, + utils.TenantIDWithAPIOpts{TenantID: &utils.TenantID{Tenant: "cgrates.org", ID: attrID}}, &replyPrfl); err != nil { + t.Fatal(err) + } -// if err := fltrRplInternalRPC.Call(utils.APIerSv1RemoveAttributeProfile, -// utils.TenantIDWithAPIOpts{TenantID: &utils.TenantID{Tenant: "cgrates.org", ID: attrID}}, &result); err != nil { -// t.Error(err) -// } else if result != utils.OK { -// t.Error("Unexpected reply returned", result) -// } -// if err := fltrRplEngine1RPC.Call(context.Background(), utils.APIerSv1GetAttributeProfileIDs, &utils.PaginatorWithTenant{}, &rplyIDs); err == nil || -// err.Error() != utils.ErrNotFound.Error() { -// t.Fatalf("Unexpected error: %v", err) -// } -// if err := fltrRplEngine2RPC.Call(utils.APIerSv1GetAttributeProfileIDs, &utils.PaginatorWithTenant{}, &rplyIDs); err == nil || -// err.Error() != utils.ErrNotFound.Error() { -// t.Fatalf("Unexpected error: %v", err) -// } -// } + if !reflect.DeepEqual(attrPrf.APIAttributeProfile, replyPrfl) { + t.Errorf("Expecting : %s, received: %s", utils.ToJSON(attrPrf.APIAttributeProfile), utils.ToJSON(replyPrfl)) + } + replyPrfl = nil -// func testFltrRplFilters(t *testing.T) { -// fltrID := "FLTR1" -// fltr := &engine.FilterWithAPIOpts{ -// Filter: &engine.Filter{ -// Tenant: "cgrates.org", -// ID: fltrID, -// Rules: []*engine.FilterRule{{ -// Element: "~*req.Account", -// Type: utils.MetaString, -// Values: []string{"dan"}, -// }}, -// }, -// } -// fltr.Compile() -// var result string -// var replyPrfl *engine.Filter -// var rplyIDs []string -// // empty -// if err := fltrRplEngine1RPC.Call(context.Background(), utils.APIerSv1GetFilterIDs, &utils.PaginatorWithTenant{}, &rplyIDs); err == nil || -// err.Error() != utils.ErrNotFound.Error() { -// t.Fatalf("Unexpected error: %v", err) -// } -// if err := fltrRplEngine2RPC.Call(utils.APIerSv1GetFilterIDs, &utils.PaginatorWithTenant{}, &rplyIDs); err == nil || -// err.Error() != utils.ErrNotFound.Error() { -// t.Fatalf("Unexpected error: %v", err) -// } + // use replicator to see if the attribute was changed in the DB + if err := fltrRplEngine1RPC.Call(context.Background(), utils.ReplicatorSv1GetAttributeProfile, + utils.TenantIDWithAPIOpts{TenantID: &utils.TenantID{Tenant: "cgrates.org", ID: attrID}}, &replyPrfl); err != nil { + t.Fatal(err) + } -// if err := fltrRplInternalRPC.Call(utils.APIerSv1SetFilter, fltr, &result); err != nil { -// t.Fatal(err) -// } else if result != utils.OK { -// t.Error("Unexpected reply returned", result) -// } -// if err := fltrRplInternalRPC.Call(utils.APIerSv1GetFilter, -// &utils.TenantID{Tenant: "cgrates.org", ID: fltrID}, &replyPrfl); err != nil { -// t.Fatal(err) -// } -// replyPrfl.Compile() -// if !reflect.DeepEqual(fltr.Filter, replyPrfl) { -// t.Errorf("Expecting : %s, received: %s", utils.ToJSON(fltr.Filter), utils.ToJSON(replyPrfl)) -// } -// replyPrfl = nil + if !reflect.DeepEqual(attrPrf.APIAttributeProfile, replyPrfl) { + t.Errorf("Expecting : %s, received: %s", utils.ToJSON(attrPrf.APIAttributeProfile), utils.ToJSON(replyPrfl)) + } -// if err := fltrRplEngine1RPC.Call(context.Background(), utils.APIerSv1GetFilterIDs, &utils.PaginatorWithTenant{}, &rplyIDs); err == nil || -// err.Error() != utils.ErrNotFound.Error() { -// t.Fatalf("Unexpected error: %v", err) -// } -// if err := fltrRplEngine2RPC.Call(utils.APIerSv1GetFilterIDs, &utils.PaginatorWithTenant{}, &rplyIDs); err == nil || -// err.Error() != utils.ErrNotFound.Error() { -// t.Fatalf("Unexpected error: %v", err) -// } + if err := fltrRplEngine2RPC.Call(context.Background(), utils.AdminSv1GetAttributeProfileIDs, &utils.PaginatorWithTenant{}, &rplyIDs); err == nil || + err.Error() != utils.ErrNotFound.Error() { + t.Fatalf("Unexpected error: %v", err) + } -// if err := fltrRplEngine1RPC.Call(context.Background(), utils.APIerSv1GetFilter, -// &utils.TenantID{Tenant: "cgrates.org", ID: fltrID}, &replyPrfl); err != nil { -// t.Fatal(err) -// } -// replyPrfl.Compile() -// if !reflect.DeepEqual(fltr.Filter, replyPrfl) { -// t.Errorf("Expecting : %s, received: %s", utils.ToJSON(fltr.Filter), utils.ToJSON(replyPrfl)) -// } -// replyPrfl = nil -// fltr.Rules[0].Type = utils.MetaPrefix -// if err := fltrRplInternalRPC.Call(utils.APIerSv1SetFilter, fltr, &result); err != nil { -// t.Fatal(err) -// } else if result != utils.OK { -// t.Error("Unexpected reply returned", result) -// } -// if err := fltrRplInternalRPC.Call(utils.APIerSv1GetFilter, -// &utils.TenantID{Tenant: "cgrates.org", ID: fltrID}, &replyPrfl); err != nil { -// t.Fatal(err) -// } -// replyPrfl.Compile() -// if !reflect.DeepEqual(fltr.Filter, replyPrfl) { -// t.Errorf("Expecting : %s, received: %s", utils.ToJSON(fltr.Filter), utils.ToJSON(replyPrfl)) -// } -// replyPrfl = nil + if err := fltrRplInternalRPC.Call(context.Background(), utils.AdminSv1RemoveAttributeProfile, + utils.TenantIDWithAPIOpts{TenantID: &utils.TenantID{Tenant: "cgrates.org", ID: attrID}}, &result); err != nil { + t.Error(err) + } else if result != utils.OK { + t.Error("Unexpected reply returned", result) + } + if err := fltrRplEngine1RPC.Call(context.Background(), utils.AdminSv1GetAttributeProfileIDs, &utils.PaginatorWithTenant{}, &rplyIDs); err == nil || + err.Error() != utils.ErrNotFound.Error() { + t.Fatalf("Unexpected error: %v", err) + } + if err := fltrRplEngine2RPC.Call(context.Background(), utils.AdminSv1GetAttributeProfileIDs, &utils.PaginatorWithTenant{}, &rplyIDs); err == nil || + err.Error() != utils.ErrNotFound.Error() { + t.Fatalf("Unexpected error: %v", err) + } +} -// // use replicator to see if the attribute was changed in the DB -// if err := fltrRplEngine1RPC.Call(context.Background(), utils.ReplicatorSv1GetFilter, -// utils.TenantIDWithAPIOpts{TenantID: &utils.TenantID{Tenant: "cgrates.org", ID: fltrID}}, &replyPrfl); err != nil { -// t.Fatal(err) -// } -// replyPrfl.Compile() -// if !reflect.DeepEqual(fltr.Filter, replyPrfl) { -// t.Errorf("Expecting : %s, received: %s", utils.ToJSON(fltr.Filter), utils.ToJSON(replyPrfl)) -// } +func testFltrRplFilters(t *testing.T) { + fltrID := "FLTR1" + fltr := &engine.FilterWithAPIOpts{ + Filter: &engine.Filter{ + Tenant: "cgrates.org", + ID: fltrID, + Rules: []*engine.FilterRule{{ + Element: "~*req.Account", + Type: utils.MetaString, + Values: []string{"dan"}, + }}, + }, + } + fltr.Compile() + var result string + var replyPrfl *engine.Filter + var rplyIDs []string + // empty + if err := fltrRplEngine1RPC.Call(context.Background(), utils.AdminSv1GetFilterIDs, &utils.PaginatorWithTenant{}, &rplyIDs); err == nil || + err.Error() != utils.ErrNotFound.Error() { + t.Fatalf("Unexpected error: %v", err) + } + if err := fltrRplEngine2RPC.Call(context.Background(), utils.AdminSv1GetFilterIDs, &utils.PaginatorWithTenant{}, &rplyIDs); err == nil || + err.Error() != utils.ErrNotFound.Error() { + t.Fatalf("Unexpected error: %v", err) + } -// if err := fltrRplEngine2RPC.Call(utils.APIerSv1GetFilterIDs, &utils.PaginatorWithTenant{}, &rplyIDs); err == nil || -// err.Error() != utils.ErrNotFound.Error() { -// t.Fatalf("Unexpected error: %v", err) -// } + if err := fltrRplInternalRPC.Call(context.Background(), utils.AdminSv1SetFilter, fltr, &result); err != nil { + t.Fatal(err) + } else if result != utils.OK { + t.Error("Unexpected reply returned", result) + } + if err := fltrRplInternalRPC.Call(context.Background(), utils.AdminSv1GetFilter, + &utils.TenantID{Tenant: "cgrates.org", ID: fltrID}, &replyPrfl); err != nil { + t.Fatal(err) + } + replyPrfl.Compile() + if !reflect.DeepEqual(fltr.Filter, replyPrfl) { + t.Errorf("Expecting : %s, received: %s", utils.ToJSON(fltr.Filter), utils.ToJSON(replyPrfl)) + } + replyPrfl = nil -// if err := fltrRplInternalRPC.Call(utils.APIerSv1RemoveFilter, -// utils.TenantIDWithAPIOpts{TenantID: &utils.TenantID{Tenant: "cgrates.org", ID: fltrID}}, &result); err != nil { -// t.Error(err) -// } else if result != utils.OK { -// t.Error("Unexpected reply returned", result) -// } -// if err := fltrRplEngine1RPC.Call(context.Background(), utils.APIerSv1GetFilterIDs, &utils.PaginatorWithTenant{}, &rplyIDs); err == nil || -// err.Error() != utils.ErrNotFound.Error() { -// t.Fatalf("Unexpected error: %v", err) -// } -// if err := fltrRplEngine2RPC.Call(utils.APIerSv1GetFilterIDs, &utils.PaginatorWithTenant{}, &rplyIDs); err == nil || -// err.Error() != utils.ErrNotFound.Error() { -// t.Fatalf("Unexpected error: %v", err) -// } -// } + if err := fltrRplEngine1RPC.Call(context.Background(), utils.AdminSv1GetFilterIDs, &utils.PaginatorWithTenant{}, &rplyIDs); err == nil || + err.Error() != utils.ErrNotFound.Error() { + t.Fatalf("Unexpected error: %v", err) + } + if err := fltrRplEngine2RPC.Call(context.Background(), utils.AdminSv1GetFilterIDs, &utils.PaginatorWithTenant{}, &rplyIDs); err == nil || + err.Error() != utils.ErrNotFound.Error() { + t.Fatalf("Unexpected error: %v", err) + } -// func testFltrRplThresholdProfile(t *testing.T) { -// thID := "TH1" -// thPrfl := &engine.ThresholdProfileWithAPIOpts{ -// ThresholdProfile: &engine.ThresholdProfile{ -// Tenant: "cgrates.org", -// ID: thID, -// FilterIDs: []string{"*string:~*req.Account:dan"}, -// MaxHits: -1, -// Weight: 20, -// }, -// } -// th := engine.Threshold{ -// Tenant: "cgrates.org", -// ID: thID, -// } -// var result string -// var replyPrfl *engine.ThresholdProfile -// var rplyIDs []string -// var replyTh engine.Threshold + if err := fltrRplEngine1RPC.Call(context.Background(), utils.AdminSv1GetFilter, + &utils.TenantID{Tenant: "cgrates.org", ID: fltrID}, &replyPrfl); err != nil { + t.Fatal(err) + } + replyPrfl.Compile() + if !reflect.DeepEqual(fltr.Filter, replyPrfl) { + t.Errorf("Expecting : %s, received: %s", utils.ToJSON(fltr.Filter), utils.ToJSON(replyPrfl)) + } + replyPrfl = nil + fltr.Rules[0].Type = utils.MetaPrefix + if err := fltrRplInternalRPC.Call(context.Background(), utils.AdminSv1SetFilter, fltr, &result); err != nil { + t.Fatal(err) + } else if result != utils.OK { + t.Error("Unexpected reply returned", result) + } + if err := fltrRplInternalRPC.Call(context.Background(), utils.AdminSv1GetFilter, + &utils.TenantID{Tenant: "cgrates.org", ID: fltrID}, &replyPrfl); err != nil { + t.Fatal(err) + } + replyPrfl.Compile() + if !reflect.DeepEqual(fltr.Filter, replyPrfl) { + t.Errorf("Expecting : %s, received: %s", utils.ToJSON(fltr.Filter), utils.ToJSON(replyPrfl)) + } + replyPrfl = nil -// argsTh := &utils.TenantIDWithAPIOpts{ -// TenantID: &utils.TenantID{ -// Tenant: "cgrates.org", -// ID: thID, -// }, -// } -// // empty -// if err := fltrRplEngine1RPC.Call(context.Background(), utils.APIerSv1GetThresholdProfileIDs, &utils.PaginatorWithTenant{}, &rplyIDs); err == nil || -// err.Error() != utils.ErrNotFound.Error() { -// t.Fatalf("Unexpected error: %v", err) -// } -// if err := fltrRplEngine2RPC.Call(utils.APIerSv1GetThresholdProfileIDs, &utils.PaginatorWithTenant{}, &rplyIDs); err == nil || -// err.Error() != utils.ErrNotFound.Error() { -// t.Fatalf("Unexpected error: %v", err) -// } + // use replicator to see if the attribute was changed in the DB + if err := fltrRplEngine1RPC.Call(context.Background(), utils.ReplicatorSv1GetFilter, + utils.TenantIDWithAPIOpts{TenantID: &utils.TenantID{Tenant: "cgrates.org", ID: fltrID}}, &replyPrfl); err != nil { + t.Fatal(err) + } + replyPrfl.Compile() + if !reflect.DeepEqual(fltr.Filter, replyPrfl) { + t.Errorf("Expecting : %s, received: %s", utils.ToJSON(fltr.Filter), utils.ToJSON(replyPrfl)) + } -// if err := fltrRplEngine1RPC.Call(context.Background(), utils.ReplicatorSv1GetThreshold, argsTh, &replyTh); err == nil || -// err.Error() != utils.ErrNotFound.Error() { -// t.Fatalf("Unexpected error: %v", err) -// } -// if err := fltrRplEngine2RPC.Call(utils.ReplicatorSv1GetThreshold, argsTh, &replyTh); err == nil || -// err.Error() != utils.ErrNotFound.Error() { -// t.Fatalf("Unexpected error: %v", err) -// } + if err := fltrRplEngine2RPC.Call(context.Background(), utils.AdminSv1GetFilterIDs, &utils.PaginatorWithTenant{}, &rplyIDs); err == nil || + err.Error() != utils.ErrNotFound.Error() { + t.Fatalf("Unexpected error: %v", err) + } -// if err := fltrRplInternalRPC.Call(utils.APIerSv1SetThresholdProfile, thPrfl, &result); err != nil { -// t.Fatal(err) -// } else if result != utils.OK { -// t.Error("Unexpected reply returned", result) -// } -// if err := fltrRplInternalRPC.Call(utils.APIerSv1GetThresholdProfile, -// &utils.TenantID{Tenant: "cgrates.org", ID: thID}, &replyPrfl); err != nil { -// t.Fatal(err) -// } -// if !reflect.DeepEqual(thPrfl.ThresholdProfile, replyPrfl) { -// t.Errorf("Expecting : %s, received: %s", utils.ToJSON(thPrfl.ThresholdProfile), utils.ToJSON(replyPrfl)) -// } -// replyPrfl = nil + if err := fltrRplInternalRPC.Call(context.Background(), utils.AdminSv1RemoveFilter, + utils.TenantIDWithAPIOpts{TenantID: &utils.TenantID{Tenant: "cgrates.org", ID: fltrID}}, &result); err != nil { + t.Error(err) + } else if result != utils.OK { + t.Error("Unexpected reply returned", result) + } + if err := fltrRplEngine1RPC.Call(context.Background(), utils.AdminSv1GetFilterIDs, &utils.PaginatorWithTenant{}, &rplyIDs); err == nil || + err.Error() != utils.ErrNotFound.Error() { + t.Fatalf("Unexpected error: %v", err) + } + if err := fltrRplEngine2RPC.Call(context.Background(), utils.AdminSv1GetFilterIDs, &utils.PaginatorWithTenant{}, &rplyIDs); err == nil || + err.Error() != utils.ErrNotFound.Error() { + t.Fatalf("Unexpected error: %v", err) + } +} -// if err := fltrRplEngine1RPC.Call(context.Background(), utils.APIerSv1GetThresholdProfileIDs, &utils.PaginatorWithTenant{}, &rplyIDs); err == nil || -// err.Error() != utils.ErrNotFound.Error() { -// t.Fatalf("Unexpected error: %v", err) -// } -// if err := fltrRplEngine2RPC.Call(utils.APIerSv1GetThresholdProfileIDs, &utils.PaginatorWithTenant{}, &rplyIDs); err == nil || -// err.Error() != utils.ErrNotFound.Error() { -// t.Fatalf("Unexpected error: %v", err) -// } +func testFltrRplThresholdProfile(t *testing.T) { + thID := "TH1" + thPrfl := &engine.ThresholdProfileWithAPIOpts{ + ThresholdProfile: &engine.ThresholdProfile{ + Tenant: "cgrates.org", + ID: thID, + FilterIDs: []string{"*string:~*req.Account:dan"}, + MaxHits: -1, + Weight: 20, + }, + } + th := engine.Threshold{ + Tenant: "cgrates.org", + ID: thID, + } + var result string + var replyPrfl *engine.ThresholdProfile + var rplyIDs []string + var replyTh engine.Threshold -// if err := fltrRplEngine1RPC.Call(context.Background(), utils.ReplicatorSv1GetThreshold, argsTh, &replyTh); err == nil || -// err.Error() != utils.ErrNotFound.Error() { -// t.Fatalf("Unexpected error: %v", err) -// } -// if err := fltrRplEngine2RPC.Call(utils.ReplicatorSv1GetThreshold, argsTh, &replyTh); err == nil || -// err.Error() != utils.ErrNotFound.Error() { -// t.Fatalf("Unexpected error: %v", err) -// } + argsTh := &utils.TenantIDWithAPIOpts{ + TenantID: &utils.TenantID{ + Tenant: "cgrates.org", + ID: thID, + }, + } + // empty + if err := fltrRplEngine1RPC.Call(context.Background(), utils.AdminSv1GetThresholdProfileIDs, &utils.PaginatorWithTenant{}, &rplyIDs); err == nil || + err.Error() != utils.ErrNotFound.Error() { + t.Fatalf("Unexpected error: %v", err) + } + if err := fltrRplEngine2RPC.Call(context.Background(), utils.AdminSv1GetThresholdProfileIDs, &utils.PaginatorWithTenant{}, &rplyIDs); err == nil || + err.Error() != utils.ErrNotFound.Error() { + t.Fatalf("Unexpected error: %v", err) + } -// if err := fltrRplEngine1RPC.Call(context.Background(), utils.APIerSv1GetThresholdProfile, -// &utils.TenantID{Tenant: "cgrates.org", ID: thID}, &replyPrfl); err != nil { -// t.Fatal(err) -// } -// if !reflect.DeepEqual(thPrfl.ThresholdProfile, replyPrfl) { -// t.Errorf("Expecting : %s, received: %s", utils.ToJSON(thPrfl.ThresholdProfile), utils.ToJSON(replyPrfl)) -// } + if err := fltrRplEngine1RPC.Call(context.Background(), utils.ReplicatorSv1GetThreshold, argsTh, &replyTh); err == nil || + err.Error() != utils.ErrNotFound.Error() { + t.Fatalf("Unexpected error: %v", err) + } + if err := fltrRplEngine2RPC.Call(context.Background(), utils.ReplicatorSv1GetThreshold, argsTh, &replyTh); err == nil || + err.Error() != utils.ErrNotFound.Error() { + t.Fatalf("Unexpected error: %v", err) + } -// if err := fltrRplEngine1RPC.Call(context.Background(), utils.ThresholdSv1GetThreshold, argsTh, &replyTh); err != nil { -// t.Fatal(err) -// } else if !reflect.DeepEqual(th, replyTh) { -// t.Errorf("Expecting : %s, received: %s", utils.ToJSON(th), utils.ToJSON(replyTh)) -// } + if err := fltrRplInternalRPC.Call(context.Background(), utils.AdminSv1SetThresholdProfile, thPrfl, &result); err != nil { + t.Fatal(err) + } else if result != utils.OK { + t.Error("Unexpected reply returned", result) + } + if err := fltrRplInternalRPC.Call(context.Background(), utils.AdminSv1GetThresholdProfile, + &utils.TenantID{Tenant: "cgrates.org", ID: thID}, &replyPrfl); err != nil { + t.Fatal(err) + } + if !reflect.DeepEqual(thPrfl.ThresholdProfile, replyPrfl) { + t.Errorf("Expecting : %s, received: %s", utils.ToJSON(thPrfl.ThresholdProfile), utils.ToJSON(replyPrfl)) + } + replyPrfl = nil -// replyPrfl = nil -// thPrfl.Weight = 10 -// if err := fltrRplInternalRPC.Call(utils.APIerSv1SetThresholdProfile, thPrfl, &result); err != nil { -// t.Fatal(err) -// } else if result != utils.OK { -// t.Error("Unexpected reply returned", result) -// } -// if err := fltrRplInternalRPC.Call(utils.APIerSv1GetThresholdProfile, -// &utils.TenantID{Tenant: "cgrates.org", ID: thID}, &replyPrfl); err != nil { -// t.Fatal(err) -// } -// if !reflect.DeepEqual(thPrfl.ThresholdProfile, replyPrfl) { -// t.Errorf("Expecting : %s, received: %s", utils.ToJSON(thPrfl.ThresholdProfile), utils.ToJSON(replyPrfl)) -// } -// replyPrfl = nil + if err := fltrRplEngine1RPC.Call(context.Background(), utils.AdminSv1GetThresholdProfileIDs, &utils.PaginatorWithTenant{}, &rplyIDs); err == nil || + err.Error() != utils.ErrNotFound.Error() { + t.Fatalf("Unexpected error: %v", err) + } + if err := fltrRplEngine2RPC.Call(context.Background(), utils.AdminSv1GetThresholdProfileIDs, &utils.PaginatorWithTenant{}, &rplyIDs); err == nil || + err.Error() != utils.ErrNotFound.Error() { + t.Fatalf("Unexpected error: %v", err) + } -// // use replicator to see if the attribute was changed in the DB -// if err := fltrRplEngine1RPC.Call(context.Background(), utils.ReplicatorSv1GetThresholdProfile, -// utils.TenantIDWithAPIOpts{TenantID: &utils.TenantID{Tenant: "cgrates.org", ID: thID}}, &replyPrfl); err != nil { -// t.Fatal(err) -// } -// if !reflect.DeepEqual(thPrfl.ThresholdProfile, replyPrfl) { -// t.Errorf("Expecting : %s, received: %s", utils.ToJSON(thPrfl.ThresholdProfile), utils.ToJSON(replyPrfl)) -// } + if err := fltrRplEngine1RPC.Call(context.Background(), utils.ReplicatorSv1GetThreshold, argsTh, &replyTh); err == nil || + err.Error() != utils.ErrNotFound.Error() { + t.Fatalf("Unexpected error: %v", err) + } + if err := fltrRplEngine2RPC.Call(context.Background(), utils.ReplicatorSv1GetThreshold, argsTh, &replyTh); err == nil || + err.Error() != utils.ErrNotFound.Error() { + t.Fatalf("Unexpected error: %v", err) + } -// if err := fltrRplEngine2RPC.Call(utils.APIerSv1GetThresholdProfileIDs, &utils.PaginatorWithTenant{}, &rplyIDs); err == nil || -// err.Error() != utils.ErrNotFound.Error() { -// t.Fatalf("Unexpected error: %v", err) -// } + if err := fltrRplEngine1RPC.Call(context.Background(), utils.AdminSv1GetThresholdProfile, + &utils.TenantID{Tenant: "cgrates.org", ID: thID}, &replyPrfl); err != nil { + t.Fatal(err) + } + if !reflect.DeepEqual(thPrfl.ThresholdProfile, replyPrfl) { + t.Errorf("Expecting : %s, received: %s", utils.ToJSON(thPrfl.ThresholdProfile), utils.ToJSON(replyPrfl)) + } -// tEv := &utils.CGREvent{ -// Tenant: "cgrates.org", -// ID: "event1", -// Event: map[string]interface{}{ -// utils.AccountField: "dan", -// }, -// } -// var thIDs []string -// //Testing ProcessEvent on set thresholdprofile using apier -// if err := fltrRplInternalRPC.Call(context.Background(), utils.ThresholdSv1ProcessEvent, tEv, &thIDs); err != nil { -// t.Fatal(err) -// } else if expected := []string{thID}; !reflect.DeepEqual(expected, thIDs) { -// t.Errorf("Expecting : %s, received: %s", utils.ToJSON(expected), utils.ToJSON(thIDs)) -// } + if err := fltrRplEngine1RPC.Call(context.Background(), utils.ThresholdSv1GetThreshold, argsTh, &replyTh); err != nil { + t.Fatal(err) + } else if !reflect.DeepEqual(th, replyTh) { + t.Errorf("Expecting : %s, received: %s", utils.ToJSON(th), utils.ToJSON(replyTh)) + } -// if err := fltrRplEngine1RPC.Call(context.Background(), utils.ThresholdSv1GetThreshold, argsTh, &replyTh); err != nil { -// t.Fatal(err) -// } -// th.Hits = 1 -// replyTh.Snooze = th.Snooze // ignore the snooze as this is relative to time.Now -// if !reflect.DeepEqual(th, replyTh) { -// t.Errorf("Expecting : %s, received: %s", utils.ToJSON(th), utils.ToJSON(replyTh)) -// } + replyPrfl = nil + thPrfl.Weight = 10 + if err := fltrRplInternalRPC.Call(context.Background(), utils.AdminSv1SetThresholdProfile, thPrfl, &result); err != nil { + t.Fatal(err) + } else if result != utils.OK { + t.Error("Unexpected reply returned", result) + } + if err := fltrRplInternalRPC.Call(context.Background(), utils.AdminSv1GetThresholdProfile, + &utils.TenantID{Tenant: "cgrates.org", ID: thID}, &replyPrfl); err != nil { + t.Fatal(err) + } + if !reflect.DeepEqual(thPrfl.ThresholdProfile, replyPrfl) { + t.Errorf("Expecting : %s, received: %s", utils.ToJSON(thPrfl.ThresholdProfile), utils.ToJSON(replyPrfl)) + } + replyPrfl = nil -// if err := fltrRplInternalRPC.Call(utils.APIerSv1RemoveThresholdProfile, -// utils.TenantIDWithAPIOpts{TenantID: &utils.TenantID{Tenant: "cgrates.org", ID: thID}}, &result); err != nil { -// t.Error(err) -// } else if result != utils.OK { -// t.Error("Unexpected reply returned", result) -// } -// if err := fltrRplEngine1RPC.Call(context.Background(), utils.APIerSv1GetThresholdProfileIDs, &utils.PaginatorWithTenant{}, &rplyIDs); err == nil || -// err.Error() != utils.ErrNotFound.Error() { -// t.Fatalf("Unexpected error: %v", err) -// } -// if err := fltrRplEngine2RPC.Call(utils.APIerSv1GetThresholdProfileIDs, &utils.PaginatorWithTenant{}, &rplyIDs); err == nil || -// err.Error() != utils.ErrNotFound.Error() { -// t.Fatalf("Unexpected error: %v", err) -// } + // use replicator to see if the attribute was changed in the DB + if err := fltrRplEngine1RPC.Call(context.Background(), utils.ReplicatorSv1GetThresholdProfile, + utils.TenantIDWithAPIOpts{TenantID: &utils.TenantID{Tenant: "cgrates.org", ID: thID}}, &replyPrfl); err != nil { + t.Fatal(err) + } + if !reflect.DeepEqual(thPrfl.ThresholdProfile, replyPrfl) { + t.Errorf("Expecting : %s, received: %s", utils.ToJSON(thPrfl.ThresholdProfile), utils.ToJSON(replyPrfl)) + } -// if err := fltrRplEngine1RPC.Call(context.Background(), utils.ReplicatorSv1GetThreshold, argsTh, &replyTh); err == nil || -// err.Error() != utils.ErrNotFound.Error() { -// t.Fatalf("Unexpected error: %v", err) -// } -// if err := fltrRplEngine2RPC.Call(utils.ReplicatorSv1GetThreshold, argsTh, &replyTh); err == nil || -// err.Error() != utils.ErrNotFound.Error() { -// t.Fatalf("Unexpected error: %v", err) -// } -// } + if err := fltrRplEngine2RPC.Call(context.Background(), utils.AdminSv1GetThresholdProfileIDs, &utils.PaginatorWithTenant{}, &rplyIDs); err == nil || + err.Error() != utils.ErrNotFound.Error() { + t.Fatalf("Unexpected error: %v", err) + } + + tEv := &utils.CGREvent{ + Tenant: "cgrates.org", + ID: "event1", + Event: map[string]interface{}{ + utils.AccountField: "dan", + }, + } + var thIDs []string + //Testing ProcessEvent on set thresholdprofile using apier + if err := fltrRplInternalRPC.Call(context.Background(), utils.ThresholdSv1ProcessEvent, tEv, &thIDs); err != nil { + t.Fatal(err) + } else if expected := []string{thID}; !reflect.DeepEqual(expected, thIDs) { + t.Errorf("Expecting : %s, received: %s", utils.ToJSON(expected), utils.ToJSON(thIDs)) + } + + if err := fltrRplEngine1RPC.Call(context.Background(), utils.ThresholdSv1GetThreshold, argsTh, &replyTh); err != nil { + t.Fatal(err) + } + th.Hits = 1 + replyTh.Snooze = th.Snooze // ignore the snooze as this is relative to time.Now + if !reflect.DeepEqual(th, replyTh) { + t.Errorf("Expecting : %s, received: %s", utils.ToJSON(th), utils.ToJSON(replyTh)) + } + + if err := fltrRplInternalRPC.Call(context.Background(), utils.AdminSv1RemoveThresholdProfile, + utils.TenantIDWithAPIOpts{TenantID: &utils.TenantID{Tenant: "cgrates.org", ID: thID}}, &result); err != nil { + t.Error(err) + } else if result != utils.OK { + t.Error("Unexpected reply returned", result) + } + if err := fltrRplEngine1RPC.Call(context.Background(), utils.AdminSv1GetThresholdProfileIDs, &utils.PaginatorWithTenant{}, &rplyIDs); err == nil || + err.Error() != utils.ErrNotFound.Error() { + t.Fatalf("Unexpected error: %v", err) + } + if err := fltrRplEngine2RPC.Call(context.Background(), utils.AdminSv1GetThresholdProfileIDs, &utils.PaginatorWithTenant{}, &rplyIDs); err == nil || + err.Error() != utils.ErrNotFound.Error() { + t.Fatalf("Unexpected error: %v", err) + } + + if err := fltrRplEngine1RPC.Call(context.Background(), utils.ReplicatorSv1GetThreshold, argsTh, &replyTh); err == nil || + err.Error() != utils.ErrNotFound.Error() { + t.Fatalf("Unexpected error: %v", err) + } + if err := fltrRplEngine2RPC.Call(context.Background(), utils.ReplicatorSv1GetThreshold, argsTh, &replyTh); err == nil || + err.Error() != utils.ErrNotFound.Error() { + t.Fatalf("Unexpected error: %v", err) + } +} // func testFltrRplStatQueueProfile(t *testing.T) { // stID := "ST1" @@ -585,7 +585,7 @@ package general_tests // err.Error() != utils.ErrNotFound.Error() { // t.Fatalf("Unexpected error: %v", err) // } -// if err := fltrRplEngine2RPC.Call(utils.AdminSv1GetStatQueueProfileIDs, &utils.PaginatorWithTenant{}, &rplyIDs); err == nil || +// if err := fltrRplEngine2RPC.Call(context.Background(), utils.AdminSv1GetStatQueueProfileIDs, &utils.PaginatorWithTenant{}, &rplyIDs); err == nil || // err.Error() != utils.ErrNotFound.Error() { // t.Fatalf("Unexpected error: %v", err) // } @@ -594,17 +594,17 @@ package general_tests // err.Error() != utils.ErrNotFound.Error() { // t.Fatalf("Unexpected error: %v", err) // } -// if err := fltrRplEngine2RPC.Call(utils.ReplicatorSv1GetStatQueue, argsSq, &replySq); err == nil || +// if err := fltrRplEngine2RPC.Call(context.Background(), utils.ReplicatorSv1GetStatQueue, argsSq, &replySq); err == nil || // err.Error() != utils.ErrNotFound.Error() { // t.Fatalf("Unexpected error: %v", err) // } -// if err := fltrRplInternalRPC.Call(utils.AdminSv1SetStatQueueProfile, stPrf, &result); err != nil { +// if err := fltrRplInternalRPC.Call(context.Background(), utils.AdminSv1SetStatQueueProfile, stPrf, &result); err != nil { // t.Fatal(err) // } else if result != utils.OK { // t.Error("Unexpected reply returned", result) // } -// if err := fltrRplInternalRPC.Call(utils.AdminSv1GetStatQueueProfile, +// if err := fltrRplInternalRPC.Call(context.Background(), utils.AdminSv1GetStatQueueProfile, // &utils.TenantID{Tenant: "cgrates.org", ID: stID}, &replyPrfl); err != nil { // t.Fatal(err) // } @@ -617,7 +617,7 @@ package general_tests // err.Error() != utils.ErrNotFound.Error() { // t.Fatalf("Unexpected error: %v", err) // } -// if err := fltrRplEngine2RPC.Call(utils.AdminSv1GetStatQueueProfileIDs, &utils.PaginatorWithTenant{}, &rplyIDs); err == nil || +// if err := fltrRplEngine2RPC.Call(context.Background(), utils.AdminSv1GetStatQueueProfileIDs, &utils.PaginatorWithTenant{}, &rplyIDs); err == nil || // err.Error() != utils.ErrNotFound.Error() { // t.Fatalf("Unexpected error: %v", err) // } @@ -626,7 +626,7 @@ package general_tests // err.Error() != utils.ErrNotFound.Error() { // t.Fatalf("Unexpected error: %v", err) // } -// if err := fltrRplEngine2RPC.Call(utils.ReplicatorSv1GetStatQueue, argsSq, &replySq); err == nil || +// if err := fltrRplEngine2RPC.Call(context.Background(), utils.ReplicatorSv1GetStatQueue, argsSq, &replySq); err == nil || // err.Error() != utils.ErrNotFound.Error() { // t.Fatalf("Unexpected error: %v", err) // } @@ -652,12 +652,12 @@ package general_tests // replyPrfl = nil // stPrf.Weight = 15 -// if err := fltrRplInternalRPC.Call(utils.AdminSv1SetStatQueueProfile, stPrf, &result); err != nil { +// if err := fltrRplInternalRPC.Call(context.Background(), utils.AdminSv1SetStatQueueProfile, stPrf, &result); err != nil { // t.Fatal(err) // } else if result != utils.OK { // t.Error("Unexpected reply returned", result) // } -// if err := fltrRplInternalRPC.Call(utils.AdminSv1GetStatQueueProfile, +// if err := fltrRplInternalRPC.Call(context.Background(), utils.AdminSv1GetStatQueueProfile, // &utils.TenantID{Tenant: "cgrates.org", ID: stID}, &replyPrfl); err != nil { // t.Fatal(err) // } @@ -675,7 +675,7 @@ package general_tests // t.Errorf("Expecting : %s, received: %s", utils.ToJSON(stPrf.StatQueueProfile), utils.ToJSON(replyPrfl)) // } -// if err := fltrRplEngine2RPC.Call(utils.AdminSv1GetStatQueueProfileIDs, &utils.PaginatorWithTenant{}, &rplyIDs); err == nil || +// if err := fltrRplEngine2RPC.Call(context.Background(), utils.AdminSv1GetStatQueueProfileIDs, &utils.PaginatorWithTenant{}, &rplyIDs); err == nil || // err.Error() != utils.ErrNotFound.Error() { // t.Fatalf("Unexpected error: %v", err) // } @@ -692,7 +692,7 @@ package general_tests // } // var sqIDs []string // //Testing ProcessEvent on set thresholdprofile using apier -// if err := fltrRplInternalRPC.Call(utils.StatSv1ProcessEvent, sEv, &sqIDs); err != nil { +// if err := fltrRplInternalRPC.Call(context.Background(), utils.StatSv1ProcessEvent, sEv, &sqIDs); err != nil { // t.Fatal(err) // } else if expected := []string{stID}; !reflect.DeepEqual(expected, sqIDs) { // t.Errorf("Expecting : %s, received: %s", utils.ToJSON(expected), utils.ToJSON(sqIDs)) @@ -710,7 +710,7 @@ package general_tests // t.Errorf("Expecting : %s, received: %s", utils.ToJSON(sq), utils.ToJSON(replySq)) // } -// if err := fltrRplInternalRPC.Call(utils.AdminSv1RemoveStatQueueProfile, +// if err := fltrRplInternalRPC.Call(context.Background(), utils.AdminSv1RemoveStatQueueProfile, // utils.TenantIDWithAPIOpts{TenantID: &utils.TenantID{Tenant: "cgrates.org", ID: stID}}, &result); err != nil { // t.Error(err) // } else if result != utils.OK { @@ -720,7 +720,7 @@ package general_tests // err.Error() != utils.ErrNotFound.Error() { // t.Fatalf("Unexpected error: %v", err) // } -// if err := fltrRplEngine2RPC.Call(utils.AdminSv1GetStatQueueProfileIDs, &utils.PaginatorWithTenant{}, &rplyIDs); err == nil || +// if err := fltrRplEngine2RPC.Call(context.Background(), utils.AdminSv1GetStatQueueProfileIDs, &utils.PaginatorWithTenant{}, &rplyIDs); err == nil || // err.Error() != utils.ErrNotFound.Error() { // t.Fatalf("Unexpected error: %v", err) // } @@ -729,7 +729,7 @@ package general_tests // err.Error() != utils.ErrNotFound.Error() { // t.Fatalf("Unexpected error: %v", err) // } -// if err := fltrRplEngine2RPC.Call(utils.ReplicatorSv1GetStatQueue, argsSq, &replySq); err == nil || +// if err := fltrRplEngine2RPC.Call(context.Background(), utils.ReplicatorSv1GetStatQueue, argsSq, &replySq); err == nil || // err.Error() != utils.ErrNotFound.Error() { // t.Fatalf("Unexpected error: %v", err) // } @@ -767,11 +767,11 @@ package general_tests // }, // } // // empty -// if err := fltrRplEngine1RPC.Call(context.Background(), utils.APIerSv1GetResourceProfileIDs, &utils.PaginatorWithTenant{}, &rplyIDs); err == nil || +// if err := fltrRplEngine1RPC.Call(context.Background(), utils.AdminSv1GetResourceProfileIDs, &utils.PaginatorWithTenant{}, &rplyIDs); err == nil || // err.Error() != utils.ErrNotFound.Error() { // t.Fatalf("Unexpected error: %v", err) // } -// if err := fltrRplEngine2RPC.Call(utils.APIerSv1GetResourceProfileIDs, &utils.PaginatorWithTenant{}, &rplyIDs); err == nil || +// if err := fltrRplEngine2RPC.Call(context.Background(), utils.AdminSv1GetResourceProfileIDs, &utils.PaginatorWithTenant{}, &rplyIDs); err == nil || // err.Error() != utils.ErrNotFound.Error() { // t.Fatalf("Unexpected error: %v", err) // } @@ -780,16 +780,16 @@ package general_tests // err.Error() != utils.ErrNotFound.Error() { // t.Fatalf("Unexpected error: %v", err) // } -// if err := fltrRplEngine2RPC.Call(utils.ReplicatorSv1GetResource, argsRs, &replyRs); err == nil || +// if err := fltrRplEngine2RPC.Call(context.Background(), utils.ReplicatorSv1GetResource, argsRs, &replyRs); err == nil || // err.Error() != utils.ErrNotFound.Error() { // t.Fatalf("Unexpected error: %v", err) // } -// if err := fltrRplInternalRPC.Call(utils.APIerSv1SetResourceProfile, resPrf, &result); err != nil { +// if err := fltrRplInternalRPC.Call(context.Background(), utils.AdminSv1SetResourceProfile, resPrf, &result); err != nil { // t.Fatal(err) // } else if result != utils.OK { // t.Error("Unexpected reply returned", result) // } -// if err := fltrRplInternalRPC.Call(utils.APIerSv1GetResourceProfile, +// if err := fltrRplInternalRPC.Call(context.Background(), utils.AdminSv1GetResourceProfile, // &utils.TenantID{Tenant: "cgrates.org", ID: resID}, &replyPrfl); err != nil { // t.Fatal(err) // } @@ -798,11 +798,11 @@ package general_tests // } // replyPrfl = nil -// if err := fltrRplEngine1RPC.Call(context.Background(), utils.APIerSv1GetResourceProfileIDs, &utils.PaginatorWithTenant{}, &rplyIDs); err == nil || +// if err := fltrRplEngine1RPC.Call(context.Background(), utils.AdminSv1GetResourceProfileIDs, &utils.PaginatorWithTenant{}, &rplyIDs); err == nil || // err.Error() != utils.ErrNotFound.Error() { // t.Fatalf("Unexpected error: %v", err) // } -// if err := fltrRplEngine2RPC.Call(utils.APIerSv1GetResourceProfileIDs, &utils.PaginatorWithTenant{}, &rplyIDs); err == nil || +// if err := fltrRplEngine2RPC.Call(context.Background(), utils.AdminSv1GetResourceProfileIDs, &utils.PaginatorWithTenant{}, &rplyIDs); err == nil || // err.Error() != utils.ErrNotFound.Error() { // t.Fatalf("Unexpected error: %v", err) // } @@ -811,12 +811,12 @@ package general_tests // err.Error() != utils.ErrNotFound.Error() { // t.Fatalf("Unexpected error: %v", err) // } -// if err := fltrRplEngine2RPC.Call(utils.ReplicatorSv1GetResource, argsRs, &replyRs); err == nil || +// if err := fltrRplEngine2RPC.Call(context.Background(), utils.ReplicatorSv1GetResource, argsRs, &replyRs); err == nil || // err.Error() != utils.ErrNotFound.Error() { // t.Fatalf("Unexpected error: %v", err) // } -// if err := fltrRplEngine1RPC.Call(context.Background(), utils.APIerSv1GetResourceProfile, +// if err := fltrRplEngine1RPC.Call(context.Background(), utils.AdminSv1GetResourceProfile, // &utils.TenantID{Tenant: "cgrates.org", ID: resID}, &replyPrfl); err != nil { // t.Fatal(err) // } @@ -832,12 +832,12 @@ package general_tests // replyPrfl = nil // resPrf.Weight = 15 -// if err := fltrRplInternalRPC.Call(utils.APIerSv1SetResourceProfile, resPrf, &result); err != nil { +// if err := fltrRplInternalRPC.Call(context.Background(), utils.AdminSv1SetResourceProfile, resPrf, &result); err != nil { // t.Fatal(err) // } else if result != utils.OK { // t.Error("Unexpected reply returned", result) // } -// if err := fltrRplInternalRPC.Call(utils.APIerSv1GetResourceProfile, +// if err := fltrRplInternalRPC.Call(context.Background(), utils.AdminSv1GetResourceProfile, // &utils.TenantID{Tenant: "cgrates.org", ID: resID}, &replyPrfl); err != nil { // t.Fatal(err) // } @@ -855,7 +855,7 @@ package general_tests // t.Errorf("Expecting : %s, received: %s", utils.ToJSON(resPrf.ResourceProfile), utils.ToJSON(replyPrfl)) // } -// if err := fltrRplEngine2RPC.Call(utils.APIerSv1GetResourceProfileIDs, &utils.PaginatorWithTenant{}, &rplyIDs); err == nil || +// if err := fltrRplEngine2RPC.Call(context.Background(), utils.AdminSv1GetResourceProfileIDs, &utils.PaginatorWithTenant{}, &rplyIDs); err == nil || // err.Error() != utils.ErrNotFound.Error() { // t.Fatalf("Unexpected error: %v", err) // } @@ -873,7 +873,7 @@ package general_tests // } // var rsIDs string // //Testing ProcessEvent on set thresholdprofile using apier -// if err := fltrRplInternalRPC.Call(utils.ResourceSv1AllocateResources, rEv, &rsIDs); err != nil { +// if err := fltrRplInternalRPC.Call(context.Background(), utils.ResourceSv1AllocateResources, rEv, &rsIDs); err != nil { // t.Fatal(err) // } else if expected := resPrf.AllocationMessage; !reflect.DeepEqual(expected, rsIDs) { // t.Errorf("Expecting : %s, received: %s", utils.ToJSON(expected), utils.ToJSON(rsIDs)) @@ -895,17 +895,17 @@ package general_tests // t.Errorf("Expecting : %s, received: %s", utils.ToJSON(rs), utils.ToJSON(replyRs)) // } -// if err := fltrRplInternalRPC.Call(utils.APIerSv1RemoveResourceProfile, +// if err := fltrRplInternalRPC.Call(context.Background(), utils.AdminSv1RemoveResourceProfile, // utils.TenantIDWithAPIOpts{TenantID: &utils.TenantID{Tenant: "cgrates.org", ID: resID}}, &result); err != nil { // t.Error(err) // } else if result != utils.OK { // t.Error("Unexpected reply returned", result) // } -// if err := fltrRplEngine1RPC.Call(context.Background(), utils.APIerSv1GetResourceProfileIDs, &utils.PaginatorWithTenant{}, &rplyIDs); err == nil || +// if err := fltrRplEngine1RPC.Call(context.Background(), utils.AdminSv1GetResourceProfileIDs, &utils.PaginatorWithTenant{}, &rplyIDs); err == nil || // err.Error() != utils.ErrNotFound.Error() { // t.Fatalf("Unexpected error: %v", err) // } -// if err := fltrRplEngine2RPC.Call(utils.APIerSv1GetResourceProfileIDs, &utils.PaginatorWithTenant{}, &rplyIDs); err == nil || +// if err := fltrRplEngine2RPC.Call(context.Background(), utils.AdminSv1GetResourceProfileIDs, &utils.PaginatorWithTenant{}, &rplyIDs); err == nil || // err.Error() != utils.ErrNotFound.Error() { // t.Fatalf("Unexpected error: %v", err) // } @@ -914,7 +914,7 @@ package general_tests // err.Error() != utils.ErrNotFound.Error() { // t.Fatalf("Unexpected error: %v", err) // } -// if err := fltrRplEngine2RPC.Call(utils.ReplicatorSv1GetResource, argsRs, &replyRs); err == nil || +// if err := fltrRplEngine2RPC.Call(context.Background(), utils.ReplicatorSv1GetResource, argsRs, &replyRs); err == nil || // err.Error() != utils.ErrNotFound.Error() { // t.Fatalf("Unexpected error: %v", err) // } @@ -947,21 +947,21 @@ package general_tests // var replyPrfl *engine.RouteProfile // var rplyIDs []string // // empty -// if err := fltrRplEngine1RPC.Call(context.Background(), utils.APIerSv1GetRouteProfileIDs, &utils.PaginatorWithTenant{}, &rplyIDs); err == nil || +// if err := fltrRplEngine1RPC.Call(context.Background(), utils.AdminSv1GetRouteProfileIDs, &utils.PaginatorWithTenant{}, &rplyIDs); err == nil || // err.Error() != utils.ErrNotFound.Error() { // t.Fatalf("Unexpected error: %v", err) // } -// if err := fltrRplEngine2RPC.Call(utils.APIerSv1GetRouteProfileIDs, &utils.PaginatorWithTenant{}, &rplyIDs); err == nil || +// if err := fltrRplEngine2RPC.Call(context.Background(), utils.AdminSv1GetRouteProfileIDs, &utils.PaginatorWithTenant{}, &rplyIDs); err == nil || // err.Error() != utils.ErrNotFound.Error() { // t.Fatalf("Unexpected error: %v", err) // } -// if err := fltrRplInternalRPC.Call(utils.APIerSv1SetRouteProfile, rpPrf, &result); err != nil { +// if err := fltrRplInternalRPC.Call(context.Background(), utils.AdminSv1SetRouteProfile, rpPrf, &result); err != nil { // t.Fatal(err) // } else if result != utils.OK { // t.Error("Unexpected reply returned", result) // } -// if err := fltrRplInternalRPC.Call(utils.APIerSv1GetRouteProfile, +// if err := fltrRplInternalRPC.Call(context.Background(), utils.AdminSv1GetRouteProfile, // &utils.TenantID{Tenant: "cgrates.org", ID: rpID}, &replyPrfl); err != nil { // t.Fatal(err) // } @@ -971,16 +971,16 @@ package general_tests // } // replyPrfl = nil -// if err := fltrRplEngine1RPC.Call(context.Background(), utils.APIerSv1GetRouteProfileIDs, &utils.PaginatorWithTenant{}, &rplyIDs); err == nil || +// if err := fltrRplEngine1RPC.Call(context.Background(), utils.AdminSv1GetRouteProfileIDs, &utils.PaginatorWithTenant{}, &rplyIDs); err == nil || // err.Error() != utils.ErrNotFound.Error() { // t.Fatalf("Unexpected error: %v", err) // } -// if err := fltrRplEngine2RPC.Call(utils.APIerSv1GetRouteProfileIDs, &utils.PaginatorWithTenant{}, &rplyIDs); err == nil || +// if err := fltrRplEngine2RPC.Call(context.Background(), utils.AdminSv1GetRouteProfileIDs, &utils.PaginatorWithTenant{}, &rplyIDs); err == nil || // err.Error() != utils.ErrNotFound.Error() { // t.Fatalf("Unexpected error: %v", err) // } -// if err := fltrRplEngine1RPC.Call(context.Background(), utils.APIerSv1GetRouteProfile, +// if err := fltrRplEngine1RPC.Call(context.Background(), utils.AdminSv1GetRouteProfile, // &utils.TenantID{Tenant: "cgrates.org", ID: rpID}, &replyPrfl); err != nil { // t.Fatal(err) // } @@ -990,12 +990,12 @@ package general_tests // } // replyPrfl = nil // rpPrf.Weight = 15 -// if err := fltrRplInternalRPC.Call(utils.APIerSv1SetRouteProfile, rpPrf, &result); err != nil { +// if err := fltrRplInternalRPC.Call(context.Background(), utils.AdminSv1SetRouteProfile, rpPrf, &result); err != nil { // t.Fatal(err) // } else if result != utils.OK { // t.Error("Unexpected reply returned", result) // } -// if err := fltrRplInternalRPC.Call(utils.APIerSv1GetRouteProfile, +// if err := fltrRplInternalRPC.Call(context.Background(), utils.AdminSv1GetRouteProfile, // &utils.TenantID{Tenant: "cgrates.org", ID: rpID}, &replyPrfl); err != nil { // t.Fatal(err) // } @@ -1015,22 +1015,22 @@ package general_tests // t.Errorf("Expecting : %s, received: %s", utils.ToJSON(rpPrf.RouteProfile), utils.ToJSON(replyPrfl)) // } -// if err := fltrRplEngine2RPC.Call(utils.APIerSv1GetRouteProfileIDs, &utils.PaginatorWithTenant{}, &rplyIDs); err == nil || +// if err := fltrRplEngine2RPC.Call(context.Background(), utils.AdminSv1GetRouteProfileIDs, &utils.PaginatorWithTenant{}, &rplyIDs); err == nil || // err.Error() != utils.ErrNotFound.Error() { // t.Fatalf("Unexpected error: %v", err) // } -// if err := fltrRplInternalRPC.Call(utils.APIerSv1RemoveRouteProfile, +// if err := fltrRplInternalRPC.Call(context.Background(), utils.AdminSv1RemoveRouteProfile, // &utils.TenantIDWithAPIOpts{TenantID: &utils.TenantID{Tenant: "cgrates.org", ID: rpID}}, &result); err != nil { // t.Error(err) // } else if result != utils.OK { // t.Error("Unexpected reply returned", result) // } -// if err := fltrRplEngine1RPC.Call(context.Background(), utils.APIerSv1GetRouteProfileIDs, &utils.PaginatorWithTenant{}, &rplyIDs); err == nil || +// if err := fltrRplEngine1RPC.Call(context.Background(), utils.AdminSv1GetRouteProfileIDs, &utils.PaginatorWithTenant{}, &rplyIDs); err == nil || // err.Error() != utils.ErrNotFound.Error() { // t.Fatalf("Unexpected error: %v", err) // } -// if err := fltrRplEngine2RPC.Call(utils.APIerSv1GetRouteProfileIDs, &utils.PaginatorWithTenant{}, &rplyIDs); err == nil || +// if err := fltrRplEngine2RPC.Call(context.Background(), utils.AdminSv1GetRouteProfileIDs, &utils.PaginatorWithTenant{}, &rplyIDs); err == nil || // err.Error() != utils.ErrNotFound.Error() { // t.Fatalf("Unexpected error: %v", err) // } @@ -1052,21 +1052,21 @@ package general_tests // var replyPrfl *engine.ChargerProfile // var rplyIDs []string // // empty -// if err := fltrRplEngine1RPC.Call(context.Background(), utils.APIerSv1GetChargerProfileIDs, &utils.PaginatorWithTenant{}, &rplyIDs); err == nil || +// if err := fltrRplEngine1RPC.Call(context.Background(), utils.AdminSv1GetChargerProfileIDs, &utils.PaginatorWithTenant{}, &rplyIDs); err == nil || // err.Error() != utils.ErrNotFound.Error() { // t.Fatalf("Unexpected error: %v", err) // } -// if err := fltrRplEngine2RPC.Call(utils.APIerSv1GetChargerProfileIDs, &utils.PaginatorWithTenant{}, &rplyIDs); err == nil || +// if err := fltrRplEngine2RPC.Call(context.Background(), utils.AdminSv1GetChargerProfileIDs, &utils.PaginatorWithTenant{}, &rplyIDs); err == nil || // err.Error() != utils.ErrNotFound.Error() { // t.Fatalf("Unexpected error: %v", err) // } -// if err := fltrRplInternalRPC.Call(utils.AdminSv1SetChargerProfile, chPrf, &result); err != nil { +// if err := fltrRplInternalRPC.Call(context.Background(), utils.AdminSv1SetChargerProfile, chPrf, &result); err != nil { // t.Fatal(err) // } else if result != utils.OK { // t.Error("Unexpected reply returned", result) // } -// if err := fltrRplInternalRPC.Call(utils.APIerSv1GetChargerProfile, +// if err := fltrRplInternalRPC.Call(context.Background(), utils.AdminSv1GetChargerProfile, // &utils.TenantID{Tenant: "cgrates.org", ID: chID}, &replyPrfl); err != nil { // t.Fatal(err) // } @@ -1075,16 +1075,16 @@ package general_tests // } // replyPrfl = nil -// if err := fltrRplEngine1RPC.Call(context.Background(), utils.APIerSv1GetChargerProfileIDs, &utils.PaginatorWithTenant{}, &rplyIDs); err == nil || +// if err := fltrRplEngine1RPC.Call(context.Background(), utils.AdminSv1GetChargerProfileIDs, &utils.PaginatorWithTenant{}, &rplyIDs); err == nil || // err.Error() != utils.ErrNotFound.Error() { // t.Fatalf("Unexpected error: %v", err) // } -// if err := fltrRplEngine2RPC.Call(utils.APIerSv1GetChargerProfileIDs, &utils.PaginatorWithTenant{}, &rplyIDs); err == nil || +// if err := fltrRplEngine2RPC.Call(context.Background(), utils.AdminSv1GetChargerProfileIDs, &utils.PaginatorWithTenant{}, &rplyIDs); err == nil || // err.Error() != utils.ErrNotFound.Error() { // t.Fatalf("Unexpected error: %v", err) // } -// if err := fltrRplEngine1RPC.Call(context.Background(), utils.APIerSv1GetChargerProfile, +// if err := fltrRplEngine1RPC.Call(context.Background(), utils.AdminSv1GetChargerProfile, // &utils.TenantID{Tenant: "cgrates.org", ID: chID}, &replyPrfl); err != nil { // t.Fatal(err) // } @@ -1093,12 +1093,12 @@ package general_tests // } // replyPrfl = nil // chPrf.Weight = 15 -// if err := fltrRplInternalRPC.Call(utils.AdminSv1SetChargerProfile, chPrf, &result); err != nil { +// if err := fltrRplInternalRPC.Call(context.Background(), utils.AdminSv1SetChargerProfile, chPrf, &result); err != nil { // t.Fatal(err) // } else if result != utils.OK { // t.Error("Unexpected reply returned", result) // } -// if err := fltrRplInternalRPC.Call(utils.APIerSv1GetChargerProfile, +// if err := fltrRplInternalRPC.Call(context.Background(), utils.AdminSv1GetChargerProfile, // &utils.TenantID{Tenant: "cgrates.org", ID: chID}, &replyPrfl); err != nil { // t.Fatal(err) // } @@ -1116,22 +1116,22 @@ package general_tests // t.Errorf("Expecting : %s, received: %s", utils.ToJSON(chPrf.ChargerProfile), utils.ToJSON(replyPrfl)) // } -// if err := fltrRplEngine2RPC.Call(utils.APIerSv1GetChargerProfileIDs, &utils.PaginatorWithTenant{}, &rplyIDs); err == nil || +// if err := fltrRplEngine2RPC.Call(context.Background(), utils.AdminSv1GetChargerProfileIDs, &utils.PaginatorWithTenant{}, &rplyIDs); err == nil || // err.Error() != utils.ErrNotFound.Error() { // t.Fatalf("Unexpected error: %v", err) // } -// if err := fltrRplInternalRPC.Call(utils.APIerSv1RemoveChargerProfile, +// if err := fltrRplInternalRPC.Call(context.Background(), utils.AdminSv1RemoveChargerProfile, // utils.TenantIDWithAPIOpts{TenantID: &utils.TenantID{Tenant: "cgrates.org", ID: chID}}, &result); err != nil { // t.Error(err) // } else if result != utils.OK { // t.Error("Unexpected reply returned", result) // } -// if err := fltrRplEngine1RPC.Call(context.Background(), utils.APIerSv1GetChargerProfileIDs, &utils.PaginatorWithTenant{}, &rplyIDs); err == nil || +// if err := fltrRplEngine1RPC.Call(context.Background(), utils.AdminSv1GetChargerProfileIDs, &utils.PaginatorWithTenant{}, &rplyIDs); err == nil || // err.Error() != utils.ErrNotFound.Error() { // t.Fatalf("Unexpected error: %v", err) // } -// if err := fltrRplEngine2RPC.Call(utils.APIerSv1GetChargerProfileIDs, &utils.PaginatorWithTenant{}, &rplyIDs); err == nil || +// if err := fltrRplEngine2RPC.Call(context.Background(), utils.AdminSv1GetChargerProfileIDs, &utils.PaginatorWithTenant{}, &rplyIDs); err == nil || // err.Error() != utils.ErrNotFound.Error() { // t.Fatalf("Unexpected error: %v", err) // } @@ -1152,21 +1152,21 @@ package general_tests // var replyPrfl *engine.DispatcherProfile // var rplyIDs []string // // empty -// if err := fltrRplEngine1RPC.Call(context.Background(), utils.APIerSv1GetDispatcherProfileIDs, &utils.PaginatorWithTenant{}, &rplyIDs); err == nil || +// if err := fltrRplEngine1RPC.Call(context.Background(), utils.AdminSv1GetDispatcherProfileIDs, &utils.PaginatorWithTenant{}, &rplyIDs); err == nil || // err.Error() != utils.ErrNotFound.Error() { // t.Fatalf("Unexpected error: %v", err) // } -// if err := fltrRplEngine2RPC.Call(utils.APIerSv1GetDispatcherProfileIDs, &utils.PaginatorWithTenant{}, &rplyIDs); err == nil || +// if err := fltrRplEngine2RPC.Call(context.Background(), utils.AdminSv1GetDispatcherProfileIDs, &utils.PaginatorWithTenant{}, &rplyIDs); err == nil || // err.Error() != utils.ErrNotFound.Error() { // t.Fatalf("Unexpected error: %v", err) // } -// if err := fltrRplInternalRPC.Call(utils.APIerSv1SetDispatcherProfile, dspPrf, &result); err != nil { +// if err := fltrRplInternalRPC.Call(context.Background(), utils.AdminSv1SetDispatcherProfile, dspPrf, &result); err != nil { // t.Fatal(err) // } else if result != utils.OK { // t.Error("Unexpected reply returned", result) // } -// if err := fltrRplInternalRPC.Call(utils.APIerSv1GetDispatcherProfile, +// if err := fltrRplInternalRPC.Call(context.Background(), utils.AdminSv1GetDispatcherProfile, // &utils.TenantID{Tenant: "cgrates.org", ID: dspID}, &replyPrfl); err != nil { // t.Fatal(err) // } @@ -1175,16 +1175,16 @@ package general_tests // } // replyPrfl = nil -// if err := fltrRplEngine1RPC.Call(context.Background(), utils.APIerSv1GetDispatcherProfileIDs, &utils.PaginatorWithTenant{}, &rplyIDs); err == nil || +// if err := fltrRplEngine1RPC.Call(context.Background(), utils.AdminSv1GetDispatcherProfileIDs, &utils.PaginatorWithTenant{}, &rplyIDs); err == nil || // err.Error() != utils.ErrNotFound.Error() { // t.Fatalf("Unexpected error: %v", err) // } -// if err := fltrRplEngine2RPC.Call(utils.APIerSv1GetDispatcherProfileIDs, &utils.PaginatorWithTenant{}, &rplyIDs); err == nil || +// if err := fltrRplEngine2RPC.Call(context.Background(), utils.AdminSv1GetDispatcherProfileIDs, &utils.PaginatorWithTenant{}, &rplyIDs); err == nil || // err.Error() != utils.ErrNotFound.Error() { // t.Fatalf("Unexpected error: %v", err) // } -// if err := fltrRplEngine1RPC.Call(context.Background(), utils.APIerSv1GetDispatcherProfile, +// if err := fltrRplEngine1RPC.Call(context.Background(), utils.AdminSv1GetDispatcherProfile, // &utils.TenantID{Tenant: "cgrates.org", ID: dspID}, &replyPrfl); err != nil { // t.Fatal(err) // } @@ -1193,12 +1193,12 @@ package general_tests // } // replyPrfl = nil // dspPrf.Weight = 15 -// if err := fltrRplInternalRPC.Call(utils.APIerSv1SetDispatcherProfile, dspPrf, &result); err != nil { +// if err := fltrRplInternalRPC.Call(context.Background(), utils.AdminSv1SetDispatcherProfile, dspPrf, &result); err != nil { // t.Fatal(err) // } else if result != utils.OK { // t.Error("Unexpected reply returned", result) // } -// if err := fltrRplInternalRPC.Call(utils.APIerSv1GetDispatcherProfile, +// if err := fltrRplInternalRPC.Call(context.Background(), utils.AdminSv1GetDispatcherProfile, // &utils.TenantID{Tenant: "cgrates.org", ID: dspID}, &replyPrfl); err != nil { // t.Fatal(err) // } @@ -1216,22 +1216,22 @@ package general_tests // t.Errorf("Expecting : %s, received: %s", utils.ToJSON(dspPrf.DispatcherProfile), utils.ToJSON(replyPrfl)) // } -// if err := fltrRplEngine2RPC.Call(utils.APIerSv1GetDispatcherProfileIDs, &utils.PaginatorWithTenant{}, &rplyIDs); err == nil || +// if err := fltrRplEngine2RPC.Call(context.Background(), utils.AdminSv1GetDispatcherProfileIDs, &utils.PaginatorWithTenant{}, &rplyIDs); err == nil || // err.Error() != utils.ErrNotFound.Error() { // t.Fatalf("Unexpected error: %v", err) // } -// if err := fltrRplInternalRPC.Call(utils.APIerSv1RemoveDispatcherProfile, +// if err := fltrRplInternalRPC.Call(context.Background(), utils.AdminSv1RemoveDispatcherProfile, // utils.TenantIDWithAPIOpts{TenantID: &utils.TenantID{Tenant: "cgrates.org", ID: dspID}}, &result); err != nil { // t.Error(err) // } else if result != utils.OK { // t.Error("Unexpected reply returned", result) // } -// if err := fltrRplEngine1RPC.Call(context.Background(), utils.APIerSv1GetDispatcherProfileIDs, &utils.PaginatorWithTenant{}, &rplyIDs); err == nil || +// if err := fltrRplEngine1RPC.Call(context.Background(), utils.AdminSv1GetDispatcherProfileIDs, &utils.PaginatorWithTenant{}, &rplyIDs); err == nil || // err.Error() != utils.ErrNotFound.Error() { // t.Fatalf("Unexpected error: %v", err) // } -// if err := fltrRplEngine2RPC.Call(utils.APIerSv1GetDispatcherProfileIDs, &utils.PaginatorWithTenant{}, &rplyIDs); err == nil || +// if err := fltrRplEngine2RPC.Call(context.Background(), utils.AdminSv1GetDispatcherProfileIDs, &utils.PaginatorWithTenant{}, &rplyIDs); err == nil || // err.Error() != utils.ErrNotFound.Error() { // t.Fatalf("Unexpected error: %v", err) // } @@ -1252,21 +1252,21 @@ package general_tests // var replyPrfl *engine.DispatcherHost // var rplyIDs []string // // empty -// if err := fltrRplEngine1RPC.Call(context.Background(), utils.APIerSv1GetDispatcherHostIDs, &utils.PaginatorWithTenant{}, &rplyIDs); err == nil || +// if err := fltrRplEngine1RPC.Call(context.Background(), utils.AdminSv1GetDispatcherHostIDs, &utils.PaginatorWithTenant{}, &rplyIDs); err == nil || // err.Error() != utils.ErrNotFound.Error() { // t.Fatalf("Unexpected error: %v", err) // } -// if err := fltrRplEngine2RPC.Call(utils.APIerSv1GetDispatcherHostIDs, &utils.PaginatorWithTenant{}, &rplyIDs); err == nil || +// if err := fltrRplEngine2RPC.Call(context.Background(), utils.AdminSv1GetDispatcherHostIDs, &utils.PaginatorWithTenant{}, &rplyIDs); err == nil || // err.Error() != utils.ErrNotFound.Error() { // t.Fatalf("Unexpected error: %v", err) // } -// if err := fltrRplInternalRPC.Call(utils.APIerSv1SetDispatcherHost, dspPrf, &result); err != nil { +// if err := fltrRplInternalRPC.Call(context.Background(), utils.AdminSv1SetDispatcherHost, dspPrf, &result); err != nil { // t.Fatal(err) // } else if result != utils.OK { // t.Error("Unexpected reply returned", result) // } -// if err := fltrRplInternalRPC.Call(utils.APIerSv1GetDispatcherHost, +// if err := fltrRplInternalRPC.Call(context.Background(), utils.AdminSv1GetDispatcherHost, // &utils.TenantID{Tenant: "cgrates.org", ID: dspID}, &replyPrfl); err != nil { // t.Fatal(err) // } @@ -1275,16 +1275,16 @@ package general_tests // } // replyPrfl = nil -// if err := fltrRplEngine1RPC.Call(context.Background(), utils.APIerSv1GetDispatcherHostIDs, &utils.PaginatorWithTenant{}, &rplyIDs); err == nil || +// if err := fltrRplEngine1RPC.Call(context.Background(), utils.AdminSv1GetDispatcherHostIDs, &utils.PaginatorWithTenant{}, &rplyIDs); err == nil || // err.Error() != utils.ErrNotFound.Error() { // t.Fatalf("Unexpected error: %v", err) // } -// if err := fltrRplEngine2RPC.Call(utils.APIerSv1GetDispatcherHostIDs, &utils.PaginatorWithTenant{}, &rplyIDs); err == nil || +// if err := fltrRplEngine2RPC.Call(context.Background(), utils.AdminSv1GetDispatcherHostIDs, &utils.PaginatorWithTenant{}, &rplyIDs); err == nil || // err.Error() != utils.ErrNotFound.Error() { // t.Fatalf("Unexpected error: %v", err) // } -// if err := fltrRplEngine1RPC.Call(context.Background(), utils.APIerSv1GetDispatcherHost, +// if err := fltrRplEngine1RPC.Call(context.Background(), utils.AdminSv1GetDispatcherHost, // &utils.TenantID{Tenant: "cgrates.org", ID: dspID}, &replyPrfl); err != nil { // t.Fatal(err) // } @@ -1293,12 +1293,12 @@ package general_tests // } // replyPrfl = nil // dspPrf.Address = "127.0.0.1:2012" -// if err := fltrRplInternalRPC.Call(utils.APIerSv1SetDispatcherHost, dspPrf, &result); err != nil { +// if err := fltrRplInternalRPC.Call(context.Background(), utils.AdminSv1SetDispatcherHost, dspPrf, &result); err != nil { // t.Fatal(err) // } else if result != utils.OK { // t.Error("Unexpected reply returned", result) // } -// if err := fltrRplInternalRPC.Call(utils.APIerSv1GetDispatcherHost, +// if err := fltrRplInternalRPC.Call(context.Background(), utils.AdminSv1GetDispatcherHost, // &utils.TenantID{Tenant: "cgrates.org", ID: dspID}, &replyPrfl); err != nil { // t.Fatal(err) // } @@ -1316,22 +1316,22 @@ package general_tests // t.Errorf("Expecting : %s, received: %s", utils.ToJSON(dspPrf.DispatcherHost), utils.ToJSON(replyPrfl)) // } -// if err := fltrRplEngine2RPC.Call(utils.APIerSv1GetDispatcherHostIDs, &utils.PaginatorWithTenant{}, &rplyIDs); err == nil || +// if err := fltrRplEngine2RPC.Call(context.Background(), utils.AdminSv1GetDispatcherHostIDs, &utils.PaginatorWithTenant{}, &rplyIDs); err == nil || // err.Error() != utils.ErrNotFound.Error() { // t.Fatalf("Unexpected error: %v", err) // } -// if err := fltrRplInternalRPC.Call(utils.APIerSv1RemoveDispatcherHost, +// if err := fltrRplInternalRPC.Call(context.Background(), utils.AdminSv1RemoveDispatcherHost, // utils.TenantIDWithAPIOpts{TenantID: &utils.TenantID{Tenant: "cgrates.org", ID: dspID}}, &result); err != nil { // t.Error(err) // } else if result != utils.OK { // t.Error("Unexpected reply returned", result) // } -// if err := fltrRplEngine1RPC.Call(context.Background(), utils.APIerSv1GetDispatcherHostIDs, &utils.PaginatorWithTenant{}, &rplyIDs); err == nil || +// if err := fltrRplEngine1RPC.Call(context.Background(), utils.AdminSv1GetDispatcherHostIDs, &utils.PaginatorWithTenant{}, &rplyIDs); err == nil || // err.Error() != utils.ErrNotFound.Error() { // t.Fatalf("Unexpected error: %v", err) // } -// if err := fltrRplEngine2RPC.Call(utils.APIerSv1GetDispatcherHostIDs, &utils.PaginatorWithTenant{}, &rplyIDs); err == nil || +// if err := fltrRplEngine2RPC.Call(context.Background(), utils.AdminSv1GetDispatcherHostIDs, &utils.PaginatorWithTenant{}, &rplyIDs); err == nil || // err.Error() != utils.ErrNotFound.Error() { // t.Fatalf("Unexpected error: %v", err) // } @@ -1391,21 +1391,21 @@ package general_tests // var replyPrfl *utils.RateProfile // var rplyIDs []string // // empty -// if err := fltrRplEngine1RPC.Call(context.Background(), utils.APIerSv1GetRateProfileIDs, &utils.PaginatorWithTenant{}, &rplyIDs); err == nil || +// if err := fltrRplEngine1RPC.Call(context.Background(), utils.AdminSv1GetRateProfileIDs, &utils.PaginatorWithTenant{}, &rplyIDs); err == nil || // err.Error() != utils.ErrNotFound.Error() { // t.Fatalf("Unexpected error: %v", err) // } -// if err := fltrRplEngine2RPC.Call(utils.APIerSv1GetRateProfileIDs, &utils.PaginatorWithTenant{}, &rplyIDs); err == nil || +// if err := fltrRplEngine2RPC.Call(context.Background(), utils.AdminSv1GetRateProfileIDs, &utils.PaginatorWithTenant{}, &rplyIDs); err == nil || // err.Error() != utils.ErrNotFound.Error() { // t.Fatalf("Unexpected error: %v", err) // } -// if err := fltrRplInternalRPC.Call(utils.APIerSv1SetRateProfile, rpPrf, &result); err != nil { +// if err := fltrRplInternalRPC.Call(context.Background(), utils.AdminSv1SetRateProfile, rpPrf, &result); err != nil { // t.Fatal(err) // } else if result != utils.OK { // t.Error("Unexpected reply returned", result) // } -// if err := fltrRplInternalRPC.Call(utils.APIerSv1GetRateProfile, +// if err := fltrRplInternalRPC.Call(context.Background(), utils.AdminSv1GetRateProfile, // utils.TenantIDWithAPIOpts{TenantID: &utils.TenantID{Tenant: "cgrates.org", ID: rpID}}, &replyPrfl); err != nil { // t.Fatal(err) // } @@ -1414,16 +1414,16 @@ package general_tests // } // replyPrfl = nil -// if err := fltrRplEngine1RPC.Call(context.Background(), utils.APIerSv1GetRateProfileIDs, &utils.PaginatorWithTenant{}, &rplyIDs); err == nil || +// if err := fltrRplEngine1RPC.Call(context.Background(), utils.AdminSv1GetRateProfileIDs, &utils.PaginatorWithTenant{}, &rplyIDs); err == nil || // err.Error() != utils.ErrNotFound.Error() { // t.Fatalf("Unexpected error: %v", err) // } -// if err := fltrRplEngine2RPC.Call(utils.APIerSv1GetRateProfileIDs, &utils.PaginatorWithTenant{}, &rplyIDs); err == nil || +// if err := fltrRplEngine2RPC.Call(context.Background(), utils.AdminSv1GetRateProfileIDs, &utils.PaginatorWithTenant{}, &rplyIDs); err == nil || // err.Error() != utils.ErrNotFound.Error() { // t.Fatalf("Unexpected error: %v", err) // } -// if err := fltrRplEngine1RPC.Call(context.Background(), utils.APIerSv1GetRateProfile, +// if err := fltrRplEngine1RPC.Call(context.Background(), utils.AdminSv1GetRateProfile, // utils.TenantIDWithAPIOpts{TenantID: &utils.TenantID{Tenant: "cgrates.org", ID: rpID}}, &replyPrfl); err != nil { // t.Fatal(err) // } @@ -1433,12 +1433,12 @@ package general_tests // replyPrfl = nil // rpPrf.Weights = ";15" // expPrf.Weights[0].Weight = 15 -// if err := fltrRplInternalRPC.Call(utils.APIerSv1SetRateProfile, rpPrf, &result); err != nil { +// if err := fltrRplInternalRPC.Call(context.Background(), utils.AdminSv1SetRateProfile, rpPrf, &result); err != nil { // t.Fatal(err) // } else if result != utils.OK { // t.Error("Unexpected reply returned", result) // } -// if err := fltrRplInternalRPC.Call(utils.APIerSv1GetRateProfile, +// if err := fltrRplInternalRPC.Call(context.Background(), utils.AdminSv1GetRateProfile, // utils.TenantIDWithAPIOpts{TenantID: &utils.TenantID{Tenant: "cgrates.org", ID: rpID}}, &replyPrfl); err != nil { // t.Fatal(err) // } @@ -1456,22 +1456,22 @@ package general_tests // t.Errorf("Expecting : %s, received: %s", utils.ToJSON(expPrf), utils.ToJSON(replyPrfl)) // } -// if err := fltrRplEngine2RPC.Call(utils.APIerSv1GetRateProfileIDs, &utils.PaginatorWithTenant{}, &rplyIDs); err == nil || +// if err := fltrRplEngine2RPC.Call(context.Background(), utils.AdminSv1GetRateProfileIDs, &utils.PaginatorWithTenant{}, &rplyIDs); err == nil || // err.Error() != utils.ErrNotFound.Error() { // t.Fatalf("Unexpected error: %v", err) // } -// if err := fltrRplInternalRPC.Call(utils.APIerSv1RemoveRateProfile, +// if err := fltrRplInternalRPC.Call(context.Background(), utils.AdminSv1RemoveRateProfile, // utils.TenantIDWithAPIOpts{TenantID: &utils.TenantID{Tenant: "cgrates.org", ID: rpID}}, &result); err != nil { // t.Error(err) // } else if result != utils.OK { // t.Error("Unexpected reply returned", result) // } -// if err := fltrRplEngine1RPC.Call(context.Background(), utils.APIerSv1GetRateProfileIDs, &utils.PaginatorWithTenant{}, &rplyIDs); err == nil || +// if err := fltrRplEngine1RPC.Call(context.Background(), utils.AdminSv1GetRateProfileIDs, &utils.PaginatorWithTenant{}, &rplyIDs); err == nil || // err.Error() != utils.ErrNotFound.Error() { // t.Fatalf("Unexpected error: %v", err) // } -// if err := fltrRplEngine2RPC.Call(utils.APIerSv1GetRateProfileIDs, &utils.PaginatorWithTenant{}, &rplyIDs); err == nil || +// if err := fltrRplEngine2RPC.Call(context.Background(), utils.AdminSv1GetRateProfileIDs, &utils.PaginatorWithTenant{}, &rplyIDs); err == nil || // err.Error() != utils.ErrNotFound.Error() { // t.Fatalf("Unexpected error: %v", err) // } @@ -1496,21 +1496,21 @@ package general_tests // var replyPrfl *engine.ActionProfile // var rplyIDs []string // // empty -// if err := fltrRplEngine1RPC.Call(context.Background(), utils.APIerSv1GetActionProfileIDs, &utils.PaginatorWithTenant{}, &rplyIDs); err == nil || +// if err := fltrRplEngine1RPC.Call(context.Background(), utils.AdminSv1GetActionProfileIDs, &utils.PaginatorWithTenant{}, &rplyIDs); err == nil || // err.Error() != utils.ErrNotFound.Error() { // t.Fatalf("Unexpected error: %v", err) // } -// if err := fltrRplEngine2RPC.Call(utils.APIerSv1GetActionProfileIDs, &utils.PaginatorWithTenant{}, &rplyIDs); err == nil || +// if err := fltrRplEngine2RPC.Call(context.Background(), utils.AdminSv1GetActionProfileIDs, &utils.PaginatorWithTenant{}, &rplyIDs); err == nil || // err.Error() != utils.ErrNotFound.Error() { // t.Fatalf("Unexpected error: %v", err) // } -// if err := fltrRplInternalRPC.Call(utils.APIerSv1SetActionProfile, acPrf, &result); err != nil { +// if err := fltrRplInternalRPC.Call(context.Background(), utils.AdminSv1SetActionProfile, acPrf, &result); err != nil { // t.Fatal(err) // } else if result != utils.OK { // t.Error("Unexpected reply returned", result) // } -// if err := fltrRplInternalRPC.Call(utils.APIerSv1GetActionProfile, +// if err := fltrRplInternalRPC.Call(context.Background(), utils.AdminSv1GetActionProfile, // utils.TenantIDWithAPIOpts{TenantID: &utils.TenantID{Tenant: "cgrates.org", ID: acID}}, &replyPrfl); err != nil { // t.Fatal(err) // } @@ -1519,16 +1519,16 @@ package general_tests // } // replyPrfl = nil -// if err := fltrRplEngine1RPC.Call(context.Background(), utils.APIerSv1GetActionProfileIDs, &utils.PaginatorWithTenant{}, &rplyIDs); err == nil || +// if err := fltrRplEngine1RPC.Call(context.Background(), utils.AdminSv1GetActionProfileIDs, &utils.PaginatorWithTenant{}, &rplyIDs); err == nil || // err.Error() != utils.ErrNotFound.Error() { // t.Fatalf("Unexpected error: %v", err) // } -// if err := fltrRplEngine2RPC.Call(utils.APIerSv1GetActionProfileIDs, &utils.PaginatorWithTenant{}, &rplyIDs); err == nil || +// if err := fltrRplEngine2RPC.Call(context.Background(), utils.AdminSv1GetActionProfileIDs, &utils.PaginatorWithTenant{}, &rplyIDs); err == nil || // err.Error() != utils.ErrNotFound.Error() { // t.Fatalf("Unexpected error: %v", err) // } -// if err := fltrRplEngine1RPC.Call(context.Background(), utils.APIerSv1GetActionProfile, +// if err := fltrRplEngine1RPC.Call(context.Background(), utils.AdminSv1GetActionProfile, // utils.TenantIDWithAPIOpts{TenantID: &utils.TenantID{Tenant: "cgrates.org", ID: acID}}, &replyPrfl); err != nil { // t.Fatal(err) // } @@ -1537,12 +1537,12 @@ package general_tests // } // replyPrfl = nil // acPrf.Weight = 15 -// if err := fltrRplInternalRPC.Call(utils.APIerSv1SetActionProfile, acPrf, &result); err != nil { +// if err := fltrRplInternalRPC.Call(context.Background(), utils.AdminSv1SetActionProfile, acPrf, &result); err != nil { // t.Fatal(err) // } else if result != utils.OK { // t.Error("Unexpected reply returned", result) // } -// if err := fltrRplInternalRPC.Call(utils.APIerSv1GetActionProfile, +// if err := fltrRplInternalRPC.Call(context.Background(), utils.AdminSv1GetActionProfile, // utils.TenantIDWithAPIOpts{TenantID: &utils.TenantID{Tenant: "cgrates.org", ID: acID}}, &replyPrfl); err != nil { // t.Fatal(err) // } @@ -1560,22 +1560,22 @@ package general_tests // t.Errorf("Expecting : %s, received: %s", utils.ToJSON(acPrf.ActionProfile), utils.ToJSON(replyPrfl)) // } -// if err := fltrRplEngine2RPC.Call(utils.APIerSv1GetActionProfileIDs, &utils.PaginatorWithTenant{}, &rplyIDs); err == nil || +// if err := fltrRplEngine2RPC.Call(context.Background(), utils.AdminSv1GetActionProfileIDs, &utils.PaginatorWithTenant{}, &rplyIDs); err == nil || // err.Error() != utils.ErrNotFound.Error() { // t.Fatalf("Unexpected error: %v", err) // } -// if err := fltrRplInternalRPC.Call(utils.APIerSv1RemoveActionProfile, +// if err := fltrRplInternalRPC.Call(context.Background(), utils.AdminSv1RemoveActionProfile, // utils.TenantIDWithAPIOpts{TenantID: &utils.TenantID{Tenant: "cgrates.org", ID: acID}}, &result); err != nil { // t.Error(err) // } else if result != utils.OK { // t.Error("Unexpected reply returned", result) // } -// if err := fltrRplEngine1RPC.Call(context.Background(), utils.APIerSv1GetActionProfileIDs, &utils.PaginatorWithTenant{}, &rplyIDs); err == nil || +// if err := fltrRplEngine1RPC.Call(context.Background(), utils.AdminSv1GetActionProfileIDs, &utils.PaginatorWithTenant{}, &rplyIDs); err == nil || // err.Error() != utils.ErrNotFound.Error() { // t.Fatalf("Unexpected error: %v", err) // } -// if err := fltrRplEngine2RPC.Call(utils.APIerSv1GetActionProfileIDs, &utils.PaginatorWithTenant{}, &rplyIDs); err == nil || +// if err := fltrRplEngine2RPC.Call(context.Background(), utils.AdminSv1GetActionProfileIDs, &utils.PaginatorWithTenant{}, &rplyIDs); err == nil || // err.Error() != utils.ErrNotFound.Error() { // t.Fatalf("Unexpected error: %v", err) // } @@ -1614,21 +1614,21 @@ package general_tests // var replyPrfl *utils.Account // var rplyIDs []string // // empty -// if err := fltrRplEngine1RPC.Call(context.Background(), utils.APIerSv1GetAccountIDs, &utils.PaginatorWithTenant{}, &rplyIDs); err == nil || +// if err := fltrRplEngine1RPC.Call(context.Background(), utils.AdminSv1GetAccountIDs, &utils.PaginatorWithTenant{}, &rplyIDs); err == nil || // err.Error() != utils.ErrNotFound.Error() { // t.Fatalf("Unexpected error: %v", err) // } -// if err := fltrRplEngine2RPC.Call(utils.APIerSv1GetAccountIDs, &utils.PaginatorWithTenant{}, &rplyIDs); err == nil || +// if err := fltrRplEngine2RPC.Call(context.Background(), utils.AdminSv1GetAccountIDs, &utils.PaginatorWithTenant{}, &rplyIDs); err == nil || // err.Error() != utils.ErrNotFound.Error() { // t.Fatalf("Unexpected error: %v", err) // } -// if err := fltrRplInternalRPC.Call(utils.APIerSv1SetAccount, acPrf, &result); err != nil { +// if err := fltrRplInternalRPC.Call(context.Background(), utils.AdminSv1SetAccount, acPrf, &result); err != nil { // t.Fatal(err) // } else if result != utils.OK { // t.Error("Unexpected reply returned", result) // } -// if err := fltrRplInternalRPC.Call(utils.APIerSv1GetAccount, +// if err := fltrRplInternalRPC.Call(context.Background(), utils.AdminSv1GetAccount, // utils.TenantIDWithAPIOpts{TenantID: &utils.TenantID{Tenant: "cgrates.org", ID: acID}}, &replyPrfl); err != nil { // t.Fatal(err) // } @@ -1637,16 +1637,16 @@ package general_tests // } // replyPrfl = nil -// if err := fltrRplEngine1RPC.Call(context.Background(), utils.APIerSv1GetAccountIDs, &utils.PaginatorWithTenant{}, &rplyIDs); err == nil || +// if err := fltrRplEngine1RPC.Call(context.Background(), utils.AdminSv1GetAccountIDs, &utils.PaginatorWithTenant{}, &rplyIDs); err == nil || // err.Error() != utils.ErrNotFound.Error() { // t.Fatalf("Unexpected error: %v", err) // } -// if err := fltrRplEngine2RPC.Call(utils.APIerSv1GetAccountIDs, &utils.PaginatorWithTenant{}, &rplyIDs); err == nil || +// if err := fltrRplEngine2RPC.Call(context.Background(), utils.AdminSv1GetAccountIDs, &utils.PaginatorWithTenant{}, &rplyIDs); err == nil || // err.Error() != utils.ErrNotFound.Error() { // t.Fatalf("Unexpected error: %v", err) // } -// if err := fltrRplEngine1RPC.Call(context.Background(), utils.APIerSv1GetAccount, +// if err := fltrRplEngine1RPC.Call(context.Background(), utils.AdminSv1GetAccount, // utils.TenantIDWithAPIOpts{TenantID: &utils.TenantID{Tenant: "cgrates.org", ID: acID}}, &replyPrfl); err != nil { // t.Fatal(err) // } @@ -1658,12 +1658,12 @@ package general_tests // if expPrf, err = acPrf.AsAccount(); err != nil { // t.Fatal(err) // } -// if err := fltrRplInternalRPC.Call(utils.APIerSv1SetAccount, acPrf, &result); err != nil { +// if err := fltrRplInternalRPC.Call(context.Background(), utils.AdminSv1SetAccount, acPrf, &result); err != nil { // t.Fatal(err) // } else if result != utils.OK { // t.Error("Unexpected reply returned", result) // } -// if err := fltrRplInternalRPC.Call(utils.APIerSv1GetAccount, +// if err := fltrRplInternalRPC.Call(context.Background(), utils.AdminSv1GetAccount, // utils.TenantIDWithAPIOpts{TenantID: &utils.TenantID{Tenant: "cgrates.org", ID: acID}}, &replyPrfl); err != nil { // t.Fatal(err) // } @@ -1681,22 +1681,22 @@ package general_tests // t.Errorf("Expecting : %s, received: %s", utils.ToJSON(expPrf), utils.ToJSON(replyPrfl)) // } -// if err := fltrRplEngine2RPC.Call(utils.APIerSv1GetAccountIDs, &utils.PaginatorWithTenant{}, &rplyIDs); err == nil || +// if err := fltrRplEngine2RPC.Call(context.Background(), utils.AdminSv1GetAccountIDs, &utils.PaginatorWithTenant{}, &rplyIDs); err == nil || // err.Error() != utils.ErrNotFound.Error() { // t.Fatalf("Unexpected error: %v", err) // } -// if err := fltrRplInternalRPC.Call(utils.APIerSv1RemoveAccount, +// if err := fltrRplInternalRPC.Call(context.Background(), utils.AdminSv1RemoveAccount, // utils.TenantIDWithAPIOpts{TenantID: &utils.TenantID{Tenant: "cgrates.org", ID: acID}}, &result); err != nil { // t.Error(err) // } else if result != utils.OK { // t.Error("Unexpected reply returned", result) // } -// if err := fltrRplEngine1RPC.Call(context.Background(), utils.APIerSv1GetAccountIDs, &utils.PaginatorWithTenant{}, &rplyIDs); err == nil || +// if err := fltrRplEngine1RPC.Call(context.Background(), utils.AdminSv1GetAccountIDs, &utils.PaginatorWithTenant{}, &rplyIDs); err == nil || // err.Error() != utils.ErrNotFound.Error() { // t.Fatalf("Unexpected error: %v", err) // } -// if err := fltrRplEngine2RPC.Call(utils.APIerSv1GetAccountIDs, &utils.PaginatorWithTenant{}, &rplyIDs); err == nil || +// if err := fltrRplEngine2RPC.Call(context.Background(), utils.AdminSv1GetAccountIDs, &utils.PaginatorWithTenant{}, &rplyIDs); err == nil || // err.Error() != utils.ErrNotFound.Error() { // t.Fatalf("Unexpected error: %v", err) // } @@ -1714,23 +1714,23 @@ package general_tests // var replyPrfl *engine.Account // var rplyCount int // // empty -// if err := fltrRplEngine1RPC.Call(context.Background(), utils.APIerSv1GetAccountsCount, &utils.PaginatorWithTenant{}, &rplyCount); err != nil { +// if err := fltrRplEngine1RPC.Call(context.Background(), utils.AdminSv1GetAccountCount, &utils.PaginatorWithTenant{}, &rplyCount); err != nil { // t.Fatal(err) // } else if rplyCount != 0 { // t.Fatal("Expected no accounts") // } -// if err := fltrRplEngine2RPC.Call(utils.APIerSv1GetAccountsCount, &utils.PaginatorWithTenant{}, &rplyCount); err != nil { +// if err := fltrRplEngine2RPC.Call(context.Background(), utils.AdminSv1GetAccountCount, &utils.PaginatorWithTenant{}, &rplyCount); err != nil { // t.Fatal(err) // } else if rplyCount != 0 { // t.Fatal("Expected no accounts") // } -// if err := fltrRplInternalRPC.Call(utils.APIerSv2SetAccount, attrPrf, &result); err != nil { +// if err := fltrRplInternalRPC.Call(context.Background(), utils.AdminSv1SetAccount, attrPrf, &result); err != nil { // t.Fatal(err) // } else if result != utils.OK { // t.Error("Unexpected reply returned", result) // } -// if err := fltrRplInternalRPC.Call(utils.APIerSv2GetAccount, attrAC, &replyPrfl); err != nil { +// if err := fltrRplInternalRPC.Call(context.Background(), utils.AdminSv1GetAccount, attrAC, &replyPrfl); err != nil { // t.Fatal(err) // } // replyPrfl.BalanceMap = nil @@ -1743,18 +1743,18 @@ package general_tests // } // replyPrfl = nil -// if err := fltrRplEngine1RPC.Call(context.Background(), utils.APIerSv1GetAccountsCount, &utils.PaginatorWithTenant{}, &rplyCount); err != nil { +// if err := fltrRplEngine1RPC.Call(context.Background(), utils.AdminSv1GetAccountCount, &utils.PaginatorWithTenant{}, &rplyCount); err != nil { // t.Fatal(err) // } else if rplyCount != 0 { // t.Fatal("Expected no accounts") // } -// if err := fltrRplEngine2RPC.Call(utils.APIerSv1GetAccountsCount, &utils.PaginatorWithTenant{}, &rplyCount); err != nil { +// if err := fltrRplEngine2RPC.Call(context.Background(), utils.AdminSv1GetAccountCount, &utils.PaginatorWithTenant{}, &rplyCount); err != nil { // t.Fatal(err) // } else if rplyCount != 0 { // t.Fatal("Expected no accounts") // } -// if err := fltrRplEngine1RPC.Call(context.Background(), utils.APIerSv2GetAccount, attrAC, &replyPrfl); err != nil { +// if err := fltrRplEngine1RPC.Call(context.Background(), utils.AdminSv1GetAccount, attrAC, &replyPrfl); err != nil { // t.Fatal(err) // } // replyPrfl.BalanceMap = nil @@ -1768,12 +1768,12 @@ package general_tests // replyPrfl = nil // attrPrf.ExtraOptions[utils.Disabled] = false // expPrf.Disabled = false -// if err := fltrRplInternalRPC.Call(utils.APIerSv2SetAccount, attrPrf, &result); err != nil { +// if err := fltrRplInternalRPC.Call(context.Background(), utils.AdminSv1SetAccount, attrPrf, &result); err != nil { // t.Fatal(err) // } else if result != utils.OK { // t.Error("Unexpected reply returned", result) // } -// if err := fltrRplInternalRPC.Call(utils.APIerSv2GetAccount, attrAC, &replyPrfl); err != nil { +// if err := fltrRplInternalRPC.Call(context.Background(), utils.AdminSv1GetAccount, attrAC, &replyPrfl); err != nil { // t.Fatal(err) // } // replyPrfl.BalanceMap = nil @@ -1801,7 +1801,7 @@ package general_tests // t.Errorf("Expecting : %s, received: %s", utils.ToJSON(expPrf), utils.ToJSON(replyPrfl)) // } -// if err := fltrRplEngine2RPC.Call(utils.APIerSv1GetAccountsCount, &utils.PaginatorWithTenant{}, &rplyCount); err != nil { +// if err := fltrRplEngine2RPC.Call(context.Background(), utils.AdminSv1GetAccountCount, &utils.PaginatorWithTenant{}, &rplyCount); err != nil { // t.Fatal(err) // } else if rplyCount != 0 { // t.Fatal("Expected no accounts") @@ -1836,21 +1836,21 @@ package general_tests // err.Error() != utils.ErrNotFound.Error() { // t.Fatalf("Unexpected error: %v", err) // } -// if err := fltrRplEngine2RPC.Call(utils.ReplicatorSv1GetDestination, args, &rplyIDs); err == nil || +// if err := fltrRplEngine2RPC.Call(context.Background(), utils.ReplicatorSv1GetDestination, args, &rplyIDs); err == nil || // err.Error() != utils.ErrNotFound.Error() { // t.Fatalf("Unexpected error: %v", err) // } -// if err := fltrRplEngine2RPC.Call(utils.ReplicatorSv1GetReverseDestination, args2, &rplyIDs2); err == nil || +// if err := fltrRplEngine2RPC.Call(context.Background(), utils.ReplicatorSv1GetReverseDestination, args2, &rplyIDs2); err == nil || // err.Error() != utils.ErrNotFound.Error() { // t.Fatalf("Unexpected error: %v", err) // } -// if err := fltrRplInternalRPC.Call(utils.APIerSv1SetDestination, dstPrf, &result); err != nil { +// if err := fltrRplInternalRPC.Call(context.Background(), utils.AdminSv1SetDestination, dstPrf, &result); err != nil { // t.Fatal(err) // } else if result != utils.OK { // t.Error("Unexpected reply returned", result) // } -// if err := fltrRplInternalRPC.Call(utils.APIerSv1GetDestination, dstID, &replyPrfl); err != nil { +// if err := fltrRplInternalRPC.Call(context.Background(), utils.AdminSv1GetDestination, dstID, &replyPrfl); err != nil { // t.Fatal(err) // } // if !reflect.DeepEqual(expPrf, replyPrfl) { @@ -1866,22 +1866,22 @@ package general_tests // err.Error() != utils.ErrNotFound.Error() { // t.Fatalf("Unexpected error: %v", err) // } -// if err := fltrRplEngine2RPC.Call(utils.ReplicatorSv1GetDestination, args, &rplyIDs); err == nil || +// if err := fltrRplEngine2RPC.Call(context.Background(), utils.ReplicatorSv1GetDestination, args, &rplyIDs); err == nil || // err.Error() != utils.ErrNotFound.Error() { // t.Fatalf("Unexpected error: %v", err) // } -// if err := fltrRplEngine2RPC.Call(utils.ReplicatorSv1GetReverseDestination, args2, &rplyIDs2); err == nil || +// if err := fltrRplEngine2RPC.Call(context.Background(), utils.ReplicatorSv1GetReverseDestination, args2, &rplyIDs2); err == nil || // err.Error() != utils.ErrNotFound.Error() { // t.Fatalf("Unexpected error: %v", err) // } -// if err := fltrRplEngine1RPC.Call(context.Background(), utils.APIerSv1GetDestination, dstID, &replyPrfl); err != nil { +// if err := fltrRplEngine1RPC.Call(context.Background(), utils.AdminSv1GetDestination, dstID, &replyPrfl); err != nil { // t.Fatal(err) // } // if !reflect.DeepEqual(expPrf, replyPrfl) { // t.Errorf("Expecting : %s, received: %s", utils.ToJSON(expPrf), utils.ToJSON(replyPrfl)) // } -// if err := fltrRplEngine1RPC.Call(context.Background(), utils.APIerSv1GetReverseDestination, "dan", &rplyIDs2); err != nil { +// if err := fltrRplEngine1RPC.Call(context.Background(), utils.AdminSv1GetReverseDestination, "dan", &rplyIDs2); err != nil { // t.Fatal(err) // } // if !reflect.DeepEqual([]string{dstID}, rplyIDs2) { @@ -1892,12 +1892,12 @@ package general_tests // dstPrf.Prefixes = []string{"dan2"} // expPrf.Prefixes = []string{"dan2"} // args2.Arg = "dan2" -// if err := fltrRplInternalRPC.Call(utils.APIerSv1SetDestination, dstPrf, &result); err != nil { +// if err := fltrRplInternalRPC.Call(context.Background(), utils.AdminSv1SetDestination, dstPrf, &result); err != nil { // t.Fatal(err) // } else if result != utils.OK { // t.Error("Unexpected reply returned", result) // } -// if err := fltrRplInternalRPC.Call(utils.APIerSv1GetDestination, dstID, &replyPrfl); err != nil { +// if err := fltrRplInternalRPC.Call(context.Background(), utils.AdminSv1GetDestination, dstID, &replyPrfl); err != nil { // t.Fatal(err) // } // if !reflect.DeepEqual(expPrf, replyPrfl) { @@ -1920,20 +1920,20 @@ package general_tests // t.Errorf("Expecting : %s, received: %s", utils.ToJSON([]string{dstID}), utils.ToJSON(rplyIDs2)) // } -// if err := fltrRplEngine2RPC.Call(utils.ReplicatorSv1GetDestination, args, &rplyIDs); err == nil || +// if err := fltrRplEngine2RPC.Call(context.Background(), utils.ReplicatorSv1GetDestination, args, &rplyIDs); err == nil || // err.Error() != utils.ErrNotFound.Error() { // t.Fatalf("Unexpected error: %v", err) // } // rplyIDs2 = nil -// if err := fltrRplEngine2RPC.Call(utils.ReplicatorSv1GetReverseDestination, args2, &rplyIDs2); err == nil || +// if err := fltrRplEngine2RPC.Call(context.Background(), utils.ReplicatorSv1GetReverseDestination, args2, &rplyIDs2); err == nil || // err.Error() != utils.ErrNotFound.Error() { // t.Log(rplyIDs2) // t.Fatalf("Unexpected error: %v", err) // } // } -// func testFltrRplKillEngine(t *testing.T) { -// if err := engine.KillEngine(100); err != nil { -// t.Error(err) -// } -// } +func testFltrRplKillEngine(t *testing.T) { + if err := engine.KillEngine(100); err != nil { + t.Error(err) + } +}