mirror of
https://github.com/cgrates/cgrates.git
synced 2026-02-23 08:08:45 +05:00
add test for SessionSv1.ProcessEvent with *rates flag
This commit is contained in:
armirveliaj
committed by
Dan Christian Bogos
Dan Christian Bogos
parent
3e01ce87a0
commit
babb50f748
215
sessions/sessions_processeventrates_it_test.go
Normal file
215
sessions/sessions_processeventrates_it_test.go
Normal file
@@ -0,0 +1,215 @@
|
||||
//go:build integration
|
||||
// +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 Affero 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 Affero General Public License for more details.
|
||||
|
||||
You should have received a copy of the GNU Affero General Public License
|
||||
along with this program. If not, see <https://www.gnu.org/licenses/>
|
||||
*/
|
||||
|
||||
package sessions
|
||||
|
||||
import (
|
||||
"testing"
|
||||
"time"
|
||||
|
||||
"github.com/cgrates/birpc/context"
|
||||
"github.com/cgrates/cgrates/engine"
|
||||
"github.com/cgrates/cgrates/utils"
|
||||
)
|
||||
|
||||
func TestSessionSv1ProcessEventRates(t *testing.T) {
|
||||
var dbcfg engine.DBCfg
|
||||
switch *utils.DBType {
|
||||
case utils.MetaInternal:
|
||||
dbcfg = engine.InternalDBCfg
|
||||
case utils.MetaRedis:
|
||||
dbcfg = engine.RedisDBCfg
|
||||
case utils.MetaMySQL:
|
||||
dbcfg = engine.MySQLDBCfg
|
||||
case utils.MetaMongo:
|
||||
dbcfg = engine.MongoDBCfg
|
||||
case utils.MetaPostgres:
|
||||
dbcfg = engine.PostgresDBCfg
|
||||
default:
|
||||
t.Fatal("unsupported dbtype value")
|
||||
}
|
||||
|
||||
ng := engine.TestEngine{
|
||||
ConfigJSON: `{
|
||||
"sessions": {
|
||||
"enabled": true,
|
||||
"rates_conns": ["*localhost"]
|
||||
},
|
||||
"rates": {
|
||||
"enabled": true
|
||||
},
|
||||
"admins": {
|
||||
"enabled": true
|
||||
}
|
||||
}`,
|
||||
TpFiles: map[string]string{
|
||||
utils.RatesCsv: `#Tenant,ID,FilterIDs,Weights,MinCost,MaxCost,MaxCostStrategy,RateID,RateFilterIDs,RateActivationStart,RateWeights,RateBlocker,RateIntervalStart,RateFixedFee,RateRecurrentFee,RateUnit,RateIncrement
|
||||
cgrates.org,RP_SIMPLE,,;10,,,,RT_SIMPLE,*string:~*req.Destination:1002,"* * * * *",;10,false,0s,0,1,1m,1m`,
|
||||
},
|
||||
DBCfg: dbcfg,
|
||||
Encoding: *utils.Encoding,
|
||||
// LogBuffer: new(bytes.Buffer),
|
||||
}
|
||||
|
||||
// t.Cleanup(func() {
|
||||
// if ng.LogBuffer != nil {
|
||||
// fmt.Println(ng.LogBuffer)
|
||||
// }
|
||||
// })
|
||||
|
||||
client, _ := ng.Run(t)
|
||||
time.Sleep(100 * time.Millisecond)
|
||||
|
||||
t.Run("noFlags", func(t *testing.T) {
|
||||
var rply V1ProcessEventReply
|
||||
err := client.Call(context.Background(), utils.SessionSv1ProcessEvent,
|
||||
&utils.CGREvent{
|
||||
Tenant: "cgrates.org",
|
||||
ID: "noFlags",
|
||||
APIOpts: map[string]any{},
|
||||
Event: map[string]any{
|
||||
utils.AccountField: "1001",
|
||||
utils.Destination: "1002",
|
||||
utils.AnswerTime: "2018-01-07T17:00:00Z",
|
||||
},
|
||||
}, &rply)
|
||||
|
||||
if err != nil {
|
||||
t.Fatalf("ProcessEvent failed without rates flag: %v", err)
|
||||
}
|
||||
if len(rply.RateSCost) > 0 {
|
||||
t.Errorf("RateSCost should be empty without *rates flag, got: %v", rply.RateSCost)
|
||||
}
|
||||
})
|
||||
|
||||
t.Run("ratesFlag", func(t *testing.T) {
|
||||
var rply V1ProcessEventReply
|
||||
err := client.Call(context.Background(), utils.SessionSv1ProcessEvent,
|
||||
&utils.CGREvent{
|
||||
Tenant: "cgrates.org",
|
||||
ID: "ratesFlag",
|
||||
APIOpts: map[string]any{
|
||||
utils.MetaRates: true,
|
||||
utils.MetaUsage: 1 * time.Minute,
|
||||
},
|
||||
Event: map[string]any{
|
||||
utils.AccountField: "1001",
|
||||
utils.Destination: "1002",
|
||||
utils.AnswerTime: "2018-01-07T17:00:00Z",
|
||||
},
|
||||
}, &rply)
|
||||
|
||||
if err != nil {
|
||||
t.Fatalf("ProcessEvent failed with *rates flag: %v", err)
|
||||
}
|
||||
if rply.RateSCost == nil {
|
||||
t.Fatal("RateSCost should not be nil with *rates flag")
|
||||
}
|
||||
cost, exists := rply.RateSCost[utils.MetaDefault]
|
||||
if !exists {
|
||||
t.Fatalf("no RateSCost entry for *default runID, got: %v", rply.RateSCost)
|
||||
}
|
||||
const wantCost = 1.0
|
||||
if cost != wantCost {
|
||||
t.Errorf("RateSCost[*default] = %g, want %g", cost, wantCost)
|
||||
}
|
||||
})
|
||||
|
||||
t.Run("ratesSecondInterval", func(t *testing.T) {
|
||||
var rply V1ProcessEventReply
|
||||
err := client.Call(context.Background(), utils.SessionSv1ProcessEvent,
|
||||
&utils.CGREvent{
|
||||
Tenant: "cgrates.org",
|
||||
ID: "ratesSecondInterval",
|
||||
APIOpts: map[string]any{
|
||||
utils.MetaRates: true,
|
||||
utils.MetaUsage: 2 * time.Minute,
|
||||
},
|
||||
Event: map[string]any{
|
||||
utils.AccountField: "1001",
|
||||
utils.Destination: "1002",
|
||||
utils.AnswerTime: "2018-01-07T17:00:00Z",
|
||||
},
|
||||
}, &rply)
|
||||
|
||||
if err != nil {
|
||||
t.Fatalf("ProcessEvent failed: %v", err)
|
||||
}
|
||||
if rply.RateSCost == nil {
|
||||
t.Fatal("RateSCost should not be nil")
|
||||
}
|
||||
cost, exists := rply.RateSCost[utils.MetaDefault]
|
||||
if !exists {
|
||||
t.Fatalf("no RateSCost entry for *default runID, got: %v", rply.RateSCost)
|
||||
}
|
||||
const wantCost = 2.0
|
||||
if cost != wantCost {
|
||||
t.Errorf("RateSCost[*default] = %g, want %g", cost, wantCost)
|
||||
}
|
||||
})
|
||||
|
||||
t.Run("ratesDisabled", func(t *testing.T) {
|
||||
var rply V1ProcessEventReply
|
||||
err := client.Call(context.Background(), utils.SessionSv1ProcessEvent,
|
||||
&utils.CGREvent{
|
||||
Tenant: "cgrates.org",
|
||||
ID: "ratesDisabled",
|
||||
APIOpts: map[string]any{
|
||||
utils.MetaRates: false,
|
||||
utils.MetaUsage: 2*time.Minute + 30*time.Second,
|
||||
},
|
||||
Event: map[string]any{
|
||||
utils.AccountField: "1001",
|
||||
utils.Destination: "1002",
|
||||
utils.AnswerTime: "2018-01-07T17:00:00Z",
|
||||
},
|
||||
}, &rply)
|
||||
|
||||
if err != nil {
|
||||
t.Fatalf("ProcessEvent failed: %v", err)
|
||||
}
|
||||
if len(rply.RateSCost) > 0 {
|
||||
t.Errorf("RateSCost should be empty when *rates=false, got: %v", rply.RateSCost)
|
||||
}
|
||||
})
|
||||
|
||||
t.Run("noMatchingRate", func(t *testing.T) {
|
||||
var rply V1ProcessEventReply
|
||||
|
||||
if err := client.Call(context.Background(), utils.SessionSv1ProcessEvent,
|
||||
&utils.CGREvent{
|
||||
Tenant: "cgrates.org",
|
||||
ID: "noMatchingRate",
|
||||
APIOpts: map[string]any{
|
||||
utils.MetaRates: true,
|
||||
utils.MetaUsage: 1 * time.Minute,
|
||||
},
|
||||
Event: map[string]any{
|
||||
utils.AccountField: "1001",
|
||||
utils.Destination: "9999",
|
||||
utils.AnswerTime: "2018-01-07T17:00:00Z",
|
||||
},
|
||||
}, &rply,
|
||||
); err == nil {
|
||||
t.Fatal("expected error, got none")
|
||||
}
|
||||
})
|
||||
}
|
||||
Reference in New Issue
Block a user