zaqar-ui/zaqar_ui/static/dashboard/project/queues/table/queue.controller.js

/**
 * Licensed under the Apache License, Version 2.0 (the "License"); you may
 * not use this file except in compliance with the License. You may obtain
 * a copy of the License at
 *
 *    http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
 * WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
 * License for the specific language governing permissions and limitations
 * under the License.
 */

(function() {
  'use strict';

  /**
   * @ngdoc overview
   * @name queueController
   * @ngController
   *
   * @description
   * Controller for the queues table
   */
  angular
    .module('horizon.dashboard.project.queues')
    .controller('horizon.dashboard.project.queues.table.queueController', queueController);

  queueController.$inject = [
    '$scope',
    'horizon.app.core.openstack-service-api.zaqar',
    'horizon.dashboard.project.queues.basePath',
    'horizon.dashboard.project.queues.events',
    'horizon.dashboard.project.queues.resourceType',
    'horizon.framework.conf.resource-type-registry.service'
  ];

  function queueController($scope, zaqar, base, events, type, registry) {

    var ctrl = this;

    ctrl.queues = [];
    ctrl.queuesSrc = [];
    ctrl.resourceType = registry.getResourceType(type);
    ctrl.subsTemplate = base + 'table/subscription.html';

    init();
    initScope();

    //////////

    function initScope() {
      var createWatcher = $scope.$on(events.CREATE_SUCCESS, onCreateSuccess);
      var deleteWatcher = $scope.$on(events.DELETE_SUCCESS, onDeleteSuccess);
      var updateWatcher = $scope.$on(events.UPDATE_SUCCESS, onUpdateSuccess);
      var purgeWatcher = $scope.$on(events.PURGE_SUCCESS, onPurgeSuccess);
      var postMessageWatcher = $scope.$on(events.POST_MESSAGE_SUCCESS, onPostMessageSuccess);
      var subWatcher = $scope.$on(events.SUBSCRIPTION_CREATE_SUCCESS, broadcastEvents);
      $scope.$on('$destroy', function destroy() {
        createWatcher();
        deleteWatcher();
        updateWatcher();
        purgeWatcher();
        postMessageWatcher();
        subWatcher();
      });
    }

    //////////

    function init() {
      ctrl.resourceType.initActions($scope);
      zaqar.getQueues().then(showQueues);
    }

    function broadcastEvents(event, data) {
      if (event.targetScope !== $scope) {
        $scope.$broadcast(event.name, data);
      }
    }

    function showQueues(response) {
      // hz-table expects all items to have the id field
      // so we need to manually add name as id here
      ctrl.queuesSrc = response.data;
      ctrl.queuesSrc.map(function addIdentifier(queue) {
        queue.id = queue.name;
      });
    }

    function refreshQueue(queueName) {
      zaqar.getQueue(queueName).then(function(response) {
        response.data.id = queueName;
        for (var i = 0; i < ctrl.queuesSrc.length; i++) {
          var queue = ctrl.queuesSrc[i];
          if (queue.id === queueName) {
            ctrl.queuesSrc[i] = response.data;
          }
        }
        for (var i = 0; i < ctrl.queues.length; i++) {
          var queue = ctrl.queues[i];
          if (queue.id === queueName) {
            ctrl.queues[i] = response.data;
          }
        }
      });
    }

    function refreshSubscriptions(queueName) {
      var queue = new Object();
      queue.name = queueName;
      zaqar.getSubscriptions(queue).then(function() {
        $scope.tCtrl.broadcastExpansion(queue);
      });
    }

    function onCreateSuccess(e, newQueue) {
      e.stopPropagation();
      newQueue.id = newQueue.name;
      ctrl.queuesSrc.push(newQueue);
    }

    function onDeleteSuccess(e, deletedNames) {
      // remove existing item from table
      e.stopPropagation();
      for (var i = ctrl.queuesSrc.length - 1; i >= 0; i--) {
        var queue = ctrl.queuesSrc[i];
        if (deletedNames.indexOf(queue.name) >= 0) {
          ctrl.queuesSrc.splice(i, 1);
        }
      }
      // clear selections upon deletion
      $scope.$emit('hzTable:clearSelected');
    }

    function onUpdateSuccess(e, queue) {
      e.stopPropagation();
      queue.id = queue.name;
      // update queue
      ctrl.queuesSrc[queue.id] = queue;
    }

    function onPurgeSuccess(e, queueName) {
      e.stopPropagation();
      // purge queue
      refreshQueue(queueName);
      refreshSubscriptions(queueName);
    }

    function onPostMessageSuccess(e, queueName) {
      e.stopPropagation();
      refreshQueue(queueName);
    }
  }

})();