#2448: make podcast episode enqueue position respect download start order

1 files changed, 134 insertions, 8 deletions

diff --git a/core/src/test/java/de/danoeh/antennapod/core/storage/DBWriterTest.java b/core/src/test/java/de/danoeh/antennapod/core/storage/DBWriterTest.java
index 6d4dc98fd..7753f55dc 100644
--- a/core/src/test/java/de/danoeh/antennapod/core/storage/DBWriterTest.java
+++ b/core/src/test/java/de/danoeh/antennapod/core/storage/DBWriterTest.java
@@ -1,16 +1,22 @@
 package de.danoeh.antennapod.core.storage;
 
+import android.support.annotation.NonNull;
+
 import org.junit.Test;
 import org.junit.runner.RunWith;
 import org.junit.runners.Parameterized;
 import org.junit.runners.Parameterized.Parameter;
 import org.junit.runners.Parameterized.Parameters;
 
+import java.util.ArrayList;
 import java.util.Arrays;
 import java.util.Collections;
 import java.util.Date;
+import java.util.HashMap;
 import java.util.List;
+import java.util.Map;
 
+import de.danoeh.antennapod.core.feed.FeedFile;
 import de.danoeh.antennapod.core.feed.FeedItem;
 import de.danoeh.antennapod.core.feed.FeedMedia;
 import de.danoeh.antennapod.core.feed.FeedMother;
@@ -30,15 +36,15 @@ public class DBWriterTest {
                 Options optDefault = new Options();
                 Options optEnqAtFront = new Options().setEnqueueAtFront(true);
 
-                return Arrays.asList(new Object[][] {
+                return Arrays.asList(new Object[][]{
                         {"case default, i.e., add to the end",
-                                QUEUE_DEFAULT.size(), optDefault , 0, QUEUE_DEFAULT},
+                                QUEUE_DEFAULT.size(), optDefault, 0, QUEUE_DEFAULT},
                         {"case default (2nd item)",
-                                QUEUE_DEFAULT.size(), optDefault , 1, QUEUE_DEFAULT},
+                                QUEUE_DEFAULT.size(), optDefault, 1, QUEUE_DEFAULT},
                         {"case option enqueue at front",
-                                0, optEnqAtFront , 0, QUEUE_DEFAULT},
+                                0, optEnqAtFront, 0, QUEUE_DEFAULT},
                         {"case option enqueue at front (2nd item)",
-                                1, optEnqAtFront , 1, QUEUE_DEFAULT},
+                                1, optEnqAtFront, 1, QUEUE_DEFAULT},
                         {"case empty queue, option default",
                                 0, optDefault, 0, QUEUE_EMPTY},
                         {"case empty queue, option enqueue at front",
@@ -72,7 +78,7 @@ public class DBWriterTest {
                 ItemEnqueuePositionCalculator calculator = new ItemEnqueuePositionCalculator(options);
 
                 int posActual = calculator.calcPosition(posAmongAdded, tFI(TFI_TO_ADD_ID), curQueue);
-                assertEquals(message, posExpected , posActual);
+                assertEquals(message, posExpected, posActual);
             }
 
         }
@@ -109,6 +115,126 @@ public class DBWriterTest {
 
         }
 
+        @RunWith(Parameterized.class)
+        public static class ItemEnqueuePositionCalculatorPreserveDownloadOrderTest {
+
+            @Parameters(name = "{index}: case<{0}>, expected:{1}")
+            public static Iterable<Object[]> data() {
+                Options optDefault = new Options();
+                Options optEnqAtFront = new Options().setEnqueueAtFront(true);
+
+                return Arrays.asList(new Object[][] {
+                        {"download order test, enqueue default",
+                                QUEUE_DEFAULT.size(), QUEUE_DEFAULT.size() + 1,
+                                QUEUE_DEFAULT.size() + 2, QUEUE_DEFAULT.size() + 3,
+                                optDefault, QUEUE_DEFAULT},
+                        {"download order test, enqueue at front",
+                                0, 1,
+                                2, 3,
+                                optEnqAtFront, QUEUE_DEFAULT},
+                });
+            }
+
+            @Parameter
+            public String message;
+
+            @Parameter(1)
+            public int pos101Expected;
+
+            @Parameter(2)
+            public int pos102Expected;
+
+            // 2XX are for testing bulk insertion cases
+            @Parameter(3)
+            public int pos201Expected;
+
+            @Parameter(4)
+            public int pos202Expected;
+
+            @Parameter(5)
+            public Options options;
+
+            @Parameter(6)
+            public List<FeedItem> queueInitial;
+
+            @Test
+            public void testQueueOrderWhenDownloading2Items() {
+
+                // Setup class under test
+                //
+                ItemEnqueuePositionCalculator calculator = new ItemEnqueuePositionCalculator(options);
+                MockDownloadRequester mockDownloadRequester = new MockDownloadRequester();
+                calculator.requester = mockDownloadRequester;
+
+                // Setup initial data
+                // A shallow copy, as the test code will manipulate the queue
+                List<FeedItem> queue = new ArrayList<>(queueInitial);
+
+
+                // Test body
+
+                // User clicks download on feed item 101
+                FeedItem tFI101 = tFI_isDownloading(101, mockDownloadRequester);
+
+                int pos101Actual = calculator.calcPosition(0, tFI101, queue);
+                queue.add(pos101Actual, tFI101);
+                assertEquals(message + " (1st download)",
+                        pos101Expected, pos101Actual);
+
+                // Then user clicks download on feed item 102
+                FeedItem tFI102 = tFI_isDownloading(102, mockDownloadRequester);
+                int pos102Actual = calculator.calcPosition(0, tFI102, queue);
+                queue.add(pos102Actual, tFI102);
+                assertEquals(message + " (2nd download, it should preserve order of download)",
+                        pos102Expected, pos102Actual);
+
+                // Items 201 and 202 are added as part of a single DBWriter.addQueueItem() calls
+
+                FeedItem tFI201 = tFI_isDownloading(201, mockDownloadRequester);
+                int pos201Actual = calculator.calcPosition(0, tFI201, queue);
+                queue.add(pos201Actual, tFI201);
+                assertEquals(message + " (bulk insertion, 1st item)", pos201Expected, pos201Actual);
+
+                FeedItem tFI202 = tFI_isDownloading(202, mockDownloadRequester);
+                int pos202Actual = calculator.calcPosition(1, tFI202, queue);
+                queue.add(pos202Actual, tFI202);
+                assertEquals(message + " (bulk insertion, 2nd item)", pos202Expected, pos202Actual);
+
+                // TODO: simulate download failure cases.
+            }
+
+
+            private static FeedItem tFI_isDownloading(int id, MockDownloadRequester requester) {
+                FeedItem item = tFI(id);
+                FeedMedia media =
+                        new FeedMedia(item, "http://download.url.net/" + id
+                                , 100000 + id, "audio/mp3");
+                media.setId(item.getId());
+                item.setMedia(media);
+
+                requester.mockDownloadingFile(media, true);
+
+                return item;
+            }
+
+            private static class MockDownloadRequester implements FeedFileDownloadStatusRequesterInterface {
+
+                private Map<Long, Boolean> downloadingByIds = new HashMap<>();
+
+                @Override
+                public synchronized boolean isDownloadingFile(@NonNull FeedFile item) {
+                    return downloadingByIds.getOrDefault(item.getId(), false);
+                }
+
+                // All other parent methods should not be called
+
+                public void mockDownloadingFile(FeedFile item, boolean isDownloading) {
+                    downloadingByIds.put(item.getId(), isDownloading);
+                }
+            }
+        }
+
+
         // Common helpers:
         // - common queue (of items) for tests
         // - construct FeedItems for tests
@@ -125,6 +251,7 @@ public class DBWriterTest {
         static FeedItem tFI(int id, int position) {
             FeedItem item = tFINoMedia(id);
             FeedMedia media = new FeedMedia(item, "download_url", 1234567, "audio/mpeg");
+            media.setId(item.getId());
             item.setMedia(media);
 
             if (position >= 0) {
@@ -135,11 +262,10 @@ public class DBWriterTest {
         }
 
         static FeedItem tFINoMedia(int id) {
-            FeedItem item = new FeedItem(0, "Item" + id, "ItemId" + id, "url",
+            FeedItem item = new FeedItem(id, "Item" + id, "ItemId" + id, "url",
                     new Date(), FeedItem.PLAYED, FeedMother.anyFeed());
             return item;
         }
-
     }
 
 }