/* Real-time Online/Offline Charging System (OCS) for Telecom & ISP environments Copyright (C) ITsysCOM GmbH This program is free software: you can redistribute it and/or modify it under the terms of the GNU General Public License as published by the Free Software Foundation, either version 3 of the License, or (at your option) any later version. This program is distributed in the hope that it will be useful, but WITHOUT ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License for more details. You should have received a copy of the GNU General Public License along with this program. If not, see */ package config import ( "reflect" "testing" "github.com/cgrates/cgrates/utils" ) func TestAttributeSCfgloadFromJsonCfg(t *testing.T) { var attscfg, expected AttributeSCfg if err := attscfg.loadFromJsonCfg(nil); err != nil { t.Error(err) } else if !reflect.DeepEqual(attscfg, expected) { t.Errorf("Expected: %+v ,recived: %+v", expected, attscfg) } if err := attscfg.loadFromJsonCfg(new(AttributeSJsonCfg)); err != nil { t.Error(err) } else if !reflect.DeepEqual(attscfg, expected) { t.Errorf("Expected: %+v ,recived: %+v", expected, attscfg) } cfgJSONStr := `{ "attributes": { // Attribute service "enabled": true, // starts attribute service: . //"string_indexed_fields": [], // query indexes based on these fields for faster processing "prefix_indexed_fields": ["*req.index1","*req.index2"], // query indexes based on these fields for faster processing "process_runs": 1, // number of run loops when processing event }, }` expected = AttributeSCfg{ Enabled: true, PrefixIndexedFields: &[]string{"*req.index1", "*req.index2"}, ProcessRuns: 1, } if jsnCfg, err := NewCgrJsonCfgFromBytes([]byte(cfgJSONStr)); err != nil { t.Error(err) } else if jsnAttSCfg, err := jsnCfg.AttributeServJsonCfg(); err != nil { t.Error(err) } else if err = attscfg.loadFromJsonCfg(jsnAttSCfg); err != nil { t.Error(err) } else if !reflect.DeepEqual(expected, attscfg) { t.Errorf("Expected: %+v , recived: %+v", expected, attscfg) } } func TestAttributeSCfgAsMapInterface(t *testing.T) { cfgJSONStr := `{ "attributes": { "enabled": true, "prefix_indexed_fields": ["*req.index1","*req.index2"], "process_runs": 3, }, }` eMap := map[string]interface{}{ utils.EnabledCfg: true, utils.PrefixIndexedFieldsCfg: []string{"*req.index1", "*req.index2"}, utils.ProcessRunsCfg: 3, utils.IndexedSelectsCfg: true, utils.NestedFieldsCfg: false, utils.SuffixIndexedFieldsCfg: []string{}, } if cgrCfg, err := NewCGRConfigFromJsonStringWithDefaults(cfgJSONStr); err != nil { t.Error(err) } else if rcv := cgrCfg.attributeSCfg.AsMapInterface(); !reflect.DeepEqual(eMap, rcv) { t.Errorf("\nExpected: %+v\nRecived: %+v", utils.ToJSON(eMap), utils.ToJSON(rcv)) } } func TestAttributeSCfgAsMapInterface2(t *testing.T) { cfgJSONStr := `{ "attributes": { "suffix_indexed_fields": ["*req.index1","*req.index2"], "nested_fields": true, "enabled": true, "process_runs": 7, }, }` expectedMap := map[string]interface{}{ utils.EnabledCfg: true, utils.IndexedSelectsCfg: true, utils.PrefixIndexedFieldsCfg: []string{}, utils.SuffixIndexedFieldsCfg: []string{"*req.index1", "*req.index2"}, utils.NestedFieldsCfg: true, utils.ProcessRunsCfg: 7, } if cgrCfg, err := NewCGRConfigFromJsonStringWithDefaults(cfgJSONStr); err != nil { t.Error(err) } else if newMap := cgrCfg.attributeSCfg.AsMapInterface(); !reflect.DeepEqual(expectedMap, newMap) { t.Errorf("Expected %+v \n, recieved %+v", utils.ToJSON(expectedMap), utils.ToJSON(newMap)) } } func TestAttributeSCfgAsMapInterface3(t *testing.T) { myJSONStr := ` { "attributes": {} } ` expectedMap := map[string]interface{}{ utils.EnabledCfg: false, utils.IndexedSelectsCfg: true, utils.PrefixIndexedFieldsCfg: []string{}, utils.SuffixIndexedFieldsCfg: []string{}, utils.NestedFieldsCfg: false, utils.ProcessRunsCfg: 1, } if conv, err := NewCGRConfigFromJsonStringWithDefaults(myJSONStr); err != nil { t.Error(err) } else if newMap := conv.attributeSCfg.AsMapInterface(); !reflect.DeepEqual(expectedMap, newMap) { t.Errorf("Expected %+v, recieved %+v", expectedMap, newMap) } }