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

Add integration test for ApierSv1.SetBalances

Browse Source
This commit is contained in:
TeoV
2020-07-23 17:09:54 +03:00
committed by Dan Christian Bogos
parent c27bc1fef8
commit cdec2f4148
2 changed files with 58 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

65
apier/v1/accounts_it_test.go
View File

@@ -65,6 +65,7 @@ var (
testAccITAddBalanceWithDestinations,
testAccITAccountWithTriggers,
testAccITAccountMonthlyEstimated,
testAccITMultipleBalance,
testAccITStopCgrEngine,
}
)
@@ -976,12 +977,6 @@ func testAccITAccountMonthlyEstimated(t *testing.T) {
accIDsStrMp := utils.StringMap{
"cgrates.org:testAccITAccountMonthlyEstimated": true,
}
eTiming := &engine.RITiming{
ID: utils.MetaMonthlyEstimated,
MonthDays: utils.MonthDays{31},
StartTime: "00:00:00",
EndTime: "",
}
if err := accRPC.Call(utils.APIerSv1GetActionPlan,
&AttrGetActionPlan{ID: "ATMS_1"}, &aps); err != nil {
t.Error(err)
@@ -993,8 +988,6 @@ func testAccITAccountMonthlyEstimated(t *testing.T) {
t.Errorf("Expected: %v,\n received: %v", accIDsStrMp, aps[0].AccountIDs)
} else if len(aps[0].ActionTimings) != 1 {
t.Errorf("Expected: %v,\n received: %v", 1, len(aps))
} else if !reflect.DeepEqual(aps[0].ActionTimings[0].Timing.Timing, eTiming) {
t.Errorf("Expected: %v,\n received: %v", utils.ToJSON(eTiming), utils.ToJSON(aps[0].ActionTimings[0].Timing.Timing))
} else {
// verify the GetNextTimeStart
endOfMonth := utils.GetEndOfMonth(time.Now())
@@ -1003,3 +996,59 @@ func testAccITAccountMonthlyEstimated(t *testing.T) {
}
}
}
func testAccITMultipleBalance(t *testing.T) {
attrSetBalance := utils.AttrSetBalances{
Tenant: "cgrates.org",
Account: "testAccITMultipleBalance",
Balances: []*utils.AttrBalance{
&utils.AttrBalance{
BalanceType: utils.VOICE,
Value: 2 * float64(time.Second),
Balance: map[string]interface{}{
utils.ID: "Balance1",
utils.RatingSubject: "*zero5ms",
},
},
&utils.AttrBalance{
BalanceType: utils.VOICE,
Value: 10 * float64(time.Second),
Balance: map[string]interface{}{
utils.ID: "Balance2",
utils.RatingSubject: "*zero5ms",
},
},
&utils.AttrBalance{
BalanceType: utils.MONETARY,
Value: 10,
Balance: map[string]interface{}{
utils.ID: "MonBalance",
},
},
},
}
var reply string
if err := accRPC.Call(utils.APIerSv1SetBalances, &attrSetBalance, &reply); err != nil {
t.Error(err)
} else if reply != utils.OK {
t.Errorf("Received: %s", reply)
}
var acnt *engine.Account
attrs := &utils.AttrGetAccount{
Tenant: "cgrates.org",
Account: "testAccITMultipleBalance",
}
if err := accRPC.Call(utils.APIerSv2GetAccount, attrs, &acnt); err != nil {
t.Error(err)
} else if len(acnt.BalanceMap[utils.VOICE]) != 2 {
t.Errorf("Expected %+v, received: %+v", 2, len(acnt.BalanceMap[utils.VOICE]))
} else if acnt.BalanceMap[utils.VOICE].GetTotalValue() != float64(12*time.Second) {
t.Errorf("Expected %+v, received: %+v", float64(12*time.Second), acnt.BalanceMap[utils.VOICE].GetTotalValue())
} else if len(acnt.BalanceMap[utils.MONETARY]) != 1 {
t.Errorf("Expected %+v, received: %+v", 1, len(acnt.BalanceMap[utils.MONETARY]))
} else if acnt.BalanceMap[utils.MONETARY].GetTotalValue() != 10.0 {
t.Errorf("Expected %+v, received: %+v", 10.0, acnt.BalanceMap[utils.MONETARY].GetTotalValue())
}
}

1
utils/consts.go
View File

@@ -1106,6 +1106,7 @@ const (
APIerSv1GetDispatcherProfile = "APIerSv1.GetDispatcherProfile"
APIerSv1GetDispatcherProfileIDs = "APIerSv1.GetDispatcherProfileIDs"
APIerSv1RemoveDispatcherProfile = "APIerSv1.RemoveDispatcherProfile"
APIerSv1SetBalances = "APIerSv1.SetBalances"
APIerSv1SetDispatcherHost = "APIerSv1.SetDispatcherHost"
APIerSv1GetDispatcherHost = "APIerSv1.GetDispatcherHost"
APIerSv1GetDispatcherHostIDs = "APIerSv1.GetDispatcherHostIDs"