Revert "[Playback] Code Cleanup"

This reverts commit 7efbbc3f11.

app/src/main/java/code/name/monkey/retromusic/service/CastPlayer.kt

@@ -33,15 +33,19 @@ class CastPlayer(castSession: CastSession) : Playback,
 
     override var callbacks: Playback.PlaybackCallbacks? = null
 
-    override fun setDataSource(song: Song, force: Boolean): Boolean {
+    override fun setDataSource(
-        return try {
+        song: Song,
+        force: Boolean,
+        completion: (success: Boolean) -> Unit,
+    ) {
+        try {
             val mediaLoadOptions =
                 MediaLoadOptions.Builder().setPlayPosition(0).setAutoplay(true).build()
             remoteMediaClient?.load(song.toMediaInfo()!!, mediaLoadOptions)
-            true
+            completion(true)
         } catch (e: Exception) {
             e.printStackTrace()
-            false
+            completion(false)
         }
     }
 

app/src/main/java/code/name/monkey/retromusic/service/CrossFadePlayer.kt

@@ -120,17 +120,25 @@ class CrossFadePlayer(context: Context) : LocalPlayback(context) {
     override val isPlaying: Boolean
         get() = mIsInitialized && getCurrentPlayer()?.isPlaying == true
 
-    override fun setDataSource(song: Song, force: Boolean): Boolean {
+    override fun setDataSource(
+        song: Song,
+        force: Boolean,
+        completion: (success: Boolean) -> Unit,
+    ) {
         if (force) hasDataSource = false
         mIsInitialized = false
         /* We've already set DataSource if initialized is true in setNextDataSource */
-        return if (!hasDataSource) {
+        if (!hasDataSource) {
-            mIsInitialized = setDataSourceImpl(getCurrentPlayer()!!, song.uri.toString())
+            getCurrentPlayer()?.let {
+                setDataSourceImpl(it, song.uri.toString()) { success ->
+                    mIsInitialized = success
+                    completion(success)
+                }
+            }
             hasDataSource = true
-            mIsInitialized
         } else {
+            completion(true)
             mIsInitialized = true
-            true
         }
     }
 
@@ -285,8 +293,8 @@ class CrossFadePlayer(context: Context) : LocalPlayback(context) {
                 val nextSong = MusicPlayerRemote.nextSong
                 // Switch to other player (Crossfade) only if next song exists
                 if (nextSong != null) {
-                    if (setDataSourceImpl(player, nextSong.uri.toString())) {
+                    setDataSourceImpl(player, nextSong.uri.toString()) { success ->
-                        switchPlayer()
+                        if (success) switchPlayer()
                     }
                 }
             }

app/src/main/java/code/name/monkey/retromusic/service/LocalPlayback.kt

@@ -109,10 +109,13 @@ abstract class LocalPlayback(val context: Context) : Playback, MediaPlayer.OnErr
      * @param path The path of the file, or the http/rtsp URL of the stream you want to play
      * @return True if the <code>player</code> has been prepared and is ready to play, false otherwise
      */
-    fun setDataSourceImpl(player: MediaPlayer, path: String): Boolean {
+    fun setDataSourceImpl(
-        try {
+        player: MediaPlayer,
+        path: String,
+        completion: (success: Boolean) -> Unit,
+    ) {
         player.reset()
-            player.setOnPreparedListener(null)
+        try {
             if (path.startsWith("content://")) {
                 player.setDataSource(context, path.toUri())
             } else {
@@ -123,14 +126,17 @@ abstract class LocalPlayback(val context: Context) : Playback, MediaPlayer.OnErr
                 .setContentType(AudioAttributes.CONTENT_TYPE_MUSIC)
                 .build()
             )
-            player.prepare()
+            player.setOnPreparedListener {
+                player.setOnPreparedListener(null)
+                completion(true)
+            }
+            player.prepareAsync()
         } catch (e: Exception) {
+            completion(false)
             e.printStackTrace()
-            return false
         }
         player.setOnCompletionListener(this)
         player.setOnErrorListener(this)
-        return true
     }
 
     private fun unregisterBecomingNoisyReceiver() {

app/src/main/java/code/name/monkey/retromusic/service/MultiPlayer.kt

@@ -46,13 +46,19 @@ class MultiPlayer(context: Context) : LocalPlayback(context) {
      * @param song The song object you want to play
      * @return True if the `player` has been prepared and is ready to play, false otherwise
      */
-    override fun setDataSource(song: Song, force: Boolean): Boolean {
+    override fun setDataSource(
+        song: Song,
+        force: Boolean,
+        completion: (success: Boolean) -> Unit,
+    ) {
         isInitialized = false
-        isInitialized = setDataSourceImpl(mCurrentMediaPlayer, song.uri.toString())
+        setDataSourceImpl(mCurrentMediaPlayer, song.uri.toString()) { success ->
+            isInitialized = success
             if (isInitialized) {
                 setNextDataSource(null)
             }
-        return isInitialized
+            completion(isInitialized)
+        }
     }
 
     /**
@@ -80,7 +86,8 @@ class MultiPlayer(context: Context) : LocalPlayback(context) {
             mNextMediaPlayer = MediaPlayer()
             mNextMediaPlayer?.setWakeMode(context, PowerManager.PARTIAL_WAKE_LOCK)
             mNextMediaPlayer?.audioSessionId = audioSessionId
-            if (setDataSourceImpl(mNextMediaPlayer!!, path)) {
+            setDataSourceImpl(mNextMediaPlayer!!, path) { success ->
+                if (success) {
                     try {
                         mCurrentMediaPlayer.setNextMediaPlayer(mNextMediaPlayer)
                     } catch (e: IllegalArgumentException) {
@@ -104,6 +111,7 @@ class MultiPlayer(context: Context) : LocalPlayback(context) {
                 }
             }
         }
+    }
 
     /**
      * Starts or resumes playback.

app/src/main/java/code/name/monkey/retromusic/service/MusicService.kt

@@ -117,11 +117,6 @@ class MusicService : MediaBrowserServiceCompat(),
     private var trackEndedByCrossfade = false
     private val serviceScope = CoroutineScope(Job() + Main)
 
-    // Every chromecast method needs to run on main thread or you are greeted with IllegalStateException
-    // So it will use Main dispatcher
-    // And by using Default dispatcher for local playback we are reducing the burden from main thread
-    private val playerDispatcher get() = if (playbackManager.isLocalPlayback) Default else Main
-
     @JvmField
     var position = -1
     private val appWidgetBig = AppWidgetBig.instance
@@ -441,9 +436,12 @@ class MusicService : MediaBrowserServiceCompat(),
     }
 
     private fun setPosition(position: Int) {
-        openTrackAndPrepareNextAt(position)
+        openTrackAndPrepareNextAt(position) { success ->
+            if (success) {
                 notifyChange(PLAY_STATE_CHANGED)
             }
+        }
+    }
 
     private fun getPreviousPosition(force: Boolean): Int {
         var newPosition = getPosition() - 1
@@ -757,15 +755,16 @@ class MusicService : MediaBrowserServiceCompat(),
     }
 
     @Synchronized
-    fun openTrackAndPrepareNextAt(position: Int): Boolean {
+    fun openTrackAndPrepareNextAt(position: Int, completion: (success: Boolean) -> Unit) {
         this.position = position
-        val prepared = openCurrent()
+        openCurrent { success ->
-        if (prepared) {
+            completion(success)
-            prepareNextImpl()
-        }
             notifyChange(META_CHANGED)
             notHandledMetaChangedForCurrentTrack = false
-        return prepared
+            if (success) {
+                prepareNextImpl()
+            }
+        }
     }
 
     fun pause(force: Boolean = false) {
@@ -794,11 +793,16 @@ class MusicService : MediaBrowserServiceCompat(),
     }
 
     fun playSongAt(position: Int) {
-        serviceScope.launch(playerDispatcher) {
+        // Every chromecast method needs to run on main thread or you are greeted with IllegalStateException
-            if (openTrackAndPrepareNextAt(position)) {
+        // So it will use Main dispatcher
+        // And by using Default dispatcher for local playback we are reduce the burden of main thread
+        serviceScope.launch(if(playbackManager.isLocalPlayback) Default else Main) {
+            openTrackAndPrepareNextAt(position) { success ->
+                if (success) {
                     play()
                 } else {
-                showToast(R.string.unplayable_file)
+                    showToast(resources.getString(R.string.unplayable_file))
+                }
             }
         }
     }
@@ -913,14 +917,15 @@ class MusicService : MediaBrowserServiceCompat(),
                     originalPlayingQueue = ArrayList(restoredOriginalQueue)
                     playingQueue = ArrayList(restoredQueue)
                     position = restoredPosition
-                    withContext(playerDispatcher) {
+                    withContext(Main) {
-                        openCurrent()
+                        openCurrent {
                             prepareNext()
                             if (restoredPositionInTrack > 0) {
                                 seek(restoredPositionInTrack)
                             }
                             notHandledMetaChangedForCurrentTrack = true
                             sendChangeInternal(META_CHANGED)
+                        }
                         if (receivedHeadsetConnected) {
                             play()
                             receivedHeadsetConnected = false
@@ -1164,18 +1169,15 @@ class MusicService : MediaBrowserServiceCompat(),
     }
 
     @Synchronized
-    private fun openCurrent(): Boolean {
+    private fun openCurrent(completion: (success: Boolean) -> Unit) {
         val force = if (!trackEndedByCrossfade) {
             true
         } else {
             trackEndedByCrossfade = false
             false
         }
-        return try {
+        playbackManager.setDataSource(currentSong, force) { success ->
-            playbackManager.setDataSource(currentSong, force)
+            completion(success)
-        } catch (e: Exception) {
-            e.printStackTrace()
-            false
         }
     }
 
@@ -1189,12 +1191,14 @@ class MusicService : MediaBrowserServiceCompat(),
 
     private fun restorePlaybackState(wasPlaying: Boolean, progress: Int) {
         playbackManager.setCallbacks(this)
-        if (openTrackAndPrepareNextAt(position)) {
+        openTrackAndPrepareNextAt(position) { success ->
+            if (success) {
                 seek(progress)
                 if (wasPlaying) {
                     play()
                 }
             }
+        }
         playbackManager.setCrossFadeDuration(crossFadeDuration)
     }
 

app/src/main/java/code/name/monkey/retromusic/service/PlaybackManager.kt

@@ -86,8 +86,12 @@ class PlaybackManager(val context: Context) {
 
     fun seek(millis: Int): Int = playback!!.seek(millis)
 
-    fun setDataSource(song: Song, force: Boolean): Boolean {
+    fun setDataSource(
-        return playback?.setDataSource(song, force) == true
+        song: Song,
+        force: Boolean,
+        completion: (success: Boolean) -> Unit,
+    ) {
+        playback?.setDataSource(song, force, completion)
     }
 
     fun setNextDataSource(trackUri: String) {

app/src/main/java/code/name/monkey/retromusic/service/playback/Playback.kt

@@ -25,7 +25,9 @@ interface Playback {
 
     val audioSessionId: Int
 
-    fun setDataSource(song: Song, force: Boolean):Boolean
+    fun setDataSource(
+        song: Song, force: Boolean, completion: (success: Boolean) -> Unit,
+    )
 
     fun setNextDataSource(path: String?)