uppal/cgrates
1
0
Fork 1
mirror of https://github.com/cgrates/cgrates.git synced 2026-02-11 18:16:24 +05:00
Code Issues Packages Projects Releases Wiki Activity

Updated tests

Browse Source
This commit is contained in:
Trial97
2020-11-03 13:53:04 +02:00
committed by Dan Christian Bogos
parent a64e58278d
commit 0b55bc7899
14 changed files with 50 additions and 13 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
analyzers/analyzers_it_test.go
View File

@@ -75,7 +75,6 @@ func newRPCClient(cfg *config.ListenCfg) (c *rpc.Client, err error) {
//Test start here
func TestAnalyzerSIT(t *testing.T) {
for _, stest := range sTestsAlsPrf {
t.Run("TestAnalyzerSIT", stest)
}
@@ -220,4 +219,7 @@ func testAnalyzerSKillEngine(t *testing.T) {
if err := engine.KillEngine(100); err != nil {
t.Error(err)
}
if err := os.RemoveAll(anzCfg.AnalyzerSCfg().DBPath); err != nil {
t.Fatal(err)
}
}

15
analyzers/analyzers_test.go
View File

@@ -63,6 +63,9 @@ func TestNewAnalyzerService(t *testing.T) {
t.Fatal(err)
}
anz.db.Close()
if err := os.RemoveAll(cfg.AnalyzerSCfg().DBPath); err != nil {
t.Fatal(err)
}
}
func TestAnalyzerSLogTraffic(t *testing.T) {
@@ -116,6 +119,9 @@ func TestAnalyzerSLogTraffic(t *testing.T) {
if err = anz.clenaUp(); err != bleve.ErrorIndexClosed {
t.Errorf("Expected error: %v,received: %+v", bleve.ErrorIndexClosed, err)
}
if err := os.RemoveAll(cfg.AnalyzerSCfg().DBPath); err != nil {
t.Fatal(err)
}
}
func TestAnalyzersDeleteHits(t *testing.T) {
@@ -138,6 +144,9 @@ func TestAnalyzersDeleteHits(t *testing.T) {
if err = anz.deleteHits(search.DocumentMatchCollection{&search.DocumentMatch{}}); err != utils.ErrPartiallyExecuted {
t.Errorf("Expected error: %v,received: %+v", utils.ErrPartiallyExecuted, err)
}
if err := os.RemoveAll(cfg.AnalyzerSCfg().DBPath); err != nil {
t.Fatal(err)
}
}
func TestAnalyzersListenAndServe(t *testing.T) {
@@ -173,6 +182,9 @@ func TestAnalyzersListenAndServe(t *testing.T) {
anz.db.Close()
}()
anz.ListenAndServe(make(chan bool))
if err := os.RemoveAll(cfg.AnalyzerSCfg().DBPath); err != nil {
t.Fatal(err)
}
}
func TestAnalyzersV1Search(t *testing.T) {
@@ -289,4 +301,7 @@ func TestAnalyzersV1Search(t *testing.T) {
if err = anz.V1StringQuery("RequestEncoding:*gob", &reply); err != bleve.ErrorIndexClosed {
t.Errorf("Expected error: %v,received: %+v", bleve.ErrorIndexClosed, err)
}
if err := os.RemoveAll(cfg.AnalyzerSCfg().DBPath); err != nil {
t.Fatal(err)
}
}

3
analyzers/codec_test.go
View File

@@ -97,4 +97,7 @@ func TestNewServerCodec(t *testing.T) {
} else if cnt != 1 {
t.Errorf("Expected only one document received:%v", cnt)
}
if err := os.RemoveAll(cfg.AnalyzerSCfg().DBPath); err != nil {
t.Fatal(err)
}
}

3
analyzers/connector_test.go
View File

@@ -62,4 +62,7 @@ func TestNewAnalyzeConnector(t *testing.T) {
} else if cnt != 1 {
t.Errorf("Expected only one document received:%v", cnt)
}
if err := os.RemoveAll(cfg.AnalyzerSCfg().DBPath); err != nil {
t.Fatal(err)
}
}

2
apier/v1/apier_it_test.go
View File

@@ -2059,7 +2059,7 @@ func testApierReplayFldPosts(t *testing.T) {
ev := &engine.ExportEvents{
Path: "http://localhost:2081",
Format: utils.MetaHTTPjson,
Events: []interface{}{bev},
Events: []interface{}{&engine.HTTPPosterRequest{Body: bev, Header: http.Header{"Content-Type": []string{"application/json"}}}},
}
fileName := "act>*http_post|63bed4ea-615e-4096-b1f4-499f64f29b28.json"

8
dispatcherh/dispatcherh_it_test.go
View File

@@ -52,10 +52,10 @@ var (
testDsphInitDB,
testDsphStartEngine,
testDsphLoadData,
// testDsphBeforeDsphStart,
// testDsphStartAll2,
// testDsphStartAll,
// testDsphStopEngines,
testDsphBeforeDsphStart,
testDsphStartAll2,
testDsphStartAll,
testDsphStopEngines,
testDsphStopDispatcher,
}
)

14
dispatcherh/libdispatcherh_test.go
View File

@@ -240,7 +240,19 @@ func TestRegister(t *testing.T) {
}
engine.NewConnManager(errCfg, map[string]chan rpcclient.ClientConnector{})
errCfg.CacheCfg().Partitions[utils.CacheDispatcherHosts].Replicate = true
errCfg.CacheCfg().ReplicationConns = []string{"*localhost"}
errCfg.RPCConns()["errCon"] = &config.RPCConn{
Strategy: utils.MetaFirst,
PoolSize: 1,
Conns: []*config.RemoteHost{
{
Address: "127.0.0.1:5612",
Transport: "*json",
Synchronous: false,
TLS: false,
},
},
}
errCfg.CacheCfg().ReplicationConns = []string{"errCon"}
engine.SetCache(engine.NewCacheS(errCfg, nil))
req.Body = ioutil.NopCloser(bytes.NewBuffer(uargsJSON))
if _, err := register(req); err != utils.ErrPartiallyExecuted {

2
ees/httppost.go
View File

@@ -115,7 +115,7 @@ func (httpPost *HTTPPost) ExportEvent(cgrEv *utils.CGREventWithOpts) (err error)
httpPost.cgrCfg.GeneralCfg().FailedPostsDir != utils.META_NONE {
engine.AddFailedPost(httpPost.cgrCfg.EEsCfg().Exporters[httpPost.cfgIdx].ExportPath,
httpPost.cgrCfg.EEsCfg().Exporters[httpPost.cfgIdx].Type, utils.EventExporterS,
engine.HTTPPosterRequest{
&engine.HTTPPosterRequest{
Header: hdr,
Body: urlVals,
}, httpPost.cgrCfg.EEsCfg().Exporters[httpPost.cfgIdx].Opts)

2
engine/caches.go
View File

@@ -78,6 +78,8 @@ func init() {
gob.Register(new(StatSum))
gob.Register(new(StatAverage))
gob.Register(new(StatDistinct))
gob.Register(new(HTTPPosterRequest))
}
//SetCache shared the cache from other subsystems

2
engine/libcdre.go
View File

@@ -164,7 +164,7 @@ func (expEv *ExportEvents) ReplayFailedPosts(attempts int) (failedEvents *Export
return expEv, err
}
for _, ev := range expEv.Events {
req := ev.(HTTPPosterRequest)
req := ev.(*HTTPPosterRequest)
err = pstr.PostValues(req.Body, req.Header)
if err != nil {
failedEvents.AddEvent(req)

2
services/dnsagent_it_test.go
View File

@@ -52,7 +52,7 @@ func TestDNSAgentReload(t *testing.T) {
db := NewDataDBService(cfg, nil)
anz := NewAnalyzerService(cfg, server, engineShutdown, make(chan rpcclient.ClientConnector, 1))
sS := NewSessionService(cfg, db, server, make(chan rpcclient.ClientConnector, 1),
engineShutdown, nil, utils.NewConReqs(0, ""), anz)
engineShutdown, nil, nil, anz)
srv := NewDNSAgent(cfg, filterSChan, engineShutdown, nil)
engine.NewConnManager(cfg, nil)
srvMngr.AddServices(srv, sS,

2
services/ers_it_test.go
View File

@@ -56,7 +56,7 @@ func TestEventReaderSReload(t *testing.T) {
srvMngr := servmanager.NewServiceManager(cfg, engineShutdown)
anz := NewAnalyzerService(cfg, server, engineShutdown, make(chan rpcclient.ClientConnector, 1))
db := NewDataDBService(cfg, nil)
sS := NewSessionService(cfg, db, server, make(chan rpcclient.ClientConnector, 1), engineShutdown, nil, utils.NewConReqs(0, ""), anz)
sS := NewSessionService(cfg, db, server, make(chan rpcclient.ClientConnector, 1), engineShutdown, nil, nil, anz)
attrS := NewEventReaderService(cfg, filterSChan, engineShutdown, nil)
engine.NewConnManager(cfg, nil)
srvMngr.AddServices(attrS, sS,

2
services/sessions_it_test.go
View File

@@ -79,7 +79,7 @@ func TestSessionSReload(t *testing.T) {
cdrS := NewCDRServer(cfg, db, stordb, filterSChan, server,
make(chan rpcclient.ClientConnector, 1),
nil, anz)
srv := NewSessionService(cfg, db, server, make(chan rpcclient.ClientConnector, 1), engineShutdown, nil, utils.NewConReqs(0, ""), anz)
srv := NewSessionService(cfg, db, server, make(chan rpcclient.ClientConnector, 1), engineShutdown, nil, nil, anz)
engine.NewConnManager(cfg, nil)
srvMngr.AddServices(srv, chrS, schS, ralS, cdrS,
NewLoaderService(cfg, db, filterSChan, server, engineShutdown, make(chan rpcclient.ClientConnector, 1), nil, anz), db, stordb)

2
services/sipagent_it_test.go
View File

@@ -52,7 +52,7 @@ func TestSIPAgentReload(t *testing.T) {
db := NewDataDBService(cfg, nil)
anz := NewAnalyzerService(cfg, server, engineShutdown, make(chan rpcclient.ClientConnector, 1))
sS := NewSessionService(cfg, db, server, make(chan rpcclient.ClientConnector, 1),
engineShutdown, nil, utils.NewConReqs(0, ""), anz)
engineShutdown, nil, nil, anz)
srv := NewSIPAgent(cfg, filterSChan, engineShutdown, nil)
engine.NewConnManager(cfg, nil)
srvMngr.AddServices(srv, sS,