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 = App.db['get' + name.capitalize()]();
if (!result){
result = this['get' + name.capitalize()]();
App.db['set' + name.capitalize()](result);
console.log(this.get('name') + ": created " + name, result);
}
this.set('content.' + name, result);
console.log(this.get('name') + ": loaded " + name, result);
},
save: function(name){
var value = this.toObject(this.get('content.' + name));
App.db['set' + name.capitalize()](value);
console.log(this.get('name') + ": saved " + name, value);
},
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(){
App.db.setService(undefined); //not to use this data at AddService page
App.db.setHosts(undefined);
App.db.setMasterComponentHosts(undefined);
App.db.setSlaveComponentHosts(undefined);
App.db.setCluster(undefined);
App.db.setAllHostNames(undefined);
App.db.setInstallOptions(undefined);
App.db.setAllHostNamesPattern(undefined);
},
installOptionsTemplate: {
hostNames: "", //string
manualInstall: false, //true, false
useSsh: true, //bool
isJavaHome : false, //bool
javaHome: App.defaultJavaHome, //string
localRepo: false, //true, false
sshKey: "", //string
bootRequestId: null, //string
sshUser: "root" //string
},
loadedServiceComponents: null,
/**
* Generate serviceComponents as pr the stack definition and save it to localdata
* called form stepController step4WizardController
*/
loadServiceComponents: function () {
App.ajax.send({
name: 'wizard.service_components',
sender: this,
data: {
stackUrl: App.get('stack2VersionURL'),
stackVersion: App.get('currentStackVersionNumber')
},
success: 'loadServiceComponentsSuccessCallback',
error: 'loadServiceComponentsErrorCallback'
});
return this.get('loadedServiceComponents');
},
loadServiceComponentsSuccessCallback: function (jsonData) {
var displayOrderConfig = require('data/services');
console.log("TRACE: getService ajax call -> In success function for the getServiceComponents call");
console.log("TRACE: jsonData.services : " + jsonData.items);
// Creating Model
var Service = Ember.Object.extend({
serviceName: null,
displayName: null,
isDisabled: true,
isSelected: true,
isInstalled: false,
description: null,
version: null
});
var data = [];
// loop through all the service components
for (var i = 0; i < displayOrderConfig.length; i++) {
var entry = jsonData.items.findProperty("StackServices.service_name", displayOrderConfig[i].serviceName);
if (entry) {
var myService = Service.create({
serviceName: entry.StackServices.service_name,
displayName: displayOrderConfig[i].displayName,
isDisabled: displayOrderConfig[i].isDisabled,
isSelected: displayOrderConfig[i].isSelected,
canBeSelected: displayOrderConfig[i].canBeSelected,
isInstalled: false,
isHidden: displayOrderConfig[i].isHidden,
description: entry.StackServices.comments,
version: entry.StackServices.service_version
});
data.push(myService);
}
else {
console.warn('Service not found - ', displayOrderConfig[i].serviceName);
}
}
this.set('loadedServiceComponents', data);
console.log('TRACE: service components: ' + JSON.stringify(data));
},
loadServiceComponentsErrorCallback: function (request, ajaxOptions, error) {
console.log("TRACE: STep5 -> In error function for the getServiceComponents call");
console.log("TRACE: STep5 -> error code status is: " + request.status);
console.log('Step8: Error message is: ' + request.responseText);
},
loadServicesFromServer: function() {
var services = App.db.getService();
if (services) {
return;
}
var apiService = this.loadServiceComponents();
this.set('content.services', apiService);
App.db.setService(apiService);
},
registerErrPopup: function (header, message) {
App.ModalPopup.show({
header: header,
secondary: false,
onPrimary: function () {
this.hide();
},
bodyClass: Ember.View.extend({
template: Ember.Handlebars.compile(['{{view.message}}
'].join('\n')), message: message }) }); }, /** * Save hosts that the user confirmed to proceed with from step 3 * @param stepController App.WizardStep3Controller */ saveConfirmedHosts: function (stepController) { var hostInfo = {}; stepController.get('content.hosts').forEach(function (_host) { hostInfo[_host.name] = { name: _host.name, cpu: _host.cpu, memory: _host.memory, disk_info: _host.disk_info, bootStatus: _host.bootStatus, isInstalled: false }; }); console.log('wizardController:saveConfirmedHosts: save hosts ', hostInfo); App.db.setHosts(hostInfo); this.set('content.hosts', hostInfo); }, /** * Save data after installation to main controller * @param stepController App.WizardStep9Controller */ saveInstalledHosts: function (stepController) { var hosts = stepController.get('hosts'); var hostInfo = App.db.getHosts(); 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.save('hosts'); console.log('wizardController:saveInstalledHosts: save hosts ', hostInfo); }, /** * Save slaveHostComponents to main controller * @param stepController */ saveSlaveComponentHosts: function (stepController) { var hosts = stepController.get('hosts'); var 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.get('checkboxes'); headers.forEach(function(header) { var cb = checkboxes.findProperty('title', header.get('label')); if (cb.get('checked')) { formattedHosts.get(header.get('name')).push({ hostName: host.hostName, group: 'Default', isInstalled: cb.get('isInstalled') }); } }); }); 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')) }); }); App.db.setSlaveComponentHosts(slaveComponentHosts); console.log('wizardController.slaveComponentHosts: saved hosts', 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(); }, /** * 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 advanced configs from server */ loadAdvancedConfigs: function () { var configs = (App.db.getAdvancedServiceConfig()) ? App.db.getAdvancedServiceConfig() : []; this.get('content.services').filterProperty('isSelected', true).mapProperty('serviceName').forEach(function (_serviceName) { var serviceComponents = App.config.loadAdvancedConfig(_serviceName); if(serviceComponents){ configs = configs.concat(serviceComponents); } }, this); this.set('content.advancedServiceConfig', configs); App.db.setAdvancedServiceConfig(configs); }, /** * Load serviceConfigProperties to model */ loadServiceConfigProperties: function () { var serviceConfigProperties = App.db.getServiceConfigProperties(); this.set('content.serviceConfigProperties', serviceConfigProperties); console.log("AddHostController.loadServiceConfigProperties: loaded config ", serviceConfigProperties); }, /** * Save config properties * @param stepController Step7WizardController */ saveServiceConfigProperties: function (stepController) { var serviceConfigProperties = []; stepController.get('stepConfigs').forEach(function (_content) { if(_content.serviceName === 'YARN' && !App.supports.capacitySchedulerUi){ _content.set('configs', App.config.textareaIntoFileConfigs(_content.get('configs'), 'capacity-scheduler.xml')); } _content.get('configs').forEach(function (_configProperties) { var displayType = _configProperties.get('displayType'); if (displayType === 'directories' || displayType === 'directory') { var value = _configProperties.get('value').split(/\s+/g).join(','); _configProperties.set('value', value); } var overrides = _configProperties.get('overrides'); var overridesArray = []; if(overrides!=null){ overrides.forEach(function(override){ var overrideEntry = { value: override.get('value'), hosts: [] }; override.get('selectedHostOptions').forEach(function(host){ overrideEntry.hosts.push(host); }); overridesArray.push(overrideEntry); }); } overridesArray = (overridesArray.length) ? overridesArray : null; var configProperty = { id: _configProperties.get('id'), name: _configProperties.get('name'), value: _configProperties.get('value'), defaultValue: _configProperties.get('defaultValue'), serviceName: _configProperties.get('serviceName'), domain: _configProperties.get('domain'), filename: _configProperties.get('filename'), overrides: overridesArray }; serviceConfigProperties.push(configProperty); }, this); }, this); App.db.setServiceConfigProperties(serviceConfigProperties); this.set('content.serviceConfigProperties', serviceConfigProperties); } })