ambari/ambari-web/app/controllers/main/alerts/definition_configs_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.
 */

App.MainAlertDefinitionConfigsController = Em.Controller.extend({

  name: 'mainAlertDefinitionConfigsController',

  /**
   * All configurable properties of alert definition
   * @type {Array}
   */
  configs: [],

  /**
   * Define whether configs are editable
   * binds to property populated in template
   * @type {Boolean}
   */
  canEdit: true,

  /**
   * Array of displayNames of all services
   * is used for "Service" config options
   * @type {Array}
   */
  allServices: function () {
    return App.Service.find().mapProperty('displayName');
  }.property(),

  /**
   * Array of all aggregate-alerts names
   * @type {Array}
   */
  aggregateAlertNames: function () {
    return App.AggregateAlertDefinition.find().mapProperty('name');
  }.property(),

  /**
   * Compute thresholds from value using <code>content.reporting</code>
   * @type {Number|Null}
   */
  thresholdsFrom: function () {
    var warning = this.get('content.reporting').findProperty('type', 'warning');
    if (warning && warning.get('value')) {
      return warning.get('value');
    } else {
      return null;
    }
  }.property('content.reporting.@each.value'),

  /**
   * Compute thresholds to value using <code>content.reporting</code>
   * @type {Number|Null}
   */
  thresholdsTo: function () {
    var critical = this.get('content.reporting').findProperty('type', 'critical');
    if (critical && critical.get('value')) {
      return critical.get('value');
    } else {
      return null;
    }
  }.property('content.reporting.@each.value'),

  /**
   * Change options of "Component", after changing value of "Service" config
   */
  onServiceSelect: function () {
    var serviceProperty = this.get('configs').findProperty('label', 'Service');
    if (serviceProperty) {
      var componentsProperty = this.get('configs').findProperty('label', 'Component');
      componentsProperty.set('options', ['No component'].concat(App.HostComponent.find().filterProperty('service.displayName', serviceProperty.get('value')).mapProperty('displayName').uniq()));
    }
  }.observes('configs.@each.value'),

  /**
   * Render array of configs for appropriate alert definition type
   */
  renderConfigs: function () {
    var alertDefinition = this.get('content');
    var configs = [];
    switch (alertDefinition.get('type')) {
      case 'PORT':
        configs = this.renderPortConfigs();
        break;
      case 'METRIC':
        configs = this.renderMetricConfigs();
        break;
      case 'WEB':
        configs = this.renderWebConfigs();
        break;
      case 'SCRIPT':
        configs = this.renderScriptConfigs();
        break;
      case 'AGGREGATE':
        configs = this.renderAggregateConfigs();
        break;
      default:
        console.error('Incorrect Alert Definition Type: ', alertDefinition.get('type'));
    }

    configs.setEach('isDisabled', !this.get('canEdit'));

    this.set('configs', configs);
  },

  /**
   * Render config properties for port-type alert definition
   * @returns {Array}
   */
  renderPortConfigs: function () {
    var alertDefinition = this.get('content');
    return [
      App.AlertConfigProperties.AlertName.create({
        value: alertDefinition.get('name')
      }),
      App.AlertConfigProperties.Service.create({
        options: this.get('allServices'),
        value: alertDefinition.get('service.displayName')
      }),
      App.AlertConfigProperties.Component.create({
        options: this.get('allComponents'),
        value: alertDefinition.get('componentName') ? App.format.role(alertDefinition.get('componentName')) : 'No component'
      }),
      App.AlertConfigProperties.Scope.create({
        value: alertDefinition.get('scope').toLowerCase().capitalize()
      }),
      App.AlertConfigProperties.Description.create({
        value: alertDefinition.get('description')
      }),
      App.AlertConfigProperties.Interval.create({
        value: alertDefinition.get('interval')
      }),
      App.AlertConfigProperties.Thresholds.create({
        value: this.get('thresholdsFrom') + '-' + this.get('thresholdsTo'),
        from: this.get('thresholdsFrom'),
        to: this.get('thresholdsTo')
      }),
      App.AlertConfigProperties.URI.create({
        value: alertDefinition.get('uri')
      }),
      App.AlertConfigProperties.DefaultPort.create({
        value: alertDefinition.get('defaultPort')
      })
    ];
  },

  /**
   * Render config properties for metric-type alert definition
   * @returns {Array}
   */
  renderMetricConfigs: function () {
    var alertDefinition = this.get('content');
    return [
      App.AlertConfigProperties.AlertName.create({
        value: alertDefinition.get('name')
      }),
      App.AlertConfigProperties.Service.create({
        options: this.get('allServices'),
        value: alertDefinition.get('service.displayName')
      }),
      App.AlertConfigProperties.Component.create({
        options: this.get('allComponents'),
        value: alertDefinition.get('componentName') ? App.format.role(alertDefinition.get('componentName')) : 'No component'
      }),
      App.AlertConfigProperties.Scope.create({
        value: alertDefinition.get('scope').toLowerCase().capitalize()
      }),
      App.AlertConfigProperties.Description.create({
        value: alertDefinition.get('description')
      }),
      App.AlertConfigProperties.Interval.create({
        value: alertDefinition.get('interval')
      }),
      App.AlertConfigProperties.Thresholds.create({
        value: this.get('thresholdsFrom') + '-' + this.get('thresholdsTo'),
        from: this.get('thresholdsFrom'),
        to: this.get('thresholdsTo')
      }),
      App.AlertConfigProperties.URIExtended.create({
        value: JSON.stringify({
          http: alertDefinition.get('uri.http'),
          https: alertDefinition.get('uri.https'),
          https_property: alertDefinition.get('uri.httpsProperty'),
          https_property_value: alertDefinition.get('uri.httpsPropertyValue')
        })
      }),
      App.AlertConfigProperties.Metrics.create({
        value: alertDefinition.get('jmx.propertyList') ? alertDefinition.get('jmx.propertyList').join(',\n') : alertDefinition.get('ganglia.propertyList').join(',\n'),
        isJMXMetric: !!alertDefinition.get('jmx.propertyList')
      }),
      App.AlertConfigProperties.FormatString.create({
        value: alertDefinition.get('jmx.value') ? alertDefinition.get('jmx.value') : alertDefinition.get('ganglia.value'),
        isJMXMetric: !!alertDefinition.get('jmx.value')
      })
    ];
  },

  /**
   * Render config properties for web-type alert definition
   * @returns {Array}
   */
  renderWebConfigs: function () {
    var alertDefinition = this.get('content');
    return [
      App.AlertConfigProperties.AlertName.create({
        value: alertDefinition.get('name')
      }),
      App.AlertConfigProperties.Service.create({
        options: this.get('allServices'),
        value: alertDefinition.get('service.displayName')
      }),
      App.AlertConfigProperties.Component.create({
        options: this.get('allComponents'),
        value: alertDefinition.get('componentName') ? App.format.role(alertDefinition.get('componentName')) : 'No component'
      }),
      App.AlertConfigProperties.Scope.create({
        value: alertDefinition.get('scope').toLowerCase().capitalize()
      }),
      App.AlertConfigProperties.Description.create({
        value: alertDefinition.get('description')
      }),
      App.AlertConfigProperties.Interval.create({
        value: alertDefinition.get('interval')
      }),
      App.AlertConfigProperties.Thresholds.create({
        value: this.get('thresholdsFrom') + '-' + this.get('thresholdsTo'),
        from: this.get('thresholdsFrom'),
        to: this.get('thresholdsTo')
      }),
      App.AlertConfigProperties.URIExtended.create({
        value: JSON.stringify({
          http: alertDefinition.get('uri.http'),
          https: alertDefinition.get('uri.https'),
          https_property: alertDefinition.get('uri.httpsProperty'),
          https_property_value: alertDefinition.get('uri.httpsPropertyValue')
        })
      })
    ];
  },

  /**
   * Render config properties for script-type alert definition
   * @returns {Array}
   */
  renderScriptConfigs: function () {
    var alertDefinition = this.get('content');
    return [
      App.AlertConfigProperties.AlertName.create({
        value: alertDefinition.get('name')
      }),
      App.AlertConfigProperties.Service.create({
        options: this.get('allServices'),
        value: alertDefinition.get('service.displayName')
      }),
      App.AlertConfigProperties.Component.create({
        options: this.get('allComponents'),
        value: alertDefinition.get('componentName') ? App.format.role(alertDefinition.get('componentName')) : 'No component'
      }),
      App.AlertConfigProperties.Scope.create({
        value: alertDefinition.get('scope').toLowerCase().capitalize()
      }),
      App.AlertConfigProperties.Description.create({
        value: alertDefinition.get('description')
      }),
      App.AlertConfigProperties.Interval.create({
        value: alertDefinition.get('interval')
      }),
      App.AlertConfigProperties.Thresholds.create({
        value: this.get('thresholdsFrom') + '-' + this.get('thresholdsTo'),
        from: this.get('thresholdsFrom'),
        to: this.get('thresholdsTo')
      }),
      App.AlertConfigProperties.Path.create({
        value: alertDefinition.get('location')
      })
    ];
  },

  /**
   * Render config properties for aggregate-type alert definition
   * @returns {Array}
   */
  renderAggregateConfigs: function () {
    var alertDefinition = this.get('content');
    return [
      App.AlertConfigProperties.AlertNameSelected.create({
        value: alertDefinition.get('name'),
        options: this.get('aggregateAlertNames')
      }),
      App.AlertConfigProperties.Description.create({
        value: alertDefinition.get('description')
      })
    ];
  },

  /**
   * Edit configs button handler
   */
  editConfigs: function () {
    this.get('configs').forEach(function (property) {
      property.set('previousValue', property.get('value'));
    });
    this.get('configs').setEach('isDisabled', false);
    this.set('canEdit', true);
  },

  /**
   * Cancel edit configs button handler
   */
  cancelEditConfigs: function () {
    this.get('configs').forEach(function (property) {
      property.set('value', property.get('previousValue'));
    });
    this.get('configs').setEach('isDisabled', true);
    this.set('canEdit', false);
  },

  /**
   * Save edit configs button handler
   */
  saveConfigs: function () {
    this.get('configs').setEach('isDisabled', true);
    this.set('canEdit', false);

    var propertiesToUpdate = this.getPropertiesToUpdate();

    App.ajax.send({
      name: 'alerts.update_alert_definition',
      sender: this,
      data: {
        id: this.get('content.id'),
        data: propertiesToUpdate
      }
    });
  },

  /**
   * Create object with new values to put it on server
   * @returns {Object}
   */
  getPropertiesToUpdate: function () {
    var propertiesToUpdate = {};
    this.get('configs').filterProperty('wasChanged').forEach(function (property) {
      var apiProperties = property.get('apiProperty');
      var apiFormattedValues = property.get('apiFormattedValue');
      if (!Em.isArray(property.get('apiProperty'))) {
        apiProperties = [property.get('apiProperty')];
        apiFormattedValues = [property.get('apiFormattedValue')];
      }
      apiProperties.forEach(function (apiProperty, i) {
        if (apiProperty.contains('source.')) {
          if (!propertiesToUpdate['AlertDefinition/source']) {
            propertiesToUpdate['AlertDefinition/source'] = this.get('content.rawSourceData');
          }

          var sourcePath = propertiesToUpdate['AlertDefinition/source'];
          apiProperty.replace('source.', '').split('.').forEach(function (path, index, array) {
            // check if it is last path
            if (array.length - index === 1) {
              sourcePath[path] = apiFormattedValues[i];
            } else {
              sourcePath = sourcePath[path];
            }
          });

        } else {
          propertiesToUpdate['AlertDefinition/' + apiProperty] = apiFormattedValues[i];
        }
      }, this);
    }, this);

    return propertiesToUpdate;
  }

});