mirror of
https://github.com/cgrates/cgrates.git
synced 2026-02-16 13:49:53 +05:00
Updated agent tests
This commit is contained in:
committed by
Dan Christian Bogos
parent
6bff7dfb9b
commit
506c337d02
@@ -223,7 +223,7 @@ func testDiamItResetAllDB(t *testing.T) {
|
||||
}
|
||||
|
||||
cfgPath2 := path.Join(*dataDir, "conf", "samples", "dispatchers", "all2")
|
||||
allCfg2, err := config.NewCGRConfigFromPath(cfgPath2)
|
||||
allCfg2, err := config.NewCGRConfigFromPath(context.Background(), cfgPath2)
|
||||
if err != nil {
|
||||
t.Fatal(err)
|
||||
}
|
||||
@@ -279,7 +279,7 @@ func testDiamItApierRpcConn(t *testing.T) {
|
||||
func testDiamItTPFromFolder(t *testing.T) {
|
||||
attrs := &utils.AttrLoadTpFromFolder{FolderPath: path.Join(*dataDir, "tariffplans", "tutorial")}
|
||||
var loadInst utils.LoadInstance
|
||||
if err := apierRpc.Call(utils.APIerSv2LoadTariffPlanFromFolder, attrs, &loadInst); err != nil {
|
||||
if err := apierRpc.Call(utils.APIerSv1LoadTariffPlanFromFolder, attrs, &loadInst); err != nil {
|
||||
t.Error(err)
|
||||
}
|
||||
if isDispatcherActive {
|
||||
|
||||
@@ -115,7 +115,7 @@ func testDNSitApierRpcConn(t *testing.T) {
|
||||
func testDNSitTPFromFolder(t *testing.T) {
|
||||
attrs := &utils.AttrLoadTpFromFolder{FolderPath: path.Join(*dataDir, "tariffplans", "dnsagent")}
|
||||
var loadInst utils.LoadInstance
|
||||
if err := dnsRPC.Call(utils.APIerSv2LoadTariffPlanFromFolder,
|
||||
if err := dnsRPC.Call(utils.APIerSv1LoadTariffPlanFromFolder,
|
||||
attrs, &loadInst); err != nil {
|
||||
t.Error(err)
|
||||
}
|
||||
|
||||
@@ -184,7 +184,7 @@ func testHAitApierRpcConn(t *testing.T) {
|
||||
func testHAitTPFromFolder(t *testing.T) {
|
||||
attrs := &utils.AttrLoadTpFromFolder{FolderPath: path.Join(*dataDir, "tariffplans", "oldtutorial")}
|
||||
var loadInst utils.LoadInstance
|
||||
if err := haRPC.Call(utils.APIerSv2LoadTariffPlanFromFolder, attrs, &loadInst); err != nil {
|
||||
if err := haRPC.Call(utils.APIerSv1LoadTariffPlanFromFolder, attrs, &loadInst); err != nil {
|
||||
t.Error(err)
|
||||
}
|
||||
time.Sleep(time.Duration(*waitRater) * time.Millisecond) // Give time for scheduler to execute topups
|
||||
|
||||
@@ -167,7 +167,7 @@ func testRAitApierRpcConn(t *testing.T) {
|
||||
func testRAitTPFromFolder(t *testing.T) {
|
||||
attrs := &utils.AttrLoadTpFromFolder{FolderPath: path.Join(*dataDir, "tariffplans", "oldtutorial")}
|
||||
var loadInst utils.LoadInstance
|
||||
if err := raRPC.Call(utils.APIerSv2LoadTariffPlanFromFolder, attrs, &loadInst); err != nil {
|
||||
if err := raRPC.Call(utils.APIerSv1LoadTariffPlanFromFolder, attrs, &loadInst); err != nil {
|
||||
t.Error(err)
|
||||
}
|
||||
if isDispatcherActive {
|
||||
|
||||
@@ -127,7 +127,7 @@ func testSAitApierRpcConn(t *testing.T) {
|
||||
func testSAitTPFromFolder(t *testing.T) {
|
||||
attrs := &utils.AttrLoadTpFromFolder{FolderPath: path.Join(*dataDir, "tariffplans", "tut_sip_redirect")}
|
||||
var loadInst utils.LoadInstance
|
||||
if err := saRPC.Call(utils.APIerSv2LoadTariffPlanFromFolder, attrs, &loadInst); err != nil {
|
||||
if err := saRPC.Call(utils.APIerSv1LoadTariffPlanFromFolder, attrs, &loadInst); err != nil {
|
||||
t.Error(err)
|
||||
}
|
||||
time.Sleep(time.Duration(*waitRater) * time.Millisecond) // Give time for scheduler to execute topups
|
||||
|
||||
Reference in New Issue
Block a user