3414c0d063
- realtime communication uses pub-sub and no storage. So using same redis server for both should be just fine. - This is how FC works since quite a lot of time. We haven't seen any problem so far.
50 lines
1.2 KiB
JavaScript
50 lines
1.2 KiB
JavaScript
const fs = require("fs");
|
|
const path = require("path");
|
|
const redis = require("redis");
|
|
const bench_path = path.resolve(__dirname, "..", "..");
|
|
|
|
function get_conf() {
|
|
// defaults
|
|
var conf = {
|
|
redis_async_broker_port: "redis://localhost:12311",
|
|
socketio_port: 3000,
|
|
};
|
|
|
|
var read_config = function (file_path) {
|
|
const full_path = path.resolve(bench_path, file_path);
|
|
|
|
if (fs.existsSync(full_path)) {
|
|
var bench_config = JSON.parse(fs.readFileSync(full_path));
|
|
for (var key in bench_config) {
|
|
if (bench_config[key]) {
|
|
conf[key] = bench_config[key];
|
|
}
|
|
}
|
|
}
|
|
};
|
|
|
|
// get ports from bench/config.json
|
|
read_config("config.json");
|
|
read_config("sites/common_site_config.json");
|
|
|
|
// set default site
|
|
if (process.env.FRAPPE_SITE) {
|
|
conf.default_site = process.env.FRAPPE_SITE;
|
|
}
|
|
if (fs.existsSync("sites/currentsite.txt")) {
|
|
conf.default_site = fs.readFileSync("sites/currentsite.txt").toString().trim();
|
|
}
|
|
|
|
return conf;
|
|
}
|
|
|
|
function get_redis_subscriber(kind = "redis_queue", options = {}) {
|
|
const conf = get_conf();
|
|
const host = conf[kind] || conf.redis_async_broker_port;
|
|
return redis.createClient({ url: host, ...options });
|
|
}
|
|
|
|
module.exports = {
|
|
get_conf,
|
|
get_redis_subscriber,
|
|
};
|