Archives/Athou_commafeed
1
0
Fork 1
mirror of https://github.com/Athou/commafeed.git synced 2026-03-21 21:37:29 +00:00
Code Issues Packages Projects Releases Wiki Activity

filter out old entries

Browse Source
This commit is contained in:
Athou
2013-05-30 13:51:18 +02:00
parent a79cfeef16
commit 2ba1614f1d
1 changed files with 21 additions and 17 deletions
Download Patch File Download Diff File Expand all files Collapse all files

38
src/main/java/com/commafeed/backend/feeds/FeedRefreshUpdater.java
View File

@@ -14,7 +14,6 @@ import javax.annotation.PreDestroy;
import javax.inject.Inject;
import javax.inject.Singleton;
import org.apache.commons.collections.CollectionUtils;
import org.apache.commons.lang.StringUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@@ -119,7 +118,8 @@ public class FeedRefreshUpdater {
@Override
public void run() {
boolean ok = true;
if (CollectionUtils.isNotEmpty(entries) && hasWork()) {
filterOldEntries();
if (entries.isEmpty() == false) {
List<FeedSubscription> subscriptions = feedSubscriptionDAO
.findByFeed(feed);
for (FeedEntry entry : entries) {
@@ -137,26 +137,30 @@ public class FeedRefreshUpdater {
taskGiver.giveBack(feed);
}
private boolean hasWork() {
boolean hasWork = false;
private void filterOldEntries() {
List<FeedEntry> keep = Lists.newArrayList();
List<String> guids = Lists.newArrayList();
for (FeedEntry entry : entries) {
guids.add(entry.getGuid());
}
if (entries != null) {
List<String> guids = Lists.newArrayList();
for (FeedEntry entry : entries) {
guids.add(entry.getGuid());
}
List<FeedEntry> existingEntries = feedEntryDAO.findByGuids(guids);
for (FeedEntry entry : entries) {
FeedEntry foundEntry = FeedUtils.findEntry(existingEntries,
entry);
if (foundEntry == null
|| FeedUtils.findFeed(foundEntry.getFeeds(), feed) == null) {
hasWork = true;
break;
List<FeedEntry> existingEntries = feedEntryDAO
.findByGuids(guids);
for (FeedEntry entry : entries) {
FeedEntry found = FeedUtils.findEntry(existingEntries,
entry);
if (found == null
|| FeedUtils.findFeed(found.getFeeds(), feed) == null) {
keep.add(entry);
}
}
}
return hasWork;
entries = keep;
}
}
private boolean updateEntry(final Feed feed, final FeedEntry entry,