uppal/cgrates
1
0
Fork 1
mirror of https://github.com/cgrates/cgrates.git synced 2026-02-14 20:59:53 +05:00
Code Issues Packages Projects Releases Wiki Activity

Fix tests after stats change

Browse Source
This commit is contained in:
ionutboangiu
2022-04-13 18:41:06 +03:00
committed by Dan Christian Bogos
parent bb41017266
commit 39b0c33ed8
6 changed files with 24 additions and 23 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
apis/actions_it_test.go
View File

@@ -549,10 +549,10 @@ func testActionsStatProcessEvent(t *testing.T) {
ID: "StatsEventTest",
Event: map[string]interface{}{
utils.AccountField: "1001",
utils.Usage: 30 * time.Second,
},
APIOpts: map[string]interface{}{
utils.OptsStatsProfileIDs: []string{"SQ_ID"},
utils.MetaUsage: 30 * time.Second,
},
}
expected := []string{"SQ_ID"}

4
apis/stats_it_test.go
View File

@@ -816,14 +816,14 @@ func testStatsProcessEvent(t *testing.T) {
ID: "StatsEventTest",
Event: map[string]interface{}{
utils.AccountField: "1001",
utils.Usage: 30 * time.Second,
},
APIOpts: map[string]interface{}{
utils.OptsStatsProfileIDs: []string{"SQ_3"},
utils.MetaUsage: 30 * time.Second,
},
}
expected := []string{"SQ_3"}
expBody := `{"*opts":{"*actProfileIDs":["actPrfID"],"*eventType":"StatUpdate","*statsProfileIDs":["SQ_3"],"*thdProfileIDs":["THD_ID"]},"*req":{"*tcd":30000000000,"EventType":"StatUpdate","StatID":"SQ_3"}}`
expBody := `{"*opts":{"*actProfileIDs":["actPrfID"],"*eventType":"StatUpdate","*statsProfileIDs":["SQ_3"],"*thdProfileIDs":["THD_ID"],"*usage":30000000000},"*req":{"*tcd":30000000000,"EventType":"StatUpdate","StatID":"SQ_3"}}`
var reply []string
if err := sqRPC.Call(context.Background(), utils.StatSv1ProcessEvent,
args, &reply); err != nil {

18
engine/statmetrics_test.go
View File

@@ -1584,7 +1584,7 @@ func TestPDDGetStringValue(t *testing.T) {
ev5 := &utils.CGREvent{Tenant: "cgrates.org", ID: "EVENT_5",
Event: map[string]interface{}{utils.PDD: 10 * time.Second},
}
pdd.AddEvent(ev4.ID, utils.MapStorage{utils.MetaOpts: ev4.APIOpts, utils.MetaReq: ev.Event})
pdd.AddEvent(ev4.ID, utils.MapStorage{utils.MetaOpts: ev4.APIOpts, utils.MetaReq: ev4.Event})
if strVal := pdd.GetStringValue(config.CgrConfig().GeneralCfg().RoundingDecimals); strVal != utils.NotAvailable {
t.Errorf("wrong pdd value: %s", strVal)
}
@@ -1744,7 +1744,7 @@ func TestPDDGetValue(t *testing.T) {
utils.MetaStartTime: time.Date(2014, 7, 14, 14, 25, 0, 0, time.UTC),
utils.MetaUsage: 8 * time.Second}}
ev3 := &utils.CGREvent{Tenant: "cgrates.org", ID: "EVENT_3"}
if err := pdd.AddEvent(ev2.ID, utils.MapStorage{utils.MetaOpts: ev2.APIOpts, utils.MetaReq: ev.Event}); err != nil {
if err := pdd.AddEvent(ev2.ID, utils.MapStorage{utils.MetaOpts: ev2.APIOpts, utils.MetaReq: ev2.Event}); err != nil {
t.Error(err)
}
if err := pdd.AddEvent(ev3.ID, utils.MapStorage{utils.MetaOpts: ev3.APIOpts}); err == nil || err.Error() != "NOT_FOUND:PDD" {
@@ -1909,8 +1909,8 @@ func TestDDCGetStringValue(t *testing.T) {
Event: map[string]interface{}{utils.Destination: "1001"},
APIOpts: map[string]interface{}{
utils.MetaStartTime: time.Date(2014, 7, 14, 14, 25, 0, 0, time.UTC)}}
ddc.AddEvent(ev2.ID, utils.MapStorage{utils.MetaOpts: ev2.APIOpts, utils.MetaReq: ev.Event})
ddc.AddEvent(ev3.ID, utils.MapStorage{utils.MetaOpts: ev3.APIOpts, utils.MetaReq: ev.Event})
ddc.AddEvent(ev2.ID, utils.MapStorage{utils.MetaOpts: ev2.APIOpts, utils.MetaReq: ev2.Event})
ddc.AddEvent(ev3.ID, utils.MapStorage{utils.MetaOpts: ev3.APIOpts, utils.MetaReq: ev3.Event})
if strVal := ddc.GetStringValue(config.CgrConfig().GeneralCfg().RoundingDecimals); strVal != "2" {
t.Errorf("wrong ddc value: %s", strVal)
}
@@ -1958,11 +1958,11 @@ func TestDDCGetFloat64Value(t *testing.T) {
utils.MetaStartTime: time.Date(2015, 7, 14, 14, 25, 0, 0, time.UTC),
},
}
ddc.AddEvent(ev4.ID, utils.MapStorage{utils.MetaOpts: ev4.APIOpts, utils.MetaReq: ev.Event})
ddc.AddEvent(ev4.ID, utils.MapStorage{utils.MetaOpts: ev4.APIOpts, utils.MetaReq: ev4.Event})
if strVal := ddc.GetValue(); strVal.Compare(utils.NewDecimalFromFloat64(2)) != 0 {
t.Errorf("wrong ddc value: %v", strVal)
}
ddc.AddEvent(ev5.ID, utils.MapStorage{utils.MetaOpts: ev5.APIOpts, utils.MetaReq: ev.Event})
ddc.AddEvent(ev5.ID, utils.MapStorage{utils.MetaOpts: ev5.APIOpts, utils.MetaReq: ev5.Event})
if strVal := ddc.GetValue(); strVal.Compare(utils.NewDecimalFromFloat64(3)) != 0 {
t.Errorf("wrong ddc value: %v", strVal)
}
@@ -2800,9 +2800,9 @@ func TestStatDistinctCompress(t *testing.T) {
Event: map[string]interface{}{utils.Destination: "1001"}}
ev3 := &utils.CGREvent{Tenant: "cgrates.org", ID: "EVENT_3",
Event: map[string]interface{}{utils.Destination: "1002"}}
ddc.AddEvent(ev1.ID, utils.MapStorage{utils.MetaEvent: ev1.Event})
ddc.AddEvent(ev2.ID, utils.MapStorage{utils.MetaEvent: ev2.Event})
ddc.AddEvent(ev3.ID, utils.MapStorage{utils.MetaEvent: ev3.Event})
ddc.AddEvent(ev1.ID, utils.MapStorage{utils.MetaReq: ev1.Event})
ddc.AddEvent(ev2.ID, utils.MapStorage{utils.MetaReq: ev2.Event})
ddc.AddEvent(ev3.ID, utils.MapStorage{utils.MetaReq: ev3.Event})
expIDs := []string{"EVENT_1", "EVENT_3"}
rply := ddc.Compress(10, "EVENT_3")
sort.Strings(rply)

16
general_tests/attributes_it_test.go
View File

@@ -332,9 +332,11 @@ func testAttributeSProcessEventWithStat(t *testing.T) {
ID: "event1",
Event: map[string]interface{}{
utils.AccountField: "1001",
utils.AnswerTime: time.Date(2014, 7, 14, 14, 25, 0, 0, time.UTC),
utils.Usage: 11 * time.Second,
utils.Cost: 10.0,
},
APIOpts: map[string]interface{}{
utils.MetaStartTime: time.Date(2014, 7, 14, 14, 25, 0, 0, time.UTC),
utils.MetaUsage: 11 * time.Second,
utils.MetaCost: 10,
},
}
if err := attrRPC.Call(context.Background(), utils.StatSv1ProcessEvent, &ev1, &reply); err != nil {
@@ -349,9 +351,11 @@ func testAttributeSProcessEventWithStat(t *testing.T) {
ID: "event2",
Event: map[string]interface{}{
utils.AccountField: "1001",
utils.AnswerTime: time.Date(2014, 7, 14, 14, 25, 0, 0, time.UTC),
utils.Usage: 11 * time.Second,
utils.Cost: 10.5,
},
APIOpts: map[string]interface{}{
utils.MetaStartTime: time.Date(2014, 7, 14, 14, 25, 0, 0, time.UTC),
utils.MetaUsage: 11 * time.Second,
utils.MetaCost: 10.5,
},
}
if err := attrRPC.Call(context.Background(), utils.StatSv1ProcessEvent, &ev1, &reply); err != nil {

6
general_tests/route_stats_it_test.go
View File

@@ -131,7 +131,6 @@ func testV1RtStatsProcessStatsValid(t *testing.T) {
utils.AccountField: "1010",
utils.Destination: "1021",
utils.Category: "call",
utils.Usage: "1m20s",
},
APIOpts: map[string]interface{}{
utils.MetaCost: 1.8,
@@ -160,11 +159,10 @@ func testV1RtStatsProcessStatsNotAnswered(t *testing.T) {
Event: map[string]interface{}{
utils.AccountField: "1010",
utils.Destination: "1021",
utils.Usage: "26s",
},
APIOpts: map[string]interface{}{
utils.MetaCost: 1.8,
utils.MetaUsage: "1m20s",
utils.MetaUsage: "26s",
},
}
// we will process this two times
@@ -199,7 +197,7 @@ func testV1RtStatsProcessStatsNotAnswered(t *testing.T) {
},
APIOpts: map[string]interface{}{
utils.MetaCost: 1.8,
utils.MetaUsage: "1m20s",
utils.MetaUsage: "50s",
utils.MetaStartTime: "2022-04-01T05:00:00Z",
},
}

1
general_tests/routes_cases_it_test.go
View File

@@ -744,7 +744,6 @@ func testV1RtsCasesSortingRoutesLCSetStatsAndResForMatching(t *testing.T) {
Tenant: "cgrates.org",
ID: "event1",
Event: map[string]interface{}{
utils.Usage: "2m30s",
utils.AccountField: "1004",
utils.Category: "vendor2",
},