telebot/telebot-rssfeed
2
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

fixing order

Browse Source
This commit is contained in:
Cedric Hoelzl 2020-07-03 11:19:19 +02:00
parent 0411a48371
commit cfb9d7fd35
1 changed files with 15 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

28
config.js
View File

@ -13,9 +13,11 @@ var db = new db_js("rss_chan");
//=== TOOL FUNCTIONS
const get_rss = function(url,min_id){
return parser.parseURL(url).then(feed=>feed.items
.sort((a, b)=>(parseInt(a.guid)-parseInt(b.guid)))
.filter((v)=>(parseInt(v.guid)>min_id)));
return parser.parseURL(url).then(feed=>{
let idx = feed.findIndex(i => i.prop_1 === min_id);
if(idx>=0) return feed.items.slice(0,idx);
else return feed.items;
});
}
const article_to_mess = function(art){
@ -58,11 +60,11 @@ module.exports = function(rssi){
return Promise.all(this.rssi.map(entry=>
db.get_v(entry.chat).then(v=>
get_rss(entry.url,v).then(articles=>
articles.forEach(art=>
db.set_v(entry.chat,parseInt(art.guid)).then(rr=>
this.bot.telegram.sendMessage(entry.chat,article_to_mess(art),{"parse_mode":"Markdown"})
)
)
Promise.all(articles.map(art=>
this.bot.telegram.sendMessage(entry.chat,article_to_mess(art),{"parse_mode":"Markdown"})
)).then(rr=>
db.set_v(entry.chat,parseInt(articles.pop().guid))
)
)
)
)).then(r=>event.reply("Refreshed all Feeds"));
@ -93,11 +95,11 @@ module.exports = function(rssi){
return Promise.all(this.rssi.map(entry=>
db.get_v(entry.chat).then(v=>
get_rss(entry.url,v).then(articles=>
articles.forEach(art=>
db.set_v(entry.chat,parseInt(art.guid)).then(rr=>
this.bot.telegram.sendMessage(entry.chat,article_to_mess(art),{"parse_mode":"Markdown"})
)
)
Promise.all(articles.map(art=>
this.bot.telegram.sendMessage(entry.chat,article_to_mess(art),{"parse_mode":"Markdown"})
)).then(rr=>
db.set_v(entry.chat,parseInt(articles.pop().guid))
)
)
)
));