Integration tests in services

config/config.go

@@ -1426,7 +1426,7 @@ func (cfg *CGRConfig) reloadSections(sections ...string) {
 	subsystemsThatNeedDataDB := utils.NewStringSet([]string{DATADB_JSN, SCHEDULER_JSN,
 		RALS_JSN, CDRS_JSN, SessionSJson, ATTRIBUTE_JSN,
 		ChargerSCfgJson, RESOURCES_JSON, STATS_JSON, THRESHOLDS_JSON,
-		RouteSJson, LoaderJson, DispatcherSJson, RateSJson, ApierS})
+		RouteSJson, LoaderJson, DispatcherSJson, RateSJson, ApierS, AccountSCfgJson})
 	subsystemsThatNeedStorDB := utils.NewStringSet([]string{STORDB_JSN, RALS_JSN, CDRS_JSN, ApierS})
 	needsDataDB := false
 	needsStorDB := false
@@ -1517,6 +1517,8 @@ func (cfg *CGRConfig) reloadSections(sections ...string) {
 			cfg.rldChans[RateSJson] <- struct{}{}
 		case DispatcherHJson:
 			cfg.rldChans[DispatcherHJson] <- struct{}{}
+		case AccountSCfgJson:
+			cfg.rldChans[AccountSCfgJson] <- struct{}{}
 		}
 	}
 	return

data/conf/samples/tutmongo/cgrates.json

@@ -126,8 +126,8 @@
 
 
 "accounts": {
-	"enabled": true
-	},
+	"enabled": true,
+},
 
 
 "filters": {								

services/accounts_it_test.go

@@ -19,7 +19,6 @@ along with this program.  If not, see <http://www.gnu.org/licenses/>
 */
 package services
 
-/*
 import (
 	"path"
 	"sync"
@@ -109,4 +108,3 @@ func TestAccountSReload(t *testing.T) {
 	time.Sleep(10 * time.Millisecond)
 
 }
-*/

services/datadb.go

@@ -141,7 +141,8 @@ func (db *DataDBService) mandatoryDB() bool {
 	return db.cfg.RalsCfg().Enabled || db.cfg.SchedulerCfg().Enabled || db.cfg.ChargerSCfg().Enabled ||
 		db.cfg.AttributeSCfg().Enabled || db.cfg.ResourceSCfg().Enabled || db.cfg.StatSCfg().Enabled ||
 		db.cfg.ThresholdSCfg().Enabled || db.cfg.RouteSCfg().Enabled || db.cfg.DispatcherSCfg().Enabled ||
-		db.cfg.LoaderCfg().Enabled() || db.cfg.ApierCfg().Enabled || db.cfg.RateSCfg().Enabled
+		db.cfg.LoaderCfg().Enabled() || db.cfg.ApierCfg().Enabled || db.cfg.RateSCfg().Enabled ||
+		db.cfg.AccountSCfg().Enabled
 }
 
 // GetDM returns the DataManager

servmanager/servmanager.go

@@ -247,6 +247,8 @@ func (srvMngr *ServiceManager) handleReload() {
 			go srvMngr.reloadService(utils.DispatcherH)
 		case <-srvMngr.GetConfig().GetReloadChan(config.HTTP_JSN):
 			go srvMngr.reloadService(utils.GlobalVarS)
+		case <-srvMngr.GetConfig().GetReloadChan(config.AccountSCfgJson):
+			go srvMngr.reloadService(utils.AccountS)
 		}
 		// handle RPC server
 	}