package com.reactnativertmppublisher;

import android.util.Log;
import android.view.SurfaceView;
import android.view.View;

import androidx.annotation.NonNull;
import androidx.annotation.Nullable;

import com.facebook.react.common.MapBuilder;
import com.facebook.react.uimanager.SimpleViewManager;
import com.facebook.react.uimanager.ThemedReactContext;
import com.facebook.react.uimanager.annotations.ReactProp;
import com.reactnativertmppublisher.modules.Publisher;
import com.reactnativertmppublisher.modules.SurfaceHolderHelper;
import com.facebook.react.bridge.ReadableArray;
import com.facebook.react.bridge.ReadableMap;
import com.reactnativertmppublisher.modules.VideoSettings;

import java.util.ArrayList;
import java.util.List;
import java.util.Map;

public class RTMPManager extends SimpleViewManager<SurfaceView> {
  //TODO: "Do not place Android context classes in static fields (static reference to Publisher which has field _surfaceView pointing to SurfaceView); this is a memory leak"
  public static Publisher publisher;
  public final String REACT_CLASS_NAME = "RTMPPublisher";
  SurfaceView surfaceView;
  private ThemedReactContext _reactContext;

  View.OnLayoutChangeListener onLayoutChangeListener = new View.OnLayoutChangeListener() {
    @Override
    public void onLayoutChange(@NonNull View view, int i, int i1, int i2, int i3, int i4, int i5, int i6, int i7) {

    }
  };

  @NonNull
  @Override
  public String getName() {
    return REACT_CLASS_NAME;
  }

  @NonNull
  @Override
  protected SurfaceView createViewInstance(@NonNull ThemedReactContext reactContext) {
    _reactContext = reactContext;
    surfaceView = new SurfaceView(_reactContext);
    publisher = new Publisher(_reactContext, surfaceView);
    surfaceView.addOnLayoutChangeListener(onLayoutChangeListener);

    SurfaceHolderHelper surfaceHolderHelper = new SurfaceHolderHelper(_reactContext, publisher.getRtmpCamera(), surfaceView.getId());
    surfaceView.getHolder().addCallback(surfaceHolderHelper);

    return surfaceView;
  }

  @ReactProp(name = "streamURL")
  public void setStreamURL(SurfaceView surfaceView, @Nullable String url) {
    publisher.setStreamUrl(url);
  }

  @ReactProp(name = "streamName")
  public void setStreamName(SurfaceView surfaceView, @Nullable String name) {
    publisher.setStreamName(name);
  }

  @ReactProp(name = "allowedVideoOrientations")
  public void setAllowedVideoOrientations(SurfaceView surfaceView, @Nullable ReadableArray allowedVideoOrientations) {
    List<String> allowedOrientations = new ArrayList<>();
    for (int i = 0; i < allowedVideoOrientations.size(); i++) {
      allowedOrientations.add(allowedVideoOrientations.getString(i));
    }
    publisher.setAllowedVideoOrientations(allowedOrientations);
  }

  @ReactProp(name = "videoOrientation")
  public void setVideoOrientation(SurfaceView surfaceView, @Nullable String videoOrientation) {
    publisher.setVideoOrientation(videoOrientation);
  }

  @ReactProp(name = "videoSettings")
  public void setVideoSettings(SurfaceView surfaceView, @Nullable ReadableMap videoSettings) {
    Log.d("RTMPPublisher", "videoSettings prop:" + String.valueOf(videoSettings));
    VideoSettings settings = VideoSettings.getDefault();

    settings.width = videoSettings.getInt("width");
    settings.height = videoSettings.getInt("height");
    settings.bitrate = videoSettings.getInt("bitrate");
    settings.audioBitrate = videoSettings.getInt("audioBitrate");

    publisher.setVideoSettings(settings);
  }

  @Nullable
  @Override
  public Map<String, Object> getExportedCustomDirectEventTypeConstants() {
    return MapBuilder.<String, Object>builder()
      .put("onDisconnect", MapBuilder.of("registrationName", "onDisconnect"))
      .put("onConnectionFailed", MapBuilder.of("registrationName", "onConnectionFailed"))
      .put("onConnectionStarted", MapBuilder.of("registrationName", "onConnectionStarted"))
      .put("onConnectionSuccess", MapBuilder.of("registrationName", "onConnectionSuccess"))
      .put("onNewBitrateReceived", MapBuilder.of("registrationName", "onNewBitrateReceived"))
      .put("onStreamStateChanged", MapBuilder.of("registrationName", "onStreamStateChanged"))
      .put("onBluetoothDeviceStatusChanged", MapBuilder.of("registrationName", "onBluetoothDeviceStatusChanged"))
      .build();
  }
}