uppal/cgrates
1
0
Fork 1
mirror of https://github.com/cgrates/cgrates.git synced 2026-02-11 18:16:24 +05:00
Code Issues Packages Projects Releases Wiki Activity

Tests in services

Browse Source
This commit is contained in:
andronache
2021-02-12 10:24:14 +02:00
committed by Dan Christian Bogos
parent ce49256a4d
commit 6e84624e64
2 changed files with 76 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
services/analyzers_it_test.go
View File

@@ -20,6 +20,7 @@ along with this program. If not, see <http://www.gnu.org/licenses/>
package services
import (
"log"
"os"
"path"
"sync"
@@ -124,16 +125,17 @@ func TestAnalyzerSReload2(t *testing.T) {
anz.anz = nil
}
/*
func TestAnalyzerSReload3(t *testing.T) {
cfg := config.NewDefaultCGRConfig()
if err := os.MkdirAll("/tmp/analyzers", 0700); err != nil {
if err := os.MkdirAll("/tmp/analyzers_test3", 0700); err != nil {
t.Fatal(err)
}
if err := os.MkdirAll("/tmp/analyzers_test", 0700); err != nil {
t.Fatal(err)
cfg.AnalyzerSCfg().DBPath = "/tmp/analyzers_test3"
err := os.RemoveAll("/tmp/analyzers_test3")
if err != nil {
log.Fatal(err)
}
cfg.AnalyzerSCfg().DBPath = "/tmp/analyzers_test"
cfg.AnalyzerSCfg().IndexType = ""
utils.Logger, _ = utils.Newlogger(utils.MetaSysLog, cfg.GeneralCfg().NodeID)
utils.Logger.SetLogLevel(7)
shdChan := utils.NewSyncedChan()
@@ -150,4 +152,3 @@ func TestAnalyzerSReload3(t *testing.T) {
close(anz.stopChan)
}
*/

69
services/datadb_it_test.go
View File

@@ -204,3 +204,72 @@ func TestDataDBReload(t *testing.T) {
shdChan.CloseOnce()
time.Sleep(10 * time.Millisecond)
}
func TestDataDBReload2(t *testing.T) {
cfg := config.NewDefaultCGRConfig()
utils.Logger, _ = utils.Newlogger(utils.MetaSysLog, cfg.GeneralCfg().NodeID)
utils.Logger.SetLogLevel(7)
shdChan := utils.NewSyncedChan()
shdWg := new(sync.WaitGroup)
chS := engine.NewCacheS(cfg, nil, nil)
filterSChan := make(chan *engine.FilterS, 1)
filterSChan <- nil
close(chS.GetPrecacheChannel(utils.CacheAttributeProfiles))
close(chS.GetPrecacheChannel(utils.CacheAttributeFilterIndexes))
server := cores.NewServer(nil)
srvDep := map[string]*sync.WaitGroup{utils.DataDB: new(sync.WaitGroup)}
srvMngr := servmanager.NewServiceManager(cfg, shdChan, shdWg)
cM := engine.NewConnManager(cfg, nil)
db := NewDataDBService(cfg, cM, srvDep)
anz := NewAnalyzerService(cfg, server, filterSChan, shdChan, make(chan rpcclient.ClientConnector, 1), srvDep)
srvMngr.AddServices(NewAttributeService(cfg, db,
chS, filterSChan, server, make(chan rpcclient.ClientConnector, 1), anz, srvDep),
NewLoaderService(cfg, db, filterSChan, server, make(chan rpcclient.ClientConnector, 1), nil, anz, srvDep), db)
if err := srvMngr.StartServices(); err != nil {
t.Error(err)
}
if db.IsRunning() {
t.Errorf("Expected service to be down")
}
var reply string
cfg.AttributeSCfg().Enabled = true
if err := cfg.V1ReloadConfig(&config.ReloadArgs{
Path: path.Join("/usr", "share", "cgrates", "conf", "samples", "tutmongo"),
Section: config.DATADB_JSN,
}, &reply); err != nil {
t.Error(err)
} else if reply != utils.OK {
t.Errorf("Expecting OK ,received %s", reply)
}
time.Sleep(10 * time.Millisecond) //need to switch to gorutine
if !db.IsRunning() {
t.Errorf("Expected service to be running")
}
err := db.Reload()
if err != nil {
t.Errorf("\nExpecting <nil>,\n Received <%+v>", err)
}
if err := cfg.V1ReloadConfig(&config.ReloadArgs{
Path: path.Join("/usr", "share", "cgrates", "conf", "samples", "tutmysql"),
Section: config.DATADB_JSN,
}, &reply); err != nil {
t.Error(err)
} else if reply != utils.OK {
t.Errorf("Expecting OK ,received %s", reply)
}
err = db.Reload()
if err != nil {
t.Errorf("\nExpecting <nil>,\n Received <%+v>", err)
}
cfg.AttributeSCfg().Enabled = false
cfg.GetReloadChan(config.DATADB_JSN) <- struct{}{}
time.Sleep(10 * time.Millisecond)
if db.IsRunning() {
t.Errorf("Expected service to be down")
}
shdChan.CloseOnce()
time.Sleep(10 * time.Millisecond)
}