/** * 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 stringUtils = require('utils/string_utils'); App.MainAdminStackAndUpgradeController = Em.Controller.extend({ name: 'mainAdminStackAndUpgradeController', /** * @type {Object|null} */ serviceToInstall: null, /** * @type {Array} */ upgradeGroups: [], /** * TODO should have actual value from call that start upgrade * @type {Number|null} */ upgradeId: 1, /** * version that currently applied to server * @type {Object|null} */ currentVersion: null, /** * versions to which cluster could be upgraded * @type {Array} */ targetVersions: [], /** * @type {Array} */ services: function() { return App.StackService.find().map(function(s) { s.set('isInstalled', App.Service.find().someProperty('serviceName', s.get('serviceName'))); return s; }); }.property('App.router.clusterController.isLoaded'), /** * launch Add Service wizard * @param event */ goToAddService: function (event) { this.set('serviceToInstall', event.context); App.get('router').transitionTo('main.serviceAdd'); }, /** * call to fetch cluster stack versions * @return {$.ajax} */ loadVersionsInfo: function () { return App.ajax.send({ name: 'admin.stack_versions.all', sender: this, data: {}, success: 'loadVersionsInfoSuccessCallback' }); }, /** * parse stack versions and * set currentVersion * set targetVersions * @param data */ loadVersionsInfoSuccessCallback: function (data) { var current = data.items.findProperty('ClusterStackVersions.state', 'CURRENT'); var currentVersion = current.repository_versions[0].RepositoryVersions.repository_version; var targetVersions = data.items.without(current) .filter(function (version) { var repositoryVersion = version.repository_versions[0].RepositoryVersions.repository_version; //Only higher versions that have already been installed to all the hosts are shown return (version.ClusterStackVersions.state === 'INSTALLED' && stringUtils.compareVersions(repositoryVersion, currentVersion) === 1); }).map(function (version) { return version.ClusterStackVersions; }); this.set('currentVersion', current.ClusterStackVersions); this.set('targetVersions', targetVersions); }, /** * load upgrade tasks by upgrade id * @return {$.ajax} */ loadUpgradeData: function () { return App.ajax.send({ name: 'admin.upgrade.data', sender: this, data: { id: this.get('upgradeId') }, success: 'loadUpgradeDataSuccessCallback' }); }, /** * parse and push upgrade tasks to controller * @param data */ loadUpgradeDataSuccessCallback: function (data) { this.set("upgradeGroups", data.upgrade_groups); }, /** * make call to start downgrade process */ downgrade: function () { //TODO start downgrade }, /** * make call to start upgrade process and show popup with current progress */ upgrade: function () { //TODO start upgrade this.loadUpgradeData(); this.openUpgradeDialog(); }, /** * make call to resume upgrade process and show popup with current progress */ resumeUpgrade: function () { //TODO resume upgrade }, /** * make call to stop upgrade process */ stopUpgrade: function () { //TODO stop upgrade }, /** * make call to finish upgrade process */ finalize: function () { //TODO start finalize }, /** * show dialog with tasks of upgrade * @return {App.ModalPopup} */ openUpgradeDialog: function () { App.router.transitionTo('admin.stackUpgrade'); } });