RTL/backend/controllers/shared/RTLConf.js

import * as fs from 'fs';
import { sep } from 'path';
import ini from 'ini';
import parseHocon from 'hocon-parser';
import request from 'request-promise';
import { Database } from '../../utils/database.js';
import { Logger } from '../../utils/logger.js';
import { Common } from '../../utils/common.js';
import { WSServer } from '../../utils/webSocketServer.js';
const options = { url: '' };
const logger = Logger;
const common = Common;
const wsServer = WSServer;
const databaseService = Database;
export const updateSelectedNode = (req, res, next) => {
    logger.log({ selectedNode: req.session.selectedNode, level: 'INFO', fileName: 'RTLConf', msg: 'Updating Selected Node..' });
    const selNodeIndex = req.params.currNodeIndex ? +req.params.currNodeIndex : common.initSelectedNode ? +common.initSelectedNode.index : 1;
    req.session.selectedNode = common.findNode(selNodeIndex);
    if (req.headers && req.headers.authorization && req.headers.authorization !== '') {
        wsServer.updateLNWSClientDetails(req.session.id, +req.session.selectedNode.index, +req.params.prevNodeIndex);
        if (req.params.prevNodeIndex !== '-1') {
            databaseService.unloadDatabase(req.params.prevNodeIndex, req.session.id);
        }
        if (req.params.currNodeIndex !== '-1') {
            databaseService.loadDatabase(req.session);
        }
    }
    const responseVal = !req.session.selectedNode.ln_node ? '' : req.session.selectedNode.ln_node;
    logger.log({ selectedNode: req.session.selectedNode, level: 'INFO', fileName: 'RTLConf', msg: 'Selected Node Updated To ' + responseVal });
    res.status(200).json({ status: 'Selected Node Updated To: ' + JSON.stringify(responseVal) + '!' });
};
export const getRTLConfigInitial = (req, res, next) => {
    logger.log({ selectedNode: req.session.selectedNode, level: 'INFO', fileName: 'RTLConf', msg: 'Getting Initial RTL Configuration..' });
    const confFile = common.rtl_conf_file_path + sep + 'RTL-Config.json';
    fs.readFile(confFile, 'utf8', (errRes, data) => {
        if (errRes) {
            if (errRes.code === 'ENOENT') {
                logger.log({ selectedNode: req.session.selectedNode, level: 'ERROR', fileName: 'RTLConf', msg: 'Node config does not exist!', error: { error: 'Node config does not exist.' } });
                res.status(200).json({ defaultNodeIndex: 0, selectedNodeIndex: 0, sso: {}, nodes: [] });
            }
            else {
                const errMsg = 'Get Node Config Error';
                const err = common.handleError({ statusCode: 500, message: errMsg, error: errRes }, 'RTLConf', errMsg, req.session.selectedNode);
                return res.status(err.statusCode).json({ message: err.error, error: err.error });
            }
        }
        else {
            const nodeConfData = JSON.parse(data);
            const sso = { rtlSSO: common.rtl_sso, logoutRedirectLink: common.logout_redirect_link };
            const enable2FA = !!common.rtl_secret2fa;
            const allowPasswordUpdate = common.flg_allow_password_update;
            const nodesArr = [];
            if (common.nodes && common.nodes.length > 0) {
                common.nodes.forEach((node, i) => {
                    const settings = { unannouncedChannels: false };
                    settings.userPersona = node.user_persona ? node.user_persona : 'MERCHANT';
                    settings.themeMode = (node.theme_mode) ? node.theme_mode : 'DAY';
                    settings.themeColor = (node.theme_color) ? node.theme_color : 'PURPLE';
                    settings.unannouncedChannels = !!node.unannounced_channels || false;
                    settings.fiatConversion = (node.fiat_conversion) ? !!node.fiat_conversion : false;
                    settings.currencyUnit = node.currency_unit;
                    nodesArr.push({
                        index: node.index,
                        lnNode: node.ln_node,
                        lnImplementation: node.ln_implementation,
                        settings: settings,
                        authentication: {}
                    });
                });
            }
            const body = { defaultNodeIndex: nodeConfData.defaultNodeIndex, selectedNodeIndex: (req.session.selectedNode && req.session.selectedNode.index ? req.session.selectedNode.index : common.initSelectedNode.index), sso: sso, enable2FA: enable2FA, allowPasswordUpdate: allowPasswordUpdate, nodes: nodesArr };
            logger.log({ selectedNode: req.session.selectedNode, level: 'INFO', fileName: 'RTLConf', msg: 'Initial RTL Configuration Received', data: body });
            res.status(200).json(body);
        }
    });
};
export const getRTLConfig = (req, res, next) => {
    logger.log({ selectedNode: req.session.selectedNode, level: 'INFO', fileName: 'RTLConf', msg: 'Getting RTL Configuration..' });
    const confFile = common.rtl_conf_file_path + sep + 'RTL-Config.json';
    fs.readFile(confFile, 'utf8', (errRes, data) => {
        if (errRes) {
            if (errRes.code === 'ENOENT') {
                logger.log({ selectedNode: req.session.selectedNode, level: 'ERROR', fileName: 'RTLConf', msg: 'Node config does not exist!', error: { error: 'Node config does not exist.' } });
                res.status(200).json({ defaultNodeIndex: 0, selectedNodeIndex: 0, sso: {}, nodes: [] });
            }
            else {
                const errMsg = 'Get Node Config Error';
                const err = common.handleError({ statusCode: 500, message: errMsg, error: errRes }, 'RTLConf', errMsg, req.session.selectedNode);
                return res.status(err.statusCode).json({ message: err.error, error: err.error });
            }
        }
        else {
            const nodeConfData = JSON.parse(data);
            const sso = { rtlSSO: common.rtl_sso, logoutRedirectLink: common.logout_redirect_link };
            const enable2FA = !!common.rtl_secret2fa;
            const allowPasswordUpdate = common.flg_allow_password_update;
            const nodesArr = [];
            if (common.nodes && common.nodes.length > 0) {
                common.nodes.forEach((node, i) => {
                    const authentication = {};
                    authentication.configPath = (node.config_path) ? node.config_path : '';
                    authentication.swapMacaroonPath = (node.swap_macaroon_path) ? node.swap_macaroon_path : '';
                    authentication.boltzMacaroonPath = (node.boltz_macaroon_path) ? node.boltz_macaroon_path : '';
                    const settings = { unannouncedChannels: false };
                    settings.userPersona = node.user_persona ? node.user_persona : 'MERCHANT';
                    settings.themeMode = (node.theme_mode) ? node.theme_mode : 'DAY';
                    settings.themeColor = (node.theme_color) ? node.theme_color : 'PURPLE';
                    settings.unannouncedChannels = !!node.unannounced_channels || false;
                    settings.fiatConversion = (node.fiat_conversion) ? !!node.fiat_conversion : false;
                    settings.bitcoindConfigPath = node.bitcoind_config_path;
                    settings.logLevel = node.log_level ? node.log_level : 'ERROR';
                    settings.lnServerUrl = node.ln_server_url;
                    settings.swapServerUrl = node.swap_server_url;
                    settings.boltzServerUrl = node.boltz_server_url;
                    settings.enableOffers = node.enable_offers;
                    settings.enablePeerswap = node.enable_peerswap;
                    settings.channelBackupPath = node.channel_backup_path;
                    settings.currencyUnit = node.currency_unit;
                    nodesArr.push({
                        index: node.index,
                        lnNode: node.ln_node,
                        lnImplementation: node.ln_implementation,
                        settings: settings,
                        authentication: authentication
                    });
                });
            }
            const body = { defaultNodeIndex: nodeConfData.defaultNodeIndex, selectedNodeIndex: (req.session.selectedNode && req.session.selectedNode.index ? req.session.selectedNode.index : common.initSelectedNode.index), sso: sso, enable2FA: enable2FA, allowPasswordUpdate: allowPasswordUpdate, nodes: nodesArr };
            logger.log({ selectedNode: req.session.selectedNode, level: 'INFO', fileName: 'RTLConf', msg: 'RTL Configuration Received', data: body });
            res.status(200).json(body);
        }
    });
};
export const updateUISettings = (req, res, next) => {
    logger.log({ selectedNode: req.session.selectedNode, level: 'INFO', fileName: 'RTLConf', msg: 'Updating UI Settings..' });
    const RTLConfFile = common.rtl_conf_file_path + sep + 'RTL-Config.json';
    const config = JSON.parse(fs.readFileSync(RTLConfFile, 'utf-8'));
    const node = config.nodes.find((node) => (node.index === req.session.selectedNode.index));
    if (node && node.Settings) {
        node.Settings.userPersona = req.body.updatedSettings.userPersona;
        node.Settings.themeMode = req.body.updatedSettings.themeMode;
        node.Settings.themeColor = req.body.updatedSettings.themeColor;
        node.Settings.unannouncedChannels = req.body.updatedSettings.unannouncedChannels;
        node.Settings.fiatConversion = req.body.updatedSettings.fiatConversion;
        if (req.body.updatedSettings.fiatConversion) {
            node.Settings.currencyUnit = req.body.updatedSettings.currencyUnit ? req.body.updatedSettings.currencyUnit : 'USD';
        }
        else {
            delete node.Settings.currencyUnit;
        }
        const selectedNode = common.findNode(req.session.selectedNode.index);
        selectedNode.user_persona = req.body.updatedSettings.userPersona;
        selectedNode.theme_mode = req.body.updatedSettings.themeMode;
        selectedNode.theme_color = req.body.updatedSettings.themeColor;
        selectedNode.unannounced_channels = req.body.updatedSettings.unannouncedChannels;
        selectedNode.fiat_conversion = req.body.updatedSettings.fiatConversion;
        if (req.body.updatedSettings.fiatConversion) {
            selectedNode.currency_unit = req.body.updatedSettings.currencyUnit ? req.body.updatedSettings.currencyUnit : 'USD';
        }
        else {
            delete selectedNode.currency_unit;
        }
        common.replaceNode(req, selectedNode);
    }
    try {
        fs.writeFileSync(RTLConfFile, JSON.stringify(config, null, 2), 'utf-8');
        logger.log({ selectedNode: req.session.selectedNode, level: 'INFO', fileName: 'RTLConf', msg: 'UI Settings Updated', data: maskPasswords(config) });
        res.status(201).json({ message: 'Node Settings Updated Successfully' });
    }
    catch (errRes) {
        const errMsg = 'Update Node Settings Error';
        const err = common.handleError({ statusCode: 500, message: errMsg, error: errRes }, 'RTLConf', errMsg, req.session.selectedNode);
        return res.status(err.statusCode).json({ message: err.error, error: err.error });
    }
};
export const update2FASettings = (req, res, next) => {
    logger.log({ selectedNode: req.session.selectedNode, level: 'INFO', fileName: 'RTLConf', msg: 'Updating 2FA Settings..' });
    const RTLConfFile = common.rtl_conf_file_path + sep + 'RTL-Config.json';
    const config = JSON.parse(fs.readFileSync(RTLConfFile, 'utf-8'));
    if (req.body.secret2fa && req.body.secret2fa.trim() !== '') {
        config.secret2fa = req.body.secret2fa;
    }
    else {
        delete config.secret2fa;
    }
    const message = req.body.secret2fa.trim() === '' ? 'Two factor authentication disabled successfully.' : 'Two factor authentication enabled successfully.';
    try {
        fs.writeFileSync(RTLConfFile, JSON.stringify(config, null, 2), 'utf-8');
        common.rtl_secret2fa = config.secret2fa;
        logger.log({ selectedNode: req.session.selectedNode, level: 'INFO', fileName: 'RTLConf', msg: message });
        res.status(201).json({ message: message });
    }
    catch (errRes) {
        const errMsg = 'Update 2FA Settings Error';
        const err = common.handleError({ statusCode: 500, message: errMsg, error: errRes }, 'RTLConf', errMsg, req.session.selectedNode);
        return res.status(err.statusCode).json({ message: err.error, error: err.error });
    }
};
export const updateDefaultNode = (req, res, next) => {
    logger.log({ selectedNode: req.session.selectedNode, level: 'INFO', fileName: 'RTLConf', msg: 'Updating Default Node..' });
    const RTLConfFile = common.rtl_conf_file_path + sep + 'RTL-Config.json';
    const config = JSON.parse(fs.readFileSync(RTLConfFile, 'utf-8'));
    config.defaultNodeIndex = req.body.defaultNodeIndex;
    try {
        fs.writeFileSync(RTLConfFile, JSON.stringify(config, null, 2), 'utf-8');
        logger.log({ selectedNode: req.session.selectedNode, level: 'INFO', fileName: 'RTLConf', msg: 'Default Node Updated', data: maskPasswords(config) });
        res.status(201).json({ message: 'Default Node Updated Successfully' });
    }
    catch (errRes) {
        const errMsg = 'Update Default Node Error';
        const err = common.handleError({ statusCode: 500, message: errMsg, error: errRes }, 'RTLConf', errMsg, req.session.selectedNode);
        return res.status(err.statusCode).json({ message: err.error, error: err.error });
    }
};
export const getConfig = (req, res, next) => {
    logger.log({ selectedNode: req.session.selectedNode, level: 'INFO', fileName: 'RTLConf', msg: 'Reading Configuration File..' });
    let confFile = '';
    let fileFormat = 'INI';
    switch (req.params.nodeType) {
        case 'ln':
            confFile = req.session.selectedNode.config_path;
            break;
        case 'bitcoind':
            confFile = req.session.selectedNode.bitcoind_config_path;
            break;
        case 'rtl':
            fileFormat = 'JSON';
            confFile = common.rtl_conf_file_path + sep + 'RTL-Config.json';
            break;
        default:
            confFile = '';
            break;
    }
    logger.log({ selectedNode: req.session.selectedNode, level: 'DEBUG', fileName: 'RTLConf', msg: 'Node Type', data: req.params.nodeType });
    logger.log({ selectedNode: req.session.selectedNode, level: 'DEBUG', fileName: 'RTLConf', msg: 'File Path', data: confFile });
    fs.readFile(confFile, 'utf8', (errRes, data) => {
        if (errRes) {
            const errMsg = 'Reading Config Error';
            const err = common.handleError({ statusCode: 500, message: errMsg, error: errRes }, 'RTLConf', errMsg, req.session.selectedNode);
            return res.status(err.statusCode).json({ message: err.error, error: err.error });
        }
        else {
            let jsonConfig = {};
            if (fileFormat === 'JSON') {
                jsonConfig = JSON.parse(data);
            }
            else {
                fileFormat = 'INI';
                data = data?.replace('color=#', 'color=');
                jsonConfig = ini.parse(data);
                if (jsonConfig['Application Options'] && jsonConfig['Application Options'].color) {
                    jsonConfig['Application Options'].color = '#' + jsonConfig['Application Options'].color;
                }
                if (req.params.nodeType === 'ln' && req.session.selectedNode.ln_implementation === 'ECL' && !jsonConfig['eclair.api.password']) {
                    fileFormat = 'HOCON';
                    jsonConfig = parseHocon(data);
                }
            }
            jsonConfig = maskPasswords(jsonConfig);
            const responseJSON = (fileFormat === 'JSON') ? jsonConfig : ini.stringify(jsonConfig)?.replace('color=\\#', 'color=#');
            logger.log({ selectedNode: req.session.selectedNode, level: 'INFO', fileName: 'RTLConf', msg: 'Configuration File Data Received', data: responseJSON });
            res.status(200).json({ format: fileFormat, data: responseJSON });
        }
    });
};
export const getFile = (req, res, next) => {
    logger.log({ selectedNode: req.session.selectedNode, level: 'INFO', fileName: 'RTLConf', msg: 'Getting File..' });
    const file = req.query.path ? req.query.path : (req.session.selectedNode.channel_backup_path + sep + 'channel-' + req.query.channel?.replace(':', '-') + '.bak');
    logger.log({ selectedNode: req.session.selectedNode, level: 'DEBUG', fileName: 'RTLConf', msg: 'Channel Point', data: req.query.channel });
    logger.log({ selectedNode: req.session.selectedNode, level: 'DEBUG', fileName: 'RTLConf', msg: 'File Path', data: file });
    fs.readFile(file, 'utf8', (errRes, data) => {
        if (errRes) {
            if (errRes.code && errRes.code === 'ENOENT') {
                errRes.code = 'File Not Found!';
            }
            const errMsg = 'Reading File Error';
            const err = common.handleError({ statusCode: 500, message: errMsg, error: errRes }, 'RTLConf', errMsg, req.session.selectedNode);
            return res.status(err.statusCode).json({ message: err.error, error: err.error });
        }
        else {
            logger.log({ selectedNode: req.session.selectedNode, level: 'INFO', fileName: 'RTLConf', msg: 'File Data Received', data: data });
            res.status(200).json(data);
        }
    });
};
export const getCurrencyRates = (req, res, next) => {
    logger.log({ selectedNode: req.session.selectedNode, level: 'INFO', fileName: 'RTLConf', msg: 'Getting Currency Rates..' });
    options.url = 'https://blockchain.info/ticker';
    request(options).then((body) => {
        logger.log({ selectedNode: req.session.selectedNode, level: 'INFO', fileName: 'RTLConf', msg: 'Currency Rates Received', data: body });
        res.status(200).json(JSON.parse(body));
    }).catch((errRes) => {
        const errMsg = 'Get Rates Error';
        const err = common.handleError({ statusCode: 500, message: errMsg, error: errRes }, 'RTLConf', errMsg, req.session.selectedNode);
        return res.status(err.statusCode).json({ message: err.error, error: err.error });
    });
};
export const updateSSO = (req, res, next) => {
    logger.log({ selectedNode: req.session.selectedNode, level: 'INFO', fileName: 'RTLConf', msg: 'Updating SSO Settings..' });
    const RTLConfFile = common.rtl_conf_file_path + sep + 'RTL-Config.json';
    const config = JSON.parse(fs.readFileSync(RTLConfFile, 'utf-8'));
    delete config.SSO;
    config.SSO = req.body.SSO;
    try {
        fs.writeFileSync(RTLConfFile, JSON.stringify(config, null, 2), 'utf-8');
        logger.log({ selectedNode: req.session.selectedNode, level: 'INFO', fileName: 'RTLConf', msg: 'SSO Setting Updated', data: maskPasswords(config) });
        res.status(201).json({ message: 'SSO Updated Successfully' });
    }
    catch (errRes) {
        const errMsg = 'Update SSO Error';
        const err = common.handleError({ statusCode: 500, message: errMsg, error: errRes }, 'RTLConf', errMsg, req.session.selectedNode);
        return res.status(err.statusCode).json({ message: err.error, error: err.error });
    }
};
export const updateServiceSettings = (req, res, next) => {
    logger.log({ selectedNode: req.session.selectedNode, level: 'INFO', fileName: 'RTLConf', msg: 'Updating Service Settings..' });
    const RTLConfFile = common.rtl_conf_file_path + sep + 'RTL-Config.json';
    const config = JSON.parse(fs.readFileSync(RTLConfFile, 'utf-8'));
    const selectedNode = common.findNode(req.session.selectedNode.index);
    config.nodes.forEach((node) => {
        if (node.index === req.session.selectedNode.index) {
            switch (req.body.service) {
                case 'LOOP':
                    if (req.body.settings.enable) {
                        node.Settings.swapServerUrl = req.body.settings.serverUrl;
                        node.Authentication.swapMacaroonPath = req.body.settings.macaroonPath;
                        selectedNode.swap_server_url = req.body.settings.serverUrl;
                        selectedNode.swap_macaroon_path = req.body.settings.macaroonPath;
                    }
                    else {
                        delete node.Settings.swapServerUrl;
                        delete node.Authentication.swapMacaroonPath;
                        delete selectedNode.swap_server_url;
                        delete selectedNode.swap_macaroon_path;
                    }
                    break;
                case 'BOLTZ':
                    if (req.body.settings.enable) {
                        node.Settings.boltzServerUrl = req.body.settings.serverUrl;
                        node.Authentication.boltzMacaroonPath = req.body.settings.macaroonPath;
                        selectedNode.boltz_server_url = req.body.settings.serverUrl;
                        selectedNode.boltz_macaroon_path = req.body.settings.macaroonPath;
                    }
                    else {
                        delete node.Settings.boltzServerUrl;
                        delete node.Authentication.boltzMacaroonPath;
                        delete selectedNode.boltz_server_url;
                        delete selectedNode.boltz_macaroon_path;
                    }
                    break;
                case 'OFFERS':
                    node.Settings.enableOffers = req.body.settings.enableOffers;
                    selectedNode.enable_offers = req.body.settings.enableOffers;
                    break;
                case 'PEERSWAP':
                    node.Settings.enablePeerswap = req.body.settings.enablePeerswap;
                    selectedNode.enable_peerswap = req.body.settings.enablePeerswap;
                    break;
                default:
                    break;
            }
            common.replaceNode(req, selectedNode);
        }
        return node;
    });
    try {
        fs.writeFileSync(RTLConfFile, JSON.stringify(config, null, 2), 'utf-8');
        logger.log({ selectedNode: req.session.selectedNode, level: 'INFO', fileName: 'RTLConf', msg: 'Service Settings Updated', data: maskPasswords(config) });
        res.status(201).json({ message: 'Service Settings Updated Successfully' });
    }
    catch (errRes) {
        const errMsg = 'Update Service Settings Error';
        const err = common.handleError({ statusCode: 500, message: errMsg, error: errRes }, 'RTLConf', errMsg, req.session.selectedNode);
        return res.status(err.statusCode).json({ message: err.error, error: err.error });
    }
};
export const maskPasswords = (obj) => {
    const keys = Object.keys(obj);
    const length = keys.length;
    if (length !== 0) {
        for (let i = 0; i < length; i++) {
            if (typeof obj[keys[i]] === 'object') {
                keys[keys[i]] = maskPasswords(obj[keys[i]]);
            }
            if (typeof keys[i] === 'string' &&
                (keys[i].toLowerCase().includes('password') || keys[i].toLowerCase().includes('multipass') ||
                    keys[i].toLowerCase().includes('rpcpass') || keys[i].toLowerCase().includes('rpcpassword') ||
                    keys[i].toLowerCase().includes('rpcuser'))) {
                obj[keys[i]] = '********************';
            }
        }
    }
    return obj;
};