-
Notifications
You must be signed in to change notification settings - Fork 13
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Merge branch 'improve-player-testing-setup' into add-ads-player-tests
- Loading branch information
Showing
31 changed files
with
1,416 additions
and
1,913 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
106 changes: 106 additions & 0 deletions
106
android/src/main/java/com/bitmovin/player/reactnative/BitmovinBaseModule.kt
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,106 @@ | ||
| package com.bitmovin.player.reactnative | ||
|
|
||
| import android.util.Log | ||
| import com.bitmovin.player.api.Player | ||
| import com.bitmovin.player.api.source.Source | ||
| import com.bitmovin.player.reactnative.extensions.drmModule | ||
| import com.bitmovin.player.reactnative.extensions.offlineModule | ||
| import com.bitmovin.player.reactnative.extensions.playerModule | ||
| import com.bitmovin.player.reactnative.extensions.sourceModule | ||
| import com.bitmovin.player.reactnative.extensions.uiManagerModule | ||
| import com.facebook.react.bridge.* | ||
| import com.facebook.react.uimanager.UIManagerModule | ||
|
|
||
| private const val MODULE_NAME = "BitmovinBaseModule" | ||
|
|
||
| /** | ||
| * Base for Bitmovin React modules. | ||
| * | ||
| * Provides many helper methods that are promise exception safe. | ||
| * | ||
| * In general, code should not throw while resolving a [Promise]. Instead, [Promise.reject] should be used. | ||
| * This doesn't match Kotlin's error style, which uses exception. The helper methods in this class, provide such | ||
| * convenience, they can only be called in a context that will catch any Exception and reject the [Promise]. | ||
| * | ||
| */ | ||
| abstract class BitmovinBaseModule( | ||
| protected val context: ReactApplicationContext, | ||
| ) : ReactContextBaseJavaModule(context) { | ||
| /** | ||
| * Runs [block] on the UI thread with [UIManagerModule.addUIBlock] and [TPromise.resolve] [this] with | ||
| * its return value. If [block] throws, [Promise.reject] [this] with the [Throwable]. | ||
| */ | ||
| protected inline fun <T, R : T> TPromise<T>.resolveOnUiThread( | ||
| crossinline block: RejectPromiseOnExceptionBlock.() -> R, | ||
| ) { | ||
| val uiManager = runAndRejectOnException { uiManager } ?: return | ||
| uiManager.addUIBlock { | ||
| resolveOnCurrentThread { block() } | ||
| } | ||
| } | ||
|
|
||
| protected val RejectPromiseOnExceptionBlock.playerModule: PlayerModule get() = context.playerModule | ||
| ?: throw IllegalArgumentException("PlayerModule not found") | ||
|
|
||
| protected val RejectPromiseOnExceptionBlock.uiManager: UIManagerModule get() = context.uiManagerModule | ||
| ?: throw IllegalStateException("UIManager not found") | ||
|
|
||
| protected val RejectPromiseOnExceptionBlock.sourceModule: SourceModule get() = context.sourceModule | ||
| ?: throw IllegalStateException("SourceModule not found") | ||
|
|
||
| protected val RejectPromiseOnExceptionBlock.offlineModule: OfflineModule get() = context.offlineModule | ||
| ?: throw IllegalStateException("OfflineModule not found") | ||
|
|
||
| protected val RejectPromiseOnExceptionBlock.drmModule: DrmModule get() = context.drmModule | ||
| ?: throw IllegalStateException("DrmModule not found") | ||
|
|
||
| fun RejectPromiseOnExceptionBlock.getPlayer( | ||
| nativeId: NativeId, | ||
| playerModule: PlayerModule = this.playerModule, | ||
| ): Player = playerModule.getPlayerOrNull(nativeId) ?: throw IllegalArgumentException("Invalid PlayerId $nativeId") | ||
|
|
||
| fun RejectPromiseOnExceptionBlock.getSource( | ||
| nativeId: NativeId, | ||
| sourceModule: SourceModule = this.sourceModule, | ||
| ): Source = sourceModule.getSourceOrNull(nativeId) ?: throw IllegalArgumentException("Invalid SourceId $nativeId") | ||
| } | ||
|
|
||
| /** Run [block], returning it's return value. If [block] throws, [Promise.reject] [this] and return null. */ | ||
| inline fun <T, R> TPromise<T>.runAndRejectOnException(block: RejectPromiseOnExceptionBlock.() -> R): R? = try { | ||
| RejectPromiseOnExceptionBlock.block() | ||
| } catch (e: Exception) { | ||
| reject(e) | ||
| null | ||
| } | ||
|
|
||
| /** | ||
| * [TPromise.resolve] [this] with [block] return value. | ||
| * If [block] throws, [Promise.reject] [this] with the [Throwable]. | ||
| */ | ||
| inline fun <T> TPromise<T>.resolveOnCurrentThread( | ||
| crossinline block: RejectPromiseOnExceptionBlock.() -> T, | ||
| ): Unit = runAndRejectOnException { this@resolveOnCurrentThread.resolve(block()) } ?: Unit | ||
|
|
||
| /** Receiver of code that can safely throw when resolving a [Promise]. */ | ||
| object RejectPromiseOnExceptionBlock | ||
|
|
||
| /** Compile time wrapper for Promises to type check the resolved type [T]. */ | ||
| @JvmInline | ||
| value class TPromise<T>(val promise: Promise) { | ||
| // Promise only support built-in types. Functions that return [Unit] must resolve to `null`. | ||
| fun resolve(value: T): Unit = promise.resolve(value.takeUnless { it is Unit }) | ||
| fun reject(throwable: Throwable) { | ||
| Log.e(MODULE_NAME, "Failed to execute Bitmovin method", throwable) | ||
| promise.reject(throwable) | ||
| } | ||
| } | ||
|
|
||
| inline val Promise.int get() = TPromise<Int>(this) | ||
| inline val Promise.unit get() = TPromise<Unit>(this) | ||
| inline val Promise.string get() = TPromise<String>(this) | ||
| inline val Promise.double get() = TPromise<Double>(this) | ||
| inline val Promise.float get() = TPromise<Float>(this) | ||
| inline val Promise.bool get() = TPromise<Boolean>(this) | ||
| inline val Promise.map get() = TPromise<ReadableMap>(this) | ||
| inline val Promise.array get() = TPromise<ReadableArray>(this) | ||
| inline val <T> TPromise<T>.nullable get() = TPromise<T?>(promise) |
44 changes: 14 additions & 30 deletions
44
android/src/main/java/com/bitmovin/player/reactnative/BitmovinCastManagerModule.kt
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Oops, something went wrong.