Coverage tests in services

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)

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))
 	}
+
 }

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 <http://www.gnu.org/licenses/>
+*/
+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 <nil>,\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 <nil>,\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 <false>,\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))
+	}
+
+}

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 <http://www.gnu.org/licenses/>
+
+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")
+	}
+
+}