1 files changed, 107 insertions, 0 deletions
diff --git a/src/de/danoeh/antennapod/service/download/HttpDownloader.java b/src/de/danoeh/antennapod/service/download/HttpDownloader.java
new file mode 100644
index 000000000..32ab7f59d
--- /dev/null
+++ b/src/de/danoeh/antennapod/service/download/HttpDownloader.java
@@ -0,0 +1,107 @@
+package de.danoeh.antennapod.service.download;
+
+import java.io.BufferedInputStream;
+import java.io.BufferedOutputStream;
+import java.io.File;
+import java.io.FileOutputStream;
+import java.io.IOException;
+import java.io.InputStream;
+import java.io.OutputStream;
+import java.net.HttpURLConnection;
+import java.net.MalformedURLException;
+import java.net.URL;
+
+import android.util.Log;
+import de.danoeh.antennapod.AppConfig;
+import de.danoeh.antennapod.R;
+import de.danoeh.antennapod.asynctask.DownloadStatus;
+import de.danoeh.antennapod.util.DownloadError;
+
+public class HttpDownloader extends Downloader {
+	private static final String TAG = "HttpDownloader";
+
+	private static final int BUFFER_SIZE = 8 * 1024;
+
+	public HttpDownloader(DownloadService downloadService, DownloadStatus status) {
+		super(downloadService, status);
+	}
+
+	@Override
+	protected void download() {
+		HttpURLConnection connection = null;
+		OutputStream out = null;
+		try {
+			status.setStatusMsg(R.string.download_pending);
+			publishProgress();
+			URL url = new URL(status.getFeedFile().getDownload_url());
+			connection = (HttpURLConnection) url.openConnection();
+			if (AppConfig.DEBUG) {
+				Log.d(TAG, "Connected to resource");
+			}
+			File destination = new File(status.getFeedFile().getFile_url());
+			if (!destination.exists()) {
+				InputStream in = new BufferedInputStream(
+						connection.getInputStream());
+				out = new BufferedOutputStream(
+						new FileOutputStream(destination));
+				byte[] buffer = new byte[BUFFER_SIZE];
+				int count = 0;
+				status.setStatusMsg(R.string.download_running);
+				status.setSize(connection.getContentLength());
+				publishProgress();
+				while ((count = in.read(buffer)) != -1 || !isInterrupted()) {
+					out.write(buffer, 0, count);
+					status.setSoFar(status.getSoFar() + count);
+				}
+				if (isInterrupted()) {
+					onCancelled();
+				} else {
+					onSuccess();
+				}
+			} else {
+				onFail(DownloadError.ERROR_FILE_EXISTS);
+			}
+		} catch (MalformedURLException e) {
+			e.printStackTrace();
+			onFail(DownloadError.ERROR_MALFORMED_URL);
+		} catch (IOException e) {
+			e.printStackTrace();
+			onFail(DownloadError.ERROR_IO_ERROR);
+		} finally {
+			if (connection != null) {
+				connection.disconnect();
+			}
+			if (out != null) {
+				try {
+					out.close();
+				} catch (IOException e) {
+					e.printStackTrace();
+				}
+			}
+		}
+	}
+
+	private void onSuccess() {
+		if (AppConfig.DEBUG)
+			Log.d(TAG, "Download was successful");
+		status.setSuccessful(true);
+		status.setDone(true);
+	}
+
+	private void onFail(int reason) {
+		if (AppConfig.DEBUG) {
+			Log.d(TAG, "Download failed");
+		}
+		status.setReason(reason);
+		status.setDone(true);
+		status.setSuccessful(false);
+	}
+
+	private void onCancelled() {
+		if (AppConfig.DEBUG) Log.d(TAG, "Download was cancelled");
+		status.setReason(DownloadError.ERROR_DOWNLOAD_CANCELLED);
+		status.setDone(true);
+		status.setSuccessful(false);
+	}
+
+}