7780670ae4
* build(deps): update redis client to v4 in legacy mode * fix: node17+ - prefer ipv4 * chore: use redis client v4 api (async) and adapt error handling * fix: timeout by exiting if not in watch mode * fix: parse message before republishing --------- Co-authored-by: Ankush Menat <ankush@frappe.io>
60 lines
1.5 KiB
JavaScript
60 lines
1.5 KiB
JavaScript
const fs = require("fs");
|
|
const path = require("path");
|
|
const redis = require("@redis/client");
|
|
const bench_path = path.resolve(__dirname, "..", "..");
|
|
|
|
const dns = require("dns");
|
|
|
|
// Since node17, node resolves to ipv6 unless system is configured otherwise.
|
|
// In Frappe context using ipv4 - 127.0.0.1 is fine.
|
|
dns.setDefaultResultOrder("ipv4first");
|
|
|
|
function get_conf() {
|
|
// defaults
|
|
var conf = {
|
|
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 overrides from environment
|
|
if (process.env.FRAPPE_SITE) {
|
|
conf.default_site = process.env.FRAPPE_SITE;
|
|
}
|
|
if (process.env.FRAPPE_REDIS_CACHE) {
|
|
conf.redis_cache = process.env.FRAPPE_REDIS_CACHE;
|
|
}
|
|
if (process.env.FRAPPE_REDIS_QUEUE) {
|
|
conf.redis_queue = process.env.FRAPPE_REDIS_QUEUE;
|
|
}
|
|
if (process.env.FRAPPE_SOCKETIO_PORT) {
|
|
conf.socketio_port = process.env.FRAPPE_SOCKETIO_PORT;
|
|
}
|
|
return conf;
|
|
}
|
|
|
|
function get_redis_subscriber(kind = "redis_queue", options = {}) {
|
|
const conf = get_conf();
|
|
const host = conf[kind];
|
|
return redis.createClient({ url: host, ...options });
|
|
}
|
|
|
|
module.exports = {
|
|
get_conf,
|
|
get_redis_subscriber,
|
|
};
|