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

Add more cases for populate Rmt/Rpl DataDB conns

Browse Source
This commit is contained in:
TeoV
2019-10-31 17:00:22 +02:00
committed by Dan Christian Bogos
parent 4f0f423c0f
commit c4dc2b7eef
1 changed files with 95 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

95
config/datadbcfg_test.go
View File

@@ -244,4 +244,99 @@ func TestDataDBRemoteReplication(t *testing.T) {
} else if !reflect.DeepEqual(expected, dbcfg) {
t.Errorf("Expected: %+v ,\n recived: %+v", utils.ToJSON(expected), utils.ToJSON(dbcfg))
}
cfgJSONStr = `{
"data_db": { // database used to store runtime data (eg: accounts, cdr stats)
"db_type": "*internal", // data_db type: <*redis|*mongo|*internal>
"remote_conns":[
{
"db_host": "0.0.0.0", // data_db host address
"db_port": 1234, // data_db port to reach the database
"db_name": "1", // data_db database name to connect to
"db_user": "cgrates", // username to use when connecting to data_db
},
{
"db_type": "*mongo",
"db_host": "1.2.3.4", // data_db host address
"db_port": 1235, // data_db port to reach the database
"db_name": "remote_mongo", // data_db database name to connect to
"db_user": "remote_mongo_user", // username to use when connecting to data_db
},
],
"replication_conns":[
{
"db_type": "*mongo",
"db_host": "1.1.1.1", // data_db host address
"db_port": 1234, // data_db port to reach the database
"db_name": "replication_mongo", // data_db database name to connect to
"db_user": "user", // username to use when connecting to data_db
"db_password": "pass",
},
{
"db_host": "127.0.0.1", // data_db host address
"db_port": 8888, // data_db port to reach the database
"db_name": "15", // data_db database name to connect to
},
],
}
}`
expected = DataDbCfg{
DataDbType: utils.INTERNAL,
DataDbHost: "127.0.0.1",
DataDbPort: "6379",
DataDbName: "10",
DataDbUser: "cgrates",
DataDbPass: "password",
DataDbSentinelName: "sentinel",
RmtDataDBCfgs: []*DataDbCfg{
&DataDbCfg{
DataDbType: utils.REDIS,
DataDbHost: "0.0.0.0",
DataDbPort: "1234",
DataDbName: "1",
DataDbUser: "cgrates",
DataDbPass: "",
QueryTimeout: 10 * time.Second,
},
&DataDbCfg{
DataDbType: utils.MONGO,
DataDbHost: "1.2.3.4",
DataDbPort: "1235",
DataDbName: "remote_mongo",
DataDbUser: "remote_mongo_user",
DataDbPass: "",
QueryTimeout: 10 * time.Second,
},
},
RplDataDBCfgs: []*DataDbCfg{
&DataDbCfg{
DataDbType: utils.MONGO,
DataDbHost: "1.1.1.1",
DataDbPort: "1234",
DataDbName: "replication_mongo",
DataDbUser: "user",
DataDbPass: "pass",
QueryTimeout: 10 * time.Second,
},
&DataDbCfg{
DataDbType: utils.REDIS,
DataDbHost: "127.0.0.1",
DataDbPort: "8888",
DataDbName: "15",
DataDbUser: "cgrates",
DataDbPass: "",
QueryTimeout: 10 * time.Second,
},
},
}
if jsnCfg, err := NewCgrJsonCfgFromBytes([]byte(cfgJSONStr)); err != nil {
t.Error(err)
} else if jsnDataDbCfg, err := jsnCfg.DbJsonCfg(DATADB_JSN); err != nil {
t.Error(err)
} else if err = dbcfg.loadFromJsonCfg(jsnDataDbCfg); err != nil {
t.Error(err)
} else if !reflect.DeepEqual(expected, dbcfg) {
t.Errorf("Expected: %+v ,\n recived: %+v", utils.ToJSON(expected), utils.ToJSON(dbcfg))
}
}