var os = require('os'); var fs = require('fs'); var platform = require('os').platform(); var crypto = require('crypto'); var hash = crypto.createHash('sha256'); var clArgs = require('optimist').argv; var ini = require('ini'); var common = require('./common'); var path = require('path'); var upperCase = require('upper-case'); var logger = require('./controllers/logger'); var connect = {}; var errMsg = ''; connect.setDefaultConfig = () => { var homeDir = os.userInfo().homedir; var macaroonPath = ''; var lndConfigPath = ''; switch (platform) { case 'win32': macaroonPath = homeDir + '\\AppData\\Local\\Lnd\\data\\chain\\bitcoin\\mainnet'; lndConfigPath = homeDir + '\\AppData\\Local\\Lnd\\lnd.conf'; break; case 'darwin': macaroonPath = homeDir + '/Library/Application Support/Lnd/data/chain/bitcoin/mainnet'; lndConfigPath = homeDir + '/Library/Application Support/Lnd/lnd.conf'; break; case 'linux': macaroonPath = homeDir + '/.lnd/data/chain/bitcoin/mainnet'; lndConfigPath = homeDir + '/.lnd/lnd.conf'; break; default: macaroonPath = ''; lndConfigPath = ''; break; } return { Authentication: { macaroonPath: macaroonPath, nodeAuthType: 'DEFAULT', lndConfigPath: lndConfigPath, rtlPass: '' }, Settings: { flgSidenavOpened: true, flgSidenavPinned: true, menu: 'Vertical', menuType: 'Regular', theme: 'dark-blue', satsToBTC: false, lndServerUrl: 'https://localhost:8080/v1', enableLogging: false, port: 3000 }, SSO: { rtlSSO: 0, rtlCookiePath: '', logoutRedirectLink: '/login' } }; } connect.normalizePort = val => { var port = parseInt(val, 10); if (isNaN(port)) { return val; } if (port >= 0) { return port; } return false; }; connect.setMacaroonPath = (clArgs, config) => { common.nodes[0] = {}; common.nodes[0].index = 1; if(undefined !== clArgs.lndir) { common.nodes[0].macaroon_path = clArgs.lndir; } else if (undefined !== process.env.MACAROON_PATH) { common.nodes[0].macaroon_path = process.env.MACAROON_PATH; } else { if(undefined !== config.Authentication.macroonPath && config.Authentication.macroonPath !== '') { common.nodes[0].macaroon_path = config.Authentication.macroonPath; } else if(undefined !== config.Authentication.macaroonPath && config.Authentication.macaroonPath !== '') { common.nodes[0].macaroon_path = config.Authentication.macaroonPath; } } } connect.convertCustomToHash = (nodeSetupType) => { common.rtl_conf_file_path = (undefined !== process.env.RTL_CONFIG_PATH) ? process.env.RTL_CONFIG_PATH.substring(0, process.env.RTL_CONFIG_PATH.length - 9) : path.normalize(__dirname); if(nodeSetupType === 'SINGLE') { try { RTLConfFile = common.rtl_conf_file_path + '/RTL.conf'; var config = ini.parse(fs.readFileSync(RTLConfFile, 'utf-8')); const authTemp = config.Authentication; authTemp.rtlPassHashed = hash.update(authTemp.rtlPass).digest('hex'); delete authTemp.rtlPass; delete config.Authentication; fs.writeFileSync(RTLConfFile, ini.stringify(config)); fs.appendFileSync(RTLConfFile, ini.stringify(authTemp, { section: 'Authentication' })); console.log('Please note that RTL has encrypted the plaintext password into its corresponding hash.'); return authTemp.rtlPassHashed; } catch (err) { errMsg = errMsg + '\nrtlPass hash conversion failed!'; } } if(nodeSetupType === 'MULTI') { try { RTLConfFile = common.rtl_conf_file_path + '/RTL-Multi-Node-Conf.json'; var config = JSON.parse(fs.readFileSync(RTLConfFile, 'utf-8')); config.multiPassHashed = hash.update(config.multiPass).digest('hex'); delete config.multiPass; fs.writeFileSync(RTLConfFile, JSON.stringify(config, null, 2), 'utf-8'); console.log('Please note that RTL has encrypted the plaintext password into its corresponding hash.'); return config.multiPassHashed; } catch (err) { errMsg = errMsg + '\nmultiPass hash conversion failed!'; } } } connect.validateSingleNodeConfig = (config) => { if(common.nodes[0].macaroon_path === '' || undefined === common.nodes[0].macaroon_path) { errMsg = 'Please set macaroon path through environment or RTL.conf!'; } if(undefined !== process.env.LND_SERVER_URL) { common.nodes[0].lnd_server_url = process.env.LND_SERVER_URL; } else { if((config.Authentication.lndServerUrl === '' || undefined === config.Authentication.lndServerUrl) && (config.Settings.lndServerUrl === '' || undefined === config.Settings.lndServerUrl)) { errMsg = errMsg + '\nPlease set LND Server URL through environment or RTL.conf!'; } else { if (config.Settings.lndServerUrl !== '' && undefined !== config.Settings.lndServerUrl) { common.nodes[0].lnd_server_url = config.Settings.lndServerUrl; } else if (config.Authentication.lndServerUrl !== '' && undefined !== config.Authentication.lndServerUrl) { common.nodes[0].lnd_server_url = config.Authentication.lndServerUrl; } } } if(undefined !== process.env.NODE_AUTH_TYPE) { common.node_auth_type = process.env.NODE_AUTH_TYPE; } else { if(config.Authentication.nodeAuthType === '' || undefined === config.Authentication.nodeAuthType) { errMsg = errMsg + '\nPlease set Node Auth Type through environment or RTL.conf!'; } else { common.node_auth_type = config.Authentication.nodeAuthType; } } if(undefined !== process.env.LND_CONFIG_PATH) { common.nodes[0].lnd_config_path = process.env.LND_CONFIG_PATH; } else { if(config.Authentication.lndConfigPath !== '' && undefined !== config.Authentication.lndConfigPath) { common.nodes[0].lnd_config_path = config.Authentication.lndConfigPath; } else { if(upperCase(common.node_auth_type) === 'DEFAULT') { errMsg = errMsg + '\nDefault Node Authentication can be set with LND Config Path only. Please set LND Config Path through environment or RTL.conf!'; } } } if(undefined !== process.env.BITCOIND_CONFIG_PATH) { common.nodes[0].bitcoind_config_path = process.env.BITCOIND_CONFIG_PATH; } else { if(config.Settings.bitcoindConfigPath !== '' && undefined !== config.Settings.bitcoindConfigPath) { common.nodes[0].bitcoind_config_path = config.Settings.bitcoindConfigPath; } else if(config.Authentication.bitcoindConfigPath !== '' && undefined !== config.Authentication.bitcoindConfigPath) { common.nodes[0].bitcoind_config_path = config.Authentication.bitcoindConfigPath; } } if (undefined !== process.env.RTL_PASS) { common.rtl_pass = process.env.RTL_PASS; } else if (config.Authentication.rtlPassHashed !== '' && undefined !== config.Authentication.rtlPassHashed) { common.rtl_pass = config.Authentication.rtlPassHashed; } else if (config.Authentication.rtlPass !== '' && undefined !== config.Authentication.rtlPass) { common.rtl_pass = connect.convertCustomToHash('SINGLE'); } if (upperCase(common.node_auth_type) === 'CUSTOM' && (common.rtl_pass === '' || undefined === common.rtl_pass)) { errMsg = errMsg + '\nCustom Node Authentication can be set with RTL password only. Please set RTL Password through environment or RTL.conf'; } if (undefined !== process.env.ENABLE_LOGGING) { common.nodes[0].enable_logging = process.env.ENABLE_LOGGING; } else if (undefined !== config.Settings.enableLogging) { common.nodes[0].enable_logging = config.Settings.enableLogging; } else if (undefined !== config.Authentication.enableLogging) { common.nodes[0].enable_logging = config.Authentication.enableLogging; } if (common.nodes[0].enable_logging) { common.nodes[0].log_file = common.rtl_conf_file_path + '/logs/RTL.log'; let exists = fs.existsSync(common.nodes[0].log_file); if (exists) { fs.writeFile(common.nodes[0].log_file, '', () => { }); } else { try { var dirname = path.dirname(common.nodes[0].log_file); connect.createDirectory(dirname); var createStream = fs.createWriteStream(common.nodes[0].log_file); createStream.end(); } catch (err) { console.error('Something went wrong while creating log file: \n' + err); } } } if (undefined !== process.env.PORT) { common.port = connect.normalizePort(process.env.PORT); } else if (undefined !== config.Settings.port) { common.port = connect.normalizePort(config.Settings.port); } connect.setSSOParams(config); if (errMsg !== '') { throw new Error(errMsg); } } connect.validateMultiNodeConfig = (config) => { common.node_auth_type = 'CUSTOM'; if (config.multiPassHashed !== '' && undefined !== config.multiPassHashed) { common.rtl_pass = config.multiPassHashed; } else if (config.multiPass !== '' && undefined !== config.multiPass) { common.rtl_pass = connect.convertCustomToHash('MULTI'); } else { errMsg = errMsg + '\nMulti Node Authentication can be set with multiPass only. Please set MultiPass in RTL-Multi-Node-Conf.json'; } common.port = (undefined !== config.port) ? connect.normalizePort(config.port) : 3000; config.nodes.forEach((node, idx) => { common.nodes[idx] = {}; if(node.Authentication.macaroonPath === '' || undefined === node.Authentication.macaroonPath) { errMsg = 'Please set macaroon path for node index ' + node.index + ' in RTL-Multi-Node-Conf.json!'; } else { common.nodes[idx].macaroon_path = node.Authentication.macaroonPath; } if((node.Settings.lndServerUrl === '' || undefined === node.Settings.lndServerUrl)) { errMsg = errMsg + '\nPlease set LND server URL for node index ' + node.index + ' in RTL-Multi-Node-Conf.json!'; } else { common.nodes[idx].lnd_server_url = node.Settings.lndServerUrl; } common.nodes[idx].index = node.index; common.nodes[idx].ln_node = node.lnNode; common.nodes[idx].ln_implementation = node.lnImplementation; common.nodes[idx].lnd_config_path = (undefined !== node.Authentication.lndConfigPath) ? node.Authentication.lndConfigPath : ''; common.nodes[idx].bitcoind_config_path = (undefined !== node.Settings.bitcoindConfigPath) ? node.Settings.bitcoindConfigPath : ''; common.nodes[idx].enable_logging = (undefined !== node.Settings.enableLogging) ? node.Settings.enableLogging : false; if (common.nodes[idx].enable_logging) { common.nodes[idx].log_file = common.rtl_conf_file_path + '/logs/RTL-Node-' + node.index + '.log'; const log_file = common.nodes[idx].log_file; if (fs.existsSync(log_file)) { fs.writeFile(log_file, '', () => { }); } else { try { var dirname = path.dirname(log_file); connect.createDirectory(dirname); var createStream = fs.createWriteStream(log_file); createStream.end(); } catch (err) { console.error('Something went wrong while creating log file ' + log_file + ': \n' + err); } } } }); connect.setSSOParams(config); if (errMsg !== '') { throw new Error(errMsg); } } connect.setSSOParams = (config) => { if (undefined !== process.env.RTL_SSO) { common.rtl_sso = process.env.RTL_SSO; } else if (undefined !== config.SSO && undefined !== config.SSO.rtlSSO) { common.rtl_sso = config.SSO.rtlSSO; } if (+common.rtl_sso) { if (undefined !== process.env.LOGOUT_REDIRECT_LINK) { common.logout_redirect_link = process.env.LOGOUT_REDIRECT_LINK; } else if (undefined !== config.SSO && undefined !== config.SSO.logoutRedirectLink) { common.logout_redirect_link = config.SSO.logoutRedirectLink; } if (undefined !== process.env.RTL_COOKIE_PATH) { common.rtl_cookie_path = process.env.RTL_COOKIE_PATH; } else if (undefined !== config.SSO && undefined !== config.SSO.rtlCookiePath) { common.rtl_cookie_path = config.SSO.rtlCookiePath; } else { common.rtl_cookie_path = common.rtl_conf_file_path + '/cookies/auth.cookie'; } connect.readCookie(common.rtl_cookie_path); } }; connect.createDirectory = (dirname) => { try { fs.mkdirSync(dirname); } catch (err) { if (err.code === 'EEXIST') { return dirname; } if (err.code === 'ENOENT') { throw new Error(`EACCES: permission denied, mkdir '${dirname}'`); } } } connect.readCookie = (cookieFile) => { let exists = fs.existsSync(cookieFile); if (exists) { common.cookie = fs.readFileSync(cookieFile, 'utf-8'); } else { try { var dirname = path.dirname(cookieFile); connect.createDirectory(dirname); fs.writeFileSync(cookieFile, crypto.randomBytes(64).toString('hex')); common.cookie = fs.readFileSync(cookieFile, 'utf-8'); } catch(err) { console.error('Something went wrong while reading cookie: \n' + err); throw new Error(err); } } } connect.refreshCookie = (cookieFile) => { try { fs.writeFileSync(cookieFile, crypto.randomBytes(64).toString('hex')); common.cookie = fs.readFileSync(cookieFile, 'utf-8'); } catch(err) { console.error('Something went wrong while refreshing cookie: \n' + err); throw new Error(err); } } connect.logEnvVariables = () => { if (common.multi_node_setup) { common.nodes.forEach((node, idx) => { if (!node.enable_logging) { return; } logger.info('\r\nConfig Setup Variable NODE_SETUP: MULTI', node); logger.info('\r\nConfig Setup Variable RTL_SSO: ' + common.rtl_sso, node); logger.info('\r\nConfig Setup Variable RTL_COOKIE_PATH: ' + common.rtl_cookie_path, node); logger.info('\r\nConfig Setup Variable LOGOUT_REDIRECT_LINK: ' + common.logout_redirect_link + '\r\n', node); logger.info('\r\nConfig Setup Variable INDEX: ' + node.index, node); logger.info('\r\nConfig Setup Variable LN NODE: ' + node.ln_node, node); logger.info('\r\nConfig Setup Variable LN IMPLEMENTATION: ' + node.ln_implementation, node); logger.info('\r\nConfig Setup Variable PORT: ' + common.port, node); logger.info('\r\nConfig Setup Variable MACAROON_PATH: ' + node.macaroon_path, node); logger.info('\r\nConfig Setup Variable LND_SERVER_URL: ' + node.lnd_server_url, node); logger.info('\r\nConfig Setup Variable RTL_CONFIG_PATH: ' + node.rtl_conf_file_path, node); logger.info('\r\nConfig Setup Variable LND_CONFIG_PATH: ' + node.lnd_config_path, node); logger.info('\r\nConfig Setup Variable BITCOIND_CONFIG_PATH: ' + node.bitcoind_config_path, node); }); } else { if (!common.nodes[0].enable_logging) { return; } logger.info('\r\nConfig Setup Variable NODE_SETUP: SINGLE'); logger.info('\r\nConfig Setup Variable PORT: ' + common.port); logger.info('\r\nConfig Setup Variable LND_SERVER_URL: ' + common.nodes[0].lnd_server_url); logger.info('\r\nConfig Setup Variable MACAROON_PATH: ' + common.nodes[0].macaroon_path); logger.info('\r\nConfig Setup Variable NODE_AUTH_TYPE: ' + common.node_auth_type); logger.info('\r\nConfig Setup Variable LND_CONFIG_PATH: ' + common.nodes[0].lnd_config_path); logger.info('\r\nConfig Setup Variable RTL_CONFIG_PATH: ' + common.rtl_conf_file_path); logger.info('\r\nConfig Setup Variable BITCOIND_CONFIG_PATH: ' + common.nodes[0].bitcoind_config_path); logger.info('\r\nConfig Setup Variable RTL_SSO: ' + common.rtl_sso); logger.info('\r\nConfig Setup Variable RTL_COOKIE_PATH: ' + common.rtl_cookie_path); logger.info('\r\nConfig Setup Variable LOGOUT_REDIRECT_LINK: ' + common.logout_redirect_link); } } connect.setSingleNodeConfiguration = (singleNodeFilePath) => { const exists = fs.existsSync(singleNodeFilePath); if (exists) { var config = ini.parse(fs.readFileSync(singleNodeFilePath, 'utf-8')); connect.setMacaroonPath(clArgs, config); connect.validateSingleNodeConfig(config); connect.logEnvVariables(); } else { try { fs.writeFileSync(singleNodeFilePath, ini.stringify(connect.setDefaultConfig())); var config = ini.parse(fs.readFileSync(singleNodeFilePath, 'utf-8')); connect.setMacaroonPath(clArgs, config); connect.validateSingleNodeConfig(config); connect.logEnvVariables(); } catch(err) { console.error('Something went wrong while configuring the single node server: \n' + err); throw new Error(err); } } } connect.setMultiNodeConfiguration = (multiNodeFilePath) => { try { var config = JSON.parse(fs.readFileSync(multiNodeFilePath, 'utf-8')); connect.validateMultiNodeConfig(config); connect.logEnvVariables(); } catch(err) { console.error('Something went wrong while configuring the multi node server: \n' + err); throw new Error(err); } } connect.setServerConfiguration = () => { common.rtl_conf_file_path = (undefined !== process.env.RTL_CONFIG_PATH) ? process.env.RTL_CONFIG_PATH.substring(0, process.env.RTL_CONFIG_PATH.length - 9) : path.normalize(__dirname); singleNodeConfFile = common.rtl_conf_file_path + '/RTL.conf'; multiNodeConfFile = common.rtl_conf_file_path + '/RTL-Multi-Node-Conf.json'; const singleNodeExists = fs.existsSync(singleNodeConfFile); const multiNodeExists = fs.existsSync(multiNodeConfFile); if ((!multiNodeExists && singleNodeExists) || (!multiNodeExists && !singleNodeExists)) { common.multi_node_setup = false; connect.setSingleNodeConfiguration(singleNodeConfFile); common.selectedNode = common.findNode(common.nodes[0].index); } else if ((multiNodeExists && singleNodeExists) || (multiNodeExists && !singleNodeExists)) { common.multi_node_setup = true; connect.setMultiNodeConfiguration(multiNodeConfFile); common.selectedNode = common.findNode(common.nodes[0].index); } } module.exports = connect;