const {
  createAgoraRtcEngine,
  ClientRoleType,
  VideoSourceType,
  VideoViewSetupMode,
  ScreenCaptureSourceType,
  RenderModeType,
  ChannelProfileType,
  MediaRecorderContainerFormat,
  MediaRecorderStreamType
} = require("agora-electron-sdk");
const { message } = require('antd');
const rtcEngine = createAgoraRtcEngine();
const option: any = {
  appId: 'dcfc466a6ecb4a1f972630065dfb1e75',
  token: '',
  channelId: '',
  userid: '',
}
rtcEngine.initialize({
  appId: option.appId,
});

rtcEngine.registerEventHandler({
  // 监听本地用户加入频道事件
  onJoinChannelSuccess: ({ channelId, localUid }: any, elapsed: any) => {
    console.log({ channelId, localUid }, elapsed, '加入房间');
    // 本地用户加入频道后，设置本地视频窗口
    rtcEngine.setupLocalVideo({
      renderMode: RenderModeType.RenderModeFit,
      // sourceType: VideoSourceType.VideoSourceScreen,
      sourceType: VideoSourceType.VideoSourceCameraPrimary,
      uid: localUid,
      view: agora.getDom(),
      setupMode: VideoViewSetupMode.VideoViewSetupAdd,
    });
  },
  // 监听远端用户加入频道事件
  onUserJoined: ({ channelId, localUid }: any, remoteUid: any, elapsed: any) => {
    console.log({ channelId, localUid }, remoteUid, '远端加入频道');
    // 远端用户加入频道后，设置远端视频窗口
    rtcEngine.setupRemoteVideo(
      {
        renderMode: RenderModeType.RenderModeFit,
        sourceType: VideoSourceType.VideoSourceRemote,
        uid: remoteUid,
        view: agora.getDom(),
        setupMode: VideoViewSetupMode.VideoViewSetupAdd,
      },
      { channelId },
    );

  },
  // 监听用户离开频道事件
  onUserOffline: ({ channelId, localUid }: any, remoteUid: any, reason: any) => {
    // 远端用户离开频道后，关闭远端视频窗口
    console.log({ channelId, localUid }, remoteUid, '离开频道');
    rtcEngine.setupRemoteVideo(
      {
        renderMode: RenderModeType.RenderModeFit,
        sourceType: VideoSourceType.VideoSourceRemote,
        uid: remoteUid,
        view: agora.getDom(),
        setupMode: VideoViewSetupMode.VideoViewSetupRemove,
      },
    );
  },
  // 视频发布状态改变回调
  onVideoPublishStateChanged: (source: any, channel: any, oldState: any, newState: any, elapseSinceLastState: any) => {
    if (newState === 1) {

    }
  },
  // 音频发布状态改变回调
  onAudioPublishStateChanged: (channel: any, oldState: any, newState: any, elapseSinceLastState: any) => {
    if (newState === 1) {

    }
  },
  // 用户音量提示回调。
  onAudioVolumeIndication: (connection: any, speakers: any, speakerNumber: any, totalVolume: any,) => {
    const percentage = (totalVolume / 255) * 100
    const dom = document.getElementById('recordingDeviceTest') as any;
    if (dom) {
      dom.style.width = `${percentage}%`
    }
  }
});

let videoID: string = '';
let iMediaRecorder: any = '';

const agora = {
  getDom: () => {
    return document.getElementById('video-1');
  },
  // 离开频道
  leaveChannel: () => {
    rtcEngine.leaveChannel({
      stopAudioMixing: true,
      stopAllEffect: true,
      stopMicrophoneRecording: true,
    })
  },
  // 加入频道
  joinChannel: (bool: boolean) => {
    if (bool) {
      rtcEngine.joinChannel(option.token, option.channelId, option.userid, {
        channelProfile: ChannelProfileType.ChannelProfileLiveBroadcasting, //设置频道场景为直播场景
        clientRoleType: ClientRoleType.ClientRoleBroadcaster, //用户角色 1主播 2观众
        publishMicrophoneTrack: true, //设置是否发布麦克风采集到的音频
        publishCameraTrack: false, //设置是否发布摄像头采集的视频
        publishScreenTrack: true, //设置是否发布屏幕采集的视频
        autoSubscribeAudio: true, //设置是否自动订阅所有音频流
        autoSubscribeVideo: true, //设置是否自动订阅所有视频流
      });
    } else {
      rtcEngine.joinChannel(option.token, option.channelId, option.userid, {
        channelProfile: ChannelProfileType.ChannelProfileLiveBroadcasting, //设置频道场景为直播场景
        clientRoleType: ClientRoleType.ClientRoleBroadcaster, //设置用户角色为主播；如果要将用户角色设置为观众，保持默认值即可
        publishMicrophoneTrack: true, //发布麦克风采集的音频
        publishCameraTrack: true, //发布摄像头采集的视频
        publishScreenTrack: false, //设置是否发布屏幕采集的视频
        autoSubscribeAudio: true, //自动订阅所有音频流
        autoSubscribeVideo: true, //自动订阅所有视频流
      });
    }
  },
  // 停止录制音视频
  stopRecording: () => {
    iMediaRecorder.stopRecording()
    rtcEngine.destroyMediaRecorder(iMediaRecorder)
    iMediaRecorder = ""
  },
  // 开始录制音视频
  startRecording: () => {
    iMediaRecorder = rtcEngine.createMediaRecorder({
      channelId: option.channelId,
      uid: 123,
    })
    iMediaRecorder.setMediaRecorderObserver({
      // 录制状态发生改变回调。
      onRecorderStateChanged: (channelId: any, uid: any, state: any, reason: any) => {
        console.log(channelId, uid, state, reason, '录制状态发生改变回调。');
      },
      // 录制信息更新回调。
      onRecorderInfoUpdated: (channelId: any, uid: any, info: any) => {
        console.log(channelId, uid, info, '录制信息更新回调。');
      },
    })
    iMediaRecorder.startRecording({
      storagePath: `D:/word/${+new Date()}.mp4`, //录音文件在本地保存的绝对路径，需精确到文件名及格式
      containerFormat: MediaRecorderContainerFormat.FormatMp4, //录制文件的格式
      streamType: MediaRecorderStreamType.StreamTypeBoth, //录制内容
      maxDurationMs: 7200000, //maxDurationMs
    })
  },
  // 停止共享屏幕
  stopScreenCapture: () => {
    rtcEngine.stopScreenCapture();
  },
  // 开启本地视频预览
  startPreview: async (): Promise<boolean> => {
    return new Promise((resolve, reject) => {
      navigator.mediaDevices.getUserMedia({
        video: true,
        audio: true,
      }).then((stream) => {
        let dom = document.getElementById('startPreview') as any;
        dom.srcObject = stream;
        dom.play()
        resolve(true)
      }).catch((error) => {
        message.error('无法获取摄像头!');
        resolve(true)
      });
    })
  },
  // 停止音频设备回路测试
  stopAudioDeviceLoopbackTest: () => {
    rtcEngine.getAudioDeviceManager().stopAudioDeviceLoopbackTest()
    rtcEngine.getAudioDeviceManager().stopRecordingDeviceTest()
    let video = document.getElementById('startPreview') as any;
    if (video.srcObject) {
      const tracks = video.srcObject.getTracks();
      tracks.forEach((track: any) => {
        track.stop();
      });
      video.srcObject = null;
    }
    let audio = document.getElementById('startAudio') as any;
    if (audio.srcObject) {
      const tracks = audio.srcObject.getTracks();
      tracks.forEach((track: any) => {
        track.stop();
      });
      audio.srcObject = null;
    }
  },
  // 启动音频采集设备测试
  startRecordingDeviceTest: (indicationInterval: number) => {
    rtcEngine.getAudioDeviceManager().startRecordingDeviceTest(indicationInterval)
    navigator.mediaDevices.getUserMedia({ audio: true })
      .then((stream) => {
        let dom = document.getElementById('startAudio') as any;
        dom.srcObject = stream;
        dom.play()
      })
      .catch((error) => {
        message.error('无法获取麦克风!');
      });
  },
  // 获取音频设备列表
  getAudioMediaList: () => {
    return {
      currentDevice: rtcEngine.getAudioDeviceManager().getRecordingDefaultDevice(),
      currentDevices: rtcEngine.getAudioDeviceManager().enumerateRecordingDevices(),
      currentVolume: rtcEngine.getAudioDeviceManager().getRecordingDeviceVolume()
    }
  },
  // 设置音频设备音量
  setRecordingDeviceVolume: (volume: number) => {
    rtcEngine.getAudioDeviceManager().setRecordingDeviceVolume(volume)
  },
  // 设置音频采集设备
  setRecordingDevice: (deviceId: string) => {
    rtcEngine.getAudioDeviceManager().setRecordingDevice(deviceId)
  },
  // 摄像头采集
  setCameraCapture: () => {
    rtcEngine.startCameraCapture(VideoSourceType.VideoSourceCamera, {})
    // joinChannel(false)
  },
  // 加入频道
  setJoinChannel: (data: any) => {
    option.token = data.token;
    option.channelId = data.channelId;
    option.userid = Number(data.userid);
    rtcEngine.startCameraCapture(VideoSourceType.VideoSourceCamera, {})
    // joinChannel(false)
  },
  // 取消或恢复发布本地音频流
  muteLocalAudioStream: (mute: any) => {
    rtcEngine.muteLocalAudioStream(mute)
  },
  // 取消或恢复发布本地视频流
  muteLocalVideoStream: (mute: any) => {
    rtcEngine.muteLocalVideoStream(mute)
  },
  // 获取当前生成的视频id
  getVideoId: () => {
    return videoID;
  },
  // 桌面捕获音频和视频的媒体源的信息
  getDesktopCapturerVideo: async () => {
    return rtcEngine.getScreenCaptureSources({ width: 300, height: 300 }, { width: 300, height: 300 }, true);
  },

  // 共享屏幕采集
  setDesktopCapturerVideo: (targetSource: any) => {
    // stopScreenCapture()
    if (
      targetSource.type ===
      ScreenCaptureSourceType.ScreencapturesourcetypeScreen
    ) {
      rtcEngine.startScreenCaptureByDisplayId(
        targetSource.sourceId,
        {},
        {
          windowFocus: true,
          enableHighLight: true,
          highLightColor: 0xFF99CC00,
        }
      );
    } else {
      rtcEngine.startScreenCaptureByWindowId(
        targetSource.sourceId,
        {},
        {
          windowFocus: true,
          enableHighLight: true,
          highLightColor: 0xFF99CC00,
        }
      );
    }
    // joinChannel(true)
  },
}

export default agora;