ambari/ambari-web/app/controllers/main/mirroring/edit_dataset_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.MainMirroringEditDataSetController = Ember.Controller.extend({
  name: 'mainMirroringEditDataSetController',

  // Fields values from Edit DataSet form
  formFields: Ember.Object.create({
    datasetName: null,
    datasetType: null,
    datasetTargetClusterName: null,
    datasetSourceDir: null,
    datasetTargetDir: null,
    datasetStartDate: null,
    hoursForStart: null,
    minutesForStart: null,
    middayPeriodForStart: null,
    datasetEndDate: null,
    hoursForEnd: null,
    minutesForEnd: null,
    middayPeriodForEnd: null,
    datasetFrequency: null,
    repeatOptionSelected: null
  }),

  // Messages for errors occurred during Edit DataSet form validation
  errorMessages: Ember.Object.create({
    name: '',
    sourceDir: '',
    targetDir: '',
    startDate: '',
    endDate: '',
    frequency: ''
  }),

  errors: Ember.Object.create({
    isNameError: false,
    isSourceDirError: false,
    isTargetDirError: false,
    isStartDateError: false,
    isEndDateError: false,
    isFrequencyError: false
  }),

  clearStep: function () {
    var formFields = this.get('formFields');
    Em.keys(formFields).forEach(function (key) {
      formFields.set(key, null);
    }, this);
    this.clearErrors();
  },

  clearErrors: function () {
    var errorMessages = this.get('errorMessages');
    Em.keys(errorMessages).forEach(function (key) {
      errorMessages.set(key, '');
    }, this);
    var errors = this.get('errors');
    Em.keys(errors).forEach(function (key) {
      errors.set(key, false);
    }, this);
  },

  showAddPopup: function () {
    this.showPopup(Em.I18n.t('mirroring.dataset.newDataset'));
  },

  showPopup: function (header) {
    var self = this;
    App.ModalPopup.show({
      classNames: ['sixty-percent-width-modal'],
      header: header,
      primary: Em.I18n.t('mirroring.dataset.save'),
      secondary: Em.I18n.t('common.cancel'),
      showCloseButton: false,
      saveDisabled: function () {
        return !self.get('saveDisabled');
      }.property('App.router.' + self.get('name') + '.saveDisabled'),
      enablePrimary: function () {
        return this.get('saveDisabled');
      }.property('saveDisabled'),
      onPrimary: function () {
        if (!this.get('saveDisabled')) {
          return false;
        }
        // Apply form validation for first click
        if (!this.get('primaryWasClicked')) {
          this.toggleProperty('primaryWasClicked');
          self.applyValidation();
          if (!this.get('saveDisabled')) {
            return false;
          }
        }
        self.save();
        this.hide();
        App.router.transitionTo('main.mirroring.index');
      },
      primaryWasClicked: false,
      onSecondary: function () {
        this.hide();
        App.router.transitionTo('main.mirroring.index');
      },
      bodyClass: App.MainMirroringEditDataSetView.extend({
        controller: self
      })
    });
  },

  // Set observer to call validate method if any property from formFields will change
  applyValidation: function () {
    Em.keys(this.get('formFields')).forEach(function (key) {
      this.addObserver('formFields.' + key, this, 'validate');
    }, this);
    this.validate();
  },

  // Return date object calculated from appropriate fields
  scheduleStartDate: function () {
    var startDate = this.get('formFields.datasetStartDate');
    var hoursForStart = this.get('formFields.hoursForStart');
    var minutesForStart = this.get('formFields.minutesForStart');
    var middayPeriodForStart = this.get('formFields.middayPeriodForStart');
    if (startDate && hoursForStart && minutesForStart && middayPeriodForStart) {
      return new Date(startDate + ' ' + hoursForStart + ':' + minutesForStart + ' ' + middayPeriodForStart);
    }
    return null;
  }.property('formFields.datasetStartDate', 'formFields.hoursForStart', 'formFields.minutesForStart', 'formFields.middayPeriodForStart'),

  // Return date object calculated from appropriate fields
  scheduleEndDate: function () {
    var endDate = this.get('formFields.datasetEndDate');
    var hoursForEnd = this.get('formFields.hoursForEnd');
    var minutesForEnd = this.get('formFields.minutesForEnd');
    var middayPeriodForEnd = this.get('formFields.middayPeriodForEnd');
    if (endDate && hoursForEnd && minutesForEnd && middayPeriodForEnd) {
      return new Date(endDate + ' ' + hoursForEnd + ':' + minutesForEnd + ' ' + middayPeriodForEnd);
    }
    return null;
  }.property('formFields.datasetEndDate', 'formFields.hoursForEnd', 'formFields.minutesForEnd', 'formFields.middayPeriodForEnd'),


  // Validation for every field in Edit DataSet form
  validate: function () {
    var formFields = this.get('formFields');
    var errors = this.get('errors');
    var errorMessages = this.get('errorMessages');
    this.clearErrors();
    // Check if feild is empty
    Em.keys(errorMessages).forEach(function (key) {
      if (!formFields.get('dataset' + key.capitalize())) {
        errors.set('is' + key.capitalize() + 'Error', true);
        errorMessages.set(key, Em.I18n.t('mirroring.required.error'));
      }
    }, this);
    // Check that endDate is after startDate
    var scheduleStartDate = this.get('scheduleStartDate');
    var scheduleEndDate = this.get('scheduleEndDate');
    if (scheduleStartDate && scheduleEndDate && (scheduleStartDate > scheduleEndDate)) {
      errors.set('isEndDateError', true);
      errorMessages.set('endDate', Em.I18n.t('mirroring.dateOrder.error'));
    }
    // Check that repeat field value consists only from digits
    if (isNaN(this.get('formFields.datasetFrequency'))) {
      errors.set('isFrequencyError', true);
      errorMessages.set('frequency', Em.I18n.t('mirroring.required.invalidNumberError'));
    }
  },

  // Add '0' for numbers less than 10
  addZero: function (number) {
    return ('0' + number).slice(-2);
  },

  // Convert date to TZ format
  toTZFormat: function (date) {
    return date.getFullYear() + '-' + this.addZero(date.getMonth() + 1) + '-' + this.addZero(date.getDate()) + 'T' + this.addZero(date.getHours()) + ':' + this.addZero(date.getMinutes()) + 'Z';
  },

  save: function () {
    var datasetName = this.get('formFields.datasetName');
    var sourceCluster = App.get('clusterName');
    var targetCluster = this.get('formFields.datasetTargetClusterName');
    var sourceDir = this.get('formFields.datasetSourceDir');
    var targetDir = this.get('formFields.datasetTargetDir');
    var datasetFrequency = this.get('formFields.datasetFrequency');
    var repeatOptionSelected = this.get('formFields.repeatOptionSelected');
    var startDate = this.get('scheduleStartDate');
    var endDate = this.get('scheduleEndDate');
    var scheduleStartDateFormatted = this.toTZFormat(startDate);
    var scheduleEndDateFormatted = this.toTZFormat(endDate);

    // Compose XML data, that will be sended to server
    var dataToSend = '<?xml version="1.0"?><feed description="" name="' + datasetName + '" xmlns="uri:falcon:feed:0.1"><frequency>' + repeatOptionSelected + '(' + datasetFrequency + ')' +
        '</frequency><clusters><cluster name="' + targetCluster + '" type="source"><validity start="' + scheduleStartDateFormatted + '" end="' + scheduleEndDateFormatted +
        '"/><retention limit="days(7)" action="delete"/></cluster><cluster name="' + targetCluster + '" type="target"><validity start="' + scheduleStartDateFormatted + '" end="' +
        '"/><retention limit="months(1)" action="delete"/><locations><location type="data" path="' + targetDir + '" /></locations></cluster></clusters><locations><location type="data" path="' +
        sourceDir + '" /></locations><ACL owner="hue" group="users" permission="0755" /><schema location="/none" provider="none"/></feed>';

    // Send request to server to create dataset
    App.ajax.send({
      name: 'mirroring.create_new_dataset',
      sender: this,
      data: {
        dataset: dataToSend
      },
      error: 'onCreateNewDatasetError'
    });

    var newDataset = {
      id: datasetName,
      name: datasetName,
      source_cluster_name: sourceCluster,
      target_cluster_name: targetCluster,
      source_dir: sourceDir,
      target_dir: targetDir,
      dataset_jobs: []
    };
    App.store.load(App.Dataset, newDataset);
  },

  onCreateNewDatasetError: function () {
    console.error('Error in sending new dataset data to server.');
  },

  saveDisabled: function () {
    var errors = this.get('errors');
    return errors.get('isNameError') || errors.get('isSourceDirError') || errors.get('isTargetDirError') || errors.get('isStartDateError') || errors.get('isEndDateError') || errors.get('isFrequencyError');
  }.property('errors.isNameError', 'errors.isSourceDirError', 'errors.isTargetDirError', 'errors.isStartDateError', 'errors.isEndDateError', 'errors.isFrequencyError')
});