garrettmills/commafeed
1
0
Fork 0
forked from Archives/Athou_commafeed
Code Pull Requests Activity

allow to force refresh feed anytime (#1036)

Browse Source
This commit is contained in:
Athou
2023-01-16 14:27:58 +01:00
parent 2b4ff4a8a5
commit 347fc4f2c8
1 changed files with 4 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
commafeed-server/src/main/java/com/commafeed/backend/feed/FeedQueues.java
View File

@@ -81,12 +81,9 @@ public class FeedQueues {
* add a feed to the refresh queue * add a feed to the refresh queue
*/ */
public void add(Feed feed, boolean urgent) { public void add(Feed feed, boolean urgent) {
int refreshInterval = config.getApplicationSettings().getRefreshIntervalMinutes(); boolean alreadyQueued = addQueue.stream().anyMatch(c -> c.getFeed().getId().equals(feed.getId()));
if (feed.getLastUpdated() == null || feed.getLastUpdated().before(DateUtils.addMinutes(new Date(), -1 * refreshInterval))) { if (!alreadyQueued) {
boolean alreadyQueued = addQueue.stream().anyMatch(c -> c.getFeed().getId().equals(feed.getId())); addQueue.add(new FeedRefreshContext(feed, urgent));
if (!alreadyQueued) {
addQueue.add(new FeedRefreshContext(feed, urgent));
}
} }
} }
@@ -134,7 +131,7 @@ public class FeedQueues {
} }
// update all feeds in the database // update all feeds in the database
List<Feed> feeds = map.values().stream().map(c -> c.getFeed()).collect(Collectors.toList()); List<Feed> feeds = map.values().stream().map(FeedRefreshContext::getFeed).collect(Collectors.toList());
UnitOfWork.run(sessionFactory, () -> feedDAO.saveOrUpdate(feeds)); UnitOfWork.run(sessionFactory, () -> feedDAO.saveOrUpdate(feeds));
} }