Geoffrey Métais
8 years ago
9 changed files with 169 additions and 27 deletions
@ -0,0 +1,2 @@ |
|||
<?xml version="1.0" encoding="utf-8"?> |
|||
<tv-input/> |
|||
@ -0,0 +1,116 @@ |
|||
package org.videolan.vlc |
|||
|
|||
|
|||
import android.content.Context |
|||
import android.media.tv.TvInputManager |
|||
import android.media.tv.TvInputManager.VIDEO_UNAVAILABLE_REASON_TUNING |
|||
import android.media.tv.TvInputService |
|||
import android.net.Uri |
|||
import android.util.Log |
|||
import android.view.Surface |
|||
import kotlinx.coroutines.experimental.CoroutineStart |
|||
import kotlinx.coroutines.experimental.android.UI |
|||
import kotlinx.coroutines.experimental.launch |
|||
import kotlinx.coroutines.experimental.withContext |
|||
import org.videolan.libvlc.Media |
|||
import org.videolan.libvlc.MediaPlayer |
|||
import org.videolan.medialibrary.Medialibrary |
|||
import org.videolan.vlc.media.MediaPlayerEventListener |
|||
import org.videolan.vlc.media.PlayerController |
|||
import org.videolan.vlc.util.VLCIO |
|||
import org.videolan.vlc.util.VLCInstance |
|||
import org.videolan.vlc.util.random |
|||
import java.io.IOException |
|||
import kotlin.coroutines.experimental.suspendCoroutine |
|||
|
|||
private const val TAG = "PreviewInputService" |
|||
|
|||
class PreviewVideoInputService : TvInputService() { |
|||
|
|||
override fun onCreateSession(inputId: String): TvInputService.Session? { |
|||
return PreviewSession(this) |
|||
} |
|||
|
|||
private inner class PreviewSession(private val context: Context |
|||
) : TvInputService.Session(context), MediaPlayerEventListener { |
|||
|
|||
val player by lazy(LazyThreadSafetyMode.NONE) { PlayerController() } |
|||
|
|||
override fun onRelease() { |
|||
player.release() |
|||
} |
|||
|
|||
override fun onTune(uri: Uri): Boolean { |
|||
notifyVideoUnavailable(VIDEO_UNAVAILABLE_REASON_TUNING) |
|||
val id = uri.lastPathSegment.toLong() |
|||
launch(UI, CoroutineStart.UNDISPATCHED) { |
|||
val mw = getMedia(id) |
|||
if (mw == null) { |
|||
Log.w(TAG, "Could not find video $id") |
|||
notifyVideoUnavailable(TvInputManager.VIDEO_UNAVAILABLE_REASON_UNKNOWN) |
|||
return@launch |
|||
} |
|||
try { |
|||
val media = Media(VLCInstance.get(), mw.uri) |
|||
val start = if (mw.length <= 0L) 0 else mw.length.random()/1000 |
|||
media.addOption(":start-time=$start") |
|||
player.getVout()?.apply { |
|||
setVideoSurface(surface, null) |
|||
attachViews(null) |
|||
setWindowSize(width, height) |
|||
} |
|||
player.setVideoAspectRatio(null) |
|||
player.setVideoScale(0f) |
|||
player.startPlayback(media, this@PreviewSession) |
|||
notifyVideoAvailable() |
|||
} catch (e: IOException) { |
|||
Log.e(TAG, "Could not prepare media player", e) |
|||
notifyVideoUnavailable(TvInputManager.VIDEO_UNAVAILABLE_REASON_UNKNOWN) |
|||
} |
|||
} |
|||
return true |
|||
} |
|||
|
|||
private suspend fun getMedia(id: Long) = withContext(VLCIO) { |
|||
val ml = Medialibrary.getInstance() |
|||
if (ml.isInitiated) ml.getMedia(id) |
|||
else suspendCoroutine { continuation -> |
|||
ml.addOnMedialibraryReadyListener(object : Medialibrary.OnMedialibraryReadyListener { |
|||
override fun onMedialibraryReady() { |
|||
ml.removeOnMedialibraryReadyListener(this) |
|||
continuation.resume(ml.getMedia(id)) |
|||
} |
|||
override fun onMedialibraryIdle() {} |
|||
|
|||
}) |
|||
this@PreviewVideoInputService.startMedialibrary(false, false, false) |
|||
} |
|||
} |
|||
|
|||
private var width = 0 |
|||
private var height = 0 |
|||
private lateinit var surface: Surface |
|||
override fun onSetSurface(surface: Surface?): Boolean { |
|||
if (surface == null) return false |
|||
this.surface = surface |
|||
return true |
|||
} |
|||
|
|||
override fun onOverlayViewSizeChanged(width: Int, height: Int) { |
|||
this.width = width |
|||
this.height = height |
|||
} |
|||
|
|||
override fun onSetStreamVolume(volume: Float) { |
|||
player.setVolume((volume*100).toInt()) |
|||
} |
|||
|
|||
override fun onSetCaptionEnabled(enabled: Boolean) {} |
|||
|
|||
override suspend fun onEvent(event: MediaPlayer.Event) { |
|||
when(event.type) { |
|||
MediaPlayer.Event.EndReached -> player.release() |
|||
} |
|||
} |
|||
} |
|||
} |
|||
Loading…
Reference in new issue