ambari/ambari-web/app/controllers/main/alerts_controller.js

/**
 * Licensed to the Apache Software Foundation (ASF) under one
 * or more contributor license agreements.  See the NOTICE file
 * distributed with this work for additional information
 * regarding copyright ownership.  The ASF licenses this file
 * to you 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.
 */

var App = require('app');

App.MainAlertsController = Em.Controller.extend({
  name: 'mainAlertsController',

  alerts: [],
  isLoaded: false,
  isUpdating: false,
  // name of resource(hostName or ServiceName)
  resourceName: null,
  //"HOST" or "SERVICE"
  resourceType: null,
  updateTimer: null,

  /**
   * load alerts for service or host
   * @param name
   * @param type
   */
  loadAlerts: function (name, type) {
    this.set('isLoaded', false);
    this.set('resourceName', name);
    this.set('resourceType', type);
    this.getFromServer();
  },
  /**
   * update alerts
   */
  update: function () {
    var self = this;
    if (this.get('isUpdating')) {
      this.set('updateTimer', setTimeout(function () {
        self.getFromServer();
        self.update();
      }, App.componentsUpdateInterval));
    } else {
      clearTimeout(this.get('updateTimer'));
    }
  }.observes('isUpdating'),

  /**
   * ask alerts from server by type
   */
  getFromServer: function () {
    if (App.router.get('clusterController.isNagiosInstalled')) {
      if (this.get('resourceType') === "SERVICE") {
        this.getAlertsByService();
      } else if (this.get('resourceType') === "HOST") {
        this.getAlertsByHost();
      } else {
        console.warn("GET Alerts error: unknown resourceType");
      }
    } else {
      this.set('isLoaded', true);
    }
  },

  getAlertsByHost: function () {
    if (this.get('resourceName')) {
      App.ajax.send({
        name: 'alerts.get_by_host',
        sender: this,
        data: {
          hostName: this.get('resourceName')
        },
        success: 'getAlertsSuccessCallback',
        error: 'getAlertsErrorCallback'
      })
    } else {
      console.warn('GET Alerts error: hostName parameter is missing');
    }
  },

  getAlertsByService: function () {
    if (this.get('resourceName')) {
      App.ajax.send({
        name: 'alerts.get_by_service',
        sender: this,
        data: {
          serviceName: this.get('resourceName')
        },
        success: 'getAlertsSuccessCallback',
        error: 'getAlertsErrorCallback'
      })
    } else {
      console.warn('GET Alerts error: serviceName parameter is missing');
    }
  },

  /**
   * map to associate old status format with and maintain sorting
   */
  statusNumberMap: {
    "OK" : "0",
    "WARNING": "1",
    "CRITICAL": "2"
  },

  getAlertsSuccessCallback: function (json) {
    var alerts = [];
    if (json && json.alerts && json.alerts.detail) {
      json.alerts.detail.forEach(function (_alert) {
        alerts.pushObject(App.Alert.create({
          title: _alert.description,
          serviceType: _alert.service_name,
          lastTime: _alert.status_time,
          status: this.get('statusNumberMap')[_alert.status] || "3",
          message: _alert.output,
          hostName: _alert.host_name,
          lastCheck: _alert.last_status_time
        }));
      }, this);
    }
    this.set('alerts', this.sortAlerts(alerts));
    this.set('isLoaded', true);
  },
  /**
   * alerts sorting
   * firstly by status
   * 1. UNKNOWN
   * 2. CRITICAL
   * 3. WARNING
   * 4. OK
   * secondly by date
   * @param array
   * @return {*}
   */
  sortAlerts: function (array) {
    return array.sort(function (left, right) {
      var statusDiff = right.get('status') - left.get('status');
      if (statusDiff == 0) { // same error severity - sort by time
        var rightTime = right.get('date');
        var leftTime = left.get('date');
        rightTime = rightTime ? rightTime.getTime() : 0;
        leftTime = leftTime ? leftTime.getTime() : 0;
        statusDiff = rightTime - leftTime;
      }
      return statusDiff;
    });
  },

  getAlertsErrorCallback: function(){
    this.set('isLoaded', true);
  }
});