diff --git a/data/conf/samples/loaders/tutinternal/cgrates.json b/data/conf/samples/loaders/tutinternal/cgrates.json index 4daa93bbf..c472c07b0 100644 --- a/data/conf/samples/loaders/tutinternal/cgrates.json +++ b/data/conf/samples/loaders/tutinternal/cgrates.json @@ -52,9 +52,9 @@ "run_delay": "0", "lock_filename": ".cgr.lock", "caches_conns": ["*internal"], - "field_separator": ",", - "tp_in_dir": "/tmp/In", - "tp_out_dir": "/tmp/Out", + "field_separator": ",", + "tp_in_dir": "/tmp/In", + "tp_out_dir": "/tmp/Out", "data":[ { "type": "*attributes", @@ -169,20 +169,20 @@ ], }, { - "id": "LoaderWithTemplate", - "enabled": true, - "dry_run": false, + "id": "LoaderWithTemplate", + "enabled": true, + "dry_run": false, "tenant": "cgrates.org", - "run_delay": "0", - "lock_filename": ".cgr.lock", + "run_delay": "0", + "lock_filename": ".cgr.lock", "caches_conns": ["*internal"], - "field_separator": ",", - "tp_in_dir": "/tmp/templateLoaderIn", - "tp_out_dir": "/tmp/templateLoaderOut", + "field_separator": ",", + "tp_in_dir": "/tmp/templateLoaderIn", + "tp_out_dir": "/tmp/templateLoaderOut", "data":[ { - "type": "*attributes", - "file_name": "Attributes.csv", + "type": "*attributes", + "file_name": "Attributes.csv", "fields": [ {"tag": "AttributesFields","type": "*template", "value": "attrTemplateLoader"} ], diff --git a/services/dnsagent_it_test.go b/services/dnsagent_it_test.go index 937f14d7c..8fb9c1d0e 100644 --- a/services/dnsagent_it_test.go +++ b/services/dnsagent_it_test.go @@ -82,10 +82,16 @@ func TestDNSAgentReload(t *testing.T) { if err == nil || err != utils.ErrServiceAlreadyRunning { t.Errorf("\nExpecting <%+v>,\n Received <%+v>", utils.ErrServiceAlreadyRunning, err) } + err = srv.Reload() if err != nil { t.Errorf("\nExpecting ,\n Received <%+v>", err) } + err = srv.Reload() + if err != nil { + t.Errorf("\nExpecting ,\n Received <%+v>", err) + } + cfg.DNSAgentCfg().Enabled = false cfg.GetReloadChan(config.DNSAgentJson) <- struct{}{} time.Sleep(10 * time.Millisecond) diff --git a/services/loaders_it_test.go b/services/loaders_it_test.go index c6727d7e3..b7b475910 100644 --- a/services/loaders_it_test.go +++ b/services/loaders_it_test.go @@ -22,7 +22,6 @@ package services /* func TestLoaderSReload(t *testing.T) { cfg := config.NewDefaultCGRConfig() - utils.Logger, _ = utils.Newlogger(utils.MetaSysLog, cfg.GeneralCfg().NodeID) utils.Logger.SetLogLevel(7) @@ -30,42 +29,43 @@ func TestLoaderSReload(t *testing.T) { shdWg := new(sync.WaitGroup) filterSChan := make(chan *engine.FilterS, 1) filterSChan <- nil - server := cores.NewServer(nil) srvMngr := servmanager.NewServiceManager(cfg, shdChan, shdWg) srvDep := map[string]*sync.WaitGroup{utils.DataDB: new(sync.WaitGroup)} db := NewDataDBService(cfg, nil, srvDep) anz := NewAnalyzerService(cfg, server, filterSChan, shdChan, make(chan rpcclient.ClientConnector, 1), srvDep) - srv := NewLoaderService(cfg, db, filterSChan, server, make(chan rpcclient.ClientConnector, 1), nil, anz, srvDep) - engine.NewConnManager(cfg, nil) - srvMngr.AddServices(srv, - NewLoaderService(cfg, db, filterSChan, server, make(chan rpcclient.ClientConnector, 1), nil, anz, srvDep), db) + conMngr := engine.NewConnManager(cfg, nil) + srv := NewLoaderService(cfg, db, filterSChan, server, make(chan rpcclient.ClientConnector, 1), conMngr, anz, srvDep) + srvMngr.AddServices(srv, db) if err := srvMngr.StartServices(); err != nil { - t.Error(err) + t.Fatal(err) } if srv.IsRunning() { t.Errorf("Expected service to be down") } - if db.IsRunning() { - t.Errorf("Expected service to be down") - } var reply string if err := cfg.V1ReloadConfig(&config.ReloadArgs{ - Path: path.Join("/usr", "share", "cgrates", "conf", "samples", "tutmysql_internal"), + Path: path.Join("/usr", "share", "cgrates", "conf", "samples", "loaders", "tutinternal"), Section: config.LoaderJson, }, &reply); err != nil { - t.Error(err) + t.Fatal(err) } else if reply != utils.OK { t.Errorf("Expecting OK ,received %s", reply) } + if !srv.IsRunning() { + t.Fatal("Expected service to be running") + } + err := srv.Start() if err == nil || err != utils.ErrServiceAlreadyRunning { t.Errorf("\nExpecting <%+v>,\n Received <%+v>", utils.ErrServiceAlreadyRunning, err) } - - cfg.AccountSCfg().Enabled = false + err = srv.Reload() + if err != nil { + t.Errorf("\nExpecting ,\n Received <%+v>", err) + } cfg.GetReloadChan(config.LoaderJson) <- struct{}{} time.Sleep(10 * time.Millisecond) diff --git a/services/responders_test.go b/services/responders_test.go index 9361ec413..a376bd8c1 100644 --- a/services/responders_test.go +++ b/services/responders_test.go @@ -52,6 +52,10 @@ func TestResponderCoverage(t *testing.T) { if !srv.IsRunning() { t.Errorf("Expected service to be running") } + err := srv.Start() + if err != utils.ErrServiceAlreadyRunning { + t.Errorf("\nExpected <%+v>, \nReceived <%+v>", utils.ErrServiceAlreadyRunning, err) + } serviceName := srv.ServiceName() if !reflect.DeepEqual(serviceName, utils.ResponderS) { t.Errorf("\nExpecting <%+v>,\n Received <%+v>", utils.ResponderS, serviceName)