const config = require('../config/default.json') const uconfig = require('../config/usersettings.json') const { parentPort, workerData } = require('worker_threads'); const { provfeed, n, nick } = workerData; 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 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+']' async function sendUpstream(content) { var output = content.join("\n") parentPort.postMessage(output); 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 ("+extra+")" } else if (error.code == "ERR_UNESCAPED_CHARACTERS"){ var error = errorMsg+" Unescaped Characters" } 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 fetchFeed(feedURL, n, nick) { var content = []; try { var feedsArr = uconfig[nick].feeds } catch (e) { errorMessage(e, "NOFEEDS", nick); } if ( n < feedsArr.length ) { var n = 1 content.push(warningMsg+" You must choose a number larger than your amount of feeds. Reverting to 1 per feed"); } else { var n = n/feedsArr.length } for (let i = 0; i < feedsArr.length; i++) { try { var newFeed = await parser.parseURL(feedsArr[i]); } catch (e) { if (e.code !== undefined) { errorMessage(e, feedsArr[i]) } else { errorMessage(e, "404", feedsArr[i]); } } if (n > newFeed.items.length) { var n = newFeed.items.length; content.push(warningMsg+" Your requested post amount exceeded the total available. Reverting to " + newFeed.items.length); } //} else if (n < 1) { // var n = 1 // content.push(warningMsg+" You requested a number less than 1. Reverting to default ("+config.feed.default_amount+")"); //} for (let i = 0; i < n; i++) { var data = newFeed.items[i] var title = data.title.replace(/(\r\n|\n|\r)/gm, " ") //remove line breaks .replace(/\s{2,}/g, ' ') //idk var title = striptags(title); var body = data.contentSnippet.replace(/(\r\n|\n|\r)/gm, " ") //remove line breaks .replace(/\s{2,}/g, ' ') //idk var body = striptags(body); if (data.isoDate !== undefined) { var date = moment(data.isoDate) var syncDate = date.tz(config.feed.timezone) console.log(syncDate.format()) var date = syncDate.format(config.feed.time_format) } else { var date = data.pubDate } if (body.length >= config.feed.body_max_chars) { var truncatedString = body.substring(0,config.feed.body_max_chars); var body = truncatedString + "..." } date = ''+config.colours.brackets+'['+config.colours.date+date+''+config.colours.brackets+'] ' title = ''+config.colours.title+title+' ' author = ''+config.colours.author+data.creator+' ' body = ''+config.colours.body+body+' ' link = ''+config.colours.link+data.link+' ' //console.log(data); //var string = "15[11" + date + "15] 08" + title + " " + body + " " + data.link; var string = date+title+body+link; content.push(string) console.log(content) } //sendUpstream(content); } sendUpstream(content); } //var file = editJsonFile('/home/node/app/config/usersettings.json'); //async function getAllFeeds(nick, n) { // console.log(nick) // var feedsArr = uconfig[nick].feeds // console.log(feedsArr) // var num = n/feedsArr.length // for (let i = 0; i < feedsArr.length; i++) { // fetchFeed(feedsArr[i], num); // } // await sendUpstream(content); //} //getAllFeeds(nick, n) fetchFeed(provfeed, n, provfeed);