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

Fixed integration tests failling

Browse Source
This commit is contained in:
andronache
2021-07-07 16:20:41 +03:00
committed by Dan Christian Bogos
parent f10f9351ec
commit bca4fb87f2
3 changed files with 10 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
dispatchers/responder_it_test.go
View File

@@ -78,13 +78,13 @@ func testDspResponderStatus(t *testing.T) {
utils.OptsAPIKey: "rsp12345",
},
}
if err := dispEngine.RPC.Call(utils.CoreSv1Status, &ev, &reply); err != nil {
if err := dispEngine.RPC.Call(utils.DispatcherSv1RemoteStatus, &ev, &reply); err != nil {
t.Error(err)
} else if reply[utils.NodeID] != "ALL" {
t.Errorf("Received: %s", utils.ToJSON(reply))
}
allEngine.stopEngine(t)
if err := dispEngine.RPC.Call(utils.CoreSv1Status, &ev, &reply); err != nil {
if err := dispEngine.RPC.Call(utils.DispatcherSv1RemoteStatus, &ev, &reply); err != nil {
t.Error(err)
} else if reply[utils.NodeID] != "ALL2" {
t.Errorf("Received: %s", utils.ToJSON(reply))
@@ -114,12 +114,12 @@ func getNodeWithRoute(route string, t *testing.T) string {
},
}
if err := dispEngine.RPC.Call(utils.CoreSv1Ping, pingEv, &pingReply); err != nil {
if err := dispEngine.RPC.Call(utils.DispatcherSv1RemotePing, pingEv, &pingReply); err != nil {
t.Error(err)
} else if pingReply != utils.Pong {
t.Errorf("Received: %s", pingReply)
}
if err := dispEngine.RPC.Call(utils.CoreSv1Status, ev, &reply); err != nil {
if err := dispEngine.RPC.Call(utils.DispatcherSv1RemoteStatus, ev, &reply); err != nil {
t.Error(err)
}
if reply[utils.NodeID] == nil {
@@ -152,7 +152,7 @@ func testDspResponderShutdown(t *testing.T) {
} else if reply != "Done!" {
t.Errorf("Received: %s", utils.ToJSON(reply))
}
if err := dispEngine.RPC.Call(utils.CoreSv1Status, &ev, &statusReply); err != nil {
if err := dispEngine.RPC.Call(utils.DispatcherSv1RemoteStatus, &ev, &statusReply); err != nil {
t.Error(err)
} else if statusReply[utils.NodeID] != "ALL2" {
t.Errorf("Received: %s", utils.ToJSON(statusReply))
@@ -223,12 +223,12 @@ func testDspResponderInternal(t *testing.T) {
utils.OptsRouteID: route,
},
}
if err := dispEngine.RPC.Call(utils.CoreSv1Ping, pingEv, &pingReply); err != nil {
if err := dispEngine.RPC.Call(utils.DispatcherSv1RemotePing, pingEv, &pingReply); err != nil {
t.Error(err)
} else if pingReply != utils.Pong {
t.Errorf("Received: %s", pingReply)
}
if err := dispEngine.RPC.Call(utils.CoreSv1Status, &ev, &reply); err != nil {
if err := dispEngine.RPC.Call(utils.DispatcherSv1RemoteStatus, &ev, &reply); err != nil {
t.Error(err)
}
if reply[utils.NodeID] == nil {

4
general_tests/cacherpl_it_test.go
View File

@@ -313,7 +313,7 @@ func testCacheRplPing(t *testing.T) {
utils.OptsRouteID: "testRoute123",
},
}
if err := dspEngine1RPC.Call(utils.CoreSv1Status, &ev, &reply); err != nil {
if err := dspEngine1RPC.Call(utils.DispatcherSv1RemoteStatus, &ev, &reply); err != nil {
t.Error(err)
} else if reply[utils.NodeID] != "Engine1" {
t.Errorf("Received: %s", utils.ToJSON(reply))
@@ -338,7 +338,7 @@ func testCacheRplCheckReplication(t *testing.T) {
ev := utils.TenantWithAPIOpts{
Tenant: "cgrates.org",
}
if err := dspEngine2RPC.Call(utils.CoreSv1Status, &ev, &reply); err != nil {
if err := dspEngine2RPC.Call(utils.DispatcherSv1RemoteStatus, &ev, &reply); err != nil {
t.Error(err)
} else if reply[utils.NodeID] != "DispatcherEngine2" {
t.Errorf("Received: %s", utils.ToJSON(reply))

2
registrarc/registrarc_it_test.go
View File

@@ -127,7 +127,7 @@ func testDsphLoadData(t *testing.T) {
func testDsphGetNodeID() (id string, err error) {
var status map[string]interface{}
if err = dspRPC.Call(utils.CoreSv1Status, utils.TenantWithAPIOpts{
if err = dspRPC.Call(utils.DispatcherSv1RemoteStatus, utils.TenantWithAPIOpts{
Tenant: "cgrates.org",
APIOpts: map[string]interface{}{},
}, &status); err != nil {