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

Migrated download log events to EventBus

This commit is contained in:
ByteHamster 2019-10-23 22:41:20 +02:00
parent bc5f36336e
commit 68da2e022d
5 changed files with 50 additions and 22 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
app/src/main/java/de/danoeh/antennapod/fragment/CompletedDownloadsFragment.java
View File

@ -16,6 +16,7 @@ import java.util.List;
import de.danoeh.antennapod.R;
import de.danoeh.antennapod.activity.MainActivity;
import de.danoeh.antennapod.adapter.DownloadedEpisodesListAdapter;
import de.danoeh.antennapod.core.event.DownloadLogEvent;
import de.danoeh.antennapod.core.feed.EventDistributor;
import de.danoeh.antennapod.core.feed.FeedItem;
import de.danoeh.antennapod.core.storage.DBReader;
@ -27,6 +28,8 @@ import io.reactivex.Observable;
import io.reactivex.android.schedulers.AndroidSchedulers;
import io.reactivex.disposables.Disposable;
import io.reactivex.schedulers.Schedulers;
import org.greenrobot.eventbus.EventBus;
import org.greenrobot.eventbus.Subscribe;
import static de.danoeh.antennapod.dialog.EpisodesApplyActionFragment.ACTION_ADD_TO_QUEUE;
import static de.danoeh.antennapod.dialog.EpisodesApplyActionFragment.ACTION_DELETE;
@ -38,9 +41,7 @@ public class CompletedDownloadsFragment extends ListFragment {
private static final String TAG = CompletedDownloadsFragment.class.getSimpleName();
private static final int EVENTS = EventDistributor.DOWNLOAD_HANDLED |
EventDistributor.DOWNLOADLOG_UPDATE |
EventDistributor.UNREAD_ITEMS_UPDATE;
private static final int EVENTS = EventDistributor.DOWNLOAD_HANDLED | EventDistributor.UNREAD_ITEMS_UPDATE;
private List<FeedItem> items = new ArrayList<>();
private DownloadedEpisodesListAdapter listAdapter;
@ -56,6 +57,13 @@ public class CompletedDownloadsFragment extends ListFragment {
listAdapter = new DownloadedEpisodesListAdapter(getActivity(), itemAccess);
setListAdapter(listAdapter);
setListShown(false);
EventBus.getDefault().register(this);
}
@Override
public void onDestroyView() {
EventBus.getDefault().unregister(this);
super.onDestroyView();
}
@Override
@ -144,6 +152,11 @@ public class CompletedDownloadsFragment extends ListFragment {
}
};
@Subscribe
public void onDownloadLogChanged(DownloadLogEvent event) {
loadItems();
}
private void loadItems() {
if (disposable != null) {
disposable.dispose();

25
app/src/main/java/de/danoeh/antennapod/fragment/DownloadLogFragment.java
View File

@ -19,6 +19,7 @@ import java.util.List;
import de.danoeh.antennapod.R;
import de.danoeh.antennapod.adapter.DownloadLogAdapter;
import de.danoeh.antennapod.core.event.DownloadLogEvent;
import de.danoeh.antennapod.core.feed.EventDistributor;
import de.danoeh.antennapod.core.feed.Feed;
import de.danoeh.antennapod.core.feed.FeedMedia;
@ -30,6 +31,8 @@ import io.reactivex.Observable;
import io.reactivex.android.schedulers.AndroidSchedulers;
import io.reactivex.disposables.Disposable;
import io.reactivex.schedulers.Schedulers;
import org.greenrobot.eventbus.EventBus;
import org.greenrobot.eventbus.Subscribe;
/**
* Shows the download log
@ -45,14 +48,12 @@ public class DownloadLogFragment extends ListFragment {
@Override
public void onStart() {
super.onStart();
EventDistributor.getInstance().register(contentUpdate);
loadItems();
}
@Override
public void onStop() {
super.onStop();
EventDistributor.getInstance().unregister(contentUpdate);
if (disposable != null) {
disposable.dispose();
}
@ -77,6 +78,13 @@ public class DownloadLogFragment extends ListFragment {
adapter = new DownloadLogAdapter(getActivity(), itemAccess);
setListAdapter(adapter);
EventBus.getDefault().register(this);
}
@Override
public void onDestroyView() {
EventBus.getDefault().unregister(this);
super.onDestroyView();
}
private void onFragmentLoaded() {
@ -133,15 +141,10 @@ public class DownloadLogFragment extends ListFragment {
}
};
private final EventDistributor.EventListener contentUpdate = new EventDistributor.EventListener() {
@Override
public void update(EventDistributor eventDistributor, Integer arg) {
if ((arg & EventDistributor.DOWNLOADLOG_UPDATE) != 0) {
loadItems();
}
}
};
@Subscribe
public void onDownloadLogChanged(DownloadLogEvent event) {
loadItems();
}
@Override
public void onCreateOptionsMenu(Menu menu, MenuInflater inflater) {

16
core/src/main/java/de/danoeh/antennapod/core/event/DownloadLogEvent.java Normal file
View File

@ -0,0 +1,16 @@
package de.danoeh.antennapod.core.event;
public class DownloadLogEvent {
private DownloadLogEvent() {
}
public static DownloadLogEvent listUpdated() {
return new DownloadLogEvent();
}
@Override
public String toString() {
return "DownloadLogEvent";
}
}

5
core/src/main/java/de/danoeh/antennapod/core/feed/EventDistributor.java
View File

@ -22,7 +22,6 @@ public class EventDistributor extends Observable {
public static final int FEED_LIST_UPDATE = 1;
public static final int UNREAD_ITEMS_UPDATE = 2;
public static final int DOWNLOADLOG_UPDATE = 8;
public static final int PLAYBACK_HISTORY_UPDATE = 16;
public static final int DOWNLOAD_HANDLED = 64;
public static final int PLAYER_STATUS_UPDATE = 128;
@ -90,10 +89,6 @@ public class EventDistributor extends Observable {
addEvent(PLAYBACK_HISTORY_UPDATE);
}
public void sendDownloadLogUpdateBroadcast() {
addEvent(DOWNLOADLOG_UPDATE);
}
public void sendPlayerStatusUpdateBroadcast() { addEvent(PLAYER_STATUS_UPDATE); }
public abstract static class EventListener implements Observer {

7
core/src/main/java/de/danoeh/antennapod/core/storage/DBWriter.java
View File

@ -6,6 +6,7 @@ import android.util.Log;
import androidx.annotation.NonNull;
import de.danoeh.antennapod.core.event.DownloadLogEvent;
import org.greenrobot.eventbus.EventBus;
import java.io.File;
@ -176,7 +177,7 @@ public class DBWriter {
// we assume we also removed download log entries for the feed or its media files.
// especially important if download or refresh failed, as the user should not be able
// to retry these
EventDistributor.getInstance().sendDownloadLogUpdateBroadcast();
EventBus.getDefault().post(DownloadLogEvent.listUpdated());
BackupManager backupManager = new BackupManager(context);
backupManager.dataChanged();
@ -206,7 +207,7 @@ public class DBWriter {
adapter.open();
adapter.clearDownloadLog();
adapter.close();
EventDistributor.getInstance().sendDownloadLogUpdateBroadcast();
EventBus.getDefault().post(DownloadLogEvent.listUpdated());
});
}
@ -243,7 +244,7 @@ public class DBWriter {
adapter.open();
adapter.setDownloadStatus(status);
adapter.close();
EventDistributor.getInstance().sendDownloadLogUpdateBroadcast();
EventBus.getDefault().post(DownloadLogEvent.listUpdated());
});
}