diff --git a/services/accounts_it_test.go b/services/accounts_it_test.go new file mode 100644 index 000000000..95d327518 --- /dev/null +++ b/services/accounts_it_test.go @@ -0,0 +1,112 @@ +// +build integration + +/* +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/rpcclient" + + "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" +) + +func TestAccountSReload(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.CacheAccountProfiles)) + close(chS.GetPrecacheChannel(utils.CacheAccountProfilesFilterIndexes)) + 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) + acctRPC := make(chan rpcclient.ClientConnector, 1) + anz := NewAnalyzerService(cfg, server, filterSChan, shdChan, make(chan rpcclient.ClientConnector, 1), srvDep) + acctS := NewAccountService(cfg, db, chS, filterSChan, server, acctRPC, anz, srvDep) + engine.NewConnManager(cfg, nil) + srvMngr.AddServices(acctS, + NewLoaderService(cfg, db, filterSChan, server, make(chan rpcclient.ClientConnector, 1), nil, anz, srvDep), db) + if err := srvMngr.StartServices(); err != nil { + t.Error(err) + } + if acctS.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", "tutmongo"), + Section: config.AccountSCfgJson, + }, &reply); err != nil { + t.Error(err) + } else if reply != utils.OK { + t.Errorf("Expecting OK ,received %s", reply) + } + select { + case d := <-acctRPC: + acctRPC <- d + case <-time.After(time.Second): + t.Fatal("It took to long to reload the cache") + } + if !acctS.IsRunning() { + t.Errorf("Expected service to be running") + } + if !db.IsRunning() { + t.Errorf("Expected service to be running") + } + err := acctS.Start() + if err == nil || err != utils.ErrServiceAlreadyRunning { + t.Errorf("\nExpecting <%+v>,\n Received <%+v>", utils.ErrServiceAlreadyRunning, err) + } + err = acctS.Reload() + if err != nil { + t.Errorf("\nExpecting ,\n Received <%+v>", err) + } + cfg.AccountSCfg().Enabled = false + cfg.GetReloadChan(config.AccountSCfgJson) <- struct{}{} + time.Sleep(10 * time.Millisecond) + + if acctS.IsRunning() { + t.Errorf("Expected service to be down") + } + + shdChan.CloseOnce() + time.Sleep(10 * time.Millisecond) + +} +*/ diff --git a/services/accounts_test.go b/services/accounts_test.go new file mode 100644 index 000000000..bc250bcd5 --- /dev/null +++ b/services/accounts_test.go @@ -0,0 +1,107 @@ +/* +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 ( + "reflect" + "sync" + "testing" + + "github.com/cgrates/cgrates/accounts" + + "github.com/cgrates/cgrates/config" + "github.com/cgrates/cgrates/cores" + "github.com/cgrates/cgrates/engine" + "github.com/cgrates/cgrates/utils" + "github.com/cgrates/rpcclient" +) + +//TestAccountSCoverage for cover testing +func TestAccountSCoverage(t *testing.T) { + cfg := config.NewDefaultCGRConfig() + shdChan := utils.NewSyncedChan() + chS := engine.NewCacheS(cfg, nil, nil) + filterSChan := make(chan *engine.FilterS, 1) + filterSChan <- nil + server := cores.NewServer(nil) + srvDep := map[string]*sync.WaitGroup{utils.DataDB: new(sync.WaitGroup)} + db := NewDataDBService(cfg, nil, srvDep) + actRPC := make(chan rpcclient.ClientConnector, 1) + anz := NewAnalyzerService(cfg, server, filterSChan, shdChan, make(chan rpcclient.ClientConnector, 1), srvDep) + actS := NewAccountService(cfg, db, + chS, filterSChan, server, actRPC, + anz, srvDep) + if actS == nil { + t.Errorf("\nExpecting ,\n Received <%+v>", utils.ToJSON(actS)) + } + //initialises an empty chan to call the reload function + testChan := make(chan struct{}) + go func() { + for { + select { + case <-testChan: + } + } + }() + //populates actRPC with something in order to call the close function + actRPC <- chS + actS2 := &AccountService{ + cfg: cfg, + dm: db, + cacheS: chS, + filterSChan: filterSChan, + server: server, + rldChan: testChan, + stopChan: make(chan struct{}, 1), + connChan: actRPC, + anz: anz, + srvDep: srvDep, + } + actS3 := &AccountService{ + cfg: cfg, + dm: db, + cacheS: chS, + filterSChan: filterSChan, + server: server, + rldChan: testChan, + stopChan: make(chan struct{}, 1), + connChan: actRPC, + anz: anz, + srvDep: srvDep, + } + if actS2.IsRunning() { + t.Errorf("Expected service to be down") + } + actS2.acts = accounts.NewAccountS(cfg, &engine.FilterS{}, &engine.DataManager{}) + if !actS2.IsRunning() { + t.Errorf("Expected service to be running") + } + serviceName := actS2.ServiceName() + if !reflect.DeepEqual(serviceName, utils.AccountS) { + t.Errorf("\nExpecting <%+v>,\n Received <%+v>", utils.AccountS, serviceName) + } + shouldRun := actS2.ShouldRun() + if !reflect.DeepEqual(shouldRun, false) { + t.Errorf("\nExpecting ,\n Received <%+v>", shouldRun) + } + actS3.rldChan <- struct{}{} + if !reflect.DeepEqual(actS2.rldChan, actS3.rldChan) { + t.Errorf("\nExpecting <%+v>,\n Received <%+v>", utils.ToJSON(actS3.rldChan), utils.ToJSON(actS2.rldChan)) + } + +}