const config = require('../config/default.json') const uconfig = require('../config/usersettings.json') const { parentPort, workerData } = require('worker_threads'); const { d1, d2, d3, d4, d5 } = workerData; var user = d1; var setting = d2; var setting2 = d3; var value = d4; var value2 = d5; const fs = require('fs-extra') let Parser = require('rss-parser'); let parser = new Parser({ headers: {'User-Agent': config.feed.useragent}, }); const editJsonFile = require("edit-json-file"); const timer = ms => new Promise(res => setTimeout(res, ms)) warningMsg = ''+config.colours.brackets+'['+config.colours.warning+'WARNING'+config.colours.brackets+']' errorMsg = ''+config.colours.brackets+'['+config.colours.error+'ERROR'+config.colours.brackets+']' function consoleLog(log) { if (config.misc.logging === "true") { console.log(log) } else { return; } } async function sendUpstream(content) { consoleLog('[options] All done.') parentPort.postMessage(content); process.exit() } function errorMessage(error, code, extra) { consoleLog('[options.errorMessage] '+error.code) if (code == "404") { var error = errorMsg+" 404: " + extra + " not found" } else if (error.code == "ECONNREFUSED") { var error = errorMsg+" Connection Refused" } else if (error.code == "ERR_UNESCAPED_CHARACTERS"){ var error = errorMsg+" Unescaped Characters" } else if (code == "INVALID") { var error = errorMsg+' '+extra+' either does not exist or is not a valid feed.' } else if (code == "ALREADYEXISTS" ) { var error = errorMsg+' '+extra+' already exists in your feed list.' } else if (error == "NOFEEDS") { var error = errorMsg+" No saved feeds for "+provfeed } else { var error = errorMsg+" Unknown error" } parentPort.postMessage(error); process.exit() } async function testFeed(feedURL) { try { consoleLog('[options.testFeed] Testing '+feed) var feed = await parser.parseURL(feedURL); } catch (e) { consoleLog('[options.testFeed] '+e) errorMessage(e, "INVALID", feedURL); } consoleLog("[options.testFeed] Feed is valid, continuing") } async function feed(nick, setting, value) { if (setting === 'add') { consoleLog('[options.feed] '+nick+' is adding '+value) await testFeed(value); var file = editJsonFile('/home/node/app/config/usersettings.json'); var feedsArr = uconfig[nick].feeds if (feedsArr.includes(value) == true) { errorMessage("null", "ALREADYEXISTS", value) } else { file.append(nick+".feeds", value); file.save(); sendUpstream(value + ' added to your feed list') } } if (setting === 'list') { content = []; try { var feedsArr = uconfig[nick].feeds consoleLog('[options.feed] Listing existing feeds for '+nick+': '+feedsArr) content.push("These are your added feeds:") } catch (e) { errorMessage(e, "NOFEEDS", nick); } for (let i = 0; i < feedsArr.length; i++) { content.push(i+1+'. '+feedsArr[i]) } var output = content.join("\n") sendUpstream(output) } } async function alias(setting, value, url, nick) { if (setting === 'add') { var value = value.toUpperCase() consoleLog('[options.alias] Adding/editing an alias for'+nick+': '+value+' ==> '+url) await testFeed(url); var file = editJsonFile('/home/node/app/config/usersettings.json'); file.set(nick+'.alias.'+value.toUpperCase(), url); file.save(); sendUpstream('Alias added ('+value.toUpperCase()+' ==> '+url+')') } if (setting === 'del') { consoleLog('[options.alias] Removing an alias for '+nick+': '+value+' ==> \"\"') var file = editJsonFile('/home/node/app/config/usersettings.json'); file.set(nick+'.alias.'+value.toUpperCase(), ""); file.save(); sendUpstream('Alias removed ('+value.toUpperCase()+' ==> BTFO\'d)') } if (setting === 'list') { content = []; var obj = uconfig[nick].alias consoleLog('[options.alias] Listing aliases for '+nick+': '+obj) console.log(obj) for (const [key, val] of Object.entries(obj)) { if (val !== "") { content.push(key + ' ==> '+val) } }; var output = content.join("\n") sendUpstream(output); } } async function get(setting) { consoleLog('[options.get] Getting value of '+setting) var file = editJsonFile('/home/node/app/config/default.json') console.log(file.get(setting)); sendUpstream(file.get(setting)) } if (setting === 'feed') { feed(user, setting2, value); } else if (setting === 'list') { feed(user, setting2) } else if (setting === 'get') { get(setting2); } else if(setting === 'alias') { alias(setting2, value, value2, user) } else { sendUpstream(errorMsg+' '+setting+' is not a valid option') }