From cd24ccc3f686f2cd02f500efad05e5ca78313006 Mon Sep 17 00:00:00 2001 From: andronache Date: Fri, 18 Dec 2020 17:24:35 +0200 Subject: [PATCH] Tests in services --- services/asteriskagent_it_test.go | 36 +++++++++++++++++++++++++++++++ 1 file changed, 36 insertions(+) diff --git a/services/asteriskagent_it_test.go b/services/asteriskagent_it_test.go index 467b8036a..bf3f7506c 100644 --- a/services/asteriskagent_it_test.go +++ b/services/asteriskagent_it_test.go @@ -25,6 +25,8 @@ import ( "testing" "time" + "github.com/cgrates/cgrates/agents" + "github.com/cgrates/cgrates/config" "github.com/cgrates/cgrates/cores" "github.com/cgrates/cgrates/engine" @@ -95,3 +97,37 @@ func TestAsteriskAgentReload(t *testing.T) { shdChan.CloseOnce() time.Sleep(10 * time.Millisecond) } + +//TestAsteriskAgentCoverage for cover testing +func TestAsteriskAgentCoverage(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 := &AsteriskAgent{ + RWMutex: sync.RWMutex{}, + cfg: cfg, + shdChan: shdChan, + stopChan: nil, + smas: nil, + connMgr: nil, + srvDep: srvDep, + } + if srv.IsRunning() { + t.Errorf("Expected service to be down") + } + srv.smas = []*agents.AsteriskAgent{} + if !srv.IsRunning() { + t.Errorf("Expected service to be running") + } + err := srv.Start() + if err != utils.ErrServiceAlreadyRunning { + t.Errorf("\nExpecting <%+v>,\n Received <%+v>", utils.ErrServiceAlreadyRunning, err) + } + +}