uppal/cgrates
1
0
Fork 1
mirror of https://github.com/cgrates/cgrates.git synced 2026-02-12 18:46:24 +05:00
Code Issues Packages Projects Releases Wiki Activity
Files
75fa22288dc199348aa6e49015f1c0f39eefb708
cgrates/config/loaderscfg_test.go
porosnicuadrian 75fa22288d Fixed loaders tests
2021-10-01 11:56:31 +02:00

2911 lines
83 KiB
Go
Raw Blame History

/*
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 <http://www.gnu.org/licenses/>
*/
package config
import (
"path"
"reflect"
"testing"
"time"
"github.com/cgrates/cgrates/utils"
)
func TestLoaderSCfgloadFromJsonCfgCase1(t *testing.T) {
cfgJSONStr := `{
"loaders": [
{
"id": "*default",
"enabled": true,
"tenant": "cgrates.org",
"lockfile_path": ".cgr.lck",
"caches_conns": ["*internal","*conn1"],
"field_separator": ",",
"tp_in_dir": "/var/spool/cgrates/loader/in",
"tp_out_dir": "/var/spool/cgrates/loader/out",
"data":[
{
"type": "*attributes",
"file_name": "Attributes.csv",
"flags": [],
"fields": [
{"tag": "TenantID", "path": "Tenant", "type": "*composed", "value": "~req.0", "mandatory": true,"layout": "2006-01-02T15:04:05Z07:00"},
],
},
],
},
],
}`
val, err := NewRSRParsers("~req.0", utils.InfieldSep)
if err != nil {
t.Error(err)
}
ten := "cgrates.org"
var flags utils.FlagsWithParams
expected := LoaderSCfgs{
{
Enabled: true,
ID: utils.MetaDefault,
Tenant: ten,
LockFilePath: ".cgr.lck",
CacheSConns: []string{utils.ConcatenatedKey(utils.MetaInternal, utils.MetaCaches), "*conn1"},
FieldSeparator: ",",
TpInDir: "/var/spool/cgrates/loader/in",
TpOutDir: "/var/spool/cgrates/loader/out",
Data: []*LoaderDataType{
{
Type: "*filters",
Filename: "Filters.csv",
Flags: flags,
Fields: []*FCTemplate{
{
Tag: "Tenant",
Path: "Tenant",
pathSlice: []string{"Tenant"},
Type: utils.MetaVariable,
Value: NewRSRParsersMustCompile("~*req.0", utils.InfieldSep),
Mandatory: true,
Layout: time.RFC3339,
},
{
Tag: "ID",
Path: "ID",
pathSlice: []string{"ID"},
Type: utils.MetaVariable,
Value: NewRSRParsersMustCompile("~*req.1", utils.InfieldSep),
Mandatory: true,
Layout: time.RFC3339,
},
{
Tag: "Type",
Path: "Type",
pathSlice: []string{"Type"},
Type: utils.MetaVariable,
Value: NewRSRParsersMustCompile("~*req.2", utils.InfieldSep),
Mandatory: false,
Layout: time.RFC3339,
},
{
Tag: "Element",
Path: "Element",
pathSlice: []string{"Element"},
Type: utils.MetaVariable,
Value: NewRSRParsersMustCompile("~*req.3", utils.InfieldSep),
Mandatory: false,
Layout: time.RFC3339,
},
{
Tag: "Values",
Path: "Values",
pathSlice: []string{"Values"},
Type: utils.MetaVariable,
Value: NewRSRParsersMustCompile("~*req.4", utils.InfieldSep),
Mandatory: false,
Layout: time.RFC3339,
},
},
},
{
Type: "*attributes",
Filename: "Attributes.csv",
Flags: utils.FlagsWithParams{},
Fields: []*FCTemplate{
{
Tag: "TenantID",
Path: "Tenant",
pathSlice: []string{"Tenant"},
Type: utils.MetaComposed,
Value: val,
Mandatory: true,
Layout: time.RFC3339,
},
},
},
{
Type: "*resources",
Filename: "Resources.csv",
Flags: flags,
Fields: []*FCTemplate{
{
Tag: "Tenant",
Path: "Tenant",
pathSlice: []string{"Tenant"},
Type: utils.MetaVariable,
Value: NewRSRParsersMustCompile("~*req.0", utils.InfieldSep),
Mandatory: true,
Layout: time.RFC3339,
},
{
Tag: "ID",
Path: "ID",
pathSlice: []string{"ID"},
Type: utils.MetaVariable,
Value: NewRSRParsersMustCompile("~*req.1", utils.InfieldSep),
Mandatory: true,
Layout: time.RFC3339,
},
{
Tag: "FilterIDs",
Path: "FilterIDs",
pathSlice: []string{"FilterIDs"},
Type: utils.MetaVariable,
Value: NewRSRParsersMustCompile("~*req.2", utils.InfieldSep),
Mandatory: false,
Layout: time.RFC3339,
},
{
Tag: "Weight",
Path: "Weight",
pathSlice: []string{"Weight"},
Type: utils.MetaVariable,
Value: NewRSRParsersMustCompile("~*req.3", utils.InfieldSep),
Mandatory: false,
Layout: time.RFC3339,
},
{
Tag: "TTL",
Path: "UsageTTL",
pathSlice: []string{"UsageTTL"},
Type: utils.MetaVariable,
Value: NewRSRParsersMustCompile("~*req.4", utils.InfieldSep),
Mandatory: false,
Layout: time.RFC3339,
},
{
Tag: "Limit",
Path: "Limit",
pathSlice: []string{"Limit"},
Type: utils.MetaVariable,
Value: NewRSRParsersMustCompile("~*req.5", utils.InfieldSep),
Mandatory: false,
Layout: time.RFC3339,
},
{
Tag: "AllocationMessage",
Path: "AllocationMessage",
pathSlice: []string{"AllocationMessage"},
Type: utils.MetaVariable,
Value: NewRSRParsersMustCompile("~*req.6", utils.InfieldSep),
Mandatory: false,
Layout: time.RFC3339,
},
{
Tag: "Blocker",
Path: "Blocker",
pathSlice: []string{"Blocker"},
Type: utils.MetaVariable,
Value: NewRSRParsersMustCompile("~*req.7", utils.InfieldSep),
Mandatory: false,
Layout: time.RFC3339,
},
{
Tag: "Stored",
Path: "Stored",
pathSlice: []string{"Stored"},
Type: utils.MetaVariable,
Value: NewRSRParsersMustCompile("~*req.8", utils.InfieldSep),
Mandatory: false,
Layout: time.RFC3339,
},
{
Tag: "ThresholdIDs",
Path: "ThresholdIDs",
pathSlice: []string{"ThresholdIDs"},
Type: utils.MetaVariable,
Value: NewRSRParsersMustCompile("~*req.9", utils.InfieldSep),
Mandatory: false,
Layout: time.RFC3339,
},
},
},
{
Type: "*stats",
Filename: "Stats.csv",
Flags: flags,
Fields: []*FCTemplate{
{
Tag: "Tenant",
Path: "Tenant",
pathSlice: []string{"Tenant"},
Type: utils.MetaVariable,
Value: NewRSRParsersMustCompile("~*req.0", utils.InfieldSep),
Mandatory: true,
Layout: time.RFC3339,
},
{
Tag: "ID",
Path: "ID",
pathSlice: []string{"ID"},
Type: utils.MetaVariable,
Value: NewRSRParsersMustCompile("~*req.1", utils.InfieldSep),
Mandatory: true,
Layout: time.RFC3339,
},
{
Tag: "FilterIDs",
Path: "FilterIDs",
pathSlice: []string{"FilterIDs"},
Type: utils.MetaVariable,
Value: NewRSRParsersMustCompile("~*req.2", utils.InfieldSep),
Mandatory: false,
Layout: time.RFC3339,
},
{
Tag: "Weight",
Path: "Weight",
pathSlice: []string{"Weight"},
Type: utils.MetaVariable,
Value: NewRSRParsersMustCompile("~*req.3", utils.InfieldSep),
Mandatory: false,
Layout: time.RFC3339,
},
{
Tag: "QueueLength",
Path: "QueueLength",
pathSlice: []string{"QueueLength"},
Type: utils.MetaVariable,
Value: NewRSRParsersMustCompile("~*req.4", utils.InfieldSep),
Mandatory: false,
Layout: time.RFC3339,
},
{
Tag: "TTL",
Path: "TTL",
pathSlice: []string{"TTL"},
Type: utils.MetaVariable,
Value: NewRSRParsersMustCompile("~*req.5", utils.InfieldSep),
Mandatory: false,
Layout: time.RFC3339,
},
{
Tag: "MinItems",
Path: "MinItems",
pathSlice: []string{"MinItems"},
Type: utils.MetaVariable,
Value: NewRSRParsersMustCompile("~*req.6", utils.InfieldSep),
Mandatory: false,
Layout: time.RFC3339,
},
{
Tag: "MetricIDs",
Path: "MetricIDs",
pathSlice: []string{"MetricIDs"},
Type: utils.MetaVariable,
Value: NewRSRParsersMustCompile("~*req.7", utils.InfieldSep),
Mandatory: false,
Layout: time.RFC3339,
},
{
Tag: "MetricFilterIDs",
Path: "MetricFilterIDs",
pathSlice: []string{"MetricFilterIDs"},
Type: utils.MetaVariable,
Value: NewRSRParsersMustCompile("~*req.8", utils.InfieldSep),
Mandatory: false,
Layout: time.RFC3339,
},
{
Tag: "Blocker",
Path: "Blocker",
pathSlice: []string{"Blocker"},
Type: utils.MetaVariable,
Value: NewRSRParsersMustCompile("~*req.9", utils.InfieldSep),
Mandatory: false,
Layout: time.RFC3339,
},
{
Tag: "Stored",
Path: "Stored",
pathSlice: []string{"Stored"},
Type: utils.MetaVariable,
Value: NewRSRParsersMustCompile("~*req.10", utils.InfieldSep),
Mandatory: false,
Layout: time.RFC3339,
},
{
Tag: "ThresholdIDs",
Path: "ThresholdIDs",
pathSlice: []string{"ThresholdIDs"},
Type: utils.MetaVariable,
Value: NewRSRParsersMustCompile("~*req.11", utils.InfieldSep),
Mandatory: false,
Layout: time.RFC3339,
},
},
},
{
Type: "*thresholds",
Filename: "Thresholds.csv",
Flags: flags,
Fields: []*FCTemplate{
{
Tag: "Tenant",
Path: "Tenant",
pathSlice: []string{"Tenant"},
Type: utils.MetaVariable,
Value: NewRSRParsersMustCompile("~*req.0", utils.InfieldSep),
Mandatory: true,
Layout: time.RFC3339,
},
{
Tag: "ID",
Path: "ID",
pathSlice: []string{"ID"},
Type: utils.MetaVariable,
Value: NewRSRParsersMustCompile("~*req.1", utils.InfieldSep),
Mandatory: true,
Layout: time.RFC3339,
},
{
Tag: "FilterIDs",
Path: "FilterIDs",
pathSlice: []string{"FilterIDs"},
Type: utils.MetaVariable,
Value: NewRSRParsersMustCompile("~*req.2", utils.InfieldSep),
Mandatory: false,
Layout: time.RFC3339,
},
{
Tag: "Weight",
Path: "Weight",
pathSlice: []string{"Weight"},
Type: utils.MetaVariable,
Value: NewRSRParsersMustCompile("~*req.3", utils.InfieldSep),
Mandatory: false,
Layout: time.RFC3339,
},
{
Tag: "MaxHits",
Path: "MaxHits",
pathSlice: []string{"MaxHits"},
Type: utils.MetaVariable,
Value: NewRSRParsersMustCompile("~*req.4", utils.InfieldSep),
Mandatory: false,
Layout: time.RFC3339,
},
{
Tag: "MinHits",
Path: "MinHits",
pathSlice: []string{"MinHits"},
Type: utils.MetaVariable,
Value: NewRSRParsersMustCompile("~*req.5", utils.InfieldSep),
Mandatory: false,
Layout: time.RFC3339,
},
{
Tag: "MinSleep",
Path: "MinSleep",
pathSlice: []string{"MinSleep"},
Type: utils.MetaVariable,
Value: NewRSRParsersMustCompile("~*req.6", utils.InfieldSep),
Mandatory: false,
Layout: time.RFC3339,
},
{
Tag: "Blocker",
Path: "Blocker",
pathSlice: []string{"Blocker"},
Type: utils.MetaVariable,
Value: NewRSRParsersMustCompile("~*req.7", utils.InfieldSep),
Mandatory: false,
Layout: time.RFC3339,
},
{
Tag: "ActionProfileIDs",
Path: "ActionProfileIDs",
pathSlice: []string{"ActionProfileIDs"},
Type: utils.MetaVariable,
Value: NewRSRParsersMustCompile("~*req.8", utils.InfieldSep),
Mandatory: false,
Layout: time.RFC3339,
},
{
Tag: "Async",
Path: "Async",
pathSlice: []string{"Async"},
Type: utils.MetaVariable,
Value: NewRSRParsersMustCompile("~*req.9", utils.InfieldSep),
Mandatory: false,
Layout: time.RFC3339,
},
},
},
{
Type: "*routes",
Filename: "Routes.csv",
Flags: flags,
Fields: []*FCTemplate{
{
Tag: "Tenant",
Path: "Tenant",
pathSlice: []string{"Tenant"},
Type: utils.MetaVariable,
Value: NewRSRParsersMustCompile("~*req.0", utils.InfieldSep),
Mandatory: true,
Layout: time.RFC3339,
},
{
Tag: "ID",
Path: "ID",
pathSlice: []string{"ID"},
Type: utils.MetaVariable,
Value: NewRSRParsersMustCompile("~*req.1", utils.InfieldSep),
Mandatory: true,
Layout: time.RFC3339,
},
{
Tag: "FilterIDs",
Path: "FilterIDs",
pathSlice: []string{"FilterIDs"},
Type: utils.MetaVariable,
Value: NewRSRParsersMustCompile("~*req.2", utils.InfieldSep),
Mandatory: false,
Layout: time.RFC3339,
},
{
Tag: "Weights",
Path: "Weights",
pathSlice: []string{"Weights"},
Type: utils.MetaVariable,
Value: NewRSRParsersMustCompile("~*req.3", utils.InfieldSep),
Mandatory: false,
Layout: time.RFC3339,
},
{
Tag: "Sorting",
Path: "Sorting",
pathSlice: []string{"Sorting"},
Type: utils.MetaVariable,
Value: NewRSRParsersMustCompile("~*req.4", utils.InfieldSep),
Mandatory: false,
Layout: time.RFC3339,
},
{
Tag: "SortingParameters",
Path: "SortingParameters",
pathSlice: []string{"SortingParameters"},
Type: utils.MetaVariable,
Value: NewRSRParsersMustCompile("~*req.5", utils.InfieldSep),
Mandatory: false,
Layout: time.RFC3339,
},
{
Tag: "RouteID",
Path: "RouteID",
pathSlice: []string{"RouteID"},
Type: utils.MetaVariable,
Value: NewRSRParsersMustCompile("~*req.6", utils.InfieldSep),
Mandatory: false,
Layout: time.RFC3339,
},
{
Tag: "RouteFilterIDs",
Path: "RouteFilterIDs",
pathSlice: []string{"RouteFilterIDs"},
Type: utils.MetaVariable,
Value: NewRSRParsersMustCompile("~*req.7", utils.InfieldSep),
Mandatory: false,
Layout: time.RFC3339,
},
{
Tag: "RouteAccountIDs",
Path: "RouteAccountIDs",
pathSlice: []string{"RouteAccountIDs"},
Type: utils.MetaVariable,
Value: NewRSRParsersMustCompile("~*req.8", utils.InfieldSep),
Mandatory: false,
Layout: time.RFC3339,
},
{
Tag: "RouteRateProfileIDs",
Path: "RouteRateProfileIDs",
pathSlice: []string{"RouteRateProfileIDs"},
Type: utils.MetaVariable,
Value: NewRSRParsersMustCompile("~*req.9", utils.InfieldSep),
Mandatory: false,
Layout: time.RFC3339,
},
{
Tag: "RouteResourceIDs",
Path: "RouteResourceIDs",
pathSlice: []string{"RouteResourceIDs"},
Type: utils.MetaVariable,
Value: NewRSRParsersMustCompile("~*req.10", utils.InfieldSep),
Mandatory: false,
Layout: time.RFC3339,
},
{
Tag: "RouteStatIDs",
Path: "RouteStatIDs",
pathSlice: []string{"RouteStatIDs"},
Type: utils.MetaVariable,
Value: NewRSRParsersMustCompile("~*req.11", utils.InfieldSep),
Mandatory: false,
Layout: time.RFC3339,
},
{
Tag: "RouteWeights",
Path: "RouteWeights",
pathSlice: []string{"RouteWeights"},
Type: utils.MetaVariable,
Value: NewRSRParsersMustCompile("~*req.12", utils.InfieldSep),
Mandatory: false,
Layout: time.RFC3339,
},
{
Tag: "RouteBlocker",
Path: "RouteBlocker",
pathSlice: []string{"RouteBlocker"},
Type: utils.MetaVariable,
Value: NewRSRParsersMustCompile("~*req.13", utils.InfieldSep),
Mandatory: false,
Layout: time.RFC3339,
},
{
Tag: "RouteParameters",
Path: "RouteParameters",
pathSlice: []string{"RouteParameters"},
Type: utils.MetaVariable,
Value: NewRSRParsersMustCompile("~*req.14", utils.InfieldSep),
Mandatory: false,
Layout: time.RFC3339,
},
},
},
{
Type: "*chargers",
Filename: "Chargers.csv",
Flags: flags,
Fields: []*FCTemplate{
{
Tag: "Tenant",
Path: "Tenant",
pathSlice: []string{"Tenant"},
Type: utils.MetaVariable,
Value: NewRSRParsersMustCompile("~*req.0", utils.InfieldSep),
Mandatory: true,
Layout: time.RFC3339,
},
{
Tag: "ID",
Path: "ID",
pathSlice: []string{"ID"},
Type: utils.MetaVariable,
Value: NewRSRParsersMustCompile("~*req.1", utils.InfieldSep),
Mandatory: true,
Layout: time.RFC3339,
},
{
Tag: "FilterIDs",
Path: "FilterIDs",
pathSlice: []string{"FilterIDs"},
Type: utils.MetaVariable,
Value: NewRSRParsersMustCompile("~*req.2", utils.InfieldSep),
Mandatory: false,
Layout: time.RFC3339,
},
{
Tag: "Weight",
Path: "Weight",
pathSlice: []string{"Weight"},
Type: utils.MetaVariable,
Value: NewRSRParsersMustCompile("~*req.3", utils.InfieldSep),
Mandatory: false,
Layout: time.RFC3339,
},
{
Tag: "RunID",
Path: "RunID",
pathSlice: []string{"RunID"},
Type: utils.MetaVariable,
Value: NewRSRParsersMustCompile("~*req.4", utils.InfieldSep),
Mandatory: false,
Layout: time.RFC3339,
},
{
Tag: "AttributeIDs",
Path: "AttributeIDs",
pathSlice: []string{"AttributeIDs"},
Type: utils.MetaVariable,
Value: NewRSRParsersMustCompile("~*req.5", utils.InfieldSep),
Mandatory: false,
Layout: time.RFC3339,
},
},
},
{
Type: "*dispatchers",
Filename: "DispatcherProfiles.csv",
Flags: flags,
Fields: []*FCTemplate{
{
Tag: "Tenant",
Path: "Tenant",
pathSlice: []string{"Tenant"},
Type: utils.MetaVariable,
Value: NewRSRParsersMustCompile("~*req.0", utils.InfieldSep),
Mandatory: true,
Layout: time.RFC3339,
},
{
Tag: "ID",
Path: "ID",
pathSlice: []string{"ID"},
Type: utils.MetaVariable,
Value: NewRSRParsersMustCompile("~*req.1", utils.InfieldSep),
Mandatory: true,
Layout: time.RFC3339,
},
{
Tag: "FilterIDs",
Path: "FilterIDs",
pathSlice: []string{"FilterIDs"},
Type: utils.MetaVariable,
Value: NewRSRParsersMustCompile("~*req.2", utils.InfieldSep),
Mandatory: false,
Layout: time.RFC3339,
},
{
Tag: "Weight",
Path: "Weight",
pathSlice: []string{"Weight"},
Type: utils.MetaVariable,
Value: NewRSRParsersMustCompile("~*req.3", utils.InfieldSep),
Mandatory: false,
Layout: time.RFC3339,
},
{
Tag: "Strategy",
Path: "Strategy",
pathSlice: []string{"Strategy"},
Type: utils.MetaVariable,
Value: NewRSRParsersMustCompile("~*req.4", utils.InfieldSep),
Mandatory: false,
Layout: time.RFC3339,
},
{
Tag: "StrategyParameters",
Path: "StrategyParameters",
pathSlice: []string{"StrategyParameters"},
Type: utils.MetaVariable,
Value: NewRSRParsersMustCompile("~*req.5", utils.InfieldSep),
Mandatory: false,
Layout: time.RFC3339,
},
{
Tag: "ConnID",
Path: "ConnID",
pathSlice: []string{"ConnID"},
Type: utils.MetaVariable,
Value: NewRSRParsersMustCompile("~*req.6", utils.InfieldSep),
Mandatory: false,
Layout: time.RFC3339,
},
{
Tag: "ConnFilterIDs",
Path: "ConnFilterIDs",
pathSlice: []string{"ConnFilterIDs"},
Type: utils.MetaVariable,
Value: NewRSRParsersMustCompile("~*req.7", utils.InfieldSep),
Mandatory: false,
Layout: time.RFC3339,
},
{
Tag: "ConnWeight",
Path: "ConnWeight",
pathSlice: []string{"ConnWeight"},
Type: utils.MetaVariable,
Value: NewRSRParsersMustCompile("~*req.8", utils.InfieldSep),
Mandatory: false,
Layout: time.RFC3339,
},
{
Tag: "ConnBlocker",
Path: "ConnBlocker",
pathSlice: []string{"ConnBlocker"},
Type: utils.MetaVariable,
Value: NewRSRParsersMustCompile("~*req.9", utils.InfieldSep),
Mandatory: false,
Layout: time.RFC3339,
},
{
Tag: "ConnParameters",
Path: "ConnParameters",
pathSlice: []string{"ConnParameters"},
Type: utils.MetaVariable,
Value: NewRSRParsersMustCompile("~*req.10", utils.InfieldSep),
Mandatory: false,
Layout: time.RFC3339,
},
},
},
{
Type: "*dispatcher_hosts",
Filename: "DispatcherHosts.csv",
Flags: flags,
Fields: []*FCTemplate{
{
Tag: "Tenant",
Path: "Tenant",
pathSlice: []string{"Tenant"},
Type: utils.MetaVariable,
Value: NewRSRParsersMustCompile("~*req.0", utils.InfieldSep),
Mandatory: true,
Layout: time.RFC3339,
},
{
Tag: "ID",
Path: "ID",
pathSlice: []string{"ID"},
Type: utils.MetaVariable,
Value: NewRSRParsersMustCompile("~*req.1", utils.InfieldSep),
Mandatory: true,
Layout: time.RFC3339,
},
{
Tag: "Address",
Path: "Address",
pathSlice: []string{"Address"},
Type: utils.MetaVariable,
Value: NewRSRParsersMustCompile("~*req.2", utils.InfieldSep),
Mandatory: false,
Layout: time.RFC3339,
},
{
Tag: "Transport",
Path: "Transport",
pathSlice: []string{"Transport"},
Type: utils.MetaVariable,
Value: NewRSRParsersMustCompile("~*req.3", utils.InfieldSep),
Mandatory: false,
Layout: time.RFC3339,
},
{
Tag: "ConnectAttempts",
Path: "ConnectAttempts",
pathSlice: []string{"ConnectAttempts"},
Type: utils.MetaVariable,
Value: NewRSRParsersMustCompile("~*req.4", utils.InfieldSep),
Mandatory: false,
Layout: time.RFC3339,
},
{
Tag: "Reconnects",
Path: "Reconnects",
pathSlice: []string{"Reconnects"},
Type: utils.MetaVariable,
Value: NewRSRParsersMustCompile("~*req.5", utils.InfieldSep),
Mandatory: false,
Layout: time.RFC3339,
},
{
Tag: "ConnectTimeout",
Path: "ConnectTimeout",
pathSlice: []string{"ConnectTimeout"},
Type: utils.MetaVariable,
Value: NewRSRParsersMustCompile("~*req.6", utils.InfieldSep),
Mandatory: false,
Layout: time.RFC3339,
},
{
Tag: "ReplyTimeout",
Path: "ReplyTimeout",
pathSlice: []string{"ReplyTimeout"},
Type: utils.MetaVariable,
Value: NewRSRParsersMustCompile("~*req.7", utils.InfieldSep),
Mandatory: false,
Layout: time.RFC3339,
},
{
Tag: "TLS",
Path: "TLS",
pathSlice: []string{"TLS"},
Type: utils.MetaVariable,
Value: NewRSRParsersMustCompile("~*req.8", utils.InfieldSep),
Mandatory: false,
Layout: time.RFC3339,
},
{
Tag: "ClientKey",
Path: "ClientKey",
pathSlice: []string{"ClientKey"},
Type: utils.MetaVariable,
Value: NewRSRParsersMustCompile("~*req.9", utils.InfieldSep),
Mandatory: false,
Layout: time.RFC3339,
},
{
Tag: "ClientCertificate",
Path: "ClientCertificate",
pathSlice: []string{"ClientCertificate"},
Type: utils.MetaVariable,
Value: NewRSRParsersMustCompile("~*req.10", utils.InfieldSep),
Mandatory: false,
Layout: time.RFC3339,
},
{
Tag: "CaCertificate",
Path: "CaCertificate",
pathSlice: []string{"CaCertificate"},
Type: utils.MetaVariable,
Value: NewRSRParsersMustCompile("~*req.11", utils.InfieldSep),
Mandatory: false,
Layout: time.RFC3339,
},
},
},
{
Type: "*rate_profiles",
Filename: "RateProfiles.csv",
Flags: flags,
Fields: []*FCTemplate{
{
Tag: "Tenant",
Path: "Tenant",
pathSlice: []string{"Tenant"},
Type: utils.MetaVariable,
Value: NewRSRParsersMustCompile("~*req.0", utils.InfieldSep),
Mandatory: true,
Layout: time.RFC3339,
},
{
Tag: "ID",
Path: "ID",
pathSlice: []string{"ID"},
Type: utils.MetaVariable,
Value: NewRSRParsersMustCompile("~*req.1", utils.InfieldSep),
Mandatory: true,
Layout: time.RFC3339,
},
{
Tag: "FilterIDs",
Path: "FilterIDs",
pathSlice: []string{"FilterIDs"},
Type: utils.MetaVariable,
Value: NewRSRParsersMustCompile("~*req.2", utils.InfieldSep),
Mandatory: false,
Layout: time.RFC3339,
},
{
Tag: "Weight",
Path: "Weight",
pathSlice: []string{"Weight"},
Type: utils.MetaVariable,
Value: NewRSRParsersMustCompile("~*req.3", utils.InfieldSep),
Mandatory: false,
Layout: time.RFC3339,
},
{
Tag: "MinCost",
Path: "MinCost",
pathSlice: []string{"MinCost"},
Type: utils.MetaVariable,
Value: NewRSRParsersMustCompile("~*req.4", utils.InfieldSep),
Mandatory: false,
Layout: time.RFC3339,
},
{
Tag: "MaxCost",
Path: "MaxCost",
pathSlice: []string{"MaxCost"},
Type: utils.MetaVariable,
Value: NewRSRParsersMustCompile("~*req.5", utils.InfieldSep),
Mandatory: false,
Layout: time.RFC3339,
},
{
Tag: "MaxCostStrategy",
Path: "MaxCostStrategy",
pathSlice: []string{"MaxCostStrategy"},
Type: utils.MetaVariable,
Value: NewRSRParsersMustCompile("~*req.6", utils.InfieldSep),
Mandatory: false,
Layout: time.RFC3339,
},
{
Tag: "RateID",
Path: "RateID",
pathSlice: []string{"RateID"},
Type: utils.MetaVariable,
Value: NewRSRParsersMustCompile("~*req.7", utils.InfieldSep),
Mandatory: false,
Layout: time.RFC3339,
},
{
Tag: "RateFilterIDs",
Path: "RateFilterIDs",
pathSlice: []string{"RateFilterIDs"},
Type: utils.MetaVariable,
Value: NewRSRParsersMustCompile("~*req.8", utils.InfieldSep),
Mandatory: false,
Layout: time.RFC3339,
},
{
Tag: "RateActivationTimes",
Path: "RateActivationTimes",
pathSlice: []string{"RateActivationTimes"},
Type: utils.MetaVariable,
Value: NewRSRParsersMustCompile("~*req.9", utils.InfieldSep),
Mandatory: false,
Layout: time.RFC3339,
},
{
Tag: "RateWeight",
Path: "RateWeight",
pathSlice: []string{"RateWeight"},
Type: utils.MetaVariable,
Value: NewRSRParsersMustCompile("~*req.10", utils.InfieldSep),
Mandatory: false,
Layout: time.RFC3339,
},
{
Tag: "RateBlocker",
Path: "RateBlocker",
pathSlice: []string{"RateBlocker"},
Type: utils.MetaVariable,
Value: NewRSRParsersMustCompile("~*req.11", utils.InfieldSep),
Mandatory: false,
Layout: time.RFC3339,
},
{
Tag: "RateIntervalStart",
Path: "RateIntervalStart",
pathSlice: []string{"RateIntervalStart"},
Type: utils.MetaVariable,
Value: NewRSRParsersMustCompile("~*req.12", utils.InfieldSep),
Mandatory: false,
Layout: time.RFC3339,
},
{
Tag: "RateFixedFee",
Path: "RateFixedFee",
pathSlice: []string{"RateFixedFee"},
Type: utils.MetaVariable,
Value: NewRSRParsersMustCompile("~*req.13", utils.InfieldSep),
Mandatory: false,
Layout: time.RFC3339,
},
{
Tag: "RateRecurrentFee",
Path: "RateRecurrentFee",
pathSlice: []string{"RateRecurrentFee"},
Type: utils.MetaVariable,
Value: NewRSRParsersMustCompile("~*req.14", utils.InfieldSep),
Mandatory: false,
Layout: time.RFC3339,
},
{
Tag: "RateUnit",
Path: "RateUnit",
pathSlice: []string{"RateUnit"},
Type: utils.MetaVariable,
Value: NewRSRParsersMustCompile("~*req.15", utils.InfieldSep),
Mandatory: false,
Layout: time.RFC3339,
},
{
Tag: "RateIncrement",
Path: "RateIncrement",
pathSlice: []string{"RateIncrement"},
Type: utils.MetaVariable,
Value: NewRSRParsersMustCompile("~*req.16", utils.InfieldSep),
Mandatory: false,
Layout: time.RFC3339,
},
},
},
{
Type: "*action_profiles",
Filename: "ActionProfiles.csv",
Flags: flags,
Fields: []*FCTemplate{
{
Tag: "Tenant",
Path: "Tenant",
pathSlice: []string{"Tenant"},
Type: utils.MetaVariable,
Value: NewRSRParsersMustCompile("~*req.0", utils.InfieldSep),
Mandatory: true,
Layout: time.RFC3339,
},
{
Tag: "ID",
Path: "ID",
pathSlice: []string{"ID"},
Type: utils.MetaVariable,
Value: NewRSRParsersMustCompile("~*req.1", utils.InfieldSep),
Mandatory: true,
Layout: time.RFC3339,
},
{
Tag: "FilterIDs",
Path: "FilterIDs",
pathSlice: []string{"FilterIDs"},
Type: utils.MetaVariable,
Value: NewRSRParsersMustCompile("~*req.2", utils.InfieldSep),
Mandatory: false,
Layout: time.RFC3339,
},
{
Tag: "Weight",
Path: "Weight",
pathSlice: []string{"Weight"},
Type: utils.MetaVariable,
Value: NewRSRParsersMustCompile("~*req.3", utils.InfieldSep),
Mandatory: false,
Layout: time.RFC3339,
},
{
Tag: "Schedule",
Path: "Schedule",
pathSlice: []string{"Schedule"},
Type: utils.MetaVariable,
Value: NewRSRParsersMustCompile("~*req.4", utils.InfieldSep),
Mandatory: false,
Layout: time.RFC3339,
},
{
Tag: "TargetType",
Path: "TargetType",
pathSlice: []string{"TargetType"},
Type: utils.MetaVariable,
Value: NewRSRParsersMustCompile("~*req.5", utils.InfieldSep),
Mandatory: false,
Layout: time.RFC3339,
},
{
Tag: "TargetIDs",
Path: "TargetIDs",
pathSlice: []string{"TargetIDs"},
Type: utils.MetaVariable,
Value: NewRSRParsersMustCompile("~*req.6", utils.InfieldSep),
Mandatory: false,
Layout: time.RFC3339,
},
{
Tag: "ActionID",
Path: "ActionID",
pathSlice: []string{"ActionID"},
Type: utils.MetaVariable,
Value: NewRSRParsersMustCompile("~*req.7", utils.InfieldSep),
Mandatory: false,
Layout: time.RFC3339,
},
{
Tag: "ActionFilterIDs",
Path: "ActionFilterIDs",
pathSlice: []string{"ActionFilterIDs"},
Type: utils.MetaVariable,
Value: NewRSRParsersMustCompile("~*req.8", utils.InfieldSep),
Mandatory: false,
Layout: time.RFC3339,
},
{
Tag: "ActionBlocker",
Path: "ActionBlocker",
pathSlice: []string{"ActionBlocker"},
Type: utils.MetaVariable,
Value: NewRSRParsersMustCompile("~*req.9", utils.InfieldSep),
Mandatory: false,
Layout: time.RFC3339,
},
{
Tag: "ActionTTL",
Path: "ActionTTL",
pathSlice: []string{"ActionTTL"},
Type: utils.MetaVariable,
Value: NewRSRParsersMustCompile("~*req.10", utils.InfieldSep),
Mandatory: false,
Layout: time.RFC3339,
},
{
Tag: "ActionType",
Path: "ActionType",
pathSlice: []string{"ActionType"},
Type: utils.MetaVariable,
Value: NewRSRParsersMustCompile("~*req.11", utils.InfieldSep),
Mandatory: false,
Layout: time.RFC3339,
},
{
Tag: "ActionOpts",
Path: "ActionOpts",
pathSlice: []string{"ActionOpts"},
Type: utils.MetaVariable,
Value: NewRSRParsersMustCompile("~*req.12", utils.InfieldSep),
Mandatory: false,
Layout: time.RFC3339,
},
{
Tag: "ActionPath",
Path: "ActionPath",
pathSlice: []string{"ActionPath"},
Type: utils.MetaVariable,
Value: NewRSRParsersMustCompile("~*req.13", utils.InfieldSep),
Mandatory: false,
Layout: time.RFC3339,
},
{
Tag: "ActionValue",
Path: "ActionValue",
pathSlice: []string{"ActionValue"},
Type: utils.MetaVariable,
Value: NewRSRParsersMustCompile("~*req.14", utils.InfieldSep),
Mandatory: false,
Layout: time.RFC3339,
},
},
},
{
Type: "*accounts",
Filename: "Accounts.csv",
Flags: flags,
Fields: []*FCTemplate{
{
Tag: "Tenant",
Path: "Tenant",
pathSlice: []string{"Tenant"},
Type: utils.MetaVariable,
Value: NewRSRParsersMustCompile("~*req.0", utils.InfieldSep),
Mandatory: true,
Layout: time.RFC3339,
},
{
Tag: "ID",
Path: "ID",
pathSlice: []string{"ID"},
Type: utils.MetaVariable,
Value: NewRSRParsersMustCompile("~*req.1", utils.InfieldSep),
Mandatory: true,
Layout: time.RFC3339,
},
{
Tag: "FilterIDs",
Path: "FilterIDs",
pathSlice: []string{"FilterIDs"},
Type: utils.MetaVariable,
Value: NewRSRParsersMustCompile("~*req.2", utils.InfieldSep),
Mandatory: false,
Layout: time.RFC3339,
},
{
Tag: "Weights",
Path: "Weights",
pathSlice: []string{"Weights"},
Type: utils.MetaVariable,
Value: NewRSRParsersMustCompile("~*req.3", utils.InfieldSep),
Mandatory: false,
Layout: time.RFC3339,
},
{
Tag: "Opts",
Path: "Opts",
pathSlice: []string{"Opts"},
Type: utils.MetaVariable,
Value: NewRSRParsersMustCompile("~*req.4", utils.InfieldSep),
Mandatory: false,
Layout: time.RFC3339,
},
{
Tag: "BalanceID",
Path: "BalanceID",
pathSlice: []string{"BalanceID"},
Type: utils.MetaVariable,
Value: NewRSRParsersMustCompile("~*req.5", utils.InfieldSep),
Mandatory: false,
Layout: time.RFC3339,
},
{
Tag: "BalanceFilterIDs",
Path: "BalanceFilterIDs",
pathSlice: []string{"BalanceFilterIDs"},
Type: utils.MetaVariable,
Value: NewRSRParsersMustCompile("~*req.6", utils.InfieldSep),
Mandatory: false,
Layout: time.RFC3339,
},
{
Tag: "BalanceWeights",
Path: "BalanceWeights",
pathSlice: []string{"BalanceWeights"},
Type: utils.MetaVariable,
Value: NewRSRParsersMustCompile("~*req.7", utils.InfieldSep),
Mandatory: false,
Layout: time.RFC3339,
},
{
Tag: "BalanceType",
Path: "BalanceType",
pathSlice: []string{"BalanceType"},
Type: utils.MetaVariable,
Value: NewRSRParsersMustCompile("~*req.8", utils.InfieldSep),
Mandatory: false,
Layout: time.RFC3339,
},
{
Tag: "BalanceUnits",
Path: "BalanceUnits",
pathSlice: []string{"BalanceUnits"},
Type: utils.MetaVariable,
Value: NewRSRParsersMustCompile("~*req.9", utils.InfieldSep),
Mandatory: false,
Layout: time.RFC3339,
},
{
Tag: "BalanceUnitFactors",
Path: "BalanceUnitFactors",
pathSlice: []string{"BalanceUnitFactors"},
Type: utils.MetaVariable,
Value: NewRSRParsersMustCompile("~*req.10", utils.InfieldSep),
Mandatory: false,
Layout: time.RFC3339,
},
{
Tag: "BalanceOpts",
Path: "BalanceOpts",
pathSlice: []string{"BalanceOpts"},
Type: utils.MetaVariable,
Value: NewRSRParsersMustCompile("~*req.11", utils.InfieldSep),
Mandatory: false,
Layout: time.RFC3339,
},
{
Tag: "BalanceCostIncrements",
Path: "BalanceCostIncrements",
pathSlice: []string{"BalanceCostIncrements"},
Type: utils.MetaVariable,
Value: NewRSRParsersMustCompile("~*req.12", utils.InfieldSep),
Mandatory: false,
Layout: time.RFC3339,
},
{
Tag: "BalanceAttributeIDs",
Path: "BalanceAttributeIDs",
pathSlice: []string{"BalanceAttributeIDs"},
Type: utils.MetaVariable,
Value: NewRSRParsersMustCompile("~*req.13", utils.InfieldSep),
Mandatory: false,
Layout: time.RFC3339,
},
{
Tag: "BalanceRateProfileIDs",
Path: "BalanceRateProfileIDs",
pathSlice: []string{"BalanceRateProfileIDs"},
Type: utils.MetaVariable,
Value: NewRSRParsersMustCompile("~*req.14", utils.InfieldSep),
Mandatory: false,
Layout: time.RFC3339,
},
{
Tag: "ThresholdIDs",
Path: "ThresholdIDs",
pathSlice: []string{"ThresholdIDs"},
Type: utils.MetaVariable,
Value: NewRSRParsersMustCompile("~*req.15", utils.InfieldSep),
Mandatory: false,
Layout: time.RFC3339,
},
},
},
},
},
}
if jsonCfg, err := NewCGRConfigFromJSONStringWithDefaults(cfgJSONStr); err != nil {
t.Error(err)
} else if !reflect.DeepEqual(expected, jsonCfg.loaderCfg) {
t.Errorf("expected: %+v,\nreceived: %+v", utils.ToJSON(expected), utils.ToJSON(jsonCfg.loaderCfg))
}
}
// func TestLoaderSCfgloadFromJsonCfgCase2(t *testing.T) {
// cfgJSON := &LoaderJsonCfg{
// Tenant: utils.StringPointer("a{*"),
// }
// expected := "invalid converter terminator in rule: <a{*>"
// jsonCfg := NewDefaultCGRConfig()
// if err = jsonCfg.loaderCfg[0].loadFromJSONCfg(nil, jsonCfg.templates, jsonCfg.generalCfg.RSRSep); err != nil {
// t.Error(err)
// } else if err = jsonCfg.loaderCfg[0].loadFromJSONCfg(cfgJSON, jsonCfg.templates, jsonCfg.generalCfg.RSRSep); err == nil || err.Error() != expected {
// t.Errorf("Expected %+v, received %+v", expected, err)
// }
// }
func TestLoaderSCfgloadFromJsonCfgCase3(t *testing.T) {
cfg := &LoaderJsonCfg{
Data: &[]*LoaderJsonDataType{
{
Fields: &[]*FcTemplateJsonCfg{
{
Value: utils.StringPointer("a{*"),
},
},
},
},
}
expected := "invalid converter terminator in rule: <a{*>"
jsonCfg := NewDefaultCGRConfig()
if err := jsonCfg.loaderCfg[0].loadFromJSONCfg(cfg, jsonCfg.templates, jsonCfg.generalCfg.RSRSep); err == nil || err.Error() != expected {
t.Errorf("Expected %+v, received %+v", expected, err)
}
}
func TestLoaderSCfgloadFromJsonCfgCase4(t *testing.T) {
cfg := &LoaderJsonCfg{
Data: &[]*LoaderJsonDataType{
{
Fields: &[]*FcTemplateJsonCfg{
{
Type: utils.StringPointer(utils.MetaTemplate),
},
},
},
},
}
expected := "no template with id: <>"
jsonCfg := NewDefaultCGRConfig()
if err = jsonCfg.loaderCfg[0].loadFromJSONCfg(cfg, jsonCfg.templates, jsonCfg.generalCfg.RSRSep); err == nil || err.Error() != expected {
t.Errorf("Expected %+v, received %+v", expected, err)
}
}
func TestLoaderSCfgloadFromJsonCfgCase5(t *testing.T) {
cfg := &LoaderJsonCfg{
Data: &[]*LoaderJsonDataType{
{
Fields: &[]*FcTemplateJsonCfg{
{
Tag: utils.StringPointer("randomTag"),
Path: utils.StringPointer("randomPath"),
Type: utils.StringPointer(utils.MetaTemplate),
Value: utils.StringPointer("randomTemplate"),
},
},
},
},
}
expectedFields := LoaderSCfgs{
{
Data: []*LoaderDataType{
{
Fields: []*FCTemplate{
{
Tag: "TenantID",
Path: "Tenant",
pathSlice: []string{"Tenant"},
Type: utils.MetaVariable,
Value: NewRSRParsersMustCompile("~*req.0", utils.InfieldSep),
Mandatory: true,
Layout: time.RFC3339,
},
},
},
},
},
}
msgTemplates := map[string][]*FCTemplate{
"randomTemplate": {
{
Tag: "TenantID",
Path: "Tenant",
Type: utils.MetaVariable,
Value: NewRSRParsersMustCompile("~*req.0", utils.InfieldSep),
Mandatory: true,
},
},
}
jsonCfg := NewDefaultCGRConfig()
if err = jsonCfg.loaderCfg[0].loadFromJSONCfg(cfg, msgTemplates, jsonCfg.generalCfg.RSRSep); err != nil {
t.Error(err)
} else if !reflect.DeepEqual(jsonCfg.loaderCfg[0].Data[1].Fields[0], expectedFields[0].Data[0].Fields[0]) {
t.Errorf("Expected %+v,\n received %+v", utils.ToJSON(expectedFields[0].Data[0].Fields[0]), utils.ToJSON(jsonCfg.loaderCfg[0].Data[1].Fields[0]))
}
}
func TestLoaderSCfgloadFromJsonCfgCase6(t *testing.T) {
cfg := &LoaderJsonCfg{
Data: &[]*LoaderJsonDataType{nil},
}
jsonCfg := NewDefaultCGRConfig()
if err = jsonCfg.loaderCfg[0].loadFromJSONCfg(cfg, jsonCfg.templates, jsonCfg.generalCfg.RSRSep); err != nil {
t.Error(err)
}
}
func TestEnabledCase1(t *testing.T) {
jsonCfg := NewDefaultCGRConfig()
if enabled := jsonCfg.loaderCfg.Enabled(); enabled {
t.Errorf("Expected %+v", enabled)
}
}
func TestEnabledCase2(t *testing.T) {
cfgJSONStr := `{
"loaders": [
{
"enabled": true,
},
],
}`
if jsonCfg, err := NewCGRConfigFromJSONStringWithDefaults(cfgJSONStr); err != nil {
t.Error(err)
} else if enabled := jsonCfg.loaderCfg.Enabled(); !enabled {
t.Errorf("Expected %+v", enabled)
}
}
func TestLoaderCfgloadFromJsonCfg(t *testing.T) {
cfgJSONStr := `{
"loaders": [
{
"enabled": true,
"run_delay": "1sa",
},
],
}`
expected := "time: unknown unit \"sa\" in duration \"1sa\""
if _, err := NewCGRConfigFromJSONStringWithDefaults(cfgJSONStr); err == nil || err.Error() != expected {
t.Errorf("Expected error: %s ,received: %v", expected, err)
}
}
func TestLoaderCfgAsMapInterfaceCase1(t *testing.T) {
cfgJSONStr := `{
"loaders": [
{
"id": "*default",
"enabled": false,
"tenant": "cgrates.org",
"dry_run": false,
"run_delay": "0",
"lockfile_path": ".cgr.lck",
"caches_conns": ["*internal:*caches"],
"field_separator": ",",
"tp_in_dir": "/var/spool/cgrates/loader/in",
"tp_out_dir": "/var/spool/cgrates/loader/out",
"data":[
{
"type": "*attributes",
"file_name": "Attributes.csv",
"fields": [
{"tag": "TenantID", "path": "Tenant", "type": "*variable", "value": "~*req.0", "mandatory": true},
{"tag": "ProfileID", "path": "ID", "type": "*variable", "value": "~*req.1", "mandatory": true},
],
},
],
},
],
}`
var flags []string
eMap := []map[string]interface{}{
{
utils.IDCfg: "*default",
utils.EnabledCfg: false,
utils.TenantCfg: "cgrates.org",
utils.DryRunCfg: false,
utils.RunDelayCfg: "0",
utils.LockFilePathCfg: ".cgr.lck",
utils.CachesConnsCfg: []string{utils.MetaInternal},
utils.FieldSepCfg: ",",
utils.TpInDirCfg: "/var/spool/cgrates/loader/in",
utils.TpOutDirCfg: "/var/spool/cgrates/loader/out",
utils.DataCfg: []map[string]interface{}{
{
utils.TypeCfg: "*filters",
utils.FilenameCfg: "Filters.csv",
utils.FlagsCfg: flags,
utils.FieldsCfg: []map[string]interface{}{
{
utils.TagCfg: "Tenant",
utils.PathCfg: "Tenant",
utils.TypeCfg: "*variable",
utils.ValueCfg: "~*req.0",
utils.MandatoryCfg: true,
},
{
utils.TagCfg: "ID",
utils.PathCfg: "ID",
utils.TypeCfg: "*variable",
utils.ValueCfg: "~*req.1",
utils.MandatoryCfg: true,
},
{
utils.TagCfg: "Type",
utils.PathCfg: "Type",
utils.TypeCfg: "*variable",
utils.ValueCfg: "~*req.2",
},
{
utils.TagCfg: "Element",
utils.PathCfg: "Element",
utils.TypeCfg: "*variable",
utils.ValueCfg: "~*req.3",
},
{
utils.TagCfg: "Values",
utils.PathCfg: "Values",
utils.TypeCfg: "*variable",
utils.ValueCfg: "~*req.4",
},
},
},
{
utils.TypeCfg: "*attributes",
utils.FilenameCfg: "Attributes.csv",
utils.FlagsCfg: flags,
utils.FieldsCfg: []map[string]interface{}{
{
utils.TagCfg: "TenantID",
utils.PathCfg: "Tenant",
utils.TypeCfg: "*variable",
utils.ValueCfg: "~*req.0",
utils.MandatoryCfg: true,
}, {
utils.TagCfg: "ProfileID",
utils.PathCfg: "ID",
utils.TypeCfg: "*variable",
utils.ValueCfg: "~*req.1",
utils.MandatoryCfg: true,
},
},
},
{
utils.TypeCfg: "*resources",
utils.FilenameCfg: "Resources.csv",
utils.FlagsCfg: flags,
utils.FieldsCfg: []map[string]interface{}{
{
utils.TagCfg: "Tenant",
utils.PathCfg: "Tenant",
utils.TypeCfg: "*variable",
utils.ValueCfg: "~*req.0",
utils.MandatoryCfg: true,
},
{
utils.TagCfg: "ID",
utils.PathCfg: "ID",
utils.TypeCfg: "*variable",
utils.ValueCfg: "~*req.1",
utils.MandatoryCfg: true,
},
{
utils.TagCfg: "FilterIDs",
utils.PathCfg: "FilterIDs",
utils.TypeCfg: "*variable",
utils.ValueCfg: "~*req.2",
},
{
utils.TagCfg: "Weight",
utils.PathCfg: "Weight",
utils.TypeCfg: "*variable",
utils.ValueCfg: "~*req.3",
},
{
utils.TagCfg: "TTL",
utils.PathCfg: "UsageTTL",
utils.TypeCfg: "*variable",
utils.ValueCfg: "~*req.4",
},
{
utils.TagCfg: "Limit",
utils.PathCfg: "Limit",
utils.TypeCfg: "*variable",
utils.ValueCfg: "~*req.5",
},
{
utils.TagCfg: "AllocationMessage",
utils.PathCfg: "AllocationMessage",
utils.TypeCfg: "*variable",
utils.ValueCfg: "~*req.6",
},
{
utils.TagCfg: "Blocker",
utils.PathCfg: "Blocker",
utils.TypeCfg: "*variable",
utils.ValueCfg: "~*req.7",
},
{
utils.TagCfg: "Stored",
utils.PathCfg: "Stored",
utils.TypeCfg: "*variable",
utils.ValueCfg: "~*req.8",
},
{
utils.TagCfg: "ThresholdIDs",
utils.PathCfg: "ThresholdIDs",
utils.TypeCfg: "*variable",
utils.ValueCfg: "~*req.9",
},
},
},
{
utils.TypeCfg: "*stats",
utils.FilenameCfg: "Stats.csv",
utils.FlagsCfg: flags,
utils.FieldsCfg: []map[string]interface{}{
{
utils.TagCfg: "Tenant",
utils.PathCfg: "Tenant",
utils.TypeCfg: "*variable",
utils.ValueCfg: "~*req.0",
utils.MandatoryCfg: true,
},
{
utils.TagCfg: "ID",
utils.PathCfg: "ID",
utils.TypeCfg: "*variable",
utils.ValueCfg: "~*req.1",
utils.MandatoryCfg: true,
},
{
utils.TagCfg: "FilterIDs",
utils.PathCfg: "FilterIDs",
utils.TypeCfg: "*variable",
utils.ValueCfg: "~*req.2",
},
{
utils.TagCfg: "Weight",
utils.PathCfg: "Weight",
utils.TypeCfg: "*variable",
utils.ValueCfg: "~*req.3",
},
{
utils.TagCfg: "QueueLength",
utils.PathCfg: "QueueLength",
utils.TypeCfg: "*variable",
utils.ValueCfg: "~*req.4",
},
{
utils.TagCfg: "TTL",
utils.PathCfg: "TTL",
utils.TypeCfg: "*variable",
utils.ValueCfg: "~*req.5",
},
{
utils.TagCfg: "MinItems",
utils.PathCfg: "MinItems",
utils.TypeCfg: "*variable",
utils.ValueCfg: "~*req.6",
},
{
utils.TagCfg: "MetricIDs",
utils.PathCfg: "MetricIDs",
utils.TypeCfg: "*variable",
utils.ValueCfg: "~*req.7",
},
{
utils.TagCfg: "MetricFilterIDs",
utils.PathCfg: "MetricFilterIDs",
utils.TypeCfg: "*variable",
utils.ValueCfg: "~*req.8",
},
{
utils.TagCfg: "Blocker",
utils.PathCfg: "Blocker",
utils.TypeCfg: "*variable",
utils.ValueCfg: "~*req.9",
},
{
utils.TagCfg: "Stored",
utils.PathCfg: "Stored",
utils.TypeCfg: "*variable",
utils.ValueCfg: "~*req.10",
},
{
utils.TagCfg: "ThresholdIDs",
utils.PathCfg: "ThresholdIDs",
utils.TypeCfg: "*variable",
utils.ValueCfg: "~*req.11",
},
},
},
{
utils.TypeCfg: "*thresholds",
utils.FilenameCfg: "Thresholds.csv",
utils.FlagsCfg: flags,
utils.FieldsCfg: []map[string]interface{}{
{
utils.TagCfg: "Tenant",
utils.PathCfg: "Tenant",
utils.TypeCfg: "*variable",
utils.ValueCfg: "~*req.0",
utils.MandatoryCfg: true,
},
{
utils.TagCfg: "ID",
utils.PathCfg: "ID",
utils.TypeCfg: "*variable",
utils.ValueCfg: "~*req.1",
utils.MandatoryCfg: true,
},
{
utils.TagCfg: "FilterIDs",
utils.PathCfg: "FilterIDs",
utils.TypeCfg: "*variable",
utils.ValueCfg: "~*req.2",
},
{
utils.TagCfg: "Weight",
utils.PathCfg: "Weight",
utils.TypeCfg: "*variable",
utils.ValueCfg: "~*req.3",
},
{
utils.TagCfg: "MaxHits",
utils.PathCfg: "MaxHits",
utils.TypeCfg: "*variable",
utils.ValueCfg: "~*req.4",
},
{
utils.TagCfg: "MinHits",
utils.PathCfg: "MinHits",
utils.TypeCfg: "*variable",
utils.ValueCfg: "~*req.5",
},
{
utils.TagCfg: "MinSleep",
utils.PathCfg: "MinSleep",
utils.TypeCfg: "*variable",
utils.ValueCfg: "~*req.6",
},
{
utils.TagCfg: "Blocker",
utils.PathCfg: "Blocker",
utils.TypeCfg: "*variable",
utils.ValueCfg: "~*req.7",
},
{
utils.TagCfg: "ActionProfileIDs",
utils.PathCfg: "ActionProfileIDs",
utils.TypeCfg: "*variable",
utils.ValueCfg: "~*req.8",
},
{
utils.TagCfg: "Async",
utils.PathCfg: "Async",
utils.TypeCfg: "*variable",
utils.ValueCfg: "~*req.9",
},
},
},
{
utils.TypeCfg: "*routes",
utils.FilenameCfg: "Routes.csv",
utils.FlagsCfg: flags,
utils.FieldsCfg: []map[string]interface{}{
{
utils.TagCfg: "Tenant",
utils.PathCfg: "Tenant",
utils.TypeCfg: "*variable",
utils.ValueCfg: "~*req.0",
utils.MandatoryCfg: true,
},
{
utils.TagCfg: "ID",
utils.PathCfg: "ID",
utils.TypeCfg: "*variable",
utils.ValueCfg: "~*req.1",
utils.MandatoryCfg: true,
},
{
utils.TagCfg: "FilterIDs",
utils.PathCfg: "FilterIDs",
utils.TypeCfg: "*variable",
utils.ValueCfg: "~*req.2",
},
{
utils.TagCfg: "Weights",
utils.PathCfg: "Weights",
utils.TypeCfg: "*variable",
utils.ValueCfg: "~*req.3",
},
{
utils.TagCfg: "Sorting",
utils.PathCfg: "Sorting",
utils.TypeCfg: "*variable",
utils.ValueCfg: "~*req.4",
},
{
utils.TagCfg: "SortingParameters",
utils.PathCfg: "SortingParameters",
utils.TypeCfg: "*variable",
utils.ValueCfg: "~*req.5",
},
{
utils.TagCfg: "RouteID",
utils.PathCfg: "RouteID",
utils.TypeCfg: "*variable",
utils.ValueCfg: "~*req.6",
},
{
utils.TagCfg: "RouteFilterIDs",
utils.PathCfg: "RouteFilterIDs",
utils.TypeCfg: "*variable",
utils.ValueCfg: "~*req.7",
},
{
utils.TagCfg: "RouteAccountIDs",
utils.PathCfg: "RouteAccountIDs",
utils.TypeCfg: "*variable",
utils.ValueCfg: "~*req.8",
},
{
utils.TagCfg: "RouteRateProfileIDs",
utils.PathCfg: "RouteRateProfileIDs",
utils.TypeCfg: "*variable",
utils.ValueCfg: "~*req.9",
},
{
utils.TagCfg: "RouteResourceIDs",
utils.PathCfg: "RouteResourceIDs",
utils.TypeCfg: "*variable",
utils.ValueCfg: "~*req.10",
},
{
utils.TagCfg: "RouteStatIDs",
utils.PathCfg: "RouteStatIDs",
utils.TypeCfg: "*variable",
utils.ValueCfg: "~*req.11",
},
{
utils.TagCfg: "RouteWeights",
utils.PathCfg: "RouteWeights",
utils.TypeCfg: "*variable",
utils.ValueCfg: "~*req.12",
},
{
utils.TagCfg: "RouteBlocker",
utils.PathCfg: "RouteBlocker",
utils.TypeCfg: "*variable",
utils.ValueCfg: "~*req.13",
},
{
utils.TagCfg: "RouteParameters",
utils.PathCfg: "RouteParameters",
utils.TypeCfg: "*variable",
utils.ValueCfg: "~*req.14",
},
},
},
{
utils.TypeCfg: "*chargers",
utils.FilenameCfg: "Chargers.csv",
utils.FlagsCfg: flags,
utils.FieldsCfg: []map[string]interface{}{
{
utils.TagCfg: "Tenant",
utils.PathCfg: "Tenant",
utils.TypeCfg: "*variable",
utils.ValueCfg: "~*req.0",
utils.MandatoryCfg: true,
},
{
utils.TagCfg: "ID",
utils.PathCfg: "ID",
utils.TypeCfg: "*variable",
utils.ValueCfg: "~*req.1",
utils.MandatoryCfg: true,
},
{
utils.TagCfg: "FilterIDs",
utils.PathCfg: "FilterIDs",
utils.TypeCfg: "*variable",
utils.ValueCfg: "~*req.2",
},
{
utils.TagCfg: "Weight",
utils.PathCfg: "Weight",
utils.TypeCfg: "*variable",
utils.ValueCfg: "~*req.3",
},
{
utils.TagCfg: "RunID",
utils.PathCfg: "RunID",
utils.TypeCfg: "*variable",
utils.ValueCfg: "~*req.4",
},
{
utils.TagCfg: "AttributeIDs",
utils.PathCfg: "AttributeIDs",
utils.TypeCfg: "*variable",
utils.ValueCfg: "~*req.5",
},
},
},
{
utils.TypeCfg: "*dispatchers",
utils.FilenameCfg: "DispatcherProfiles.csv",
utils.FlagsCfg: flags,
utils.FieldsCfg: []map[string]interface{}{
{
utils.TagCfg: "Tenant",
utils.PathCfg: "Tenant",
utils.TypeCfg: "*variable",
utils.ValueCfg: "~*req.0",
utils.MandatoryCfg: true,
},
{
utils.TagCfg: "ID",
utils.PathCfg: "ID",
utils.TypeCfg: "*variable",
utils.ValueCfg: "~*req.1",
utils.MandatoryCfg: true,
},
{
utils.TagCfg: "FilterIDs",
utils.PathCfg: "FilterIDs",
utils.TypeCfg: "*variable",
utils.ValueCfg: "~*req.2",
},
{
utils.TagCfg: "Weight",
utils.PathCfg: "Weight",
utils.TypeCfg: "*variable",
utils.ValueCfg: "~*req.3",
},
{
utils.TagCfg: "Strategy",
utils.PathCfg: "Strategy",
utils.TypeCfg: "*variable",
utils.ValueCfg: "~*req.4",
},
{
utils.TagCfg: "StrategyParameters",
utils.PathCfg: "StrategyParameters",
utils.TypeCfg: "*variable",
utils.ValueCfg: "~*req.5",
},
{
utils.TagCfg: "ConnID",
utils.PathCfg: "ConnID",
utils.TypeCfg: "*variable",
utils.ValueCfg: "~*req.6",
},
{
utils.TagCfg: "ConnFilterIDs",
utils.PathCfg: "ConnFilterIDs",
utils.TypeCfg: "*variable",
utils.ValueCfg: "~*req.7",
},
{
utils.TagCfg: "ConnWeight",
utils.PathCfg: "ConnWeight",
utils.TypeCfg: "*variable",
utils.ValueCfg: "~*req.8",
},
{
utils.TagCfg: "ConnBlocker",
utils.PathCfg: "ConnBlocker",
utils.TypeCfg: "*variable",
utils.ValueCfg: "~*req.9",
},
{
utils.TagCfg: "ConnParameters",
utils.PathCfg: "ConnParameters",
utils.TypeCfg: "*variable",
utils.ValueCfg: "~*req.10",
},
},
},
{
utils.TypeCfg: "*dispatcher_hosts",
utils.FilenameCfg: "DispatcherHosts.csv",
utils.FlagsCfg: flags,
utils.FieldsCfg: []map[string]interface{}{
{
utils.TagCfg: "Tenant",
utils.PathCfg: "Tenant",
utils.TypeCfg: "*variable",
utils.ValueCfg: "~*req.0",
utils.MandatoryCfg: true,
},
{
utils.TagCfg: "ID",
utils.PathCfg: "ID",
utils.TypeCfg: "*variable",
utils.ValueCfg: "~*req.1",
utils.MandatoryCfg: true,
},
{
utils.TagCfg: "Address",
utils.PathCfg: "Address",
utils.TypeCfg: "*variable",
utils.ValueCfg: "~*req.2",
},
{
utils.TagCfg: "Transport",
utils.PathCfg: "Transport",
utils.TypeCfg: "*variable",
utils.ValueCfg: "~*req.3",
},
{
utils.TagCfg: "ConnectAttempts",
utils.PathCfg: "ConnectAttempts",
utils.TypeCfg: "*variable",
utils.ValueCfg: "~*req.4",
},
{
utils.TagCfg: "Reconnects",
utils.PathCfg: "Reconnects",
utils.TypeCfg: "*variable",
utils.ValueCfg: "~*req.5",
},
{
utils.TagCfg: "ConnectTimeout",
utils.PathCfg: "ConnectTimeout",
utils.TypeCfg: "*variable",
utils.ValueCfg: "~*req.6",
},
{
utils.TagCfg: "ReplyTimeout",
utils.PathCfg: "ReplyTimeout",
utils.TypeCfg: "*variable",
utils.ValueCfg: "~*req.7",
},
{
utils.TagCfg: "TLS",
utils.PathCfg: "TLS",
utils.TypeCfg: "*variable",
utils.ValueCfg: "~*req.8",
},
{
utils.TagCfg: "ClientKey",
utils.PathCfg: "ClientKey",
utils.TypeCfg: "*variable",
utils.ValueCfg: "~*req.9",
},
{
utils.TagCfg: "ClientCertificate",
utils.PathCfg: "ClientCertificate",
utils.TypeCfg: "*variable",
utils.ValueCfg: "~*req.10",
},
{
utils.TagCfg: "CaCertificate",
utils.PathCfg: "CaCertificate",
utils.TypeCfg: "*variable",
utils.ValueCfg: "~*req.11",
},
},
},
{
utils.TypeCfg: "*rate_profiles",
utils.FilenameCfg: "RateProfiles.csv",
utils.FlagsCfg: flags,
utils.FieldsCfg: []map[string]interface{}{
{
utils.TagCfg: "Tenant",
utils.PathCfg: "Tenant",
utils.TypeCfg: "*variable",
utils.ValueCfg: "~*req.0",
utils.MandatoryCfg: true,
},
{
utils.TagCfg: "ID",
utils.PathCfg: "ID",
utils.TypeCfg: "*variable",
utils.ValueCfg: "~*req.1",
utils.MandatoryCfg: true,
},
{
utils.TagCfg: "FilterIDs",
utils.PathCfg: "FilterIDs",
utils.TypeCfg: "*variable",
utils.ValueCfg: "~*req.2",
},
{
utils.TagCfg: "Weight",
utils.PathCfg: "Weight",
utils.TypeCfg: "*variable",
utils.ValueCfg: "~*req.3",
},
{
utils.TagCfg: "MinCost",
utils.PathCfg: "MinCost",
utils.TypeCfg: "*variable",
utils.ValueCfg: "~*req.4",
},
{
utils.TagCfg: "MaxCost",
utils.PathCfg: "MaxCost",
utils.TypeCfg: "*variable",
utils.ValueCfg: "~*req.5",
},
{
utils.TagCfg: "MaxCostStrategy",
utils.PathCfg: "MaxCostStrategy",
utils.TypeCfg: "*variable",
utils.ValueCfg: "~*req.6",
},
{
utils.TagCfg: "RateID",
utils.PathCfg: "RateID",
utils.TypeCfg: "*variable",
utils.ValueCfg: "~*req.7",
},
{
utils.TagCfg: "RateFilterIDs",
utils.PathCfg: "RateFilterIDs",
utils.TypeCfg: "*variable",
utils.ValueCfg: "~*req.8",
},
{
utils.TagCfg: "RateActivationTimes",
utils.PathCfg: "RateActivationTimes",
utils.TypeCfg: "*variable",
utils.ValueCfg: "~*req.9",
},
{
utils.TagCfg: "RateWeight",
utils.PathCfg: "RateWeight",
utils.TypeCfg: "*variable",
utils.ValueCfg: "~*req.10",
},
{
utils.TagCfg: "RateBlocker",
utils.PathCfg: "RateBlocker",
utils.TypeCfg: "*variable",
utils.ValueCfg: "~*req.11",
},
{
utils.TagCfg: "RateIntervalStart",
utils.PathCfg: "RateIntervalStart",
utils.TypeCfg: "*variable",
utils.ValueCfg: "~*req.12",
},
{
utils.TagCfg: "RateFixedFee",
utils.PathCfg: "RateFixedFee",
utils.TypeCfg: "*variable",
utils.ValueCfg: "~*req.13",
},
{
utils.TagCfg: "RateRecurrentFee",
utils.PathCfg: "RateRecurrentFee",
utils.TypeCfg: "*variable",
utils.ValueCfg: "~*req.14",
},
{
utils.TagCfg: "RateUnit",
utils.PathCfg: "RateUnit",
utils.TypeCfg: "*variable",
utils.ValueCfg: "~*req.15",
},
{
utils.TagCfg: "RateIncrement",
utils.PathCfg: "RateIncrement",
utils.TypeCfg: "*variable",
utils.ValueCfg: "~*req.16",
},
},
},
{
utils.TypeCfg: "*action_profiles",
utils.FilenameCfg: "ActionProfiles.csv",
utils.FlagsCfg: flags,
utils.FieldsCfg: []map[string]interface{}{
{
utils.TagCfg: "Tenant",
utils.PathCfg: "Tenant",
utils.TypeCfg: "*variable",
utils.ValueCfg: "~*req.0",
utils.MandatoryCfg: true,
},
{
utils.TagCfg: "ID",
utils.PathCfg: "ID",
utils.TypeCfg: "*variable",
utils.ValueCfg: "~*req.1",
utils.MandatoryCfg: true,
},
{
utils.TagCfg: "FilterIDs",
utils.PathCfg: "FilterIDs",
utils.TypeCfg: "*variable",
utils.ValueCfg: "~*req.2",
},
{
utils.TagCfg: "Weight",
utils.PathCfg: "Weight",
utils.TypeCfg: "*variable",
utils.ValueCfg: "~*req.3",
},
{
utils.TagCfg: "Schedule",
utils.PathCfg: "Schedule",
utils.TypeCfg: "*variable",
utils.ValueCfg: "~*req.4",
},
{
utils.TagCfg: "TargetType",
utils.PathCfg: "TargetType",
utils.TypeCfg: "*variable",
utils.ValueCfg: "~*req.5",
},
{
utils.TagCfg: "TargetIDs",
utils.PathCfg: "TargetIDs",
utils.TypeCfg: "*variable",
utils.ValueCfg: "~*req.6",
},
{
utils.TagCfg: "ActionID",
utils.PathCfg: "ActionID",
utils.TypeCfg: "*variable",
utils.ValueCfg: "~*req.7",
},
{
utils.TagCfg: "ActionFilterIDs",
utils.PathCfg: "ActionFilterIDs",
utils.TypeCfg: "*variable",
utils.ValueCfg: "~*req.8",
},
{
utils.TagCfg: "ActionBlocker",
utils.PathCfg: "ActionBlocker",
utils.TypeCfg: "*variable",
utils.ValueCfg: "~*req.9",
},
{
utils.TagCfg: "ActionTTL",
utils.PathCfg: "ActionTTL",
utils.TypeCfg: "*variable",
utils.ValueCfg: "~*req.10",
},
{
utils.TagCfg: "ActionType",
utils.PathCfg: "ActionType",
utils.TypeCfg: "*variable",
utils.ValueCfg: "~*req.11",
},
{
utils.TagCfg: "ActionOpts",
utils.PathCfg: "ActionOpts",
utils.TypeCfg: "*variable",
utils.ValueCfg: "~*req.12",
},
{
utils.TagCfg: "ActionPath",
utils.PathCfg: "ActionPath",
utils.TypeCfg: "*variable",
utils.ValueCfg: "~*req.13",
},
{
utils.TagCfg: "ActionValue",
utils.PathCfg: "ActionValue",
utils.TypeCfg: "*variable",
utils.ValueCfg: "~*req.14",
},
},
},
{
utils.TypeCfg: "*accounts",
utils.FilenameCfg: "Accounts.csv",
utils.FlagsCfg: flags,
utils.FieldsCfg: []map[string]interface{}{
{
utils.TagCfg: "Tenant",
utils.PathCfg: "Tenant",
utils.TypeCfg: "*variable",
utils.ValueCfg: "~*req.0",
utils.MandatoryCfg: true,
},
{
utils.TagCfg: "ID",
utils.PathCfg: "ID",
utils.TypeCfg: "*variable",
utils.ValueCfg: "~*req.1",
utils.MandatoryCfg: true,
},
{
utils.TagCfg: "FilterIDs",
utils.PathCfg: "FilterIDs",
utils.TypeCfg: "*variable",
utils.ValueCfg: "~*req.2",
},
{
utils.TagCfg: "Weights",
utils.PathCfg: "Weights",
utils.TypeCfg: "*variable",
utils.ValueCfg: "~*req.3",
},
{
utils.TagCfg: "Opts",
utils.PathCfg: "Opts",
utils.TypeCfg: "*variable",
utils.ValueCfg: "~*req.4",
},
{
utils.TagCfg: "BalanceID",
utils.PathCfg: "BalanceID",
utils.TypeCfg: "*variable",
utils.ValueCfg: "~*req.5",
},
{
utils.TagCfg: "BalanceFilterIDs",
utils.PathCfg: "BalanceFilterIDs",
utils.TypeCfg: "*variable",
utils.ValueCfg: "~*req.6",
},
{
utils.TagCfg: "BalanceWeights",
utils.PathCfg: "BalanceWeights",
utils.TypeCfg: "*variable",
utils.ValueCfg: "~*req.7",
},
{
utils.TagCfg: "BalanceType",
utils.PathCfg: "BalanceType",
utils.TypeCfg: "*variable",
utils.ValueCfg: "~*req.8",
},
{
utils.TagCfg: "BalanceUnits",
utils.PathCfg: "BalanceUnits",
utils.TypeCfg: "*variable",
utils.ValueCfg: "~*req.9",
},
{
utils.TagCfg: "BalanceUnitFactors",
utils.PathCfg: "BalanceUnitFactors",
utils.TypeCfg: "*variable",
utils.ValueCfg: "~*req.10",
},
{
utils.TagCfg: "BalanceOpts",
utils.PathCfg: "BalanceOpts",
utils.TypeCfg: "*variable",
utils.ValueCfg: "~*req.11",
},
{
utils.TagCfg: "BalanceCostIncrements",
utils.PathCfg: "BalanceCostIncrements",
utils.TypeCfg: "*variable",
utils.ValueCfg: "~*req.12",
},
{
utils.TagCfg: "BalanceAttributeIDs",
utils.PathCfg: "BalanceAttributeIDs",
utils.TypeCfg: "*variable",
utils.ValueCfg: "~*req.13",
},
{
utils.TagCfg: "BalanceRateProfileIDs",
utils.PathCfg: "BalanceRateProfileIDs",
utils.TypeCfg: "*variable",
utils.ValueCfg: "~*req.14",
},
{
utils.TagCfg: "ThresholdIDs",
utils.PathCfg: "ThresholdIDs",
utils.TypeCfg: "*variable",
utils.ValueCfg: "~*req.15",
},
},
},
},
},
}
if cfgCgr, err := NewCGRConfigFromJSONStringWithDefaults(cfgJSONStr); err != nil {
t.Error(err)
} else {
rcv := cfgCgr.loaderCfg.AsMapInterface(cfgCgr.generalCfg.RSRSep)
if len(cfgCgr.loaderCfg) != 1 {
t.Errorf("expected: <%+v>, \nreceived: <%+v>", 1, len(cfgCgr.loaderCfg))
} else if !reflect.DeepEqual(rcv, eMap) {
t.Errorf("expected: <%+v>, \nreceived: <%+v>", utils.ToJSON(eMap), utils.ToJSON(rcv))
}
}
}
func TestLoaderCfgAsMapInterfaceCase2(t *testing.T) {
cfgJSONStr := `{
"loaders": [
{
"id": "*default",
"enabled": false,
"tenant": "~*req.Destination1",
"dry_run": false,
"run_delay": "1",
"lockfile_path": ".cgr.lck",
"caches_conns": ["*conn1"],
"field_separator": ",",
"tp_in_dir": "/var/spool/cgrates/loader/in",
"tp_out_dir": "/var/spool/cgrates/loader/out",
"data":[
{
"type": "*attributes",
"file_name": "Attributes.csv",
"fields": [
{"tag": "TenantID", "path": "Tenant", "type": "*variable", "value": "~req.0", "mandatory": true},
{"tag": "ProfileID", "path": "ID", "type": "*variable", "value": "~*req.1", "mandatory": true},
],
},
],
},
],
}`
eMap := []map[string]interface{}{
{
utils.IDCfg: "*default",
utils.EnabledCfg: false,
utils.TenantCfg: "~*req.Destination1",
utils.DryRunCfg: false,
utils.RunDelayCfg: "0",
utils.LockFilePathCfg: ".cgr.lck",
utils.CachesConnsCfg: []string{"*conn1"},
utils.FieldSepCfg: ",",
utils.TpInDirCfg: "/var/spool/cgrates/loader/in",
utils.TpOutDirCfg: "/var/spool/cgrates/loader/out",
utils.DataCfg: []map[string]interface{}{
{
utils.TypeCfg: "*attributes",
utils.FilenameCfg: "Attributes.csv",
utils.FieldsCfg: []map[string]interface{}{
{
utils.TagCfg: "TenantID",
utils.PathCfg: "Tenant",
utils.TypeCfg: "*variable",
utils.ValueCfg: "~*req.0",
utils.MandatoryCfg: true,
}, {
utils.TagCfg: "ProfileID",
utils.PathCfg: "ID",
utils.TypeCfg: "*variable",
utils.ValueCfg: "~*req.1",
utils.MandatoryCfg: true,
},
},
},
},
},
}
if jsonCfg, err := NewCGRConfigFromJSONStringWithDefaults(cfgJSONStr); err != nil {
t.Error(err)
} else if rcv := jsonCfg.loaderCfg.AsMapInterface(jsonCfg.generalCfg.RSRSep).([]map[string]interface{}); !reflect.DeepEqual(rcv[0][utils.Tenant], eMap[0][utils.Tenant]) {
t.Errorf("Expected %+v, received %+v", rcv[0][utils.Tenant], eMap[0][utils.Tenant])
}
}
func TestLoaderSCfgsClone(t *testing.T) {
ban := LoaderSCfgs{{
Enabled: true,
ID: utils.MetaDefault,
Tenant: "cgrates.org",
LockFilePath: ".cgr.lck",
CacheSConns: []string{utils.ConcatenatedKey(utils.MetaInternal, utils.MetaCaches), "*conn1"},
FieldSeparator: ",",
TpInDir: "/var/spool/cgrates/loader/in",
TpOutDir: "/var/spool/cgrates/loader/out",
Data: []*LoaderDataType{{
Type: "*attributes",
Filename: "Attributes.csv",
Flags: utils.FlagsWithParams{},
Fields: []*FCTemplate{
{
Tag: "TenantID",
Path: "Tenant",
pathSlice: []string{"Tenant"},
Type: utils.MetaComposed,
Value: NewRSRParsersMustCompile("cgrates.org", utils.InfieldSep),
Mandatory: true,
Layout: time.RFC3339,
},
}},
},
}}
rcv := ban.Clone()
if !reflect.DeepEqual(ban, *rcv) {
t.Errorf("Expected: %+v\nReceived: %+v", utils.ToJSON(ban), utils.ToJSON(*rcv))
}
if (*rcv)[0].CacheSConns[1] = ""; ban[0].CacheSConns[1] != "*conn1" {
t.Errorf("Expected clone to not modify the cloned")
}
if (*rcv)[0].Data[0].Type = ""; ban[0].Data[0].Type != "*attributes" {
t.Errorf("Expected clone to not modify the cloned")
}
}
func TestEqualsLoaderDatasType(t *testing.T) {
v1 := []*LoaderDataType{
{
Type: "*json",
Filename: "file.json",
Flags: utils.FlagsWithParams{
"FLAG_1": {
"PARAM_1": []string{"param1"},
},
},
Fields: []*FCTemplate{
{
Type: "Type",
Tag: "Tag",
},
},
},
}
v2 := []*LoaderDataType{
{
Type: "*xml",
Filename: "file.xml",
Flags: utils.FlagsWithParams{
"FLAG_2": {
"PARAM_2": []string{"param2"},
},
},
Fields: []*FCTemplate{
{
Type: "Type2",
Tag: "Tag2",
},
},
},
}
if equalsLoaderDatasType(v1, v2) {
t.Error("Loaders should not match")
}
v1 = v2
if !equalsLoaderDatasType(v1, v2) {
t.Error("Loaders should match")
}
v2 = []*LoaderDataType{}
if equalsLoaderDatasType(v1, v2) {
t.Error("Loaders should not match")
}
}
func TestDiffLoaderJsonCfg(t *testing.T) {
v1 := &LoaderSCfg{
ID: "LoaderID",
Enabled: true,
Tenant: "cgrates.org",
DryRun: false,
RunDelay: 1 * time.Millisecond,
LockFilePath: "lockFileName",
CacheSConns: []string{"*localhost"},
FieldSeparator: ";",
TpInDir: "/tp/in/dir",
TpOutDir: "/tp/out/dir",
Data: nil,
}
v2 := &LoaderSCfg{
ID: "LoaderID2",
Enabled: false,
Tenant: "itsyscom.com",
DryRun: true,
RunDelay: 2 * time.Millisecond,
LockFilePath: "lockFileName2",
CacheSConns: []string{"*birpc"},
FieldSeparator: ":",
TpInDir: "/tp/in/dir/2",
TpOutDir: "/tp/out/dir/2",
Data: []*LoaderDataType{
{
Type: "*xml",
Filename: "file.xml",
Flags: utils.FlagsWithParams{
"FLAG_2": {
"PARAM_2": []string{"param2"},
},
},
Fields: []*FCTemplate{
{
Type: "Type2",
Tag: "Tag2",
},
},
},
},
}
expected := &LoaderJsonCfg{
ID: utils.StringPointer("LoaderID2"),
Enabled: utils.BoolPointer(false),
Tenant: utils.StringPointer("itsyscom.com"),
Dry_run: utils.BoolPointer(true),
Run_delay: utils.StringPointer("2ms"),
Lockfile_path: utils.StringPointer("lockFileName2"),
Caches_conns: &[]string{"*birpc"},
Field_separator: utils.StringPointer(":"),
Tp_in_dir: utils.StringPointer("/tp/in/dir/2"),
Tp_out_dir: utils.StringPointer("/tp/out/dir/2"),
Data: &[]*LoaderJsonDataType{
{
Type: utils.StringPointer("*xml"),
File_name: utils.StringPointer("file.xml"),
Flags: &[]string{"FLAG_2:PARAM_2:param2"},
Fields: &[]*FcTemplateJsonCfg{
{
Type: utils.StringPointer("Type2"),
Tag: utils.StringPointer("Tag2"),
Layout: utils.StringPointer(""),
},
},
},
},
}
rcv := diffLoaderJsonCfg(v1, v2, ";")
if !reflect.DeepEqual(rcv, expected) {
t.Errorf("Expected %v \n but received \n %v", utils.ToJSON(expected), utils.ToJSON(rcv))
}
v1 = v2
expected = &LoaderJsonCfg{}
rcv = diffLoaderJsonCfg(v1, v2, ";")
if !reflect.DeepEqual(rcv, expected) {
t.Errorf("Expected %v \n but received \n %v", utils.ToJSON(expected), utils.ToJSON(rcv))
}
}
func TestEqualsLoadersJsonCfg(t *testing.T) {
v1 := LoaderSCfgs{
{
ID: "LoaderID",
Enabled: true,
Tenant: "cgrates.org",
DryRun: false,
RunDelay: 1 * time.Millisecond,
LockFilePath: "lockFileName",
CacheSConns: []string{"*localhost"},
FieldSeparator: ";",
TpInDir: "/tp/in/dir",
TpOutDir: "/tp/out/dir",
Data: nil,
},
}
v2 := LoaderSCfgs{
{
ID: "LoaderID2",
Enabled: false,
Tenant: "cgrates.org",
DryRun: true,
RunDelay: 2 * time.Millisecond,
LockFilePath: "lockFileName2",
CacheSConns: []string{"*birpc"},
FieldSeparator: ":",
TpInDir: "/tp/in/dir/2",
TpOutDir: "/tp/out/dir/2",
Data: []*LoaderDataType{
{
Type: "*xml",
Filename: "file.xml",
Flags: utils.FlagsWithParams{
"FLAG_2": {
"PARAM_2": []string{"param2"},
},
},
Fields: []*FCTemplate{
{
Type: "Type2",
Tag: "Tag2",
},
},
},
},
},
}
if equalsLoadersJsonCfg(v1, v2) {
t.Error("Loaders shouldn't match")
}
v2 = v1
if !equalsLoadersJsonCfg(v1, v2) {
t.Error("Loaders shouldn't match")
}
v2 = LoaderSCfgs{}
if equalsLoadersJsonCfg(v1, v2) {
t.Error("Loaders shouldn't match")
}
}
func TestDiffLoadersJsonCfg(t *testing.T) {
var d []*LoaderJsonCfg
v1 := LoaderSCfgs{
{
ID: "LoaderID",
Enabled: false,
Tenant: "cgrates.org",
DryRun: false,
RunDelay: 1 * time.Millisecond,
LockFilePath: "lockFileName",
CacheSConns: []string{"*localhost"},
FieldSeparator: ";",
TpInDir: "/tp/in/dir",
TpOutDir: "/tp/out/dir",
Data: nil,
},
}
v2 := LoaderSCfgs{
{
ID: "LoaderID2",
Enabled: true,
Tenant: "itsyscom.com",
DryRun: true,
RunDelay: 2 * time.Millisecond,
LockFilePath: "lockFileName2",
CacheSConns: []string{"*birpc"},
FieldSeparator: ":",
TpInDir: "/tp/in/dir/2",
TpOutDir: "/tp/out/dir/2",
Data: []*LoaderDataType{
{
Type: "*xml",
Filename: "file.xml",
Flags: utils.FlagsWithParams{
"FLAG_2": {
"PARAM_2": []string{"param2"},
},
},
Fields: []*FCTemplate{
{
Type: "Type2",
Tag: "Tag2",
},
},
},
},
},
}
expected := []*LoaderJsonCfg{
{
ID: utils.StringPointer("LoaderID2"),
Enabled: utils.BoolPointer(true),
Tenant: utils.StringPointer("itsyscom.com"),
Dry_run: utils.BoolPointer(true),
Run_delay: utils.StringPointer("2ms"),
Lockfile_path: utils.StringPointer("lockFileName2"),
Caches_conns: &[]string{"*birpc"},
Field_separator: utils.StringPointer(":"),
Tp_in_dir: utils.StringPointer("/tp/in/dir/2"),
Tp_out_dir: utils.StringPointer("/tp/out/dir/2"),
Data: &[]*LoaderJsonDataType{
{
Type: utils.StringPointer("*xml"),
File_name: utils.StringPointer("file.xml"),
Flags: &[]string{"FLAG_2:PARAM_2:param2"},
Fields: &[]*FcTemplateJsonCfg{
{
Type: utils.StringPointer("Type2"),
Tag: utils.StringPointer("Tag2"),
Layout: utils.StringPointer(""),
},
},
},
},
},
}
rcv := diffLoadersJsonCfg(d, v1, v2, ";")
if !reflect.DeepEqual(rcv, expected) {
t.Errorf("Expected %v \n but received \n %v", utils.ToJSON(expected), utils.ToJSON(rcv))
}
v1 = v2
expected = nil
rcv = diffLoadersJsonCfg(d, v1, v2, ";")
if !reflect.DeepEqual(rcv, expected) {
t.Errorf("Expected %v \n but received \n %v", utils.ToJSON(expected), utils.ToJSON(rcv))
}
}
func TestLockFolderRelativePath(t *testing.T) {
ldr := &LoaderSCfg{
TpInDir: "/var/spool/cgrates/loader/in/",
TpOutDir: "/var/spool/cgrates/loader/out/",
LockFilePath: utils.ResourcesCsv,
}
jsonCfg := &LoaderJsonCfg{
ID: utils.StringPointer("loaderid"),
Enabled: utils.BoolPointer(true),
Tenant: utils.StringPointer("cgrates.org"),
Dry_run: utils.BoolPointer(false),
Lockfile_path: utils.StringPointer(utils.ResourcesCsv),
Field_separator: utils.StringPointer(utils.InfieldSep),
Tp_in_dir: utils.StringPointer("/var/spool/cgrates/loader/in/"),
Tp_out_dir: utils.StringPointer("/var/spool/cgrates/loader/out/"),
}
expPath := path.Join(ldr.LockFilePath)
if err = ldr.loadFromJSONCfg(jsonCfg, map[string][]*FCTemplate{}, utils.InfieldSep); err != nil {
t.Error(err)
} else if ldr.LockFilePath != expPath {
t.Errorf("Expected %v \n but received \n %v", expPath, ldr.LockFilePath)
}
}
func TestLockFolderNonRelativePath(t *testing.T) {
ldr := &LoaderSCfg{
TpInDir: "/var/spool/cgrates/loader/in/",
TpOutDir: "/var/spool/cgrates/loader/out/",
LockFilePath: utils.ResourcesCsv,
}
jsonCfg := &LoaderJsonCfg{
ID: utils.StringPointer("loaderid"),
Enabled: utils.BoolPointer(true),
Tenant: utils.StringPointer("cgrates.org"),
Dry_run: utils.BoolPointer(false),
Lockfile_path: utils.StringPointer(path.Join("/tmp/", utils.ResourcesCsv)),
Field_separator: utils.StringPointer(utils.InfieldSep),
Tp_in_dir: utils.StringPointer("/var/spool/cgrates/loader/in/"),
Tp_out_dir: utils.StringPointer("/var/spool/cgrates/loader/out/"),
}
expPath := path.Join("/tmp/", utils.ResourcesCsv)
if err = ldr.loadFromJSONCfg(jsonCfg, map[string][]*FCTemplate{}, utils.InfieldSep); err != nil {
t.Error(err)
} else if ldr.LockFilePath != expPath {
t.Errorf("Expected %v \n but received \n %v", expPath, ldr.LockFilePath)
}
}
func TestLockFolderIsDir(t *testing.T) {
ldr := &LoaderSCfg{
LockFilePath: "test",
}
jsonCfg := &LoaderJsonCfg{
ID: utils.StringPointer("loaderid"),
Enabled: utils.BoolPointer(true),
Tenant: utils.StringPointer("cgrates.org"),
Dry_run: utils.BoolPointer(false),
Lockfile_path: utils.StringPointer("/tmp"),
Field_separator: utils.StringPointer(utils.InfieldSep),
Tp_in_dir: utils.StringPointer("/var/spool/cgrates/loader/in/"),
Tp_out_dir: utils.StringPointer("/var/spool/cgrates/loader/out/"),
}
expPath := path.Join("/tmp")
if err = ldr.loadFromJSONCfg(jsonCfg, map[string][]*FCTemplate{}, utils.InfieldSep); err != nil {
t.Error(err)
} else if ldr.LockFilePath != expPath {
t.Errorf("Expected %v \n but received \n %v", expPath, ldr.LockFilePath)
}
}
Reference in New Issue View Git Blame Copy Permalink