linagora/hublin

(function(angular) {
  'use strict';

  angular.module('op.live-conference')
    .factory('AutoVideoSwitcher', AutoVideoSwitcher);

  function AutoVideoSwitcher($rootScope, $timeout, AUTO_VIDEO_SWITCH_TIMEOUT, LOCAL_VIDEO_ID) {

    function AutoVideoSwitcher(conferenceState) {
      this.conferenceState = conferenceState;
      this.timeouts = {};
      var self = this;

      $rootScope.$on('conferencestate:speaking', function(event, data) {
        if (data.speaking) {
          self.onSpeech(event, data);
        } else {
          self.onSpeechEnd(event, data);
        }
      });
    }

    AutoVideoSwitcher.prototype.onSpeech = function(evt, data) {
      var member = this.getMemberFromData(data);

      if (!member || this.timeouts[member.rtcid] || member.videoId === LOCAL_VIDEO_ID || member.mute || member.videoId === this.conferenceState.localVideoId) {
        return;
      }
      var rtcid = member.rtcid;

      this.timeouts[rtcid] = $timeout(function() {
        var member = this.getMemberFromData(data);

        if (!member) {
          return;
        }

        this.conferenceState.updateLocalVideoId(member.videoId);
      }.bind(this), AUTO_VIDEO_SWITCH_TIMEOUT, false);
    };

    AutoVideoSwitcher.prototype.onSpeechEnd = function(evt, data) {
      var member = this.getMemberFromData(data);

      if (!member || !this.timeouts[member.rtcid] || member.videoId === LOCAL_VIDEO_ID) {
        return;
      }
      $timeout.cancel(this.timeouts[member.rtcid]);
      this.timeouts[member.rtcid] = null;
    };

    AutoVideoSwitcher.prototype.getMemberFromData = function(data) {
      return this.conferenceState.getAttendeeByRtcid(data.id);
    };

    return AutoVideoSwitcher;
  }
})(angular);