linagora/openpaas-esn

(function(angular) {
  'use strict';

  angular.module('linagora.esn.contact')
    .controller('ContactSidebarController', ContactSidebarController);

  function ContactSidebarController(
    $scope,
    $q,
    _,
    userAPI,
    userUtils,
    contactAddressbookDisplayService,
    contactAddressbookService,
    CONTACT_ADDRESSBOOK_EVENTS
  ) {
    var self = this;
    var LOADING_STATUS = {
      loading: 'loading',
      loaded: 'loaded',
      error: 'error'
    };
    var DISPLAY_SHELL_CONVERT_OPTIONS = {
      includeActions: true,
      includePriority: true
    };

    self.$onInit = $onInit;
    self.reload = reload;

    function $onInit() {
      self.status = LOADING_STATUS.loading;

      contactAddressbookService.listAddressbooks()
        .then(function(addressbooks) {
          self.status = LOADING_STATUS.loaded;

          return _injectOwnerToSubscription(addressbooks);
        })
        .then(function(addressbooks) {
          contactAddressbookDisplayService.convertShellsToDisplayShells(addressbooks, DISPLAY_SHELL_CONVERT_OPTIONS).then(function(displayShells) {
            self.displayShells = displayShells;
            _refreshAddressbooksList();
            _listenAddressbookEvents();
          });
        })
        .catch(function() {
          self.status = LOADING_STATUS.error;
        });
    }

    function reload() {
      $onInit();
    }

    function _listenAddressbookEvents() {
      $scope.$on(CONTACT_ADDRESSBOOK_EVENTS.CREATED, _onAddressbookCreatedEvent);
      $scope.$on(CONTACT_ADDRESSBOOK_EVENTS.UPDATED, _onUpdatedAddressbookEvent);
      $scope.$on(CONTACT_ADDRESSBOOK_EVENTS.DELETED, _onRemovedAddressbookEvent);
      $scope.$on(CONTACT_ADDRESSBOOK_EVENTS.SUBSCRIPTION_DELETED, _onRemovedAddressbookEvent);
    }

    function _injectOwnerToSubscription(addressbooks) {
      var userIds = [];

      addressbooks.forEach(function(addressbook) {
        if (addressbook.isSubscription && !addressbook.group) {
          userIds.push(addressbook.source.bookId);
        }
      });

      var getOwnersPromises = _.unique(userIds).map(function(userId) {
        return userAPI.user(userId).then(function(response) {
            return {
              id: userId,
              displayName: userUtils.displayNameOf(response.data)
            };
          });
      });

      return $q.all(getOwnersPromises).then(function(owners) {
        addressbooks.forEach(function(addressbook) {
          if (addressbook.isSubscription) {
            var target = _.find(owners, function(owner) {
              return addressbook.source.bookId === owner.id;
            });

            if (target) {
              addressbook.owner = target;
            }
          }
        });

        return addressbooks;
      });
    }

    function _onAddressbookCreatedEvent(event, createdAddressbook) {
      if (createdAddressbook.isSubscription) {
        return _injectOwnerToSubscription([createdAddressbook])
          .then(function() {
            self.displayShells.push(contactAddressbookDisplayService.convertShellToDisplayShell(createdAddressbook, DISPLAY_SHELL_CONVERT_OPTIONS));
          })
          .then(_refreshAddressbooksList);
      }

      self.displayShells.push(contactAddressbookDisplayService.convertShellToDisplayShell(createdAddressbook, DISPLAY_SHELL_CONVERT_OPTIONS));
      _refreshAddressbooksList();
    }

    function _onUpdatedAddressbookEvent(event, updatedAddressbook) {
      if (updatedAddressbook.isSubscription) {
        return _injectOwnerToSubscription([updatedAddressbook])
          .then(function(injectedOwnerAddressbooks) {
            _updateAddressbookInList(injectedOwnerAddressbooks[0]);
            _refreshAddressbooksList();
          });
      }

      _updateAddressbookInList(updatedAddressbook);
      _refreshAddressbooksList();
    }

    function _updateAddressbookInList(addressbookToUpdate) {
      var index = _.findIndex(self.displayShells, function(addressbook) {
        return addressbook.shell.bookName === addressbookToUpdate.bookName;
      });

      if (index !== -1) {
        self.displayShells[index].shell = addressbookToUpdate;
        self.displayShells[index].displayName = addressbookToUpdate.name;
      }
    }

    function _onRemovedAddressbookEvent(event, removedAddressbook) {
      _.remove(self.displayShells, function(addressbook) {
        return addressbook.shell.bookName === removedAddressbook.bookName;
      });

      _refreshAddressbooksList();
    }

    function _refreshAddressbooksList() {
      var categories = contactAddressbookDisplayService.categorizeDisplayShells(self.displayShells);

      self.userAddressbooks = categories.userAddressbooks;
      self.sharedAddressbooks = categories.sharedAddressbooks;
      self.virtualAddressbooks = categories.virtualAddressbooks;
    }
  }
})(angular);