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

prevent duplicate entries for push infos

Browse Source
This commit is contained in:
Athou
2013-05-22 11:25:29 +02:00
parent cafcfc4c9f
commit eff84c69af
2 changed files with 45 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
src/main/java/com/commafeed/backend/feeds/FeedRefreshWorker.java
View File

@@ -16,6 +16,7 @@ import com.commafeed.backend.model.Feed;
import com.commafeed.backend.model.FeedEntry;
import com.commafeed.backend.model.FeedPushInfo;
import com.commafeed.backend.services.ApplicationSettingsService;
import com.commafeed.backend.services.FeedPushInfoService;
import com.sun.syndication.io.FeedException;
public class FeedRefreshWorker {
@@ -35,6 +36,9 @@ public class FeedRefreshWorker {
@Inject
ApplicationSettingsService applicationSettingsService;
@Inject
FeedPushInfoService feedPushInfoService;
public void start(MutableBoolean running, String threadName) {
log.info("{} starting", threadName);
@@ -132,7 +136,7 @@ public class FeedRefreshWorker {
log.debug("feed {} has pubsub info: {}", feed.getUrl(), topic);
FeedPushInfo info = feed.getPushInfo();
if (info == null) {
info = new FeedPushInfo();
info = feedPushInfoService.findOrCreate(feed, hub, topic);
}
if (!StringUtils.equals(hub, info.getHub())
|| !StringUtils.equals(topic, info.getTopic())) {

40
src/main/java/com/commafeed/backend/services/FeedPushInfoService.java Normal file
View File

@@ -0,0 +1,40 @@
package com.commafeed.backend.services;
import java.util.List;
import javax.ejb.Lock;
import javax.ejb.LockType;
import javax.ejb.Singleton;
import javax.inject.Inject;
import com.commafeed.backend.dao.FeedPushInfoDAO;
import com.commafeed.backend.model.Feed;
import com.commafeed.backend.model.FeedPushInfo;
import com.commafeed.backend.model.FeedPushInfo_;
@Singleton
public class FeedPushInfoService {
@Inject
FeedPushInfoDAO feedPushInfoDAO;
@Lock(LockType.WRITE)
public FeedPushInfo findOrCreate(Feed feed, String hub, String topic) {
FeedPushInfo info = null;
List<FeedPushInfo> infos = feedPushInfoDAO.findByField(
FeedPushInfo_.feed, feed);
if (infos.isEmpty()) {
info = new FeedPushInfo();
info.setFeed(feed);
info.setHub(hub);
info.setTopic(topic);
info.setActive(false);
feedPushInfoDAO.save(info);
} else {
info = infos.get(0);
}
return info;
}
}