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

Added communication interface to DownloadService

This commit is contained in:
Daniel Oeh 2012-04-15 15:30:00 +02:00
parent 91166cd442
commit 53e5e7c588
1 changed files with 48 additions and 24 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

72
src/de/podfetcher/service/DownloadService.java
View File

@ -20,9 +20,13 @@ import android.os.IBinder;
import android.content.BroadcastReceiver; import android.content.BroadcastReceiver;
import android.content.Context; import android.content.Context;
import android.util.Log; import android.util.Log;
import android.app.NotificationManager;
import android.os.Handler;
import android.os.Message;
import android.os.Messenger;
public class DownloadService extends Service { public class DownloadService extends Service {
private static final String TAG = "DownloadService"; private static final String TAG = "DownloadService";
public static String ACTION_ALL_FEED_DOWNLOADS_COMPLETED = "action.de.podfetcher.storage.all_feed_downloads_completed"; public static String ACTION_ALL_FEED_DOWNLOADS_COMPLETED = "action.de.podfetcher.storage.all_feed_downloads_completed";
public static final String ACTION_FEED_SYNC_COMPLETED = "action.de.podfetcher.service.feed_sync_completed"; public static final String ACTION_FEED_SYNC_COMPLETED = "action.de.podfetcher.service.feed_sync_completed";
@ -31,6 +35,13 @@ public class DownloadService extends Service {
private DownloadRequester requester; private DownloadRequester requester;
private FeedManager manager; private FeedManager manager;
// Objects for communication
private final Messenger mMessenger = new Messenger(new IncomingHandler());
// Message codes
public static final int MSG_QUERY_DOWNLOADS = 1;
@Override @Override
public void onCreate() { public void onCreate() {
Log.d(TAG, "Service started"); Log.d(TAG, "Service started");
@ -42,7 +53,7 @@ public class DownloadService extends Service {
@Override @Override
public IBinder onBind(Intent intent) { public IBinder onBind(Intent intent) {
return null; return mMessenger.getBinder();
} }
@Override @Override
@ -92,32 +103,45 @@ public class DownloadService extends Service {
handleCompletedImageDownload(context, image); handleCompletedImageDownload(context, image);
} }
} }
queryDownloads();
// Check if there's something else to download, otherwise stop
if(requester.getNumberOfDownloads() == 0) {
unregisterReceiver(downloadReceiver);
initiateShutdown();
}
} }
}; };
/** Check if there's something else to download, otherwise stop */
private void queryDownloads() {
if(requester.getNumberOfDownloads() == 0) {
unregisterReceiver(downloadReceiver);
initiateShutdown();
}
}
/** Is called whenever a Feed is downloaded */ /** Is called whenever a Feed is downloaded */
private void handleCompletedFeedDownload(Context context, Feed feed) { private void handleCompletedFeedDownload(Context context, Feed feed) {
Log.d(TAG, "Handling completed Feed Download"); Log.d(TAG, "Handling completed Feed Download");
// Get Feed Information
//feed.setFile_url((new File(requester.getFeedfilePath(context), requester.getFeedfileName(feed.getId()))).toString());
syncExecutor.execute(new FeedSyncThread(feed, this, requester)); syncExecutor.execute(new FeedSyncThread(feed, this, requester));
} }
/** Is called whenever a Feed-Image is downloaded */ /** Is called whenever a Feed-Image is downloaded */
private void handleCompletedImageDownload(Context context, FeedImage image) { private void handleCompletedImageDownload(Context context, FeedImage image) {
Log.d(TAG, "Handling completed Image Download"); Log.d(TAG, "Handling completed Image Download");
requester.removeFeedImage(image); requester.removeFeedImage(image);
//image.setFile_url(requester.getImagefilePath(context) + requester.getImagefileName(image.getId())); manager.setFeedImage(this, image);
manager.setFeedImage(this, image); }
class IncomingHandler extends Handler {
@Override
public void handleMessage(Message msg) {
Log.d(TAG, "Received new Message.");
switch(msg.what) {
case MSG_QUERY_DOWNLOADS:
queryDownloads();
break;
default:
super.handleMessage(msg);
}
}
} }
/** Takes a single Feed, parses the corresponding file and refreshes information in the manager */ /** Takes a single Feed, parses the corresponding file and refreshes information in the manager */
@ -137,16 +161,16 @@ public class DownloadService extends Service {
public void run() { public void run() {
FeedManager manager = FeedManager.getInstance(); FeedManager manager = FeedManager.getInstance();
FeedHandler handler = new FeedHandler(); FeedHandler handler = new FeedHandler();
feed = handler.parseFeed(feed); feed = handler.parseFeed(feed);
Log.d(TAG, feed.getTitle() + " parsed"); Log.d(TAG, feed.getTitle() + " parsed");
// Download Feed Image if provided // Download Feed Image if provided
if(feed.getImage() != null) { if(feed.getImage() != null) {
Log.d(TAG, "Feed has image; Downloading...."); Log.d(TAG, "Feed has image; Downloading....");
requester.downloadImage(service, feed.getImage()); requester.downloadImage(service, feed.getImage());
} }
requester.removeFeed(feed); requester.removeFeed(feed);
cleanup(); cleanup();
// Save information of feed in DB // Save information of feed in DB
@ -159,6 +183,6 @@ public class DownloadService extends Service {
Log.d(TAG, "Successfully deleted cache file."); else Log.e(TAG, "Failed to delete cache file."); Log.d(TAG, "Successfully deleted cache file."); else Log.e(TAG, "Failed to delete cache file.");
feed.setFile_url(null); feed.setFile_url(null);
} }
} }
} }