/**
* 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({
template: Ember.Handlebars.compile('
{{t installer.step2.evaluateStep.installedHosts}}
' + self.get('inputtedAgainHostNames').join(', ') + '
{{t installer.step2.evaluateStep.continueConfirm}}
') }) }); }, /** * 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({ template: Ember.Handlebars.compile(['{{#each host in view.hostNames}}{{host}}
{{/each}}'].join('\n')), hostNames: 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, onPrimary: function () { this.hide(); }, 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'); } });