Covered more tests in config package + updated reloadSection function

config/config.go

@@ -1412,6 +1412,13 @@ func (cfg *CGRConfig) reloadSections(sections ...string) (err error) {
 		case DATADB_JSN: // reloaded before
 		case STORDB_JSN: // reloaded before
 		case LISTEN_JSN:
+		case CACHE_JSN:
+		case FilterSjsn:
+		case MAILER_JSN:
+		case SURETAX_JSON:
+		case CgrLoaderCfgJson:
+		case CgrMigratorCfgJson:
+		case TemplatesJson:
 		case TlsCfgJson: // nothing to reload
 		case APIBanCfgJson: // nothing to reload
 		case CoreSCfgJson: // nothing to reload
@@ -1470,7 +1477,6 @@ func (cfg *CGRConfig) reloadSections(sections ...string) (err error) {
 		case DispatcherHJson:
 			cfg.rldChans[DispatcherHJson] <- struct{}{}
 		}
-		return
 	}
 	return
 }
@@ -1710,11 +1716,9 @@ func (cfg *CGRConfig) V1ReloadConfig(args *ArgsReloadWithOpts, reply *string) (e
 		return
 	}
 
-	err = cfg.reloadSections(sections...)
-	if err != nil {
-		return
+	if err = cfg.reloadSections(sections...); err == nil {
+		*reply = utils.OK
 	}
-	*reply = utils.OK
 	return
 }
 
@@ -1849,9 +1853,8 @@ func (cfg *CGRConfig) V1ReloadConfigFromJSON(args *JSONStringReloadWithOpts, rep
 		return
 	}
 
-	if err = cfg.reloadSections(sortedCfgSections...); err != nil {
-		return
+	if err = cfg.reloadSections(sortedCfgSections...); err == nil {
+		*reply = utils.OK
 	}
-	*reply = utils.OK
 	return
 }

config/config_json_test.go

@@ -26,16 +26,6 @@ import (
 	"github.com/cgrates/cgrates/utils"
 )
 
-var dfCgrJSONCfg *CgrJsonCfg
-
-// Loads up the default configuration and  tests it's sections one by one
-func TestDfNewdfCgrJsonCfgFromReader(t *testing.T) {
-	var err error
-	if dfCgrJSONCfg, err = NewCgrJsonCfgFromBytes([]byte(CGRATES_CFG_JSON)); err != nil {
-		t.Error(err)
-	}
-}
-
 func TestDfGeneralJsonCfg(t *testing.T) {
 	eCfg := &GeneralJsonCfg{
 		Node_id:              utils.StringPointer(""),
@@ -64,18 +54,27 @@ func TestDfGeneralJsonCfg(t *testing.T) {
 		Rsr_separator:        utils.StringPointer(";"),
 		Max_parallel_conns:   utils.IntPointer(100),
 	}
+	dfCgrJSONCfg, err := NewCgrJsonCfgFromBytes([]byte(CGRATES_CFG_JSON))
+	if err != nil {
+		t.Error(err)
+	}
 	if gCfg, err := dfCgrJSONCfg.GeneralJsonCfg(); err != nil {
 		t.Error(err)
 	} else if !reflect.DeepEqual(eCfg, gCfg) {
 		t.Errorf("expecting: %s, \nreceived: %s", utils.ToIJSON(eCfg), utils.ToIJSON(gCfg))
 	}
 }
+
 func TestDfCoreSJsonCfg(t *testing.T) {
 	eCfg := &CoreSJsonCfg{
 		Caps:                utils.IntPointer(0),
 		Caps_strategy:       utils.StringPointer(utils.MetaBusy),
 		Caps_stats_interval: utils.StringPointer("0"),
 	}
+	dfCgrJSONCfg, err := NewCgrJsonCfgFromBytes([]byte(CGRATES_CFG_JSON))
+	if err != nil {
+		t.Error(err)
+	}
 	if gCfg, err := dfCgrJSONCfg.CoreSCfgJson(); err != nil {
 		t.Error(err)
 	} else if !reflect.DeepEqual(eCfg, gCfg) {
@@ -311,6 +310,10 @@ func TestCacheJsonCfg(t *testing.T) {
 		},
 		Replication_conns: &[]string{},
 	}
+	dfCgrJSONCfg, err := NewCgrJsonCfgFromBytes([]byte(CGRATES_CFG_JSON))
+	if err != nil {
+		t.Error(err)
+	}
 
 	if gCfg, err := dfCgrJSONCfg.CacheJsonCfg(); err != nil {
 		t.Error(err)
@@ -328,6 +331,10 @@ func TestDfListenJsonCfg(t *testing.T) {
 		Rpc_gob_tls:  utils.StringPointer("127.0.0.1:2023"),
 		Http_tls:     utils.StringPointer("127.0.0.1:2280"),
 	}
+	dfCgrJSONCfg, err := NewCgrJsonCfgFromBytes([]byte(CGRATES_CFG_JSON))
+	if err != nil {
+		t.Error(err)
+	}
 	if cfg, err := dfCgrJSONCfg.ListenJsonCfg(); err != nil {
 		t.Error(err)
 	} else if !reflect.DeepEqual(eCfg, cfg) {
@@ -463,6 +470,10 @@ func TestDfDataDbJsonCfg(t *testing.T) {
 			},
 		},
 	}
+	dfCgrJSONCfg, err := NewCgrJsonCfgFromBytes([]byte(CGRATES_CFG_JSON))
+	if err != nil {
+		t.Error(err)
+	}
 	if cfg, err := dfCgrJSONCfg.DbJsonCfg(DATADB_JSN); err != nil {
 		t.Error(err)
 	} else if !reflect.DeepEqual(eCfg, cfg) {
@@ -586,6 +597,10 @@ func TestDfStorDBJsonCfg(t *testing.T) {
 			},
 		},
 	}
+	dfCgrJSONCfg, err := NewCgrJsonCfgFromBytes([]byte(CGRATES_CFG_JSON))
+	if err != nil {
+		t.Error(err)
+	}
 	if cfg, err := dfCgrJSONCfg.DbJsonCfg(STORDB_JSN); err != nil {
 		t.Error(err)
 	} else if !reflect.DeepEqual(eCfg, cfg) {
@@ -615,6 +630,10 @@ func TestDfRalsJsonCfg(t *testing.T) {
 		},
 		Dynaprepaid_actionplans: &[]string{},
 	}
+	dfCgrJSONCfg, err := NewCgrJsonCfgFromBytes([]byte(CGRATES_CFG_JSON))
+	if err != nil {
+		t.Error(err)
+	}
 	if cfg, err := dfCgrJSONCfg.RalsJsonCfg(); err != nil {
 		t.Error(err)
 	} else if !reflect.DeepEqual(eCfg, cfg) {
@@ -630,6 +649,10 @@ func TestDfSchedulerJsonCfg(t *testing.T) {
 		Stats_conns:      &[]string{},
 		Filters:          &[]string{},
 	}
+	dfCgrJSONCfg, err := NewCgrJsonCfgFromBytes([]byte(CGRATES_CFG_JSON))
+	if err != nil {
+		t.Error(err)
+	}
 	if cfg, err := dfCgrJSONCfg.SchedulerJsonCfg(); err != nil {
 		t.Error(err)
 	} else if !reflect.DeepEqual(eCfg, cfg) {
@@ -652,6 +675,10 @@ func TestDfCdrsJsonCfg(t *testing.T) {
 		Scheduler_conns:      &[]string{},
 		Ees_conns:            &[]string{},
 	}
+	dfCgrJSONCfg, err := NewCgrJsonCfgFromBytes([]byte(CGRATES_CFG_JSON))
+	if err != nil {
+		t.Error(err)
+	}
 	if cfg, err := dfCgrJSONCfg.CdrsJsonCfg(); err != nil {
 		t.Error(err)
 	} else if !reflect.DeepEqual(eCfg, cfg) {
@@ -689,6 +716,10 @@ func TestSmgJsonCfg(t *testing.T) {
 		},
 		Scheduler_conns: &[]string{},
 	}
+	dfCgrJSONCfg, err := NewCgrJsonCfgFromBytes([]byte(CGRATES_CFG_JSON))
+	if err != nil {
+		t.Error(err)
+	}
 	if cfg, err := dfCgrJSONCfg.SessionSJsonCfg(); err != nil {
 		t.Error(err)
 	} else if !reflect.DeepEqual(eCfg, cfg) {
@@ -715,6 +746,10 @@ func TestFsAgentJsonCfg(t *testing.T) {
 				Alias:      utils.StringPointer(""),
 			}},
 	}
+	dfCgrJSONCfg, err := NewCgrJsonCfgFromBytes([]byte(CGRATES_CFG_JSON))
+	if err != nil {
+		t.Error(err)
+	}
 	if cfg, err := dfCgrJSONCfg.FreeswitchAgentJsonCfg(); err != nil {
 		t.Error(err)
 	} else if !reflect.DeepEqual(eCfg, cfg) {
@@ -735,6 +770,10 @@ func TestKamAgentJsonCfg(t *testing.T) {
 		},
 		Timezone: utils.StringPointer(utils.EmptyString),
 	}
+	dfCgrJSONCfg, err := NewCgrJsonCfgFromBytes([]byte(CGRATES_CFG_JSON))
+	if err != nil {
+		t.Error(err)
+	}
 	if cfg, err := dfCgrJSONCfg.KamAgentJsonCfg(); err != nil {
 		t.Error(err)
 	} else if !reflect.DeepEqual(eCfg, cfg) {
@@ -758,6 +797,10 @@ func TestAsteriskAgentJsonCfg(t *testing.T) {
 			},
 		},
 	}
+	dfCgrJSONCfg, err := NewCgrJsonCfgFromBytes([]byte(CGRATES_CFG_JSON))
+	if err != nil {
+		t.Error(err)
+	}
 	if cfg, err := dfCgrJSONCfg.AsteriskAgentJsonCfg(); err != nil {
 		t.Error(err)
 	} else if !reflect.DeepEqual(eCfg, cfg) {
@@ -783,6 +826,10 @@ func TestDiameterAgentJsonCfg(t *testing.T) {
 		Forced_disconnect:    utils.StringPointer(utils.META_NONE),
 		Request_processors:   &[]*ReqProcessorJsnCfg{},
 	}
+	dfCgrJSONCfg, err := NewCgrJsonCfgFromBytes([]byte(CGRATES_CFG_JSON))
+	if err != nil {
+		t.Error(err)
+	}
 	if cfg, err := dfCgrJSONCfg.DiameterAgentJsonCfg(); err != nil {
 		t.Error(err)
 	} else if !reflect.DeepEqual(eCfg, cfg) {
@@ -805,6 +852,10 @@ func TestRadiusAgentJsonCfg(t *testing.T) {
 		Sessions_conns:     &[]string{utils.MetaInternal},
 		Request_processors: &[]*ReqProcessorJsnCfg{},
 	}
+	dfCgrJSONCfg, err := NewCgrJsonCfgFromBytes([]byte(CGRATES_CFG_JSON))
+	if err != nil {
+		t.Error(err)
+	}
 	if cfg, err := dfCgrJSONCfg.RadiusAgentJsonCfg(); err != nil {
 		t.Error(err)
 	} else if !reflect.DeepEqual(eCfg, cfg) {
@@ -815,6 +866,10 @@ func TestRadiusAgentJsonCfg(t *testing.T) {
 
 func TestHttpAgentJsonCfg(t *testing.T) {
 	eCfg := &[]*HttpAgentJsonCfg{}
+	dfCgrJSONCfg, err := NewCgrJsonCfgFromBytes([]byte(CGRATES_CFG_JSON))
+	if err != nil {
+		t.Error(err)
+	}
 	if cfg, err := dfCgrJSONCfg.HttpAgentJsonCfg(); err != nil {
 		t.Error(err)
 	} else if !reflect.DeepEqual(eCfg, cfg) {
@@ -831,6 +886,10 @@ func TestDNSAgentJsonCfg(t *testing.T) {
 		Timezone:           utils.StringPointer(""),
 		Request_processors: &[]*ReqProcessorJsnCfg{},
 	}
+	dfCgrJSONCfg, err := NewCgrJsonCfgFromBytes([]byte(CGRATES_CFG_JSON))
+	if err != nil {
+		t.Error(err)
+	}
 	if cfg, err := dfCgrJSONCfg.DNSAgentJsonCfg(); err != nil {
 		t.Error(err)
 	} else if !reflect.DeepEqual(eCfg, cfg) {
@@ -851,6 +910,10 @@ func TestDfAttributeServJsonCfg(t *testing.T) {
 		Nested_fields:         utils.BoolPointer(false),
 		Process_runs:          utils.IntPointer(1),
 	}
+	dfCgrJSONCfg, err := NewCgrJsonCfgFromBytes([]byte(CGRATES_CFG_JSON))
+	if err != nil {
+		t.Error(err)
+	}
 	if cfg, err := dfCgrJSONCfg.AttributeServJsonCfg(); err != nil {
 		t.Error(err)
 	} else if !reflect.DeepEqual(eCfg, cfg) {
@@ -868,6 +931,10 @@ func TestDfChargerServJsonCfg(t *testing.T) {
 		Suffix_indexed_fields: &[]string{},
 		Nested_fields:         utils.BoolPointer(false),
 	}
+	dfCgrJSONCfg, err := NewCgrJsonCfgFromBytes([]byte(CGRATES_CFG_JSON))
+	if err != nil {
+		t.Error(err)
+	}
 	if cfg, err := dfCgrJSONCfg.ChargerServJsonCfg(); err != nil {
 		t.Error(err)
 	} else if !reflect.DeepEqual(eCfg, cfg) {
@@ -881,6 +948,10 @@ func TestDfFilterSJsonCfg(t *testing.T) {
 		Resources_conns: &[]string{},
 		Apiers_conns:    &[]string{},
 	}
+	dfCgrJSONCfg, err := NewCgrJsonCfgFromBytes([]byte(CGRATES_CFG_JSON))
+	if err != nil {
+		t.Error(err)
+	}
 	if cfg, err := dfCgrJSONCfg.FilterSJsonCfg(); err != nil {
 		t.Error(err)
 	} else if !reflect.DeepEqual(eCfg, cfg) {
@@ -899,6 +970,10 @@ func TestDfResourceLimiterSJsonCfg(t *testing.T) {
 		Suffix_indexed_fields: &[]string{},
 		Nested_fields:         utils.BoolPointer(false),
 	}
+	dfCgrJSONCfg, err := NewCgrJsonCfgFromBytes([]byte(CGRATES_CFG_JSON))
+	if err != nil {
+		t.Error(err)
+	}
 	if cfg, err := dfCgrJSONCfg.ResourceSJsonCfg(); err != nil {
 		t.Error(err)
 	} else if !reflect.DeepEqual(eCfg, cfg) {
@@ -918,6 +993,10 @@ func TestDfStatServiceJsonCfg(t *testing.T) {
 		Suffix_indexed_fields:    &[]string{},
 		Nested_fields:            utils.BoolPointer(false),
 	}
+	dfCgrJSONCfg, err := NewCgrJsonCfgFromBytes([]byte(CGRATES_CFG_JSON))
+	if err != nil {
+		t.Error(err)
+	}
 	if cfg, err := dfCgrJSONCfg.StatSJsonCfg(); err != nil {
 		t.Error(err)
 	} else if !reflect.DeepEqual(eCfg, cfg) {
@@ -935,6 +1014,10 @@ func TestDfThresholdSJsonCfg(t *testing.T) {
 		Suffix_indexed_fields: &[]string{},
 		Nested_fields:         utils.BoolPointer(false),
 	}
+	dfCgrJSONCfg, err := NewCgrJsonCfgFromBytes([]byte(CGRATES_CFG_JSON))
+	if err != nil {
+		t.Error(err)
+	}
 	if cfg, err := dfCgrJSONCfg.ThresholdSJsonCfg(); err != nil {
 		t.Error(err)
 	} else if !reflect.DeepEqual(eCfg, cfg) {
@@ -956,6 +1039,10 @@ func TestDfRouteSJsonCfg(t *testing.T) {
 		Default_ratio:         utils.IntPointer(1),
 		Nested_fields:         utils.BoolPointer(false),
 	}
+	dfCgrJSONCfg, err := NewCgrJsonCfgFromBytes([]byte(CGRATES_CFG_JSON))
+	if err != nil {
+		t.Error(err)
+	}
 	if cfg, err := dfCgrJSONCfg.RouteSJsonCfg(); err != nil {
 		t.Error(err)
 	} else if !reflect.DeepEqual(eCfg, cfg) {
@@ -1513,6 +1600,10 @@ func TestDfLoaderJsonCfg(t *testing.T) {
 			},
 		},
 	}
+	dfCgrJSONCfg, err := NewCgrJsonCfgFromBytes([]byte(CGRATES_CFG_JSON))
+	if err != nil {
+		t.Error(err)
+	}
 	if cfg, err := dfCgrJSONCfg.LoaderJsonCfg(); err != nil {
 		t.Error(err)
 	} else if !reflect.DeepEqual(eCfg, cfg) {
@@ -1528,6 +1619,10 @@ func TestDfMailerJsonCfg(t *testing.T) {
 		Auth_password: utils.StringPointer("CGRateS.org"),
 		From_address:  utils.StringPointer("cgr-mailer@localhost.localdomain"),
 	}
+	dfCgrJSONCfg, err := NewCgrJsonCfgFromBytes([]byte(CGRATES_CFG_JSON))
+	if err != nil {
+		t.Error(err)
+	}
 	if cfg, err := dfCgrJSONCfg.MailerJsonCfg(); err != nil {
 		t.Error(err)
 	} else if !reflect.DeepEqual(eCfg, cfg) {
@@ -1564,6 +1659,10 @@ func TestDfSureTaxJsonCfg(t *testing.T) {
 		Sales_type_code:         utils.StringPointer("R"),
 		Tax_exemption_code_list: utils.StringPointer(""),
 	}
+	dfCgrJSONCfg, err := NewCgrJsonCfgFromBytes([]byte(CGRATES_CFG_JSON))
+	if err != nil {
+		t.Error(err)
+	}
 	if cfg, err := dfCgrJSONCfg.SureTaxJsonCfg(); err != nil {
 		t.Error(err)
 	} else if !reflect.DeepEqual(eCfg, cfg) {
@@ -1597,6 +1696,10 @@ func TestDfHttpJsonCfg(t *testing.T) {
 			utils.HTTPClientDialKeepAliveCfg:         "30s",
 		},
 	}
+	dfCgrJSONCfg, err := NewCgrJsonCfgFromBytes([]byte(CGRATES_CFG_JSON))
+	if err != nil {
+		t.Error(err)
+	}
 	if cfg, err := dfCgrJSONCfg.HttpJsonCfg(); err != nil {
 		t.Error(err)
 	} else if !reflect.DeepEqual(eCfg, cfg) {
@@ -1614,6 +1717,10 @@ func TestDfDispatcherSJsonCfg(t *testing.T) {
 		Attributes_conns:      &[]string{},
 		Nested_fields:         utils.BoolPointer(false),
 	}
+	dfCgrJSONCfg, err := NewCgrJsonCfgFromBytes([]byte(CGRATES_CFG_JSON))
+	if err != nil {
+		t.Error(err)
+	}
 	if cfg, err := dfCgrJSONCfg.DispatcherSJsonCfg(); err != nil {
 		t.Error(err)
 	} else if !reflect.DeepEqual(eCfg, cfg) {
@@ -1634,6 +1741,10 @@ func TestDfLoaderCfg(t *testing.T) {
 		Gapi_credentials: &cred,
 		Gapi_token:       &tok,
 	}
+	dfCgrJSONCfg, err := NewCgrJsonCfgFromBytes([]byte(CGRATES_CFG_JSON))
+	if err != nil {
+		t.Error(err)
+	}
 	if cfg, err := dfCgrJSONCfg.LoaderCfgJson(); err != nil {
 		t.Error(err)
 	} else if !reflect.DeepEqual(eCfg, cfg) {
@@ -1670,6 +1781,10 @@ func TestDfMigratorCfg(t *testing.T) {
 			utils.RedisCACertificate:         "",
 		},
 	}
+	dfCgrJSONCfg, err := NewCgrJsonCfgFromBytes([]byte(CGRATES_CFG_JSON))
+	if err != nil {
+		t.Error(err)
+	}
 	if cfg, err := dfCgrJSONCfg.MigratorCfgJson(); err != nil {
 		t.Error(err)
 	} else if !reflect.DeepEqual(eCfg, cfg) {
@@ -1687,6 +1802,10 @@ func TestDfTlsCfg(t *testing.T) {
 		Server_name:        utils.StringPointer(""),
 		Server_policy:      utils.IntPointer(4),
 	}
+	dfCgrJSONCfg, err := NewCgrJsonCfgFromBytes([]byte(CGRATES_CFG_JSON))
+	if err != nil {
+		t.Error(err)
+	}
 	if cfg, err := dfCgrJSONCfg.TlsCfgJson(); err != nil {
 		t.Error(err)
 	} else if !reflect.DeepEqual(eCfg, cfg) {
@@ -1702,6 +1821,10 @@ func TestDfAnalyzerCfg(t *testing.T) {
 		Index_type:       utils.StringPointer(utils.MetaScorch),
 		Ttl:              utils.StringPointer("24h"),
 	}
+	dfCgrJSONCfg, err := NewCgrJsonCfgFromBytes([]byte(CGRATES_CFG_JSON))
+	if err != nil {
+		t.Error(err)
+	}
 	if cfg, err := dfCgrJSONCfg.AnalyzerCfgJson(); err != nil {
 		t.Error(err)
 	} else if !reflect.DeepEqual(eCfg, cfg) {
@@ -1717,6 +1840,10 @@ func TestDfApierCfg(t *testing.T) {
 		Attributes_conns: &[]string{},
 		Ees_conns:        &[]string{},
 	}
+	dfCgrJSONCfg, err := NewCgrJsonCfgFromBytes([]byte(CGRATES_CFG_JSON))
+	if err != nil {
+		t.Error(err)
+	}
 	if cfg, err := dfCgrJSONCfg.ApierCfgJson(); err != nil {
 		t.Error(err)
 	} else if !reflect.DeepEqual(eCfg, cfg) {
@@ -1774,6 +1901,10 @@ func TestDfEventReaderCfg(t *testing.T) {
 			},
 		},
 	}
+	dfCgrJSONCfg, err := NewCgrJsonCfgFromBytes([]byte(CGRATES_CFG_JSON))
+	if err != nil {
+		t.Error(err)
+	}
 	if cfg, err := dfCgrJSONCfg.ERsJsonCfg(); err != nil {
 		t.Error(err)
 	} else if !reflect.DeepEqual(eCfg, cfg) {
@@ -1811,6 +1942,10 @@ func TestDfEventExporterCfg(t *testing.T) {
 			},
 		},
 	}
+	dfCgrJSONCfg, err := NewCgrJsonCfgFromBytes([]byte(CGRATES_CFG_JSON))
+	if err != nil {
+		t.Error(err)
+	}
 	if cfg, err := dfCgrJSONCfg.EEsJsonCfg(); err != nil {
 		t.Error(err)
 	} else if !reflect.DeepEqual(eCfg, cfg) {
@@ -1832,6 +1967,10 @@ func TestDfRateSJsonCfg(t *testing.T) {
 		Rate_suffix_indexed_fields: &[]string{},
 		Rate_nested_fields:         utils.BoolPointer(false),
 	}
+	dfCgrJSONCfg, err := NewCgrJsonCfgFromBytes([]byte(CGRATES_CFG_JSON))
+	if err != nil {
+		t.Error(err)
+	}
 	if cfg, err := dfCgrJSONCfg.RateCfgJson(); err != nil {
 		t.Error(err)
 	} else if !reflect.DeepEqual(eCfg, cfg) {
@@ -1994,6 +2133,10 @@ func TestDfTemplateSJsonCfg(t *testing.T) {
 				Value: utils.StringPointer("0")},
 		},
 	}
+	dfCgrJSONCfg, err := NewCgrJsonCfgFromBytes([]byte(CGRATES_CFG_JSON))
+	if err != nil {
+		t.Error(err)
+	}
 	if cfg, err := dfCgrJSONCfg.TemplateSJsonCfg(); err != nil {
 		t.Error(err)
 	} else if !reflect.DeepEqual(eCfg, cfg) {