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

Updating dispatcher management API tests

Browse Source
This commit is contained in:
DanB
2019-02-13 17:51:00 +01:00
parent 02b370aef1
commit 5ae801a8b3
2 changed files with 28 additions and 15 deletions
Download Patch File Download Diff File Expand all files Collapse all files

31
apier/v1/dispatcher_it_test.go
View File

@@ -26,6 +26,7 @@ import (
"path"
"reflect"
"testing"
"time"
"github.com/cgrates/cgrates/config"
"github.com/cgrates/cgrates/engine"
@@ -110,7 +111,7 @@ func testDispatcherSRPCConn(t *testing.T) {
func testDispatcherSSetDispatcherProfile(t *testing.T) {
var reply string
if err := dispatcherRPC.Call("ApierV1.GetDispatcherProfile",
if err := dispatcherRPC.Call(utils.ApierV1GetDispatcherProfile,
&utils.TenantID{Tenant: "cgrates.org", ID: "Dsp1"},
&reply); err == nil || err.Error() != utils.ErrNotFound.Error() {
t.Error(err)
@@ -125,7 +126,7 @@ func testDispatcherSSetDispatcherProfile(t *testing.T) {
Weight: 20,
}
if err := dispatcherRPC.Call("ApierV1.SetDispatcherProfile",
if err := dispatcherRPC.Call(utils.ApierV1SetDispatcherProfile,
dispatcherProfile,
&reply); err != nil {
t.Error(err)
@@ -134,7 +135,7 @@ func testDispatcherSSetDispatcherProfile(t *testing.T) {
}
var dsp *engine.DispatcherProfile
if err := dispatcherRPC.Call("ApierV1.GetDispatcherProfile",
if err := dispatcherRPC.Call(utils.ApierV1GetDispatcherProfile,
&utils.TenantID{Tenant: "cgrates.org", ID: "Dsp1"},
&dsp); err != nil {
t.Error(err)
@@ -156,17 +157,25 @@ func testDispatcherSGetDispatcherProfileIDs(t *testing.T) {
func testDispatcherSUpdateDispatcherProfile(t *testing.T) {
var result string
dispatcherProfile.Strategy = utils.MetaRandom
if err := dispatcherRPC.Call("ApierV1.SetDispatcherProfile",
dispatcherProfile,
&result); err != nil {
dispatcherProfile.Strategy = utils.MetaWeight
dispatcherProfile.Subsystems = []string{utils.MetaAttributes, utils.MetaSessionS, utils.MetaRALs, utils.MetaCDRs}
dispatcherProfile.ActivationInterval = &utils.ActivationInterval{
ActivationTime: time.Date(2019, 3, 1, 0, 0, 0, 0, time.UTC),
ExpiryTime: time.Date(2019, 4, 1, 0, 0, 0, 0, time.UTC),
}
dispatcherProfile.Conns = []*engine.DispatcherConn{
{ID: "HOST1", Weight: 20.0},
{ID: "HOST2", Weight: 10.0},
}
if err := dispatcherRPC.Call(utils.ApierV1SetDispatcherProfile,
dispatcherProfile, &result); err != nil {
t.Error(err)
} else if result != utils.OK {
t.Errorf("Expecting : %+v, received: %+v", utils.OK, result)
}
var dsp *engine.DispatcherProfile
if err := dispatcherRPC.Call("ApierV1.GetDispatcherProfile",
if err := dispatcherRPC.Call(utils.ApierV1GetDispatcherProfile,
&utils.TenantID{Tenant: "cgrates.org", ID: "Dsp1"},
&dsp); err != nil {
t.Error(err)
@@ -177,7 +186,7 @@ func testDispatcherSUpdateDispatcherProfile(t *testing.T) {
func testDispatcherSRemDispatcherProfile(t *testing.T) {
var result string
if err := dispatcherRPC.Call("ApierV1.RemoveDispatcherProfile",
if err := dispatcherRPC.Call(utils.ApierV1RemoveDispatcherProfile,
&utils.TenantID{Tenant: "cgrates.org", ID: "Dsp1"},
&result); err != nil {
t.Error(err)
@@ -186,13 +195,13 @@ func testDispatcherSRemDispatcherProfile(t *testing.T) {
}
var dsp *engine.DispatcherProfile
if err := dispatcherRPC.Call("ApierV1.GetDispatcherProfile",
if err := dispatcherRPC.Call(utils.ApierV1GetDispatcherProfile,
&utils.TenantID{Tenant: "cgrates.org", ID: "Dsp1"},
&dsp); err == nil || err.Error() != utils.ErrNotFound.Error() {
t.Error(err)
}
if err := dispatcherRPC.Call("ApierV1.RemoveDispatcherProfile",
if err := dispatcherRPC.Call(utils.ApierV1RemoveDispatcherProfile,
&utils.TenantID{Tenant: "cgrates.org", ID: "Dsp1"},
&result); err.Error() != utils.ErrNotFound.Error() {
t.Errorf("Expected error: %v recived: %v", utils.ErrNotFound, err)

12
utils/consts.go
View File

@@ -386,6 +386,7 @@ const (
MetaActionTriggers = "*action_triggers"
MetaActions = "*actions"
MetaSharedGroups = "*shared_groups"
MetaRALs = "*rals"
MetaStats = "*stats"
MetaThresholds = "*thresholds"
MetaSuppliers = "*suppliers"
@@ -701,10 +702,13 @@ const (
// ApierV1 APIs
const (
ApierV1ComputeFilterIndexes = "ApierV1.ComputeFilterIndexes"
ApierV1ReloadCache = "ApierV1.ReloadCache"
ApierV1ReloadScheduler = "ApierV1.ReloadScheduler"
ApierV1Ping = "ApierV1.Ping"
ApierV1ComputeFilterIndexes = "ApierV1.ComputeFilterIndexes"
ApierV1ReloadCache = "ApierV1.ReloadCache"
ApierV1ReloadScheduler = "ApierV1.ReloadScheduler"
ApierV1Ping = "ApierV1.Ping"
ApierV1SetDispatcherProfile = "ApierV1.SetDispatcherProfile"
ApierV1GetDispatcherProfile = "ApierV1.GetDispatcherProfile"
ApierV1RemoveDispatcherProfile = "ApierV1.RemoveDispatcherProfile"
)
const (