node-red-nodes/social/feedparser/32-feedparse.js

module.exports = function(RED) {
    "use strict";
    const { parseFeed } = require('@rowanmanning/feed-parser');

    function FeedParseNode(n) {
        RED.nodes.createNode(this,n);
        this.url = n.url;
        if (n.interval > 35790) { this.warn(RED._("feedparse.errors.invalidinterval")) }
        this.interval = (parseInt(n.interval)||15) * 60000;
        this.interval_id = null;
        this.ignorefirst = n.ignorefirst || false;
        this.sendarray = n.sendarray || false;
        this.seen = {};
        this.donefirst = false;
        var node = this;

        async function getFeed() {
            const response = await fetch(node.url);
            if (response.status !== 200) {
                node.error("Bad Feed: "+node.url, err)
                node.status({fill:"red",shape:"dot",text:response.status+": "+RED._("feedparse.errors.badstatuscode")});
                return;
            }
            const feed = parseFeed(await response.text());
            if (node.sendarray === true) {
                var msg = JSON.parse(JSON.stringify(feed));
                node.send(msg);
            }
            else {
                for (let a=0; a<feed.items.length; a++) {
                    const article = feed.items[a];
                    if (!(article.id in node.seen) || ( node.seen[article.id] !== 0 && node.seen[article.id] != new Date(article.published).getTime())) {
                        node.seen[article.id] = article.published ? new Date(article.published).getTime() : 0;
                        const msg = { article: JSON.parse(JSON.stringify(article)) };
                        msg.topic = msg.article.title;
                        msg.payload = msg.article.description;
                        msg.link = msg.article.url
                        msg.feed = node.url;

                        if (node.ignorefirst === true && node.donefirst === false) {
                            // do nothing
                        }
                        else {
                            node.send(msg);
                        }
                    }
                }
            }
            node.status({fill:"green",shape:"dot",text:""});
        }

        node.interval_id = setInterval(function() { node.donefirst = true; getFeed(); }, node.interval);
        setTimeout(getFeed, 2000);

        node.on("close", function() {
            if (this.interval_id != null) {
                clearInterval(this.interval_id);
            }
        });
    }

    RED.nodes.registerType("feedparse",FeedParseNode);
}