Tell Queue fragment to refresh

2 files changed, 9 insertions, 4 deletions

diff --git a/core/src/main/java/de/danoeh/antennapod/core/feed/QueueEvent.java b/core/src/main/java/de/danoeh/antennapod/core/feed/QueueEvent.java
index c8497f509..97d086e5b 100644
--- a/core/src/main/java/de/danoeh/antennapod/core/feed/QueueEvent.java
+++ b/core/src/main/java/de/danoeh/antennapod/core/feed/QueueEvent.java
@@ -8,7 +8,7 @@ import java.util.List;
 public class QueueEvent {
 
     public enum Action {
-        ADDED, ADDED_ITEMS, REMOVED, CLEARED, DELETED_MEDIA, SORTED, MOVED
+        ADDED, ADDED_ITEMS, REMOVED, IRREVERSIBLE_REMOVED, CLEARED, DELETED_MEDIA, SORTED, MOVED
     }
 
     public final Action action;
diff --git a/core/src/main/java/de/danoeh/antennapod/core/storage/DBWriter.java b/core/src/main/java/de/danoeh/antennapod/core/storage/DBWriter.java
index d1f67cd29..acdcf5f85 100644
--- a/core/src/main/java/de/danoeh/antennapod/core/storage/DBWriter.java
+++ b/core/src/main/java/de/danoeh/antennapod/core/storage/DBWriter.java
@@ -13,6 +13,7 @@ import org.shredzone.flattr4j.model.Flattr;
 import java.io.File;
 import java.io.UnsupportedEncodingException;
 import java.net.URLEncoder;
+import java.util.ArrayList;
 import java.util.Collections;
 import java.util.Comparator;
 import java.util.Date;
@@ -184,13 +185,15 @@ public class DBWriter {
                     }
                     // delete stored media files and mark them as read
                     List<FeedItem> queue = DBReader.getQueue(context);
-                    boolean queueWasModified = false;
+                    List<FeedItem> removed = new ArrayList<>();
                     if (feed.getItems() == null) {
                         DBReader.getFeedItemList(context, feed);
                     }
 
                     for (FeedItem item : feed.getItems()) {
-                        queueWasModified |= queue.remove(item);
+                        if(queue.remove(item)) {
+                            removed.add(item);
+                        }
                         if (item.getMedia() != null
                                 && item.getMedia().isDownloaded()) {
                             File mediaFile = new File(item.getMedia()
@@ -213,8 +216,10 @@ public class DBWriter {
                     }
                     PodDBAdapter adapter = new PodDBAdapter(context);
                     adapter.open();
-                    if (queueWasModified) {
+                    if (removed.size() > 0) {
                         adapter.setQueue(queue);
+                        EventBus.getDefault().post(new QueueEvent(QueueEvent.Action.IRREVERSIBLE_REMOVED,
+                                removed));
                     }
                     adapter.removeFeed(feed);
                     adapter.close();