/** * 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'); var validator = require('utils/validator'); App.WizardStep2Controller = Em.Controller.extend({ name: 'wizardStep2Controller', hostNameArr: [], isPattern: false, bootRequestId: null, hasSubmitted: false, inputtedAgainHostNames: [], isInstaller: function () { return this.get('content.controllerName') == 'installerController'; }.property('content.controllerName'), hostNames: function () { return this.get('content.installOptions.hostNames'); }.property('content.installOptions.hostNames'), manualInstall: function () { return this.get('content.installOptions.manualInstall'); }.property('content.installOptions.manualInstall'), sshKey: function () { return this.get('content.installOptions.sshKey'); }.property('content.installOptions.sshKey'), sshUser: function () { return this.get('content.installOptions.sshUser'); }.property('content.installOptions.sshUser'), installType: function () { return this.get('manualInstall') ? 'manualDriven' : 'ambariDriven'; }.property('manualInstall'), isHostNameValid: function (hostname) { return validator.isHostname(hostname); }, /** * set not installed hosts to the hostNameArr */ updateHostNameArr: function(){ this.hostNameArr = this.get('hostNames').trim().split(new RegExp("\\s+", "g")); this.patternExpression(); this.get('inputtedAgainHostNames').clear(); var installedHostNames = App.Host.find().mapProperty('hostName'); var tempArr = []; for (var i = 0; i < this.hostNameArr.length; i++) { if (!installedHostNames.contains(this.hostNameArr[i])) { tempArr.push(this.hostNameArr[i]); } else { this.get('inputtedAgainHostNames').push(this.hostNameArr[i]); } } this.set('hostNameArr', tempArr); }, invalidHostNames: [], /** * validate host names * @return {Boolean} */ isAllHostNamesValid: function () { var result = true; this.updateHostNameArr(); this.get('invalidHostNames').clear(); this.hostNameArr.forEach(function(hostName){ if (!this.isHostNameValid(hostName)) { this.get('invalidHostNames').push(hostName); result = false; } }, this); return result; }, hostsError: null, /** * set hostsError if host names don't pass validation */ checkHostError: function () { if (this.get('hostNames').trim() === '') { this.set('hostsError', Em.I18n.t('installer.step2.hostName.error.required')); } else { this.set('hostsError', null); } }, checkHostAfterSubmitHandler: function() { if (this.get('hasSubmitted')) { this.checkHostError(); } }.observes('hasSubmitted', 'hostNames'), sshKeyError: function () { if (this.get('hasSubmitted') && this.get('manualInstall') === false && this.get('sshKey').trim() === '') { return Em.I18n.t('installer.step2.sshKey.error.required'); } return null; }.property('sshKey', 'manualInstall', 'hasSubmitted'), sshUserError: function(){ if (this.get('manualInstall') === false && this.get('sshUser').trim() === '') { return Em.I18n.t('installer.step2.sshUser.required'); } return null; }.property('sshUser', 'hasSubmitted', 'manualInstall'), /** * Get host info, which will be saved in parent controller */ getHostInfo: function () { var hostNameArr = this.get('hostNameArr'); var hostInfo = {}; for (var i = 0; i < hostNameArr.length; i++) { hostInfo[hostNameArr[i]] = { name: hostNameArr[i], installType: this.get('installType'), bootStatus: 'PENDING' }; } return hostInfo; }, /** * Used to set sshKey from FileUploader * @param sshKey */ setSshKey: function(sshKey){ this.set("content.installOptions.sshKey", sshKey); }, /** * Onclick handler for next button. Do all UI work except data saving. * This work is doing by router. * @return {Boolean} */ evaluateStep: function () { console.log('TRACE: Entering controller:WizardStep2:evaluateStep function'); if (this.get('isSubmitDisabled')) { return false; } this.set('hasSubmitted', true); this.checkHostError(); if (this.get('hostsError') || this.get('sshUserError') || this.get('sshKeyError')) { return false; } this.updateHostNameArr(); if (!this.hostNameArr.length) { this.set('hostsError', Em.I18n.t('installer.step2.hostName.error.already_installed')); return false; } if(this.isPattern) { this.hostNamePatternPopup(this.hostNameArr); return false; } if (this.get('inputtedAgainHostNames').length) { this.installedHostsPopup(); } else { this.proceedNext(); } }, /** * check is there a pattern expression in host name textarea * push hosts that match pattern in hostNamesArr */ patternExpression: function(){ this.isPattern = false; var self = this; var hostNames = []; $.each(this.hostNameArr, function(e,a){ var start, end, extra = {0:""}; if(/\[\d*\-\d*\]/.test(a)){ start=a.match(/\[\d*/); end=a.match(/\-\d*]/); start=start[0].substr(1); end=end[0].substr(1); if(parseInt(start) <= parseInt(end, 10) && parseInt(start, 10) >= 0){ self.isPattern = true; if(start[0] == "0" && start.length > 1) { extra = start.match(/0*/); } for (var i = parseInt(start, 10); i < parseInt(end, 10) + 1; i++) { hostNames.push(a.replace(/\[\d*\-\d*\]/,extra[0].substring(0,start.length-i.toString().length)+i)) } }else{ hostNames.push(a); } }else{ hostNames.push(a); } }); this.hostNameArr = hostNames; }, /** * launch hosts to bootstrap * and save already registered hosts * @return {Boolean} */ proceedNext: function(warningConfirmed){ if (this.isAllHostNamesValid() !== true && !warningConfirmed) { this.warningPopup(); return false; } if (this.get('manualInstall') === true) { this.manualInstallPopup(); return false; } var bootStrapData = JSON.stringify({'verbose': true, 'sshKey': this.get('sshKey'), 'hosts': this.get('hostNameArr'), 'user': this.get('sshUser')}); if (App.skipBootstrap) { this.saveHosts(); return true; } var requestId = App.router.get(this.get('content.controllerName')).launchBootstrap(bootStrapData); if (requestId == '0') { var controller = App.router.get(App.clusterStatus.wizardControllerName); controller.registerErrPopup(Em.I18n.t('common.information'), Em.I18n.t('installer.step2.evaluateStep.hostRegInProgress')); } else if (requestId) { this.set('content.installOptions.bootRequestId', requestId); this.saveHosts(); } }, /** * show warning for host names without dots or IP addresses */ warningPopup: function () { var self = this; App.ModalPopup.show({ header: Em.I18n.t('common.warning'), onPrimary: function () { this.hide(); self.proceedNext(true); }, bodyClass: Ember.View.extend({ template: Ember.Handlebars.compile(Em.I18n.t('installer.step2.warning.popup.body').format(self.get('invalidHostNames').join(', '))) }) }); }, /** * show popup with the list of hosts that are already part of the cluster */ installedHostsPopup: function () { var self = this; App.ModalPopup.show({ header: Em.I18n.t('common.warning'), onPrimary: function () { self.proceedNext(); this.hide(); }, bodyClass: Ember.View.extend({ inputtedAgainHostNames: function() { return self.get('inputtedAgainHostNames').join(', '); }.property(), templateName: require('templates/wizard/step2_installed_hosts_popup') }) }); }, /** * show popup with hosts generated by pattern * @param hostNames */ hostNamePatternPopup: function (hostNames) { var self = this; App.ModalPopup.show({ header: Em.I18n.t('installer.step2.hostName.pattern.header'), onPrimary: function () { self.proceedNext(); this.hide(); }, bodyClass: Ember.View.extend({ templateName: require('templates/common/items_list_popup'), items: hostNames }) }); }, /** * show notify that installation is manual * save hosts */ manualInstallPopup: function () { var self = this; App.ModalPopup.show({ header: Em.I18n.t('installer.step2.manualInstall.popup.header'), onPrimary: function () { this.hide(); self.saveHosts(); }, bodyClass: Ember.View.extend({ templateName: require('templates/wizard/step2ManualInstallPopup') }) }); }, /** * warn to manually install ambari-agent on each host */ manualInstallWarningPopup: function(){ if(!this.get('content.installOptions.useSsh')){ App.ModalPopup.show({ header: Em.I18n.t('common.warning'), body: Em.I18n.t('installer.step2.manualInstall.info'), encodeBody: false, secondary: null }); } this.set('content.installOptions.manualInstall', !this.get('content.installOptions.useSsh')); }.observes('content.installOptions.useSsh'), isSubmitDisabled: function () { return (this.get('hostsError') || this.get('sshKeyError') || this.get('sshUserError')) ; }.property('hostsError', 'sshKeyError', 'sshUserError'), setAmbariJavaHome: function(){ App.ajax.send({ name: 'ambari.service', sender: this, success: 'onGetAmbariJavaHomeSuccess', error: 'onGetAmbariJavaHomeError' }); }, onGetAmbariJavaHomeSuccess: function(data) { this.set('content.installOptions.javaHome',data.RootServiceComponents.properties['java.home']); }, onGetAmbariJavaHomeError: function() { console.warn('can\'t get java.home value from server'); this.set('content.installOptions.javaHome',App.defaultJavaHome); }, saveHosts: function(){ this.set('content.hosts', this.getHostInfo()); this.setAmbariJavaHome(); App.router.send('next'); } });