stack_and_upgrade_controller.js 58 KB

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