123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999 |
- /**
- * 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 batchUtils = require('utils/batch_scheduled_requests');
- var date = require('utils/date');
- /**
- * App.HostPopup is for the popup that shows up upon clicking already-performed or currently-in-progress operations
- */
- App.HostPopup = Em.Object.create({
- name: 'hostPopup',
- servicesInfo: null,
- hosts: null,
- inputData: null,
- /**
- * @type {string}
- */
- serviceName: "",
- /**
- * @type {Number}
- */
- currentServiceId: null,
- previousServiceId: null,
- /**
- * @type {string}
- */
- popupHeaderName: "",
- /**
- * @type {App.Controller}
- */
- dataSourceController: null,
- /**
- * @type {bool}
- */
- isBackgroundOperations: false,
- /**
- * @type {string}
- */
- currentHostName: null,
- /**
- * @type {App.ModalPopup}
- */
- isPopup: null,
- /**
- * Entering point of this component
- * @param {String} serviceName
- * @param {Object} controller
- * @param {Boolean} isBackgroundOperations
- * @param {Integer} requestId
- */
- initPopup: function (serviceName, controller, isBackgroundOperations, requestId) {
- if (!isBackgroundOperations) {
- this.clearHostPopup();
- this.set("popupHeaderName", serviceName);
- }
- this.set('currentServiceId', requestId);
- this.set("serviceName", serviceName);
- this.set("dataSourceController", controller);
- this.set("isBackgroundOperations", isBackgroundOperations);
- this.set("inputData", this.get("dataSourceController.services"));
- if(isBackgroundOperations){
- this.onServiceUpdate();
- } else {
- this.onHostUpdate();
- }
- return this.createPopup();
- },
- /**
- * clear info popup data
- */
- clearHostPopup: function () {
- this.set('servicesInfo', null);
- this.set('hosts', null);
- this.set('inputData', null);
- this.set('serviceName', "");
- this.set('currentServiceId', null);
- this.set('previousServiceId', null);
- this.set('popupHeaderName', "");
- this.set('dataSourceController', null);
- this.set('currentHostName', null);
- this.get('isPopup') ? this.get('isPopup').remove() : null;
- },
- /**
- * Depending on tasks status
- * @param {Array} tasks
- * @return {Array} [Status, Icon type, Progressbar color, is IN_PROGRESS]
- */
- getStatus: function(tasks){
- var isCompleted = true;
- var status;
- var tasksLength = tasks.length;
- var isFailed = false;
- var isAborted = false;
- var isTimedout = false;
- var isInProgress = false;
- for (var i = 0; i < tasksLength; i++) {
- if (tasks[i].Tasks.status !== 'COMPLETED') {
- isCompleted = false;
- }
- if(tasks[i].Tasks.status === 'FAILED'){
- isFailed = true;
- }
- if (tasks[i].Tasks.status === 'ABORTED') {
- isAborted = true;
- }
- if (tasks[i].Tasks.status === 'TIMEDOUT') {
- isTimedout = true;
- }
- if (tasks[i].Tasks.status === 'IN_PROGRESS') {
- isInProgress = true;
- }
- }
- if (isFailed) {
- status = ['FAILED', 'icon-exclamation-sign', 'progress-danger', false];
- } else if (isAborted) {
- status = ['ABORTED', 'icon-minus', 'progress-warning', false];
- } else if (isTimedout) {
- status = ['TIMEDOUT', 'icon-time', 'progress-warning', false];
- } else if (isInProgress) {
- status = ['IN_PROGRESS', 'icon-cogs', 'progress-info', true];
- }
- if(status){
- return status;
- } else if(isCompleted){
- return ['SUCCESS', 'icon-ok', 'progress-success', false];
- } else {
- return ['PENDING', 'icon-cog', 'progress-info', true];
- }
- },
- /**
- * Progress of host or service depending on tasks status
- * @param {Array} tasks
- * @return {Number} percent of completion
- */
- getProgress: function (tasks) {
- if (!tasks || tasks.length === 0) return 0;
- var completedActions = 0;
- var queuedActions = 0;
- var inProgressActions = 0;
- tasks.forEach(function (task) {
- if (['COMPLETED', 'FAILED', 'ABORTED', 'TIMEDOUT'].contains(task.Tasks.status)) {
- completedActions++;
- } else if (task.Tasks.status === 'QUEUED') {
- queuedActions++;
- } else if (task.Tasks.status === 'IN_PROGRESS') {
- inProgressActions++;
- }
- });
- return Math.ceil(((queuedActions * 0.09) + (inProgressActions * 0.35) + completedActions ) / tasks.length * 100);
- },
- /**
- * Count number of operations for select box options
- * @param {Object[]} obj
- * @param {Object[]} categories
- */
- setSelectCount: function (obj, categories) {
- if (!obj) return;
- var countAll = obj.length;
- var countPending = 0;
- var countInProgress = 0;
- var countFailed = 0;
- var countCompleted = 0;
- var countAborted = 0;
- var countTimedout = 0;
- obj.forEach(function(item){
- switch (item.status){
- case 'pending':
- countPending++;
- break;
- case 'queued':
- countPending++;
- break;
- case 'in_progress':
- countInProgress++;
- break;
- case 'failed':
- countFailed++;
- break;
- case 'success':
- countCompleted++;
- break;
- case 'completed':
- countCompleted++;
- break;
- case 'aborted':
- countAborted++;
- break;
- case 'timedout':
- countTimedout++;
- break;
- }
- });
- categories.findProperty("value", 'all').set("count", countAll);
- categories.findProperty("value", 'pending').set("count", countPending);
- categories.findProperty("value", 'in_progress').set("count", countInProgress);
- categories.findProperty("value", 'failed').set("count", countFailed);
- categories.findProperty("value", 'completed').set("count", countCompleted);
- categories.findProperty("value", 'aborted').set("count", countAborted);
- categories.findProperty("value", 'timedout').set("count", countTimedout);
- },
- /**
- * For Background operation popup calculate number of running Operations, and set popup header
- * @param {bool} isServiceListHidden
- */
- setBackgroundOperationHeader: function (isServiceListHidden) {
- if (this.get('isBackgroundOperations') && !isServiceListHidden) {
- var numRunning = App.router.get('backgroundOperationsController.allOperationsCount');
- this.set("popupHeaderName", numRunning + Em.I18n.t('hostPopup.header.postFix'));
- }
- },
- /**
- * Create services obj data structure for popup
- * Set data for services
- * @param {bool} isServiceListHidden
- */
- onServiceUpdate: function (isServiceListHidden) {
- if (this.get('isBackgroundOperations') && this.get("inputData")) {
- var self = this;
- var allNewServices = [];
- var statuses = {
- 'FAILED': ['FAILED', 'icon-exclamation-sign', 'progress-danger', false],
- 'ABORTED': ['ABORTED', 'icon-minus', 'progress-warning', false],
- 'TIMEDOUT': ['TIMEDOUT', 'icon-time', 'progress-warning', false],
- 'IN_PROGRESS': ['IN_PROGRESS', 'icon-cogs', 'progress-info', true],
- 'COMPLETED': ['SUCCESS', 'icon-ok', 'progress-success', false]
- };
- var pendingStatus = ['PENDING', 'icon-cog', 'progress-info', true];
- this.set("servicesInfo", null);
- this.get("inputData").forEach(function (service) {
- var status = statuses[service.status] || pendingStatus;
- var newService = Ember.Object.create({
- id: service.id,
- displayName: service.displayName,
- progress: service.progress,
- status: App.format.taskStatus(status[0]),
- isRunning: service.isRunning,
- name: service.name,
- isVisible: true,
- startTime: date.startTime(service.startTime),
- duration: date.durationSummary(service.startTime, service.endTime),
- icon: status[1],
- barColor: status[2],
- isInProgress: status[3],
- barWidth: "width:" + service.progress + "%;",
- sourceRequestScheduleId: service.get('sourceRequestScheduleId'),
- contextCommand: service.get('contextCommand')
- });
- allNewServices.push(newService);
- });
- self.set('servicesInfo', allNewServices);
- this.setBackgroundOperationHeader(isServiceListHidden);
- }
- },
- /**
- * create task Ember object
- * @param {Object} _task
- * @return {Em.Object}
- */
- createTask: function (_task) {
- return Em.Object.create({
- id: _task.Tasks.id,
- hostName: _task.Tasks.host_name,
- command: ( _task.Tasks.command.toLowerCase() != 'service_check') ? _task.Tasks.command.toLowerCase() : '',
- commandDetail: App.format.commandDetail(_task.Tasks.command_detail, _task.Tasks.request_inputs),
- status: App.format.taskStatus(_task.Tasks.status),
- role: App.format.role(_task.Tasks.role),
- stderr: _task.Tasks.stderr,
- stdout: _task.Tasks.stdout,
- isVisible: true,
- startTime: date.startTime(_task.Tasks.start_time),
- duration: date.durationSummary(_task.Tasks.start_time, _task.Tasks.end_time),
- icon: function () {
- var statusIconMap = {
- 'pending': 'icon-cog',
- 'queued': 'icon-cog',
- 'in_progress': 'icon-cogs',
- 'completed': 'icon-ok',
- 'failed': 'icon-exclamation-sign',
- 'aborted': 'icon-minus',
- 'timedout': 'icon-time'
- };
- return statusIconMap[this.get('status')] || 'icon-cog';
- }.property('status')
- });
- },
- /**
- * Create hosts and tasks data structure for popup
- * Set data for hosts and tasks
- */
- onHostUpdate: function () {
- var self = this;
- var inputData = this.get("inputData");
- if (inputData) {
- var hostsArr = [];
- var hostsData;
- var hostsMap = {};
- if(this.get('isBackgroundOperations') && this.get("currentServiceId")){
- //hosts popup for Background Operations
- hostsData = inputData.findProperty("id", this.get("currentServiceId"));
- } else if (this.get("serviceName")) {
- //hosts popup for Wizards
- hostsData = inputData.findProperty("name", this.get("serviceName"));
- }
- if (hostsData) {
- if (hostsData.hostsMap) {
- //hosts data come from Background Operations as object map
- hostsMap = hostsData.hostsMap;
- } else if (hostsData.hosts) {
- //hosts data come from Wizard as array
- hostsData.hosts.forEach(function (_host) {
- hostsMap[_host.name] = _host;
- });
- }
- }
- var existedHosts = self.get('hosts');
- if (existedHosts && (existedHosts.length > 0) && this.get('currentServiceId') === this.get('previousServiceId')) {
- existedHosts.forEach(function (host) {
- var newHostInfo = hostsMap[host.get('name')];
- //update only hosts with changed tasks or currently opened tasks of host
- if (newHostInfo && (!this.get('isBackgroundOperations') || newHostInfo.isModified || this.get('currentHostName') === host.get('name'))) {
- var hostStatus = self.getStatus(newHostInfo.logTasks);
- var hostProgress = self.getProgress(newHostInfo.logTasks);
- host.set('status', App.format.taskStatus(hostStatus[0]));
- host.set('icon', hostStatus[1]);
- host.set('barColor', hostStatus[2]);
- host.set('isInProgress', hostStatus[3]);
- host.set('progress', hostProgress);
- host.set('barWidth', "width:" + hostProgress + "%;");
- host.set('logTasks', newHostInfo.logTasks);
- var existTasks = host.get('tasks');
- if (existTasks) {
- newHostInfo.logTasks.forEach(function (_task) {
- var existTask = existTasks.findProperty('id', _task.Tasks.id);
- if (existTask) {
- existTask.set('status', App.format.taskStatus(_task.Tasks.status));
- existTask.set('stdout', _task.Tasks.stdout);
- existTask.set('stderr', _task.Tasks.stderr);
- // Verified that this is needed.
- existTask.set('outputLog', _task.Tasks.output_log);
- existTask.set('errorLog', _task.Tasks.error_log);
- existTask.set('startTime', date.startTime(_task.Tasks.start_time));
- existTask.set('duration', date.durationSummary(_task.Tasks.start_time, _task.Tasks.end_time));
- } else {
- existTasks.pushObject(this.createTask(_task));
- }
- }, this);
- }
- }
- }, this);
- } else {
- for (var hostName in hostsMap) {
- var _host = hostsMap[hostName];
- var tasks = _host.logTasks;
- var hostInfo = Ember.Object.create({
- name: hostName,
- publicName: _host.publicName,
- displayName: function () {
- return this.get('name').length < 43 ? this.get('name') : (this.get('name').substr(0, 40) + '...');
- }.property('name'),
- progress: 0,
- status: App.format.taskStatus("PENDING"),
- serviceName: _host.serviceName,
- isVisible: true,
- icon: "icon-cog",
- barColor: "progress-info",
- barWidth: "width:0%;"
- });
- if (tasks.length) {
- tasks = tasks.sortProperty('Tasks.id');
- var hostStatus = self.getStatus(tasks);
- var hostProgress = self.getProgress(tasks);
- hostInfo.set('status', App.format.taskStatus(hostStatus[0]));
- hostInfo.set('icon', hostStatus[1]);
- hostInfo.set('barColor', hostStatus[2]);
- hostInfo.set('isInProgress', hostStatus[3]);
- hostInfo.set('progress', hostProgress);
- hostInfo.set('barWidth', "width:" + hostProgress + "%;");
- }
- hostInfo.set('logTasks', tasks);
- hostsArr.push(hostInfo);
- }
- hostsArr = hostsArr.sortProperty('name');
- hostsArr.setEach("serviceName", this.get("serviceName"));
- self.set("hosts", hostsArr);
- self.set('previousServiceId', this.get('currentServiceId'));
- }
- }
- },
- /**
- * Show popup
- * @return {App.ModalPopup} PopupObject For testing purposes
- */
- createPopup: function () {
- var self = this;
- var hostsInfo = this.get("hosts");
- var servicesInfo = this.get("servicesInfo");
- var isBackgroundOperations = this.get('isBackgroundOperations');
- var categoryObject = Em.Object.extend({
- value: '',
- count: 0,
- labelPath: '',
- label: function(){
- return Em.I18n.t(this.get('labelPath')).format(this.get('count'));
- }.property('count')
- });
- self.set('isPopup', App.ModalPopup.show({
- isHideBodyScroll: true,
- /**
- * no need to track is it loaded when popup contain only list of hosts
- * @type {bool}
- */
- isLoaded: !isBackgroundOperations,
- /**
- * is BG-popup opened
- * @type {bool}
- */
- isOpen: false,
- didInsertElement: function(){
- this._super();
- this.set('isOpen', true);
- },
- /**
- * @type {Em.View}
- */
- headerClass: Em.View.extend({
- controller: this,
- template: Ember.Handlebars.compile('{{popupHeaderName}}')
- }),
- /**
- * @type {String[]}
- */
- classNames: ['sixty-percent-width-modal', 'host-progress-popup'],
- /**
- * for the checkbox: do not show this dialog again
- * @type {bool}
- */
- hasFooterCheckbox: true,
- /**
- * Auto-display BG-popup
- * @type {bool}
- */
- isNotShowBgChecked : null,
- /**
- * Save user pref about auto-display BG-popup
- */
- updateNotShowBgChecked: function () {
- var curVal = !this.get('isNotShowBgChecked');
- var key = App.router.get('applicationController').persistKey();
- if (!App.get('testMode')) {
- App.router.get('applicationController').postUserPref(key, curVal);
- }
- }.observes('isNotShowBgChecked'),
- autoHeight: false,
- closeModelPopup: function () {
- this.set('isOpen', false);
- if(isBackgroundOperations){
- $(this.get('element')).detach();
- App.router.get('backgroundOperationsController').set('levelInfo.name', 'REQUESTS_LIST');
- } else {
- this.hide();
- self.set('isPopup', null);
- }
- },
- onPrimary: function () {
- this.closeModelPopup();
- },
- onClose: function () {
- this.closeModelPopup();
- },
- secondary: null,
- bodyClass: App.TableView.extend({
- templateName: require('templates/common/host_progress_popup'),
- isLogWrapHidden: true,
- isTaskListHidden: true,
- isHostListHidden: true,
- isServiceListHidden: false,
- showTextArea: false,
- isServiceEmptyList: true,
- isTasksEmptyList: true,
- controller: this,
- sourceRequestScheduleId: -1,
- sourceRequestScheduleRunning: false,
- sourceRequestScheduleAborted: false,
- sourceRequestScheduleCommand: null,
- hosts: self.get('hosts'),
- services: self.get('servicesInfo'),
- filterMap: {
- pending: ["pending", "queued"],
- in_progress: ["in_progress", "upgrading"],
- failed: ["failed"],
- completed: ["completed", "success"],
- aborted: ["aborted"],
- timedout: ["timedout"]
- },
- pagination: true,
- isPaginate: false,
- /**
- * Select box, display names and values
- */
- categories: [
- categoryObject.create({value: 'all', labelPath: 'hostPopup.status.category.all'}),
- categoryObject.create({value: 'pending', labelPath: 'hostPopup.status.category.pending'}),
- categoryObject.create({value: 'in_progress', labelPath: 'hostPopup.status.category.inProgress'}),
- categoryObject.create({value: 'failed', labelPath: 'hostPopup.status.category.failed'}),
- categoryObject.create({value: 'completed', labelPath: 'hostPopup.status.category.success'}),
- categoryObject.create({value: 'aborted', labelPath: 'hostPopup.status.category.aborted'}),
- categoryObject.create({value: 'timedout', labelPath: 'hostPopup.status.category.timedout'})
- ],
- /**
- * Selected option is bound to this values
- */
- serviceCategory: null,
- hostCategory: null,
- taskCategory: null,
- /**
- * flag to indicate whether level data has already been loaded
- * applied only to HOSTS_LIST and TASK_DETAILS levels, whereas async query used to obtain data
- */
- isLevelLoaded: true,
- isHostEmptyList: function() {
- return !this.get('pageContent.length');
- }.property('pageContent.length'),
- currentHost: function () {
- return this.get('hosts') && this.get('hosts').findProperty('name', this.get('controller.currentHostName'));
- }.property('controller.currentHostName'),
- tasks: function () {
- var currentHost = this.get('currentHost');
- if (currentHost) {
- return currentHost.get('tasks');
- }
- return [];
- }.property('currentHost.tasks', 'currentHost.tasks.@each.status'),
- /**
- * Preset values on init
- */
- setOnStart: function () {
- this.set('serviceCategory', this.get('categories').findProperty('value','all'));
- if (this.get("controller.isBackgroundOperations")) {
- this.get('controller').setSelectCount(this.get("services"), this.get('categories'));
- this.updateHostInfo();
- } else {
- this.set("isHostListHidden", false);
- this.set("isServiceListHidden", true);
- }
- },
- /**
- * force popup to show list of operations
- */
- resetState: function(){
- if(this.get('parentView.isOpen')){
- this.set('isLogWrapHidden', true);
- this.set('isTaskListHidden', true);
- this.set('isHostListHidden', true);
- this.set('isServiceListHidden', false);
- this.get("controller").setBackgroundOperationHeader(false);
- this.setOnStart();
- }
- }.observes('parentView.isOpen'),
- /**
- * When popup is opened, and data after polling has changed, update this data in component
- */
- updateHostInfo: function () {
- if(!this.get('parentView.isOpen')) return;
- this.set('parentView.isLoaded', false);
- this.get("controller").set("inputData", this.get("controller.dataSourceController.services"));
- this.get("controller").onServiceUpdate(this.get('isServiceListHidden'));
- this.get("controller").onHostUpdate();
- this.set('parentView.isLoaded', true);
- this.set("hosts", this.get("controller.hosts"));
- this.set("services", this.get("controller.servicesInfo"));
- this.set('isLevelLoaded', true);
- }.observes("controller.dataSourceController.serviceTimestamp"),
- /**
- * Depending on service filter, set which services should be shown
- */
- visibleServices: function () {
- if (this.get("services")) {
- this.set("isServiceEmptyList", true);
- if (this.get('serviceCategory.value')) {
- var filter = this.get('serviceCategory.value');
- var services = this.get('services');
- this.set("isServiceEmptyList", this.setVisibility(filter, services));
- }
- }
- }.observes('serviceCategory', 'services', 'services.@each.status'),
- /**
- * Depending on hosts filter, set which hosts should be shown
- */
- filter: function() {
- var _this = this,
- filter = this.get('hostCategory.value'),
- hosts = this.get('hosts') || [];
- if (!filter || !hosts.length) return;
- if (filter === 'all') {
- this.set('filteredContent', hosts);
- } else {
- this.set('filteredContent', hosts.filter(function(item) {
- return _this.get('filterMap')[filter].contains(item.status);
- }));
- }
- }.observes('hosts.length', 'hostCategory.value'),
- /**
- * Reset startIndex property back to 1 when filter type has been changed.
- */
- resetIndex: function() {
- if (this.get('hostCategory.value')) this.set('startIndex', 1)
- }.observes('hostCategory.value'),
- /**
- * Depending on tasks filter, set which tasks should be shown
- */
- visibleTasks: function () {
- this.set("isTasksEmptyList", true);
- if (this.get('taskCategory.value') && this.get('tasks')) {
- var filter = this.get('taskCategory.value');
- var tasks = this.get('tasks');
- this.set("isTasksEmptyList", this.setVisibility(filter, tasks));
- }
- }.observes('taskCategory', 'tasks', 'tasks.@each.status'),
- /**
- * Depending on selected filter type, set object visibility value
- * @param filter
- * @param obj
- * @return {bool} isEmptyList
- */
- setVisibility: function (filter, obj) {
- var isEmptyList = true;
- if (filter == "all") {
- obj.setEach("isVisible", true);
- isEmptyList = !(obj.length > 0);
- } else {
- obj.forEach(function(item){
- item.set('isVisible', this.get('filterMap')[filter].contains(item.status));
- isEmptyList = (isEmptyList) ? !item.get('isVisible') : false;
- }, this)
- }
- return isEmptyList;
- },
- /**
- * Depending on currently viewed tab, call setSelectCount function
- */
- updateSelectView: function () {
- var isPaginate;
- if (!this.get('isHostListHidden')) {
- //since lazy loading used for hosts, we need to get hosts info directly from controller, that always contains entire array of data
- this.get('controller').setSelectCount(this.get("controller.hosts"), this.get('categories'));
- isPaginate = true;
- } else if (!this.get('isTaskListHidden')) {
- this.get('controller').setSelectCount(this.get("tasks"), this.get('categories'));
- } else if (!this.get('isServiceListHidden')) {
- this.get('controller').setSelectCount(this.get("services"), this.get('categories'));
- }
- this.set('isPaginate', !!isPaginate);
- }.observes('tasks.@each.status', 'hosts.@each.status', 'isTaskListHidden', 'isHostListHidden', 'services.length', 'services.@each.status'),
- /**
- * control data uploading, depending on which display level is showed
- * @param levelName
- */
- switchLevel: function (levelName) {
- var dataSourceController = this.get('controller.dataSourceController');
- var securityControllers = [
- 'mainAdminSecurityDisableController',
- 'mainAdminSecurityAddStep4Controller'
- ];
- if (this.get("controller.isBackgroundOperations")) {
- var levelInfo = dataSourceController.get('levelInfo');
- levelInfo.set('taskId', this.get('openedTaskId'));
- levelInfo.set('requestId', this.get('controller.currentServiceId'));
- levelInfo.set('name', levelName);
- if (levelName === 'HOSTS_LIST') {
- this.set('isLevelLoaded', dataSourceController.requestMostRecent());
- this.set('hostCategory', this.get('categories').findProperty('value','all'));
- } else if (levelName === 'TASK_DETAILS') {
- dataSourceController.requestMostRecent();
- this.set('isLevelLoaded', false);
- } else if (levelName === 'REQUESTS_LIST') {
- this.set('serviceCategory', this.get('categories').findProperty('value','all'));
- this.get('controller.hosts').clear();
- dataSourceController.requestMostRecent();
- } else {
- this.set('taskCategory', this.get('categories').findProperty('value','all'));
- }
- } else if (securityControllers.contains(dataSourceController.get('name'))) {
- if (levelName === 'TASK_DETAILS') {
- this.set('isLevelLoaded', false);
- dataSourceController.startUpdatingTask(this.get('controller.currentServiceId'), this.get('openedTaskId'));
- } else {
- dataSourceController.stopUpdatingTask(this.get('controller.currentServiceId'));
- }
- }
- },
- /**
- * Onclick handler for button <-Tasks
- */
- backToTaskList: function () {
- this.destroyClipBoard();
- this.set("openedTaskId", 0);
- this.set("isLogWrapHidden", true);
- this.set("isTaskListHidden", false);
- this.switchLevel("TASKS_LIST");
- },
- /**
- * Onclick handler for button <-Hosts
- */
- backToHostList: function () {
- this.set("isHostListHidden", false);
- this.set("isTaskListHidden", true);
- this.get("controller").set("popupHeaderName", this.get("controller.serviceName"));
- this.switchLevel("HOSTS_LIST");
- },
- /**
- * Onclick handler for button <-Services
- */
- backToServiceList: function () {
- this.get("controller").set("serviceName", "");
- this.set("isHostListHidden", true);
- this.set("isServiceListHidden", false);
- this.set("isTaskListHidden", true);
- this.set("hosts", null);
- this.get("controller").setBackgroundOperationHeader(false);
- this.switchLevel("REQUESTS_LIST");
- },
- /**
- * Onclick handler for Show more ..
- */
- requestMoreOperations: function () {
- var count = App.db.getBGOOperationsCount();
- App.db.setBGOOperationsCount(count + 10);
- App.router.get('backgroundOperationsController').requestMostRecent();
- },
- setShowMoreAvailable: function () {
- if (this.get('parentView.isOpen')) {
- this.set('isShowMore', App.router.get("backgroundOperationsController.isShowMoreAvailable"));
- }
- }.observes('parentView.isOpen', 'App.router.backgroundOperationsController.isShowMoreAvailable'),
- isShowMore: true,
- /**
- * Onclick handler for selected Service
- * @param {Object} event
- */
- gotoHosts: function (event) {
- this.get("controller").set("serviceName", event.context.get("name"));
- this.get("controller").set("currentServiceId", event.context.get("id"));
- this.get("controller").set("currentHostName", null);
- this.get("controller").onHostUpdate();
- this.switchLevel("HOSTS_LIST");
- var servicesInfo = this.get("controller.hosts");
- if (servicesInfo.length) {
- this.get("controller").set("popupHeaderName", event.context.get("name"));
- }
- //apply lazy loading on cluster with more than 100 nodes
- if (servicesInfo.length > 100) {
- this.set('hosts', servicesInfo.slice(0, 50));
- } else {
- this.set('hosts', servicesInfo);
- }
- this.set("isServiceListHidden", true);
- this.set("isHostListHidden", false);
- $(".modal").scrollTop(0);
- $(".modal-body").scrollTop(0);
- if (servicesInfo.length > 100) {
- Em.run.next(this, function(){
- this.set('hosts', this.get('hosts').concat(servicesInfo.slice(50, servicesInfo.length)));
- });
- }
- // Determine if source request schedule is present
- this.set('sourceRequestScheduleId', event.context.get("sourceRequestScheduleId"));
- this.set('sourceRequestScheduleCommand', event.context.get('contextCommand'));
- this.refreshRequestScheduleInfo();
- },
- isRequestSchedule : function() {
- var id = this.get('sourceRequestScheduleId');
- return id != null && !isNaN(id) && id > -1;
- }.property('sourceRequestScheduleId'),
- refreshRequestScheduleInfo : function() {
- var self = this;
- var id = this.get('sourceRequestScheduleId');
- batchUtils.getRequestSchedule(id, function(data) {
- if (data != null && data.RequestSchedule != null &&
- data.RequestSchedule.status != null) {
- switch (data.RequestSchedule.status) {
- case 'DISABLED':
- self.set('sourceRequestScheduleRunning', false);
- self.set('sourceRequestScheduleAborted', true);
- break;
- case 'COMPLETED':
- self.set('sourceRequestScheduleRunning', false);
- self.set('sourceRequestScheduleAborted', false);
- break;
- case 'SCHEDULED':
- self.set('sourceRequestScheduleRunning', true);
- self.set('sourceRequestScheduleAborted', false);
- break;
- }
- } else {
- self.set('sourceRequestScheduleRunning', false);
- self.set('sourceRequestScheduleAborted', false);
- }
- }, function(xhr, textStatus, error, opt) {
- console.log("Error getting request schedule information: ", textStatus, error, opt);
- self.set('sourceRequestScheduleRunning', false);
- self.set('sourceRequestScheduleAborted', false);
- });
- }.observes('sourceRequestScheduleId'),
- /**
- * Attempts to abort the current request schedule
- */
- doAbortRequestSchedule: function(event){
- var self = this;
- var id = event.context;
- console.log("Aborting request schedule: ", id);
- batchUtils.doAbortRequestSchedule(id, function(){
- self.refreshRequestScheduleInfo();
- });
- },
- requestScheduleAbortLabel : function() {
- var label = Em.I18n.t("common.abort");
- var command = this.get('sourceRequestScheduleCommand');
- if (command != null && "ROLLING-RESTART" == command) {
- label = Em.I18n.t("hostPopup.bgop.abort.rollingRestart");
- }
- return label;
- }.property('sourceRequestScheduleCommand'),
- /**
- * Onclick handler for selected Host
- * @param {Object} event
- */
- gotoTasks: function (event) {
- var tasksInfo = [];
- event.context.logTasks.forEach(function (_task) {
- tasksInfo.pushObject(this.get("controller").createTask(_task));
- }, this);
- if (tasksInfo.length) {
- this.get("controller").set("popupHeaderName", event.context.publicName);
- this.get("controller").set("currentHostName", event.context.publicName);
- }
- this.switchLevel("TASKS_LIST");
- this.set('currentHost.tasks', tasksInfo);
- this.set("isHostListHidden", true);
- this.set("isTaskListHidden", false);
- $(".modal").scrollTop(0);
- $(".modal-body").scrollTop(0);
- },
- /**
- * Onclick handler for selected Task
- */
- openTaskLogInDialog: function () {
- if ($(".task-detail-log-clipboard").length > 0) {
- this.destroyClipBoard();
- }
- var newWindow = window.open();
- var newDocument = newWindow.document;
- newDocument.write($(".task-detail-log-info").html());
- newDocument.close();
- },
- openedTaskId: 0,
- /**
- * Return task detail info of opened task
- */
- openedTask: function () {
- if (!(this.get('openedTaskId') && this.get('tasks'))) {
- return Ember.Object.create();
- }
- return this.get('tasks').findProperty('id', this.get('openedTaskId'));
- }.property('tasks', 'tasks.@each.stderr', 'tasks.@each.stdout', 'openedTaskId'),
- /**
- * Onclick event for show task detail info
- * @param {Object} event
- */
- toggleTaskLog: function (event) {
- var taskInfo = event.context;
- this.set("isLogWrapHidden", false);
- if ($(".task-detail-log-clipboard").length > 0) {
- this.destroyClipBoard();
- }
- this.set("isHostListHidden", true);
- this.set("isTaskListHidden", true);
- this.set('openedTaskId', taskInfo.id);
- this.switchLevel("TASK_DETAILS");
- $(".modal").scrollTop(0);
- $(".modal-body").scrollTop(0);
- },
- /**
- * Onclick event for copy to clipboard button
- */
- textTrigger: function () {
- $(".task-detail-log-clipboard").length > 0 ? this.destroyClipBoard() : this.createClipBoard();
- },
- /**
- * Create Clip Board
- */
- createClipBoard: function () {
- var logElement = $(".task-detail-log-maintext");
- $(".task-detail-log-clipboard-wrap").html('<textarea class="task-detail-log-clipboard"></textarea>');
- $(".task-detail-log-clipboard")
- .html("stderr: \n" + $(".stderr").html() + "\n stdout:\n" + $(".stdout").html())
- .css("display", "block")
- .width(logElement.width())
- .height(logElement.height())
- .select();
- logElement.css("display", "none")
- },
- /**
- * Destroy Clip Board
- */
- destroyClipBoard: function () {
- $(".task-detail-log-clipboard").remove();
- $(".task-detail-log-maintext").css("display", "block");
- }
- })
- }));
- return self.get('isPopup');
- }
- });
|