From 732cce24a98cf54776bcc2e9d9fc7381ea636c2d Mon Sep 17 00:00:00 2001 From: porosnicuadrian Date: Tue, 6 Jul 2021 13:30:53 +0300 Subject: [PATCH] Finished testing all prefixes for AgentRequest --- agents/agentreq_test.go | 85 +++++++++++++++++++++++++++++++++++++++++ 1 file changed, 85 insertions(+) diff --git a/agents/agentreq_test.go b/agents/agentreq_test.go index 5e2c13d43..05766d767 100644 --- a/agents/agentreq_test.go +++ b/agents/agentreq_test.go @@ -1015,6 +1015,91 @@ func TestAgReqFieldAsInterfaceForOneFldPathCgrReq(t *testing.T) { } } +func TestAgReqFieldAsInterfaceForOneFldPathVars(t *testing.T) { + cfg := config.NewDefaultCGRConfig() + dm := engine.NewDataManager(engine.NewInternalDB(nil, nil, true), + config.CgrConfig().CacheCfg(), nil) + filterS := engine.NewFilterS(cfg, nil, dm) + dN := &utils.DataNode{ + Type: utils.NMMapType, + Map: map[string]*utils.DataNode{ + "Name": utils.NewLeafNode("1001"), + "ExtraFields": { + Type: utils.NMMapType, + Map: map[string]*utils.DataNode{ + "Usage": utils.NewLeafNode("20m"), + }, + }, + }, + } + aqReq := NewAgentRequest(nil, dN, nil, nil, nil, nil, + "cgrates.org", utils.EmptyString, filterS, nil) + + path := []string{utils.MetaVars} + if rply, err := aqReq.FieldAsInterface(path); err != nil { + t.Error(err) + } else if !reflect.DeepEqual(dN, rply) { + t.Errorf("Expected %+v, received %+v", dN, rply) + } +} + +func TestAgReqFieldAsInterfaceForOneFldPathCgrReply(t *testing.T) { + cfg := config.NewDefaultCGRConfig() + dm := engine.NewDataManager(engine.NewInternalDB(nil, nil, true), + config.CgrConfig().CacheCfg(), nil) + filterS := engine.NewFilterS(cfg, nil, dm) + dN := &utils.DataNode{ + Type: utils.NMMapType, + Map: map[string]*utils.DataNode{ + "Name": utils.NewLeafNode("1001"), + "ExtraFields": { + Type: utils.NMMapType, + Map: map[string]*utils.DataNode{ + "Usage": utils.NewLeafNode("20m"), + }, + }, + }, + } + aqReq := NewAgentRequest(nil, nil, dN, nil, nil, nil, + "cgrates.org", utils.EmptyString, filterS, nil) + + path := []string{utils.MetaCgrep} + if rply, err := aqReq.FieldAsInterface(path); err != nil { + t.Error(err) + } else if !reflect.DeepEqual(dN, rply) { + t.Errorf("Expected %+v, received %+v", dN, rply) + } +} + +func TestAgReqFieldAsInterfaceForOneFldPathTmp(t *testing.T) { + cfg := config.NewDefaultCGRConfig() + dm := engine.NewDataManager(engine.NewInternalDB(nil, nil, true), + config.CgrConfig().CacheCfg(), nil) + filterS := engine.NewFilterS(cfg, nil, dm) + dN := &utils.DataNode{ + Type: utils.NMMapType, + Map: map[string]*utils.DataNode{ + "Name": utils.NewLeafNode("1001"), + "ExtraFields": { + Type: utils.NMMapType, + Map: map[string]*utils.DataNode{ + "Usage": utils.NewLeafNode("20m"), + }, + }, + }, + } + aqReq := NewAgentRequest(nil, nil, nil, nil, nil, nil, + "cgrates.org", utils.EmptyString, filterS, nil) + aqReq.tmp = dN + + path := []string{utils.MetaTmp} + if rply, err := aqReq.FieldAsInterface(path); err != nil { + t.Error(err) + } else if !reflect.DeepEqual(dN, rply) { + t.Errorf("Expected %+v, received %+v", dN, rply) + } +} + func TestAgReqFieldAsInterfaceForOneFldPathReq(t *testing.T) { cfg := config.NewDefaultCGRConfig() dm := engine.NewDataManager(engine.NewInternalDB(nil, nil, true),