Castopod
/
AntennaPod
mirror of https://github.com/AntennaPod/AntennaPod.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

test refactor - ensure playback queue updated after download - make test logic more readable by hiding EventBus setup in a helper.

This commit is contained in:
orionlee 2019-09-30 12:18:41 -07:00
parent cbf6103c00
commit 4a0a825c08
1 changed files with 25 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

37
app/src/androidTest/java/de/test/antennapod/service/playback/PlaybackServiceTaskManagerTest.java
View File

@ -29,6 +29,7 @@ import de.danoeh.antennapod.core.storage.DBReader;
import de.danoeh.antennapod.core.storage.DBWriter; import de.danoeh.antennapod.core.storage.DBWriter;
import de.danoeh.antennapod.core.storage.PodDBAdapter; import de.danoeh.antennapod.core.storage.PodDBAdapter;
import de.danoeh.antennapod.core.util.playback.Playable; import de.danoeh.antennapod.core.util.playback.Playable;
import io.reactivex.functions.Consumer;
import static org.hamcrest.CoreMatchers.is; import static org.hamcrest.CoreMatchers.is;
import static org.hamcrest.MatcherAssert.assertThat; import static org.hamcrest.MatcherAssert.assertThat;
@ -149,30 +150,42 @@ public class PlaybackServiceTaskManagerTest {
assertThat("The item is not yet downloaded", assertThat("The item is not yet downloaded",
testItem.getMedia().isDownloaded(), is(false)); testItem.getMedia().isDownloaded(), is(false));
FeedItemEventListener feedItemEventListener = new FeedItemEventListener(); withFeedItemEventListener( feedItemEventListener -> {
EventBus.getDefault().register(feedItemEventListener); // simulate download complete (in DownloadService.MediaHandlerThread)
{ // simulate download complete (in DownloadService.MediaHandlerThread)
FeedItem item = DBReader.getFeedItem(testItem.getId()); FeedItem item = DBReader.getFeedItem(testItem.getId());
item.getMedia().setDownloaded(true); item.getMedia().setDownloaded(true);
item.getMedia().setFile_url("file://123"); item.getMedia().setFile_url("file://123");
item.setAutoDownload(false); item.setAutoDownload(false);
DBWriter.setFeedMedia(item.getMedia()).get(); DBWriter.setFeedMedia(item.getMedia()).get();
DBWriter.setFeedItem(item).get(); DBWriter.setFeedItem(item).get();
}
Awaitility.await() Awaitility.await()
.atMost(1000, TimeUnit.MILLISECONDS) .atMost(1000, TimeUnit.MILLISECONDS)
.until(() -> feedItemEventListener.getEvents().size() > 0); .until(() -> feedItemEventListener.getEvents().size() > 0);
final FeedItem itemUpdated = pstm.getQueue().get(0); final FeedItem itemUpdated = pstm.getQueue().get(0);
assertThat("The queue in PlaybackService has been updated item after download is completed", assertThat("The queue in PlaybackService has been updated item after download is completed",
itemUpdated.getMedia().isDownloaded(), is(true)); itemUpdated.getMedia().isDownloaded(), is(true));
});
EventBus.getDefault().unregister(feedItemEventListener);
pstm.shutdown(); pstm.shutdown();
} }
/**
* Provides an listener subscribing to {@link FeedItemEvent} that the callers can use
*
* Note: it uses RxJava's version of {@link Consumer} because it allows exceptions to be thrown.
*/
private static void withFeedItemEventListener(Consumer<FeedItemEventListener> consumer) throws Exception {
FeedItemEventListener feedItemEventListener = new FeedItemEventListener();
try {
EventBus.getDefault().register(feedItemEventListener);
consumer.accept(feedItemEventListener);
} finally {
EventBus.getDefault().unregister(feedItemEventListener);
}
}
private static class FeedItemEventListener { private static class FeedItemEventListener {
private final List<FeedItemEvent> events = new ArrayList<>(); private final List<FeedItemEvent> events = new ArrayList<>();