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

Modified filter indexes it tests to use methods over RCP

Browse Source
This commit is contained in:
Trial97
2018-11-01 17:33:27 +02:00
committed by Dan Christian Bogos
parent 00313d9334
commit a845675094
2 changed files with 358 additions and 430 deletions
Download Patch File Download Diff File Expand all files Collapse all files

765
apier/v1/filter_indexes_it_test.go
View File

File diff suppressed because it is too large Load Diff

23
apier/v1/filterindexecache_it_test.go
View File

@@ -20,7 +20,6 @@ along with this program. If not, see <http://www.gnu.org/licenses/>
package v1
import (
"fmt"
"net/rpc"
"net/rpc/jsonrpc"
"path"
@@ -82,15 +81,6 @@ var sTestsFilterIndexesSV1Ca = []func(t *testing.T){
// Test start here
func TestFIdxCaV1ITMySQL(t *testing.T) {
cfg, _ := config.NewDefaultCGRConfig()
rdsITdb, err := engine.NewRedisStorage(
fmt.Sprintf("%s:%s", cfg.DataDbCfg().DataDbHost, cfg.DataDbCfg().DataDbPort),
10, cfg.DataDbCfg().DataDbPass, cfg.GeneralCfg().DBDataEncoding,
utils.REDIS_MAX_CONNS, nil, "")
if err != nil {
t.Fatal("Could not connect to Redis", err.Error())
}
onStor = engine.NewDataManager(rdsITdb)
tSv1ConfDIR = "tutmysql"
for _, stest := range sTestsFilterIndexesSV1Ca {
t.Run(tSv1ConfDIR, stest)
@@ -98,19 +88,6 @@ func TestFIdxCaV1ITMySQL(t *testing.T) {
}
func TestFIdxCaV1ITMongo(t *testing.T) {
cdrsMongoCfgPath := path.Join(*dataDir, "conf", "samples", "tutmongo")
mgoITCfg, err := config.NewCGRConfigFromFolder(cdrsMongoCfgPath)
if err != nil {
t.Fatal(err)
}
mgoITdb, err := engine.NewMongoStorage(mgoITCfg.DataDbCfg().DataDbHost,
mgoITCfg.DataDbCfg().DataDbPort, mgoITCfg.DataDbCfg().DataDbName,
mgoITCfg.DataDbCfg().DataDbUser, mgoITCfg.DataDbCfg().DataDbPass,
utils.DataDB, nil, mgoITCfg.CacheCfg())
if err != nil {
t.Fatal(err)
}
onStor = engine.NewDataManager(mgoITdb)
tSv1ConfDIR = "tutmongo"
time.Sleep(time.Duration(2 * time.Second)) // give time for engine to start
for _, stest := range sTestsFilterIndexesSV1Ca {