Merge branch 'master' of github.com:daneren2005/Subsonic

12 files changed, 172 insertions, 348 deletions

diff --git a/src/github/daneren2005/dsub/activity/SubsonicActivity.java b/src/github/daneren2005/dsub/activity/SubsonicActivity.java
index c1534639..62349480 100644
--- a/src/github/daneren2005/dsub/activity/SubsonicActivity.java
+++ b/src/github/daneren2005/dsub/activity/SubsonicActivity.java
@@ -649,7 +649,7 @@ public class SubsonicActivity extends ActionBarActivity implements OnItemSelecte
 		}

 	}

 

-	public boolean isDestroyed() {

+	public boolean isDestroyedCompat() {

 		return destroyed;

 	}

 

diff --git a/src/github/daneren2005/dsub/fragments/DownloadFragment.java b/src/github/daneren2005/dsub/fragments/DownloadFragment.java
index 0a146b33..87cffd03 100644
--- a/src/github/daneren2005/dsub/fragments/DownloadFragment.java
+++ b/src/github/daneren2005/dsub/fragments/DownloadFragment.java
@@ -13,6 +13,7 @@ import android.content.SharedPreferences;
 import android.graphics.Color;

 import android.os.Bundle;

 import android.os.Handler;

+import android.support.v4.view.MenuItemCompat;

 import android.support.v7.app.MediaRouteButton;

 import android.view.ContextMenu;

 import android.view.Display;

@@ -505,7 +506,7 @@ public class DownloadFragment extends SubsonicFragment implements OnGestureListe
 		if(downloadService != null) {

 			MenuItem mediaRouteItem = menu.findItem(R.id.menu_mediaroute);

 			if(mediaRouteItem != null) {

-				MediaRouteButton mediaRouteButton = (MediaRouteButton) mediaRouteItem.getActionView();

+				MediaRouteButton mediaRouteButton = (MediaRouteButton) MenuItemCompat.getActionView(mediaRouteItem);

 				mediaRouteButton.setRouteSelector(downloadService.getRemoteSelector());

 			}

 		}

diff --git a/src/github/daneren2005/dsub/fragments/MainFragment.java b/src/github/daneren2005/dsub/fragments/MainFragment.java
index ebb9318e..801238de 100644
--- a/src/github/daneren2005/dsub/fragments/MainFragment.java
+++ b/src/github/daneren2005/dsub/fragments/MainFragment.java
@@ -209,6 +209,10 @@ public class MainFragment extends SubsonicFragment {
 		boolean isOffline = Util.isOffline(context);

 		Util.setOffline(context, !isOffline);

 		context.invalidate();

+		DownloadService service = getDownloadService();

+		if (service != null) {

+			service.setOnline(isOffline);

+		}

 		

 		if(isOffline) {

 			int scrobblesCount = Util.offlineScrobblesCount(context);

diff --git a/src/github/daneren2005/dsub/service/ChromeCastController.java b/src/github/daneren2005/dsub/service/ChromeCastController.java
index dc360797..02661f14 100644
--- a/src/github/daneren2005/dsub/service/ChromeCastController.java
+++ b/src/github/daneren2005/dsub/service/ChromeCastController.java
@@ -15,6 +15,7 @@
 
 package github.daneren2005.dsub.service;
 
+import android.content.SharedPreferences;
 import android.net.Uri;
 import android.os.Bundle;
 import android.util.Log;
@@ -32,14 +33,17 @@ import com.google.android.gms.common.api.ResultCallback;
 import com.google.android.gms.common.api.Status;
 import com.google.android.gms.common.images.WebImage;
 
+import java.io.File;
 import java.io.IOException;
 
 import github.daneren2005.dsub.R;
 import github.daneren2005.dsub.domain.MusicDirectory;
 import github.daneren2005.dsub.domain.PlayerState;
 import github.daneren2005.dsub.util.Constants;
+import github.daneren2005.dsub.util.FileUtil;
 import github.daneren2005.dsub.util.Util;
 import github.daneren2005.dsub.util.compat.CastCompat;
+import github.daneren2005.serverproxy.FileProxy;
 
 /**
  * Created by owner on 2/9/14.
@@ -58,12 +62,17 @@ public class ChromeCastController extends RemoteController {
 	private boolean error = false;
 	private boolean ignoreNextPaused = false;
 
+	private FileProxy proxy;
+	private String rootLocation;
 	private RemoteMediaPlayer mediaPlayer;
 	private double gain = 0.5;
 
 	public ChromeCastController(DownloadService downloadService, CastDevice castDevice) {
 		this.downloadService = downloadService;
 		this.castDevice = castDevice;
+
+		SharedPreferences prefs = Util.getPreferences(downloadService);
+		rootLocation = prefs.getString(Constants.PREFERENCES_KEY_CACHE_LOCATION, null);
 	}
 
 	@Override
@@ -154,6 +163,11 @@ public class ChromeCastController extends RemoteController {
 			apiClient.disconnect();
 		}
 		apiClient = null;
+
+		if(proxy != null) {
+			proxy.stop();
+			proxy = null;
+		}
 	}
 
 	@Override
@@ -209,9 +223,30 @@ public class ChromeCastController extends RemoteController {
 
 		try {
 			MusicService musicService = MusicServiceFactory.getMusicService(downloadService);
-			String url = song.isVideo() ? musicService.getHlsUrl(song.getId(), currentPlaying.getBitRate(), downloadService) : musicService.getMusicUrl(downloadService, song, currentPlaying.getBitRate());
-			//  Use separate profile for Chromecast so users can do ogg on phone, mp3 for CC
-			url = url.replace(Constants.REST_CLIENT_ID, Constants.CHROMECAST_CLIENT_ID);
+			String url;
+			// Offline, use file proxy
+			if(Util.isOffline(downloadService) || song.getId().indexOf(rootLocation) != -1) {
+				if(proxy == null) {
+					proxy = new FileProxy(downloadService);
+					proxy.start();
+				}
+
+				url = proxy.getPublicAddress(song.getId());
+			} else {
+				if(proxy != null) {
+					proxy.stop();
+					proxy = null;
+				}
+
+				if(song.isVideo()) {
+					url = musicService.getHlsUrl(song.getId(), currentPlaying.getBitRate(), downloadService);
+				} else {
+					url = musicService.getMusicUrl(downloadService, song, currentPlaying.getBitRate());
+				}
+
+				url = fixURLs(url);
+				Log.i(TAG, "Cast url: " + url);
+			}
 
 			// Setup song/video information
 			MediaMetadata meta = new MediaMetadata(song.isVideo() ? MediaMetadata.MEDIA_TYPE_MOVIE : MediaMetadata.MEDIA_TYPE_MUSIC_TRACK);
@@ -223,8 +258,20 @@ public class ChromeCastController extends RemoteController {
 				meta.putString(MediaMetadata.KEY_ARTIST, song.getArtist());
 				meta.putString(MediaMetadata.KEY_ALBUM_ARTIST, song.getArtist());
 				meta.putString(MediaMetadata.KEY_ALBUM_TITLE, song.getAlbum());
-				String coverArt = musicService.getCoverArtUrl(downloadService, song);
-				meta.addImage(new WebImage(Uri.parse(coverArt)));
+
+				String coverArt = "";
+				if(proxy == null) {
+					coverArt = musicService.getCoverArtUrl(downloadService, song);
+					coverArt = fixURLs(coverArt);
+					meta.addImage(new WebImage(Uri.parse(coverArt)));
+				} else {
+					File coverArtFile = FileUtil.getAlbumArtFile(downloadService, song);
+					if(coverArtFile != null && coverArtFile.exists()) {
+						coverArt = proxy.getPublicAddress(coverArtFile.getPath());
+						meta.addImage(new WebImage(Uri.parse(coverArt)));
+					}
+				}
+				Log.i(TAG, "Cover art: " + coverArt);
 			}
 
 			String contentType;
@@ -233,8 +280,10 @@ public class ChromeCastController extends RemoteController {
 			}
 			else if(song.getTranscodedContentType() != null) {
 				contentType = song.getTranscodedContentType();
-			} else {
+			} else if(song.getContentType() != null) {
 				contentType = song.getContentType();
+			} else {
+				contentType = "audio/mpeg";
 			}
 
 			// Load it into a MediaInfo wrapper
@@ -268,6 +317,20 @@ public class ChromeCastController extends RemoteController {
 		}
 	}
 
+	private String fixURLs(String url) {
+		// Only change to internal when using https
+		if(url.indexOf("https") != -1) {
+			SharedPreferences prefs = Util.getPreferences(downloadService);
+			int instance = prefs.getInt(Constants.PREFERENCES_KEY_SERVER_INSTANCE, 1);
+			String externalUrl = prefs.getString(Constants.PREFERENCES_KEY_SERVER_URL + instance, null);
+			String internalUrl = prefs.getString(Constants.PREFERENCES_KEY_SERVER_INTERNAL_URL + instance, null);
+			url = url.replace(internalUrl, externalUrl);
+		}
+
+		//  Use separate profile for Chromecast so users can do ogg on phone, mp3 for CC
+		return url.replace(Constants.REST_CLIENT_ID, Constants.CHROMECAST_CLIENT_ID);
+	}
+
 	private void failedLoad() {
 		Util.toast(downloadService, downloadService.getResources().getString(R.string.download_failed_to_load));
 		downloadService.setPlayerState(PlayerState.STOPPED);
diff --git a/src/github/daneren2005/dsub/service/DownloadFile.java b/src/github/daneren2005/dsub/service/DownloadFile.java
index 9598b572..d7c3959c 100644
--- a/src/github/daneren2005/dsub/service/DownloadFile.java
+++ b/src/github/daneren2005/dsub/service/DownloadFile.java
@@ -36,6 +36,8 @@ import github.daneren2005.dsub.util.CancellableTask;
 import github.daneren2005.dsub.util.FileUtil;
 import github.daneren2005.dsub.util.Util;
 import github.daneren2005.dsub.util.CacheCleaner;
+import github.daneren2005.serverproxy.BufferFile;
+
 import org.apache.http.Header;
 
 import org.apache.http.HttpResponse;
@@ -45,7 +47,7 @@ import org.apache.http.HttpStatus;
  * @author Sindre Mehus
  * @version $Id$
  */
-public class DownloadFile {
+public class DownloadFile implements BufferFile {
     private static final String TAG = DownloadFile.class.getSimpleName();
     private static final int MAX_FAILURES = 5;
     private final Context context;
@@ -63,7 +65,7 @@ public class DownloadFile {
 	private boolean isPlaying = false;
 	private boolean saveWhenDone = false;
 	private boolean completeWhenDone = false;
-	private Integer contentLength = null;
+	private Long contentLength = null;
 	private long currentSpeed = 0;
 
     public DownloadFile(Context context, MusicDirectory.Entry song, boolean save) {
@@ -108,7 +110,7 @@ public class DownloadFile {
 		return br;
 	}
 	
-	public Integer getContentLength() {
+	public Long getContentLength() {
 		return contentLength;
 	}
 
@@ -125,6 +127,7 @@ public class DownloadFile {
 		}
 	}
 
+	@Override
 	public long getEstimatedSize() {
 		if(contentLength != null) {
 			return contentLength;
@@ -136,7 +139,7 @@ public class DownloadFile {
 		} else if(song.getDuration() == null) {
 			return 0;
 		} else {
-			int br = (getBitRate() * 1024) / 8;
+			int br = (getBitRate() * 1000) / 8;
 			int duration = song.getDuration();
 			return br * duration;
 		}
@@ -171,6 +174,17 @@ public class DownloadFile {
         }
     }
 
+	@Override
+	public File getFile() {
+		if (saveFile.exists()) {
+			return saveFile;
+		} else if (completeFile.exists()) {
+			return completeFile;
+		} else {
+			return partialFile;
+		}
+	}
+
     public File getCompleteFile() {
         if (saveFile.exists()) {
             return saveFile;
@@ -195,11 +209,22 @@ public class DownloadFile {
         return saveFile.exists() || completeFile.exists();
     }
 
+	@Override
     public synchronized boolean isWorkDone() {
         return saveFile.exists() || (completeFile.exists() && !save) || saveWhenDone || completeWhenDone;
     }
 
-    public synchronized boolean isDownloading() {
+	@Override
+	public void onStart() {
+		setPlaying(true);
+	}
+
+	@Override
+	public void onStop() {
+		setPlaying(false);
+	}
+
+	public synchronized boolean isDownloading() {
         return downloadTask != null && downloadTask.isRunning();
     }
 
@@ -353,7 +378,7 @@ public class DownloadFile {
 						String contentLengthString = contentLengthHeader.getValue();
 						if(contentLengthString != null) {
 							Log.i(TAG, "Content Length: " + contentLengthString);
-							contentLength = Integer.parseInt(contentLengthString);
+							contentLength = Long.parseLong(contentLengthString);
 						}
 					}
 					in = response.getEntity().getContent();
diff --git a/src/github/daneren2005/dsub/service/DownloadService.java b/src/github/daneren2005/dsub/service/DownloadService.java
index 01753026..924f53a7 100644
--- a/src/github/daneren2005/dsub/service/DownloadService.java
+++ b/src/github/daneren2005/dsub/service/DownloadService.java
@@ -43,6 +43,7 @@ import github.daneren2005.dsub.util.ShufflePlayBuffer;
 import github.daneren2005.dsub.util.SimpleServiceBinder;
 import github.daneren2005.dsub.util.Util;
 import github.daneren2005.dsub.util.compat.RemoteControlClientHelper;
+import github.daneren2005.serverproxy.BufferProxy;
 
 import java.io.File;
 import java.util.ArrayList;
@@ -133,7 +134,7 @@ public class DownloadService extends Service {
 	private boolean showVisualization;
 	private RemoteControlState remoteState = RemoteControlState.LOCAL;
 	private PositionCache positionCache;
-	private StreamProxy proxy;
+	private BufferProxy proxy;
 
 	private Timer sleepTimer;
 	private int timerDuration;
@@ -274,6 +275,10 @@ public class DownloadService extends Service {
 			remoteController.stop();
 			remoteController.shutdown();
 		}
+		if(proxy != null) {
+			proxy.stop();
+			proxy = null;
+		}
 		mediaRouter.destroy();
 		Util.hidePlayingNotification(this, this, handler);
 		Util.hideDownloadingNotification(this);
@@ -368,7 +373,7 @@ public class DownloadService extends Service {
 		}
 	}
 
-	public void restore(List<MusicDirectory.Entry> songs, List<MusicDirectory.Entry> toDelete, int currentPlayingIndex, int currentPlayingPosition) {
+	public synchronized void restore(List<MusicDirectory.Entry> songs, List<MusicDirectory.Entry> toDelete, int currentPlayingIndex, int currentPlayingPosition) {
 		SharedPreferences prefs = Util.getPreferences(this);
 		remoteState = RemoteControlState.values()[prefs.getInt(Constants.PREFERENCES_KEY_CONTROL_MODE, 0)];
 		if(remoteState != RemoteControlState.LOCAL) {
@@ -518,6 +523,15 @@ public class DownloadService extends Service {
 		updateJukeboxPlaylist();
 	}
 
+	public synchronized void setOnline(boolean online) {
+		if(online) {
+			mediaRouter.addOfflineProviders();
+		} else {
+			mediaRouter.removeOfflineProviders();
+			clearIncomplete();
+		}
+	}
+
 	public synchronized int size() {
 		return downloadList.size();
 	}
@@ -552,6 +566,13 @@ public class DownloadService extends Service {
 		}
 		updateJukeboxPlaylist();
 		setNextPlaying();
+		if(proxy != null) {
+			proxy.stop();
+			proxy = null;
+		}
+
+		suggestedPlaylistName = null;
+		suggestedPlaylistId = null;
 	}
 
 	public synchronized void remove(int which) {
@@ -830,17 +851,7 @@ public class DownloadService extends Service {
 			nextPlayingIndex++;
 		}
 		if (index != -1 && nextPlayingIndex < size()) {
-			if(nextPlaying != null && downloadList.get(nextPlayingIndex) == nextPlaying && nextPlayerState == PlayerState.PREPARED && remoteState == RemoteControlState.LOCAL) {
-				if(mediaPlayer.isPlaying()) {
-					mediaPlayer.stop();
-				}
-				mediaPlayer.setOnErrorListener(null);
-				mediaPlayer.setOnCompletionListener(null);
-				mediaPlayer.reset();
-				playNext(true);
-			} else {
-				play(nextPlayingIndex);
-			}
+			play(nextPlayingIndex);
 		}
 	}
 
@@ -1146,6 +1157,16 @@ public class DownloadService extends Service {
 			if (currentDownloading != null) {
 				currentDownloading.cancelDownload();
 			}
+
+			// Cancels current setup tasks
+			if(bufferTask != null && bufferTask.isRunning()) {
+				bufferTask.cancel();
+				bufferTask = null;
+			}
+			if(nextPlayingTask != null && nextPlayingTask.isRunning()) {
+				nextPlayingTask.cancel();
+				nextPlayingTask = null;
+			}
 		}
 
 		SharedPreferences prefs = Util.getPreferences(this);
@@ -1216,10 +1237,11 @@ public class DownloadService extends Service {
 			String dataSource = file.getPath();
 			if(isPartial) {
 				if (proxy == null) {
-					proxy = new StreamProxy(this);
+					proxy = new BufferProxy(this);
 					proxy.start();
 				}
-				dataSource = String.format("http://127.0.0.1:%d/%s", proxy.getPort(), URLEncoder.encode(dataSource, Constants.UTF_8));
+				proxy.setBufferFile(downloadFile);
+				dataSource = proxy.getPrivateAddress(dataSource);
 				Log.i(TAG, "Data Source: " + dataSource);
 			} else if(proxy != null) {
 				proxy.stop();
diff --git a/src/github/daneren2005/dsub/service/JukeboxController.java b/src/github/daneren2005/dsub/service/JukeboxController.java
index 7f248f03..ebebbaf8 100644
--- a/src/github/daneren2005/dsub/service/JukeboxController.java
+++ b/src/github/daneren2005/dsub/service/JukeboxController.java
@@ -217,9 +217,9 @@ public class JukeboxController extends RemoteController {
 			@Override
 			public void run() {
 				Util.toast(downloadService, resourceId, false);
+				downloadService.setRemoteEnabled(RemoteControlState.LOCAL);
 			}
 		});
-		downloadService.setRemoteEnabled(RemoteControlState.LOCAL);
 	}
 	
 	private MusicService getMusicService() {
diff --git a/src/github/daneren2005/dsub/service/RESTMusicService.java b/src/github/daneren2005/dsub/service/RESTMusicService.java
index 8ea29a41..879339cc 100644
--- a/src/github/daneren2005/dsub/service/RESTMusicService.java
+++ b/src/github/daneren2005/dsub/service/RESTMusicService.java
@@ -623,7 +623,7 @@ public class RESTMusicService implements MusicService {
 
 	@Override
 	public String getCoverArtUrl(Context context, MusicDirectory.Entry entry) throws Exception {
-		StringBuilder builder = new StringBuilder(getRestUrl(context, "getCoverArt", false));
+		StringBuilder builder = new StringBuilder(getRestUrl(context, "getCoverArt"));
 		builder.append("&id=").append(entry.getId());
 		String url = rewriteUrlWithRedirect(context, builder.toString());
 		return url;
@@ -710,7 +710,7 @@ public class RESTMusicService implements MusicService {
 
 	@Override
 	public String getMusicUrl(Context context, MusicDirectory.Entry song, int maxBitrate) throws Exception {
-		StringBuilder builder = new StringBuilder(getRestUrl(context, "stream", false));
+		StringBuilder builder = new StringBuilder(getRestUrl(context, "stream"));
 		builder.append("&id=").append(song.getId());
 		builder.append("&maxBitRate=").append(maxBitrate);
 
diff --git a/src/github/daneren2005/dsub/service/StreamProxy.java b/src/github/daneren2005/dsub/service/StreamProxy.java
deleted file mode 100644
index d660b6d3..00000000
--- a/src/github/daneren2005/dsub/service/StreamProxy.java
+++ /dev/null
@@ -1,311 +0,0 @@
-package github.daneren2005.dsub.service;

-

-import java.io.BufferedOutputStream;

-import java.io.BufferedReader;

-import java.io.File;

-import java.io.FileInputStream;

-import java.io.IOException;

-import java.io.InputStream;

-import java.io.InputStreamReader;

-import java.io.OutputStream;

-import java.io.UnsupportedEncodingException;

-import java.net.InetAddress;

-import java.net.ServerSocket;

-import java.net.Socket;

-import java.net.SocketException;

-import java.net.SocketTimeoutException;

-import java.net.URLDecoder;

-import java.net.UnknownHostException;

-import java.util.StringTokenizer;

-

-import org.apache.http.Header;

-import org.apache.http.HttpRequest;

-import org.apache.http.message.BasicHttpRequest;

-

-import android.os.AsyncTask;

-import android.os.Looper;

-import android.util.Log;

-import github.daneren2005.dsub.domain.MusicDirectory;

-import github.daneren2005.dsub.util.Constants;

-

-public class StreamProxy implements Runnable {

-	private static final String TAG = StreamProxy.class.getSimpleName();

-

-	private Thread thread;

-	private boolean isRunning;

-	private ServerSocket socket;

-	private int port;

-	private DownloadService downloadService;

-

-	public StreamProxy(DownloadService downloadService) {

-

-		// Create listening socket

-		try {

-			socket = new ServerSocket(0, 0, InetAddress.getByAddress(new byte[] { 127, 0, 0, 1 }));

-			socket.setSoTimeout(5000);

-			port = socket.getLocalPort();

-			this.downloadService = downloadService;

-		} catch (UnknownHostException e) { // impossible

-		} catch (IOException e) {

-			Log.e(TAG, "IOException initializing server", e);

-		}

-	}

-	

-	public int getPort() {

-		return port;

-	}

-

-	public void start() {

-		thread = new Thread(this, "StreamProxy");

-		thread.start();

-	}

-

-	public void stop() {

-		isRunning = false;

-		thread.interrupt();

-	}

-

-	@Override

-	public void run() {

-		isRunning = true;

-		while (isRunning) {

-			try {

-				Socket client = socket.accept();

-				if (client == null) {

-					continue;

-				}

-				Log.i(TAG, "client connected");

-

-				StreamToMediaPlayerTask task = new StreamToMediaPlayerTask(client);

-				if (task.processRequest()) {

-					new Thread(task).start();

-				}

-

-			} catch (SocketTimeoutException e) {

-				// Do nothing

-			} catch (IOException e) {

-				Log.e(TAG, "Error connecting to client", e);

-			}

-		}

-		Log.i(TAG, "Proxy interrupted. Shutting down.");

-	}

-

-	private class StreamToMediaPlayerTask implements Runnable {

-		DownloadFile downloadFile;

-		File file;

-		Socket client;

-		int cbSkip = 0;

-

-		public StreamToMediaPlayerTask(Socket client) {

-			this.client = client;

-		}

-		

-		private HttpRequest readRequest() {

-			HttpRequest request = null;

-			InputStream is;

-			String firstLine;

-			BufferedReader reader = null;

-			try {

-				is = client.getInputStream();

-				reader = new BufferedReader(new InputStreamReader(is), 8192);

-				firstLine = reader.readLine();

-			} catch (IOException e) {

-				Log.e(TAG, "Error parsing request", e);

-				return request;

-			}

-

-			if (firstLine == null) {

-				Log.i(TAG, "Proxy client closed connection without a request.");

-				return request;

-			}

-

-			StringTokenizer st = new StringTokenizer(firstLine);

-			String method = st.nextToken();

-			String uri = st.nextToken();

-			String realUri = uri.substring(1);

-			Log.i(TAG, realUri);

-			request = new BasicHttpRequest(method, realUri);

-			

-			// Get all of the headers 

-			try {

-				String line;

-				while((line = reader.readLine()) != null && !"".equals(line)) {

-					String headerName = line.substring(0, line.indexOf(':'));

-					String headerValue = line.substring(line.indexOf(": ") + 2);

-					request.addHeader(headerName, headerValue);

-				}

-			} catch(IOException e) {

-				// Don't really care once past first line

-			}

-			

-			return request;

-		}

-

-		public boolean processRequest() {

-			HttpRequest request = readRequest();

-			if (request == null) {

-				return false;

-			}

-			

-			// Read HTTP headers

-			Log.i(TAG, "Processing request");

-

-			String localPath;

-			try {

-				localPath = URLDecoder.decode(request.getRequestLine().getUri(), Constants.UTF_8);

-			} catch (UnsupportedEncodingException e) {

-				Log.e(TAG, "Unsupported encoding", e);

-				return false;

-			}

-			

-			Log.i(TAG, "Processing request for file " + localPath);

-			downloadFile = downloadService.getCurrentPlaying();

-			File partialFile = new File(localPath);

-			if (!partialFile.equals(downloadFile.getPartialFile())) {

-				Log.e(TAG, "File " + localPath + " does not exist");

-				return false;

-			}

-

-			// Use either partial or complete if downloading finished while StreamProxy was idle

-			file = downloadFile.isCompleteFileAvailable() ? downloadFile.getCompleteFile() : downloadFile.getPartialFile();

-			

-			// Try to get range requested

-			Header rangeHeader = request.getFirstHeader("Range");

-

-			if(rangeHeader != null) {

-				String range = rangeHeader.getValue();

-				int index = range.indexOf("=");

-				if(index >= 0) {

-					range = range.substring(index + 1);

-					

-					index = range.indexOf("-");

-					if(index > 0) {

-						range = range.substring(0, index);

-					}

-					

-					cbSkip = Integer.parseInt(range);

-					

-					// Make sure to not try to read past where the file is downloaded

-					if(cbSkip >= file.length()) {

-						return false;

-					}

-				}

-			}

-			

-			return true;

-		}

-

-		@Override

-		public void run() {

-			Log.i(TAG, "Streaming song in background");

-			MusicDirectory.Entry song = downloadFile.getSong();

-			

-			Integer contentLength = downloadFile.getContentLength();

-			if(contentLength == null && downloadFile.isWorkDone()) {

-				contentLength = (int)file.length();

-			}

-

-            // Create HTTP header

-            String headers;

-            if(cbSkip == 0) {

-            	headers = "HTTP/1.0 200 OK\r\n";

-            } else {

-            	headers = "HTTP/1.0 206 OK\r\n;";

-            	headers += "Content-Range: bytes " + cbSkip + "-" + (file.length() - 1) + "/";

-            	if(contentLength == null) {

-            		headers += "*";

-            	} else {

-            		headers += contentLength;

-            	}

-

-				Log.i(TAG, "Streaming starts from: " + cbSkip);

-            }

-            headers += "Content-Type: " + "application/octet-stream" + "\r\n";

-			

-			long fileSize;

-			if(contentLength == null) {

-				fileSize = downloadFile.getBitRate() * ((song.getDuration() != null) ? song.getDuration() : 0) * 1000 / 8;

-			} else {

-				fileSize = contentLength;

-				headers += "Content-Length: " + fileSize + "\r\n";

-			}

-			Log.i(TAG, "Streaming fileSize: " + fileSize);

-            

-            headers += "Connection: close\r\n";

-            headers += "\r\n";

-

-            long cbToSend = fileSize - cbSkip;

-            OutputStream output = null;

-            byte[] buff = new byte[64 * 1024];

-            try {

-                output = new BufferedOutputStream(client.getOutputStream(), 32*1024);                           

-                output.write(headers.getBytes());

-

-				// Make sure to have file lock

-				downloadFile.setPlaying(true);

-				

-				// Loop as long as there's stuff to send

-				while (isRunning && !client.isClosed()) {

-

-					// See if there's more to send

-					int cbSentThisBatch = 0;

-					if (file.exists()) {

-						FileInputStream input = new FileInputStream(file);

-						input.skip(cbSkip);

-						int cbToSendThisBatch = input.available();

-						while (cbToSendThisBatch > 0) {

-							int cbToRead = Math.min(cbToSendThisBatch, buff.length);

-							int cbRead = input.read(buff, 0, cbToRead);

-							if (cbRead == -1) {

-								break;

-							}

-							cbToSendThisBatch -= cbRead;

-							cbToSend -= cbRead;

-							output.write(buff, 0, cbRead);

-							output.flush();

-							cbSkip += cbRead;

-							cbSentThisBatch += cbRead;

-						}

-						input.close();

-					}

-

-					// Done regardless of whether or not it thinks it is

-					if(downloadFile.isWorkDone() && cbSkip >= file.length()) {

-						break;

-					}

-

-					// If we did nothing this batch, block for a second

-					if (cbSentThisBatch == 0) {

-						Log.d(TAG, "Blocking until more data appears (" + cbToSend + ")");

-						Thread.sleep(1000);

-					}

-				}

-

-				// Release file lock, use of stream proxy means nothing else is using it

-				downloadFile.setPlaying(false);

-            }

-            catch (SocketException socketException) {

-                Log.e(TAG, "SocketException() thrown, proxy client has probably closed. This can exit harmlessly");

-

-				// Release file lock, use of stream proxy means nothing else is using it

-				downloadFile.setPlaying(false);

-            }

-            catch (Exception e) {

-                Log.e(TAG, "Exception thrown from streaming task:");

-                Log.e(TAG, e.getClass().getName() + " : " + e.getLocalizedMessage());

-            }

-

-            // Cleanup

-            try {

-                if (output != null) {

-                    output.close();

-                }

-                client.close();

-            }

-            catch (IOException e) {

-                Log.e(TAG, "IOException while cleaning up streaming task:");                

-                Log.e(TAG, e.getClass().getName() + " : " + e.getLocalizedMessage());

-            }

-        }

-	}

-}

diff --git a/src/github/daneren2005/dsub/util/BackgroundTask.java b/src/github/daneren2005/dsub/util/BackgroundTask.java
index b9fe212f..fbeaea74 100644
--- a/src/github/daneren2005/dsub/util/BackgroundTask.java
+++ b/src/github/daneren2005/dsub/util/BackgroundTask.java
@@ -53,7 +53,7 @@ public abstract class BackgroundTask<T> implements ProgressListener {
 	private static Handler handler = null;
 	static {
 		try {
-			handler = new Handler();
+			handler = new Handler(Looper.getMainLooper());
 		} catch(Exception e) {
 			// Not called from main thread
 		}
@@ -69,6 +69,13 @@ public abstract class BackgroundTask<T> implements ProgressListener {
 				thread.start();
 			}
 		}
+		if(handler == null) {
+			try {
+				handler = new Handler(Looper.getMainLooper());
+			} catch(Exception e) {
+				// Not called from main thread
+			}
+		}
     }
 
 	public static void stopThreads() {
diff --git a/src/github/daneren2005/dsub/util/LoadingTask.java b/src/github/daneren2005/dsub/util/LoadingTask.java
index c47931ee..17215abd 100644
--- a/src/github/daneren2005/dsub/util/LoadingTask.java
+++ b/src/github/daneren2005/dsub/util/LoadingTask.java
@@ -52,7 +52,7 @@ public abstract class LoadingTask<T> extends BackgroundTask<T> {
 

 	@Override

     protected boolean isCancelled() {

-        return (tabActivity instanceof SubsonicActivity && tabActivity.isDestroyed()) || cancelled;

+        return (tabActivity instanceof SubsonicActivity && ((SubsonicActivity) tabActivity).isDestroyedCompat()) || cancelled;

     }

 	

 	@Override

diff --git a/src/github/daneren2005/dsub/util/MediaRouteManager.java b/src/github/daneren2005/dsub/util/MediaRouteManager.java
index 4a124402..d41a5516 100644
--- a/src/github/daneren2005/dsub/util/MediaRouteManager.java
+++ b/src/github/daneren2005/dsub/util/MediaRouteManager.java
@@ -42,6 +42,7 @@ public class MediaRouteManager extends MediaRouter.Callback {
 	private MediaRouter router;
 	private MediaRouteSelector selector;
 	private List<MediaRouteProvider> providers = new ArrayList<MediaRouteProvider>();
+	private List<MediaRouteProvider> offlineProviders = new ArrayList<MediaRouteProvider>();
 
 	static {
 		try {
@@ -116,10 +117,22 @@ public class MediaRouteManager extends MediaRouter.Callback {
 		}
 	}
 
+	public void addOfflineProviders() {
+		JukeboxRouteProvider jukeboxProvider = new JukeboxRouteProvider(downloadService);
+		router.addProvider(jukeboxProvider);
+		providers.add(jukeboxProvider);
+		offlineProviders.add(jukeboxProvider);
+	}
+	public void removeOfflineProviders() {
+		for(MediaRouteProvider provider: offlineProviders) {
+			router.removeProvider(provider);
+		}
+	}
+
 	private void addProviders() {
-		JukeboxRouteProvider routeProvider = new JukeboxRouteProvider(downloadService);
-		router.addProvider(routeProvider);
-		providers.add(routeProvider);
+		if(!Util.isOffline(downloadService)) {
+			addOfflineProviders();
+		}
 	}
 	private void buildSelector() {
 		MediaRouteSelector.Builder builder = new MediaRouteSelector.Builder();