uppal/cgrates
1
0
Fork 1
mirror of https://github.com/cgrates/cgrates.git synced 2026-02-24 16:48:45 +05:00
Code Issues Packages Projects Releases Wiki Activity

Cover funcs from engine/calldesc.go

Browse Source
This commit is contained in:
ionutboangiu
2021-04-15 17:55:39 +03:00
committed by Dan Christian Bogos
parent a3085e9c14
commit 94f1e4b0ba
2 changed files with 359 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

20
engine/callcost_test.go
View File

@@ -217,7 +217,7 @@ func TestCallcostCallCostToDataCost(t *testing.T) {
TimeEnd: time.Date(2021, 1, 1, 10, 30, 0, 0, time.Local),
ratingInfo: &RatingInfo{
MatchedSubject: "1001",
RatingPlanId: "RT_20CNT",
RatingPlanId: "RP_1001",
MatchedPrefix: "1001",
MatchedDestId: "1002",
ActivationTime: time.Date(2021, 1, 1, 10, 30, 0, 0, time.Local),
@@ -280,7 +280,7 @@ func TestCallcostCallCostToDataCost(t *testing.T) {
},
Weight: 10,
},
RatingPlanId: "RT_20CNT",
RatingPlanId: "RP_1001",
MatchedDestId: "1002",
MatchedSubject: "1001",
MatchedPrefix: "1001",
@@ -402,7 +402,7 @@ func TestCallcostCallCostToDataCost(t *testing.T) {
MatchedSubject: "1001",
MatchedPrefix: "1001",
MatchedDestId: "1002",
RatingPlanId: "RT_20CNT",
RatingPlanId: "RP_1001",
},
},
}
@@ -495,7 +495,7 @@ func TestCallcostAsJSON(t *testing.T) {
TimeEnd: time.Date(2021, 1, 1, 10, 30, 0, 0, time.Local),
ratingInfo: &RatingInfo{
MatchedSubject: "1001",
RatingPlanId: "RT_20CNT",
RatingPlanId: "RP_1001",
MatchedPrefix: "1001",
MatchedDestId: "1002",
ActivationTime: time.Date(2021, 1, 1, 10, 30, 0, 0, time.Local),
@@ -558,7 +558,7 @@ func TestCallcostAsJSON(t *testing.T) {
},
Weight: 10,
},
RatingPlanId: "RT_20CNT",
RatingPlanId: "RP_1001",
MatchedDestId: "1002",
MatchedSubject: "1001",
MatchedPrefix: "1001",
@@ -611,7 +611,7 @@ func TestCallcostAsJSON(t *testing.T) {
},
}
exp := `{"Category":"call","Tenant":"cgrates.org","Subject":"1001","Account":"1001","Destination":"1002","ToR":"*voice","Cost":10,"Timespans":[{"TimeStart":"2021-01-01T10:25:00+02:00","TimeEnd":"2021-01-01T10:30:00+02:00","Cost":15,"RateInterval":{"Timing":{"ID":"ritTimingID","Years":null,"Months":null,"MonthDays":null,"WeekDays":null,"StartTime":"","EndTime":""},"Rating":{"ConnectFee":15,"RoundingMethod":"up","RoundingDecimals":1,"MaxCost":100,"MaxCostStrategy":"*disconnect","Rates":[{"GroupIntervalStart":30000000000,"Value":5,"RateIncrement":60000000000,"RateUnit":60000000000},{"GroupIntervalStart":60000000000,"Value":5,"RateIncrement":1000000000,"RateUnit":60000000000}]},"Weight":10},"DurationIndex":10,"Increments":[{"Duration":24000000000,"Cost":20,"BalanceInfo":{"Unit":{"UUID":"unitUUID2","ID":"1001","Value":10,"DestinationID":"1002","Consumed":20,"ToR":"*voice","RateInterval":{"Timing":{"ID":"","Years":null,"Months":null,"MonthDays":null,"WeekDays":null,"StartTime":"","EndTime":""},"Rating":{"ConnectFee":0,"RoundingMethod":"","RoundingDecimals":0,"MaxCost":0,"MaxCostStrategy":"","Rates":null},"Weight":15}},"Monetary":null,"AccountID":""},"CompressFactor":2}],"RoundIncrement":{"Duration":12000000000,"Cost":15,"BalanceInfo":{"Unit":{"UUID":"unitUUID1","ID":"1001","Value":10,"DestinationID":"1002","Consumed":20,"ToR":"*voice","RateInterval":{"Timing":{"ID":"","Years":null,"Months":null,"MonthDays":null,"WeekDays":null,"StartTime":"","EndTime":""},"Rating":{"ConnectFee":0,"RoundingMethod":"","RoundingDecimals":0,"MaxCost":0,"MaxCostStrategy":"","Rates":null},"Weight":10}},"Monetary":null,"AccountID":""},"CompressFactor":2},"MatchedSubject":"1001","MatchedPrefix":"1001","MatchedDestId":"1002","RatingPlanId":"RT_20CNT","CompressFactor":5}],"RatedUsage":0,"AccountSummary":null}`
exp := `{"Category":"call","Tenant":"cgrates.org","Subject":"1001","Account":"1001","Destination":"1002","ToR":"*voice","Cost":10,"Timespans":[{"TimeStart":"2021-01-01T10:25:00+02:00","TimeEnd":"2021-01-01T10:30:00+02:00","Cost":15,"RateInterval":{"Timing":{"ID":"ritTimingID","Years":null,"Months":null,"MonthDays":null,"WeekDays":null,"StartTime":"","EndTime":""},"Rating":{"ConnectFee":15,"RoundingMethod":"up","RoundingDecimals":1,"MaxCost":100,"MaxCostStrategy":"*disconnect","Rates":[{"GroupIntervalStart":30000000000,"Value":5,"RateIncrement":60000000000,"RateUnit":60000000000},{"GroupIntervalStart":60000000000,"Value":5,"RateIncrement":1000000000,"RateUnit":60000000000}]},"Weight":10},"DurationIndex":10,"Increments":[{"Duration":24000000000,"Cost":20,"BalanceInfo":{"Unit":{"UUID":"unitUUID2","ID":"1001","Value":10,"DestinationID":"1002","Consumed":20,"ToR":"*voice","RateInterval":{"Timing":{"ID":"","Years":null,"Months":null,"MonthDays":null,"WeekDays":null,"StartTime":"","EndTime":""},"Rating":{"ConnectFee":0,"RoundingMethod":"","RoundingDecimals":0,"MaxCost":0,"MaxCostStrategy":"","Rates":null},"Weight":15}},"Monetary":null,"AccountID":""},"CompressFactor":2}],"RoundIncrement":{"Duration":12000000000,"Cost":15,"BalanceInfo":{"Unit":{"UUID":"unitUUID1","ID":"1001","Value":10,"DestinationID":"1002","Consumed":20,"ToR":"*voice","RateInterval":{"Timing":{"ID":"","Years":null,"Months":null,"MonthDays":null,"WeekDays":null,"StartTime":"","EndTime":""},"Rating":{"ConnectFee":0,"RoundingMethod":"","RoundingDecimals":0,"MaxCost":0,"MaxCostStrategy":"","Rates":null},"Weight":10}},"Monetary":null,"AccountID":""},"CompressFactor":2},"MatchedSubject":"1001","MatchedPrefix":"1001","MatchedDestId":"1002","RatingPlanId":"RP_1001","CompressFactor":5}],"RatedUsage":0,"AccountSummary":null}`
rcv := cc.AsJSON()
if rcv != exp {
@@ -629,7 +629,7 @@ func TestCallcostUpdateCost(t *testing.T) {
TimeEnd: time.Date(2021, 1, 1, 10, 30, 0, 0, time.Local),
ratingInfo: &RatingInfo{
MatchedSubject: "1001",
RatingPlanId: "RT_20CNT",
RatingPlanId: "RP_1001",
MatchedPrefix: "1001",
MatchedDestId: "1002",
ActivationTime: time.Date(2021, 1, 1, 10, 30, 0, 0, time.Local),
@@ -692,7 +692,7 @@ func TestCallcostUpdateCost(t *testing.T) {
},
Weight: 10,
},
RatingPlanId: "RT_20CNT",
RatingPlanId: "RP_1001",
MatchedDestId: "1002",
MatchedSubject: "1001",
MatchedPrefix: "1001",
@@ -776,7 +776,7 @@ func TestCallcostGetStartTime(t *testing.T) {
TimeEnd: time.Date(2021, 1, 1, 10, 30, 0, 0, time.Local),
ratingInfo: &RatingInfo{
MatchedSubject: "1001",
RatingPlanId: "RT_20CNT",
RatingPlanId: "RP_1001",
MatchedPrefix: "1001",
MatchedDestId: "1002",
ActivationTime: time.Date(2021, 1, 1, 10, 30, 0, 0, time.Local),
@@ -839,7 +839,7 @@ func TestCallcostGetStartTime(t *testing.T) {
},
Weight: 10,
},
RatingPlanId: "RT_20CNT",
RatingPlanId: "RP_1001",
MatchedDestId: "1002",
MatchedSubject: "1001",
MatchedPrefix: "1001",

349
engine/calldesc_test.go
View File

@@ -2036,6 +2036,355 @@ func TestCalldescFieldAsStringNilFieldPath(t *testing.T) {
}
}
func TestCalldescSetRoundingDecimals(t *testing.T) {
exp := 6
SetRoundingDecimals(6)
if globalRoundingDecimals != exp {
t.Errorf("\nexpected: <%+v>, \nreceived: <%+v>", exp, globalRoundingDecimals)
}
}
func TestCalldescSetRpSubjectPrefixMatching(t *testing.T) {
SetRpSubjectPrefixMatching(false)
if rpSubjectPrefixMatching != false {
t.Errorf("\nexpected: <%+v>, \nreceived: <%+v>",
false, rpSubjectPrefixMatching)
}
}
func TestCalldescNewCallDescriptorFromCGREventNoAccount(t *testing.T) {
cgrEv := &utils.CGREvent{
Event: map[string]interface{}{
"testKey": 5,
},
}
timezone := ""
experr := utils.ErrNotFound
exp := &CallDescriptor{}
rcv, err := NewCallDescriptorFromCGREvent(cgrEv, timezone)
if err == nil || err != experr {
t.Errorf("\nexpected: <%+v>, \nreceived: <%+v>", experr, err)
}
if !reflect.DeepEqual(rcv, exp) {
t.Errorf("\nexpected: <%+v>, \nreceived: <%+v>", exp, rcv)
}
}
func TestCalldescNewCallDescriptorFromCGREventNoDestination(t *testing.T) {
cgrEv := &utils.CGREvent{
Event: map[string]interface{}{
utils.Category: "catField",
utils.AccountField: "accField",
},
}
timezone := ""
experr := utils.ErrNotFound
var exp *CallDescriptor
rcv, err := NewCallDescriptorFromCGREvent(cgrEv, timezone)
if err == nil || err != experr {
t.Errorf("\nexpected: <%+v>, \nreceived: <%+v>", experr, err)
}
if !reflect.DeepEqual(rcv, exp) {
t.Errorf("\nexpected: <%+v>, \nreceived: <%+v>", exp, rcv)
}
}
func TestCalldescNewCallDescriptorFromCGREventNoTimeStart(t *testing.T) {
cgrEv := &utils.CGREvent{
Event: map[string]interface{}{
utils.Category: "catField",
utils.AccountField: "accField",
utils.Destination: "destField",
},
}
timezone := ""
experr := utils.ErrNotFound
var exp *CallDescriptor
rcv, err := NewCallDescriptorFromCGREvent(cgrEv, timezone)
if err == nil || err != experr {
t.Errorf("\nexpected: <%+v>, \nreceived: <%+v>", experr, err)
}
if !reflect.DeepEqual(rcv, exp) {
t.Errorf("\nexpected: <%+v>, \nreceived: <%+v>", exp, rcv)
}
}
func TestCalldescNewCallDescriptorFromCGREventInvalidAnswerTime(t *testing.T) {
cgrEv := &utils.CGREvent{
Event: map[string]interface{}{
utils.Category: "catField",
utils.AccountField: "accField",
utils.Destination: "destField",
utils.SetupTime: time.Date(2021, 1, 1, 23, 59, 59, 0, time.Local),
utils.AnswerTime: 5,
},
}
timezone := "UTC"
experr := "cannot convert field: 5 to time.Time"
var exp *CallDescriptor
rcv, err := NewCallDescriptorFromCGREvent(cgrEv, timezone)
if err == nil || err.Error() != experr {
t.Errorf("\nexpected: <%+v>, \nreceived: <%+v>", experr, err)
}
if !reflect.DeepEqual(rcv, exp) {
t.Errorf("\nexpected: <%+v>, \nreceived: <%+v>", exp, rcv)
}
}
func TestCalldescNewCallDescriptorFromCGREventNoUsage(t *testing.T) {
cgrEv := &utils.CGREvent{
Event: map[string]interface{}{
utils.Category: "catField",
utils.AccountField: "accField",
utils.Destination: "destField",
utils.SetupTime: time.Date(2021, 1, 1, 23, 59, 59, 0, time.Local),
utils.AnswerTime: time.Date(2021, 1, 5, 23, 59, 59, 0, time.Local),
},
}
timezone := "UTC"
experr := utils.ErrNotFound
var exp *CallDescriptor
rcv, err := NewCallDescriptorFromCGREvent(cgrEv, timezone)
if err == nil || err != experr {
t.Errorf("\nexpected: <%+v>, \nreceived: <%+v>", experr, err)
}
if !reflect.DeepEqual(rcv, exp) {
t.Errorf("\nexpected: <%+v>, \nreceived: <%+v>", exp, rcv)
}
}
func TestCalldescNewCallDescriptorFromCGREvent(t *testing.T) {
cgrEv := &utils.CGREvent{
Event: map[string]interface{}{
utils.Category: "catField",
utils.AccountField: "accField",
utils.Destination: "destField",
utils.SetupTime: time.Date(2021, 1, 1, 23, 59, 59, 0, time.Local),
utils.AnswerTime: time.Date(2021, 1, 5, 23, 59, 59, 0, time.Local),
utils.Usage: 100,
utils.ToR: utils.MetaVoice,
},
Tenant: "cgrates.org",
}
timezone := "UTC"
exp := &CallDescriptor{
Category: "catField",
Subject: "accField",
Account: "accField",
Destination: "destField",
TimeStart: time.Date(2021, 1, 5, 23, 59, 59, 0, time.Local),
TimeEnd: time.Date(2021, 1, 5, 23, 59, 59, 100, time.Local),
ToR: utils.MetaVoice,
Tenant: "cgrates.org",
}
rcv, err := NewCallDescriptorFromCGREvent(cgrEv, timezone)
if err != nil {
t.Errorf("\nexpected: <%+v>, \nreceived: <%+v>", nil, err)
}
if !reflect.DeepEqual(rcv, exp) {
t.Errorf("\nexpected: <%+v>, \nreceived: <%+v>", exp, rcv)
}
}
func TestCalldescAsCGREvent(t *testing.T) {
cd := &CallDescriptor{
Category: "catField",
Subject: "accField",
Account: "accField",
Destination: "destField",
TimeStart: time.Date(2021, 1, 5, 23, 59, 59, 0, time.Local),
TimeEnd: time.Date(2021, 1, 5, 23, 59, 59, 100, time.Local),
ToR: utils.MetaVoice,
Tenant: "cgrates.org",
ExtraFields: map[string]string{
"eventKey1": "eventValue1",
"eventKey2": "eventValue2",
"eventKey3": "eventValue3",
},
}
opts := make(map[string]interface{})
exp := &utils.CGREvent{
Event: map[string]interface{}{
utils.Category: "catField",
utils.Subject: "accField",
utils.AccountField: "accField",
utils.Destination: "destField",
utils.AnswerTime: time.Date(2021, 1, 5, 23, 59, 59, 0, time.Local),
utils.Usage: 100 * time.Nanosecond,
utils.ToR: utils.MetaVoice,
utils.Tenant: "cgrates.org",
"eventKey1": "eventValue1",
"eventKey2": "eventValue2",
"eventKey3": "eventValue3",
},
APIOpts: opts,
Tenant: "cgrates.org",
}
rcv := cd.AsCGREvent(opts)
exp.ID = rcv.ID
if !reflect.DeepEqual(rcv, exp) {
t.Errorf("\nexpected: <%+v>, \nreceived: <%+v>", exp, rcv)
}
}
func TestCalldescAddRatingInfo(t *testing.T) {
cd := &CallDescriptor{
Category: "call",
Tenant: "cgrates.org",
Subject: "1001",
Account: "1001",
Destination: "1002",
}
ris := []*RatingInfo{
{
MatchedSubject: "1001",
RatingPlanId: "RP_1001",
MatchedPrefix: "1001",
MatchedDestId: "1002",
ActivationTime: time.Date(2021, 1, 5, 23, 59, 59, 0, time.Local),
RateIntervals: RateIntervalList{
{
Rating: &RIRate{
ConnectFee: 0.4,
tag: "tag",
RoundingMethod: "*up",
RoundingDecimals: 4,
MaxCost: 100,
MaxCostStrategy: "*disconnect",
Rates: RateGroups{
{
Value: 10,
RateIncrement: 60,
RateUnit: 60,
},
},
},
},
},
FallbackKeys: []string{"key1", "key2"},
},
{
MatchedSubject: "1002",
RatingPlanId: "RP_1002",
MatchedPrefix: "1002",
MatchedDestId: "1003",
ActivationTime: time.Date(2021, 1, 5, 23, 59, 59, 0, time.Local),
RateIntervals: RateIntervalList{
{
Rating: &RIRate{
ConnectFee: 0.3,
tag: "tag",
RoundingMethod: "*up",
RoundingDecimals: 7,
MaxCost: 150,
MaxCostStrategy: "*disconnect",
Rates: RateGroups{
{
Value: 10,
RateIncrement: 1,
RateUnit: 60,
},
},
},
},
},
FallbackKeys: []string{"key3"},
},
}
exp := &CallDescriptor{
Category: "call",
Tenant: "cgrates.org",
Subject: "1001",
Account: "1001",
Destination: "1002",
RatingInfos: RatingInfos{
{
MatchedSubject: "1001",
RatingPlanId: "RP_1001",
MatchedPrefix: "1001",
MatchedDestId: "1002",
ActivationTime: time.Date(2021, 1, 5, 23, 59, 59, 0, time.Local),
RateIntervals: RateIntervalList{
{
Rating: &RIRate{
ConnectFee: 0.4,
tag: "tag",
RoundingMethod: "*up",
RoundingDecimals: 4,
MaxCost: 100,
MaxCostStrategy: "*disconnect",
Rates: RateGroups{
{
Value: 10,
RateIncrement: 60,
RateUnit: 60,
},
},
},
},
},
FallbackKeys: []string{"key1", "key2"},
},
{
MatchedSubject: "1002",
RatingPlanId: "RP_1002",
MatchedPrefix: "1002",
MatchedDestId: "1003",
ActivationTime: time.Date(2021, 1, 5, 23, 59, 59, 0, time.Local),
RateIntervals: RateIntervalList{
{
Rating: &RIRate{
ConnectFee: 0.3,
tag: "tag",
RoundingMethod: "*up",
RoundingDecimals: 7,
MaxCost: 150,
MaxCostStrategy: "*disconnect",
Rates: RateGroups{
{
Value: 10,
RateIncrement: 1,
RateUnit: 60,
},
},
},
},
},
FallbackKeys: []string{"key3"},
},
},
}
cd.AddRatingInfo(ris[0], ris[1])
if !reflect.DeepEqual(cd, exp) {
t.Errorf("\nexpected: <%+v>, \nreceived: <%+v>", exp, cd)
}
}
/*************** BENCHMARKS ********************/
func BenchmarkStorageGetting(b *testing.B) {
b.StopTimer()