stack_and_upgrade_controller.js 53 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293129412951296129712981299130013011302130313041305130613071308130913101311131213131314131513161317131813191320132113221323132413251326132713281329133013311332133313341335133613371338133913401341134213431344134513461347134813491350135113521353135413551356135713581359136013611362136313641365136613671368136913701371137213731374137513761377137813791380138113821383138413851386138713881389139013911392139313941395139613971398139914001401140214031404140514061407140814091410141114121413141414151416141714181419142014211422142314241425142614271428142914301431143214331434143514361437143814391440144114421443144414451446144714481449145014511452145314541455145614571458145914601461146214631464146514661467146814691470147114721473147414751476147714781479148014811482148314841485148614871488148914901491149214931494149514961497149814991500150115021503150415051506150715081509151015111512151315141515151615171518151915201521152215231524152515261527152815291530153115321533153415351536153715381539154015411542154315441545154615471548154915501551155215531554155515561557155815591560156115621563156415651566156715681569157015711572157315741575157615771578157915801581158215831584158515861587158815891590159115921593159415951596159715981599160016011602160316041605160616071608160916101611161216131614161516161617
  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. }).fail(function () {
  1432. return App.showAlertPopup(Em.I18n.t('admin.stackUpgrade.state.paused.fail.header'), Em.I18n.t('admin.stackUpgrade.state.paused.fail.body'));
  1433. });
  1434. },
  1435. /**
  1436. * @returns {$.ajax}
  1437. */
  1438. resumeUpgrade: function() {
  1439. var self = this;
  1440. this.retryUpgrade().done(function () {
  1441. App.set('upgradeState', 'PENDING');
  1442. App.propertyDidChange('upgradeAborted');
  1443. self.setDBProperty('upgradeState', 'PENDING');
  1444. App.clusterStatus.setClusterStatus({
  1445. wizardControllerName: self.get('name'),
  1446. localdb: App.db.data
  1447. });
  1448. });
  1449. },
  1450. /**
  1451. * restore last Upgrade data
  1452. * @param {object} lastUpgradeData
  1453. */
  1454. restoreLastUpgrade: function(lastUpgradeData) {
  1455. var self = this;
  1456. var upgradeType = this.get('upgradeMethods').findProperty('type', lastUpgradeData.Upgrade.upgrade_type);
  1457. this.setDBProperties({
  1458. upgradeId: lastUpgradeData.Upgrade.request_id,
  1459. isDowngrade: lastUpgradeData.Upgrade.direction === 'DOWNGRADE',
  1460. upgradeState: lastUpgradeData.Upgrade.request_status,
  1461. upgradeType: lastUpgradeData.Upgrade.upgrade_type,
  1462. downgradeAllowed: lastUpgradeData.Upgrade.downgrade_allowed,
  1463. upgradeTypeDisplayName: upgradeType.get('displayName'),
  1464. failuresTolerance: Em.Object.create({
  1465. skipComponentFailures: lastUpgradeData.Upgrade.skip_failures,
  1466. skipSCFailures: lastUpgradeData.Upgrade.skip_service_check_failures
  1467. })
  1468. });
  1469. this.loadRepoVersionsToModel().done(function () {
  1470. var toVersion = App.RepositoryVersion.find().findProperty('repositoryVersion', lastUpgradeData.Upgrade.to_version);
  1471. self.setDBProperty('upgradeVersion', toVersion && toVersion.get('displayName'));
  1472. self.initDBProperties();
  1473. self.loadUpgradeData(true);
  1474. });
  1475. },
  1476. /**
  1477. * Build table from configs list and open new window to show this table
  1478. * @param configs
  1479. */
  1480. openConfigsInNewWindow: function (configs) {
  1481. var newWindow;
  1482. var output = '';
  1483. output += '<table style="text-align: left;"><thead><tr>' +
  1484. '<th>' + Em.I18n.t('popup.clusterCheck.Upgrade.configsMerge.configType') + '</th>' +
  1485. '<th>' + Em.I18n.t('popup.clusterCheck.Upgrade.configsMerge.propertyName') + '</th>' +
  1486. '<th>' + Em.I18n.t('popup.clusterCheck.Upgrade.configsMerge.currentValue') + '</th>' +
  1487. '<th>' + Em.I18n.t('popup.clusterCheck.Upgrade.configsMerge.recommendedValue') + '</th>' +
  1488. '<th>' + Em.I18n.t('popup.clusterCheck.Upgrade.configsMerge.resultingValue') + '</th>' +
  1489. '</tr></thead><tbody>';
  1490. configs.context.forEach(function (config) {
  1491. output += '<tr>' +
  1492. '<td>' + config.type + '</td>' +
  1493. '<td>' + config.name + '</td>' +
  1494. '<td>' + config.currentValue + '</td>' +
  1495. '<td>' + config.recommendedValue + '</td>' +
  1496. '<td>' + config.resultingValue + '</td>' +
  1497. '</tr>';
  1498. });
  1499. output += '</tbody></table>';
  1500. newWindow = window.open();
  1501. newWindow.document.write(output);
  1502. newWindow.focus();
  1503. }
  1504. });