miniflux-legacy/assets/js/src/feed.js

74 lines
2.6 KiB
JavaScript
Raw Normal View History

2013-10-15 04:38:07 +02:00
Miniflux.Feed = (function() {
// List of feeds currently updating
var queue = [];
// Number of concurrent requests when updating all feeds
var queue_length = 5;
var updateInterval = null;
2013-10-15 04:38:07 +02:00
return {
Update: function(feed, callback) {
var itemsCounter = feed.querySelector("span.items-count");
if (! itemsCounter) return;
2016-07-31 00:21:01 +02:00
var feed_id = feed.getAttribute("data-feed-id");
var heading = feed.querySelector("h2:first-of-type");
heading.className = "loading-icon";
2013-10-15 04:38:07 +02:00
var request = new XMLHttpRequest();
request.onload = function() {
heading.className = "";
feed.removeAttribute("data-feed-error");
var lastChecked = feed.querySelector(".feed-last-checked");
if (lastChecked) lastChecked.innerHTML = lastChecked.getAttribute("data-after-update");
var response = JSON.parse(this.responseText);
if (response.result) {
itemsCounter.innerHTML = response.items_count.items_unread + "/" + response.items_count.items_total;
} else {
feed.setAttribute("data-feed-error", "1");
}
if (callback) {
callback(response);
}
else {
Miniflux.Item.CheckForUpdates();
}
2013-10-15 04:38:07 +02:00
};
request.open("POST", "?action=refresh-feed&feed_id=" + feed_id, true);
request.send();
},
2015-08-02 18:59:14 +02:00
UpdateAll: function(nb_concurrent_requests) {
var feeds = Array.prototype.slice.call(document.querySelectorAll("article:not([data-feed-disabled])"));
2013-10-15 04:38:07 +02:00
2015-08-02 18:59:14 +02:00
// Check if a custom amount of concurrent requests was defined
if (nb_concurrent_requests) {
queue_length = nb_concurrent_requests;
}
updateInterval = setInterval(function() {
2013-10-15 04:38:07 +02:00
while (feeds.length > 0 && queue.length < queue_length) {
var feed = feeds.shift();
queue.push(parseInt(feed.getAttribute('data-feed-id'), 10));
Miniflux.Feed.Update(feed, Miniflux.Feed.OnFeedUpdated);
2013-10-15 04:38:07 +02:00
}
}, 100);
},
OnFeedUpdated: function(response) {
var index = queue.indexOf(response.feed_id);
if (index >= 0) queue.splice(index, 1);
if (feeds.length === 0 && queue.length === 0) {
clearInterval(updateInterval);
Miniflux.Item.CheckForUpdates();
}
2013-10-15 04:38:07 +02:00
}
};
2016-07-31 00:21:01 +02:00
})();