/* global $ TRTC getCameraId getMicrophoneId resetView isHidden shareUserId addMemberView removeView addVideoView setAnimationFrame clearAnimationFrame*/
class RtcClient {
  constructor(options) {
    this.sdkAppId_ = parseInt(options.sdkAppId);
    this.userId_ = options.userId;
    this.userSig_ = options.userSig;
    this.roomId_ = options.roomId;
    this.privateMapKey_ = options.privateMapKey;

    this.isJoined_ = false;
    this.isPublished_ = false;
    this.isAudioMuted = false;
    this.isVideoMuted = false;
    this.localStream_ = null;
    this.remoteStreams_ = [];
    this.members_ = new Map();
    this.getAudioLevelTimer_ = -1;

    // create a client for RtcClient
    this.client_ = TRTC.createClient({
      mode: 'rtc',
      sdkAppId: this.sdkAppId_,
      userId: this.userId_,
      userSig: this.userSig_
    });
    this.handleEvents();
  }

  async join() {
    if (this.isJoined_) {
      console.warn('duplicate RtcClient.join() observed');
      return;
    }
    try {
      // join the room
      await this.client_.join({
        roomId: parseInt(this.roomId_)
      });
      console.log('join room success');
      this.isJoined_ = true;

      // create a local stream with audio/video from microphone/camera
      if (getCameraId() && getMicrophoneId()) {
        this.localStream_ = TRTC.createStream({
          audio: true,
          video: true,
          userId: this.userId_,
          cameraId: getCameraId(),
          microphoneId: getMicrophoneId(),
          mirror: true
        });
      } else {
        // not to specify cameraId/microphoneId to avoid OverConstrainedError
        this.localStream_ = TRTC.createStream({
          audio: true,
          video: true,
          userId: this.userId_,
          mirror: true
        });
      }
      try {
        // initialize the local stream and the stream will be populated with audio/video
        await this.localStream_.initialize();
        console.log('initialize local stream success');
        this.localStream_.on('player-state-changed', event => {
          console.log(`local stream ${event.type} player is ${event.state}`);
			if(event.type == 'video' && event.state == 'PLAYING'){
				spviewStart();
			}
        });
		
      } catch (error) {
        console.error('failed to initialize local stream - ' + error);
        switch (error.name) {
          case 'NotReadableError':
            cameraUsed();
            return;
          case 'NotAllowedError':
            if (error.message === 'Permission denied by system') {
              cameraDenied();
            } else {
              console.log('User refused to share the screen');
            }
            return;
          case 'NotFoundError':
            deviceNotFound();
            return;
          default:
            return;
        }
      }

      try {
        // publish the local stream
        await this.publish();
		
		this.localStream_.play('mine-video');
		
		this.localStream_.on('error', error => {
		  const errorCode = error.getCode();
		  if (errorCode === 16451) {
		    // PLAY_NOT_ALLOWED,引导用户手势操作并调用 stream.resume 恢复音视频播放
			let self = this;
			
			let replay = () => {
			    this.localStream_.stop()
			    this.localStream_.play('mine-video', { muted: false })
			    // 移除用户鼠标事件监听
			    document.removeEventListener('mousedown', replay)
			    // 移除用户触屏事件监听
			    document.removeEventListener('touchstart', replay)
			  }
			  
			document.addEventListener('mousedown', replay);
			document.addEventListener('touchstart', replay);
			this.localStream_.play('mine-video', { muted: true });
			
			vant.Toast({
				message: '请点击屏幕开始视频面试',
				duration: 0,
				overlay: true,
				closeOnClick: true,
				closeOnClickOverlay: true
			});
		  }
		})
		
		//$('#main-video-btns').show();
		$('#mask_main').appendTo($('#player_' + this.localStream_.getId()));
		
		// 开始获取音量
		this.startGetAudioLevel();
		
      } catch (error) {
        console.error('failed to publish local stream - ', error);
      }

      
    } catch (error) {
	  joinFail();
      console.error('join room failed! ' + error);
    }
    //更新成员状态
    let states = this.client_.getRemoteMutedState();
    for (let state of states) {
      if (state.audioMuted) {
        $('#' + state.userId)
          .find('.member-audio-btn')
          .attr('src', './img/mic-off.png');
      }
      if (state.videoMuted) {
        $('#' + state.userId)
          .find('.member-video-btn')
          .attr('src', './img/camera-off.png');
        $('#mask_' + this.members_.get(state.userId).getId()).show();
      }
    }
  }

  async leave() {
    if (!this.isJoined_) {
      console.warn('leave() - please join() firstly');
      return;
    }
    // ensure the local stream is unpublished before leaving.
    await this.unpublish();

    // leave the room
    await this.client_.leave();

    this.localStream_.stop();
    this.localStream_.close();
    this.localStream_ = null;
    this.isJoined_ = false;
    // 停止获取音量
    this.stopGetAudioLevel();
    //resetView();
  }
  async playAllowed(){
	return new Promise((resolve, reject) => {
	  	
	});
  }
  async publish() {
    if (!this.isJoined_) {
      console.warn('publish() - please join() firstly');
      return;
    }
    if (this.isPublished_) {
      console.warn('duplicate RtcClient.publish() observed');
      return;
    }
    try {
      await this.client_.publish(this.localStream_);
    } catch (error) {
      console.error('failed to publish local stream ' + error);
      this.isPublished_ = false;
    }

    this.isPublished_ = true;
  }

  async unpublish() {
    if (!this.isJoined_) {
      console.warn('unpublish() - please join() firstly');
      return;
    }
    if (!this.isPublished_) {
      console.warn('RtcClient.unpublish() called but not published yet');
      return;
    }

    await this.client_.unpublish(this.localStream_);
    this.isPublished_ = false;
  }

  muteLocalAudio() {
    this.localStream_.muteAudio();
  }

  unmuteLocalAudio() {
    this.localStream_.unmuteAudio();
  }

  muteLocalVideo() {
    this.localStream_.muteVideo();
  }

  unmuteLocalVideo() {
    this.localStream_.unmuteVideo();
  }

  resumeStreams() {
    this.localStream_.resume();
    for (let stream of this.remoteStreams_) {
      stream.resume();
    }
  }

  handleEvents() {
    this.client_.on('error', err => {
      console.error(err);
      alert(err);
      location.reload();
    });
    this.client_.on('client-banned', err => {
      console.error('client has been banned for ' + err);
      if (!isHidden()) {
        alert('您已被踢出房间');
        location.reload();
      } else {
        document.addEventListener(
          'visibilitychange',
          () => {
            if (!isHidden()) {
              alert('您已被踢出房间');
              location.reload();
            }
          },
          false
        );
      }
    });
    // fired when a remote peer is joining the room
    this.client_.on('peer-join', evt => {
      const userId = evt.userId;
      console.log('peer-join ' + userId);
	   /*
      if (userId !== shareUserId) {
        addMemberView(userId);
      }
	  */
    });
    // fired when a remote peer is leaving the room
	// 对方离开房间
    this.client_.on('peer-leave', evt => {
      const userId = evt.userId;
      removeView(userId);
      console.log('peer-leave ' + userId);
    });
    // fired when a remote stream is added
    this.client_.on('stream-added', evt => {
      const remoteStream = evt.stream;
      const id = remoteStream.getId();
      const userId = remoteStream.getUserId();
      this.members_.set(userId, remoteStream);
      console.log(`remote stream added: [${userId}] ID: ${id} type: ${remoteStream.getType()}`);
      if (remoteStream.getUserId() === shareUserId) {
        // don't need screen shared by us
        this.client_.unsubscribe(remoteStream);
      } else {
        console.log('subscribe to this remote stream');
        this.client_.subscribe(remoteStream);
      }
    });
    // fired when a remote stream has been subscribed
    this.client_.on('stream-subscribed', evt => {
      const uid = evt.userId;
      const remoteStream = evt.stream;
      const id = remoteStream.getId();
      this.remoteStreams_.push(remoteStream);
      remoteStream.on('player-state-changed', event => {
        console.log(`${event.type} player is ${event.state}`);
      });
      addVideoView(id);
      if (remoteStream.userId_ && remoteStream.userId_.indexOf('share_') > -1) {
        remoteStream.play(id, { objectFit: 'contain' }).then(() => {
          // Firefox，当video的controls设置为true的时候，video-box无法监听到click事件
          // if (getBrowser().browser === 'Firefox') {
          //   return;
          // }
          remoteStream.videoPlayer_.element_.controls = true;
        });
      } else {
        remoteStream.play(id);
      }
	  remoteStream.on('error', error => {
	    const errorCode = error.getCode();
	    if (errorCode === 16451) {
	      // PLAY_NOT_ALLOWED,引导用户手势操作并调用 stream.resume 恢复音视频播放
	  	let self = this;
	  	
	  	let replay = () => {
	  	    remoteStream.stop()
	  	    remoteStream.play(id, { muted: false })
	  	    // 移除用户鼠标事件监听
	  	    document.removeEventListener('mousedown', replay)
	  	    // 移除用户触屏事件监听
	  	    document.removeEventListener('touchstart', replay)
	  	  }
	  	  
	  	document.addEventListener('mousedown', replay);
	  	document.addEventListener('touchstart', replay);
	  	remoteStream.play(id, { muted: true });
	  	
	  	vant.Toast({
	  		message: '请点击屏幕开始视频面试',
	  		duration: 0,
	  		overlay: true,
	  		closeOnClick: true,
	  		closeOnClickOverlay: true
	  	});
	    }
	  })
      //添加“摄像头未打开”遮罩
      let mask = $('#mask_main').clone();
      mask.attr('id', 'mask_' + id);
      mask.appendTo($('#player_' + id));
      mask.hide();
      if (!remoteStream.hasVideo()) {
        mask.show();
        $('#' + remoteStream.getUserId())
          .find('.member-video-btn')
          .attr('src', 'img/camera-off.png');
      }
      console.log('stream-subscribed ID: ', id);
    });
    // fired when the remote stream is removed, e.g. the remote user called Client.unpublish()
    this.client_.on('stream-removed', evt => {
      const remoteStream = evt.stream;
      const id = remoteStream.getId();
      remoteStream.stop();
      this.remoteStreams_ = this.remoteStreams_.filter(stream => {
        return stream.getId() !== id;
      });
      removeView(id);
      $('#' + remoteStream.getUserId())
        .find('.member-audio-btn')
        .attr('src', 'img/mic-off.png');
      $('#' + remoteStream.getUserId())
        .find('.member-video-btn')
        .attr('src', 'img/camera-off.png');
      console.log(`stream-removed ID: ${id}  type: ${remoteStream.getType()}`);
    });

    this.client_.on('stream-updated', evt => {
      const remoteStream = evt.stream;
      let uid = this.getUidByStreamId(remoteStream.getId());
      if (!remoteStream.hasVideo()) {
        $('#' + uid)
          .find('.member-video-btn')
          .attr('src', 'img/camera-off.png');
      }
      console.log(
        'type: ' +
          remoteStream.getType() +
          ' stream-updated hasAudio: ' +
          remoteStream.hasAudio() +
          ' hasVideo: ' +
          remoteStream.hasVideo() +
          ' uid: ' +
          uid
      );
    });

    this.client_.on('mute-audio', evt => {
      console.log(evt.userId + ' mute audio');
      $('#' + evt.userId)
        .find('.member-audio-btn')
        .attr('src', 'img/mic-off.png');
    });
    this.client_.on('unmute-audio', evt => {
      console.log(evt.userId + ' unmute audio');
      $('#' + evt.userId)
        .find('.member-audio-btn')
        .attr('src', 'img/mic-on.png');
    });
    this.client_.on('mute-video', evt => {
      console.log(evt.userId + ' mute video');
      $('#' + evt.userId)
        .find('.member-video-btn')
        .attr('src', 'img/camera-off.png');
      const remoteStream = this.members_.get(evt.userId);
      if (remoteStream) {
        let streamId = remoteStream.getId();
        if (streamId) {
          $('#mask_' + streamId).show();
        }
      }
    });
    this.client_.on('unmute-video', evt => {
      console.log(evt.userId + ' unmute video');
      $('#' + evt.userId)
        .find('.member-video-btn')
        .attr('src', 'img/camera-on.png');
      const stream = this.members_.get(evt.userId);
      if (stream) {
        let streamId = stream.getId();
        if (streamId) {
          $('#mask_' + streamId).hide();
        }
      }
    });
  }

  showStreamState(stream) {
    console.log('has audio: ' + stream.hasAudio() + ' has video: ' + stream.hasVideo());
  }

  getUidByStreamId(streamId) {
    for (let [uid, stream] of this.members_) {
      if (stream.getId() == streamId) {
        return uid;
      }
    }
  }

  startGetAudioLevel() {
    // 监听音量回调事件，更新每个用户的音量图标
    this.client_.on('audio-volume', ({ result }) => {
      result.forEach(({ userId, audioVolume }) => {
        if (audioVolume >= 10) {
          console.warn(`userId: ${userId} is speaking audioVolume: ${audioVolume}`);
          $(`#${userId === this.userId_ ? 'member-me' : userId}`)
            .find('.volume-level')
            .css('height', `${audioVolume * 4}%`);
        } else {
          $(`#${userId === this.userId_ ? 'member-me' : userId}`)
            .find('.volume-level')
            .css('height', `0%`);
        }
      });
    });
    this.client_.enableAudioVolumeEvaluation(100);
  }

  // 停止获取流音量
  stopGetAudioLevel() {
    this.client_.enableAudioVolumeEvaluation(-1);
  }
}