Merge branch 'edge' into connection

8 files changed, 95 insertions, 26 deletions

diff --git a/app/src/main/java/github/daneren2005/dsub/fragments/SelectInternetRadioStationFragment.java b/app/src/main/java/github/daneren2005/dsub/fragments/SelectInternetRadioStationFragment.java
index 16082cbd..c39e9f61 100644
--- a/app/src/main/java/github/daneren2005/dsub/fragments/SelectInternetRadioStationFragment.java
+++ b/app/src/main/java/github/daneren2005/dsub/fragments/SelectInternetRadioStationFragment.java
@@ -18,10 +18,18 @@
 */
 package github.daneren2005.dsub.fragments;
 
+import android.util.Log;
 import android.view.Menu;
 import android.view.MenuInflater;
 import android.view.MenuItem;
 
+import java.io.BufferedInputStream;
+import java.io.BufferedReader;
+import java.io.InputStream;
+import java.io.InputStreamReader;
+import java.net.HttpURLConnection;
+import java.net.MalformedURLException;
+import java.net.URL;
 import java.util.ArrayList;
 import java.util.List;
 
@@ -37,6 +45,8 @@ import github.daneren2005.dsub.util.Util;
 import github.daneren2005.dsub.view.UpdateView;
 
 public class SelectInternetRadioStationFragment extends SelectRecyclerFragment<InternetRadioStation> {
+	private static final String TAG = SelectInternetRadioStationFragment.class.getSimpleName();
+
 	@Override
 	public int getOptionsMenu() {
 		return R.menu.abstract_top_menu;
@@ -67,6 +77,7 @@ public class SelectInternetRadioStationFragment extends SelectRecyclerFragment<I
 					return null;
 				}
 
+				getStreamFromPlaylist(item);
 				downloadService.download(item);
 				return null;
 			}
@@ -94,6 +105,40 @@ public class SelectInternetRadioStationFragment extends SelectRecyclerFragment<I
 		return false;
 	}
 
+	private void getStreamFromPlaylist(InternetRadioStation internetRadioStation) {
+		if(internetRadioStation.getStreamUrl() != null && (internetRadioStation.getStreamUrl().indexOf(".m3u") != -1 || internetRadioStation.getStreamUrl().indexOf(".pls") != -1)) {
+			try {
+				URL url = new URL(internetRadioStation.getStreamUrl());
+				HttpURLConnection connection = (HttpURLConnection) url.openConnection();
+
+				try {
+					BufferedReader in = new BufferedReader(new InputStreamReader(connection.getInputStream()));
+					String line;
+					while((line = in.readLine()) != null) {
+						// Not blank line or comment
+						if(line.length() > 0 && line.indexOf('#') != 0) {
+							if(internetRadioStation.getStreamUrl().indexOf(".m3u") != -1) {
+								internetRadioStation.setStreamUrl(line);
+								break;
+							} else {
+								if(line.indexOf("File1=") == 0) {
+									internetRadioStation.setStreamUrl(line.replace("File1=", ""));
+								} else if(line.indexOf("Title1=") == 0) {
+									internetRadioStation.setTitle(line.replace("Title1=", ""));
+								}
+							}
+						}
+					}
+				} finally {
+					connection.disconnect();
+				}
+			} catch (Exception e) {
+				Log.e(TAG, "Failed to get stream data from playlist");
+			}
+
+		}
+	}
+
 	private void displayInternetRadioStationInfo(final InternetRadioStation station) {
 		List<Integer> headers = new ArrayList<>();
 		List<String> details = new ArrayList<>();
diff --git a/app/src/main/java/github/daneren2005/dsub/service/DownloadService.java b/app/src/main/java/github/daneren2005/dsub/service/DownloadService.java
index a6bbc327..1cf482ca 100644
--- a/app/src/main/java/github/daneren2005/dsub/service/DownloadService.java
+++ b/app/src/main/java/github/daneren2005/dsub/service/DownloadService.java
@@ -1469,7 +1469,7 @@ public class DownloadService extends Service {
 			Notifications.hidePlayingNotification(this, this, handler);
 		}
 		if(mRemoteControl != null) {
-			mRemoteControl.setPlaybackState(playerState.getRemoteControlClientPlayState());
+			mRemoteControl.setPlaybackState(playerState.getRemoteControlClientPlayState(), getCurrentPlayingIndex(), size());
 		}
 
 		if (playerState == STARTED) {
@@ -2842,6 +2842,8 @@ public class DownloadService extends Service {
 		final Integer duration = getPlayerDuration();
 		final boolean isSeekable = isSeekable();
 		final int position = getPlayerPosition();
+		final int index = getCurrentPlayingIndex();
+		final int queueSize = size();
 
 		synchronized(onSongChangedListeners) {
 			for (final OnSongChangedListener listener : onSongChangedListeners) {
@@ -2861,7 +2863,7 @@ public class DownloadService extends Service {
 				@Override
 				public void run() {
 					if(mRemoteControl != null) {
-						mRemoteControl.setPlaybackState(playerState.getRemoteControlClientPlayState());
+						mRemoteControl.setPlaybackState(playerState.getRemoteControlClientPlayState(), index, queueSize);
 					}
 				}
 			});
diff --git a/app/src/main/java/github/daneren2005/dsub/util/BackgroundTask.java b/app/src/main/java/github/daneren2005/dsub/util/BackgroundTask.java
index 31e83200..2b0c6279 100644
--- a/app/src/main/java/github/daneren2005/dsub/util/BackgroundTask.java
+++ b/app/src/main/java/github/daneren2005/dsub/util/BackgroundTask.java
@@ -27,6 +27,7 @@ import java.util.List;
 import java.util.concurrent.BlockingQueue;
 import java.util.concurrent.LinkedBlockingQueue;
 import java.util.concurrent.atomic.AtomicBoolean;
+import java.util.concurrent.atomic.AtomicInteger;
 
 import org.xmlpull.v1.XmlPullParserException;
 
@@ -54,6 +55,7 @@ public abstract class BackgroundTask<T> implements ProgressListener {
 	private static final Collection<Thread> threads = Collections.synchronizedCollection(new ArrayList<Thread>());
 	protected static final BlockingQueue<BackgroundTask.Task> queue = new LinkedBlockingQueue<BackgroundTask.Task>(10);
 	private static Handler handler = null;
+	private static AtomicInteger currentlyRunning = new AtomicInteger(0);
 	static {
 		try {
 			handler = new Handler(Looper.getMainLooper());
@@ -71,6 +73,11 @@ public abstract class BackgroundTask<T> implements ProgressListener {
 				threads.add(thread);
 				thread.start();
 			}
+		} else if(currentlyRunning.get() >= threads.size()) {
+			Log.w(TAG, "Emergency add new thread: " + (threads.size() + 1));
+			Thread thread = new Thread(new TaskRunnable(), String.format("BackgroundTask_%d", threads.size()));
+			threads.add(thread);
+			thread.start();
 		}
 		if(handler == null) {
 			try {
@@ -304,22 +311,30 @@ public abstract class BackgroundTask<T> implements ProgressListener {
 		@Override
 		public void run() {
 			Looper.prepare();
+			final Thread currentThread = Thread.currentThread();
 			while(running) {
 				try {
 					Task task = queue.take();
+					currentlyRunning.incrementAndGet();
 					task.execute();
 				} catch(InterruptedException stop) {
 					Log.e(TAG, "Thread died");
 					running = false;
-					threads.remove(Thread.currentThread());
 				} catch(Throwable t) {
 					Log.e(TAG, "Unexpected crash in BackgroundTask thread", t);
+					running = false;
 				}
+
+				currentlyRunning.decrementAndGet();
+			}
+
+			if(threads.contains(currentThread)) {
+				threads.remove(currentThread);
 			}
 		}
 	}
 
-	public static interface OnCancelListener {
+	public interface OnCancelListener {
 		void onCancel();
 	}
 }
diff --git a/app/src/main/java/github/daneren2005/dsub/util/Notifications.java b/app/src/main/java/github/daneren2005/dsub/util/Notifications.java
index 0d4a0f9c..d6a92b07 100644
--- a/app/src/main/java/github/daneren2005/dsub/util/Notifications.java
+++ b/app/src/main/java/github/daneren2005/dsub/util/Notifications.java
@@ -99,7 +99,12 @@ public final class Notifications {
 				public void run() {
 					downloadService.stopForeground(true);
 					showDownloadingNotification(context, downloadService, handler, downloadService.getCurrentDownloading(), downloadService.getBackgroundDownloads().size());
-					downloadService.startForeground(NOTIFICATION_ID_PLAYING, notification);
+
+					try {
+						downloadService.startForeground(NOTIFICATION_ID_PLAYING, notification);
+					} catch(Exception e) {
+						Log.e(TAG, "Failed to start notifications after stopping foreground download");
+					}
 				}
 			});
 		} else {
@@ -107,13 +112,22 @@ public final class Notifications {
 				@Override
 				public void run() {
 					if (playing) {
-						downloadService.startForeground(NOTIFICATION_ID_PLAYING, notification);
+						try {
+							downloadService.startForeground(NOTIFICATION_ID_PLAYING, notification);
+						} catch(Exception e) {
+							Log.e(TAG, "Failed to start notifications while playing");
+						}
 					} else {
 						playShowing = false;
 						persistentPlayingShowing = true;
 						NotificationManager notificationManager = (NotificationManager) context.getSystemService(Context.NOTIFICATION_SERVICE);
 						downloadService.stopForeground(false);
-						notificationManager.notify(NOTIFICATION_ID_PLAYING, notification);
+
+						try {
+							notificationManager.notify(NOTIFICATION_ID_PLAYING, notification);
+						} catch(Exception e) {
+							Log.e(TAG, "Failed to start notifications while paused");
+						}
 					}
 				}
 			});
diff --git a/app/src/main/java/github/daneren2005/dsub/util/compat/RemoteControlClientBase.java b/app/src/main/java/github/daneren2005/dsub/util/compat/RemoteControlClientBase.java
index 1f7035dc..4f9a27f0 100644
--- a/app/src/main/java/github/daneren2005/dsub/util/compat/RemoteControlClientBase.java
+++ b/app/src/main/java/github/daneren2005/dsub/util/compat/RemoteControlClientBase.java
@@ -29,7 +29,7 @@ public abstract class RemoteControlClientBase {
 	
 	public abstract void register(final Context context, final ComponentName mediaButtonReceiverComponent);
 	public abstract void unregister(final Context context);
-	public abstract void setPlaybackState(int state);
+	public abstract void setPlaybackState(int state, int index, int queueSize);
 	public abstract void updateMetadata(Context context, MusicDirectory.Entry currentSong);
 	public abstract void metadataChanged(MusicDirectory.Entry currentSong);
 	public abstract void updateAlbumArt(MusicDirectory.Entry currentSong, Bitmap bitmap);
diff --git a/app/src/main/java/github/daneren2005/dsub/util/compat/RemoteControlClientICS.java b/app/src/main/java/github/daneren2005/dsub/util/compat/RemoteControlClientICS.java
index 2a06e798..74076afb 100644
--- a/app/src/main/java/github/daneren2005/dsub/util/compat/RemoteControlClientICS.java
+++ b/app/src/main/java/github/daneren2005/dsub/util/compat/RemoteControlClientICS.java
@@ -54,7 +54,7 @@ public class RemoteControlClientICS extends RemoteControlClientBase {
 		audioManager.unregisterRemoteControlClient(mRemoteControl);
 	}
 	
-	public void setPlaybackState(final int state) {
+	public void setPlaybackState(final int state, int index, int queueSize) {
 		if(mRemoteControl == null) {
 			return;
 		}
diff --git a/app/src/main/java/github/daneren2005/dsub/util/compat/RemoteControlClientJB.java b/app/src/main/java/github/daneren2005/dsub/util/compat/RemoteControlClientJB.java
index e61e9a47..d10c8594 100644
--- a/app/src/main/java/github/daneren2005/dsub/util/compat/RemoteControlClientJB.java
+++ b/app/src/main/java/github/daneren2005/dsub/util/compat/RemoteControlClientJB.java
@@ -1,17 +1,10 @@
 package github.daneren2005.dsub.util.compat;
 
-import github.daneren2005.dsub.domain.MusicDirectory;
-import github.daneren2005.dsub.util.ImageLoader;
 import android.annotation.TargetApi;
-import android.app.PendingIntent;
 import android.content.ComponentName;
 import android.content.Context;
-import android.content.Intent;
-import android.media.AudioManager;
-import android.media.MediaMetadataRetriever;
 import android.media.RemoteControlClient;
-import github.daneren2005.dsub.activity.SubsonicActivity;
-import github.daneren2005.dsub.service.DownloadService;
+
 import github.daneren2005.dsub.util.SilentBackgroundTask;
 
 @TargetApi(18)
@@ -36,13 +29,13 @@ public class RemoteControlClientJB extends RemoteControlClientICS {
 						return null;
 					}
 				}.execute();
-				setPlaybackState(RemoteControlClient.PLAYSTATE_PLAYING);
+				setPlaybackState(RemoteControlClient.PLAYSTATE_PLAYING, 0, 0);
 			}
 		});
 	}
 	
 	@Override
-	public void setPlaybackState(final int state) {
+	public void setPlaybackState(final int state, int index, int queueSize) {
 		if(mRemoteControl == null) {
 			return;
 		}
diff --git a/app/src/main/java/github/daneren2005/dsub/util/compat/RemoteControlClientLP.java b/app/src/main/java/github/daneren2005/dsub/util/compat/RemoteControlClientLP.java
index df468155..d666afb2 100644
--- a/app/src/main/java/github/daneren2005/dsub/util/compat/RemoteControlClientLP.java
+++ b/app/src/main/java/github/daneren2005/dsub/util/compat/RemoteControlClientLP.java
@@ -39,7 +39,6 @@ import android.support.v7.media.MediaRouter;
 import android.util.Log;
 import android.view.KeyEvent;
 
-import java.io.Serializable;
 import java.util.ArrayList;
 import java.util.List;
 
@@ -50,7 +49,6 @@ import github.daneren2005.dsub.domain.Bookmark;
 import github.daneren2005.dsub.domain.MusicDirectory;
 import github.daneren2005.dsub.domain.MusicDirectory.Entry;
 import github.daneren2005.dsub.domain.Playlist;
-import github.daneren2005.dsub.domain.PodcastEpisode;
 import github.daneren2005.dsub.domain.SearchCritera;
 import github.daneren2005.dsub.domain.SearchResult;
 import github.daneren2005.dsub.service.DownloadFile;
@@ -123,8 +121,12 @@ public class RemoteControlClientLP extends RemoteControlClientBase {
 		mediaSession.release();
 	}
 
+	private void setPlaybackState(int state) {
+		setPlaybackState(state, downloadService.getCurrentPlayingIndex(), downloadService.size());
+	}
+
 	@Override
-	public void setPlaybackState(int state) {
+	public void setPlaybackState(int state, int index, int queueSize) {
 		PlaybackState.Builder builder = new PlaybackState.Builder();
 
 		int newState = PlaybackState.STATE_NONE;
@@ -156,7 +158,7 @@ public class RemoteControlClientLP extends RemoteControlClientBase {
 			isSong = entry.isSong();
 		}
 
-		builder.setActions(getPlaybackActions(isSong));
+		builder.setActions(getPlaybackActions(isSong, index, queueSize));
 
 		if(entry != null) {
 			addCustomActions(entry, builder);
@@ -240,14 +242,12 @@ public class RemoteControlClientLP extends RemoteControlClientBase {
 		return mediaSession;
 	}
 
-	protected long getPlaybackActions(boolean isSong) {
+	protected long getPlaybackActions(boolean isSong, int currentIndex, int size) {
 		long actions = PlaybackState.ACTION_PLAY |
 				PlaybackState.ACTION_PAUSE |
 				PlaybackState.ACTION_SEEK_TO |
 				PlaybackState.ACTION_SKIP_TO_QUEUE_ITEM;
 
-		int currentIndex = downloadService.getCurrentPlayingIndex();
-		int size = downloadService.size();
 		if(isSong) {
 			if (currentIndex > 0) {
 				actions |= PlaybackState.ACTION_SKIP_TO_PREVIOUS;