/**
* 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');
App.WizardStep3Controller = Em.ArrayController.extend({
name: 'wizardStep3Controller',
content: [],
bootHosts: [],
isSubmitDisabled: false,
categories: ['Hosts', 'Succeeded', 'Failed'],
category: 'Hosts',
allChecked: true,
onAllChecked: function () {
var hosts = this.visibleHosts();
if (this.get('allChecked') === true) {
hosts.setEach('isChecked', true);
} else {
hosts.setEach('isChecked', false);
}
}.observes('allChecked'),
mockData: require('data/mock/step3_hosts'),
mockRetryData: require('data/mock/step3_pollData'),
/**
* Provide some initialisation work. Start bootstrap if needed
*/
navigateStep: function () {
if (App.db.getBootStatus() === false) {
this.startBootstrap();
}
},
/**
* Onclick handler for Retry
button.
*/
retry: function () {
if (this.get('isSubmitDisabled')) {
return;
}
var hosts = this.visibleHosts();
var selectedHosts = hosts.filterProperty('isChecked', true);
selectedHosts.forEach(function (_host) {
console.log('Retrying: ' + _host.name);
});
//TODO: uncomment below code to hookup with @GET bootstrap API
/*
this.set('bootHosts',selectedHosts);
this.doBootstrap();
*/
},
/**
* Below function returns the current set of visible hosts on view (All, succeded, failed)
*/
visibleHosts: function () {
if (this.get('category') === 'Succeeded') {
return (this.filterProperty('bootStatus', 'success'));
} else if (this.get('category') === 'Failed') {
return (this.filterProperty('bootStatus', 'error'));
} else if (this.get('category') === 'Hosts') {
return this.content;
}
},
/**
* Onclick handler for Remove
button
*/
removeBtn: function () {
if (this.get('isSubmitDisabled')) {
return;
}
var hostResult = this.visibleHosts();
var selectedHosts = hostResult.filterProperty('isChecked', true);
selectedHosts.forEach(function (_hostInfo) {
console.log('Removing: ' + _hostInfo.name);
});
this.removeHosts(selectedHosts);
},
/**
* Do remove hosts logic: remove host info from UI and save it to model
* @param hosts
*/
removeHosts: function (hosts) {
this.removeObjects(hosts);
App.router.send('removeHosts', hosts);
},
startBootstrap: function () {
this.set('isSubmitDisabled', true);
this.set('bootHosts', this.get('content'));
this.doBootstrap();
},
/**
* Below function parses and updates the content, and governs
* the possibility of the next doBootstrap (polling) call
*
* @param hostsFrmServer
* @param hostsFrmContent
* @return {Boolean}
*/
parseHostInfo: function (hostsFrmServer, hostsFrmContent) {
var result = true; // default value as true implies if the data rendered by REST API has no hosts, polling will stop
hostsFrmServer.forEach(function (_hostFrmServer) {
var host = hostsFrmContent.findProperty('name', _hostFrmServer.name);
if (host !== null && host !== undefined) { // check if hostname extracted from REST API data matches any hostname in content
host.set('bootStatus', _hostFrmServer.status);
host.set('cpu', _hostFrmServer.cpu);
host.set('memory', _hostFrmServer.memory);
}
});
result = !this.content.someProperty('bootStatus', 'pending');
return result;
},
doBootstrap: function () {
var self = this;
$.ajax({
type: 'GET',
url: '/ambari_server/api/bootstrap',
async: false,
timeout: 5000,
success: function (data) {
console.log("TRACE: In success function for the GET bootstrap call");
var result = self.parseHostInfo(data, this.get('bootHosts'));
if (result !== true && App.router.getInstallerCurrentStep() === '3') {
window.setTimeout(self.doBootstrap, 3000);
} else {
self.stopBootstrap();
}
},
error: function () {
console.log("ERROR");
self.stopBootstrap();
},
statusCode: {
404: function () {
console.log("URI not found.");
}
},
dataType: 'application/json'
});
},
stopBootstrap: function () {
//TODO: uncomment following line after the hook up with the API call
// this.set('isSubmitDisabled',false);
},
hostLogPopup: function (event) {
App.ModalPopup.show({
header: Em.I18n.t('installer.step3.hostLog.popup.header'),
onPrimary: function () {
this.hide();
},
bodyClass: Ember.View.extend({
templateName: require('templates/installer/step3HostLogPopup')
})
});
},
// TODO: dummy button. Remove this after the hook up with actual REST API.
mockBtn: function () {
this.set('isSubmitDisabled', false);
this.clear();
var hostInfo = this.mockData;
this.renderHosts(hostInfo);
},
renderHosts: function (hostsInfo) {
var self = this;
hostsInfo.forEach(function (_hostInfo) {
var hostInfo = App.HostInfo.create({
name: _hostInfo.name,
bootStatus: _hostInfo.bootStatus
});
console.log('pushing ' + hostInfo.name);
self.content.pushObject(hostInfo);
});
},
pollBtn: function () {
if (this.get('isSubmitDisabled')) {
return;
}
var hosts = this.visibleHosts();
var selectedHosts = hosts.filterProperty('isChecked', true);
var mockHosts = this.mockRetryData;
if (this.parseHostInfo(mockHosts, selectedHosts)) {
// this.saveHostInfoToDb();
}
}
});