441495b561
* refactor!: Drop currentsite.txt - `bench use` will continue to work. - Instead of txt file use common_site_config to set default site using `default_site` key. - `FRAPPE_SITE` environment variable also works * fix(DX): warn if non-empty currentsite.txt is present
46 lines
1.1 KiB
JavaScript
46 lines
1.1 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;
|
|
}
|
|
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,
|
|
};
|