diff --git a/node_modules/rss-braider/lib/RssBraider.js b/node_modules/rss-braider/lib/RssBraider.js index 6891ad3..d6d8cd4 100644 --- a/node_modules/rss-braider/lib/RssBraider.js +++ b/node_modules/rss-braider/lib/RssBraider.js @@ -12,7 +12,7 @@ var FeedParser = require('feedparser'), var RssBraider = function (options) { this.uniques = {}; this.mdUniques = []; - this.feedCount = 0; + this.feedCount = []; if (!options) { options = {}; } @@ -81,8 +81,8 @@ RssBraider.prototype.processFeed = function(feed_name, format, callback) // Then process each item/article through rss-braider and any plugins async.each(feed.sources, function(source, callback) { console.log('+ async.each'); - self.feedCount++; - console.log('## FEED COUNT: ' + self.feedCount); + self.feedCount.push(source.feed_url); + console.log('## FEED COUNT: ' + self.feedCount.length); var count = source.count || feed.default_count || 10, // Number of articles per source url = source.feed_url || null, file_path = source.file_path || null, @@ -152,10 +152,15 @@ RssBraider.prototype.processFeed = function(feed_name, format, callback) source_articles = self.date_sort(source_articles); source_articles = source_articles.slice(0, count); feed_articles = feed_articles.concat(source_articles); - self.feedCount--; - console.log('~~ FEED COUNT: ' + self.feedCount); + var p = self.feedCount.indexOf(source.feed_url); + if (p > -1) { + self.feedCount.splice(p, 1); + } + console.log('~~ FEED COUNT: ' + self.feedCount.length); + console.log(self.feedCount); callback(); console.log('- end'); + }); console.log('- async.each'); },