|
@@ -24,6 +24,7 @@ const REACT_PROBABILITY = 0.6;
|
|
async function checkFeeds() {
|
|
async function checkFeeds() {
|
|
let feeds = db.get("rssFeeds").value();
|
|
let feeds = db.get("rssFeeds").value();
|
|
let outlets = db.get("feedOutputs").value();
|
|
let outlets = db.get("feedOutputs").value();
|
|
|
|
+ let oldNews = db.get("postedNewsGuids");
|
|
for(let feedEntry of feeds) {
|
|
for(let feedEntry of feeds) {
|
|
let feed = await parser.parseURL(feedEntry.url);
|
|
let feed = await parser.parseURL(feedEntry.url);
|
|
if(feed.items.length == 0)
|
|
if(feed.items.length == 0)
|
|
@@ -31,9 +32,12 @@ async function checkFeeds() {
|
|
let printableItems = feed.items.filter(i => i.isoDate > feedEntry.lastUpdate).sort((a, b) => a.isoDate.localeCompare(b.isoDate));
|
|
let printableItems = feed.items.filter(i => i.isoDate > feedEntry.lastUpdate).sort((a, b) => a.isoDate.localeCompare(b.isoDate));
|
|
if(printableItems.length > 0) {
|
|
if(printableItems.length > 0) {
|
|
printableItems.forEach(item => {
|
|
printableItems.forEach(item => {
|
|
|
|
+ if(oldNews.has(item.guid).value())
|
|
|
|
+ return;
|
|
outlets.forEach(ch => {
|
|
outlets.forEach(ch => {
|
|
client.channels.get(ch).send(`**${item.title}**\nPosted by ${item.creator}\n${item.link}\n\n${turndown.turndown(item[feedEntry.contentElement]).replace(/( {2}\n|\n\n){2,}/gm, "\n").replace(item.link, "")}`);
|
|
client.channels.get(ch).send(`**${item.title}**\nPosted by ${item.creator}\n${item.link}\n\n${turndown.turndown(item[feedEntry.contentElement]).replace(/( {2}\n|\n\n){2,}/gm, "\n").replace(item.link, "")}`);
|
|
});
|
|
});
|
|
|
|
+ oldNews.set(item.guid, true).write();
|
|
});
|
|
});
|
|
let lastUpdateDate = printableItems[printableItems.length - 1].isoDate;
|
|
let lastUpdateDate = printableItems[printableItems.length - 1].isoDate;
|
|
console.log(`Setting last update marker on ${feedEntry.url} to ${lastUpdateDate}`);
|
|
console.log(`Setting last update marker on ${feedEntry.url} to ${lastUpdateDate}`);
|