diff --git a/services/actions_it_test.go b/services/actions_test.go similarity index 95% rename from services/actions_it_test.go rename to services/actions_test.go index a0be55255..9ae9e23b9 100644 --- a/services/actions_it_test.go +++ b/services/actions_test.go @@ -1,5 +1,3 @@ -// +build integration - /* Real-time Online/Offline Charging System (OCS) for Telecom & ISP environments Copyright (C) ITsysCOM GmbH @@ -33,11 +31,9 @@ import ( "github.com/cgrates/rpcclient" ) -//TestNewActionService for cover testing +//TestActionSCoverage for cover testing func TestActionSCoverage(t *testing.T) { cfg := config.NewDefaultCGRConfig() - utils.Logger, _ = utils.Newlogger(utils.MetaSysLog, cfg.GeneralCfg().NodeID) - utils.Logger.SetLogLevel(7) shdChan := utils.NewSyncedChan() chS := engine.NewCacheS(cfg, nil, nil) filterSChan := make(chan *engine.FilterS, 1) diff --git a/services/analyzers_it_test.go b/services/analyzers_it_test.go index 03fe25836..508483af7 100644 --- a/services/analyzers_it_test.go +++ b/services/analyzers_it_test.go @@ -33,8 +33,7 @@ import ( "github.com/cgrates/rpcclient" ) -//TestNewActionService for cover testing -func TestNewAnalyzerCoverage(t *testing.T) { +func TestNewAnalyzerReload(t *testing.T) { cfg := config.NewDefaultCGRConfig() utils.Logger, _ = utils.Newlogger(utils.MetaSysLog, cfg.GeneralCfg().NodeID) utils.Logger.SetLogLevel(7) @@ -87,4 +86,5 @@ func TestNewAnalyzerCoverage(t *testing.T) { if !reflect.DeepEqual(anz2.anz, getAnalyzerS) { t.Errorf("\nExpecting <%+v>,\n Received <%+v>", utils.ToJSON(anz2.anz), utils.ToJSON(getAnalyzerS)) } + } diff --git a/services/analyzers_test.go b/services/analyzers_test.go new file mode 100644 index 000000000..8895a79ab --- /dev/null +++ b/services/analyzers_test.go @@ -0,0 +1,97 @@ +/* +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/analyzers" + + "github.com/cgrates/cgrates/config" + "github.com/cgrates/cgrates/cores" + "github.com/cgrates/cgrates/engine" + "github.com/cgrates/cgrates/utils" + "github.com/cgrates/rpcclient" +) + +//TestNewAnalyzerCoverage for cover testing +func TestAnalyzerCoverage(t *testing.T) { + cfg := config.NewDefaultCGRConfig() + shdChan := utils.NewSyncedChan() + filterSChan := make(chan *engine.FilterS, 1) + filterSChan <- nil + server := cores.NewServer(nil) + srvDep := map[string]*sync.WaitGroup{utils.DataDB: new(sync.WaitGroup)} + connChan := make(chan rpcclient.ClientConnector, 1) + anz := NewAnalyzerService(cfg, server, filterSChan, shdChan, connChan, srvDep) + if anz == nil { + t.Errorf("\nExpecting ,\n Received <%+v>", utils.ToJSON(anz)) + } + anz2 := &AnalyzerService{ + RWMutex: sync.RWMutex{}, + cfg: cfg, + server: server, + filterSChan: filterSChan, + stopChan: make(chan struct{}, 1), + shdChan: shdChan, + connChan: connChan, + srvDep: srvDep, + } + if anz2.IsRunning() { + t.Errorf("Expected service to be down") + } + var rpcClientCnctr rpcclient.ClientConnector + getIntrnCdc := anz2.GetInternalCodec(rpcClientCnctr, utils.EmptyString) + if !reflect.DeepEqual(getIntrnCdc, rpcClientCnctr) { + t.Errorf("\nExpecting <%+v>,\n Received <%+v>", utils.ToJSON(rpcClientCnctr), utils.ToJSON(getIntrnCdc)) + } + var err error + anz2.anz, _ = analyzers.NewAnalyzerService(cfg) + if !anz2.IsRunning() { + t.Errorf("Expected service to be running") + } + err = anz2.Start() + if err == nil || err != utils.ErrServiceAlreadyRunning { + t.Errorf("\nExpecting <%+v>,\n Received <%+v>", utils.ErrServiceAlreadyRunning, err) + } + err = anz2.Reload() + if err != nil { + t.Errorf("\nExpecting ,\n Received <%+v>", err) + } + serviceName := anz2.ServiceName() + if !reflect.DeepEqual(serviceName, utils.AnalyzerS) { + t.Errorf("\nExpecting <%+v>,\n Received <%+v>", utils.AnalyzerS, serviceName) + } + shouldRun := anz2.ShouldRun() + if !reflect.DeepEqual(shouldRun, false) { + t.Errorf("\nExpecting ,\n Received <%+v>", shouldRun) + } + getAnalyzerS := anz2.GetAnalyzerS() + if !reflect.DeepEqual(anz2.anz, getAnalyzerS) { + t.Errorf("\nExpecting <%+v>,\n Received <%+v>", utils.ToJSON(anz2.anz), utils.ToJSON(getAnalyzerS)) + } + var rpcClientCnctr2 rpcclient.ClientConnector + getIntrnCdc2 := anz2.GetInternalCodec(rpcClientCnctr2, utils.EmptyString) + expected2 := anz2.anz.NewAnalyzerConnector(nil, utils.MetaInternal, utils.EmptyString, utils.EmptyString) + if !reflect.DeepEqual(getIntrnCdc2, expected2) { + t.Errorf("\nExpecting <%+v>,\n Received <%+v>", utils.ToJSON(expected2), utils.ToJSON(getIntrnCdc2)) + } + +} diff --git a/services/sipagent_test.go b/services/sipagent_test.go new file mode 100644 index 000000000..5bad53819 --- /dev/null +++ b/services/sipagent_test.go @@ -0,0 +1,56 @@ +/* +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 +*/ +package services + +import ( + "sync" + "testing" + + "github.com/cgrates/cgrates/config" + "github.com/cgrates/cgrates/engine" + "github.com/cgrates/cgrates/utils" + "github.com/cgrates/rpcclient" +) + +//TestSIPAgentCoverage for cover testing +func TestSIPAgentCoverage(t *testing.T) { + cfg := config.NewDefaultCGRConfig() + cfg.SessionSCfg().Enabled = true + filterSChan := make(chan *engine.FilterS, 1) + filterSChan <- nil + shdChan := utils.NewSyncedChan() + chS := engine.NewCacheS(cfg, nil, nil) + cacheSChan := make(chan rpcclient.ClientConnector, 1) + cacheSChan <- chS + srvDep := map[string]*sync.WaitGroup{utils.DataDB: new(sync.WaitGroup)} + srv := &SIPAgent{ + RWMutex: sync.RWMutex{}, + cfg: cfg, + filterSChan: filterSChan, + shdChan: shdChan, + connMgr: nil, + srvDep: srvDep, + oldListen: "", + } + if srv.IsRunning() { + t.Errorf("Expected service to be down") + } + +}