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

Test fixes

Browse Source
This commit is contained in:
DanB
2016-04-23 18:25:32 +02:00
parent 51aff554e6
commit eb3bf6e205
3 changed files with 22 additions and 19 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
cdrc/cdrc_local_test.go
View File

@@ -166,8 +166,10 @@ func TestCsvLclProcessCdrDir(t *testing.T) {
for _, cdrcCfg = range cdrcCfgs { // Take the first config out, does not matter which one
break
}
if cdrcCfg.Cdrs == utils.INTERNAL { // For now we only test over network
cdrcCfg.Cdrs = "127.0.0.1:2013"
for _, cdrsConn := range cdrcCfg.CdrsConns {
if cdrsConn.Address == utils.INTERNAL {
cdrsConn.Address = "127.0.0.1:2013"
}
}
if err := startEngine(); err != nil {
t.Fatal(err.Error())
@@ -202,8 +204,10 @@ func TestCsvLclProcessCdr3Dir(t *testing.T) {
if !*testLocal {
return
}
if cdrcCfg.Cdrs == utils.INTERNAL { // For now we only test over network
cdrcCfg.Cdrs = "127.0.0.1:2013"
for _, cdrsConn := range cdrcCfg.CdrsConns {
if cdrsConn.Address == utils.INTERNAL {
cdrsConn.Address = "127.0.0.1:2013"
}
}
if err := startEngine(); err != nil {
t.Fatal(err.Error())

2
cmd/cgr-engine/rater.go
View File

@@ -189,12 +189,10 @@ func startRater(internalRaterChan chan rpcclient.RpcClientConnection, cacheDoneC
engine.SetUserService(usersConns)
}()
}
// Wait for all connections to complete before going further
for _, chn := range waitTasks {
<-chn
}
responder := &engine.Responder{Bal: bal, ExitChan: exitChan, Stats: cdrStats}
responder.SetTimeToLive(cfg.ResponseCacheTTL, nil)
apierRpcV1 := &v1.ApierV1{StorDb: loadDb, RatingDb: ratingDb, AccountDb: accountDb, CdrDb: cdrDb, LogDb: logDb, Sched: sched,

27
sessionmanager/session_test.go
View File

@@ -23,6 +23,7 @@ import (
"time"
"github.com/cgrates/cgrates/engine"
"github.com/cgrates/cgrates/utils"
)
//"github.com/cgrates/cgrates/config"
@@ -89,26 +90,26 @@ func (mc *MockRpcClient) Call(methodName string, arg interface{}, reply interfac
}
return nil
}
func (mc *MockConnector) GetCost(*engine.CallDescriptor, *engine.CallCost) error { return nil }
func (mc *MockConnector) Debit(*engine.CallDescriptor, *engine.CallCost) error { return nil }
func (mc *MockConnector) MaxDebit(*engine.CallDescriptor, *engine.CallCost) error { return nil }
func (mc *MockConnector) RefundIncrements(cd *engine.CallDescriptor, reply *float64) error {
func (mc *MockRpcClient) GetCost(*engine.CallDescriptor, *engine.CallCost) error { return nil }
func (mc *MockRpcClient) Debit(*engine.CallDescriptor, *engine.CallCost) error { return nil }
func (mc *MockRpcClient) MaxDebit(*engine.CallDescriptor, *engine.CallCost) error { return nil }
func (mc *MockRpcClient) RefundIncrements(cd *engine.CallDescriptor, reply *float64) error {
mc.refundCd = cd
return nil
}
func (mc *MockConnector) RefundRounding(cd *engine.CallDescriptor, reply *float64) error {
func (mc *MockRpcClient) RefundRounding(cd *engine.CallDescriptor, reply *float64) error {
return nil
}
func (mc *MockConnector) GetMaxSessionTime(*engine.CallDescriptor, *float64) error { return nil }
func (mc *MockConnector) GetDerivedChargers(*utils.AttrDerivedChargers, *utils.DerivedChargers) error {
func (mc *MockRpcClient) GetMaxSessionTime(*engine.CallDescriptor, *float64) error { return nil }
func (mc *MockRpcClient) GetDerivedChargers(*utils.AttrDerivedChargers, *utils.DerivedChargers) error {
return nil
}
func (mc *MockConnector) GetDerivedMaxSessionTime(*engine.CDR, *float64) error { return nil }
func (mc *MockConnector) GetSessionRuns(*engine.CDR, *[]*engine.SessionRun) error { return nil }
func (mc *MockConnector) ProcessCdr(*engine.CDR, *string) error { return nil }
func (mc *MockConnector) StoreSMCost(engine.AttrCDRSStoreSMCost, *string) error { return nil }
func (mc *MockConnector) GetLCR(*engine.AttrGetLcr, *engine.LCRCost) error { return nil }
func (mc *MockConnector) GetTimeout(int, *time.Duration) error { return nil }
func (mc *MockRpcClient) GetDerivedMaxSessionTime(*engine.CDR, *float64) error { return nil }
func (mc *MockRpcClient) GetSessionRuns(*engine.CDR, *[]*engine.SessionRun) error { return nil }
func (mc *MockRpcClient) ProcessCdr(*engine.CDR, *string) error { return nil }
func (mc *MockRpcClient) StoreSMCost(engine.AttrCDRSStoreSMCost, *string) error { return nil }
func (mc *MockRpcClient) GetLCR(*engine.AttrGetLcr, *engine.LCRCost) error { return nil }
func (mc *MockRpcClient) GetTimeout(int, *time.Duration) error { return nil }
func TestSessionRefund(t *testing.T) {
mc := &MockRpcClient{}