/**
* 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');
require('models/host');
App.WizardController = Em.Controller.extend(App.LocalStorage, App.ThemesMappingMixin, {
isStepDisabled: null,
previousStep: 0,
/**
* map of actions which load data required by which step
* used by loadAllPriorSteps
*/
loadMap: {},
/**
* Wizard properties in local storage, which should be cleaned right after wizard has been finished
*/
dbPropertiesToClean: [
'service',
'hosts',
'masterComponentHosts',
'slaveComponentHosts',
'cluster',
'allHostNames',
'installOptions',
'allHostNamesPattern',
'serviceComponents',
'fileNamesToUpdate'
],
sensibleConfigs: [
{ name: 'admin_principal', filename: 'krb5-conf.xml'},
{ name: 'admin_password', filename: 'krb5-conf.xml' }
],
init: function () {
this.clusters = App.Cluster.find();
this.setIsStepDisabled();
},
connectOutlet:function(name) {
if (name !== 'loading') this.set('isStepDisabled.isLocked', false);
App.router.setProperties({
backBtnClickInProgress: false,
nextBtnClickInProgress: false
});
return this._super.apply(this,arguments);
},
/**
* Set isStepDisabled
with list of available steps (basing on totalSteps
)
* @method setIsStepDisabled
*/
setIsStepDisabled: function () {
this.set('isStepDisabled', Ember.ArrayProxy.create({
content:[],
isLocked:true,
objectAtContent: function(idx) {
var obj = this.get('content').objectAt(idx);
if (obj && !obj.hasOwnProperty('isLocked')) {
obj.reopen({
isLocked:true,
get:function (key) {
return key === 'value' && this.get('isLocked') || this._super.apply(this,arguments);
},
notifyValues:function () {
this.notifyPropertyChange('value');
}.observes('isLocked')
});
}
return obj;
},
toggleLock:function () {
this.setEach('isLocked',this.get('isLocked'));
}.observes('isLocked')
}));
this.get('isStepDisabled').pushObject(Em.Object.create({
step: 1,
value: false
}));
for (var i = 2; i <= this.get('totalSteps'); i++) {
this.get('isStepDisabled').pushObject(Em.Object.create({
step: i,
value: true
}));
}
},
slaveComponents: function () {
return App.StackServiceComponent.find().filterProperty('isSlave', true);
}.property('App.router.clusterController.isLoaded'),
allHosts: function () {
var dbHosts = this.get('content.hosts');
var hosts = [];
var hostComponents = [];
for (var hostName in dbHosts) {
hostComponents = [];
var disksOverallCapacity = 0;
var diskFree = 0;
dbHosts[hostName].hostComponents.forEach(function (componentName) {
hostComponents.push(Em.Object.create({
componentName: componentName,
displayName: App.format.role(componentName, false)
}));
});
dbHosts[hostName].disk_info.forEach(function (disk) {
disksOverallCapacity += parseFloat(disk.size);
diskFree += parseFloat(disk.available);
});
hosts.push(Em.Object.create({
id: hostName,
hostName: hostName,
publicHostName: hostName,
diskInfo: dbHosts[hostName].disk_info,
diskTotal: disksOverallCapacity / (1024 * 1024),
diskFree: diskFree / (1024 * 1024),
disksMounted: dbHosts[hostName].disk_info.length,
cpu: dbHosts[hostName].cpu,
memory: dbHosts[hostName].memory,
osType: dbHosts[hostName].osType ? dbHosts[hostName].osType: 0,
osArch: dbHosts[hostName].osArch ? dbHosts[hostName].osArch : 0,
ip: dbHosts[hostName].ip ? dbHosts[hostName].ip: 0,
hostComponents: hostComponents,
maintenanceState: dbHosts[hostName].maintenance_state
}))
}
return hosts;
}.property('content.hosts'),
setStepsEnable: function () {
for (var i = 1; i <= this.totalSteps; i++) {
var step = this.get('isStepDisabled').findProperty('step', i);
if (i <= this.get('currentStep')) {
step.set('value', false);
} else {
step.set('value', true);
}
}
}.observes('currentStep'),
/**
* Enable step link in left nav menu
* @param step - step number
*/
enableStep: function (step) {
this.get('isStepDisabled').findProperty('step', step).set('value', false);
},
setLowerStepsDisable: function (stepNo) {
for (var i = 1; i < stepNo; i++) {
var step = this.get('isStepDisabled').findProperty('step', i);
step.set('value', true);
}
},
/**
* Set current step to new value.
* Method moved from App.router.setInstallerCurrentStep
* @param currentStep
* @param completed
*/
currentStep: function () {
return App.get('router').getWizardCurrentStep(this.get('name').substr(0, this.get('name').length - 10));
}.property(),
/**
* Set current step to new value.
* Method moved from App.router.setInstallerCurrentStep
* @param currentStep
* @param completed
*/
setCurrentStep: function (currentStep, completed) {
this.set('previousStep', this.get('currentStep'));
App.db.setWizardCurrentStep(this.get('name').substr(0, this.get('name').length - 10), currentStep, completed);
this.set('currentStep', currentStep);
},
clusters: null,
isStep0: function () {
return this.get('currentStep') == 0;
}.property('currentStep'),
isStep1: function () {
return this.get('currentStep') == 1;
}.property('currentStep'),
isStep2: function () {
return this.get('currentStep') == 2;
}.property('currentStep'),
isStep3: function () {
return this.get('currentStep') == 3;
}.property('currentStep'),
isStep4: function () {
return this.get('currentStep') == 4;
}.property('currentStep'),
isStep5: function () {
return this.get('currentStep') == 5;
}.property('currentStep'),
isStep6: function () {
return this.get('currentStep') == 6;
}.property('currentStep'),
isStep7: function () {
return this.get('currentStep') == 7;
}.property('currentStep'),
isStep8: function () {
return this.get('currentStep') == 8;
}.property('currentStep'),
isStep9: function () {
return this.get('currentStep') == 9;
}.property('currentStep'),
isStep10: function () {
return this.get('currentStep') == 10;
}.property('currentStep'),
/**
* Move user to the selected step
*
* @param {number} step number of the step, where user is moved
* @param {boolean} disableNaviWarning true - don't show warning about moving more than 1 step back
* @returns {boolean}
*/
gotoStep: function (step, disableNaviWarning) {
if (this.get('isStepDisabled').findProperty('step', step).get('value') !== false) {
return false;
}
// if going back from Step 9 in Install Wizard, delete the checkpoint so that the user is not redirected
// to Step 9
if (this.get('content.controllerName') === 'installerController' && this.get('currentStep') === '9' && step < 9) {
App.clusterStatus.setClusterStatus({
clusterName: this.get('clusterName'),
clusterState: 'CLUSTER_NOT_CREATED_1',
wizardControllerName: 'installerController',
localdb: {}
});
}
if ((this.get('currentStep') - step) > 1 && !disableNaviWarning) {
App.ModalPopup.show({
header: Em.I18n.t('installer.navigation.warning.header'),
onPrimary: function () {
App.router.send('gotoStep' + step);
this.hide();
},
body: "If you proceed to go back to Step " + step + ", you will lose any changes you have made beyond this step"
});
} else {
App.router.send('gotoStep' + step);
}
return true;
},
gotoStep0: function () {
this.gotoStep(0);
},
gotoStep1: function () {
this.gotoStep(1);
},
gotoStep2: function () {
this.gotoStep(2);
},
gotoStep3: function () {
this.gotoStep(3);
},
gotoStep4: function () {
this.gotoStep(4);
},
gotoStep5: function () {
this.gotoStep(5);
},
gotoStep6: function () {
this.gotoStep(6);
},
gotoStep7: function () {
this.gotoStep(7);
},
gotoStep8: function () {
this.gotoStep(8);
},
gotoStep9: function () {
this.gotoStep(9);
},
gotoStep10: function () {
this.gotoStep(10);
},
/**
* Initialize host status info for step9
*/
setInfoForStep9: function () {
var hostInfo = this.getDBProperty('hosts');
for (var index in hostInfo) {
hostInfo[index].status = "pending";
hostInfo[index].message = 'Waiting';
hostInfo[index].logTasks = [];
hostInfo[index].tasks = [];
hostInfo[index].progress = '0';
}
this.setDBProperty('hosts', hostInfo);
},
/**
* Remove all data for installOptions step
*/
clearInstallOptions: function () {
var installOptions = this.getInstallOptions();
this.set('content.installOptions', installOptions);
this.set('content.hosts', {});
this.setDBProperties({
installOptions: installOptions,
hosts: {}
});
},
toObject: function (object) {
var result = {};
for (var i in object) {
if (object.hasOwnProperty(i)) {
result[i] = object[i];
}
}
return result;
},
/**
* Convert any object or array to pure JS instance without inherit properties
* It is used to convert Ember.Object to pure JS Object and Ember.Array to pure JS Array
* @param originalInstance
* @returns {*}
*/
toJSInstance: function (originalInstance) {
var convertedInstance = originalInstance;
if (Em.isArray(originalInstance)) {
convertedInstance = [];
originalInstance.forEach(function (element) {
convertedInstance.push(this.toJSInstance(element));
}, this)
} else if (originalInstance && typeof originalInstance === 'object') {
convertedInstance = {};
for (var property in originalInstance) {
if (originalInstance.hasOwnProperty(property)) {
convertedInstance[property] = this.toJSInstance(originalInstance[property]);
}
}
}
return convertedInstance
},
/**
* save status of the cluster. This is called from step8 and step9 to persist install and start requestId
* @param clusterStatus object with status, isCompleted, requestId, isInstallError and isStartError field.
*/
saveClusterStatus: function (clusterStatus) {
var oldStatus = this.toObject(this.get('content.cluster'));
clusterStatus = jQuery.extend(oldStatus, clusterStatus);
if (clusterStatus.requestId &&
clusterStatus.oldRequestsId.indexOf(clusterStatus.requestId) === -1) {
clusterStatus.oldRequestsId.push(clusterStatus.requestId);
}
this.set('content.cluster', clusterStatus);
this.setDBProperty('cluster', clusterStatus);
},
/**
* Invoke installation of selected services to the server and saves the request id returned by the server.
* @param isRetry
*/
installServices: function (isRetry, callback) {
// clear requests since we are installing services
// and we don't want to get tasks for previous install attempts
this.set('content.cluster.oldRequestsId', []);
var data;
callback = callback || Em.K;
if (isRetry) {
data = {
context: Em.I18n.t('requestInfo.installComponents'),
HostRoles: {"state": "INSTALLED"},
urlParams: "HostRoles/desired_state=INSTALLED"
};
} else {
data = {
context: Em.I18n.t('requestInfo.installServices'),
ServiceInfo: {"state": "INSTALLED"},
urlParams: "ServiceInfo/state=INIT"
};
}
var clusterStatus = {
status: 'PENDING'
};
this.saveClusterStatus(clusterStatus);
App.ajax.send({
name: isRetry ? 'common.host_components.update' : 'common.services.update',
sender: this,
data: data,
success: 'installServicesSuccessCallback',
error: 'installServicesErrorCallback'
}).then(callback, callback);
},
installServicesSuccessCallback: function (jsonData) {
var installStartTime = App.dateTime();
if (jsonData) {
var requestId = jsonData.Requests.id;
var clusterStatus = {
status: 'PENDING',
requestId: requestId,
isInstallError: false,
isCompleted: false,
installStartTime: installStartTime
};
this.saveClusterStatus(clusterStatus);
}
},
installServicesErrorCallback: function (request, ajaxOptions, error) {
var clusterStatus = {
status: 'PENDING',
requestId: this.get('content.cluster.requestId'),
isInstallError: true,
isCompleted: false
};
this.saveClusterStatus(clusterStatus);
App.showAlertPopup(Em.I18n.t('common.errorPopup.header'), request.responseText);
},
/**
* show popup, that display status of bootstrap launching
* @param callback
* @return {Object}
*/
showLaunchBootstrapPopup: function (callback) {
return App.ModalPopup.show({
header: Em.I18n.t('installer.step2.bootStrap.header'),
isError: false,
serverError: null,
bodyClass: Em.View.extend({
templateName: require('templates/wizard/bootstrap_call_popup')
}),
showFooter: false,
showCloseButton: false,
secondary: null,
/**
* handle requestId when call is completed,
* if it's correct call callback and hide popup
* otherwise notify error and enable buttons to close popup
* @param requestId
* @param serverError
* @param status
* @param log
*/
finishLoading: function (requestId, serverError, status, log) {
if (Em.isNone(requestId) || status === 'ERROR') {
var stepController = App.get('router.wizardStep3Controller');
this.setProperties({
isError: true,
showFooter: true,
showCloseButton: true,
serverError: status === 'ERROR' ? log : serverError
});
stepController.setProperties({
isRegistrationInProgress: false,
isBootstrapFailed: true
});
stepController.get('hosts').setEach('bootStatus', 'FAILED');
} else {
callback(requestId);
this.hide();
}
}
});
},
/**
* Bootstrap selected hosts.
* @param bootStrapData
* @param callback
* @return {Object}
*/
launchBootstrap: function (bootStrapData, callback) {
var popup = this.showLaunchBootstrapPopup(callback);
App.ajax.send({
name: 'wizard.launch_bootstrap',
sender: this,
data: {
bootStrapData: bootStrapData,
popup: popup
},
success: 'launchBootstrapSuccessCallback',
error: 'launchBootstrapErrorCallback'
});
return popup;
},
launchBootstrapSuccessCallback: function (data, opt, params) {
params.popup.finishLoading(data.requestId, null, data.status, data.log);
},
launchBootstrapErrorCallback: function (request, ajaxOptions, error, opt, params) {
params.popup.finishLoading(null, error);
},
/**
* Load content.
variable from localStorage, if wasn't loaded before.
* If you specify reload
to true - it will reload it.
* @param name
* @param reload
* @return {Boolean}
*/
load: function (name, reload) {
if (this.get('content.' + name) && !reload) {
return false;
}
var result = this.getDBProperty(name);
if (!result) {
if (this['get' + name.capitalize()]) {
result = this['get' + name.capitalize()]();
this.setDBProperty(name, result);
}
else {
console.debug('get' + name.capitalize(), ' not defined in the ' + this.get('name'));
}
}
this.set('content.' + name, result);
},
save: function (name) {
var convertedValue = this.toJSInstance(this.get('content.' + name));
this.setDBProperty(name, convertedValue);
},
clear: function () {
this.set('content', Ember.Object.create({
'controllerName': this.get('content.controllerName')
}));
this.set('currentStep', 0);
this.clearStorageData();
},
clusterStatusTemplate: {
name: "",
status: "PENDING",
isCompleted: false,
requestId: null,
installStartTime: null,
installTime: null,
isInstallError: false,
isStartError: false,
oldRequestsId: []
},
clearStorageData: function () {
var hash = {};
this.get('dbPropertiesToClean').forEach(function (key) {
hash[key] = undefined;
}, this);
this.setDBProperties(hash);
},
getInstallOptions: function() {
return jQuery.extend({}, App.get('isHadoopWindowsStack') ? this.get('installWindowsOptionsTemplate') : this.get('installOptionsTemplate'));
},
installOptionsTemplate: {
hostNames: "", //string
manualInstall: false, //true, false
useSsh: true, //bool
javaHome: App.defaultJavaHome, //string
localRepo: false, //true, false
sshKey: "", //string
bootRequestId: null, //string
sshUser: "root", //string
sshPort: "22",
agentUser: "root" //string
},
installWindowsOptionsTemplate: {
hostNames: "", //string
manualInstall: false, //true, false
useSsh: true, //bool
javaHome: App.defaultJavaHome, //string
localRepo: false, //true, false
sshKey: "", //string
bootRequestId: null, //string
sshUser: "", //string
sshPort: "22",
agentUser: "" //string
},
loadedServiceComponents: null,
/**
* Generate serviceComponents as pr the stack definition and save it to localdata
* called form stepController step4WizardController
*/
loadServiceComponents: function () {
return App.ajax.send({
name: 'wizard.service_components',
sender: this,
data: {
stackUrl: App.get('stackVersionURL'),
stackVersion: App.get('currentStackVersionNumber')
},
success: 'loadServiceComponentsSuccessCallback',
error: 'loadServiceComponentsErrorCallback'
});
},
loadServiceComponentsSuccessCallback: function (jsonData) {
var props = this.getDBProperties(['selectedServiceNames', 'installedServiceNames']);
var savedSelectedServices = props.selectedServiceNames;
var savedInstalledServices = props.installedServiceNames;
this.set('content.selectedServiceNames', savedSelectedServices);
this.set('content.installedServiceNames', savedInstalledServices);
if (!savedSelectedServices) {
jsonData.items.forEach(function (service) {
service.StackServices.is_selected = true;
}, this);
} else {
jsonData.items.forEach(function (service) {
service.StackServices.is_selected = savedSelectedServices.contains(service.StackServices.service_name);
}, this);
}
if (!savedInstalledServices) {
jsonData.items.forEach(function (service) {
service.StackServices.is_installed = false;
}, this);
} else {
jsonData.items.forEach(function (service) {
service.StackServices.is_installed = savedInstalledServices.contains(service.StackServices.service_name);
}, this);
}
App.stackServiceMapper.mapStackServices(jsonData);
},
loadServiceComponentsErrorCallback: function (request, ajaxOptions, error) {
},
/**
* load version for services to display on Choose Servoces page
* should load from VersionDefinition endpoint
*/
loadServiceVersionFromVersionDefinitions: function () {
return App.ajax.send({
name: 'cluster.load_current_repo_stack_services',
sender: this,
data: {
clusterName: App.clusterName
},
success: 'loadServiceVersionFromVersionDefinitionsSuccessCallback',
error: 'loadServiceVersionFromVersionDefinitionsErrorCallback'
});
},
serviceVersionsMap: {},
loadServiceVersionFromVersionDefinitionsSuccessCallback: function (jsonData) {
var rv = jsonData.items[0].repository_versions[0].RepositoryVersions;
var map = this.get('serviceVersionsMap');
if (rv) {
rv.stack_services.forEach(function (item) {
map[item.name] = item.versions[0];
});
}
},
loadServiceVersionFromVersionDefinitionsErrorCallback: function (request, ajaxOptions, error) {
},
/**
* Load config groups from local DB
*/
loadServiceConfigGroups: function () {
var props = this.getDBProperties(['serviceConfigGroups', 'hosts']);
var serviceConfigGroups = props.serviceConfigGroups,
hosts = props.hosts || {},
host_names = Em.keys(hosts);
if (Em.isNone(serviceConfigGroups)) {
serviceConfigGroups = [];
}
else {
serviceConfigGroups.forEach(function(group) {
var hostNames = group.hosts.map(function(host_id) {
for (var i = 0; i < host_names.length; i++) {
if (hosts[host_names[i]].id === host_id) {
return host_names[i];
}
}
Em.assert('host is missing!!!!', false);
});
Em.set(group, 'hosts', hostNames);
});
}
this.set('content.configGroups', serviceConfigGroups);
},
registerErrPopup: function (header, message) {
App.ModalPopup.show({
header: header,
secondary: false,
bodyClass: Ember.View.extend({
template: Ember.Handlebars.compile('
{{view.message}}
'), message: message }) }); }, /** * Save hosts that the user confirmed to proceed with from step 3 * @param stepController App.WizardStep3Controller */ saveConfirmedHosts: function (stepController) { var hosts = this.get('content.hosts'), indx = 1; //add previously installed hosts for (var hostName in hosts) { if (!hosts[hostName].isInstalled) { delete hosts[hostName]; } } stepController.get('confirmedHosts').forEach(function (_host) { if (_host.bootStatus === 'REGISTERED') { hosts[_host.name] = { name: _host.name, cpu: _host.cpu, memory: _host.memory, disk_info: _host.disk_info, os_type: _host.os_type, os_arch: _host.os_arch, ip: _host.ip, maintenance_state: _host.maintenance_state, bootStatus: _host.bootStatus, isInstalled: false, id: indx++ }; } }); this.setDBProperty('hosts', hosts); this.set('content.hosts', hosts); }, /** * Save data after installation to main controller * @param stepController App.WizardStep9Controller */ saveInstalledHosts: function (stepController) { var hosts = stepController.get('hosts'); var hostInfo = this.getDBProperty('hosts'); for (var index in hostInfo) { hostInfo[index].status = "pending"; var host = hosts.findProperty('name', hostInfo[index].name); if (host) { hostInfo[index].status = host.status; hostInfo[index].message = host.message; hostInfo[index].progress = host.progress; } } this.set('content.hosts', hostInfo); this.setDBProperty('hosts', hostInfo); }, /** * Save slaveHostComponents to main controller * @param stepController */ saveSlaveComponentHosts: function (stepController) { var hosts = stepController.get('hosts'), dbHosts = this.getDBProperty('hosts'), headers = stepController.get('headers'); var formattedHosts = Ember.Object.create(); headers.forEach(function (header) { formattedHosts.set(header.get('name'), []); }); hosts.forEach(function (host) { var checkboxes = host.checkboxes; headers.forEach(function (header) { var cb = checkboxes.findProperty('title', header.get('label')); if (cb.checked) { formattedHosts.get(header.get('name')).push({ group: 'Default', isInstalled: cb.isInstalled, host_id: dbHosts[host.hostName].id }); } }); }); var slaveComponentHosts = []; headers.forEach(function (header) { slaveComponentHosts.push({ componentName: header.get('name'), displayName: header.get('label').replace(/\s/g, ''), hosts: formattedHosts.get(header.get('name')) }); }); this.setDBProperty('slaveComponentHosts', slaveComponentHosts); this.set('content.slaveComponentHosts', slaveComponentHosts); }, /** * Return true if cluster data is loaded and false otherwise. * This is used for all wizard controllers except for installer wizard. */ dataLoading: function () { var dfd = $.Deferred(); this.connectOutlet('loading'); if (App.router.get('clusterController.isLoaded')) { dfd.resolve(); } else { var interval = setInterval(function () { if (App.router.get('clusterController.isLoaded')) { dfd.resolve(); clearInterval(interval); } }, 50); } return dfd.promise(); }, /** * Return true if user data is loaded via App.MainServiceInfoConfigsController * This function is used in reassign master wizard right now. */ usersLoading: function () { var self = this; var dfd = $.Deferred(); var miscController = App.MainAdminServiceAccountsController.create({content: self.get('content')}); miscController.loadUsers(); var interval = setInterval(function () { if (miscController.get('dataIsLoaded')) { if (self.get("content.hdfsUser")) { self.set('content.hdfsUser', miscController.get('content.hdfsUser')); } dfd.resolve(); clearInterval(interval); } }, 10); return dfd.promise(); }, /** * Save cluster status before going to deploy step * @param name cluster state. Unique for every wizard */ saveClusterState: function (name) { App.clusterStatus.setClusterStatus({ clusterName: this.get('content.cluster.name'), clusterState: name, wizardControllerName: this.get('content.controllerName'), localdb: App.db.data }); }, /** * Load serviceConfigProperties to model */ loadServiceConfigProperties: function () { var serviceConfigProperties = this.getDBProperty('serviceConfigProperties'); this.set('content.serviceConfigProperties', serviceConfigProperties); }, /** * Save config properties * @param stepController Step7WizardController */ saveServiceConfigProperties: function (stepController) { var serviceConfigProperties = []; var fileNamesToUpdate = this.getDBProperty('fileNamesToUpdate') || []; var installedServiceNames = stepController.get('installedServiceNames') || []; var installedServiceNamesMap = installedServiceNames.toWickMap(); stepController.get('stepConfigs').forEach(function (_content) { if (_content.serviceName === 'YARN') { _content.set('configs', App.config.textareaIntoFileConfigs(_content.get('configs'), 'capacity-scheduler.xml')); } _content.get('configs').forEach(function (_configProperties) { if (!Em.isNone(_configProperties.get('group'))) { return false; } var configProperty = App.config.createDefaultConfig( _configProperties.get('name'), _configProperties.get('filename'), // need to invert boolean because this argument will be inverted in method body !_configProperties.get('isUserProperty'), { value: _configProperties.get('value'), isRequired: _configProperties.get('isRequired') } ); configProperty = App.config.mergeStaticProperties(configProperty, _configProperties, [], ['name', 'filename', 'isUserProperty', 'value']); if (this.isExcludedConfig(configProperty)) { configProperty.value = ''; } serviceConfigProperties.push(configProperty); }, this); // check for configs that need to update for installed services if (installedServiceNamesMap[_content.get('serviceName')]) { // get only modified configs var configs = _content.get('configs').filter(function (config) { if (config.get('isNotDefaultValue') || config.get('savedValue') === null) { return config.isRequiredByAgent!== false; } return false; }); // if modified configs detected push all service's configs for update if (configs.length) { fileNamesToUpdate = fileNamesToUpdate.concat(configs.mapProperty('filename').uniq()); } } }, this); this.setDBProperties({ fileNamesToUpdate: fileNamesToUpdate, serviceConfigProperties: serviceConfigProperties }); this.set('content.serviceConfigProperties', serviceConfigProperties); }, isExcludedConfig: function (configProperty) { return this.get('sensibleConfigs').mapProperty('name').indexOf(configProperty.name) > -1 && this.get('sensibleConfigs').mapProperty('filename').indexOf(configProperty.filename) > -1; }, /** * save Config groups * @param stepController * @param isAddService */ saveServiceConfigGroups: function (stepController, isAddService) { var serviceConfigGroups = [], hosts = isAddService ? App.router.get('addServiceController').getDBProperty('hosts') : this.getDBProperty('hosts'); stepController.get('stepConfigs').forEach(function (service) { // mark group of installed service var isForInstalledService = service.get('selected') === false; service.get('configGroups').forEach(function (configGroup) { var properties = []; configGroup.get('properties').forEach(function (property) { properties.push({ name: property.get('name'), value: property.get('value'), isFinal: property.get('isFinal'), filename: property.get('filename') }) }); //configGroup copied into plain JS object to avoid Converting circular structure to JSON var hostNames = configGroup.get('hosts').map(function(host_name) {return hosts[host_name].id;}); serviceConfigGroups.push({ id: configGroup.get('id'), name: configGroup.get('name'), description: configGroup.get('description'), hosts: hostNames.slice(), properties: properties.slice(), is_default: configGroup.get('isDefault'), is_for_installed_service: isForInstalledService, is_for_update: configGroup.isForUpdate || configGroup.get('hash') != this.getConfigGroupHash(configGroup, hostNames), service_name: configGroup.get('serviceName'), service_id: configGroup.get('serviceName'), desired_configs: configGroup.get('desiredConfigs'), child_config_groups: configGroup.get('childConfigGroups') ? configGroup.get('childConfigGroups').mapProperty('id') : [], parent_config_group_id: configGroup.get('parentConfigGroup.id'), is_temporary: configGroup.get('isTemporary') }); }, this) }, this); this.setDBProperty('serviceConfigGroups', serviceConfigGroups); this.set('content.configGroups', serviceConfigGroups); }, /** * generate string hash for config group * @param {Object} configGroup * @param {Array|undefined} hosts * @returns {String|null} * @method getConfigGroupHash */ getConfigGroupHash: function(configGroup, hosts) { if (!Em.get(configGroup, 'properties.length') && !Em.get(configGroup, 'hosts.length') && !hosts) { return null; } var hash = {}; Em.get(configGroup, 'properties').forEach(function (config) { hash[Em.get(config, 'name')] = {value: Em.get(config, 'value'), isFinal: Em.get(config, 'isFinal')}; }); hash.hosts = hosts || Em.get(configGroup, 'hosts'); return JSON.stringify(hash); }, /** * return slaveComponents bound to hosts * @return {Array} */ getSlaveComponentHosts: function () { var components = this.get('slaveComponents'); var result = []; var installedServices = App.Service.find().mapProperty('serviceName'); var selectedServices = App.StackService.find().filterProperty('isSelected', true).mapProperty('serviceName'); var installedComponentsMap = {}; var uninstalledComponents = []; components.forEach(function (component) { if (installedServices.contains(component.get('serviceName'))) { installedComponentsMap[component.get('componentName')] = []; } else if (selectedServices.contains(component.get('serviceName'))) { uninstalledComponents.push(component); } }, this); installedComponentsMap.HDFS_CLIENT = []; App.HostComponent.find().forEach(function (hostComponent) { if (installedComponentsMap[hostComponent.get('componentName')]) { installedComponentsMap[hostComponent.get('componentName')].push(hostComponent.get('hostName')); } }, this); for (var componentName in installedComponentsMap) { var name = componentName === 'HDFS_CLIENT' ? 'CLIENT' : componentName; var component = { componentName: name, displayName: App.format.role(name, false), hosts: [], isInstalled: true }; installedComponentsMap[componentName].forEach(function (hostName) { component.hosts.push({ group: "Default", hostName: hostName, isInstalled: true }); }, this); result.push(component); } uninstalledComponents.forEach(function (component) { var hosts = jQuery.extend(true, [], result.findProperty('componentName', 'DATANODE').hosts); hosts.setEach('isInstalled', false); result.push({ componentName: component.get('componentName'), displayName: App.format.role(component.get('componentName'), false), hosts: hosts, isInstalled: false }) }); return result; }, /** * Load master component hosts data for using in required step controllers */ loadMasterComponentHosts: function () { var masterComponentHosts = this.getDBProperty('masterComponentHosts'), self = this, observerContext = { setMasterComponentHosts: function () { if (App.get('router.clusterController.isServiceMetricsLoaded')) { var stackMasterComponents = App.get('components.masters').uniq(); App.HostComponent.find().filter(function(component) { return stackMasterComponents.contains(component.get('componentName')); }).forEach(function (item) { masterComponentHosts.push({ component: item.get('componentName'), hostName: item.get('hostName'), isInstalled: true, serviceId: item.get('service.id'), display_name: item.get('displayName') }) }); self.setDBProperty('masterComponentHosts', masterComponentHosts); self.set('content.masterComponentHosts', masterComponentHosts); self.removeObserver('App.router.clusterController.isServiceMetricsLoaded', this, 'setMasterComponentHosts'); dfd.resolve(); } } }, dfd = $.Deferred(); if (Em.isNone(masterComponentHosts)) { masterComponentHosts = []; if (App.get('router.clusterController.isServiceMetricsLoaded')) { observerContext.setMasterComponentHosts(); } else { this.addObserver('App.router.clusterController.isServiceMetricsLoaded', observerContext, 'setMasterComponentHosts'); } } else { this.set('content.masterComponentHosts', masterComponentHosts); dfd.resolve(); } return dfd.promise(); }, /** * Save Master Component Hosts data to Main Controller * @param stepController App.WizardStep5Controller */ saveMasterComponentHosts: function (stepController) { var obj = stepController.get('selectedServicesMasters'); var masterComponentHosts = []; obj.forEach(function (_component) { masterComponentHosts.push({ display_name: _component.get('display_name'), component: _component.get('component_name'), hostName: _component.get('selectedHost'), serviceId: _component.get('serviceId'), isInstalled: _component.get('isInstalled') }); }); this.setDBProperty('masterComponentHosts', masterComponentHosts); this.set('content.masterComponentHosts', masterComponentHosts); }, clearMasterComponentHosts: function() { this.set('content.masterComponentHosts', null); this.setDBProperty('masterComponentHosts', null); }, /** * Load information about hosts with clients components */ loadClients: function () { var clients = this.getDBProperty('clientInfo'); this.set('content.clients', clients); }, /** * load methods assigned to each step * methods executed in exact order as they described in map * @return {object} */ loadAllPriorSteps: function () { var currentStep = this.get('currentStep'); var loadMap = this.get('loadMap'); var operationStack = []; var dfd = $.Deferred(); for (var s in loadMap) { if (parseInt(s, 10) <= parseInt(currentStep, 10)) { operationStack.pushObjects(loadMap[s]); } } var sequence = App.actionSequence.create({context: this}); sequence.setSequence(operationStack).onFinish(function () { dfd.resolve(); }).start(); return dfd.promise(); }, /** * return new object extended from clusterStatusTemplate * @return Object */ getCluster: function () { return jQuery.extend({}, this.get('clusterStatusTemplate'), {name: App.router.getClusterName()}); }, /** * Load services data from server. */ loadServicesFromServer: function () { var services = this.getDBProperty('services'); if (!services) { services = { selectedServices: [], installedServices: [] }; App.StackService.find().forEach(function(item){ var isInstalled = App.Service.find().someProperty('id', item.get('serviceName')); item.set('isSelected', isInstalled); item.set('isInstalled', isInstalled); if (isInstalled) { services.selectedServices.push(item.get('serviceName')); services.installedServices.push(item.get('serviceName')); } },this); this.setDBProperty('services',services); } else { App.StackService.find().forEach(function(item) { var isSelected = services.selectedServices.contains(item.get('serviceName')); var isInstalled = services.installedServices.contains(item.get('serviceName')); item.set('isSelected', isSelected); item.set('isInstalled', isInstalled); },this); } this.set('content.services', App.StackService.find()); }, /** * Load confirmed hosts. * Will be used atAssign Masters(step5)
step
*/
loadConfirmedHosts: function () {
var hosts = App.db.getHosts();
if (hosts) {
this.set('content.hosts', hosts);
}
},
loadHosts: function () {
var dfd;
var hostsInDb = this.getDBProperty('hosts');
if (hostsInDb) {
this.set('content.hosts', hostsInDb);
dfd = $.Deferred();
dfd.resolve();
} else {
dfd = App.ajax.send({
name: 'hosts.confirmed',
sender: this,
data: {},
success: 'loadHostsSuccessCallback',
error: 'loadHostsErrorCallback'
});
}
return dfd.promise();
},
loadHostsSuccessCallback: function (response) {
var installedHosts = {};
response.items.forEach(function (item, indx) {
installedHosts[item.Hosts.host_name] = {
name: item.Hosts.host_name,
cpu: item.Hosts.cpu_count,
memory: item.Hosts.total_mem,
disk_info: item.Hosts.disk_info,
osType: item.Hosts.os_type,
osArch: item.Hosts.os_arch,
ip: item.Hosts.ip,
maintenance_state: item.Hosts.maintenance_state,
bootStatus: "REGISTERED",
isInstalled: true,
hostComponents: item.host_components,
id: indx++
};
});
this.setDBProperty('hosts', installedHosts);
this.set('content.hosts', installedHosts);
},
loadHostsErrorCallback: function (jqXHR, ajaxOptions, error, opt) {
App.ajax.defaultErrorHandler(jqXHR, opt.url, opt.type, jqXHR.status);
},
/**
* Determine if Assign Slaves and Clients
step should be skipped
* @method setSkipSlavesStep
* @param services
* @param step
*/
setSkipSlavesStep: function (services, step) {
var hasServicesWithSlave = services.someProperty('hasSlave');
var hasServicesWithClient = services.someProperty('hasClient');
var hasServicesWithCustomAssignedNonMasters = services.someProperty('hasNonMastersWithCustomAssignment');
this.set('content.skipSlavesStep', !hasServicesWithSlave && !hasServicesWithClient || !hasServicesWithCustomAssignedNonMasters);
if (this.get('content.skipSlavesStep')) {
this.get('isStepDisabled').findProperty('step', step).set('value', this.get('content.skipSlavesStep'));
}
},
/**
* Load config themes for enhanced config layout.
*
* @method loadConfigThemes
* @return {$.Deferred}
*/
loadConfigThemes: function () {
var self = this;
var dfd = $.Deferred();
if (!this.get('stackConfigsLoaded')) {
var serviceNames = App.StackService.find().filter(function (s) {
return s.get('isSelected') || s.get('isInstalled');
}).mapProperty('serviceName');
// Load stack configs before loading themes
App.config.loadClusterConfigsFromStack().always(function() {
App.config.loadConfigsFromStack(serviceNames).done(function () {
self.loadConfigThemeForServices(serviceNames).always(function () {
self.set('stackConfigsLoaded', true);
dfd.resolve();
});
});
});
} else {
dfd.resolve();
}
return dfd.promise();
},
/**
* Clear all config static data
* and theme info
*
* @method clearEnhancedConfigs
*/
clearEnhancedConfigs: function() {
App.configsCollection.clearAll();
App.Section.find().clear();
App.SubSection.find().clear();
App.SubSectionTab.find().clear();
App.Tab.find().clear();
this.set('stackConfigsLoaded', false);
},
/**
* Cache "stepConfigs" to local storage in name value pairs
* @param stepController
*/
cacheStepConfigValues: function(stepController) {
var self = this;
var stepConfigs = [];
stepController.get("stepConfigs").forEach(function (category) {
var configs = category.configs.map(function(config) {
if (self.isExcludedConfig(config)) {
config.set('value', '');
}
return {
name: config.name,
filename: config.filename,
value: config.value
};
});
stepConfigs = stepConfigs.concat(configs);
});
if (stepConfigs.length > 0 ) {
this.setDBProperty(stepController.name + "-sc", stepConfigs);
}
},
loadCachedStepConfigValues: function(stepController) {
return this.getDBProperty(stepController.name + "-sc");
},
clearCachedStepConfigValues: function(stepController) {
this.setDBProperty(stepController.name + "-sc", null);
},
saveTasksStatuses: function (tasksStatuses) {
this.set('content.tasksStatuses', tasksStatuses);
this.setDBProperty('tasksStatuses', tasksStatuses);
},
loadTasksStatuses: function() {
var tasksStatuses = this.getDBProperty('tasksStatuses');
this.set('content.tasksStatuses', tasksStatuses);
},
saveTasksRequestIds: function (tasksRequestIds) {
this.set('content.tasksRequestIds', tasksRequestIds);
this.setDBProperty('tasksRequestIds', tasksRequestIds);
},
loadTasksRequestIds: function() {
var tasksRequestIds = this.getDBProperty('tasksRequestIds');
this.set('content.tasksRequestIds', tasksRequestIds);
},
saveRequestIds: function (requestIds) {
this.set('content.requestIds', requestIds);
this.setDBProperty('requestIds', requestIds);
},
loadRequestIds: function() {
var requestIds = this.getDBProperty('requestIds');
this.set('content.requestIds', requestIds);
},
loadRecommendations: function () {
this.set("content.recommendations", this.getDBProperty('recommendations'));
},
/**
* reset stored wizard data and reload App
* @param {App.WizardController} controller - wizard controller
* @param {string} route - preferable path to go after wizard finished
*/
resetOnClose: function(controller, route) {
App.router.get('wizardWatcherController').resetUser();
controller.finish();
App.router.get('updateController').set('isWorking', true);
App.clusterStatus.setClusterStatus({
clusterName: App.get('clusterName'),
clusterState: 'DEFAULT',
localdb: App.db.data
},
{
alwaysCallback: function () {
controller.get('popup').hide();
App.router.transitionTo(route);
Em.run.next(function() {
location.reload();
});
}
});
}
});