mirror of
https://github.com/cgrates/cgrates.git
synced 2026-02-11 18:16:24 +05:00
Refactor test for sessions data_it_test
This commit is contained in:
TeoV
committed by
Dan Christian Bogos
Dan Christian Bogos
parent
c3dfb80c39
commit
64b85d349c
@@ -1,797 +0,0 @@
|
||||
// +build integration
|
||||
|
||||
/*
|
||||
Real-time Online/Offline Charging System (OCS) for Telecom & ISP environments
|
||||
Copyright (C) ITsysCOM GmbH
|
||||
|
||||
This program is free software: you can redistribute it and/or modify
|
||||
it under the terms of the GNU General Public License as published by
|
||||
the Free Software Foundation, either version 3 of the License, or
|
||||
(at your option) any later version.
|
||||
|
||||
This program is distributed in the hope that it will be useful,
|
||||
but WITHOUT ANY WARRANTY; without even the implied warranty of
|
||||
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
||||
GNU General Public License for more details.
|
||||
|
||||
You should have received a copy of the GNU General Public License
|
||||
along with this program. If not, see <http://www.gnu.org/licenses/>
|
||||
*/
|
||||
package sessions
|
||||
|
||||
import (
|
||||
"net/rpc"
|
||||
"net/rpc/jsonrpc"
|
||||
"path"
|
||||
"testing"
|
||||
"time"
|
||||
|
||||
"github.com/cgrates/cgrates/config"
|
||||
"github.com/cgrates/cgrates/engine"
|
||||
"github.com/cgrates/cgrates/utils"
|
||||
)
|
||||
|
||||
var smgRPC *rpc.Client
|
||||
|
||||
func TestSMGDataInitCfg(t *testing.T) {
|
||||
daCfgPath = path.Join(*dataDir, "conf", "samples", "smg")
|
||||
// Init config first
|
||||
var err error
|
||||
daCfg, err = config.NewCGRConfigFromFolder(daCfgPath)
|
||||
if err != nil {
|
||||
t.Error(err)
|
||||
}
|
||||
daCfg.DataFolderPath = *dataDir // Share DataFolderPath through config towards StoreDb for Flush()
|
||||
config.SetCgrConfig(daCfg)
|
||||
}
|
||||
|
||||
// Remove data in both rating and accounting db
|
||||
func TestSMGDataResetDataDb(t *testing.T) {
|
||||
if err := engine.InitDataDb(daCfg); err != nil {
|
||||
t.Fatal(err)
|
||||
}
|
||||
}
|
||||
|
||||
// Wipe out the cdr database
|
||||
func TestSMGDataResetStorDb(t *testing.T) {
|
||||
if err := engine.InitStorDb(daCfg); err != nil {
|
||||
t.Fatal(err)
|
||||
}
|
||||
}
|
||||
|
||||
// Start CGR Engine
|
||||
func TestSMGDataStartEngine(t *testing.T) {
|
||||
if _, err := engine.StopStartEngine(daCfgPath, *waitRater); err != nil {
|
||||
t.Fatal(err)
|
||||
}
|
||||
}
|
||||
|
||||
// Connect rpc client to rater
|
||||
func TestSMGDataApierRpcConn(t *testing.T) {
|
||||
var err error
|
||||
smgRPC, err = jsonrpc.Dial("tcp", daCfg.ListenCfg().RPCJSONListen) // We connect over JSON so we can also troubleshoot if needed
|
||||
if err != nil {
|
||||
t.Fatal(err)
|
||||
}
|
||||
}
|
||||
|
||||
// Load the tariff plan, creating accounts and their balances
|
||||
func TestSMGDataTPFromFolder(t *testing.T) {
|
||||
attrs := &utils.AttrLoadTpFromFolder{FolderPath: path.Join(*dataDir, "tariffplans", "oldtutorial")}
|
||||
var loadInst utils.LoadInstance
|
||||
if err := smgRPC.Call("ApierV2.LoadTariffPlanFromFolder", attrs, &loadInst); err != nil {
|
||||
t.Error(err)
|
||||
}
|
||||
time.Sleep(time.Duration(*waitRater) * time.Millisecond) // Give time for scheduler to execute topups
|
||||
}
|
||||
|
||||
func TestSMGDataLastUsedData(t *testing.T) {
|
||||
var acnt *engine.Account
|
||||
attrs := &utils.AttrGetAccount{Tenant: "cgrates.org", Account: "1001"}
|
||||
eAcntVal := 102400.0
|
||||
if err := smgRPC.Call("ApierV2.GetAccount", attrs, &acnt); err != nil {
|
||||
t.Error(err)
|
||||
} else if acnt.BalanceMap[utils.DATA].GetTotalValue() != eAcntVal {
|
||||
t.Errorf("Expected: %f, received: %f",
|
||||
eAcntVal, acnt.BalanceMap[utils.DATA].GetTotalValue())
|
||||
}
|
||||
tStart, _ := utils.ParseTimeDetectLayout("2016-01-05T18:31:05Z", "")
|
||||
cd := engine.CallDescriptor{
|
||||
Direction: "*out",
|
||||
Category: "data",
|
||||
Tenant: "cgrates.org",
|
||||
Subject: "1001",
|
||||
Account: "1001",
|
||||
Destination: utils.DATA,
|
||||
TimeStart: tStart,
|
||||
TimeEnd: tStart.Add(time.Duration(1024)),
|
||||
}
|
||||
var cc engine.CallCost
|
||||
// Make sure the cost is what we expect to be for 1MB of data
|
||||
if err := smgRPC.Call("Responder.GetCost", cd, &cc); err != nil {
|
||||
t.Error("Got error on Responder.GetCost: ", err.Error())
|
||||
} else if cc.Cost != 1024 {
|
||||
t.Errorf("Calling Responder.GetCost got callcost: %v", cc.Cost)
|
||||
}
|
||||
smgEv := map[string]interface{}{
|
||||
utils.EVENT_NAME: "TEST_EVENT",
|
||||
utils.ToR: utils.DATA,
|
||||
utils.OriginID: "123491",
|
||||
utils.Direction: utils.OUT,
|
||||
utils.Account: "1001",
|
||||
utils.Subject: "1001",
|
||||
utils.Destination: utils.DATA,
|
||||
utils.Category: "data",
|
||||
utils.Tenant: "cgrates.org",
|
||||
utils.RequestType: utils.META_PREPAID,
|
||||
utils.SetupTime: "2016-01-05 18:30:59",
|
||||
utils.AnswerTime: "2016-01-05 18:31:05",
|
||||
utils.Usage: "5120", // 5MB
|
||||
}
|
||||
var maxUsage int64
|
||||
if err := smgRPC.Call("SMGenericV2.InitiateSession", smgEv, &maxUsage); err != nil {
|
||||
t.Error(err)
|
||||
}
|
||||
if maxUsage != 5120 {
|
||||
t.Error("Bad max usage: ", maxUsage)
|
||||
}
|
||||
eAcntVal = 97280.0 // 100 -5
|
||||
if err := smgRPC.Call("ApierV2.GetAccount", attrs, &acnt); err != nil {
|
||||
t.Error(err)
|
||||
} else if acnt.BalanceMap[utils.DATA].GetTotalValue() != eAcntVal {
|
||||
t.Errorf("Expected: %f, received: %f",
|
||||
eAcntVal, acnt.BalanceMap[utils.DATA].GetTotalValue())
|
||||
}
|
||||
smgEv = map[string]interface{}{
|
||||
utils.EVENT_NAME: "TEST_EVENT",
|
||||
utils.ToR: utils.DATA,
|
||||
utils.OriginID: "123491",
|
||||
utils.Direction: utils.OUT,
|
||||
utils.Account: "1001",
|
||||
utils.Subject: "1001",
|
||||
utils.Destination: utils.DATA,
|
||||
utils.Category: "data",
|
||||
utils.Tenant: "cgrates.org",
|
||||
utils.RequestType: utils.META_PREPAID,
|
||||
utils.SetupTime: "2016-01-05 18:30:59",
|
||||
utils.AnswerTime: "2016-01-05 18:31:05",
|
||||
utils.Usage: "5120",
|
||||
utils.LastUsed: "4096",
|
||||
}
|
||||
if err := smgRPC.Call("SMGenericV2.UpdateSession", smgEv, &maxUsage); err != nil {
|
||||
t.Error(err)
|
||||
}
|
||||
if maxUsage != 5120 {
|
||||
t.Error("Bad max usage: ", maxUsage)
|
||||
}
|
||||
eAcntVal = 93184.0 // 100-9
|
||||
if err := smgRPC.Call("ApierV2.GetAccount", attrs, &acnt); err != nil {
|
||||
t.Error(err)
|
||||
} else if acnt.BalanceMap[utils.DATA].GetTotalValue() != eAcntVal {
|
||||
t.Errorf("Expected: %f, received: %f", eAcntVal, acnt.BalanceMap[utils.DATA].GetTotalValue())
|
||||
}
|
||||
smgEv = map[string]interface{}{
|
||||
utils.EVENT_NAME: "TEST_EVENT",
|
||||
utils.ToR: utils.DATA,
|
||||
utils.OriginID: "123491",
|
||||
utils.Direction: utils.OUT,
|
||||
utils.Account: "1001",
|
||||
utils.Subject: "1001",
|
||||
utils.Destination: utils.DATA,
|
||||
utils.Category: "data",
|
||||
utils.Tenant: "cgrates.org",
|
||||
utils.RequestType: utils.META_PREPAID,
|
||||
utils.SetupTime: "2016-01-05 18:30:59",
|
||||
utils.AnswerTime: "2016-01-05 18:31:05",
|
||||
utils.LastUsed: "0",
|
||||
}
|
||||
var rpl string
|
||||
if err := smgRPC.Call("SMGenericV1.TerminateSession",
|
||||
smgEv, &rpl); err != nil || rpl != utils.OK {
|
||||
t.Error(err)
|
||||
}
|
||||
eAcntVal = 98304.0 //100-4
|
||||
if err := smgRPC.Call("ApierV2.GetAccount", attrs, &acnt); err != nil {
|
||||
t.Error(err)
|
||||
} else if acnt.BalanceMap[utils.DATA].GetTotalValue() != eAcntVal {
|
||||
t.Errorf("Expected: %f, received: %f",
|
||||
eAcntVal, acnt.BalanceMap[utils.DATA].GetTotalValue())
|
||||
}
|
||||
}
|
||||
|
||||
func TestSMGDataLastUsedMultipleUpdates(t *testing.T) {
|
||||
var acnt *engine.Account
|
||||
acntAttrs := &utils.AttrGetAccount{Tenant: "cgrates.org",
|
||||
Account: "TestSMGDataLastUsedMultipleData"}
|
||||
eAcntVal := 102400.0
|
||||
attrSetBalance := utils.AttrSetBalance{
|
||||
Tenant: acntAttrs.Tenant, Account: acntAttrs.Account,
|
||||
BalanceType: utils.DATA,
|
||||
BalanceID: utils.StringPointer("TestSMGDataLastUsedMultipleData"),
|
||||
Value: utils.Float64Pointer(eAcntVal)}
|
||||
var reply string
|
||||
if err := smgRPC.Call("ApierV2.SetBalance", attrSetBalance, &reply); err != nil {
|
||||
t.Error(err)
|
||||
} else if reply != utils.OK {
|
||||
t.Errorf("Received: %s", reply)
|
||||
}
|
||||
if err := smgRPC.Call("ApierV2.GetAccount", acntAttrs, &acnt); err != nil {
|
||||
t.Error(err)
|
||||
} else if totalVal := acnt.BalanceMap[utils.DATA].GetTotalValue(); totalVal != eAcntVal {
|
||||
t.Errorf("Expected: %f, received: %f", eAcntVal, totalVal)
|
||||
}
|
||||
smgEv := map[string]interface{}{
|
||||
utils.EVENT_NAME: "TEST_EVENT",
|
||||
utils.ToR: utils.DATA,
|
||||
utils.OriginID: "123492",
|
||||
utils.Direction: utils.OUT,
|
||||
utils.Account: acntAttrs.Account,
|
||||
utils.Subject: acntAttrs.Account,
|
||||
utils.Destination: utils.DATA,
|
||||
utils.Category: "data",
|
||||
utils.Tenant: acntAttrs.Tenant,
|
||||
utils.RequestType: utils.META_PREPAID,
|
||||
utils.SetupTime: "2016-01-05 18:30:50",
|
||||
utils.AnswerTime: "2016-01-05 18:31:05",
|
||||
utils.Usage: "6144", // 6 MB
|
||||
}
|
||||
var maxUsage float64
|
||||
if err := smgRPC.Call("SMGenericV2.InitiateSession", smgEv, &maxUsage); err != nil {
|
||||
t.Error(err)
|
||||
}
|
||||
if maxUsage != 6144 {
|
||||
t.Error("Bad max usage: ", maxUsage)
|
||||
}
|
||||
eAcntVal = 96256 // 100-6
|
||||
if err := smgRPC.Call("ApierV2.GetAccount", acntAttrs, &acnt); err != nil {
|
||||
t.Error(err)
|
||||
} else if totalVal := acnt.BalanceMap[utils.DATA].GetTotalValue(); totalVal != eAcntVal {
|
||||
t.Errorf("Expected: %f, received: %f", eAcntVal, totalVal)
|
||||
}
|
||||
aSessions := make([]*ActiveSession, 0)
|
||||
if err := smgRPC.Call("SMGenericV1.GetActiveSessions", nil, &aSessions); err != nil {
|
||||
t.Error(err)
|
||||
} else if len(aSessions) != 1 ||
|
||||
aSessions[0].Usage != time.Duration(6144) {
|
||||
t.Errorf("wrong active sessions: %f", aSessions[0].Usage.Seconds())
|
||||
}
|
||||
smgEv = map[string]interface{}{
|
||||
utils.EVENT_NAME: "TEST_EVENT",
|
||||
utils.ToR: utils.DATA,
|
||||
utils.OriginID: "123492",
|
||||
utils.Direction: utils.OUT,
|
||||
utils.Account: acntAttrs.Account,
|
||||
utils.Subject: acntAttrs.Account,
|
||||
utils.Destination: utils.DATA,
|
||||
utils.Category: "data",
|
||||
utils.Tenant: acntAttrs.Tenant,
|
||||
utils.RequestType: utils.META_PREPAID,
|
||||
utils.SetupTime: "2016-01-05 18:30:50",
|
||||
utils.AnswerTime: "2016-01-05 18:31:05",
|
||||
utils.Usage: "8192", // 8 MB
|
||||
utils.LastUsed: "7168",
|
||||
}
|
||||
if err := smgRPC.Call("SMGenericV2.UpdateSession", smgEv, &maxUsage); err != nil {
|
||||
t.Error(err)
|
||||
}
|
||||
if maxUsage != 8192 {
|
||||
t.Error("Bad max usage: ", maxUsage)
|
||||
}
|
||||
eAcntVal = 87040.000000 // 15MB used
|
||||
if err := smgRPC.Call("ApierV2.GetAccount", acntAttrs, &acnt); err != nil {
|
||||
t.Error(err)
|
||||
} else if totalVal := acnt.BalanceMap[utils.DATA].GetTotalValue(); totalVal != eAcntVal {
|
||||
t.Errorf("Expected: %f, received: %f", eAcntVal, totalVal)
|
||||
}
|
||||
if err := smgRPC.Call("SMGenericV1.GetActiveSessions", nil, &aSessions); err != nil {
|
||||
t.Error(err)
|
||||
} else if len(aSessions) != 1 ||
|
||||
aSessions[0].Usage != time.Duration(15360) {
|
||||
t.Errorf("wrong active sessions: %v", aSessions[0].Usage)
|
||||
}
|
||||
smgEv = map[string]interface{}{
|
||||
utils.EVENT_NAME: "TEST_EVENT",
|
||||
utils.ToR: utils.DATA,
|
||||
utils.OriginID: "123492",
|
||||
utils.Direction: utils.OUT,
|
||||
utils.Account: acntAttrs.Account,
|
||||
utils.Subject: acntAttrs.Account,
|
||||
utils.Destination: utils.DATA,
|
||||
utils.Category: "data",
|
||||
utils.Tenant: acntAttrs.Tenant,
|
||||
utils.RequestType: utils.META_PREPAID,
|
||||
utils.SetupTime: "2016-01-05 18:30:50",
|
||||
utils.AnswerTime: "2016-01-05 18:31:05",
|
||||
utils.Usage: "1024", // 8 MB
|
||||
utils.LastUsed: "5120", // 5 MB
|
||||
}
|
||||
if err := smgRPC.Call("SMGenericV2.UpdateSession", smgEv, &maxUsage); err != nil {
|
||||
t.Error(err)
|
||||
}
|
||||
if maxUsage != 1024 {
|
||||
t.Error("Bad max usage: ", maxUsage)
|
||||
}
|
||||
eAcntVal = 87040.000000 // the amount is not modified and there will be 1024 extra left in SMG
|
||||
if err := smgRPC.Call("ApierV2.GetAccount", acntAttrs, &acnt); err != nil {
|
||||
t.Error(err)
|
||||
} else if totalVal := acnt.BalanceMap[utils.DATA].GetTotalValue(); totalVal != eAcntVal {
|
||||
t.Errorf("Expected: %f, received: %f", eAcntVal, totalVal)
|
||||
}
|
||||
if err := smgRPC.Call("SMGenericV1.GetActiveSessions", nil, &aSessions); err != nil {
|
||||
t.Error(err)
|
||||
} else if len(aSessions) != 1 ||
|
||||
aSessions[0].Usage != time.Duration(13312) { // 14MB in used, 2MB extra reserved
|
||||
t.Errorf("wrong active sessions: %+v", aSessions[0].Usage)
|
||||
}
|
||||
smgEv = map[string]interface{}{
|
||||
utils.EVENT_NAME: "TEST_EVENT",
|
||||
utils.ToR: utils.DATA,
|
||||
utils.OriginID: "123492",
|
||||
utils.Direction: utils.OUT,
|
||||
utils.Account: acntAttrs.Account,
|
||||
utils.Subject: acntAttrs.Account,
|
||||
utils.Destination: utils.DATA,
|
||||
utils.Category: "data",
|
||||
utils.Tenant: acntAttrs.Tenant,
|
||||
utils.RequestType: utils.META_PREPAID,
|
||||
utils.SetupTime: "2016-01-05 18:30:50",
|
||||
utils.AnswerTime: "2016-01-05 18:31:05",
|
||||
utils.Usage: "1024",
|
||||
}
|
||||
if err := smgRPC.Call("SMGenericV2.UpdateSession", smgEv, &maxUsage); err != nil {
|
||||
t.Error(err)
|
||||
}
|
||||
if maxUsage != 1024 {
|
||||
t.Error("Bad max usage: ", maxUsage)
|
||||
}
|
||||
eAcntVal = 87040.000000
|
||||
if err := smgRPC.Call("ApierV2.GetAccount", acntAttrs, &acnt); err != nil {
|
||||
t.Error(err)
|
||||
} else if totalVal := acnt.BalanceMap[utils.DATA].GetTotalValue(); totalVal != eAcntVal {
|
||||
t.Errorf("Expected: %f, received: %f", eAcntVal, totalVal)
|
||||
}
|
||||
if err := smgRPC.Call("SMGenericV1.GetActiveSessions", nil, &aSessions); err != nil {
|
||||
t.Error(err)
|
||||
} else if len(aSessions) != 1 ||
|
||||
aSessions[0].Usage != time.Duration(14336) { // 14MB in use
|
||||
t.Errorf("wrong active sessions: %v", aSessions[0].Usage)
|
||||
}
|
||||
smgEv = map[string]interface{}{
|
||||
utils.EVENT_NAME: "TEST_EVENT",
|
||||
utils.ToR: utils.DATA,
|
||||
utils.OriginID: "123492",
|
||||
utils.Direction: utils.OUT,
|
||||
utils.Account: acntAttrs.Account,
|
||||
utils.Subject: acntAttrs.Account,
|
||||
utils.Destination: utils.DATA,
|
||||
utils.Category: "data",
|
||||
utils.Tenant: acntAttrs.Tenant,
|
||||
utils.RequestType: utils.META_PREPAID,
|
||||
utils.SetupTime: "2016-01-05 18:30:50",
|
||||
utils.AnswerTime: "2016-01-05 18:31:05",
|
||||
utils.LastUsed: "0", // refund 1024 (extra used) + 1024 (extra reserved)
|
||||
}
|
||||
var rpl string
|
||||
if err := smgRPC.Call("SMGenericV1.TerminateSession", smgEv, &rpl); err != nil || rpl != utils.OK {
|
||||
t.Error(err)
|
||||
}
|
||||
eAcntVal = 89088.000000
|
||||
if err := smgRPC.Call("ApierV2.GetAccount", acntAttrs, &acnt); err != nil {
|
||||
t.Error(err)
|
||||
} else if totalVal := acnt.BalanceMap[utils.DATA].GetTotalValue(); totalVal != eAcntVal {
|
||||
t.Errorf("Expected: %f, received: %f", eAcntVal, totalVal)
|
||||
}
|
||||
if err := smgRPC.Call("SMGenericV1.GetActiveSessions",
|
||||
nil, &aSessions); err == nil || err.Error() != utils.ErrNotFound.Error() {
|
||||
t.Error(err, aSessions)
|
||||
}
|
||||
if err := smgRPC.Call("SMGenericV1.ProcessCDR", smgEv, &reply); err != nil {
|
||||
t.Error(err)
|
||||
} else if reply != utils.OK {
|
||||
t.Errorf("Received reply: %s", reply)
|
||||
}
|
||||
time.Sleep(time.Duration(20) * time.Millisecond)
|
||||
var cdrs []*engine.ExternalCDR
|
||||
req := utils.RPCCDRsFilter{RunIDs: []string{utils.META_DEFAULT},
|
||||
Accounts: []string{acntAttrs.Account}}
|
||||
if err := smgRPC.Call("ApierV2.GetCdrs", req, &cdrs); err != nil {
|
||||
t.Error("Unexpected error: ", err.Error())
|
||||
} else if len(cdrs) != 1 {
|
||||
t.Error("Unexpected number of CDRs returned: ", len(cdrs))
|
||||
} else {
|
||||
if cdrs[0].Usage != "13312" {
|
||||
t.Errorf("Unexpected CDR Usage received, cdr: %v %+v ", cdrs[0].Usage, cdrs[0])
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
func TestSMGDataTTLExpired(t *testing.T) {
|
||||
var acnt *engine.Account
|
||||
acntAttrs := &utils.AttrGetAccount{Tenant: "cgrates.org",
|
||||
Account: "TestSMGDataTTLExpired"}
|
||||
eAcntVal := 102400.0
|
||||
attrSetBalance := utils.AttrSetBalance{
|
||||
Tenant: acntAttrs.Tenant, Account: acntAttrs.Account,
|
||||
BalanceType: utils.DATA,
|
||||
BalanceID: utils.StringPointer("TestSMGDataTTLExpired"),
|
||||
Value: utils.Float64Pointer(eAcntVal)}
|
||||
var reply string
|
||||
if err := smgRPC.Call("ApierV2.SetBalance", attrSetBalance, &reply); err != nil {
|
||||
t.Error(err)
|
||||
} else if reply != utils.OK {
|
||||
t.Errorf("Received: %s", reply)
|
||||
}
|
||||
if err := smgRPC.Call("ApierV2.GetAccount", acntAttrs, &acnt); err != nil {
|
||||
t.Error(err)
|
||||
} else if totalVal := acnt.BalanceMap[utils.DATA].GetTotalValue(); totalVal != eAcntVal {
|
||||
t.Errorf("Expected: %f, received: %f", eAcntVal, totalVal)
|
||||
}
|
||||
smgEv := map[string]interface{}{
|
||||
utils.EVENT_NAME: "TEST_EVENT",
|
||||
utils.ToR: utils.DATA,
|
||||
utils.OriginID: "TestSMGDataTTLExpired",
|
||||
utils.Direction: utils.OUT,
|
||||
utils.Account: acntAttrs.Account,
|
||||
utils.Subject: acntAttrs.Account,
|
||||
utils.Destination: utils.DATA,
|
||||
utils.Category: "data",
|
||||
utils.Tenant: "cgrates.org",
|
||||
utils.RequestType: utils.META_PREPAID,
|
||||
utils.SetupTime: "2016-01-05 18:30:52",
|
||||
utils.AnswerTime: "2016-01-05 18:31:05",
|
||||
utils.Usage: "1024",
|
||||
utils.SessionTTLUsage: "2048", // will be charged on TTL
|
||||
}
|
||||
var maxUsage float64
|
||||
if err := smgRPC.Call("SMGenericV2.InitiateSession", smgEv, &maxUsage); err != nil {
|
||||
t.Error(err)
|
||||
}
|
||||
if maxUsage != 1024 {
|
||||
t.Error("Bad max usage: ", maxUsage)
|
||||
}
|
||||
eAcntVal = 101376.000000
|
||||
if err := smgRPC.Call("ApierV2.GetAccount", acntAttrs, &acnt); err != nil {
|
||||
t.Error(err)
|
||||
} else if dataVal := acnt.BalanceMap[utils.DATA].GetTotalValue(); dataVal != eAcntVal {
|
||||
t.Errorf("Expected: %f, received: %f", eAcntVal, dataVal)
|
||||
}
|
||||
time.Sleep(70 * time.Millisecond)
|
||||
eAcntVal = 99328.000000
|
||||
if err := smgRPC.Call("ApierV2.GetAccount", acntAttrs, &acnt); err != nil {
|
||||
t.Error(err)
|
||||
} else if dataVal := acnt.BalanceMap[utils.DATA].GetTotalValue(); dataVal != eAcntVal {
|
||||
t.Errorf("Expected: %f, received: %f", eAcntVal, dataVal)
|
||||
}
|
||||
}
|
||||
|
||||
func TestSMGDataTTLExpMultiUpdates(t *testing.T) {
|
||||
var acnt *engine.Account
|
||||
acntAttrs := &utils.AttrGetAccount{Tenant: "cgrates.org",
|
||||
Account: "TestSMGDataTTLExpMultiUpdates"}
|
||||
eAcntVal := 102400.0
|
||||
attrSetBalance := utils.AttrSetBalance{
|
||||
Tenant: acntAttrs.Tenant, Account: acntAttrs.Account,
|
||||
BalanceType: utils.DATA,
|
||||
BalanceID: utils.StringPointer("TestSMGDataTTLExpMultiUpdates"),
|
||||
Value: utils.Float64Pointer(eAcntVal)}
|
||||
var reply string
|
||||
if err := smgRPC.Call("ApierV2.SetBalance", attrSetBalance, &reply); err != nil {
|
||||
t.Error(err)
|
||||
} else if reply != utils.OK {
|
||||
t.Errorf("Received: %s", reply)
|
||||
}
|
||||
if err := smgRPC.Call("ApierV2.GetAccount", acntAttrs, &acnt); err != nil {
|
||||
t.Error(err)
|
||||
} else if totalVal := acnt.BalanceMap[utils.DATA].GetTotalValue(); totalVal != eAcntVal {
|
||||
t.Errorf("Expected: %f, received: %f", eAcntVal, totalVal)
|
||||
}
|
||||
smgEv := map[string]interface{}{
|
||||
utils.EVENT_NAME: "TEST_EVENT",
|
||||
utils.ToR: utils.DATA,
|
||||
utils.OriginID: "123495",
|
||||
utils.Direction: utils.OUT,
|
||||
utils.Account: acntAttrs.Account,
|
||||
utils.Subject: acntAttrs.Account,
|
||||
utils.Destination: utils.DATA,
|
||||
utils.Category: "data",
|
||||
utils.Tenant: "cgrates.org",
|
||||
utils.RequestType: utils.META_PREPAID,
|
||||
utils.SetupTime: "2016-01-05 18:30:53",
|
||||
utils.AnswerTime: "2016-01-05 18:31:05",
|
||||
utils.Usage: "4096", // 3MB
|
||||
}
|
||||
var maxUsage int64
|
||||
if err := smgRPC.Call("SMGenericV2.InitiateSession", smgEv, &maxUsage); err != nil {
|
||||
t.Error(err)
|
||||
}
|
||||
if maxUsage != 4096 {
|
||||
t.Error("Bad max usage: ", maxUsage)
|
||||
}
|
||||
eAcntVal = 98304.000000 //96MB
|
||||
if err := smgRPC.Call("ApierV2.GetAccount", acntAttrs, &acnt); err != nil {
|
||||
t.Error(err)
|
||||
} else if dataVal := acnt.BalanceMap[utils.DATA].GetTotalValue(); dataVal != eAcntVal {
|
||||
t.Errorf("Expected: %f, received: %f", eAcntVal, dataVal)
|
||||
}
|
||||
aSessions := make([]*ActiveSession, 0)
|
||||
if err := smgRPC.Call("SMGenericV1.GetActiveSessions", nil, &aSessions); err != nil {
|
||||
t.Error(err)
|
||||
} else if len(aSessions) != 1 ||
|
||||
int64(aSessions[0].Usage) != 4096 {
|
||||
t.Errorf("wrong active sessions: %d", int64(aSessions[0].Usage))
|
||||
}
|
||||
smgEv = map[string]interface{}{
|
||||
utils.EVENT_NAME: "TEST_EVENT",
|
||||
utils.ToR: utils.DATA,
|
||||
utils.OriginID: "123495",
|
||||
utils.Direction: utils.OUT,
|
||||
utils.Account: acntAttrs.Account,
|
||||
utils.Subject: acntAttrs.Account,
|
||||
utils.Destination: utils.DATA,
|
||||
utils.Category: "data",
|
||||
utils.Tenant: "cgrates.org",
|
||||
utils.RequestType: utils.META_PREPAID,
|
||||
utils.SetupTime: "2016-01-05 18:30:53",
|
||||
utils.AnswerTime: "2016-01-05 18:31:05",
|
||||
utils.LastUsed: "1024",
|
||||
utils.Usage: "4096",
|
||||
utils.SessionTTLUsage: "2048", // will be charged on TTL
|
||||
utils.SessionTTLLastUsed: "1024"} // will force last usage on timeout
|
||||
if err := smgRPC.Call("SMGenericV2.UpdateSession", smgEv, &maxUsage); err != nil {
|
||||
t.Error(err)
|
||||
}
|
||||
if maxUsage != 4096 {
|
||||
t.Error("Bad max usage: ", maxUsage)
|
||||
}
|
||||
eAcntVal = 97280.000000 // 20480
|
||||
if err := smgRPC.Call("ApierV2.GetAccount", acntAttrs, &acnt); err != nil {
|
||||
t.Error(err)
|
||||
} else if acnt.BalanceMap[utils.DATA].GetTotalValue() != eAcntVal {
|
||||
t.Errorf("Expected: %f, received: %f", eAcntVal, acnt.BalanceMap[utils.DATA].GetTotalValue())
|
||||
}
|
||||
time.Sleep(60 * time.Millisecond) // TTL will kick in
|
||||
eAcntVal = 98304.000000 // 1MB is returned
|
||||
if err := smgRPC.Call("ApierV2.GetAccount", acntAttrs, &acnt); err != nil {
|
||||
t.Error(err)
|
||||
} else if dataVal := acnt.BalanceMap[utils.DATA].GetTotalValue(); dataVal != eAcntVal {
|
||||
t.Errorf("Expected: %f, received: %f", eAcntVal, dataVal)
|
||||
}
|
||||
if err := smgRPC.Call("SMGenericV1.GetActiveSessions",
|
||||
nil, &aSessions); err == nil || err.Error() != utils.ErrNotFound.Error() {
|
||||
t.Error(err, aSessions)
|
||||
}
|
||||
}
|
||||
|
||||
func TestSMGDataMultipleDataNoUsage(t *testing.T) {
|
||||
var acnt *engine.Account
|
||||
acntAttrs := &utils.AttrGetAccount{Tenant: "cgrates.org",
|
||||
Account: "TestSMGDataTTLExpMultiUpdates"}
|
||||
eAcntVal := 102400.0
|
||||
attrSetBalance := utils.AttrSetBalance{
|
||||
Tenant: acntAttrs.Tenant, Account: acntAttrs.Account,
|
||||
BalanceType: utils.DATA,
|
||||
BalanceID: utils.StringPointer("TestSMGDataTTLExpMultiUpdates"),
|
||||
Value: utils.Float64Pointer(eAcntVal)}
|
||||
var reply string
|
||||
if err := smgRPC.Call("ApierV2.SetBalance", attrSetBalance, &reply); err != nil {
|
||||
t.Error(err)
|
||||
} else if reply != utils.OK {
|
||||
t.Errorf("Received: %s", reply)
|
||||
}
|
||||
if err := smgRPC.Call("ApierV2.GetAccount", acntAttrs, &acnt); err != nil {
|
||||
t.Error(err)
|
||||
} else if totalVal := acnt.BalanceMap[utils.DATA].GetTotalValue(); totalVal != eAcntVal {
|
||||
t.Errorf("Expected: %f, received: %f", eAcntVal, totalVal)
|
||||
}
|
||||
smgEv := map[string]interface{}{
|
||||
utils.EVENT_NAME: "TEST_EVENT",
|
||||
utils.ToR: utils.DATA,
|
||||
utils.OriginID: "123495",
|
||||
utils.Direction: utils.OUT,
|
||||
utils.Account: acntAttrs.Account,
|
||||
utils.Subject: acntAttrs.Account,
|
||||
utils.Destination: utils.DATA,
|
||||
utils.Category: "data",
|
||||
utils.Tenant: "cgrates.org",
|
||||
utils.RequestType: utils.META_PREPAID,
|
||||
utils.SetupTime: "2016-01-05 18:30:53",
|
||||
utils.AnswerTime: "2016-01-05 18:31:05",
|
||||
utils.Usage: "2048",
|
||||
}
|
||||
var maxUsage int64
|
||||
if err := smgRPC.Call("SMGenericV2.InitiateSession", smgEv, &maxUsage); err != nil {
|
||||
t.Error(err)
|
||||
}
|
||||
if maxUsage != 2048 {
|
||||
t.Error("Bad max usage: ", maxUsage)
|
||||
}
|
||||
eAcntVal = 100352.000000 // 1054720
|
||||
if err := smgRPC.Call("ApierV2.GetAccount", acntAttrs, &acnt); err != nil {
|
||||
t.Error(err)
|
||||
} else if dataVal := acnt.BalanceMap[utils.DATA].GetTotalValue(); dataVal != eAcntVal {
|
||||
t.Errorf("Expected: %f, received: %f", eAcntVal, dataVal)
|
||||
}
|
||||
aSessions := make([]*ActiveSession, 0)
|
||||
if err := smgRPC.Call("SMGenericV1.GetActiveSessions", nil, &aSessions); err != nil {
|
||||
t.Error(err)
|
||||
} else if len(aSessions) != 1 ||
|
||||
int64(aSessions[0].Usage) != 2048 {
|
||||
t.Errorf("wrong active sessions usage: %d", int64(aSessions[0].Usage))
|
||||
}
|
||||
smgEv = map[string]interface{}{
|
||||
utils.EVENT_NAME: "TEST_EVENT",
|
||||
utils.ToR: utils.DATA,
|
||||
utils.OriginID: "123495",
|
||||
utils.Direction: utils.OUT,
|
||||
utils.Account: acntAttrs.Account,
|
||||
utils.Subject: acntAttrs.Account,
|
||||
utils.Destination: utils.DATA,
|
||||
utils.Category: "data",
|
||||
utils.Tenant: "cgrates.org",
|
||||
utils.RequestType: utils.META_PREPAID,
|
||||
utils.SetupTime: "2016-01-05 18:30:53",
|
||||
utils.AnswerTime: "2016-01-05 18:31:05",
|
||||
utils.SessionTTL: "1h", // cancel timeout since usage 0 will not update it
|
||||
utils.Usage: "1024",
|
||||
utils.LastUsed: "1024",
|
||||
}
|
||||
if err := smgRPC.Call("SMGenericV2.UpdateSession", smgEv, &maxUsage); err != nil {
|
||||
t.Error(err)
|
||||
}
|
||||
if maxUsage != 1024 {
|
||||
t.Error("Bad max usage: ", maxUsage)
|
||||
}
|
||||
eAcntVal = 100352.000000
|
||||
if err := smgRPC.Call("ApierV2.GetAccount", acntAttrs, &acnt); err != nil {
|
||||
t.Error(err)
|
||||
} else if dataVal := acnt.BalanceMap[utils.DATA].GetTotalValue(); dataVal != eAcntVal {
|
||||
t.Errorf("Expected: %f, received: %f", eAcntVal, dataVal)
|
||||
}
|
||||
aSessions = make([]*ActiveSession, 0)
|
||||
if err := smgRPC.Call("SMGenericV1.GetActiveSessions", nil, &aSessions); err != nil {
|
||||
t.Error(err)
|
||||
} else if len(aSessions) != 1 ||
|
||||
int64(aSessions[0].Usage) != 2048 {
|
||||
t.Errorf("wrong active sessions usage: %d", int64(aSessions[0].Usage))
|
||||
}
|
||||
|
||||
smgEv = map[string]interface{}{
|
||||
utils.EVENT_NAME: "TEST_EVENT",
|
||||
utils.ToR: utils.DATA,
|
||||
utils.OriginID: "123495",
|
||||
utils.Direction: utils.OUT,
|
||||
utils.Account: acntAttrs.Account,
|
||||
utils.Subject: acntAttrs.Account,
|
||||
utils.Destination: utils.DATA,
|
||||
utils.Category: "data",
|
||||
utils.Tenant: "cgrates.org",
|
||||
utils.RequestType: utils.META_PREPAID,
|
||||
utils.SetupTime: "2016-01-05 18:30:53",
|
||||
utils.AnswerTime: "2016-01-05 18:31:05",
|
||||
utils.SessionTTL: "1h", // cancel timeout since usage 0 will not update it
|
||||
utils.Usage: "0",
|
||||
utils.LastUsed: "0",
|
||||
}
|
||||
if err := smgRPC.Call("SMGenericV2.UpdateSession", smgEv, &maxUsage); err != nil {
|
||||
t.Error(err)
|
||||
}
|
||||
if maxUsage != 0 {
|
||||
t.Error("Bad max usage: ", maxUsage)
|
||||
}
|
||||
eAcntVal = 100352.000000
|
||||
if err := smgRPC.Call("ApierV2.GetAccount", acntAttrs, &acnt); err != nil {
|
||||
t.Error(err)
|
||||
} else if dataVal := acnt.BalanceMap[utils.DATA].GetTotalValue(); dataVal != eAcntVal {
|
||||
t.Errorf("Expected: %f, received: %f", eAcntVal, dataVal)
|
||||
}
|
||||
aSessions = make([]*ActiveSession, 0)
|
||||
if err := smgRPC.Call("SMGenericV1.GetActiveSessions", nil, &aSessions); err != nil {
|
||||
t.Error(err)
|
||||
} else if len(aSessions) != 1 ||
|
||||
int64(aSessions[0].Usage) != 1024 {
|
||||
t.Errorf("wrong active sessions usage: %d", int64(aSessions[0].Usage))
|
||||
}
|
||||
smgEv = map[string]interface{}{
|
||||
utils.EVENT_NAME: "TEST_EVENT",
|
||||
utils.ToR: utils.DATA,
|
||||
utils.OriginID: "123495",
|
||||
utils.Direction: utils.OUT,
|
||||
utils.Account: acntAttrs.Account,
|
||||
utils.Subject: acntAttrs.Account,
|
||||
utils.Destination: utils.DATA,
|
||||
utils.Category: "data",
|
||||
utils.Tenant: "cgrates.org",
|
||||
utils.RequestType: utils.META_PREPAID,
|
||||
utils.SetupTime: "2016-01-05 18:30:53",
|
||||
utils.AnswerTime: "2016-01-05 18:31:05",
|
||||
utils.LastUsed: "0",
|
||||
}
|
||||
var rpl string
|
||||
if err := smgRPC.Call("SMGenericV1.TerminateSession",
|
||||
smgEv, &rpl); err != nil || rpl != utils.OK {
|
||||
t.Error(err)
|
||||
}
|
||||
eAcntVal = 101376.000000 // refunded last 1MB reserved and unused
|
||||
if err := smgRPC.Call("ApierV2.GetAccount", acntAttrs, &acnt); err != nil {
|
||||
t.Error(err)
|
||||
} else if acnt.BalanceMap[utils.DATA].GetTotalValue() != eAcntVal {
|
||||
t.Errorf("Expected: %f, received: %f",
|
||||
eAcntVal, acnt.BalanceMap[utils.DATA].GetTotalValue())
|
||||
}
|
||||
if err := smgRPC.Call("SMGenericV1.GetActiveSessions",
|
||||
nil, &aSessions); err == nil ||
|
||||
err.Error() != utils.ErrNotFound.Error() {
|
||||
t.Error(err, aSessions)
|
||||
}
|
||||
}
|
||||
|
||||
// TestSMGDataTTLUsageProtection makes sure that original TTL (50ms)
|
||||
// limits the additional debit without overloading memory
|
||||
func TestSMGDataTTLUsageProtection(t *testing.T) {
|
||||
var acnt *engine.Account
|
||||
acntAttrs := &utils.AttrGetAccount{Tenant: "cgrates.org",
|
||||
Account: "TestSMGDataTTLUsageProtection"}
|
||||
eAcntVal := 102400.0
|
||||
attrSetBalance := utils.AttrSetBalance{
|
||||
Tenant: acntAttrs.Tenant, Account: acntAttrs.Account,
|
||||
BalanceType: utils.DATA,
|
||||
BalanceID: utils.StringPointer("TestSMGDataTTLUsageProtection"),
|
||||
Value: utils.Float64Pointer(eAcntVal)}
|
||||
var reply string
|
||||
if err := smgRPC.Call("ApierV2.SetBalance", attrSetBalance, &reply); err != nil {
|
||||
t.Error(err)
|
||||
} else if reply != utils.OK {
|
||||
t.Errorf("Received: %s", reply)
|
||||
}
|
||||
if err := smgRPC.Call("ApierV2.GetAccount", acntAttrs, &acnt); err != nil {
|
||||
t.Error(err)
|
||||
} else if totalVal := acnt.BalanceMap[utils.DATA].GetTotalValue(); totalVal != eAcntVal {
|
||||
t.Errorf("Expected: %f, received: %f", eAcntVal, totalVal)
|
||||
}
|
||||
smgEv := map[string]interface{}{
|
||||
utils.EVENT_NAME: "TEST_EVENT",
|
||||
utils.ToR: utils.DATA,
|
||||
utils.OriginID: "123495",
|
||||
utils.Direction: utils.OUT,
|
||||
utils.Account: acntAttrs.Account,
|
||||
utils.Subject: acntAttrs.Account,
|
||||
utils.Destination: utils.DATA,
|
||||
utils.Category: "data",
|
||||
utils.Tenant: "cgrates.org",
|
||||
utils.RequestType: utils.META_PREPAID,
|
||||
utils.SetupTime: "2016-01-05 18:30:53",
|
||||
utils.AnswerTime: "2016-01-05 18:31:05",
|
||||
utils.Usage: "2048",
|
||||
}
|
||||
var maxUsage int64
|
||||
if err := smgRPC.Call("SMGenericV2.InitiateSession", smgEv, &maxUsage); err != nil {
|
||||
t.Error(err)
|
||||
}
|
||||
if maxUsage != 2048 {
|
||||
t.Error("Bad max usage: ", maxUsage)
|
||||
}
|
||||
eAcntVal = 100352.000000 // 1054720
|
||||
if err := smgRPC.Call("ApierV2.GetAccount", acntAttrs, &acnt); err != nil {
|
||||
t.Error(err)
|
||||
} else if dataVal := acnt.BalanceMap[utils.DATA].GetTotalValue(); dataVal != eAcntVal {
|
||||
t.Errorf("Expected: %f, received: %f", eAcntVal, dataVal)
|
||||
}
|
||||
aSessions := make([]*ActiveSession, 0)
|
||||
if err := smgRPC.Call("SMGenericV1.GetActiveSessions", nil, &aSessions); err != nil {
|
||||
t.Error(err)
|
||||
} else if len(aSessions) != 1 ||
|
||||
int64(aSessions[0].Usage) != 2048 {
|
||||
t.Errorf("wrong active sessions usage: %d", int64(aSessions[0].Usage))
|
||||
}
|
||||
time.Sleep(60 * time.Millisecond)
|
||||
if err := smgRPC.Call("SMGenericV1.GetActiveSessions",
|
||||
nil, &aSessions); err == nil || err.Error() != utils.ErrNotFound.Error() {
|
||||
t.Error(err, aSessions)
|
||||
}
|
||||
}
|
||||
|
||||
func TestSMGDataTTKillEngine(t *testing.T) {
|
||||
if err := engine.KillEngine(100); err != nil {
|
||||
t.Error(err)
|
||||
}
|
||||
}
|
||||
@@ -362,9 +362,8 @@ func (sS *SessionS) setSTerminator(s *Session) {
|
||||
// forceSTerminate is called when a session times-out or it is forced from CGRateS side
|
||||
func (sS *SessionS) forceSTerminate(s *Session, extraDebit time.Duration, lastUsed *time.Duration) (err error) {
|
||||
if extraDebit != 0 {
|
||||
|
||||
for i := range s.SRuns {
|
||||
if _, err = sS.debitSession(s, i, extraDebit, nil); err != nil {
|
||||
if _, err = sS.debitSession(s, i, extraDebit, lastUsed); err != nil {
|
||||
utils.Logger.Warning(
|
||||
fmt.Sprintf(
|
||||
"<%s> failed debitting cgrID %s, sRunIdx: %d, err: %s",
|
||||
@@ -372,6 +371,7 @@ func (sS *SessionS) forceSTerminate(s *Session, extraDebit time.Duration, lastUs
|
||||
}
|
||||
}
|
||||
}
|
||||
//we apply the correction before
|
||||
if err = sS.endSession(s, nil, nil); err != nil {
|
||||
utils.Logger.Warning(
|
||||
fmt.Sprintf(
|
||||
@@ -712,7 +712,6 @@ func (sS *SessionS) registerSession(s *Session, passive bool) {
|
||||
// uregisterSession will unregister an active or passive session based on it's CGRID
|
||||
// called on session terminate or relocate
|
||||
func (sS *SessionS) unregisterSession(cgrID string, passive bool) bool {
|
||||
fmt.Println("entering in unregisterSession ")
|
||||
sMux := &sS.aSsMux
|
||||
sMp := sS.aSessions
|
||||
if passive {
|
||||
@@ -2054,7 +2053,6 @@ func (sS *SessionS) BiRPCv1UpdateSession(clnt rpcclient.RpcClientConnection,
|
||||
} else {
|
||||
s = ss[0]
|
||||
}
|
||||
|
||||
if maxUsage, err := sS.updateSession(s, ev.AsMapInterface()); err != nil {
|
||||
return utils.NewErrRALs(err)
|
||||
} else {
|
||||
|
||||
984
sessions/sessions_data_it_test.go
Normal file
984
sessions/sessions_data_it_test.go
Normal file
@@ -0,0 +1,984 @@
|
||||
// +build integration
|
||||
|
||||
/*
|
||||
Real-time Online/Offline Charging System (OCS) for Telecom & ISP environments
|
||||
Copyright (C) ITsysCOM GmbH
|
||||
|
||||
This program is free software: you can redistribute it and/or modify
|
||||
it under the terms of the GNU General Public License as published by
|
||||
the Free Software Foundation, either version 3 of the License, or
|
||||
(at your option) any later version.
|
||||
|
||||
This program is distributed in the hope that it will be useful,
|
||||
but WITHOUT ANY WARRANTY; without even the implied warranty of
|
||||
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
||||
GNU General Public License for more details.
|
||||
|
||||
You should have received a copy of the GNU General Public License
|
||||
along with this program. If not, see <http://www.gnu.org/licenses/>
|
||||
*/
|
||||
package sessions
|
||||
|
||||
import (
|
||||
"net/rpc"
|
||||
"net/rpc/jsonrpc"
|
||||
"path"
|
||||
"testing"
|
||||
"time"
|
||||
|
||||
"github.com/cgrates/cgrates/config"
|
||||
"github.com/cgrates/cgrates/engine"
|
||||
"github.com/cgrates/cgrates/utils"
|
||||
)
|
||||
|
||||
var dataCfgPath string
|
||||
var dataCfg *config.CGRConfig
|
||||
var sDataRPC *rpc.Client
|
||||
|
||||
func TestSessionsDataInitCfg(t *testing.T) {
|
||||
dataCfgPath = path.Join(*dataDir, "conf", "samples", "smg")
|
||||
// Init config first
|
||||
var err error
|
||||
dataCfg, err = config.NewCGRConfigFromFolder(dataCfgPath)
|
||||
if err != nil {
|
||||
t.Error(err)
|
||||
}
|
||||
dataCfg.DataFolderPath = *dataDir // Share DataFolderPath through config towards StoreDb for Flush()
|
||||
config.SetCgrConfig(dataCfg)
|
||||
}
|
||||
|
||||
// Remove data in both rating and accounting db
|
||||
func TestSessionsDataResetDataDb(t *testing.T) {
|
||||
if err := engine.InitDataDb(dataCfg); err != nil {
|
||||
t.Fatal(err)
|
||||
}
|
||||
}
|
||||
|
||||
// Wipe out the cdr database
|
||||
func TestSessionsDataResetStorDb(t *testing.T) {
|
||||
if err := engine.InitStorDb(dataCfg); err != nil {
|
||||
t.Fatal(err)
|
||||
}
|
||||
}
|
||||
|
||||
// Start CGR Engine
|
||||
func TestSessionsDataStartEngine(t *testing.T) {
|
||||
if _, err := engine.StopStartEngine(dataCfgPath, *waitRater); err != nil {
|
||||
t.Fatal(err)
|
||||
}
|
||||
}
|
||||
|
||||
// Connect rpc client to rater
|
||||
func TestSessionsDataApierRpcConn(t *testing.T) {
|
||||
var err error
|
||||
sDataRPC, err = jsonrpc.Dial("tcp", dataCfg.ListenCfg().RPCJSONListen) // We connect over JSON so we can also troubleshoot if needed
|
||||
if err != nil {
|
||||
t.Fatal(err)
|
||||
}
|
||||
|
||||
//add a default charger
|
||||
chargerProfile := &engine.ChargerProfile{
|
||||
Tenant: "cgrates.org",
|
||||
ID: "Default",
|
||||
RunID: "*default",
|
||||
AttributeIDs: []string{"*none"},
|
||||
Weight: 20,
|
||||
}
|
||||
var result string
|
||||
if err := sDataRPC.Call("ApierV1.SetChargerProfile", chargerProfile, &result); err != nil {
|
||||
t.Error(err)
|
||||
} else if result != utils.OK {
|
||||
t.Error("Unexpected reply returned", result)
|
||||
}
|
||||
}
|
||||
|
||||
// Load the tariff plan, creating accounts and their balances
|
||||
func TestSessionsDataTPFromFolder(t *testing.T) {
|
||||
attrs := &utils.AttrLoadTpFromFolder{FolderPath: path.Join(*dataDir, "tariffplans", "oldtutorial")}
|
||||
var loadInst utils.LoadInstance
|
||||
if err := sDataRPC.Call("ApierV2.LoadTariffPlanFromFolder", attrs, &loadInst); err != nil {
|
||||
t.Error(err)
|
||||
}
|
||||
time.Sleep(time.Duration(*waitRater) * time.Millisecond) // Give time for scheduler to execute topups
|
||||
}
|
||||
|
||||
func TestSessionsDataLastUsedData(t *testing.T) {
|
||||
var acnt *engine.Account
|
||||
attrs := &utils.AttrGetAccount{Tenant: "cgrates.org", Account: "1001"}
|
||||
eAcntVal := 102400.0
|
||||
if err := sDataRPC.Call("ApierV2.GetAccount", attrs, &acnt); err != nil {
|
||||
t.Error(err)
|
||||
} else if acnt.BalanceMap[utils.DATA].GetTotalValue() != eAcntVal {
|
||||
t.Errorf("Expected: %f, received: %f",
|
||||
eAcntVal, acnt.BalanceMap[utils.DATA].GetTotalValue())
|
||||
}
|
||||
tStart, _ := utils.ParseTimeDetectLayout("2016-01-05T18:31:05Z", "")
|
||||
cd := engine.CallDescriptor{
|
||||
Direction: "*out",
|
||||
Category: "data",
|
||||
Tenant: "cgrates.org",
|
||||
Subject: "1001",
|
||||
Account: "1001",
|
||||
Destination: utils.DATA,
|
||||
TimeStart: tStart,
|
||||
TimeEnd: tStart.Add(time.Duration(1024)),
|
||||
}
|
||||
var cc engine.CallCost
|
||||
// Make sure the cost is what we expect to be for 1MB of data
|
||||
if err := sDataRPC.Call("Responder.GetCost", cd, &cc); err != nil {
|
||||
t.Error("Got error on Responder.GetCost: ", err.Error())
|
||||
} else if cc.Cost != 1024 {
|
||||
t.Errorf("Calling Responder.GetCost got callcost: %v", cc.Cost)
|
||||
}
|
||||
|
||||
usage := int64(5120)
|
||||
initArgs := &V1InitSessionArgs{
|
||||
InitSession: true,
|
||||
CGREvent: utils.CGREvent{
|
||||
Tenant: "cgrates.org",
|
||||
ID: "TestSessionsDataLastUsedData",
|
||||
Event: map[string]interface{}{
|
||||
utils.EVENT_NAME: "TEST_EVENT",
|
||||
utils.ToR: utils.DATA,
|
||||
utils.OriginID: "123491",
|
||||
utils.Account: "1001",
|
||||
utils.Subject: "1001",
|
||||
utils.Destination: utils.DATA,
|
||||
utils.Category: "data",
|
||||
utils.Tenant: "cgrates.org",
|
||||
utils.RequestType: utils.META_PREPAID,
|
||||
utils.SetupTime: time.Date(2016, time.January, 5, 18, 30, 59, 0, time.UTC),
|
||||
utils.AnswerTime: time.Date(2016, time.January, 5, 18, 31, 05, 0, time.UTC),
|
||||
utils.Usage: "5120", // 5MB
|
||||
},
|
||||
},
|
||||
}
|
||||
|
||||
var initRpl *V1InitSessionReply
|
||||
if err := sDataRPC.Call(utils.SessionSv1InitiateSession,
|
||||
initArgs, &initRpl); err != nil {
|
||||
t.Error(err)
|
||||
}
|
||||
if (*initRpl.MaxUsage).Nanoseconds() != usage {
|
||||
t.Errorf("Expecting : %+v, received: %+v", usage, (*initRpl.MaxUsage).Nanoseconds())
|
||||
}
|
||||
|
||||
eAcntVal = 97280.0 // 100 -5
|
||||
if err := sDataRPC.Call("ApierV2.GetAccount", attrs, &acnt); err != nil {
|
||||
t.Error(err)
|
||||
} else if acnt.BalanceMap[utils.DATA].GetTotalValue() != eAcntVal {
|
||||
t.Errorf("Expected: %f, received: %f",
|
||||
eAcntVal, acnt.BalanceMap[utils.DATA].GetTotalValue())
|
||||
}
|
||||
|
||||
updateArgs := &V1UpdateSessionArgs{
|
||||
UpdateSession: true,
|
||||
CGREvent: utils.CGREvent{
|
||||
Tenant: "cgrates.org",
|
||||
ID: "TestSessionsDataLastUsedData",
|
||||
Event: map[string]interface{}{
|
||||
utils.EVENT_NAME: "TEST_EVENT",
|
||||
utils.ToR: utils.DATA,
|
||||
utils.OriginID: "123491",
|
||||
utils.Account: "1001",
|
||||
utils.Subject: "1001",
|
||||
utils.Destination: utils.DATA,
|
||||
utils.Category: "data",
|
||||
utils.Tenant: "cgrates.org",
|
||||
utils.RequestType: utils.META_PREPAID,
|
||||
utils.SetupTime: time.Date(2016, time.January, 5, 18, 30, 59, 0, time.UTC),
|
||||
utils.AnswerTime: time.Date(2016, time.January, 5, 18, 31, 05, 0, time.UTC),
|
||||
utils.Usage: "5120",
|
||||
utils.LastUsed: "4096",
|
||||
},
|
||||
},
|
||||
}
|
||||
|
||||
var updateRpl *V1UpdateSessionReply
|
||||
if err := sDataRPC.Call(utils.SessionSv1UpdateSession, updateArgs, &updateRpl); err != nil {
|
||||
t.Error(err)
|
||||
}
|
||||
if (*updateRpl.MaxUsage).Nanoseconds() != usage {
|
||||
t.Errorf("Expected: %+v, received: %+v", usage, (*updateRpl.MaxUsage).Nanoseconds())
|
||||
}
|
||||
|
||||
eAcntVal = 93184.0 // 100-9
|
||||
if err := sDataRPC.Call("ApierV2.GetAccount", attrs, &acnt); err != nil {
|
||||
t.Error(err)
|
||||
} else if acnt.BalanceMap[utils.DATA].GetTotalValue() != eAcntVal {
|
||||
t.Errorf("Expected: %f, received: %f", eAcntVal, acnt.BalanceMap[utils.DATA].GetTotalValue())
|
||||
}
|
||||
|
||||
termArgs := &V1TerminateSessionArgs{
|
||||
TerminateSession: true,
|
||||
CGREvent: utils.CGREvent{
|
||||
Tenant: "cgrates.org",
|
||||
ID: "TestSessionsDataLastUsedData",
|
||||
Event: map[string]interface{}{
|
||||
utils.EVENT_NAME: "TEST_EVENT",
|
||||
utils.ToR: utils.DATA,
|
||||
utils.OriginID: "123491",
|
||||
utils.Account: "1001",
|
||||
utils.Subject: "1001",
|
||||
utils.Destination: utils.DATA,
|
||||
utils.Category: "data",
|
||||
utils.Tenant: "cgrates.org",
|
||||
utils.RequestType: utils.META_PREPAID,
|
||||
utils.SetupTime: time.Date(2016, time.January, 5, 18, 30, 49, 0, time.UTC),
|
||||
utils.AnswerTime: time.Date(2016, time.January, 5, 18, 31, 05, 0, time.UTC),
|
||||
utils.LastUsed: "0",
|
||||
},
|
||||
},
|
||||
}
|
||||
|
||||
var rpl string
|
||||
if err := sDataRPC.Call(utils.SessionSv1TerminateSession, termArgs, &rpl); err != nil || rpl != utils.OK {
|
||||
t.Error(err)
|
||||
}
|
||||
eAcntVal = 98304.0 //100-4
|
||||
if err := sDataRPC.Call("ApierV2.GetAccount", attrs, &acnt); err != nil {
|
||||
t.Error(err)
|
||||
} else if acnt.BalanceMap[utils.DATA].GetTotalValue() != eAcntVal {
|
||||
t.Errorf("Expected: %f, received: %f",
|
||||
eAcntVal, acnt.BalanceMap[utils.DATA].GetTotalValue())
|
||||
}
|
||||
}
|
||||
|
||||
func TestSessionsDataLastUsedMultipleUpdates(t *testing.T) {
|
||||
var acnt *engine.Account
|
||||
acntAttrs := &utils.AttrGetAccount{Tenant: "cgrates.org",
|
||||
Account: "TestSessionsDataLastUsedMultipleData"}
|
||||
eAcntVal := 102400.0
|
||||
attrSetBalance := utils.AttrSetBalance{
|
||||
Tenant: acntAttrs.Tenant, Account: acntAttrs.Account,
|
||||
BalanceType: utils.DATA,
|
||||
BalanceID: utils.StringPointer("TestSessionsDataLastUsedMultipleData"),
|
||||
Value: utils.Float64Pointer(eAcntVal)}
|
||||
var reply string
|
||||
if err := sDataRPC.Call("ApierV2.SetBalance", attrSetBalance, &reply); err != nil {
|
||||
t.Error(err)
|
||||
} else if reply != utils.OK {
|
||||
t.Errorf("Received: %s", reply)
|
||||
}
|
||||
if err := sDataRPC.Call("ApierV2.GetAccount", acntAttrs, &acnt); err != nil {
|
||||
t.Error(err)
|
||||
} else if totalVal := acnt.BalanceMap[utils.DATA].GetTotalValue(); totalVal != eAcntVal {
|
||||
t.Errorf("Expected: %f, received: %f", eAcntVal, totalVal)
|
||||
}
|
||||
|
||||
usage := int64(6144)
|
||||
initArgs := &V1InitSessionArgs{
|
||||
InitSession: true,
|
||||
CGREvent: utils.CGREvent{
|
||||
Tenant: "cgrates.org",
|
||||
ID: "TestSessionsDataLastUsedMultipleUpdates",
|
||||
Event: map[string]interface{}{
|
||||
utils.EVENT_NAME: "TEST_EVENT",
|
||||
utils.ToR: utils.DATA,
|
||||
utils.OriginID: "123492",
|
||||
utils.Account: acntAttrs.Account,
|
||||
utils.Subject: acntAttrs.Account,
|
||||
utils.Destination: utils.DATA,
|
||||
utils.Category: "data",
|
||||
utils.Tenant: acntAttrs.Tenant,
|
||||
utils.RequestType: utils.META_PREPAID,
|
||||
utils.SetupTime: time.Date(2016, time.January, 5, 18, 30, 59, 0, time.UTC),
|
||||
utils.AnswerTime: time.Date(2016, time.January, 5, 18, 31, 05, 0, time.UTC),
|
||||
utils.Usage: "6144", // 5MB
|
||||
},
|
||||
},
|
||||
}
|
||||
|
||||
var initRpl *V1InitSessionReply
|
||||
if err := sDataRPC.Call(utils.SessionSv1InitiateSession,
|
||||
initArgs, &initRpl); err != nil {
|
||||
t.Error(err)
|
||||
}
|
||||
if (*initRpl.MaxUsage).Nanoseconds() != usage {
|
||||
t.Errorf("Expecting : %+v, received: %+v", usage, (*initRpl.MaxUsage).Nanoseconds())
|
||||
}
|
||||
|
||||
eAcntVal = 96256 // 100-6
|
||||
if err := sDataRPC.Call("ApierV2.GetAccount", acntAttrs, &acnt); err != nil {
|
||||
t.Error(err)
|
||||
} else if totalVal := acnt.BalanceMap[utils.DATA].GetTotalValue(); totalVal != eAcntVal {
|
||||
t.Errorf("Expected: %f, received: %f", eAcntVal, totalVal)
|
||||
}
|
||||
aSessions := make([]*ActiveSession, 0)
|
||||
if err := sDataRPC.Call(utils.SessionSv1GetActiveSessions, nil, &aSessions); err != nil {
|
||||
t.Error(err)
|
||||
} else if len(aSessions) != 1 ||
|
||||
aSessions[0].Usage != time.Duration(6144) {
|
||||
t.Errorf("wrong active sessions: %f", aSessions[0].Usage.Seconds())
|
||||
}
|
||||
|
||||
usage = int64(8192)
|
||||
updateArgs := &V1UpdateSessionArgs{
|
||||
UpdateSession: true,
|
||||
CGREvent: utils.CGREvent{
|
||||
Tenant: "cgrates.org",
|
||||
ID: "TestSessionsDataLastUsedMultipleUpdates",
|
||||
Event: map[string]interface{}{
|
||||
utils.EVENT_NAME: "TEST_EVENT",
|
||||
utils.ToR: utils.DATA,
|
||||
utils.OriginID: "123492",
|
||||
utils.Account: acntAttrs.Account,
|
||||
utils.Subject: acntAttrs.Account,
|
||||
utils.Destination: utils.DATA,
|
||||
utils.Category: "data",
|
||||
utils.Tenant: acntAttrs.Tenant,
|
||||
utils.RequestType: utils.META_PREPAID,
|
||||
utils.SetupTime: time.Date(2016, time.January, 5, 18, 30, 59, 0, time.UTC),
|
||||
utils.AnswerTime: time.Date(2016, time.January, 5, 18, 31, 05, 0, time.UTC),
|
||||
utils.Usage: "8192", // 8 MB
|
||||
utils.LastUsed: "7168",
|
||||
},
|
||||
},
|
||||
}
|
||||
|
||||
var updateRpl *V1UpdateSessionReply
|
||||
if err := sDataRPC.Call(utils.SessionSv1UpdateSession, updateArgs, &updateRpl); err != nil {
|
||||
t.Error(err)
|
||||
}
|
||||
if (*updateRpl.MaxUsage).Nanoseconds() != usage {
|
||||
t.Errorf("Expected: %+v, received: %+v", usage, (*updateRpl.MaxUsage).Nanoseconds())
|
||||
}
|
||||
|
||||
eAcntVal = 87040.000000 // 15MB used
|
||||
if err := sDataRPC.Call("ApierV2.GetAccount", acntAttrs, &acnt); err != nil {
|
||||
t.Error(err)
|
||||
} else if totalVal := acnt.BalanceMap[utils.DATA].GetTotalValue(); totalVal != eAcntVal {
|
||||
t.Errorf("Expected: %f, received: %f", eAcntVal, totalVal)
|
||||
}
|
||||
if err := sDataRPC.Call(utils.SessionSv1GetActiveSessions, nil, &aSessions); err != nil {
|
||||
t.Error(err)
|
||||
} else if len(aSessions) != 1 ||
|
||||
aSessions[0].Usage != time.Duration(15360) {
|
||||
t.Errorf("wrong active sessions: %v", aSessions[0].Usage)
|
||||
}
|
||||
|
||||
usage = int64(1024)
|
||||
updateArgs = &V1UpdateSessionArgs{
|
||||
UpdateSession: true,
|
||||
CGREvent: utils.CGREvent{
|
||||
Tenant: "cgrates.org",
|
||||
ID: "TestSessionsDataLastUsedMultipleUpdates",
|
||||
Event: map[string]interface{}{
|
||||
utils.EVENT_NAME: "TEST_EVENT",
|
||||
utils.ToR: utils.DATA,
|
||||
utils.OriginID: "123492",
|
||||
utils.Account: acntAttrs.Account,
|
||||
utils.Subject: acntAttrs.Account,
|
||||
utils.Destination: utils.DATA,
|
||||
utils.Category: "data",
|
||||
utils.Tenant: acntAttrs.Tenant,
|
||||
utils.RequestType: utils.META_PREPAID,
|
||||
utils.SetupTime: time.Date(2016, time.January, 5, 18, 30, 59, 0, time.UTC),
|
||||
utils.AnswerTime: time.Date(2016, time.January, 5, 18, 31, 05, 0, time.UTC),
|
||||
utils.Usage: "1024", // 8 MB
|
||||
utils.LastUsed: "5120", // 5 MB
|
||||
},
|
||||
},
|
||||
}
|
||||
|
||||
if err := sDataRPC.Call(utils.SessionSv1UpdateSession, updateArgs, &updateRpl); err != nil {
|
||||
t.Error(err)
|
||||
}
|
||||
if (*updateRpl.MaxUsage).Nanoseconds() != usage {
|
||||
t.Errorf("Expected: %+v, received: %+v", usage, (*updateRpl.MaxUsage).Nanoseconds())
|
||||
}
|
||||
|
||||
eAcntVal = 87040.000000 // the amount is not modified and there will be 1024 extra left in SMG
|
||||
if err := sDataRPC.Call("ApierV2.GetAccount", acntAttrs, &acnt); err != nil {
|
||||
t.Error(err)
|
||||
} else if totalVal := acnt.BalanceMap[utils.DATA].GetTotalValue(); totalVal != eAcntVal {
|
||||
t.Errorf("Expected: %f, received: %f", eAcntVal, totalVal)
|
||||
}
|
||||
if err := sDataRPC.Call(utils.SessionSv1GetActiveSessions, nil, &aSessions); err != nil {
|
||||
t.Error(err)
|
||||
} else if len(aSessions) != 1 ||
|
||||
aSessions[0].Usage != time.Duration(13312) { // 14MB in used, 2MB extra reserved
|
||||
t.Errorf("wrong active sessions: %+v", aSessions[0].Usage)
|
||||
}
|
||||
|
||||
usage = int64(1024)
|
||||
updateArgs = &V1UpdateSessionArgs{
|
||||
UpdateSession: true,
|
||||
CGREvent: utils.CGREvent{
|
||||
Tenant: "cgrates.org",
|
||||
ID: "TestSessionsDataLastUsedMultipleUpdates",
|
||||
Event: map[string]interface{}{
|
||||
utils.EVENT_NAME: "TEST_EVENT",
|
||||
utils.ToR: utils.DATA,
|
||||
utils.OriginID: "123492",
|
||||
utils.Account: acntAttrs.Account,
|
||||
utils.Subject: acntAttrs.Account,
|
||||
utils.Destination: utils.DATA,
|
||||
utils.Category: "data",
|
||||
utils.Tenant: acntAttrs.Tenant,
|
||||
utils.RequestType: utils.META_PREPAID,
|
||||
utils.SetupTime: time.Date(2016, time.January, 5, 18, 30, 59, 0, time.UTC),
|
||||
utils.AnswerTime: time.Date(2016, time.January, 5, 18, 31, 05, 0, time.UTC),
|
||||
utils.Usage: "1024", // 8 MB
|
||||
},
|
||||
},
|
||||
}
|
||||
|
||||
if err := sDataRPC.Call(utils.SessionSv1UpdateSession, updateArgs, &updateRpl); err != nil {
|
||||
t.Error(err)
|
||||
}
|
||||
if (*updateRpl.MaxUsage).Nanoseconds() != usage {
|
||||
t.Errorf("Expected: %+v, received: %+v", usage, (*updateRpl.MaxUsage).Nanoseconds())
|
||||
}
|
||||
|
||||
eAcntVal = 87040.000000
|
||||
if err := sDataRPC.Call("ApierV2.GetAccount", acntAttrs, &acnt); err != nil {
|
||||
t.Error(err)
|
||||
} else if totalVal := acnt.BalanceMap[utils.DATA].GetTotalValue(); totalVal != eAcntVal {
|
||||
t.Errorf("Expected: %f, received: %f", eAcntVal, totalVal)
|
||||
}
|
||||
if err := sDataRPC.Call(utils.SessionSv1GetActiveSessions, nil, &aSessions); err != nil {
|
||||
t.Error(err)
|
||||
} else if len(aSessions) != 1 ||
|
||||
aSessions[0].Usage != time.Duration(14336) { // 14MB in use
|
||||
t.Errorf("wrong active sessions: %v", aSessions[0].Usage)
|
||||
}
|
||||
|
||||
termArgs := &V1TerminateSessionArgs{
|
||||
TerminateSession: true,
|
||||
CGREvent: utils.CGREvent{
|
||||
Tenant: "cgrates.org",
|
||||
ID: "TestSessionsDataLastUsedMultipleUpdates",
|
||||
Event: map[string]interface{}{
|
||||
utils.EVENT_NAME: "TEST_EVENT",
|
||||
utils.ToR: utils.DATA,
|
||||
utils.OriginID: "123492",
|
||||
utils.Account: acntAttrs.Account,
|
||||
utils.Subject: acntAttrs.Account,
|
||||
utils.Destination: utils.DATA,
|
||||
utils.Category: "data",
|
||||
utils.Tenant: acntAttrs.Tenant,
|
||||
utils.RequestType: utils.META_PREPAID,
|
||||
utils.SetupTime: time.Date(2016, time.January, 5, 18, 30, 49, 0, time.UTC),
|
||||
utils.AnswerTime: time.Date(2016, time.January, 5, 18, 31, 05, 0, time.UTC),
|
||||
utils.LastUsed: "0", // refund 1024 (extra used) + 1024 (extra reserved)
|
||||
},
|
||||
},
|
||||
}
|
||||
|
||||
var rpl string
|
||||
if err := sDataRPC.Call(utils.SessionSv1TerminateSession, termArgs, &rpl); err != nil || rpl != utils.OK {
|
||||
t.Error(err)
|
||||
}
|
||||
|
||||
eAcntVal = 89088.000000
|
||||
if err := sDataRPC.Call("ApierV2.GetAccount", acntAttrs, &acnt); err != nil {
|
||||
t.Error(err)
|
||||
} else if totalVal := acnt.BalanceMap[utils.DATA].GetTotalValue(); totalVal != eAcntVal {
|
||||
t.Errorf("Expected: %f, received: %f", eAcntVal, totalVal)
|
||||
}
|
||||
if err := sDataRPC.Call(utils.SessionSv1GetActiveSessions,
|
||||
nil, &aSessions); err == nil || err.Error() != utils.ErrNotFound.Error() {
|
||||
t.Error(err, aSessions)
|
||||
}
|
||||
if err := sDataRPC.Call(utils.SessionSv1ProcessCDR, termArgs.CGREvent, &reply); err != nil {
|
||||
t.Error(err)
|
||||
} else if reply != utils.OK {
|
||||
t.Errorf("Received reply: %s", reply)
|
||||
}
|
||||
|
||||
time.Sleep(time.Duration(20) * time.Millisecond)
|
||||
|
||||
var cdrs []*engine.ExternalCDR
|
||||
req := utils.RPCCDRsFilter{RunIDs: []string{utils.META_DEFAULT},
|
||||
Accounts: []string{acntAttrs.Account}}
|
||||
if err := sDataRPC.Call("ApierV2.GetCdrs", req, &cdrs); err != nil {
|
||||
t.Error("Unexpected error: ", err.Error())
|
||||
} else if len(cdrs) != 1 {
|
||||
t.Error("Unexpected number of CDRs returned: ", len(cdrs))
|
||||
} else {
|
||||
if cdrs[0].Usage != "13312" {
|
||||
t.Errorf("Unexpected CDR Usage received, cdr: %v %+v ", cdrs[0].Usage, cdrs[0])
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
func TestSessionsDataTTLExpired(t *testing.T) {
|
||||
var acnt *engine.Account
|
||||
acntAttrs := &utils.AttrGetAccount{Tenant: "cgrates.org",
|
||||
Account: "TestSessionsDataTTLExpired"}
|
||||
eAcntVal := 102400.0
|
||||
attrSetBalance := utils.AttrSetBalance{
|
||||
Tenant: acntAttrs.Tenant, Account: acntAttrs.Account,
|
||||
BalanceType: utils.DATA,
|
||||
BalanceID: utils.StringPointer("TestSessionsDataTTLExpired"),
|
||||
Value: utils.Float64Pointer(eAcntVal)}
|
||||
var reply string
|
||||
if err := sDataRPC.Call("ApierV2.SetBalance", attrSetBalance, &reply); err != nil {
|
||||
t.Error(err)
|
||||
} else if reply != utils.OK {
|
||||
t.Errorf("Received: %s", reply)
|
||||
}
|
||||
if err := sDataRPC.Call("ApierV2.GetAccount", acntAttrs, &acnt); err != nil {
|
||||
t.Error(err)
|
||||
} else if totalVal := acnt.BalanceMap[utils.DATA].GetTotalValue(); totalVal != eAcntVal {
|
||||
t.Errorf("Expected: %f, received: %f", eAcntVal, totalVal)
|
||||
}
|
||||
|
||||
usage := int64(1024)
|
||||
initArgs := &V1InitSessionArgs{
|
||||
InitSession: true,
|
||||
CGREvent: utils.CGREvent{
|
||||
Tenant: "cgrates.org",
|
||||
ID: "TestSessionsDataTTLExpired",
|
||||
Event: map[string]interface{}{
|
||||
utils.EVENT_NAME: "TEST_EVENT",
|
||||
utils.ToR: utils.DATA,
|
||||
utils.OriginID: "TestSessionsDataTTLExpired",
|
||||
utils.Account: acntAttrs.Account,
|
||||
utils.Subject: acntAttrs.Account,
|
||||
utils.Destination: utils.DATA,
|
||||
utils.Category: "data",
|
||||
utils.Tenant: "cgrates.org",
|
||||
utils.RequestType: utils.META_PREPAID,
|
||||
utils.SetupTime: time.Date(2016, time.January, 5, 18, 30, 59, 0, time.UTC),
|
||||
utils.AnswerTime: time.Date(2016, time.January, 5, 18, 31, 05, 0, time.UTC),
|
||||
utils.Usage: "1024",
|
||||
utils.SessionTTLUsage: "2048", // will be charged on TTL
|
||||
},
|
||||
},
|
||||
}
|
||||
|
||||
var initRpl *V1InitSessionReply
|
||||
if err := sDataRPC.Call(utils.SessionSv1InitiateSession,
|
||||
initArgs, &initRpl); err != nil {
|
||||
t.Error(err)
|
||||
}
|
||||
if (*initRpl.MaxUsage).Nanoseconds() != usage {
|
||||
t.Errorf("Expecting : %+v, received: %+v", usage, (*initRpl.MaxUsage).Nanoseconds())
|
||||
}
|
||||
|
||||
eAcntVal = 101376.000000
|
||||
if err := sDataRPC.Call("ApierV2.GetAccount", acntAttrs, &acnt); err != nil {
|
||||
t.Error(err)
|
||||
} else if dataVal := acnt.BalanceMap[utils.DATA].GetTotalValue(); dataVal != eAcntVal {
|
||||
t.Errorf("Expected: %f, received: %f", eAcntVal, dataVal)
|
||||
}
|
||||
time.Sleep(70 * time.Millisecond)
|
||||
|
||||
eAcntVal = 99328.000000
|
||||
if err := sDataRPC.Call("ApierV2.GetAccount", acntAttrs, &acnt); err != nil {
|
||||
t.Error(err)
|
||||
} else if dataVal := acnt.BalanceMap[utils.DATA].GetTotalValue(); dataVal != eAcntVal {
|
||||
t.Errorf("Expected: %f, received: %f", eAcntVal, dataVal)
|
||||
}
|
||||
}
|
||||
|
||||
func TestSessionsDataTTLExpMultiUpdates(t *testing.T) {
|
||||
var acnt *engine.Account
|
||||
acntAttrs := &utils.AttrGetAccount{
|
||||
Tenant: "cgrates.org",
|
||||
Account: "TestSessionsDataTTLExpMultiUpdates",
|
||||
}
|
||||
eAcntVal := 102400.0
|
||||
attrSetBalance := utils.AttrSetBalance{
|
||||
Tenant: acntAttrs.Tenant, Account: acntAttrs.Account,
|
||||
BalanceType: utils.DATA,
|
||||
BalanceID: utils.StringPointer("TestSessionsDataTTLExpMultiUpdates"),
|
||||
Value: utils.Float64Pointer(eAcntVal)}
|
||||
var reply string
|
||||
if err := sDataRPC.Call("ApierV2.SetBalance", attrSetBalance, &reply); err != nil {
|
||||
t.Error(err)
|
||||
} else if reply != utils.OK {
|
||||
t.Errorf("Received: %s", reply)
|
||||
}
|
||||
if err := sDataRPC.Call("ApierV2.GetAccount", acntAttrs, &acnt); err != nil {
|
||||
t.Error(err)
|
||||
} else if totalVal := acnt.BalanceMap[utils.DATA].GetTotalValue(); totalVal != eAcntVal {
|
||||
t.Errorf("Expected: %f, received: %f", eAcntVal, totalVal)
|
||||
}
|
||||
|
||||
usage := int64(4096)
|
||||
initArgs := &V1InitSessionArgs{
|
||||
InitSession: true,
|
||||
CGREvent: utils.CGREvent{
|
||||
Tenant: "cgrates.org",
|
||||
ID: "TestSessionsDataTTLExpMultiUpdates",
|
||||
Event: map[string]interface{}{
|
||||
utils.EVENT_NAME: "TEST_EVENT",
|
||||
utils.ToR: utils.DATA,
|
||||
utils.OriginID: "123495",
|
||||
utils.Account: acntAttrs.Account,
|
||||
utils.Subject: acntAttrs.Account,
|
||||
utils.Destination: utils.DATA,
|
||||
utils.Category: "data",
|
||||
utils.Tenant: "cgrates.org",
|
||||
utils.RequestType: utils.META_PREPAID,
|
||||
utils.SetupTime: time.Date(2016, time.January, 5, 18, 30, 59, 0, time.UTC),
|
||||
utils.AnswerTime: time.Date(2016, time.January, 5, 18, 31, 05, 0, time.UTC),
|
||||
utils.Usage: "4096", // 4MB
|
||||
},
|
||||
},
|
||||
}
|
||||
|
||||
var initRpl *V1InitSessionReply
|
||||
if err := sDataRPC.Call(utils.SessionSv1InitiateSession,
|
||||
initArgs, &initRpl); err != nil {
|
||||
t.Error(err)
|
||||
}
|
||||
if (*initRpl.MaxUsage).Nanoseconds() != usage {
|
||||
t.Errorf("Expecting : %+v, received: %+v", usage, (*initRpl.MaxUsage).Nanoseconds())
|
||||
}
|
||||
|
||||
eAcntVal = 98304.000000 //96MB
|
||||
if err := sDataRPC.Call("ApierV2.GetAccount", acntAttrs, &acnt); err != nil {
|
||||
t.Error(err)
|
||||
} else if dataVal := acnt.BalanceMap[utils.DATA].GetTotalValue(); dataVal != eAcntVal {
|
||||
t.Errorf("Expected: %f, received: %f", eAcntVal, dataVal)
|
||||
}
|
||||
aSessions := make([]*ActiveSession, 0)
|
||||
if err := sDataRPC.Call(utils.SessionSv1GetActiveSessions, nil, &aSessions); err != nil {
|
||||
t.Error(err)
|
||||
} else if len(aSessions) != 1 ||
|
||||
int64(aSessions[0].Usage) != 4096 {
|
||||
t.Errorf("wrong active sessions: %d", int64(aSessions[0].Usage))
|
||||
}
|
||||
|
||||
usage = int64(4096)
|
||||
updateArgs := &V1UpdateSessionArgs{
|
||||
UpdateSession: true,
|
||||
CGREvent: utils.CGREvent{
|
||||
Tenant: "cgrates.org",
|
||||
ID: "TestSessionsDataTTLExpMultiUpdates",
|
||||
Event: map[string]interface{}{
|
||||
utils.EVENT_NAME: "TEST_EVENT",
|
||||
utils.ToR: utils.DATA,
|
||||
utils.OriginID: "123495",
|
||||
utils.Account: acntAttrs.Account,
|
||||
utils.Subject: acntAttrs.Account,
|
||||
utils.Destination: utils.DATA,
|
||||
utils.Category: "data",
|
||||
utils.Tenant: "cgrates.org",
|
||||
utils.RequestType: utils.META_PREPAID,
|
||||
utils.SetupTime: time.Date(2016, time.January, 5, 18, 30, 59, 0, time.UTC),
|
||||
utils.AnswerTime: time.Date(2016, time.January, 5, 18, 31, 05, 0, time.UTC),
|
||||
utils.LastUsed: "1024",
|
||||
utils.Usage: "4096",
|
||||
utils.SessionTTLUsage: "2048", // will be charged on TTL
|
||||
utils.SessionTTLLastUsed: "1024",
|
||||
},
|
||||
},
|
||||
}
|
||||
|
||||
var updateRpl *V1UpdateSessionReply
|
||||
if err := sDataRPC.Call(utils.SessionSv1UpdateSession, updateArgs, &updateRpl); err != nil {
|
||||
t.Error(err)
|
||||
}
|
||||
if (*updateRpl.MaxUsage).Nanoseconds() != usage {
|
||||
t.Errorf("Expected: %+v, received: %+v", usage, (*updateRpl.MaxUsage).Nanoseconds())
|
||||
}
|
||||
|
||||
eAcntVal = 97280.000000 // 20480
|
||||
if err := sDataRPC.Call("ApierV2.GetAccount", acntAttrs, &acnt); err != nil {
|
||||
t.Error(err)
|
||||
} else if acnt.BalanceMap[utils.DATA].GetTotalValue() != eAcntVal {
|
||||
t.Errorf("Expected: %f, received: %f", eAcntVal, acnt.BalanceMap[utils.DATA].GetTotalValue())
|
||||
}
|
||||
time.Sleep(60 * time.Millisecond) // TTL will kick in
|
||||
|
||||
eAcntVal = 98304.000000 // 1MB is returned
|
||||
if err := sDataRPC.Call("ApierV2.GetAccount", acntAttrs, &acnt); err != nil {
|
||||
t.Error(err)
|
||||
} else if dataVal := acnt.BalanceMap[utils.DATA].GetTotalValue(); dataVal != eAcntVal {
|
||||
t.Errorf("Expected: %f, received: %f", eAcntVal, dataVal)
|
||||
}
|
||||
if err := sDataRPC.Call(utils.SessionSv1GetActiveSessions,
|
||||
nil, &aSessions); err == nil || err.Error() != utils.ErrNotFound.Error() {
|
||||
t.Error(err, aSessions)
|
||||
}
|
||||
}
|
||||
|
||||
func TestSessionsDataMultipleDataNoUsage(t *testing.T) {
|
||||
var acnt *engine.Account
|
||||
acntAttrs := &utils.AttrGetAccount{Tenant: "cgrates.org",
|
||||
Account: "TestSessionsDataTTLExpMultiUpdates"}
|
||||
eAcntVal := 102400.0
|
||||
attrSetBalance := utils.AttrSetBalance{
|
||||
Tenant: acntAttrs.Tenant, Account: acntAttrs.Account,
|
||||
BalanceType: utils.DATA,
|
||||
BalanceID: utils.StringPointer("TestSessionsDataTTLExpMultiUpdates"),
|
||||
Value: utils.Float64Pointer(eAcntVal)}
|
||||
var reply string
|
||||
if err := sDataRPC.Call("ApierV2.SetBalance", attrSetBalance, &reply); err != nil {
|
||||
t.Error(err)
|
||||
} else if reply != utils.OK {
|
||||
t.Errorf("Received: %s", reply)
|
||||
}
|
||||
if err := sDataRPC.Call("ApierV2.GetAccount", acntAttrs, &acnt); err != nil {
|
||||
t.Error(err)
|
||||
} else if totalVal := acnt.BalanceMap[utils.DATA].GetTotalValue(); totalVal != eAcntVal {
|
||||
t.Errorf("Expected: %f, received: %f", eAcntVal, totalVal)
|
||||
}
|
||||
|
||||
usage := int64(2048)
|
||||
initArgs := &V1InitSessionArgs{
|
||||
InitSession: true,
|
||||
CGREvent: utils.CGREvent{
|
||||
Tenant: "cgrates.org",
|
||||
ID: "TestSessionsDataMultipleDataNoUsage",
|
||||
Event: map[string]interface{}{
|
||||
utils.EVENT_NAME: "TEST_EVENT",
|
||||
utils.ToR: utils.DATA,
|
||||
utils.OriginID: "123495",
|
||||
utils.Account: acntAttrs.Account,
|
||||
utils.Subject: acntAttrs.Account,
|
||||
utils.Destination: utils.DATA,
|
||||
utils.Category: "data",
|
||||
utils.Tenant: "cgrates.org",
|
||||
utils.RequestType: utils.META_PREPAID,
|
||||
utils.SetupTime: time.Date(2016, time.January, 5, 18, 30, 59, 0, time.UTC),
|
||||
utils.AnswerTime: time.Date(2016, time.January, 5, 18, 31, 05, 0, time.UTC),
|
||||
utils.Usage: "2048",
|
||||
},
|
||||
},
|
||||
}
|
||||
|
||||
var initRpl *V1InitSessionReply
|
||||
if err := sDataRPC.Call(utils.SessionSv1InitiateSession,
|
||||
initArgs, &initRpl); err != nil {
|
||||
t.Error(err)
|
||||
}
|
||||
if (*initRpl.MaxUsage).Nanoseconds() != usage {
|
||||
t.Errorf("Expecting : %+v, received: %+v", usage, (*initRpl.MaxUsage).Nanoseconds())
|
||||
}
|
||||
|
||||
eAcntVal = 100352.000000 // 1054720
|
||||
if err := sDataRPC.Call("ApierV2.GetAccount", acntAttrs, &acnt); err != nil {
|
||||
t.Error(err)
|
||||
} else if dataVal := acnt.BalanceMap[utils.DATA].GetTotalValue(); dataVal != eAcntVal {
|
||||
t.Errorf("Expected: %f, received: %f", eAcntVal, dataVal)
|
||||
}
|
||||
aSessions := make([]*ActiveSession, 0)
|
||||
if err := sDataRPC.Call(utils.SessionSv1GetActiveSessions, nil, &aSessions); err != nil {
|
||||
t.Error(err)
|
||||
} else if len(aSessions) != 1 ||
|
||||
int64(aSessions[0].Usage) != 2048 {
|
||||
t.Errorf("wrong active sessions usage: %d", int64(aSessions[0].Usage))
|
||||
}
|
||||
|
||||
usage = int64(1024)
|
||||
updateArgs := &V1UpdateSessionArgs{
|
||||
UpdateSession: true,
|
||||
CGREvent: utils.CGREvent{
|
||||
Tenant: "cgrates.org",
|
||||
ID: "TestSessionsDataMultipleDataNoUsage",
|
||||
Event: map[string]interface{}{
|
||||
utils.EVENT_NAME: "TEST_EVENT",
|
||||
utils.ToR: utils.DATA,
|
||||
utils.OriginID: "123495",
|
||||
utils.Account: acntAttrs.Account,
|
||||
utils.Subject: acntAttrs.Account,
|
||||
utils.Destination: utils.DATA,
|
||||
utils.Category: "data",
|
||||
utils.Tenant: "cgrates.org",
|
||||
utils.RequestType: utils.META_PREPAID,
|
||||
utils.SetupTime: time.Date(2016, time.January, 5, 18, 30, 59, 0, time.UTC),
|
||||
utils.AnswerTime: time.Date(2016, time.January, 5, 18, 31, 05, 0, time.UTC),
|
||||
utils.SessionTTL: "1h", // cancel timeout since usage 0 will not update it
|
||||
utils.Usage: "1024",
|
||||
utils.LastUsed: "1024",
|
||||
},
|
||||
},
|
||||
}
|
||||
|
||||
var updateRpl *V1UpdateSessionReply
|
||||
if err := sDataRPC.Call(utils.SessionSv1UpdateSession, updateArgs, &updateRpl); err != nil {
|
||||
t.Error(err)
|
||||
}
|
||||
if (*updateRpl.MaxUsage).Nanoseconds() != usage {
|
||||
t.Errorf("Expected: %+v, received: %+v", usage, (*updateRpl.MaxUsage).Nanoseconds())
|
||||
}
|
||||
|
||||
eAcntVal = 100352.000000
|
||||
if err := sDataRPC.Call("ApierV2.GetAccount", acntAttrs, &acnt); err != nil {
|
||||
t.Error(err)
|
||||
} else if dataVal := acnt.BalanceMap[utils.DATA].GetTotalValue(); dataVal != eAcntVal {
|
||||
t.Errorf("Expected: %f, received: %f", eAcntVal, dataVal)
|
||||
}
|
||||
aSessions = make([]*ActiveSession, 0)
|
||||
if err := sDataRPC.Call(utils.SessionSv1GetActiveSessions, nil, &aSessions); err != nil {
|
||||
t.Error(err)
|
||||
} else if len(aSessions) != 1 ||
|
||||
int64(aSessions[0].Usage) != 2048 {
|
||||
t.Errorf("wrong active sessions usage: %d", int64(aSessions[0].Usage))
|
||||
}
|
||||
|
||||
usage = int64(0)
|
||||
updateArgs = &V1UpdateSessionArgs{
|
||||
UpdateSession: true,
|
||||
CGREvent: utils.CGREvent{
|
||||
Tenant: "cgrates.org",
|
||||
ID: "TestSessionsDataMultipleDataNoUsage",
|
||||
Event: map[string]interface{}{
|
||||
utils.EVENT_NAME: "TEST_EVENT",
|
||||
utils.ToR: utils.DATA,
|
||||
utils.OriginID: "123495",
|
||||
utils.Account: acntAttrs.Account,
|
||||
utils.Subject: acntAttrs.Account,
|
||||
utils.Destination: utils.DATA,
|
||||
utils.Category: "data",
|
||||
utils.Tenant: "cgrates.org",
|
||||
utils.RequestType: utils.META_PREPAID,
|
||||
utils.SetupTime: time.Date(2016, time.January, 5, 18, 30, 59, 0, time.UTC),
|
||||
utils.AnswerTime: time.Date(2016, time.January, 5, 18, 31, 05, 0, time.UTC),
|
||||
utils.SessionTTL: "1h", // cancel timeout since usage 0 will not update it
|
||||
utils.Usage: "0",
|
||||
utils.LastUsed: "0",
|
||||
},
|
||||
},
|
||||
}
|
||||
|
||||
if err := sDataRPC.Call(utils.SessionSv1UpdateSession, updateArgs, &updateRpl); err != nil {
|
||||
t.Error(err)
|
||||
}
|
||||
if (*updateRpl.MaxUsage).Nanoseconds() != usage {
|
||||
t.Errorf("Expected: %+v, received: %+v", usage, (*updateRpl.MaxUsage).Nanoseconds())
|
||||
}
|
||||
|
||||
eAcntVal = 100352.000000
|
||||
if err := sDataRPC.Call("ApierV2.GetAccount", acntAttrs, &acnt); err != nil {
|
||||
t.Error(err)
|
||||
} else if dataVal := acnt.BalanceMap[utils.DATA].GetTotalValue(); dataVal != eAcntVal {
|
||||
t.Errorf("Expected: %f, received: %f", eAcntVal, dataVal)
|
||||
}
|
||||
aSessions = make([]*ActiveSession, 0)
|
||||
if err := sDataRPC.Call(utils.SessionSv1GetActiveSessions, nil, &aSessions); err != nil {
|
||||
t.Error(err)
|
||||
} else if len(aSessions) != 1 ||
|
||||
int64(aSessions[0].Usage) != 1024 {
|
||||
t.Errorf("wrong active sessions usage: %d", int64(aSessions[0].Usage))
|
||||
}
|
||||
|
||||
termArgs := &V1TerminateSessionArgs{
|
||||
TerminateSession: true,
|
||||
CGREvent: utils.CGREvent{
|
||||
Tenant: "cgrates.org",
|
||||
ID: "TestSessionsDataMultipleDataNoUsage",
|
||||
Event: map[string]interface{}{
|
||||
utils.EVENT_NAME: "TEST_EVENT",
|
||||
utils.ToR: utils.DATA,
|
||||
utils.OriginID: "123495",
|
||||
utils.Account: acntAttrs.Account,
|
||||
utils.Subject: acntAttrs.Account,
|
||||
utils.Destination: utils.DATA,
|
||||
utils.Category: "data",
|
||||
utils.Tenant: "cgrates.org",
|
||||
utils.RequestType: utils.META_PREPAID,
|
||||
utils.SetupTime: time.Date(2016, time.January, 5, 18, 30, 49, 0, time.UTC),
|
||||
utils.AnswerTime: time.Date(2016, time.January, 5, 18, 31, 05, 0, time.UTC),
|
||||
utils.LastUsed: "0",
|
||||
},
|
||||
},
|
||||
}
|
||||
|
||||
var rpl string
|
||||
if err := sDataRPC.Call(utils.SessionSv1TerminateSession, termArgs, &rpl); err != nil || rpl != utils.OK {
|
||||
t.Error(err)
|
||||
}
|
||||
|
||||
eAcntVal = 101376.000000 // refunded last 1MB reserved and unused
|
||||
if err := sDataRPC.Call("ApierV2.GetAccount", acntAttrs, &acnt); err != nil {
|
||||
t.Error(err)
|
||||
} else if acnt.BalanceMap[utils.DATA].GetTotalValue() != eAcntVal {
|
||||
t.Errorf("Expected: %f, received: %f",
|
||||
eAcntVal, acnt.BalanceMap[utils.DATA].GetTotalValue())
|
||||
}
|
||||
if err := sDataRPC.Call(utils.SessionSv1GetActiveSessions,
|
||||
nil, &aSessions); err == nil ||
|
||||
err.Error() != utils.ErrNotFound.Error() {
|
||||
t.Error(err, aSessions)
|
||||
}
|
||||
}
|
||||
|
||||
// TestSessionsDataTTLUsageProtection makes sure that original TTL (50ms)
|
||||
// limits the additional debit without overloading memory
|
||||
func TestSessionsDataTTLUsageProtection(t *testing.T) {
|
||||
var acnt *engine.Account
|
||||
acntAttrs := &utils.AttrGetAccount{Tenant: "cgrates.org",
|
||||
Account: "TestSessionsDataTTLUsageProtection"}
|
||||
eAcntVal := 102400.0
|
||||
attrSetBalance := utils.AttrSetBalance{
|
||||
Tenant: acntAttrs.Tenant, Account: acntAttrs.Account,
|
||||
BalanceType: utils.DATA,
|
||||
BalanceID: utils.StringPointer("TestSessionsDataTTLUsageProtection"),
|
||||
Value: utils.Float64Pointer(eAcntVal),
|
||||
}
|
||||
var reply string
|
||||
if err := sDataRPC.Call("ApierV2.SetBalance", attrSetBalance, &reply); err != nil {
|
||||
t.Error(err)
|
||||
} else if reply != utils.OK {
|
||||
t.Errorf("Received: %s", reply)
|
||||
}
|
||||
if err := sDataRPC.Call("ApierV2.GetAccount", acntAttrs, &acnt); err != nil {
|
||||
t.Error(err)
|
||||
} else if totalVal := acnt.BalanceMap[utils.DATA].GetTotalValue(); totalVal != eAcntVal {
|
||||
t.Errorf("Expected: %f, received: %f", eAcntVal, totalVal)
|
||||
}
|
||||
|
||||
usage := int64(2048)
|
||||
initArgs := &V1InitSessionArgs{
|
||||
InitSession: true,
|
||||
CGREvent: utils.CGREvent{
|
||||
Tenant: "cgrates.org",
|
||||
ID: "TestSessionsDataTTLUsageProtection",
|
||||
Event: map[string]interface{}{
|
||||
utils.EVENT_NAME: "TEST_EVENT",
|
||||
utils.ToR: utils.DATA,
|
||||
utils.OriginID: "123495",
|
||||
utils.Account: acntAttrs.Account,
|
||||
utils.Subject: acntAttrs.Account,
|
||||
utils.Destination: utils.DATA,
|
||||
utils.Category: "data",
|
||||
utils.Tenant: "cgrates.org",
|
||||
utils.RequestType: utils.META_PREPAID,
|
||||
utils.SetupTime: time.Date(2016, time.January, 5, 18, 30, 53, 0, time.UTC),
|
||||
utils.AnswerTime: time.Date(2016, time.January, 5, 18, 31, 05, 0, time.UTC),
|
||||
utils.Usage: "2048",
|
||||
},
|
||||
},
|
||||
}
|
||||
|
||||
var initRpl *V1InitSessionReply
|
||||
if err := sDataRPC.Call(utils.SessionSv1InitiateSession,
|
||||
initArgs, &initRpl); err != nil {
|
||||
t.Error(err)
|
||||
}
|
||||
if (*initRpl.MaxUsage).Nanoseconds() != usage {
|
||||
t.Errorf("Expecting : %+v, received: %+v", usage, (*initRpl.MaxUsage).Nanoseconds())
|
||||
}
|
||||
|
||||
eAcntVal = 100352.000000 // 1054720
|
||||
if err := sDataRPC.Call("ApierV2.GetAccount", acntAttrs, &acnt); err != nil {
|
||||
t.Error(err)
|
||||
} else if dataVal := acnt.BalanceMap[utils.DATA].GetTotalValue(); dataVal != eAcntVal {
|
||||
t.Errorf("Expected: %f, received: %f", eAcntVal, dataVal)
|
||||
}
|
||||
aSessions := make([]*ActiveSession, 0)
|
||||
if err := sDataRPC.Call(utils.SessionSv1GetActiveSessions, nil, &aSessions); err != nil {
|
||||
t.Error(err)
|
||||
} else if len(aSessions) != 1 ||
|
||||
int64(aSessions[0].Usage) != 2048 {
|
||||
t.Errorf("wrong active sessions usage: %d", int64(aSessions[0].Usage))
|
||||
}
|
||||
time.Sleep(60 * time.Millisecond)
|
||||
if err := sDataRPC.Call(utils.SessionSv1GetActiveSessions,
|
||||
nil, &aSessions); err == nil || err.Error() != utils.ErrNotFound.Error() {
|
||||
t.Error(err, aSessions)
|
||||
}
|
||||
}
|
||||
|
||||
func TestSessionsDataTTKillEngine(t *testing.T) {
|
||||
if err := engine.KillEngine(100); err != nil {
|
||||
t.Error(err)
|
||||
}
|
||||
}
|
||||
@@ -34,6 +34,7 @@ import (
|
||||
var smgRplcMasterCfgPath, smgRplcSlaveCfgPath string
|
||||
var smgRplcMasterCfg, smgRplcSlaveCfg *config.CGRConfig
|
||||
var smgRplcMstrRPC, smgRplcSlvRPC *rpc.Client
|
||||
var err error
|
||||
|
||||
func TestSessionSRplInitCfg(t *testing.T) {
|
||||
smgRplcMasterCfgPath = path.Join(*dataDir, "conf", "samples", "smgreplcmaster")
|
||||
|
||||
@@ -35,39 +35,39 @@ import (
|
||||
var waitRater = flag.Int("wait_rater", 150, "Number of miliseconds to wait for rater to start and cache")
|
||||
var dataDir = flag.String("data_dir", "/usr/share/cgrates", "CGR data dir path here")
|
||||
|
||||
var daCfgPath string
|
||||
var daCfg *config.CGRConfig
|
||||
var voiceCfgPath string
|
||||
var voiceCfg *config.CGRConfig
|
||||
var sessionsRPC *rpc.Client
|
||||
|
||||
func TestSessionsVoiceInitCfg(t *testing.T) {
|
||||
daCfgPath = path.Join(*dataDir, "conf", "samples", "smg")
|
||||
voiceCfgPath = path.Join(*dataDir, "conf", "samples", "smg")
|
||||
// Init config first
|
||||
var err error
|
||||
daCfg, err = config.NewCGRConfigFromFolder(daCfgPath)
|
||||
voiceCfg, err = config.NewCGRConfigFromFolder(voiceCfgPath)
|
||||
if err != nil {
|
||||
t.Error(err)
|
||||
}
|
||||
daCfg.DataFolderPath = *dataDir // Share DataFolderPath through config towards StoreDb for Flush()
|
||||
config.SetCgrConfig(daCfg)
|
||||
voiceCfg.DataFolderPath = *dataDir // Share DataFolderPath through config towards StoreDb for Flush()
|
||||
config.SetCgrConfig(voiceCfg)
|
||||
}
|
||||
|
||||
// Remove data in both rating and accounting db
|
||||
func TestSessionsVoiceResetDataDb(t *testing.T) {
|
||||
if err := engine.InitDataDb(daCfg); err != nil {
|
||||
if err := engine.InitDataDb(voiceCfg); err != nil {
|
||||
t.Fatal(err)
|
||||
}
|
||||
}
|
||||
|
||||
// Wipe out the cdr database
|
||||
func TestSessionsVoiceResetStorDb(t *testing.T) {
|
||||
if err := engine.InitStorDb(daCfg); err != nil {
|
||||
if err := engine.InitStorDb(voiceCfg); err != nil {
|
||||
t.Fatal(err)
|
||||
}
|
||||
}
|
||||
|
||||
// Start CGR Engine
|
||||
func TestSessionsVoiceStartEngine(t *testing.T) {
|
||||
if _, err := engine.StopStartEngine(daCfgPath, *waitRater); err != nil {
|
||||
if _, err := engine.StopStartEngine(voiceCfgPath, *waitRater); err != nil {
|
||||
t.Fatal(err)
|
||||
}
|
||||
}
|
||||
@@ -75,7 +75,7 @@ func TestSessionsVoiceStartEngine(t *testing.T) {
|
||||
// Connect rpc client to rater
|
||||
func TestSessionsVoiceApierRpcConn(t *testing.T) {
|
||||
var err error
|
||||
sessionsRPC, err = jsonrpc.Dial("tcp", daCfg.ListenCfg().RPCJSONListen) // We connect over JSON so we can also troubleshoot if needed
|
||||
sessionsRPC, err = jsonrpc.Dial("tcp", voiceCfg.ListenCfg().RPCJSONListen) // We connect over JSON so we can also troubleshoot if needed
|
||||
if err != nil {
|
||||
t.Fatal(err)
|
||||
}
|
||||
@@ -106,7 +106,6 @@ func TestSessionsVoiceTPFromFolder(t *testing.T) {
|
||||
}
|
||||
}
|
||||
|
||||
/*
|
||||
func TestSessionsVoiceMonetaryRefund(t *testing.T) {
|
||||
usage := time.Duration(1*time.Minute + 30*time.Second)
|
||||
initArgs := &V1InitSessionArgs{
|
||||
@@ -897,8 +896,10 @@ func TestSessionsVoiceSessionTTL(t *testing.T) {
|
||||
}
|
||||
}
|
||||
}
|
||||
*/
|
||||
|
||||
/*
|
||||
//For the moment we let these tests commented
|
||||
//Need to investigate them
|
||||
func TestSessionsVoiceSessionTTLWithRelocate(t *testing.T) {
|
||||
attrSetBalance := utils.AttrSetBalance{
|
||||
Tenant: "cgrates.org",
|
||||
@@ -1061,7 +1062,6 @@ func TestSessionsVoiceSessionTTLWithRelocate(t *testing.T) {
|
||||
}
|
||||
}
|
||||
|
||||
/*
|
||||
func TestSessionsVoiceRelocateWithOriginIDPrefix(t *testing.T) {
|
||||
attrSetBalance := utils.AttrSetBalance{
|
||||
Tenant: "cgrates.org",
|
||||
|
||||
@@ -20,6 +20,7 @@ along with this program. If not, see <http://www.gnu.org/licenses/>
|
||||
|
||||
package sessions
|
||||
|
||||
/*
|
||||
import (
|
||||
"net/rpc/jsonrpc"
|
||||
"path"
|
||||
@@ -284,3 +285,4 @@ func TestSMGBiRPCStopCgrEngine(t *testing.T) {
|
||||
t.Error(err)
|
||||
}
|
||||
}
|
||||
*/
|
||||
|
||||
Reference in New Issue
Block a user