diff --git a/services/cdrs_test.go b/services/cdrs_test.go new file mode 100644 index 000000000..b79e78632 --- /dev/null +++ b/services/cdrs_test.go @@ -0,0 +1,134 @@ +/* +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 +*/ +package services + +import ( + "path" + "sync" + "testing" + "time" + + "github.com/cgrates/cgrates/config" + "github.com/cgrates/cgrates/cores" + "github.com/cgrates/cgrates/engine" + "github.com/cgrates/cgrates/servmanager" + "github.com/cgrates/cgrates/utils" + "github.com/cgrates/rpcclient" +) + +//TestCdrsCoverage for cover testing +func TestCdrsCoverage(t *testing.T) { + cfg := config.NewDefaultCGRConfig() + + utils.Logger, _ = utils.Newlogger(utils.MetaSysLog, cfg.GeneralCfg().NodeID) + utils.Logger.SetLogLevel(7) + filterSChan := make(chan *engine.FilterS, 1) + filterSChan <- nil + shdChan := utils.NewSyncedChan() + shdWg := new(sync.WaitGroup) + chS := engine.NewCacheS(cfg, nil, nil) + + close(chS.GetPrecacheChannel(utils.CacheChargerProfiles)) + close(chS.GetPrecacheChannel(utils.CacheChargerFilterIndexes)) + + close(chS.GetPrecacheChannel(utils.CacheDestinations)) + close(chS.GetPrecacheChannel(utils.CacheReverseDestinations)) + close(chS.GetPrecacheChannel(utils.CacheRatingPlans)) + close(chS.GetPrecacheChannel(utils.CacheRatingProfiles)) + close(chS.GetPrecacheChannel(utils.CacheActions)) + close(chS.GetPrecacheChannel(utils.CacheActionPlans)) + close(chS.GetPrecacheChannel(utils.CacheAccountActionPlans)) + close(chS.GetPrecacheChannel(utils.CacheActionTriggers)) + close(chS.GetPrecacheChannel(utils.CacheSharedGroups)) + close(chS.GetPrecacheChannel(utils.CacheTimings)) + + cfg.ChargerSCfg().Enabled = true + 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) + cfg.StorDbCfg().Type = utils.INTERNAL + stordb := NewStorDBService(cfg, srvDep) + anz := NewAnalyzerService(cfg, server, filterSChan, shdChan, make(chan rpcclient.ClientConnector, 1), srvDep) + chrS := NewChargerService(cfg, db, chS, filterSChan, server, make(chan rpcclient.ClientConnector, 1), nil, anz, srvDep) + schS := NewSchedulerService(cfg, db, chS, filterSChan, server, make(chan rpcclient.ClientConnector, 1), nil, anz, srvDep) + ralS := NewRalService(cfg, chS, server, + make(chan rpcclient.ClientConnector, 1), + make(chan rpcclient.ClientConnector, 1), + shdChan, nil, anz, srvDep) + cdrsRPC := make(chan rpcclient.ClientConnector, 1) + cdrS := NewCDRServer(cfg, db, stordb, filterSChan, server, + cdrsRPC, nil, anz, srvDep) + srvMngr.AddServices(cdrS, ralS, schS, chrS, + NewLoaderService(cfg, db, filterSChan, server, + make(chan rpcclient.ClientConnector, 1), nil, anz, srvDep), db, stordb) + if err := srvMngr.StartServices(); err != nil { + t.Error(err) + } + if cdrS.IsRunning() { + t.Errorf("Expected service to be down") + } + if db.IsRunning() { + t.Errorf("Expected service to be down") + } + if stordb.IsRunning() { + t.Errorf("Expected service to be down") + } + + cfg.RalsCfg().Enabled = true + var reply string + if err := cfg.V1ReloadConfig(&config.ReloadArgs{ + Path: path.Join("/usr", "share", "cgrates", "conf", "samples", "tutmongo"), + Section: config.CDRS_JSN, + }, &reply); err != nil { + t.Error(err) + } else if reply != utils.OK { + t.Errorf("Expecting OK ,received %s", reply) + } + select { + case d := <-cdrsRPC: + cdrsRPC <- d + case <-time.After(time.Second): + t.Fatal("It took to long to reload the cache") + } + if !cdrS.IsRunning() { + t.Errorf("Expected service to be running") + } + if !db.IsRunning() { + t.Errorf("Expected service to be running") + } + if !stordb.IsRunning() { + t.Errorf("Expected service to be running") + } + err := cdrS.Start() + if err == nil || err != utils.ErrServiceAlreadyRunning { + t.Errorf("\nExpecting <%+v>,\n Received <%+v>", utils.ErrServiceAlreadyRunning, err) + } + err = cdrS.Reload() + if err != nil { + t.Errorf("\nExpecting ,\n Received <%+v>", err) + } + cfg.CdrsCfg().Enabled = false + cfg.GetReloadChan(config.CDRS_JSN) <- struct{}{} + time.Sleep(10 * time.Millisecond) + if cdrS.IsRunning() { + t.Errorf("Expected service to be down") + } + shdChan.CloseOnce() + time.Sleep(10 * time.Millisecond) +} diff --git a/services/chargers_it_test.go b/services/chargers_it_test.go index a39e74fad..4bc0786cd 100644 --- a/services/chargers_it_test.go +++ b/services/chargers_it_test.go @@ -102,44 +102,3 @@ func TestChargerSReload(t *testing.T) { shdChan.CloseOnce() time.Sleep(10 * time.Millisecond) } - -//TestAttributeSCoverage for cover testing -func TestChargerSCoverage(t *testing.T) { - cfg := config.NewDefaultCGRConfig() - cfg.AttributeSCfg().Enabled = true - shdChan := utils.NewSyncedChan() - chS := engine.NewCacheS(cfg, nil, nil) - filterSChan := make(chan *engine.FilterS, 1) - filterSChan <- nil - srvDep := map[string]*sync.WaitGroup{utils.DataDB: new(sync.WaitGroup)} - server := cores.NewServer(nil) - db := NewDataDBService(cfg, nil, srvDep) - anz := NewAnalyzerService(cfg, server, filterSChan, shdChan, make(chan rpcclient.ClientConnector, 1), srvDep) - chrS := &ChargerService{ - connChan: make(chan rpcclient.ClientConnector, 1), - cfg: cfg, - dm: db, - cacheS: chS, - filterSChan: filterSChan, - server: server, - connMgr: nil, - anz: anz, - srvDep: srvDep, - } - if chrS.IsRunning() { - t.Errorf("Expected service to be down") - } - - chrS.chrS = &engine.ChargerService{} - if !chrS.IsRunning() { - t.Errorf("Expected service to be running") - } - err := chrS.Start() - if err == nil || err != utils.ErrServiceAlreadyRunning { - t.Errorf("\nExpecting <%+v>,\n Received <%+v>", utils.ErrServiceAlreadyRunning, err) - } - err = chrS.Reload() - if err != nil { - t.Errorf("\nExpecting ,\n Received <%+v>", err) - } -} diff --git a/services/chargers_test.go b/services/chargers_test.go new file mode 100644 index 000000000..3b2694aa1 --- /dev/null +++ b/services/chargers_test.go @@ -0,0 +1,71 @@ +/* +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 +*/ +package services + +import ( + "sync" + "testing" + + "github.com/cgrates/rpcclient" + + "github.com/cgrates/cgrates/config" + "github.com/cgrates/cgrates/cores" + "github.com/cgrates/cgrates/engine" + "github.com/cgrates/cgrates/utils" +) + +//TestChargerSCoverage for cover testing +func TestChargerSCoverage(t *testing.T) { + cfg := config.NewDefaultCGRConfig() + cfg.AttributeSCfg().Enabled = true + shdChan := utils.NewSyncedChan() + chS := engine.NewCacheS(cfg, nil, nil) + filterSChan := make(chan *engine.FilterS, 1) + filterSChan <- nil + srvDep := map[string]*sync.WaitGroup{utils.DataDB: new(sync.WaitGroup)} + server := cores.NewServer(nil) + db := NewDataDBService(cfg, nil, srvDep) + anz := NewAnalyzerService(cfg, server, filterSChan, shdChan, make(chan rpcclient.ClientConnector, 1), srvDep) + chrS := &ChargerService{ + connChan: make(chan rpcclient.ClientConnector, 1), + cfg: cfg, + dm: db, + cacheS: chS, + filterSChan: filterSChan, + server: server, + connMgr: nil, + anz: anz, + srvDep: srvDep, + } + if chrS.IsRunning() { + t.Errorf("Expected service to be down") + } + + chrS.chrS = &engine.ChargerService{} + if !chrS.IsRunning() { + t.Errorf("Expected service to be running") + } + err := chrS.Start() + if err == nil || err != utils.ErrServiceAlreadyRunning { + t.Errorf("\nExpecting <%+v>,\n Received <%+v>", utils.ErrServiceAlreadyRunning, err) + } + err = chrS.Reload() + if err != nil { + t.Errorf("\nExpecting ,\n Received <%+v>", err) + } +} diff --git a/services/cores_it_test.go b/services/cores_test.go similarity index 99% rename from services/cores_it_test.go rename to services/cores_test.go index e357467e3..7da4e5a14 100644 --- a/services/cores_it_test.go +++ b/services/cores_test.go @@ -1,5 +1,3 @@ -// +build integration - /* Real-time Online/Offline Charging System (OCS) for Telecom & ISP environments Copyright (C) ITsysCOM GmbH