/** * 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.RollbackHighAvailabilityWizardController = App.WizardController.extend({ name: 'rollbackHighAvailabilityWizardController', totalSteps: 3, /** * Used for hiding back button in wizard */ hideBackButton: true, content: Em.Object.create({ controllerName: 'RollbackHighAvailabilityWizardController', cluster: null, hosts: null, services: null, slaveComponentHosts: null, masterComponentHosts: null, serviceName: 'MISC', hdfsUser:"hdfs", nameServiceId: '', failedTask : null }), /** * 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 displayOrderConfig = require('data/services'); var apiUrl = App.get('stack2VersionURL'); var apiService = this.loadServiceComponents(displayOrderConfig, apiUrl); // apiService.forEach(function(item, index){ apiService[index].isSelected = App.Service.find().someProperty('id', item.serviceName); apiService[index].isDisabled = apiService[index].isSelected; apiService[index].isInstalled = apiService[index].isSelected; }); this.set('content.services', apiService); App.db.setService(apiService); }, /** * Load confirmed hosts. * Will be used at Assign Masters(step5) step */ loadConfirmedHosts: function(){ var hosts = App.db.getHosts(); if(!hosts || !hosts.length){ var hosts = {}; App.Host.find().forEach(function(item){ hosts[item.get('id')] = { name: item.get('id'), cpu: item.get('cpu'), memory: item.get('memory'), disk_info: item.get('diskInfo'), bootStatus: "REGISTERED", isInstalled: true }; }); App.db.setHosts(hosts); } this.set('content.hosts', hosts); console.log('ReassignMasterController.loadConfirmedHosts: loaded hosts', hosts); }, /** * Load master component hosts data for using in required step controllers */ loadMasterComponentHosts: function () { var masterComponentHosts = App.db.getMasterComponentHosts(); if(!masterComponentHosts){ masterComponentHosts = []; App.HostComponent.find().filterProperty('isMaster', true).forEach(function(item){ masterComponentHosts.push({ component: item.get('componentName'), hostName: item.get('host.hostName'), isInstalled: true }) }); } this.set("content.masterComponentHosts", masterComponentHosts); console.log("ReassignMasterController.loadMasterComponentHosts: loaded hosts ", masterComponentHosts); }, /** * save status of the cluster. * @param clusterStatus object with status,requestId fields. */ saveClusterStatus: function (clusterStatus) { var oldStatus = this.toObject(this.get('content.cluster')); clusterStatus = jQuery.extend(oldStatus, clusterStatus); if (clusterStatus.requestId) { clusterStatus.requestId.forEach(function (requestId) { if (clusterStatus.oldRequestsId.indexOf(requestId) === -1) { clusterStatus.oldRequestsId.push(requestId) } }, this); } this.set('content.cluster', clusterStatus); this.save('cluster'); }, /** * 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'), isCurNameNode: _component.get('isCurNameNode'), isAddNameNode: _component.get('isAddNameNode'), isInstalled: true }); }); App.db.setMasterComponentHosts(masterComponentHosts); this.set('content.masterComponentHosts', masterComponentHosts); }, saveTasksStatuses: function(statuses){ App.db.setRollbackHighAvailabilityWizardTasksStatuses(statuses); this.set('content.tasksStatuses', statuses); }, loadTasksStatuses: function(){ var statuses = App.db.getRollbackHighAvailabilityWizardTasksStatuses(); this.set('content.tasksStatuses', statuses); }, saveRequestIds: function(requestIds){ App.db.setRollbackHighAvailabilityWizardRequestIds(requestIds); this.set('content.requestIds', requestIds); }, saveLogs: function(logs){ App.db.setRollbackHighAvailabilityWizardLogs(logs); this.set('content.logs', logs); }, loadRequestIds: function(){ var requestIds = App.db.getRollbackHighAvailabilityWizardRequestIds(); this.set('content.requestIds', requestIds); }, loadLogs: function(){ var logs = App.db.getRollbackHighAvailabilityWizardLogs(); this.set('content.logs', logs); }, /** * Load data for all steps until current step */ loadAllPriorSteps: function () { var step = this.get('currentStep'); switch (step) { case '3': case '2': //this.loadServicesFromServer(); //this.loadMasterComponentHosts(); //this.loadConfirmedHosts(); case '1': this.load('cluster'); } }, /** * Remove all loaded data. * Created as copy for App.router.clearAllSteps */ clearAllSteps: function () { this.clearInstallOptions(); // clear temporary information stored during the install this.set('content.cluster', this.getCluster()); }, clearTasksData: function () { this.saveTasksStatuses(undefined); this.saveRequestIds(undefined); this.saveLogs(undefined); }, /** * Clear all temporary data */ finish: function () { this.setCurrentStep('1'); this.clearAllSteps(); App.router.get('updateController').updateAll(); } });