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

coverage tests at engine

Browse Source
This commit is contained in:
gezimbll
2022-11-21 10:57:43 -05:00
committed by Dan Christian Bogos
parent aebb5edcb0
commit 6e024ae79a
1 changed files with 162 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

162
engine/responder_test.go
View File

@@ -468,3 +468,165 @@ func TestResponderGetMaxSessionTimeMaxUsageVOICE(t *testing.T) {
t.Errorf("Expected %+v, received : %+v", utils.ErrMaxUsageExceeded, err)
}
}
func TestResponderGetCost(t *testing.T) {
Cache.Clear(nil)
cfg := config.NewDefaultCGRConfig()
cfg.CacheCfg().Partitions[utils.CacheRPCResponses].Limit = 1
db := NewInternalDB(nil, nil, true, cfg.DataDbCfg().Items)
dm := NewDataManager(db, cfg.CacheCfg(), nil)
Cache = NewCacheS(cfg, dm, nil)
config.SetCgrConfig(cfg)
rs := &Responder{
Timezone: "UTC",
FilterS: &FilterS{
cfg: cfg,
dm: dm,
connMgr: nil,
},
}
arg := &CallDescriptorWithAPIOpts{
CallDescriptor: &CallDescriptor{
CgrID: "cgrid",
Category: "category",
Tenant: "tenant",
Subject: "subject",
Account: "acount",
Destination: "uk",
},
APIOpts: map[string]interface{}{},
}
reply := &CallCost{
Category: "category",
Tenant: "tenant",
Subject: "subject",
Account: "acount",
Destination: "uk",
}
if err = rs.GetCost(arg, reply); err != nil {
t.Error(err)
}
exp := &utils.CachedRPCResponse{
Result: reply,
Error: nil,
}
rcv, has := Cache.Get(utils.CacheRPCResponses, utils.ConcatenatedKey(utils.ResponderGetCost, arg.CgrID))
if !has {
t.Error("has no value")
}
if !reflect.DeepEqual(rcv, exp) {
t.Errorf("expected %+v,received %+v", utils.ToJSON(rcv), utils.ToJSON(exp))
}
}
func TestResponderGetCostSet(t *testing.T) {
Cache.Clear(nil)
cfg := config.NewDefaultCGRConfig()
cfg.CacheCfg().Partitions[utils.CacheRPCResponses].Limit = 1
db := NewInternalDB(nil, nil, true, cfg.DataDbCfg().Items)
dm := NewDataManager(db, cfg.CacheCfg(), nil)
Cache = NewCacheS(cfg, dm, nil)
config.SetCgrConfig(cfg)
rs := &Responder{
Timezone: "UTC",
FilterS: &FilterS{
cfg: cfg,
dm: dm,
connMgr: nil,
},
}
arg := &CallDescriptorWithAPIOpts{
CallDescriptor: &CallDescriptor{
CgrID: "cgrid",
Category: "category",
Tenant: "tenant",
Subject: "subject",
Account: "acount",
Destination: "uk",
},
APIOpts: map[string]interface{}{},
}
reply := &CallCost{
Category: "category",
Tenant: "tenant",
Subject: "subject",
Account: "acount",
Destination: "uk",
}
Cache.Set(utils.CacheRPCResponses, utils.ConcatenatedKey(utils.ResponderGetCost, arg.CgrID),
&utils.CachedRPCResponse{Result: reply, Error: nil},
nil, true, utils.NonTransactional)
if err = rs.GetCost(arg, reply); err != nil {
t.Error(err)
}
exp := &utils.CachedRPCResponse{
Result: reply,
Error: nil,
}
rcv, has := Cache.Get(utils.CacheRPCResponses, utils.ConcatenatedKey(utils.ResponderGetCost, arg.CgrID))
if !has {
t.Error("has no value")
}
if !reflect.DeepEqual(rcv, exp) {
t.Errorf("expected %+v,received %+v", utils.ToJSON(rcv), utils.ToJSON(exp))
}
}
func TestResponderDebit(t *testing.T) {
Cache.Clear(nil)
cfg := config.NewDefaultCGRConfig()
cfg.CacheCfg().Partitions[utils.CacheRPCResponses].Limit = 1
db := NewInternalDB(nil, nil, true, cfg.DataDbCfg().Items)
dm := NewDataManager(db, cfg.CacheCfg(), nil)
Cache = NewCacheS(cfg, dm, nil)
config.SetCgrConfig(cfg)
rs := &Responder{
Timezone: "UTC",
FilterS: &FilterS{
cfg: cfg,
dm: dm,
connMgr: nil,
},
MaxComputedUsage: map[string]time.Duration{},
}
arg := &CallDescriptorWithAPIOpts{
CallDescriptor: &CallDescriptor{
CgrID: "cgrid",
Category: "category",
Tenant: "tenant",
Subject: "subject",
Account: "acount",
Destination: "uk",
ToR: "tor",
TimeStart: time.Date(2022, 12, 1, 12, 0, 0, 0, time.UTC),
TimeEnd: time.Date(2022, 12, 1, 12, 0, 0, 0, time.UTC),
},
APIOpts: map[string]interface{}{
"tor": 30 * time.Minute,
},
}
reply := &CallCost{
Category: "category",
Tenant: "tenant",
Subject: "subject",
Account: "acount",
Destination: "uk",
}
if err := rs.Debit(arg, reply); err == nil {
t.Error(err)
}
}