72 lines
2.1 KiB
JavaScript
72 lines
2.1 KiB
JavaScript
|
const config = require('../config/default.json')
|
|||
|
const { parentPort, workerData } = require('worker_threads');
|
|||
|
const { user, setting, setting2, value } = workerData;
|
|||
|
const fs = require('fs-extra')
|
|||
|
let Parser = require('rss-parser');
|
|||
|
let parser = new Parser({
|
|||
|
headers: {'User-Agent': config.feed.useragent},
|
|||
|
});
|
|||
|
const striptags = require("striptags");
|
|||
|
const moment = require('moment');
|
|||
|
const tz = require('moment-timezone');
|
|||
|
const editJsonFile = require("edit-json-file");
|
|||
|
const timer = ms => new Promise(res => setTimeout(res, ms))
|
|||
|
|
|||
|
warningMsg = '['+config.colours.warning+'WARNING]'
|
|||
|
errorMsg = '['+config.colours.error+'ERROR]'
|
|||
|
|
|||
|
async function sendUpstream(content) {
|
|||
|
//var output = content.join("\n")
|
|||
|
parentPort.postMessage(content);
|
|||
|
process.exit()
|
|||
|
}
|
|||
|
|
|||
|
function errorMessage(error, code, extra) {
|
|||
|
console.log(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 {
|
|||
|
var error = errorMsg+" Unknown error"
|
|||
|
}
|
|||
|
parentPort.postMessage(error);
|
|||
|
process.exit()
|
|||
|
}
|
|||
|
|
|||
|
async function testFeed(feedURL) {
|
|||
|
try {
|
|||
|
var feed = await parser.parseURL(feedURL);
|
|||
|
} catch (e) {
|
|||
|
errorMessage(e, "INVALID", feedURL);
|
|||
|
}
|
|||
|
console.log(feed)
|
|||
|
console.log("Feed is good, saving")
|
|||
|
}
|
|||
|
|
|||
|
async function feed(nick, setting, value) {
|
|||
|
if (setting === 'add') {
|
|||
|
await testFeed(value);
|
|||
|
var file = editJsonFile('/home/node/app/config/usersettings.json');
|
|||
|
file.append(nick+".feeds", value);
|
|||
|
file.save();
|
|||
|
sendUpstream(value + ' added to your feed list')
|
|||
|
//file.custom.feed.nick = value;
|
|||
|
//fs.writeFile(file, JSON.stringify({ feed: value }))
|
|||
|
|
|||
|
}
|
|||
|
}
|
|||
|
|
|||
|
|
|||
|
//fs.readFile('../config/feeds.json').catch(() =>
|
|||
|
// fs.writeFile('../config/feeds.json', '')
|
|||
|
//);
|
|||
|
|
|||
|
if (setting === 'feed') {
|
|||
|
feed(user, setting2, value);
|
|||
|
}
|