mercury/commands/feed-list.js

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);