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); } } 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 = {}; 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.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 = {}; 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.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.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.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) => { var _a; 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 === null || data === void 0 ? void 0 : 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.session.selectedNode.ln_implementation === 'ECL' && !jsonConfig['eclair.api.password']) { fileFormat = 'HOCON'; jsonConfig = parseHocon(data); } } jsonConfig = maskPasswords(jsonConfig); const responseJSON = (fileFormat === 'JSON') ? jsonConfig : (_a = ini.stringify(jsonConfig)) === null || _a === void 0 ? void 0 : _a.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) => { var _a; 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-' + ((_a = req.query.channel) === null || _a === void 0 ? void 0 : _a.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'))) { obj[keys[i]] = '********************'; } } } return obj; };