145 lines
4.8 KiB
JavaScript
145 lines
4.8 KiB
JavaScript
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) {
|
||
parentPort.postMessage(content);
|
||
consoleLog('[options] All done.')
|
||
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') {
|
||
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, url);
|
||
file.save();
|
||
sendUpstream('Alias added ('+value+' ==> '+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, "");
|
||
file.save();
|
||
sendUpstream('Alias removed ('+value+' ==> 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)
|
||
}
|