diff --git a/config/datadbcfg_test.go b/config/datadbcfg_test.go index 379f3143e..9519418d2 100644 --- a/config/datadbcfg_test.go +++ b/config/datadbcfg_test.go @@ -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)) + } }