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

Add verification to onEviction test in ers

Browse Source
This commit is contained in:
ionutboangiu
2021-07-09 17:47:59 +03:00
committed by Dan Christian Bogos
parent 34d93e2dd7
commit fd5a3f30ae
1 changed files with 39 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

45
ers/ers_it_test.go
View File

@@ -24,6 +24,7 @@ import (
"errors"
"log"
"os"
"path/filepath"
"reflect"
"strings"
"testing"
@@ -771,6 +772,9 @@ func TestErsOnEvictedMetaDumpToFileOK(t *testing.T) {
}
defer os.RemoveAll(dirPath)
val1 := config.NewRSRParsersMustCompile("TestTenant", ",")
val2 := config.NewRSRParsersMustCompile("1001", ",")
val3 := config.NewRSRParsersMustCompile("1002", ",")
value := &erEvents{
events: []*utils.CGREvent{
{
@@ -788,8 +792,31 @@ func TestErsOnEvictedMetaDumpToFileOK(t *testing.T) {
utils.PartialCacheActionOpt: utils.MetaDumpToFile,
utils.PartialPathOpt: dirPath,
},
CacheDumpFields: []*config.FCTemplate{
{
Tag: "Tenant",
Type: utils.MetaConstant,
Path: "*exp.Tenant",
Value: val1,
},
{
Tag: "Account",
Type: utils.MetaConstant,
Path: "*exp.Account",
Value: val2,
},
{
Tag: "Destination",
Type: utils.MetaConstant,
Path: "*exp.Destination",
Value: val3,
},
},
},
}
for _, field := range value.rdrCfg.CacheDumpFields {
field.ComputePath()
}
cfg := config.NewDefaultCGRConfig()
data := engine.NewInternalDB(nil, nil, true)
dm := engine.NewDataManager(data, cfg.CacheCfg(), nil)
@@ -799,13 +826,19 @@ func TestErsOnEvictedMetaDumpToFileOK(t *testing.T) {
rdrEvents: make(chan *erEvent, 1),
filterS: fltrS,
}
erS.onEvicted("ID", value)
expBody := "TestTenant,1001,1002\n"
erS.onEvicted("FileID", value)
// rcv, err := os.ReadFile(filepath.Join(dirPath, "ID.*.*"))
// if err != nil {
// t.Error(err)
// }
// fmt.Println(rcv)
path := filepath.Join(dirPath, "FileID.*.tmp")
if match, err := filepath.Glob(path); err != nil {
t.Error(err)
} else if len(match) != 1 {
t.Error("expected exactly one file")
} else if body, err := os.ReadFile(match[0]); err != nil {
t.Error(err)
} else if expBody != string(body) {
t.Errorf("expected: %q\nreceived: %q", expBody, string(body))
}
}
func TestErsOnEvictedMetaDumpToFileCSVWriteErr(t *testing.T) {