LiveStreamViewManager.kt

package video.api.reactnative.livestream

import android.util.Log
import com.facebook.react.bridge.ReactMethod
import com.facebook.react.bridge.ReadableMap
import com.facebook.react.uimanager.ThemedReactContext
import com.facebook.react.uimanager.UIManagerHelper
import com.facebook.react.uimanager.annotations.ReactProp
import video.api.reactnative.livestream.events.OnConnectionFailedEvent
import video.api.reactnative.livestream.events.OnConnectionSuccessEvent
import video.api.reactnative.livestream.events.OnDisconnectEvent
import video.api.reactnative.livestream.events.OnPermissionsDeniedEvent
import video.api.reactnative.livestream.events.OnStartStreamingEvent
import video.api.reactnative.livestream.utils.getCameraFacing
import video.api.reactnative.livestream.utils.toAudioConfig
import video.api.reactnative.livestream.utils.toVideoConfig


class LiveStreamViewManager : LiveStreamViewManagerSpec<LiveStreamView>() {
  override fun getName() = NAME

  override fun createViewInstance(reactContext: ThemedReactContext): LiveStreamView {
    val view = LiveStreamView(reactContext)
    view.onConnectionSuccess = {
      UIManagerHelper.getEventDispatcherForReactTag(reactContext, view.id)?.dispatchEvent(
        OnConnectionSuccessEvent(view.id)
      ) ?: Log.e(NAME, "No event dispatcher for react tag ${view.id}")
    }
    view.onConnectionFailed = { reason ->
      UIManagerHelper.getEventDispatcherForReactTag(reactContext, view.id)?.dispatchEvent(
        OnConnectionFailedEvent(view.id, reason)
      ) ?: Log.e(NAME, "No event dispatcher for react tag ${view.id}")
    }
    view.onDisconnected = {
      UIManagerHelper.getEventDispatcherForReactTag(reactContext, view.id)?.dispatchEvent(
        OnDisconnectEvent(view.id)
      ) ?: Log.e(NAME, "No event dispatcher for react tag ${view.id}")
    }
    view.onPermissionsDenied = { permissions ->
      UIManagerHelper.getEventDispatcherForReactTag(reactContext, view.id)?.dispatchEvent(
        OnPermissionsDeniedEvent(view.id, permissions)
      ) ?: Log.e(NAME, "No event dispatcher for react tag ${view.id}")
    }
    view.onStartStreaming = { requestId, result, error ->
      UIManagerHelper.getEventDispatcherForReactTag(reactContext, view.id)?.dispatchEvent(
        OnStartStreamingEvent(view.id, requestId, result, error)
      ) ?: Log.e(NAME, "No event dispatcher for react tag ${view.id}")
    }
    return view
  }

  override fun getExportedCustomDirectEventTypeConstants(): Map<String, *> {
    val eventsMap = super.getExportedCustomDirectEventTypeConstants() ?: mutableMapOf()
    eventsMap.putAll(ViewProps.Events.toEventsMap())
    return eventsMap
  }

  @ReactProp(name = ViewProps.VIDEO_CONFIG)
  override fun setVideo(view: LiveStreamView, value: ReadableMap?) {
    if (value == null) {
      throw IllegalArgumentException("Video config cannot be null")
    }
    if (view.isStreaming) {
      view.videoBitrate = value.getInt(ViewProps.BITRATE)
    } else {
      view.videoConfig = value.toVideoConfig()
    }
  }

  @ReactProp(name = ViewProps.AUDIO_CONFIG)
  override fun setAudio(view: LiveStreamView, value: ReadableMap?) {
    if (value == null) {
      throw IllegalArgumentException("Audio config cannot be null")
    }
    view.audioConfig = value.toAudioConfig()
  }

  @ReactProp(name = ViewProps.CAMERA)
  override fun setCamera(view: LiveStreamView, value: String?) {
    value?.let {
      view.camera = it.getCameraFacing()
    }
  }

  @ReactProp(name = ViewProps.IS_MUTED)
  override fun setIsMuted(view: LiveStreamView, value: Boolean) {
    view.isMuted = value
  }

  @ReactProp(name = ViewProps.ZOOM_ENABLED)
  override fun setEnablePinchedZoom(view: LiveStreamView, value: Boolean) {
    view.enablePinchedZoom = value
  }

  @ReactProp(name = ViewProps.ZOOM_RATIO)
  override fun setZoomRatio(view: LiveStreamView, value: Float) {
    view.zoomRatio = value
  }

  @ReactMethod
  override fun startStreaming(
    view: LiveStreamView,
    requestId: Int,
    streamKey: String,
    url: String?
  ) {
    view.startStreaming(requestId, streamKey, url)
  }

  @ReactMethod
  override fun stopStreaming(view: LiveStreamView) {
    view.stopStreaming()
  }

  @ReactMethod
  override fun setZoomRatioCommand(view: LiveStreamView, zoomRatio: Float) {
    view.zoomRatio = zoomRatio
  }

  override fun onDropViewInstance(view: LiveStreamView) {
    super.onDropViewInstance(view)
    view.close()
  }

  companion object {
    const val NAME = "ApiVideoLiveStreamView"
  }
}