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

Clean up redundant tests

Browse Source
This commit is contained in:
armirveliaj
2025-01-17 11:28:16 -05:00
committed by Dan Christian Bogos
parent ef79d370d8
commit 4ce506faa9
7 changed files with 0 additions and 923 deletions
Download Patch File Download Diff File Expand all files Collapse all files

44
data/conf/samples/cache_replicate/dispatcher_engine/cgrates.json
View File

@@ -1,44 +0,0 @@
{
"general": {
"node_id": "DispatcherEngine",
"reconnects": 1,
},
"logger": {
"level": 7
},
"stor_db": {
"db_type": "*internal"
},
"listen": {
"rpc_json": ":2012",
"rpc_gob": ":2013",
"http": ":2080",
},
"caches":{
"partitions": {
},
"replication_conns": ["cacheReplication"],
"remote_conns": ["cacheReplication"],
},
"rpc_conns": {
"cacheReplication": {
"conns": [{"address": "127.0.0.1:3013", "transport":"*gob"}],
},
},
"admins": {
"enabled": true,
},
}

40
data/conf/samples/cache_replicate/dispatcher_engine2/cgrates.json
View File

@@ -1,40 +0,0 @@
{
"general": {
"node_id": "DispatcherEngine2",
"reconnects": 1,
},
"logger": {
"level": 7
},
"listen": {
"rpc_json": ":3012",
"rpc_gob": ":3013",
"http": ":3080",
},
"data_db": {
"db_type": "redis",
"db_port": 6379,
"db_name": "11",
},
"stor_db": {
"db_type": "*internal",
},
"caches":{
"partitions": {
},
},
"admins": {
"enabled": true,
},
}

60
data/conf/samples/cache_replicate/engine1/cgrates.json
View File

@@ -1,60 +0,0 @@
{
// CGRateS Configuration file
//
"general": {
"node_id": "Engine1",
},
"logger": {
"level": 7
},
"listen": {
"rpc_json": ":6012",
"rpc_gob": ":6013",
"http": ":6080",
},
"data_db": {
"db_type": "*internal",
},
"stor_db": {
"db_type": "*internal"
},
"caches":{
"remote_conns": ["gob_cache"], // the conns that are queried when the items are not found in cache
},
"rpc_conns": {
"conn1": {
"strategy": "*first",
"conns": [{"address": "127.0.0.1:6012", "transport":"*json"}],
},
"gob_cache": {
"strategy": "*first",
"conns": [
{"address": "127.0.0.1:6013", "transport":"*gob"},
],
},
},
"attributes": {
"enabled": true
},
"chargers": {
"enabled": true,
"attributes_conns": ["*internal"],
},
"admins": {
"enabled": true,
"caches_conns":["conn1"],
},
}

43
data/conf/samples/cache_rpl_active_active/dispatcher_engine/cgrates.json
View File

@@ -1,43 +0,0 @@
{
"general": {
"node_id": "DispatcherEngine",
"reconnects": 1,
},
"logger": {
"level": 7
},
"listen": {
"rpc_json": ":2012",
"rpc_gob": ":2013",
"http": ":2080",
},
"stor_db": {
"db_type": "*internal"
},
"caches":{
"partitions": {
},
"replication_conns": ["cacheReplication"],
},
"rpc_conns": {
"cacheReplication": {
"conns": [{"address": "127.0.0.1:3013", "transport":"*gob"}],
},
},
"admins": {
"enabled": true,
},
}

53
data/conf/samples/cache_rpl_active_active/dispatcher_engine2/cgrates.json
View File

@@ -1,53 +0,0 @@
{
"general": {
"node_id": "DispatcherEngine2",
"reconnects": 1,
},
"logger": {
"level": 7
},
"listen": {
"rpc_json": ":3012",
"rpc_gob": ":3013",
"http": ":3080",
},
"data_db": {
"db_type": "redis",
"db_port": 6379,
"db_name": "11",
},
"stor_db": {
"db_type": "*internal"
},
"caches":{
"partitions": {
},
"replication_conns": ["cacheReplication"],
},
"rpc_conns": {
"cacheReplication": {
"conns": [{"address": "127.0.0.1:2013", "transport":"*gob"}],
},
},
"dispatchers":{
"enabled": true,
},
"admins": {
"enabled": true,
},
}

50
data/conf/samples/cache_rpl_active_active/engine1/cgrates.json
View File

@@ -1,50 +0,0 @@
{
// CGRateS Configuration file
//
"general": {
"node_id": "Engine1",
},
"logger": {
"level": 7
},
"listen": {
"rpc_json": ":6012",
"rpc_gob": ":6013",
"http": ":6080",
},
"data_db": {
"db_type": "*internal",
},
"stor_db": {
"db_type": "*internal"
},
"rpc_conns": {
"conn1": {
"strategy": "*first",
"conns": [{"address": "127.0.0.1:6012", "transport":"*json"}],
},
},
"attributes": {
"enabled": true
},
"chargers": {
"enabled": true,
"attributes_conns": ["*internal"],
},
"admins": {
"enabled": true,
"caches_conns":["conn1"],
},
}

633
general_tests/cacherpl_it_test.go
View File

@@ -1,633 +0,0 @@
//go:build integration
// +build integration
/*
Real-time Online/Offline Charging System (OCS) for Telecom & ISP environments
Copyright (C) ITsysCOM GmbH
This program is free software: you can redistribute it and/or modify
it under the terms of the GNU General Public License as published by
the Free Software Foundation, either version 3 of the License, or
(at your option) any later version.
This program is distributed in the hope that it will be useful,
but WITHOUT ANY WARRANTY; without even the implied warranty of
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
GNU General Public License for more details.
You should have received a copy of the GNU General Public License
along with this program. If not, see <http://www.gnu.org/licenses/>
*/
package general_tests
import (
"os/exec"
"path"
"reflect"
"sort"
"testing"
"time"
"github.com/cgrates/birpc"
"github.com/cgrates/birpc/context"
"github.com/cgrates/cgrates/apis"
"github.com/cgrates/cgrates/config"
"github.com/cgrates/cgrates/engine"
"github.com/cgrates/cgrates/utils"
)
var (
dspEngine1Cfg *config.CGRConfig
dspEngine1CfgPath string
dspEngine1RPC *birpc.Client
dspEngine2Cfg *config.CGRConfig
dspEngine2CfgPath string
dspEngine2RPC *birpc.Client
engine1Cfg *config.CGRConfig
engine1CfgPath string
engine1RPC *birpc.Client
sTestsCacheRpl = []func(t *testing.T){
testCacheRplInitCfg,
testCacheRplFlushDBs,
testCacheRplStartEngine,
testCacheRplRpcConn,
testCacheRplAddData,
testCacheRplPing,
// testCacheRplCheckReplication,
// testCacheRplCheckLoadReplication,
testCacheRplStopEngine,
}
sTestsCacheRplAA = []func(t *testing.T){
testCacheRplAAInitCfg,
testCacheRplFlushDBs,
testCacheRplStartEngine,
testCacheRplRpcConn,
testCacheRplAAAddData,
testCacheRplAACheckReplication,
// testCacheRplAACheckLoadReplication,
testCacheRplStopEngine,
}
)
func TestCacheReplications(t *testing.T) {
switch *utils.DBType {
case utils.MetaInternal:
t.SkipNow()
case utils.MetaMySQL:
for _, stest := range sTestsCacheRpl {
t.Run("TestCacheReplications", stest)
}
case utils.MetaMongo:
t.SkipNow()
case utils.MetaPostgres:
t.SkipNow()
default:
t.Fatal("Unknown Database type")
}
}
//to be fixed
// func TestCacheReplicationActiveActive(t *testing.T) {
// switch *utils.DBType {
// case utils.MetaInternal:
// t.SkipNow()
// case utils.MetaMySQL:
// for _, stest := range sTestsCacheRplAA {
// t.Run("TestCacheReplicationActiveActive", stest)
// }
// case utils.MetaMongo:
// t.SkipNow()
// case utils.MetaPostgres:
// t.SkipNow()
// default:
// t.Fatal("Unknown Database type")
// }
// }
func testCacheRplInitCfg(t *testing.T) {
var err error
dspEngine1CfgPath = path.Join(*utils.DataDir, "conf", "samples", "cache_replicate", "dispatcher_engine")
dspEngine1Cfg, err = config.NewCGRConfigFromPath(context.Background(), dspEngine1CfgPath)
if err != nil {
t.Error(err)
}
dspEngine2CfgPath = path.Join(*utils.DataDir, "conf", "samples", "cache_replicate", "dispatcher_engine2")
dspEngine2Cfg, err = config.NewCGRConfigFromPath(context.Background(), dspEngine2CfgPath)
if err != nil {
t.Error(err)
}
engine1CfgPath = path.Join(*utils.DataDir, "conf", "samples", "cache_replicate", "engine1")
engine1Cfg, err = config.NewCGRConfigFromPath(context.Background(), engine1CfgPath)
if err != nil {
t.Error(err)
}
}
func testCacheRplAAInitCfg(t *testing.T) {
var err error
dspEngine1CfgPath = path.Join(*utils.DataDir, "conf", "samples", "cache_rpl_active_active", "dispatcher_engine")
dspEngine1Cfg, err = config.NewCGRConfigFromPath(context.Background(), dspEngine1CfgPath)
if err != nil {
t.Error(err)
}
dspEngine2CfgPath = path.Join(*utils.DataDir, "conf", "samples", "cache_rpl_active_active", "dispatcher_engine2")
dspEngine2Cfg, err = config.NewCGRConfigFromPath(context.Background(), dspEngine2CfgPath)
if err != nil {
t.Error(err)
}
engine1CfgPath = path.Join(*utils.DataDir, "conf", "samples", "cache_rpl_active_active", "engine1")
engine1Cfg, err = config.NewCGRConfigFromPath(context.Background(), engine1CfgPath)
if err != nil {
t.Error(err)
}
}
func testCacheRplFlushDBs(t *testing.T) {
if err := engine.InitDataDB(dspEngine1Cfg); err != nil {
t.Fatal(err)
}
if err := engine.InitDataDB(dspEngine2Cfg); err != nil {
t.Fatal(err)
}
if err := engine.InitStorDB(dspEngine1Cfg); err != nil {
t.Fatal(err)
}
if err := engine.InitStorDB(dspEngine2Cfg); err != nil {
t.Fatal(err)
}
}
func testCacheRplStartEngine(t *testing.T) {
if _, err := engine.StopStartEngine(dspEngine1CfgPath, *utils.WaitRater); err != nil {
t.Fatal(err)
}
if _, err := engine.StartEngine(dspEngine2CfgPath, *utils.WaitRater); err != nil {
t.Fatal(err)
}
if _, err := engine.StartEngine(engine1CfgPath, *utils.WaitRater); err != nil {
t.Fatal(err)
}
}
func testCacheRplRpcConn(t *testing.T) {
dspEngine1RPC = engine.NewRPCClient(t, dspEngine1Cfg.ListenCfg(), *utils.Encoding)
dspEngine2RPC = engine.NewRPCClient(t, dspEngine2Cfg.ListenCfg(), *utils.Encoding)
engine1RPC = engine.NewRPCClient(t, engine1Cfg.ListenCfg(), *utils.Encoding)
}
func testCacheRplAddData(t *testing.T) {
wchan := make(chan struct{}, 1)
go func() {
loaderPath, err := exec.LookPath("cgr-loader")
if err != nil {
t.Error(err)
}
loader := exec.Command(loaderPath, "-config_path", dspEngine1CfgPath, "-path",
path.Join(*utils.DataDir, "tariffplans", "cache_replications", "dispatcher_engine"))
if err := loader.Start(); err != nil {
t.Error(err)
}
loader.Wait()
wchan <- struct{}{}
}()
select {
case <-wchan:
case <-time.After(2 * time.Second):
t.Errorf("cgr-loader failed: ")
}
go func() {
loaderPath, err := exec.LookPath("cgr-loader")
if err != nil {
t.Error(err)
}
loader := exec.Command(loaderPath, "-config_path", dspEngine2CfgPath, "-path",
path.Join(*utils.DataDir, "tariffplans", "cache_replications", "dispatcher_engine2"))
if err := loader.Start(); err != nil {
t.Error(err)
}
loader.Wait()
wchan <- struct{}{}
}()
select {
case <-wchan:
case <-time.After(2 * time.Second):
t.Errorf("cgr-loader failed: ")
}
chargerProfile := &apis.ChargerWithAPIOpts{
ChargerProfile: &engine.ChargerProfile{
Tenant: "cgrates.org",
ID: "DefaultCharger",
RunID: utils.MetaDefault,
AttributeIDs: []string{utils.MetaNone},
Weights: utils.DynamicWeights{
{
Weight: 20,
}},
},
}
var result string
if err := engine1RPC.Call(context.Background(), utils.AdminSv1SetChargerProfile, chargerProfile, &result); err != nil {
t.Error(err)
} else if result != utils.OK {
t.Error("Unexpected reply returned", result)
}
}
func testCacheRplAAAddData(t *testing.T) {
wchan := make(chan struct{}, 1)
go func() {
loaderPath, err := exec.LookPath("cgr-loader")
if err != nil {
t.Error(err)
}
loader := exec.Command(loaderPath, "-config_path", dspEngine1CfgPath, "-path",
path.Join(*utils.DataDir, "tariffplans", "cache_rpl_active_active", "dispatcher_engine"))
if err := loader.Start(); err != nil {
t.Error(err)
}
loader.Wait()
wchan <- struct{}{}
}()
select {
case <-wchan:
case <-time.After(2 * time.Second):
t.Errorf("cgr-loader failed: ")
}
go func() {
loaderPath, err := exec.LookPath("cgr-loader")
if err != nil {
t.Error(err)
}
loader := exec.Command(loaderPath, "-config_path", dspEngine2CfgPath, "-path",
path.Join(*utils.DataDir, "tariffplans", "cache_rpl_active_active", "dispatcher_engine2"))
if err := loader.Start(); err != nil {
t.Error(err)
}
loader.Wait()
wchan <- struct{}{}
}()
select {
case <-wchan:
case <-time.After(2 * time.Second):
t.Errorf("cgr-loader failed: ")
}
chargerProfile := &apis.ChargerWithAPIOpts{
ChargerProfile: &engine.ChargerProfile{
Tenant: "cgrates.org",
ID: "DefaultCharger",
RunID: utils.MetaDefault,
AttributeIDs: []string{utils.MetaNone},
Weights: utils.DynamicWeights{
{
Weight: 20,
}},
},
}
var result string
if err := engine1RPC.Call(context.Background(), utils.AdminSv1SetChargerProfile, chargerProfile, &result); err != nil {
t.Error(err)
} else if result != utils.OK {
t.Error("Unexpected reply returned", result)
}
}
func testCacheRplPing(t *testing.T) {
var reply map[string]any
ev := utils.TenantWithAPIOpts{
Tenant: "cgrates.org",
APIOpts: map[string]any{
utils.OptsRouteID: "testRoute123",
},
}
if err := dspEngine1RPC.Call(context.Background(), utils.CoreSv1Status, &ev, &reply); err != nil {
t.Error(err)
} else if reply[utils.NodeID] != "Engine1" {
t.Errorf("Received: %s", utils.ToJSON(reply))
}
var rpl string
if err := dspEngine1RPC.Call(context.Background(), utils.AttributeSv1Ping, &utils.CGREvent{
Tenant: "cgrates.org",
APIOpts: map[string]any{
utils.OptsRouteID: "testRoute123",
},
}, &rpl); err != nil {
t.Error(err)
} else if rpl != utils.Pong {
t.Errorf("Received: %s", rpl)
}
}
// func testCacheRplCheckReplication(t *testing.T) {
// var reply map[string]any
// ev := utils.TenantWithAPIOpts{
// Tenant: "cgrates.org",
// }
// if err := dspEngine2RPC.Call(context.Background(), utils.CoreSv1Status, &ev, &reply); err != nil {
// t.Error(err)
// } else if reply[utils.NodeID] != "DispatcherEngine2" {
// t.Errorf("Received: %s", utils.ToJSON(reply))
// }
// var rcvKeys []string
// expKeys := []string{"testRoute123:*core", "testRoute123:*attributes"}
// argsAPI := utils.ArgsGetCacheItemIDsWithAPIOpts{
// Tenant: "cgrates.org",
// ArgsGetCacheItemIDs: utils.ArgsGetCacheItemIDs{
// CacheID: utils.CacheDispatcherRoutes,
// },
// }
// if err := dspEngine2RPC.Call(context.Background(), utils.CacheSv1GetItemIDs, argsAPI, &rcvKeys); err != nil {
// t.Error(err.Error())
// }
// sort.Strings(rcvKeys)
// sort.Strings(expKeys)
// if !reflect.DeepEqual(expKeys, rcvKeys) {
// t.Errorf("Expected: %+v, received: %+v", expKeys, rcvKeys)
// }
// var rpl string
// if err := dspEngine2RPC.Call(context.Background(), utils.AttributeSv1Ping, &utils.CGREvent{
// Tenant: "cgrates.org",
// APIOpts: map[string]any{
// utils.OptsRouteID: "testRoute123",
// },
// }, &rpl); err != nil {
// t.Error(err)
// } else if rpl != utils.Pong {
// t.Errorf("Received: %s", rpl)
// }
// }
func testCacheRplAACheckReplication(t *testing.T) {
var rcvKeys []string
argsAPI := utils.ArgsGetCacheItemIDsWithAPIOpts{
Tenant: "cgrates.org",
ArgsGetCacheItemIDs: utils.ArgsGetCacheItemIDs{},
}
if err := dspEngine1RPC.Call(context.Background(), utils.CacheSv1GetItemIDs, argsAPI, &rcvKeys); err == nil ||
err.Error() != utils.ErrNotFound.Error() {
t.Error(err)
}
if err := dspEngine2RPC.Call(context.Background(), utils.CacheSv1GetItemIDs, argsAPI, &rcvKeys); err == nil ||
err.Error() != utils.ErrNotFound.Error() {
t.Error(err)
}
var rpl string
if err := dspEngine2RPC.Call(context.Background(), utils.AttributeSv1Ping, &utils.CGREvent{
Tenant: "cgrates.org",
APIOpts: map[string]any{
utils.OptsRouteID: "testRouteFromDispatcher2",
},
}, &rpl); err != nil {
t.Error(err)
} else if rpl != utils.Pong {
t.Errorf("Received: %s", rpl)
}
if err := dspEngine1RPC.Call(context.Background(), utils.AttributeSv1Ping, &utils.CGREvent{
Tenant: "cgrates.org",
APIOpts: map[string]any{
utils.OptsRouteID: "testRouteFromDispatcher1",
},
}, &rpl); err != nil {
t.Error(err)
} else if rpl != utils.Pong {
t.Errorf("Received: %s", rpl)
}
expKeys := []string{"testRouteFromDispatcher2:*attributes", "testRouteFromDispatcher1:*attributes"}
if err := dspEngine2RPC.Call(context.Background(), utils.CacheSv1GetItemIDs, argsAPI, &rcvKeys); err != nil {
t.Error(err.Error())
}
sort.Strings(rcvKeys)
sort.Strings(expKeys)
if !reflect.DeepEqual(expKeys, rcvKeys) {
t.Errorf("Expected: %+v, received: %+v", expKeys, rcvKeys)
}
if err := dspEngine1RPC.Call(context.Background(), utils.CacheSv1GetItemIDs, argsAPI, &rcvKeys); err != nil {
t.Error(err.Error())
}
sort.Strings(rcvKeys)
sort.Strings(expKeys)
if !reflect.DeepEqual(expKeys, rcvKeys) {
t.Errorf("Expected: %+v, received: %+v", expKeys, rcvKeys)
}
}
// func testCacheRplAACheckLoadReplication(t *testing.T) {
// var rcvKeys []string
// argsAPI := utils.ArgsGetCacheItemIDsWithAPIOpts{
// Tenant: "cgrates.org",
// ArgsGetCacheItemIDs: utils.ArgsGetCacheItemIDs{
// CacheID: utils.CacheDispatcherLoads,
// },
// }
// if err := dspEngine2RPC.Call(context.Background(), utils.CacheSv1GetItemIDs, argsAPI, &rcvKeys); err == nil ||
// err.Error() != utils.ErrNotFound.Error() {
// t.Error(err)
// }
// if err := dspEngine1RPC.Call(context.Background(), utils.CacheSv1GetItemIDs, argsAPI, &rcvKeys); err == nil ||
// err.Error() != utils.ErrNotFound.Error() {
// t.Error(err)
// }
// var wgDisp1 sync.WaitGroup
// var wgDisp2 sync.WaitGroup
// for i := 0; i < 10; i++ {
// wgDisp1.Add(1)
// wgDisp2.Add(1)
// go func() {
// var rpl []*engine.ChrgSProcessEventReply
// if err := dspEngine1RPC.Call(context.Background(), utils.ChargerSv1ProcessEvent, &utils.CGREvent{
// Tenant: "cgrates.org",
// ID: "testCacheRplAACheckLoadReplication",
// Event: map[string]any{
// utils.AccountField: "1007",
// utils.Destination: "+491511231234",
// "EventName": "TestLoad",
// },
// APIOpts: map[string]any{
// utils.OptsRouteID: "testRouteFromDispatcher1",
// },
// }, &rpl); err != nil {
// t.Error(err)
// } else if rpl[0].ChargerSProfile != "DefaultCharger" {
// t.Errorf("Received: %+v", utils.ToJSON(rpl))
// }
// wgDisp1.Done()
// }()
// go func() {
// var rpl []*engine.ChrgSProcessEventReply
// if err := dspEngine2RPC.Call(context.Background(), utils.ChargerSv1ProcessEvent, &utils.CGREvent{
// Tenant: "cgrates.org",
// ID: "testCacheRplAACheckLoadReplication",
// Event: map[string]any{
// utils.AccountField: "1007",
// utils.Destination: "+491511231234",
// "EventName": "TestLoad",
// },
// APIOpts: map[string]any{
// utils.OptsRouteID: "testRouteFromDispatcher2",
// },
// }, &rpl); err != nil {
// t.Error(err)
// } else if rpl[0].ChargerSProfile != "DefaultCharger" {
// t.Errorf("Received: %+v", utils.ToJSON(rpl))
// }
// wgDisp2.Done()
// }()
// }
// wgDisp1.Wait()
// wgDisp2.Wait()
// expKeys := []string{"testRouteFromDispatcher1:*attributes",
// "testRouteFromDispatcher1:*chargers", "testRouteFromDispatcher2:*attributes",
// "testRouteFromDispatcher2:*chargers"}
// argsAPI = utils.ArgsGetCacheItemIDsWithAPIOpts{
// Tenant: "cgrates.org",
// }
// if err := dspEngine2RPC.Call(context.Background(), utils.CacheSv1GetItemIDs, argsAPI, &rcvKeys); err != nil {
// t.Error(err.Error())
// }
// sort.Strings(rcvKeys)
// sort.Strings(expKeys)
// if !reflect.DeepEqual(expKeys, rcvKeys) {
// t.Errorf("Expected: %+v, received: %+v", expKeys, rcvKeys)
// }
// if err := dspEngine1RPC.Call(context.Background(), utils.CacheSv1GetItemIDs, argsAPI, &rcvKeys); err != nil {
// t.Error(err.Error())
// }
// sort.Strings(rcvKeys)
// sort.Strings(expKeys)
// if !reflect.DeepEqual(expKeys, rcvKeys) {
// t.Errorf("Expected: %+v, received: %+v", expKeys, rcvKeys)
// }
// expKeys = []string{"cgrates.org:Engine2"}
// argsAPI = utils.ArgsGetCacheItemIDsWithAPIOpts{
// Tenant: "cgrates.org",
// ArgsGetCacheItemIDs: utils.ArgsGetCacheItemIDs{
// CacheID: utils.CacheDispatcherLoads,
// },
// }
// if err := dspEngine2RPC.Call(context.Background(), utils.CacheSv1GetItemIDs, argsAPI, &rcvKeys); err != nil {
// t.Error(err.Error())
// }
// sort.Strings(rcvKeys)
// sort.Strings(expKeys)
// if !reflect.DeepEqual(expKeys, rcvKeys) {
// t.Errorf("Expected: %+v, received: %+v", expKeys, rcvKeys)
// }
// if err := dspEngine1RPC.Call(context.Background(), utils.CacheSv1GetItemIDs, argsAPI, &rcvKeys); err != nil {
// t.Error(err.Error())
// }
// sort.Strings(rcvKeys)
// sort.Strings(expKeys)
// if !reflect.DeepEqual(expKeys, rcvKeys) {
// t.Errorf("Expected: %+v, received: %+v", expKeys, rcvKeys)
// }
// }
// func testCacheRplCheckLoadReplication(t *testing.T) {
// var rcvKeys []string
// argsAPI := utils.ArgsGetCacheItemIDsWithAPIOpts{
// Tenant: "cgrates.org",
// ArgsGetCacheItemIDs: utils.ArgsGetCacheItemIDs{
// CacheID: utils.CacheDispatcherLoads,
// },
// }
// if err := dspEngine2RPC.Call(context.Background(), utils.CacheSv1GetItemIDs, argsAPI, &rcvKeys); err == nil || err.Error() != utils.ErrNotFound.Error() {
// t.Error(err)
// }
// var rpl []*engine.ChrgSProcessEventReply
// var wg sync.WaitGroup
// for i := 0; i < 10; i++ {
// wg.Add(1)
// go func() {
// if err := dspEngine1RPC.Call(context.Background(), utils.ChargerSv1ProcessEvent, &utils.CGREvent{
// Tenant: "cgrates.org",
// ID: "testCacheRplCheckLoadReplication",
// Event: map[string]any{
// utils.AccountField: "1007",
// utils.Destination: "+491511231234",
// "EventName": "TestLoad",
// },
// APIOpts: map[string]any{
// utils.OptsRouteID: "testRoute123",
// },
// }, &rpl); err != nil {
// t.Error(err)
// } else if rpl[0].ChargerSProfile != "DefaultCharger" {
// t.Errorf("Received: %+v", utils.ToJSON(rpl))
// }
// wg.Done()
// }()
// }
// wg.Wait()
// expKeys := []string{"testRoute123:*core", "testRoute123:*attributes", "testRoute123:*chargers"}
// argsAPI = utils.ArgsGetCacheItemIDsWithAPIOpts{
// Tenant: "cgrates.org",
// ArgsGetCacheItemIDs: utils.ArgsGetCacheItemIDs{
// CacheID: utils.CacheDispatcherRoutes,
// },
// }
// if err := dspEngine2RPC.Call(context.Background(), utils.CacheSv1GetItemIDs, argsAPI, &rcvKeys); err != nil {
// t.Error(err.Error())
// }
// sort.Strings(rcvKeys)
// sort.Strings(expKeys)
// if !reflect.DeepEqual(expKeys, rcvKeys) {
// t.Errorf("Expected: %+v, received: %+v", expKeys, rcvKeys)
// }
// expKeys = []string{"cgrates.org:Engine2"}
// argsAPI = utils.ArgsGetCacheItemIDsWithAPIOpts{
// Tenant: "cgrates.org",
// ArgsGetCacheItemIDs: utils.ArgsGetCacheItemIDs{
// CacheID: utils.CacheDispatcherLoads,
// },
// }
// if err := dspEngine2RPC.Call(context.Background(), utils.CacheSv1GetItemIDs, argsAPI, &rcvKeys); err != nil {
// t.Error(err.Error())
// }
// sort.Strings(rcvKeys)
// sort.Strings(expKeys)
// if !reflect.DeepEqual(expKeys, rcvKeys) {
// t.Errorf("Expected: %+v, received: %+v", expKeys, rcvKeys)
// }
// }
func testCacheRplStopEngine(t *testing.T) {
if err := engine.KillEngine(*utils.WaitRater); err != nil {
t.Error(err)
}
}