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

Reformated integration tests

Browse Source
This commit is contained in:
Edwardro22
2016-11-28 03:49:53 +01:00
parent f742970ddd
commit 46c240bc8e
7 changed files with 54 additions and 127 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
engine/actions_test.go
View File

@@ -29,6 +29,7 @@ import (
"github.com/cgrates/cgrates/utils"
)
var err error
var (
//referenceDate = time.Date(2013, 7, 10, 10, 30, 0, 0, time.Local)
//referenceDate = time.Date(2013, 12, 31, 23, 59, 59, 0, time.Local)

17
engine/storage_cdrs_it_test.go
View File

@@ -1,3 +1,5 @@
// +build integration
/*
Real-time Online/Offline Charging System (OCS) for Telecom & ISP environments
Copyright (C) ITsysCOM GmbH
@@ -19,7 +21,6 @@ package engine
import (
"errors"
"flag"
"fmt"
"path"
"strconv"
@@ -30,12 +31,8 @@ import (
"github.com/cgrates/cgrates/utils"
)
var testIntegration = flag.Bool("integration", false, "Perform the tests in integration mode, not by default.") // This flag will be passed here via "go test -local" args
func TestITCDRsMySQL(t *testing.T) {
if !*testIntegration {
return
}
cfg, err := config.NewCGRConfigFromFolder(path.Join(*dataDir, "conf", "samples", "storage", "mysql"))
if err != nil {
t.Error(err)
@@ -52,9 +49,7 @@ func TestITCDRsMySQL(t *testing.T) {
}
func TestITCDRsPSQL(t *testing.T) {
if !*testIntegration {
return
}
cfg, err := config.NewCGRConfigFromFolder(path.Join(*dataDir, "conf", "samples", "storage", "postgres"))
if err != nil {
t.Error(err)
@@ -71,9 +66,7 @@ func TestITCDRsPSQL(t *testing.T) {
}
func TestITCDRsMongo(t *testing.T) {
if !*testIntegration {
return
}
cfg, err := config.NewCGRConfigFromFolder(path.Join(*dataDir, "conf", "samples", "storage", "mongo"))
if err != nil {
t.Error(err)

22
engine/storage_mongo_it_test.go
View File

@@ -1,3 +1,5 @@
// +build integration
/*
Real-time Online/Offline Charging System (OCS) for Telecom & ISP environments
Copyright (C) ITsysCOM GmbH
@@ -29,9 +31,7 @@ import (
var mgoITDB *MongoStorage
func TestMGOitConnect(t *testing.T) {
if !*testIntegration {
return
}
var err error
cdrsMongoCfgPath := path.Join(*dataDir, "conf", "samples", "cdrsv2mongo")
mgoITCfg, err := config.NewCGRConfigFromFolder(cdrsMongoCfgPath)
@@ -45,18 +45,14 @@ func TestMGOitConnect(t *testing.T) {
}
func TestMGOitFlush(t *testing.T) {
if !*testIntegration {
return
}
if err := mgoITDB.Flush(""); err != nil {
t.Error(err)
}
}
func TestMGOitSetReqFilterIndexes(t *testing.T) {
if !*testIntegration {
return
}
idxes := map[string]map[string]utils.StringMap{
"Account": map[string]utils.StringMap{
"1001": utils.StringMap{
@@ -88,9 +84,7 @@ func TestMGOitSetReqFilterIndexes(t *testing.T) {
}
func TestMGOitGetReqFilterIndexes(t *testing.T) {
if !*testIntegration {
return
}
eIdxes := map[string]map[string]utils.StringMap{
"Account": map[string]utils.StringMap{
"1001": utils.StringMap{
@@ -127,9 +121,7 @@ func TestMGOitGetReqFilterIndexes(t *testing.T) {
}
func TestMGOitMatchReqFilterIndex(t *testing.T) {
if !*testIntegration {
return
}
eMp := utils.StringMap{
"RL1": true,
"RL2": true,

27
engine/storage_redis_it_test.go
View File

@@ -1,3 +1,5 @@
// +build integration
/*
Real-time Online/Offline Charging System (OCS) for Telecom & ISP environments
Copyright (C) ITsysCOM GmbH
@@ -27,12 +29,9 @@ import (
)
var rds *RedisStorage
var err error
func TestRDSitConnectRedis(t *testing.T) {
if !*testIntegration {
return
}
cfg, _ := config.NewDefaultCGRConfig()
rds, err = NewRedisStorage(fmt.Sprintf("%s:%s", cfg.TpDbHost, cfg.TpDbPort), 4, cfg.TpDbPass, cfg.DBDataEncoding, utils.REDIS_MAX_CONNS, nil, 1)
if err != nil {
@@ -41,9 +40,7 @@ func TestRDSitConnectRedis(t *testing.T) {
}
func TestRDSitFlush(t *testing.T) {
if !*testIntegration {
return
}
if err := rds.Flush(""); err != nil {
t.Error("Failed to Flush redis database", err.Error())
}
@@ -51,9 +48,7 @@ func TestRDSitFlush(t *testing.T) {
}
func TestRDSitSetGetDerivedCharges(t *testing.T) {
if !*testIntegration {
return
}
keyCharger1 := utils.ConcatenatedKey("*out", "cgrates.org", "call", "dan", "dan")
charger1 := &utils.DerivedChargers{Chargers: []*utils.DerivedCharger{
&utils.DerivedCharger{RunID: "extra1", RequestTypeField: "^prepaid", DirectionField: "*default", TenantField: "*default", CategoryField: "*default",
@@ -79,9 +74,7 @@ func TestRDSitSetGetDerivedCharges(t *testing.T) {
}
func TestRDSitSetReqFilterIndexes(t *testing.T) {
if !*testIntegration {
return
}
idxes := map[string]map[string]utils.StringMap{
"Account": map[string]utils.StringMap{
"1001": utils.StringMap{
@@ -113,9 +106,7 @@ func TestRDSitSetReqFilterIndexes(t *testing.T) {
}
func TestRDSitGetReqFilterIndexes(t *testing.T) {
if !*testIntegration {
return
}
eIdxes := map[string]map[string]utils.StringMap{
"Account": map[string]utils.StringMap{
"1001": utils.StringMap{
@@ -152,9 +143,7 @@ func TestRDSitGetReqFilterIndexes(t *testing.T) {
}
func TestRDSitMatchReqFilterIndex(t *testing.T) {
if !*testIntegration {
return
}
eMp := utils.StringMap{
"RL1": true,
"RL2": true,