From 5ae801a8b3e4bf97ffa95598bf86ebf812df6e73 Mon Sep 17 00:00:00 2001 From: DanB Date: Wed, 13 Feb 2019 17:51:00 +0100 Subject: [PATCH] Updating dispatcher management API tests --- apier/v1/dispatcher_it_test.go | 31 ++++++++++++++++++++----------- utils/consts.go | 12 ++++++++---- 2 files changed, 28 insertions(+), 15 deletions(-) diff --git a/apier/v1/dispatcher_it_test.go b/apier/v1/dispatcher_it_test.go index b9c6478d3..ee411def7 100644 --- a/apier/v1/dispatcher_it_test.go +++ b/apier/v1/dispatcher_it_test.go @@ -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) diff --git a/utils/consts.go b/utils/consts.go index d4e30f2b7..f760fe66d 100755 --- a/utils/consts.go +++ b/utils/consts.go @@ -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 (