stack_and_upgrade_controller.js 53 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348134913501351135213531354135513561357135813591360136113621363136413651366136713681369137013711372137313741375137613771378137913801381138213831384138513861387138813891390139113921393139413951396139713981399140014011402140314041405140614071408140914101411141214131414141514161417141814191420142114221423142414251426142714281429143014311432143314341435143614371438143914401441144214431444144514461447144814491450145114521453145414551456145714581459146014611462146314641465146614671468146914701471147214731474147514761477147814791480148114821483148414851486148714881489149014911492149314941495149614971498149915001501150215031504150515061507150815091510151115121513151415151516151715181519152015211522152315241525152615271528152915301531153215331534153515361537153815391540154115421543154415451546154715481549155015511552155315541555155615571558155915601561156215631564156515661567156815691570157115721573157415751576157715781579158015811582158315841585158615871588158915901591159215931594159515961597159815991600160116021603160416051606160716081609161016111612161316141615
  1. /**
  2. * Licensed to the Apache Software Foundation (ASF) under one
  3. * or more contributor license agreements. See the NOTICE file
  4. * distributed with this work for additional information
  5. * regarding copyright ownership. The ASF licenses this file
  6. * to you under the Apache License, Version 2.0 (the
  7. * "License"); you may not use this file except in compliance
  8. * with the License. You may obtain a copy of the License at
  9. *
  10. * http://www.apache.org/licenses/LICENSE-2.0
  11. *
  12. * Unless required by applicable law or agreed to in writing, software
  13. * distributed under the License is distributed on an "AS IS" BASIS,
  14. * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  15. * See the License for the specific language governing permissions and
  16. * limitations under the License.
  17. */
  18. var App = require('app');
  19. var stringUtils = require('utils/string_utils');
  20. App.MainAdminStackAndUpgradeController = Em.Controller.extend(App.LocalStorage, {
  21. name: 'mainAdminStackAndUpgradeController',
  22. /**
  23. * @type {boolean}
  24. */
  25. isLoaded: false,
  26. /**
  27. * @type {object}
  28. * @default null
  29. */
  30. upgradeData: null,
  31. /**
  32. * @type {number}
  33. * @default null
  34. */
  35. upgradeId: null,
  36. /**
  37. * @type {string}
  38. * @default null
  39. */
  40. upgradeVersion: null,
  41. /**
  42. * @type {string}
  43. * @default null
  44. */
  45. upgradeType: null,
  46. /**
  47. * @type {boolean}
  48. * @default true
  49. */
  50. downgradeAllowed: true,
  51. /**
  52. * @type {string}
  53. * @default null
  54. */
  55. upgradeTypeDisplayName: null,
  56. /**
  57. * @type {object}
  58. * @default null
  59. */
  60. failuresTolerance: null,
  61. /**
  62. * @type {boolean}
  63. * @default false
  64. */
  65. isDowngrade: false,
  66. /**
  67. * version that currently applied to server
  68. * should be plain object, because stored to localStorage
  69. * @type {object|null}
  70. */
  71. currentVersion: null,
  72. /**
  73. * versions to which cluster could be upgraded
  74. * @type {Array}
  75. */
  76. targetVersions: [],
  77. /**
  78. * @type {object}
  79. * @default null
  80. */
  81. slaveComponentStructuredInfo: null,
  82. /**
  83. * @type {Array}
  84. */
  85. serviceCheckFailuresServicenames: [],
  86. /**
  87. * methods through which cluster could be upgraded, "allowed" indicated if the method is allowed
  88. * by stack upgrade path
  89. * @type {Array}
  90. */
  91. upgradeMethods: [
  92. Em.Object.create({
  93. displayName: Em.I18n.t('admin.stackVersions.version.upgrade.upgradeOptions.RU.title'),
  94. type: 'ROLLING',
  95. icon: "icon-dashboard",
  96. description: Em.I18n.t('admin.stackVersions.version.upgrade.upgradeOptions.RU.description'),
  97. selected: false,
  98. allowed: true,
  99. isCheckComplete: false,
  100. isCheckRequestInProgress: false,
  101. precheckResultsMessage: '',
  102. precheckResultsTitle: '',
  103. action: ''
  104. }),
  105. Em.Object.create({
  106. displayName: Em.I18n.t('admin.stackVersions.version.upgrade.upgradeOptions.EU.title'),
  107. type: 'NON_ROLLING',
  108. icon: "icon-bolt",
  109. description: Em.I18n.t('admin.stackVersions.version.upgrade.upgradeOptions.EU.description'),
  110. selected: false,
  111. allowed: true,
  112. isCheckComplete: false,
  113. isCheckRequestInProgress: false,
  114. precheckResultsMessage: '',
  115. precheckResultsTitle: '',
  116. action: ''
  117. })
  118. ],
  119. runningCheckRequests: [],
  120. /**
  121. * @type {boolean} true if some request that should disable actions is in progress
  122. */
  123. requestInProgress: false,
  124. /**
  125. * @type {boolean} true while no updated upgrade info is loaded after retry
  126. */
  127. isRetryPending: false,
  128. /**
  129. * properties that stored to localStorage to resume wizard progress
  130. */
  131. wizardStorageProperties: [
  132. 'upgradeId',
  133. 'upgradeVersion',
  134. 'currentVersion',
  135. 'upgradeTypeDisplayName',
  136. 'upgradeType',
  137. 'failuresTolerance',
  138. 'isDowngrade',
  139. 'downgradeAllowed'
  140. ],
  141. /**
  142. * mutable properties of Upgrade Task
  143. * @type {Array}
  144. */
  145. taskDetailsProperties: ['status', 'stdout', 'stderr', 'error_log', 'host_name', 'output_log'],
  146. /**
  147. * Context for Finalize item
  148. * @type {string}
  149. */
  150. finalizeContext: 'Confirm Finalize',
  151. /**
  152. * Context for Slave component failures manual item
  153. * @type {string}
  154. */
  155. slaveFailuresContext: "Check Component Versions",
  156. /**
  157. * Context for Service check (may include slave component) failures manual item
  158. * @type {string}
  159. */
  160. serviceCheckFailuresContext: "Verifying Skipped Failures",
  161. /**
  162. * Check if current item is Finalize
  163. * @type {boolean}
  164. */
  165. isFinalizeItem: false,
  166. isLoadUpgradeDataPending: false,
  167. /**
  168. * path to the mock json
  169. * @type {String}
  170. */
  171. mockRepoUrl: '/data/stack_versions/repo_versions_all.json',
  172. /**
  173. * api to get RepoVersions
  174. * @type {String}
  175. */
  176. realRepoUrl: function () {
  177. return App.get('apiPrefix') + App.get('stackVersionURL') +
  178. '/compatible_repository_versions?fields=*,operating_systems/*,operating_systems/repositories/*';
  179. }.property('App.stackVersionURL'),
  180. /**
  181. * path to the mock json
  182. * @type {String}
  183. */
  184. mockStackUrl: '/data/stack_versions/stack_version_all.json',
  185. /**
  186. * api to get ClusterStackVersions with repository_versions (use to init data load)
  187. * @type {String}
  188. */
  189. realStackUrl: function () {
  190. return App.get('apiPrefix') + '/clusters/' + App.get('clusterName') +
  191. '/stack_versions?fields=*,repository_versions/*,repository_versions/operating_systems/repositories/*';
  192. }.property('App.clusterName'),
  193. /**
  194. * api to get ClusterStackVersions without repository_versions (use to update data)
  195. * @type {String}
  196. */
  197. realUpdateUrl: function () {
  198. return App.get('apiPrefix') + '/clusters/' + App.get('clusterName') + '/stack_versions?fields=ClusterStackVersions/*';
  199. }.property('App.clusterName'),
  200. /**
  201. * Determines if list of services with checks that failed and were skipped by user during the upgrade is loaded
  202. * @type {boolean}
  203. */
  204. areSkippedServiceChecksLoaded: false,
  205. /**
  206. * List of services with checks that failed and were skipped by user during the upgrade
  207. * @type {array}
  208. */
  209. skippedServiceChecks: [],
  210. /**
  211. * status of tasks/items/groups which should be grayed out and disabled
  212. * @type {Array}
  213. */
  214. nonActiveStates: ['PENDING', 'ABORTED'],
  215. /**
  216. * status of Upgrade request
  217. * @type {string}
  218. */
  219. requestStatus: function () {
  220. if (this.get('upgradeData.Upgrade') && this.get('upgradeData.Upgrade.request_status') == 'ABORTED') {
  221. return 'SUSPENDED';
  222. } else if (this.get('upgradeData.Upgrade')){
  223. return this.get('upgradeData.Upgrade.request_status');
  224. } else {
  225. return '';
  226. }
  227. }.property('upgradeData.Upgrade.request_status'),
  228. init: function () {
  229. this.initDBProperties();
  230. },
  231. /**
  232. * restore data from localStorage
  233. */
  234. initDBProperties: function () {
  235. var props = this.getDBProperties(this.get('wizardStorageProperties'));
  236. Em.keys(props).forEach(function (k) {
  237. if (!Em.isNone(props[k])) {
  238. this.set(k, props[k]);
  239. }
  240. }, this);
  241. },
  242. /**
  243. * load all data:
  244. * - upgrade data
  245. * - stack versions
  246. * - repo versions
  247. */
  248. load: function () {
  249. var dfd = $.Deferred();
  250. var self = this;
  251. this.loadUpgradeData(true).done(function() {
  252. self.loadStackVersionsToModel(true).done(function () {
  253. self.loadRepoVersionsToModel().done(function() {
  254. var currentVersion = App.StackVersion.find().findProperty('state', 'CURRENT');
  255. if (currentVersion) {
  256. self.set('currentVersion', {
  257. repository_version: currentVersion.get('repositoryVersion.repositoryVersion'),
  258. repository_name: currentVersion.get('repositoryVersion.displayName')
  259. });
  260. }
  261. dfd.resolve();
  262. });
  263. });
  264. });
  265. return dfd.promise();
  266. },
  267. /**
  268. * load upgrade tasks by upgrade id
  269. * @return {$.Deferred}
  270. * @param {boolean} onlyState
  271. */
  272. loadUpgradeData: function (onlyState) {
  273. var upgradeId = this.get('upgradeId'),
  274. deferred = $.Deferred(),
  275. self = this;
  276. if (Em.isNone(upgradeId)) {
  277. deferred.resolve();
  278. } else {
  279. this.set('isLoadUpgradeDataPending', true);
  280. App.ajax.send({
  281. name: (onlyState) ? 'admin.upgrade.state' : 'admin.upgrade.data',
  282. sender: this,
  283. data: {
  284. id: upgradeId
  285. },
  286. success: 'loadUpgradeDataSuccessCallback'
  287. }).then(deferred.resolve).complete(function () {
  288. self.set('isLoadUpgradeDataPending', false);
  289. });
  290. }
  291. return deferred.promise();
  292. },
  293. /**
  294. * parse and push upgrade tasks to controller
  295. * @param data
  296. */
  297. loadUpgradeDataSuccessCallback: function (data) {
  298. if (Em.isNone(data)) return;
  299. App.set('upgradeState', data.Upgrade.request_status);
  300. this.setDBProperty('upgradeState', data.Upgrade.request_status);
  301. if (data.upgrade_groups) {
  302. this.updateUpgradeData(data);
  303. }
  304. if (this.get('isRetryPending') && data.Upgrade.request_status != 'ABORTED') {
  305. this.setProperties({
  306. requestInProgress: false,
  307. isRetryPending: false
  308. });
  309. }
  310. },
  311. /**
  312. * update data of Upgrade
  313. * @param {object} newData
  314. */
  315. updateUpgradeData: function (newData) {
  316. var oldData = this.get('upgradeData'),
  317. nonActiveStates = this.get('nonActiveStates'),
  318. groupsMap = {},
  319. itemsMap = {};
  320. if (Em.isNone(oldData) || (newData.upgrade_groups.length !== oldData.upgradeGroups.length)) {
  321. this.initUpgradeData(newData);
  322. } else {
  323. //create entities maps
  324. newData.upgrade_groups.forEach(function (newGroup) {
  325. groupsMap[newGroup.UpgradeGroup.group_id] = newGroup.UpgradeGroup;
  326. newGroup.upgrade_items.forEach(function (item) {
  327. itemsMap[item.UpgradeItem.stage_id] = item.UpgradeItem;
  328. })
  329. });
  330. //update existed entities with new data
  331. oldData.upgradeGroups.forEach(function (oldGroup) {
  332. oldGroup.set('status', groupsMap[oldGroup.get('group_id')].status);
  333. oldGroup.set('progress_percent', groupsMap[oldGroup.get('group_id')].progress_percent);
  334. oldGroup.set('completed_task_count', groupsMap[oldGroup.get('group_id')].completed_task_count);
  335. oldGroup.upgradeItems.forEach(function (item) {
  336. item.set('status', itemsMap[item.get('stage_id')].status);
  337. item.set('progress_percent', itemsMap[item.get('stage_id')].progress_percent);
  338. });
  339. var hasExpandableItems = oldGroup.upgradeItems.some(function (item) {
  340. return !nonActiveStates.contains(item.get('status'));
  341. });
  342. oldGroup.set('hasExpandableItems', hasExpandableItems);
  343. });
  344. oldData.set('Upgrade', newData.Upgrade);
  345. }
  346. },
  347. /**
  348. * change structure of Upgrade
  349. * In order to maintain nested views in template object should have direct link to its properties, for example
  350. * item.UpgradeItem.<properties> -> item.<properties>
  351. * @param {object} newData
  352. */
  353. initUpgradeData: function (newData) {
  354. var upgradeGroups = [],
  355. nonActiveStates = this.get('nonActiveStates');
  356. //wrap all entities into App.upgradeEntity
  357. newData.upgrade_groups.forEach(function (newGroup) {
  358. var hasExpandableItems = newGroup.upgrade_items.some(function (item) {
  359. return !nonActiveStates.contains(item.UpgradeItem.status);
  360. }),
  361. oldGroup = App.upgradeEntity.create({type: 'GROUP', hasExpandableItems: hasExpandableItems}, newGroup.UpgradeGroup),
  362. upgradeItems = [];
  363. newGroup.upgrade_items.forEach(function (item) {
  364. var oldItem = App.upgradeEntity.create({type: 'ITEM'}, item.UpgradeItem);
  365. oldItem.set('tasks', []);
  366. upgradeItems.pushObject(oldItem);
  367. });
  368. upgradeItems.reverse();
  369. oldGroup.set('upgradeItems', upgradeItems);
  370. upgradeGroups.pushObject(oldGroup);
  371. });
  372. upgradeGroups.reverse();
  373. this.set('upgradeData', Em.Object.create({
  374. upgradeGroups: upgradeGroups,
  375. Upgrade: newData.Upgrade
  376. }));
  377. this.set('downgradeAllowed', newData.Upgrade.downgrade_allowed);
  378. this.setDBProperty('downgradeAllowed', newData.Upgrade.downgrade_allowed);
  379. },
  380. /**
  381. * request Upgrade Item and its tasks from server
  382. * @param {Em.Object} item
  383. * @param {Function} customCallback
  384. * @return {$.ajax}
  385. */
  386. getUpgradeItem: function (item, customCallback) {
  387. return App.ajax.send({
  388. name: 'admin.upgrade.upgrade_item',
  389. sender: this,
  390. data: {
  391. upgradeId: item.get('request_id'),
  392. groupId: item.get('group_id'),
  393. stageId: item.get('stage_id')
  394. },
  395. success: customCallback || 'getUpgradeItemSuccessCallback'
  396. });
  397. },
  398. /**
  399. * success callback of <code>getTasks</code>
  400. * @param {object} data
  401. */
  402. getUpgradeItemSuccessCallback: function (data) {
  403. this.get('upgradeData.upgradeGroups').forEach(function (group) {
  404. if (group.get('group_id') === data.UpgradeItem.group_id) {
  405. group.get('upgradeItems').forEach(function (item) {
  406. if (item.get('stage_id') === data.UpgradeItem.stage_id) {
  407. if (item.get('tasks.length')) {
  408. item.set('isTasksLoaded', true);
  409. data.tasks.forEach(function (task) {
  410. var currentTask = item.get('tasks').findProperty('id', task.Tasks.id);
  411. this.get('taskDetailsProperties').forEach(function (property) {
  412. currentTask.set(property, task.Tasks[property]);
  413. }, this);
  414. }, this);
  415. } else {
  416. var tasks = [];
  417. data.tasks.forEach(function (task) {
  418. tasks.pushObject(App.upgradeEntity.create({type: 'TASK'}, task.Tasks));
  419. });
  420. item.set('tasks', tasks);
  421. }
  422. item.set('isTasksLoaded', true);
  423. }
  424. }, this);
  425. }
  426. }, this);
  427. },
  428. /**
  429. * Failures info may includes service_check and host_component failures. These two types should be displayed separately.
  430. */
  431. getServiceCheckItemSuccessCallback: function(data) {
  432. var task = data.tasks[0];
  433. var info = {
  434. hosts: [],
  435. host_detail: {}
  436. };
  437. if (task && task.Tasks && task.Tasks.structured_out && task.Tasks.structured_out.failures) {
  438. this.set('serviceCheckFailuresServicenames', task.Tasks.structured_out.failures.service_check || []);
  439. if (task.Tasks.structured_out.failures.host_component) {
  440. for (var hostname in task.Tasks.structured_out.failures.host_component){
  441. info.hosts.push(hostname);
  442. }
  443. info.host_detail = task.Tasks.structured_out.failures.host_component;
  444. }
  445. this.set('slaveComponentStructuredInfo', info);
  446. }
  447. },
  448. getSlaveComponentItemSuccessCallback: function(data) {
  449. var info = data.tasks[0];
  450. if (info && info.Tasks && info.Tasks.structured_out) {
  451. this.set('slaveComponentStructuredInfo', info.Tasks.structured_out);
  452. }
  453. },
  454. /**
  455. * downgrade confirmation popup
  456. * @param {object} event
  457. */
  458. confirmDowngrade: function (event) {
  459. var self = this;
  460. var currentVersion = this.get('currentVersion');
  461. return App.showConfirmationPopup(
  462. function() {
  463. self.downgrade.call(self, currentVersion, event);
  464. },
  465. Em.I18n.t('admin.stackUpgrade.downgrade.body').format(currentVersion.repository_name),
  466. null,
  467. Em.I18n.t('admin.stackUpgrade.dialog.downgrade.header').format(currentVersion.repository_name),
  468. Em.I18n.t('admin.stackUpgrade.downgrade.proceed')
  469. );
  470. },
  471. /**
  472. * make call to start downgrade process
  473. * @param {object} currentVersion
  474. * @param {object} event
  475. */
  476. downgrade: function (currentVersion, event) {
  477. this.set('requestInProgress', true);
  478. this.abortUpgrade();
  479. App.ajax.send({
  480. name: 'admin.downgrade.start',
  481. sender: this,
  482. data: {
  483. from: App.RepositoryVersion.find().findProperty('displayName', this.get('upgradeVersion')).get('repositoryVersion'),
  484. value: currentVersion.repository_version,
  485. label: currentVersion.repository_name,
  486. isDowngrade: true,
  487. upgradeType: this.get('upgradeType')
  488. },
  489. success: 'upgradeSuccessCallback',
  490. callback: function() {
  491. this.sender.set('requestInProgress', false);
  492. }
  493. });
  494. },
  495. /**
  496. * abort upgrade (in order to start Downgrade)
  497. */
  498. abortUpgrade: function () {
  499. return App.ajax.send({
  500. name: 'admin.upgrade.abort',
  501. sender: this,
  502. data: {
  503. upgradeId: this.get('upgradeId')
  504. }
  505. });
  506. },
  507. retryUpgrade: function () {
  508. this.setProperties({
  509. requestInProgress: true,
  510. isRetryPending: true
  511. });
  512. return App.ajax.send({
  513. name: 'admin.upgrade.retry',
  514. sender: this,
  515. data: {
  516. upgradeId: this.get('upgradeId')
  517. }
  518. });
  519. },
  520. /**
  521. * make call to start upgrade process and show popup with current progress
  522. * @param {object} version
  523. */
  524. upgrade: function (version) {
  525. this.set('requestInProgress', true);
  526. App.ajax.send({
  527. name: 'admin.upgrade.start',
  528. sender: this,
  529. data: version,
  530. success: 'upgradeSuccessCallback',
  531. error: 'upgradeErrorCallback',
  532. callback: function() {
  533. this.sender.set('requestInProgress', false);
  534. }
  535. });
  536. this.setDBProperty('currentVersion', this.get('currentVersion'));
  537. },
  538. /**
  539. * error callback of <code>upgrade()</code>
  540. * @param {object} data
  541. */
  542. upgradeErrorCallback: function (data) {
  543. var header = Em.I18n.t('admin.stackVersions.upgrade.start.fail.title');
  544. var body = "";
  545. if(data && data.responseText){
  546. try {
  547. var json = $.parseJSON(data.responseText);
  548. body = json.message;
  549. } catch (err) {}
  550. }
  551. App.showAlertPopup(header, body);
  552. },
  553. /**
  554. * success callback of <code>upgrade()</code>
  555. * @param {object} data
  556. */
  557. upgradeSuccessCallback: function (data, opt, params) {
  558. this.set('upgradeData', null);
  559. this.set('upgradeId', data.resources[0].Upgrade.request_id);
  560. this.set('upgradeVersion', params.label);
  561. this.set('isDowngrade', !!params.isDowngrade);
  562. var upgradeMethod = this.get('upgradeMethods').findProperty('type', params.type);
  563. var upgradeTypeDisplayName = null;
  564. var upgradeType = null;
  565. if (upgradeMethod) {
  566. upgradeTypeDisplayName = upgradeMethod.get('displayName');
  567. upgradeType = upgradeMethod.get('type');
  568. }
  569. this.set('upgradeType', upgradeType);
  570. this.set('upgradeTypeDisplayName', upgradeTypeDisplayName);
  571. this.set('failuresTolerance', Em.Object.create({
  572. skipComponentFailures: params.skipComponentFailures == 'true',
  573. skipSCFailures: params.skipSCFailures == 'true'
  574. }));
  575. this.setDBProperties({
  576. upgradeVersion: params.label,
  577. upgradeId: data.resources[0].Upgrade.request_id,
  578. upgradeState: 'PENDING',
  579. isDowngrade: !!params.isDowngrade,
  580. upgradeType: upgradeType,
  581. upgradeTypeDisplayName: upgradeTypeDisplayName,
  582. failuresTolerance: Em.Object.create({
  583. skipComponentFailures: params.skipComponentFailures == 'true',
  584. skipSCFailures: params.skipSCFailures == 'true'
  585. })
  586. });
  587. App.set('upgradeState', 'PENDING');
  588. App.clusterStatus.setClusterStatus({
  589. wizardControllerName: this.get('name'),
  590. localdb: App.db.data
  591. });
  592. this.load();
  593. this.openUpgradeDialog();
  594. },
  595. /**
  596. * success callback of updating upgrade options including failures tolerance. etc
  597. * @param {object} data
  598. */
  599. updateOptionsSuccessCallback: function (data, opt, params) {
  600. this.set('failuresTolerance', Em.Object.create({
  601. skipComponentFailures: params.skipComponentFailures == 'true',
  602. skipSCFailures: params.skipSCFailures == 'true'
  603. }));
  604. },
  605. /**
  606. * run upgrade checks and add results to each method object and set selected method
  607. * @param {Em.Object} version
  608. */
  609. runUpgradeMethodChecks: function(version) {
  610. this.get('upgradeMethods').forEach(function (method) {
  611. if (method.get('allowed')) {
  612. this.runPreUpgradeCheckOnly({
  613. value: version.get('repositoryVersion'),
  614. label: version.get('displayName'),
  615. type: method.get('type')
  616. });
  617. } else {
  618. //if method not supported in current stack version, mark as check completed
  619. method.setProperties({
  620. isCheckComplete: false,
  621. isCheckRequestInProgress: false,
  622. action: ''
  623. });
  624. }
  625. }, this);
  626. },
  627. getConfigsWarnings: function (configsMergeWarning) {
  628. var configs = [];
  629. if (configsMergeWarning && Em.get(configsMergeWarning, 'UpgradeChecks.status') === 'WARNING') {
  630. var configsMergeCheckData = Em.get(configsMergeWarning, 'UpgradeChecks.failed_detail');
  631. if (configsMergeCheckData && Em.isArray(configsMergeCheckData)) {
  632. configs = configsMergeCheckData.map(function (item) {
  633. var isDeprecated = Em.isNone(item.new_stack_value),
  634. willBeRemoved = Em.isNone(item.result_value);
  635. return {
  636. type: item.type,
  637. name: item.property,
  638. currentValue: item.current,
  639. recommendedValue: isDeprecated ? Em.I18n.t('popup.clusterCheck.Upgrade.configsMerge.deprecated') : item.new_stack_value,
  640. isDeprecated: isDeprecated,
  641. resultingValue: willBeRemoved ? Em.I18n.t('popup.clusterCheck.Upgrade.configsMerge.willBeRemoved') : item.result_value,
  642. willBeRemoved: willBeRemoved
  643. };
  644. });
  645. }
  646. }
  647. return configs;
  648. },
  649. /**
  650. * Open upgrade options window: upgrade type and failures tolerance
  651. * @param {boolean} isInUpgradeWizard
  652. * @param {object} version
  653. * @return App.ModalPopup
  654. */
  655. upgradeOptions: function (isInUpgradeWizard, version) {
  656. var self = this,
  657. upgradeMethods = this.get('upgradeMethods'),
  658. runningCheckRequests = this.get('runningCheckRequests');
  659. if (!isInUpgradeWizard) {
  660. upgradeMethods.setEach('isCheckRequestInProgress', true);
  661. upgradeMethods.setEach('selected', false);
  662. var request = this.getSupportedUpgradeTypes(Ember.Object.create({
  663. stackName: App.get('currentStackVersion').split('-')[0],
  664. stackVersion: App.get('currentStackVersion').split('-')[1],
  665. toVersion: version.get('repositoryVersion')
  666. })).done(function () {
  667. if (App.get('router.currentState.name') === 'versions' && App.get('router.currentState.parentState.name') === 'stackAndUpgrade') {
  668. self.runUpgradeMethodChecks(version);
  669. }
  670. }).always(function () {
  671. self.set('runningCheckRequests', runningCheckRequests.rejectProperty('type', 'ALL'));
  672. });
  673. request.type = 'ALL';
  674. this.get('runningCheckRequests').push(request);
  675. }
  676. return App.ModalPopup.show({
  677. encodeBody: false,
  678. primary: isInUpgradeWizard ? Em.I18n.t('ok') : Em.I18n.t('common.proceed'),
  679. primaryClass: 'btn-success',
  680. classNames: ['upgrade-options-popup'],
  681. header: Em.I18n.t('admin.stackVersions.version.upgrade.upgradeOptions.header'),
  682. bodyClass: Em.View.extend({
  683. templateName: require('templates/main/admin/stack_upgrade/upgrade_options'),
  684. didInsertElement: function () {
  685. App.tooltip($(".failure-tolerance-tooltip"), {
  686. placement: "top",
  687. title: Em.I18n.t('admin.stackVersions.version.upgrade.upgradeOptions.tolerance.tooltip')
  688. });
  689. Em.run.later(this, function () {
  690. App.tooltip($(".thumbnail.check-failed"), {
  691. placement: "bottom",
  692. title: Em.I18n.t('admin.stackVersions.version.upgrade.upgradeOptions.preCheck.failed.tooltip')
  693. });
  694. App.tooltip($(".not-allowed-by-version"), {
  695. placement: "bottom",
  696. title: Em.I18n.t('admin.stackVersions.version.upgrade.upgradeOptions.notAllowed')
  697. });
  698. }, 1000);
  699. },
  700. upgradeMethods: function () {
  701. self.updateSelectedMethod(isInUpgradeWizard);
  702. return self.get('upgradeMethods');
  703. }.property().volatile(),
  704. isInUpgradeWizard: isInUpgradeWizard,
  705. versionText: isInUpgradeWizard ? '' : Em.I18n.t('admin.stackVersions.version.upgrade.upgradeOptions.bodyMsg.version').format(version.get('displayName')),
  706. selectMethod: function (event) {
  707. if (isInUpgradeWizard || !event.context.get('allowed') || event.context.get('isPrecheckFailed')) return;
  708. var selectedMethod = event.context;
  709. self.updateSelectedMethod(isInUpgradeWizard);
  710. self.get('upgradeMethods').forEach(function (method) {
  711. method.set('selected', false);
  712. });
  713. selectedMethod.set('selected', true);
  714. this.set('parentView.selectedMethod', selectedMethod);
  715. },
  716. runAction: function (event) {
  717. var method = event.context,
  718. action = method.get('action');
  719. if (action) {
  720. this.get(action)(event);
  721. }
  722. },
  723. rerunCheck: function (event) {
  724. self.runPreUpgradeCheckOnly({
  725. value: version.get('repositoryVersion'),
  726. label: version.get('displayName'),
  727. type: event.context.get('type')
  728. });
  729. },
  730. openMessage: function (event) {
  731. if (isInUpgradeWizard || !event.context.get('allowed')) return;
  732. var data = event.context.get('precheckResultsData');
  733. var header = Em.I18n.t('popup.clusterCheck.Upgrade.header').format(version.get('displayName')),
  734. failTitle = Em.I18n.t('popup.clusterCheck.Upgrade.fail.title'),
  735. failAlert = new Em.Handlebars.SafeString(Em.I18n.t('popup.clusterCheck.Upgrade.fail.alert')),
  736. warningTitle = Em.I18n.t('popup.clusterCheck.Upgrade.warning.title'),
  737. warningAlert = new Em.Handlebars.SafeString(Em.I18n.t('popup.clusterCheck.Upgrade.warning.alert')),
  738. configsMergeWarning = data.items.findProperty('UpgradeChecks.id', "CONFIG_MERGE"),
  739. popupData = {
  740. items: data.items.rejectProperty('UpgradeChecks.id', 'CONFIG_MERGE')
  741. },
  742. configs = self.getConfigsWarnings(configsMergeWarning);
  743. App.showClusterCheckPopup(popupData, {
  744. header: header,
  745. failTitle: failTitle,
  746. failAlert: failAlert,
  747. warningTitle: warningTitle,
  748. warningAlert: warningAlert,
  749. primary: Em.I18n.t('admin.stackVersions.version.upgrade.upgradeOptions.preCheck.rerun'),
  750. secondary: Em.I18n.t('common.cancel'),
  751. callback: function () {
  752. self.runPreUpgradeCheckOnly.call(self, {
  753. value: version.get('repositoryVersion'),
  754. label: version.get('displayName'),
  755. type: event.context.get('type')
  756. });
  757. }
  758. }, configs, version.get('displayName'));
  759. }
  760. }),
  761. /**
  762. * @type {Em.Object}
  763. * @default null
  764. */
  765. selectedMethod: null,
  766. skipComponentFailures: self.get('failuresTolerance.skipComponentFailures'),
  767. skipSCFailures: self.get('failuresTolerance.skipSCFailures'),
  768. disablePrimary: function () {
  769. if (isInUpgradeWizard) return false;
  770. var selectedMethod = this.get('selectedMethod');
  771. return (selectedMethod ? (selectedMethod.get('isPrecheckFailed') || selectedMethod.get('isCheckRequestInProgress')) : true);
  772. }.property('selectedMethod', 'selectedMethod.isPrecheckFailed', 'selectedMethod.isCheckRequestInProgress'),
  773. onPrimary: function () {
  774. this.hide();
  775. if (isInUpgradeWizard) {
  776. return App.ajax.send({
  777. name: 'admin.upgrade.update.options',
  778. sender: self,
  779. data: {
  780. upgradeId: self.get('upgradeId'),
  781. skipComponentFailures: Boolean(this.get('skipComponentFailures')).toString(),
  782. skipSCFailures: Boolean(this.get('skipSCFailures')).toString()
  783. },
  784. success: 'updateOptionsSuccessCallback'
  785. });
  786. } else {
  787. var upgradeMethod = self.get('upgradeMethods').findProperty('selected');
  788. version.upgradeType = upgradeMethod.get('type');
  789. version.upgradeTypeDisplayName = upgradeMethod.get('displayName');
  790. version.skipComponentFailures = this.get('skipComponentFailures');
  791. version.skipSCFailures = this.get('skipSCFailures');
  792. var fromVersion = self.get('upgradeVersion') || App.RepositoryVersion.find().findProperty('status', 'CURRENT').get('displayName');
  793. var toVersion = version.get('displayName');
  794. var bodyMessage = Em.Object.create({
  795. confirmButton: Em.I18n.t('yes'),
  796. confirmMsg: upgradeMethod.get('type') === 'ROLLING' ?
  797. Em.I18n.t('admin.stackVersions.version.upgrade.upgradeOptions.RU.confirm.msg').format(fromVersion, toVersion) :
  798. Em.I18n.t('admin.stackVersions.version.upgrade.upgradeOptions.EU.confirm.msg').format(fromVersion, toVersion)
  799. });
  800. return App.showConfirmationFeedBackPopup(function (query) {
  801. return self.runPreUpgradeCheck.call(self, version);
  802. }, bodyMessage);
  803. }
  804. }
  805. });
  806. },
  807. /**
  808. * open upgrade options from upgrade wizard
  809. */
  810. openUpgradeOptions: function () {
  811. if (this.get('isDowngrade')) return;
  812. this.upgradeOptions(true, null);
  813. },
  814. /**
  815. * upgrade confirmation popup including upgrade options: upgrade type and failures tolerance
  816. * @param {object} version
  817. * @return App.ModalPopup
  818. */
  819. confirmUpgrade: function (version) {
  820. this.upgradeOptions(false, version);
  821. },
  822. /**
  823. * send request for pre upgrade check only
  824. */
  825. runPreUpgradeCheckOnly: function (data) {
  826. if (App.get('supports.preUpgradeCheck')) {
  827. var method = this.get('upgradeMethods').findProperty('type', data.type);
  828. method.setProperties({
  829. isCheckComplete: false,
  830. isCheckRequestInProgress: true,
  831. action: ''
  832. });
  833. var request = App.ajax.send({
  834. name: "admin.upgrade.pre_upgrade_check",
  835. sender: this,
  836. data: data,
  837. success: 'runPreUpgradeCheckOnlySuccess',
  838. error: 'runPreUpgradeCheckOnlyError',
  839. callback: function () {
  840. var runningCheckRequests = this.sender.get('runningCheckRequests');
  841. method.set('isCheckRequestInProgress', false);
  842. this.sender.set('runningCheckRequests', runningCheckRequests.rejectProperty('type', this.data.type));
  843. }
  844. });
  845. request.type = data.type;
  846. this.get('runningCheckRequests').push(request);
  847. }
  848. },
  849. /**
  850. * send request to get available upgrade tye names
  851. */
  852. getSupportedUpgradeTypes: function(data) {
  853. return App.ajax.send({
  854. name: "admin.upgrade.get_supported_upgradeTypes",
  855. sender: this,
  856. data: data,
  857. success: "getSupportedUpgradeTypesSuccess"
  858. });
  859. },
  860. /**
  861. * success callback of <code>getSupportedUpgradeTypes()</code>
  862. * @param data {object}
  863. */
  864. getSupportedUpgradeTypesSuccess: function (data) {
  865. var supportedUpgradeTypes = data.items[0] && data.items[0].CompatibleRepositoryVersions.upgrade_types;
  866. this.get('upgradeMethods').forEach(function (method) {
  867. method.set('allowed', supportedUpgradeTypes && !!supportedUpgradeTypes.contains(method.get('type')));
  868. });
  869. },
  870. /**
  871. * success callback of <code>runPreUpgradeCheckOnly()</code>
  872. * Show a message how many fails/warnings/passed
  873. * on clicking that message a popup window show up
  874. * @param data {object}
  875. * @param opt {object}
  876. * @param params {object}
  877. */
  878. runPreUpgradeCheckOnlySuccess: function (data, opt, params) {
  879. var self = this;
  880. var message = '';
  881. var messageClass = 'GREEN';
  882. var messageIconClass = 'icon-ok';
  883. if (data.items.someProperty('UpgradeChecks.status', 'WARNING')) {
  884. message = message + data.items.filterProperty('UpgradeChecks.status', 'WARNING').length + ' Warning ';
  885. messageClass = 'ORANGE';
  886. messageIconClass = 'icon-warning-sign';
  887. }
  888. if (data.items.someProperty('UpgradeChecks.status', 'FAIL')) {
  889. message = data.items.filterProperty('UpgradeChecks.status', 'FAIL').length + ' Required ' + message;
  890. messageClass = 'RED';
  891. messageIconClass = 'icon-remove';
  892. }
  893. if (!message) {
  894. message = Em.I18n.t('admin.stackVersions.version.upgrade.upgradeOptions.preCheck.allPassed');
  895. }
  896. var method = self.get('upgradeMethods').findProperty('type', params.type);
  897. method.setProperties({
  898. precheckResultsMessage: message,
  899. precheckResultsMessageClass: messageClass,
  900. precheckResultsTitle: Em.I18n.t('admin.stackVersions.version.upgrade.upgradeOptions.preCheck.msg.title'),
  901. isPrecheckFailed: messageClass == 'RED',
  902. precheckResultsMessageIconClass: messageIconClass,
  903. precheckResultsData: data,
  904. isCheckComplete: true,
  905. action: 'openMessage'
  906. });
  907. this.updateSelectedMethod(false);
  908. Em.run.later(this, function () {
  909. // add tooltip for the type with preCheck errors
  910. App.tooltip($(".thumbnail.check-failed"), {
  911. placement: "bottom",
  912. title: Em.I18n.t('admin.stackVersions.version.upgrade.upgradeOptions.preCheck.failed.tooltip')
  913. });
  914. // destroy the tooltip for the type wo preCheck errors
  915. $(".thumbnail").not(".check-failed").not(".not-allowed-by-version").tooltip("destroy");
  916. }, 1000);
  917. },
  918. runPreUpgradeCheckOnlyError: function (request, ajaxOptions, error, data, params) {
  919. var method = this.get('upgradeMethods').findProperty('type', params.type);
  920. method.setProperties({
  921. precheckResultsMessage: Em.I18n.t('admin.stackVersions.version.upgrade.upgradeOptions.preCheck.msg.failed.link'),
  922. precheckResultsTitle: Em.I18n.t('admin.stackVersions.version.upgrade.upgradeOptions.preCheck.msg.failed.title'),
  923. precheckResultsMessageClass: 'RED',
  924. isPrecheckFailed: true,
  925. precheckResultsMessageIconClass: 'icon-warning-sign',
  926. action: 'rerunCheck'
  927. });
  928. },
  929. /**
  930. * In Upgrade Wizard: update which method already been selected on open
  931. * Not in upgrade wizard: de-select the method with pre-check errors
  932. * @param isInUpgradeWizard {boolean}
  933. */
  934. updateSelectedMethod: function(isInUpgradeWizard) {
  935. var self = this;
  936. if (isInUpgradeWizard) {
  937. this.get('upgradeMethods').forEach(function(method){
  938. if (method.get('type') == self.get('upgradeType')) {
  939. method.set('selected', true);
  940. } else {
  941. method.set('selected', false);
  942. }
  943. });
  944. } else {
  945. var ruMethod = this.get('upgradeMethods').findProperty('type', 'ROLLING');
  946. var euMethod = this.get('upgradeMethods').findProperty('type', 'NON_ROLLING');
  947. if (ruMethod && ruMethod.get('isPrecheckFailed')) ruMethod.set('selected', false);
  948. if (euMethod && euMethod.get('isPrecheckFailed')) euMethod.set('selected', false);
  949. }
  950. },
  951. /**
  952. * send request for pre upgrade check
  953. * @param version
  954. */
  955. runPreUpgradeCheck: function(version) {
  956. var params = {
  957. value: version.get('repositoryVersion'),
  958. label: version.get('displayName'),
  959. type: version.get('upgradeType'),
  960. skipComponentFailures: version.get('skipComponentFailures') ? 'true' : 'false',
  961. skipSCFailures: version.get('skipSCFailures') ? 'true' : 'false'
  962. };
  963. if (App.get('supports.preUpgradeCheck')) {
  964. this.set('requestInProgress', true);
  965. App.ajax.send({
  966. name: "admin.upgrade.pre_upgrade_check",
  967. sender: this,
  968. data: params,
  969. success: "runPreUpgradeCheckSuccess",
  970. error: "runPreUpgradeCheckError"
  971. });
  972. } else {
  973. this.upgrade(params);
  974. }
  975. },
  976. /**
  977. * success callback of <code>runPreUpgradeCheckSuccess()</code>
  978. * if there are some fails - it shows popup else run upgrade
  979. * @param data {object}
  980. * @param opt {object}
  981. * @param params {object}
  982. * @returns {App.ModalPopup|undefined}
  983. */
  984. runPreUpgradeCheckSuccess: function (data, opt, params) {
  985. var self = this;
  986. if (data.items.someProperty('UpgradeChecks.status', 'FAIL') || data.items.someProperty('UpgradeChecks.status', 'WARNING')) {
  987. this.set('requestInProgress', false);
  988. var hasFails = data.items.someProperty('UpgradeChecks.status', 'FAIL'),
  989. header = Em.I18n.t('popup.clusterCheck.Upgrade.header').format(params.label),
  990. failTitle = Em.I18n.t('popup.clusterCheck.Upgrade.fail.title'),
  991. failAlert = new Em.Handlebars.SafeString(Em.I18n.t('popup.clusterCheck.Upgrade.fail.alert')),
  992. warningTitle = Em.I18n.t('popup.clusterCheck.Upgrade.warning.title'),
  993. warningAlert = new Em.Handlebars.SafeString(Em.I18n.t('popup.clusterCheck.Upgrade.warning.alert')),
  994. configsMergeWarning = data.items.findProperty('UpgradeChecks.id', 'CONFIG_MERGE'),
  995. popupData = {
  996. items: data.items.rejectProperty('UpgradeChecks.id', 'CONFIG_MERGE')
  997. },
  998. configs = this.getConfigsWarnings(configsMergeWarning);
  999. App.showClusterCheckPopup(popupData, {
  1000. header: header,
  1001. failTitle: failTitle,
  1002. failAlert: failAlert,
  1003. warningTitle: warningTitle,
  1004. warningAlert: warningAlert,
  1005. noCallbackCondition: hasFails,
  1006. callback: function () {
  1007. self.upgrade(params);
  1008. }
  1009. }, configs, params.label);
  1010. } else {
  1011. this.upgrade(params);
  1012. }
  1013. },
  1014. runPreUpgradeCheckError: function() {
  1015. this.set('requestInProgress', false);
  1016. },
  1017. confirmRetryUpgrade: function (version) {
  1018. var self = this;
  1019. return App.showConfirmationPopup(
  1020. function () {
  1021. self.retryUpgrade();
  1022. },
  1023. Em.I18n.t('admin.stackUpgrade.upgrade.retry.confirm.body').format(version.get('displayName')),
  1024. null,
  1025. Em.I18n.t('admin.stackUpgrade.dialog.header').format(version.get('upgradeTypeDislayName'), version.get('displayName'))
  1026. );
  1027. },
  1028. confirmRetryDowngrade: function () {
  1029. var self = this,
  1030. currentVersion = this.get('currentVersion');
  1031. return App.showConfirmationPopup(
  1032. function() {
  1033. self.retryUpgrade();
  1034. },
  1035. Em.I18n.t('admin.stackUpgrade.downgrade.retry.body').format(currentVersion.repository_name),
  1036. null,
  1037. Em.I18n.t('admin.stackUpgrade.dialog.downgrade.header').format(currentVersion.repository_name),
  1038. Em.I18n.t('admin.stackUpgrade.downgrade.proceed')
  1039. );
  1040. },
  1041. /**
  1042. * confirmation popup before install repository version
  1043. */
  1044. installRepoVersionConfirmation: function (repo) {
  1045. var self = this;
  1046. return App.showConfirmationPopup(function () {
  1047. self.installRepoVersion(repo);
  1048. },
  1049. Em.I18n.t('admin.stackVersions.version.install.confirm').format(repo.get('displayName'))
  1050. );
  1051. },
  1052. /**
  1053. * sends request to install repoVersion to the cluster
  1054. * and create clusterStackVersion resourse
  1055. * @param {Em.Object} repo
  1056. * @return {$.ajax}
  1057. * @method installRepoVersion
  1058. */
  1059. installRepoVersion: function (repo) {
  1060. this.set('requestInProgress', true);
  1061. var data = {
  1062. ClusterStackVersions: {
  1063. stack: repo.get('stackVersionType'),
  1064. version: repo.get('stackVersionNumber'),
  1065. repository_version: repo.get('repositoryVersion')
  1066. },
  1067. id: repo.get('id')
  1068. };
  1069. return App.ajax.send({
  1070. name: 'admin.stack_version.install.repo_version',
  1071. sender: this,
  1072. data: data,
  1073. success: 'installRepoVersionSuccess',
  1074. callback: function() {
  1075. this.sender.set('requestInProgress', false);
  1076. }
  1077. });
  1078. },
  1079. /**
  1080. * transform repo data into json for
  1081. * saving changes to repository version
  1082. * @param {Em.Object} repo
  1083. * @returns {{operating_systems: Array}}
  1084. */
  1085. prepareRepoForSaving: function(repo) {
  1086. var repoVersion = { "operating_systems": [] };
  1087. repo.get('operatingSystems').forEach(function (os, k) {
  1088. repoVersion.operating_systems.push({
  1089. "OperatingSystems": {
  1090. "os_type": os.get("osType")
  1091. },
  1092. "repositories": []
  1093. });
  1094. os.get('repositories').forEach(function (repository) {
  1095. repoVersion.operating_systems[k].repositories.push({
  1096. "Repositories": {
  1097. "base_url": repository.get('baseUrl'),
  1098. "repo_id": repository.get('repoId'),
  1099. "repo_name": repository.get('repoName')
  1100. }
  1101. });
  1102. });
  1103. });
  1104. return repoVersion;
  1105. },
  1106. /**
  1107. * Return stack version for the repo object
  1108. * @param {Em.Object} repo
  1109. * */
  1110. getStackVersionNumber: function(repo){
  1111. var stackVersionNumber = repo.get('stackVersion');
  1112. if(null == stackVersionNumber)
  1113. stackVersionNumber = App.get('currentStackVersion');
  1114. return stackVersionNumber;
  1115. },
  1116. /**
  1117. * perform validation if <code>skip<code> is false and run save if
  1118. * validation successfull or run save without validation is <code>skip<code> is true
  1119. * @param {Em.Object} repo
  1120. * @param {boolean} skip
  1121. * @returns {$.Deferred}
  1122. */
  1123. saveRepoOS: function (repo, skip) {
  1124. var self = this;
  1125. var deferred = $.Deferred();
  1126. this.validateRepoVersions(repo, skip).done(function(data) {
  1127. if (data.length > 0) {
  1128. deferred.resolve(data);
  1129. } else {
  1130. var repoVersion = self.prepareRepoForSaving(repo);
  1131. var stackVersionNumber = self.getStackVersionNumber(repo);
  1132. App.ajax.send({
  1133. name: 'admin.stack_versions.edit.repo',
  1134. sender: this,
  1135. data: {
  1136. stackName: App.get('currentStackName'),
  1137. stackVersion: stackVersionNumber,
  1138. repoVersionId: repo.get('repoVersionId'),
  1139. repoVersion: repoVersion
  1140. }
  1141. }).success(function() {
  1142. deferred.resolve([]);
  1143. });
  1144. }
  1145. });
  1146. return deferred.promise();
  1147. },
  1148. /**
  1149. * send request for validation for each repository
  1150. * @param {Em.Object} repo
  1151. * @param {boolean} skip
  1152. * @returns {*}
  1153. */
  1154. validateRepoVersions: function(repo, skip) {
  1155. var deferred = $.Deferred(),
  1156. totalCalls = 0,
  1157. invalidUrls = [];
  1158. if (skip) {
  1159. deferred.resolve(invalidUrls);
  1160. } else {
  1161. var stackVersionNumber = this.getStackVersionNumber(repo);
  1162. repo.get('operatingSystems').forEach(function (os) {
  1163. if (os.get('isSelected')) {
  1164. os.get('repositories').forEach(function (repo) {
  1165. totalCalls++;
  1166. App.ajax.send({
  1167. name: 'admin.stack_versions.validate.repo',
  1168. sender: this,
  1169. data: {
  1170. repo: repo,
  1171. repoId: repo.get('repoId'),
  1172. baseUrl: repo.get('baseUrl'),
  1173. osType: os.get('osType'),
  1174. stackName: App.get('currentStackName'),
  1175. stackVersion: stackVersionNumber
  1176. }
  1177. })
  1178. .success(function () {
  1179. totalCalls--;
  1180. if (totalCalls === 0) deferred.resolve(invalidUrls);
  1181. })
  1182. .error(function () {
  1183. repo.set('hasError', true);
  1184. invalidUrls.push(repo);
  1185. totalCalls--;
  1186. if (totalCalls === 0) deferred.resolve(invalidUrls);
  1187. });
  1188. });
  1189. } else {
  1190. return deferred.resolve(invalidUrls);
  1191. }
  1192. });
  1193. }
  1194. return deferred.promise();
  1195. },
  1196. /**
  1197. * success callback for <code>installRepoVersion()<code>
  1198. * saves request id to the db
  1199. * @param data
  1200. * @param opt
  1201. * @param params
  1202. * @method installStackVersionSuccess
  1203. */
  1204. installRepoVersionSuccess: function (data, opt, params) {
  1205. var version = App.RepositoryVersion.find(params.id);
  1206. App.db.set('repoVersionInstall', 'id', [data.Requests.id]);
  1207. App.clusterStatus.setClusterStatus({
  1208. wizardControllerName: this.get('name'),
  1209. localdb: App.db.data
  1210. });
  1211. version.set('defaultStatus', 'INSTALLING');
  1212. if (version.get('stackVersion')) {
  1213. version.set('stackVersion.state', 'INSTALLING');
  1214. }
  1215. },
  1216. /**
  1217. * opens a popup with installations state per host
  1218. * @param {Em.Object} version
  1219. * @method showProgressPopup
  1220. */
  1221. showProgressPopup: function(version) {
  1222. var popupTitle = Em.I18n.t('admin.stackVersions.details.install.hosts.popup.title').format(version.get('displayName'));
  1223. var requestIds = App.get('testMode') ? [1] : App.db.get('repoVersionInstall', 'id');
  1224. var hostProgressPopupController = App.router.get('highAvailabilityProgressPopupController');
  1225. hostProgressPopupController.initPopup(popupTitle, requestIds, this);
  1226. },
  1227. /**
  1228. * reset upgradeState to INIT when upgrade is COMPLETED
  1229. * and clean auxiliary data
  1230. */
  1231. finish: function () {
  1232. if (App.get('upgradeState') === 'COMPLETED') {
  1233. var upgradeVersion = this.get('upgradeVersion') && this.get('upgradeVersion').match(/[a-zA-Z]+\-\d+\.\d+/);
  1234. this.setDBProperties({
  1235. upgradeId: undefined,
  1236. upgradeState: 'INIT',
  1237. upgradeVersion: undefined,
  1238. currentVersion: undefined,
  1239. upgradeTypeDisplayName: undefined,
  1240. upgradeType: undefined,
  1241. failuresTolerance: undefined,
  1242. isDowngrade: undefined,
  1243. downgradeAllowed: undefined
  1244. });
  1245. App.clusterStatus.setClusterStatus({
  1246. localdb: App.db.data
  1247. });
  1248. if (upgradeVersion && upgradeVersion[0]) {
  1249. App.set('currentStackVersion', upgradeVersion[0]);
  1250. }
  1251. App.set('upgradeState', 'INIT');
  1252. }
  1253. }.observes('App.upgradeState'),
  1254. /**
  1255. * Check <code>App.upgradeState</code> for HOLDING
  1256. * If it is, send request to check if current item is Finalize
  1257. * @method updateFinalize
  1258. */
  1259. updateFinalize: function () {
  1260. var upgradeState = App.get('upgradeState');
  1261. if (upgradeState === 'HOLDING') {
  1262. return App.ajax.send({
  1263. name: 'admin.upgrade.finalizeContext',
  1264. sender: this,
  1265. success: 'updateFinalizeSuccessCallback',
  1266. error: 'updateFinalizeErrorCallback'
  1267. })
  1268. }
  1269. else {
  1270. this.set('isFinalizeItem', false);
  1271. }
  1272. }.observes('App.upgradeState'),
  1273. /**
  1274. *
  1275. * @param {object|null} data
  1276. * @method updateFinalizeSuccessCallback
  1277. */
  1278. updateFinalizeSuccessCallback: function (data) {
  1279. var context = data ? Em.get(data, 'items.firstObject.upgrade_groups.firstObject.upgrade_items.firstObject.UpgradeItem.context') : '';
  1280. this.set('isFinalizeItem', context === this.get('finalizeContext'));
  1281. },
  1282. updateFinalizeErrorCallback: function() {
  1283. this.set('isFinalizeItem', false);
  1284. },
  1285. /**
  1286. * show dialog with tasks of upgrade
  1287. * @return {App.ModalPopup}
  1288. */
  1289. openUpgradeDialog: function () {
  1290. App.router.transitionTo('admin.stackUpgrade');
  1291. },
  1292. /**
  1293. * returns url to get data for repoVersion or clusterStackVersion
  1294. * @param {Boolean} stack true if load clusterStackVersion
  1295. * @param {Boolean} fullLoad true if load all data
  1296. * @returns {String}
  1297. * @method getUrl
  1298. */
  1299. getUrl: function(stack, fullLoad) {
  1300. if (App.get('testMode')) {
  1301. return stack ? this.get('mockStackUrl') : this.get('mockRepoUrl')
  1302. } else {
  1303. if (fullLoad) {
  1304. return stack ? this.get('realStackUrl') : this.get('realRepoUrl');
  1305. } else {
  1306. return this.get('realUpdateUrl');
  1307. }
  1308. }
  1309. },
  1310. /**
  1311. * get stack versions from server and push it to model
  1312. * @return {*}
  1313. * @method loadStackVersionsToModel
  1314. */
  1315. loadStackVersionsToModel: function (fullLoad) {
  1316. var dfd = $.Deferred();
  1317. App.HttpClient.get(this.getUrl(true, fullLoad), App.stackVersionMapper, {
  1318. complete: function () {
  1319. dfd.resolve();
  1320. }
  1321. });
  1322. return dfd.promise();
  1323. },
  1324. /**
  1325. * get repo versions from server and push it to model
  1326. * @return {*}
  1327. * @params {Boolean} isUpdate - if true loads part of data that need to be updated
  1328. * @method loadRepoVersionsToModel()
  1329. */
  1330. loadRepoVersionsToModel: function () {
  1331. var dfd = $.Deferred();
  1332. App.HttpClient.get(this.getUrl(false, true), App.repoVersionMapper, {
  1333. complete: function () {
  1334. dfd.resolve();
  1335. }
  1336. });
  1337. return dfd.promise();
  1338. },
  1339. /**
  1340. * set status to Upgrade item
  1341. * @param item
  1342. * @param status
  1343. */
  1344. setUpgradeItemStatus: function(item, status) {
  1345. this.set('requestInProgress', true);
  1346. return App.ajax.send({
  1347. name: 'admin.upgrade.upgradeItem.setState',
  1348. sender: this,
  1349. data: {
  1350. upgradeId: item.get('request_id'),
  1351. itemId: item.get('stage_id'),
  1352. groupId: item.get('group_id'),
  1353. status: status
  1354. },
  1355. callback: function() {
  1356. this.sender.set('requestInProgress', false);
  1357. }
  1358. }).done(function () {
  1359. item.set('status', status);
  1360. });
  1361. },
  1362. currentVersionObserver: function () {
  1363. var versionNumber = this.get('currentVersion.repository_version');
  1364. var currentVersionObject = App.RepositoryVersion.find().findProperty('status', 'CURRENT');
  1365. var versionName = currentVersionObject && currentVersionObject.get('stackVersionType');
  1366. App.set('isStormMetricsSupported', versionName != 'HDP' || stringUtils.compareVersions(versionNumber, '2.2.2') > -1 || !versionNumber);
  1367. }.observes('currentVersion.repository_version'),
  1368. /**
  1369. * get the installed repositories of HDP from server
  1370. */
  1371. loadRepositories: function () {
  1372. if (App.router.get('clusterController.isLoaded')) {
  1373. var nameVersionCombo = App.get('currentStackVersion');
  1374. var stackName = nameVersionCombo.split('-')[0];
  1375. var stackVersion = nameVersionCombo.split('-')[1];
  1376. App.ajax.send({
  1377. name: 'cluster.load_repositories',
  1378. sender: this,
  1379. data: {
  1380. stackName: stackName,
  1381. stackVersion: stackVersion
  1382. },
  1383. success: 'loadRepositoriesSuccessCallback',
  1384. error: 'loadRepositoriesErrorCallback'
  1385. });
  1386. }
  1387. }.observes('App.router.clusterController.isLoaded'),
  1388. loadRepositoriesSuccessCallback: function (data) {
  1389. var allRepos = [];
  1390. data.items.forEach(function (os) {
  1391. os.repositories.forEach(function (repository) {
  1392. var osType = repository.Repositories.os_type;
  1393. var repo = Em.Object.create({
  1394. baseUrl: repository.Repositories.base_url,
  1395. osType: osType,
  1396. repoId: repository.Repositories.repo_id,
  1397. repoName : repository.Repositories.repo_name,
  1398. stackName : repository.Repositories.stack_name,
  1399. stackVersion : repository.Repositories.stack_version,
  1400. isFirst: false
  1401. });
  1402. var group = allRepos.findProperty('name', osType);
  1403. if (!group) {
  1404. group = {
  1405. name: osType,
  1406. repositories: []
  1407. };
  1408. repo.set('isFirst', true);
  1409. allRepos.push(group);
  1410. }
  1411. group.repositories.push(repo);
  1412. });
  1413. }, this);
  1414. allRepos.stackVersion = App.get('currentStackVersionNumber');
  1415. this.set('allRepos', allRepos);
  1416. },
  1417. loadRepositoriesErrorCallback: function (request, ajaxOptions, error) {
  1418. },
  1419. /**
  1420. * @returns {$.ajax}
  1421. */
  1422. suspendUpgrade: function () {
  1423. var self = this;
  1424. return this.abortUpgrade().done(function () {
  1425. App.set('upgradeState', 'ABORTED');
  1426. self.setDBProperty('upgradeState', 'ABORTED');
  1427. App.clusterStatus.setClusterStatus({
  1428. wizardControllerName: self.get('name'),
  1429. localdb: App.db.data
  1430. });
  1431. });
  1432. },
  1433. /**
  1434. * @returns {$.ajax}
  1435. */
  1436. resumeUpgrade: function() {
  1437. var self = this;
  1438. this.retryUpgrade().done(function () {
  1439. App.set('upgradeState', 'PENDING');
  1440. App.propertyDidChange('upgradeAborted');
  1441. self.setDBProperty('upgradeState', 'PENDING');
  1442. App.clusterStatus.setClusterStatus({
  1443. wizardControllerName: self.get('name'),
  1444. localdb: App.db.data
  1445. });
  1446. });
  1447. },
  1448. /**
  1449. * restore last Upgrade data
  1450. * @param {object} lastUpgradeData
  1451. */
  1452. restoreLastUpgrade: function(lastUpgradeData) {
  1453. var self = this;
  1454. var upgradeType = this.get('upgradeMethods').findProperty('type', lastUpgradeData.Upgrade.upgrade_type);
  1455. this.setDBProperties({
  1456. upgradeId: lastUpgradeData.Upgrade.request_id,
  1457. isDowngrade: lastUpgradeData.Upgrade.direction === 'DOWNGRADE',
  1458. upgradeState: lastUpgradeData.Upgrade.request_status,
  1459. upgradeType: lastUpgradeData.Upgrade.upgrade_type,
  1460. downgradeAllowed: lastUpgradeData.Upgrade.downgrade_allowed,
  1461. upgradeTypeDisplayName: upgradeType.get('displayName'),
  1462. failuresTolerance: Em.Object.create({
  1463. skipComponentFailures: lastUpgradeData.Upgrade.skip_failures,
  1464. skipSCFailures: lastUpgradeData.Upgrade.skip_service_check_failures
  1465. })
  1466. });
  1467. this.loadRepoVersionsToModel().done(function () {
  1468. var toVersion = App.RepositoryVersion.find().findProperty('repositoryVersion', lastUpgradeData.Upgrade.to_version);
  1469. self.setDBProperty('upgradeVersion', toVersion && toVersion.get('displayName'));
  1470. self.initDBProperties();
  1471. self.loadUpgradeData(true);
  1472. });
  1473. },
  1474. /**
  1475. * Build table from configs list and open new window to show this table
  1476. * @param configs
  1477. */
  1478. openConfigsInNewWindow: function (configs) {
  1479. var newWindow;
  1480. var output = '';
  1481. output += '<table style="text-align: left;"><thead><tr>' +
  1482. '<th>' + Em.I18n.t('popup.clusterCheck.Upgrade.configsMerge.configType') + '</th>' +
  1483. '<th>' + Em.I18n.t('popup.clusterCheck.Upgrade.configsMerge.propertyName') + '</th>' +
  1484. '<th>' + Em.I18n.t('popup.clusterCheck.Upgrade.configsMerge.currentValue') + '</th>' +
  1485. '<th>' + Em.I18n.t('popup.clusterCheck.Upgrade.configsMerge.recommendedValue') + '</th>' +
  1486. '<th>' + Em.I18n.t('popup.clusterCheck.Upgrade.configsMerge.resultingValue') + '</th>' +
  1487. '</tr></thead><tbody>';
  1488. configs.context.forEach(function (config) {
  1489. output += '<tr>' +
  1490. '<td>' + config.type + '</td>' +
  1491. '<td>' + config.name + '</td>' +
  1492. '<td>' + config.currentValue + '</td>' +
  1493. '<td>' + config.recommendedValue + '</td>' +
  1494. '<td>' + config.resultingValue + '</td>' +
  1495. '</tr>';
  1496. });
  1497. output += '</tbody></table>';
  1498. newWindow = window.open();
  1499. newWindow.document.write(output);
  1500. newWindow.focus();
  1501. }
  1502. });