1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
|
package de.luhmer.owncloudnewsreader.services;
import android.app.DownloadManager;
import android.app.IntentService;
import android.content.Context;
import android.content.Intent;
import android.net.Uri;
import android.widget.Toast;
import java.io.BufferedInputStream;
import java.io.File;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.math.BigInteger;
import java.net.URL;
import java.net.URLConnection;
import java.security.MessageDigest;
import de.greenrobot.event.EventBus;
import de.luhmer.owncloudnewsreader.helper.FileUtils;
import de.luhmer.owncloudnewsreader.model.PodcastItem;
/**
* An {@link IntentService} subclass for handling asynchronous task requests in
* a service on a separate handler thread.
* <p>
* helper methods.
*/
public class PodcastDownloadService extends IntentService {
// IntentService can perform, e.g. ACTION_FETCH_NEW_ITEMS
private static final String ACTION_DOWNLOAD = "de.luhmer.owncloudnewsreader.services.action.DOWNLOAD";
private static final String EXTRA_RECEIVER = "de.luhmer.owncloudnewsreader.services.extra.RECEIVER";
private static final String EXTRA_URL = "de.luhmer.owncloudnewsreader.services.extra.URL";
private static final String TAG = PodcastDownloadService.class.getCanonicalName();
private EventBus eventBus;
/**
* Starts this service to perform action Foo with the given parameters. If
* the service is already performing a task this action will be queued.
*
* @see IntentService
*/
public static void startPodcastDownload(Context context, PodcastItem podcastItem/*, ResultReceiver receiver*/) {
Intent intent = new Intent(context, PodcastDownloadService.class);
intent.setAction(ACTION_DOWNLOAD);
intent.putExtra(EXTRA_URL, podcastItem);
//intent.putExtra(EXTRA_RECEIVER, receiver);
context.startService(intent);
}
public PodcastDownloadService() {
super("PodcastDownloadService");
eventBus = EventBus.getDefault();
}
@Override
protected void onHandleIntent(Intent intent) {
if (intent != null) {
final String action = intent.getAction();
if (ACTION_DOWNLOAD.equals(action)) {
//ResultReceiver receiver = intent.getParcelableExtra(EXTRA_RECEIVER);
PodcastItem podcast = (PodcastItem) intent.getSerializableExtra(EXTRA_URL);
//final String param2 = intent.getStringExtra(EXTRA_PARAM2);
//handleActionDownload(podcast);
downloadPodcast(podcast, this);
}
}
}
/**
* Handle action Foo in the provided background thread with the provided
* parameters.
*/
private void handleActionDownload(PodcastItem podcast) {
Uri uri = Uri.parse(podcast.link);
DownloadManager.Request request = new DownloadManager.Request(uri);
request.setDescription(podcast.mimeType);
request.setTitle(podcast.title);
request.allowScanningByMediaScanner();
request.setNotificationVisibility(DownloadManager.Request.VISIBILITY_VISIBLE_NOTIFY_COMPLETED);
String path = "file://" + getUrlToPodcastFile(this, podcast.link, true);
request.setDestinationUri(Uri.parse(path));
//request.setDestinationInExternalPublicDir(Environment.DIRECTORY_DOWNLOADS, "bla.txt");
// get download service and enqueue file
DownloadManager manager = (DownloadManager) getSystemService(Context.DOWNLOAD_SERVICE);
manager.enqueue(request);
}
public static String getUrlToPodcastFile(Context context, String WEB_URL_TO_FILE, boolean createDir) {
File file = new File(WEB_URL_TO_FILE);
String path = FileUtils.getPathPodcasts(context) + "/" + getHashOfString(WEB_URL_TO_FILE) + "/";
if(createDir)
new File(path).mkdirs();
return path + file.getName();
}
public static String getHashOfString(String WEB_URL_TO_FILE)
{
try {
MessageDigest m = MessageDigest.getInstance("MD5");
m.reset();
m.update(WEB_URL_TO_FILE.trim().getBytes());
byte[] digest = m.digest();
BigInteger bigInt = new BigInteger(1,digest);
return bigInt.toString(16);
} catch (Exception e) {
e.printStackTrace();
}
return WEB_URL_TO_FILE;
}
private void downloadPodcast(PodcastItem podcast, Context context) {
try {
String urlTemp = podcast.link;
String path = getUrlToPodcastFile(this, urlTemp, true);
URL url = new URL(urlTemp);
URLConnection connection = url.openConnection();
connection.connect();
connection.setConnectTimeout(10000);
connection.setReadTimeout(120000);//2min
// this will be useful so that you can show a typical 0-100% progress bar
int fileLength = connection.getContentLength();
// download the file
InputStream input = new BufferedInputStream(url.openStream());
String pathCache = path + ".download";
OutputStream output = new FileOutputStream(pathCache);
byte data[] = new byte[1024];
long total = 0;
int count;
while ((count = input.read(data)) != -1) {
total += count;
podcast.downloadProgress = (int) (total * 100 / fileLength);
eventBus.post(new DownloadProgressUpdate(podcast));
output.write(data, 0, count);
}
output.flush();
output.close();
input.close();
new File(pathCache).renameTo(new File(path));
} catch (IOException e) {
e.printStackTrace();
Toast.makeText(context, e.getLocalizedMessage(), Toast.LENGTH_SHORT).show();
}
podcast.downloadProgress = 100;
eventBus.post(new DownloadProgressUpdate(podcast));
/*
Bundle resultData = new Bundle();
resultData.putInt("progress" ,100);
receiver.send(UPDATE_PROGRESS, resultData);
*/
}
//public static final int UPDATE_PROGRESS = 5555;
public class DownloadProgressUpdate {
public DownloadProgressUpdate(PodcastItem podcast) {
this.podcast = podcast;
}
public PodcastItem podcast;
}
public static boolean PodcastAlreadyCached(Context context, String podcastUrl) {
File file = new File(PodcastDownloadService.getUrlToPodcastFile(context, podcastUrl, false));
return file.exists();
}
}
|
