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

Fixed random failing test in sessions

Browse Source
This commit is contained in:
porosnicuadrian
2021-03-22 12:32:58 +02:00
committed by Dan Christian Bogos
parent 99526ddde2
commit 622d01a56b
1 changed files with 38 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

45
sessions/sessionscover_test.go
View File

@@ -4253,8 +4253,7 @@ func TestBiRPCv1ProcessEventRals2(t *testing.T) {
engine.Cache = tmp
}
/*
func TestBiRPCv1ProcessEventCDRs(t *testing.T) {
func TestBiRPCv1ProcessEventCDRs11(t *testing.T) {
log.SetOutput(io.Discard)
engine.Cache.Clear(nil)
@@ -4302,6 +4301,7 @@ func TestBiRPCv1ProcessEventCDRs(t *testing.T) {
ID: "testBiRPCv1ProcessEventStatsResources",
Event: map[string]interface{}{
utils.Tenant: "cgrates.org",
utils.CGRID: "TEST_CGRID",
utils.Destination: "1002",
utils.RequestType: utils.MetaPrepaid,
},
@@ -4310,6 +4310,25 @@ func TestBiRPCv1ProcessEventCDRs(t *testing.T) {
},
},
}
sessions.aSessions = map[string]*Session{
"TEST_CGRID": {
Tenant: "cgrates.org",
CGRID: "TEST_CGRID",
SRuns: []*SRun{
{
Event: map[string]interface{}{
utils.RequestType: utils.MetaDynaprepaid,
},
CD: &engine.CallDescriptor{Category: "test"},
EventCost: &engine.EventCost{CGRID: "testCGRID"},
ExtraDuration: 1,
LastUsage: time.Minute,
TotalUsage: 3 * time.Minute,
NextAutoDebit: utils.TimePointer(time.Date(2020, time.April, 18, 23, 0, 0, 0, time.UTC)),
},
},
},
}
reply := V1ProcessEventReply{}
expected := "PARTIALLY_EXECUTED"
@@ -4320,10 +4339,24 @@ func TestBiRPCv1ProcessEventCDRs(t *testing.T) {
args.Flags = []string{utils.MetaCDRs, utils.MetaBlockerError,
utils.ConcatenatedKey(utils.MetaRALs, utils.MetaDerivedReply),
utils.MetaChargers}
expected = "CDRS_ERROR:NOT_IMPLEMENTED"
if err := sessions.BiRPCv1ProcessEvent(nil, args, &reply); err == nil || err.Error() != expected {
t.Errorf("Exepected %+v, received %+v", expected, err)
var err error
utils.Logger, err = utils.Newlogger(utils.MetaStdLog, utils.EmptyString)
if err != nil {
t.Error(err)
}
utils.Logger.SetLogLevel(7)
buff := new(bytes.Buffer)
log.SetOutput(buff)
expectedLogger := "[WARNING] <SessionS> ProcessCDR called for active session with CGRID: <TEST_CGRID>"
expected = "CDRS_ERROR:PARTIALLY_EXECUTED"
if err := sessions.BiRPCv1ProcessEvent(nil, args, &reply); err == nil || err.Error() != expected {
t.Errorf("Expected %+v, received %+v", expected, err)
} else if rcv := buff.String(); !strings.Contains(rcv, expectedLogger) {
t.Errorf("Expected %+v, received %+v", expectedLogger, rcv)
}
buff.Reset()
sessions.cgrCfg.SessionSCfg().CDRsConns = []string{}
expected = "NOT_CONNECTED: CDRs"
@@ -4332,8 +4365,6 @@ func TestBiRPCv1ProcessEventCDRs(t *testing.T) {
}
}
*/
func TestBiRPCv1GetCost(t *testing.T) {
log.SetOutput(io.Discard)
tmp := engine.Cache