stack_and_upgrade_controller.js 25 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835
  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 {boolean}
  43. * @default false
  44. */
  45. isDowngrade: false,
  46. /**
  47. * version that currently applied to server
  48. * should be plain object, because stored to localStorage
  49. * @type {object|null}
  50. */
  51. currentVersion: null,
  52. /**
  53. * versions to which cluster could be upgraded
  54. * @type {Array}
  55. */
  56. targetVersions: [],
  57. /**
  58. * @type {boolean} true if some request that should disable actions is in progress
  59. */
  60. requestInProgress: false,
  61. /**
  62. * properties that stored to localStorage to resume wizard progress
  63. */
  64. wizardStorageProperties: ['upgradeId', 'upgradeVersion', 'currentVersion', 'isDowngrade'],
  65. /**
  66. * mutable properties of Upgrade Task
  67. * @type {Array}
  68. */
  69. taskDetailsProperties: ['status', 'stdout', 'stderr', 'error_log', 'host_name', 'output_log'],
  70. /**
  71. * path to the mock json
  72. * @type {String}
  73. */
  74. mockRepoUrl: '/data/stack_versions/repo_versions_all.json',
  75. /**
  76. * api to get RepoVersions
  77. * @type {String}
  78. */
  79. realRepoUrl: function () {
  80. return App.get('apiPrefix') + App.get('stackVersionURL') +
  81. '/compatible_repository_versions?fields=*,operating_systems/*,operating_systems/repositories/*';
  82. }.property('App.stackVersionURL'),
  83. /**
  84. * path to the mock json
  85. * @type {String}
  86. */
  87. mockStackUrl: '/data/stack_versions/stack_version_all.json',
  88. /**
  89. * api to get ClusterStackVersions with repository_versions (use to init data load)
  90. * @type {String}
  91. */
  92. realStackUrl: function () {
  93. return App.get('apiPrefix') + '/clusters/' + App.get('clusterName') +
  94. '/stack_versions?fields=*,repository_versions/*,repository_versions/operating_systems/repositories/*';
  95. }.property('App.clusterName'),
  96. /**
  97. * api to get ClusterStackVersions without repository_versions (use to update data)
  98. * @type {String}
  99. */
  100. realUpdateUrl: function () {
  101. return App.get('apiPrefix') + '/clusters/' + App.get('clusterName') + '/stack_versions?fields=ClusterStackVersions/*';
  102. }.property('App.clusterName'),
  103. /**
  104. * Determines if list of services with checks that failed and were skipped by user during the upgrade is loaded
  105. * @type {boolean}
  106. */
  107. areSkippedServiceChecksLoaded: false,
  108. /**
  109. * List of services with checks that failed and were skipped by user during the upgrade
  110. * @type {array}
  111. */
  112. skippedServiceChecks: [],
  113. init: function () {
  114. this.initDBProperties();
  115. },
  116. /**
  117. * restore data from localStorage
  118. */
  119. initDBProperties: function () {
  120. this.get('wizardStorageProperties').forEach(function (property) {
  121. if (this.getDBProperty(property)) {
  122. this.set(property, this.getDBProperty(property));
  123. }
  124. }, this);
  125. },
  126. /**
  127. * load all data:
  128. * - upgrade data
  129. * - stack versions
  130. * - repo versions
  131. */
  132. load: function () {
  133. var dfd = $.Deferred();
  134. var self = this;
  135. this.loadUpgradeData(true).done(function() {
  136. self.loadStackVersionsToModel(true).done(function () {
  137. self.loadRepoVersionsToModel().done(function() {
  138. var currentVersion = App.StackVersion.find().findProperty('state', 'CURRENT');
  139. if (currentVersion) {
  140. self.set('currentVersion', {
  141. repository_version: currentVersion.get('repositoryVersion.repositoryVersion'),
  142. repository_name: currentVersion.get('repositoryVersion.displayName')
  143. });
  144. }
  145. dfd.resolve();
  146. });
  147. });
  148. });
  149. return dfd.promise();
  150. },
  151. /**
  152. * load upgrade tasks by upgrade id
  153. * @return {$.Deferred}
  154. * @param {boolean} onlyState
  155. */
  156. loadUpgradeData: function (onlyState) {
  157. var upgradeId = this.get('upgradeId');
  158. var deferred = $.Deferred();
  159. if (Em.isNone(upgradeId)) {
  160. deferred.resolve();
  161. console.log('Upgrade in INIT state');
  162. } else {
  163. App.ajax.send({
  164. name: (onlyState) ? 'admin.upgrade.state' : 'admin.upgrade.data',
  165. sender: this,
  166. data: {
  167. id: upgradeId
  168. },
  169. success: 'loadUpgradeDataSuccessCallback'
  170. }).then(deferred.resolve);
  171. }
  172. return deferred.promise();
  173. },
  174. /**
  175. * parse and push upgrade tasks to controller
  176. * @param data
  177. */
  178. loadUpgradeDataSuccessCallback: function (data) {
  179. if (Em.isNone(data)) return;
  180. App.set('upgradeState', data.Upgrade.request_status);
  181. this.setDBProperty('upgradeState', data.Upgrade.request_status);
  182. if (data.upgrade_groups) {
  183. this.updateUpgradeData(data);
  184. }
  185. },
  186. /**
  187. * update data of Upgrade
  188. * @param {object} newData
  189. */
  190. updateUpgradeData: function (newData) {
  191. var oldData = this.get('upgradeData'),
  192. groupsMap = {},
  193. itemsMap = {};
  194. if (Em.isNone(oldData) || (newData.upgrade_groups.length !== oldData.upgradeGroups.length)) {
  195. this.initUpgradeData(newData);
  196. } else {
  197. //create entities maps
  198. newData.upgrade_groups.forEach(function (newGroup) {
  199. groupsMap[newGroup.UpgradeGroup.group_id] = newGroup.UpgradeGroup;
  200. newGroup.upgrade_items.forEach(function (item) {
  201. itemsMap[item.UpgradeItem.stage_id] = item.UpgradeItem;
  202. })
  203. });
  204. //update existed entities with new data
  205. oldData.upgradeGroups.forEach(function (oldGroup) {
  206. oldGroup.set('status', groupsMap[oldGroup.get('group_id')].status);
  207. oldGroup.set('progress_percent', groupsMap[oldGroup.get('group_id')].progress_percent);
  208. oldGroup.set('completed_task_count', groupsMap[oldGroup.get('group_id')].completed_task_count);
  209. oldGroup.upgradeItems.forEach(function (item) {
  210. item.set('status', itemsMap[item.get('stage_id')].status);
  211. item.set('progress_percent', itemsMap[item.get('stage_id')].progress_percent);
  212. })
  213. });
  214. oldData.set('Upgrade', newData.Upgrade);
  215. }
  216. },
  217. /**
  218. * change structure of Upgrade
  219. * In order to maintain nested views in template object should have direct link to its properties, for example
  220. * item.UpgradeItem.<properties> -> item.<properties>
  221. * @param {object} newData
  222. */
  223. initUpgradeData: function (newData) {
  224. var upgradeGroups = [];
  225. //wrap all entities into App.upgradeEntity
  226. newData.upgrade_groups.forEach(function (newGroup) {
  227. var oldGroup = App.upgradeEntity.create({type: 'GROUP'}, newGroup.UpgradeGroup);
  228. var upgradeItems = [];
  229. newGroup.upgrade_items.forEach(function (item) {
  230. var oldItem = App.upgradeEntity.create({type: 'ITEM'}, item.UpgradeItem);
  231. oldItem.set('tasks', []);
  232. upgradeItems.pushObject(oldItem);
  233. });
  234. upgradeItems.reverse();
  235. oldGroup.set('upgradeItems', upgradeItems);
  236. upgradeGroups.pushObject(oldGroup);
  237. });
  238. upgradeGroups.reverse();
  239. this.set('upgradeData', Em.Object.create({
  240. upgradeGroups: upgradeGroups,
  241. Upgrade: newData.Upgrade
  242. }));
  243. },
  244. /**
  245. * request Upgrade Item and its tasks from server
  246. * @return {$.ajax}
  247. */
  248. getUpgradeItem: function (item) {
  249. return App.ajax.send({
  250. name: 'admin.upgrade.upgrade_item',
  251. sender: this,
  252. data: {
  253. upgradeId: item.get('request_id'),
  254. groupId: item.get('group_id'),
  255. stageId: item.get('stage_id')
  256. },
  257. success: 'getUpgradeItemSuccessCallback'
  258. });
  259. },
  260. /**
  261. * success callback of <code>getTasks</code>
  262. * @param {object} data
  263. */
  264. getUpgradeItemSuccessCallback: function (data) {
  265. this.get('upgradeData.upgradeGroups').forEach(function (group) {
  266. if (group.get('group_id') === data.UpgradeItem.group_id) {
  267. group.get('upgradeItems').forEach(function (item) {
  268. if (item.get('stage_id') === data.UpgradeItem.stage_id) {
  269. if (item.get('tasks.length')) {
  270. item.set('isTasksLoaded', true);
  271. data.tasks.forEach(function (task) {
  272. var currentTask = item.get('tasks').findProperty('id', task.Tasks.id);
  273. this.get('taskDetailsProperties').forEach(function (property) {
  274. currentTask.set(property, task.Tasks[property]);
  275. }, this);
  276. }, this);
  277. } else {
  278. var tasks = [];
  279. data.tasks.forEach(function (task) {
  280. tasks.pushObject(App.upgradeEntity.create({type: 'TASK'}, task.Tasks));
  281. });
  282. item.set('tasks', tasks);
  283. }
  284. item.set('isTasksLoaded', true);
  285. }
  286. }, this);
  287. }
  288. }, this);
  289. },
  290. /**
  291. * downgrade confirmation popup
  292. * @param {object} event
  293. */
  294. confirmDowngrade: function (event) {
  295. var self = this;
  296. var currentVersion = this.get('currentVersion');
  297. return App.showConfirmationPopup(
  298. function() {
  299. self.downgrade.call(self, currentVersion, event);
  300. },
  301. Em.I18n.t('admin.stackUpgrade.downgrade.body').format(currentVersion.repository_name),
  302. null,
  303. Em.I18n.t('admin.stackUpgrade.dialog.downgrade.header').format(currentVersion.repository_name),
  304. Em.I18n.t('admin.stackUpgrade.downgrade.proceed')
  305. );
  306. },
  307. /**
  308. * make call to start downgrade process
  309. * @param {object} currentVersion
  310. * @param {object} event
  311. */
  312. downgrade: function (currentVersion, event) {
  313. this.set('requestInProgress', true);
  314. this.abortUpgrade();
  315. App.ajax.send({
  316. name: 'admin.downgrade.start',
  317. sender: this,
  318. data: {
  319. value: currentVersion.repository_version,
  320. label: currentVersion.repository_name,
  321. isDowngrade: true
  322. },
  323. success: 'upgradeSuccessCallback',
  324. callback: function() {
  325. this.sender.set('requestInProgress', false);
  326. }
  327. });
  328. },
  329. /**
  330. * abort upgrade (in order to start Downgrade)
  331. */
  332. abortUpgrade: function () {
  333. return App.ajax.send({
  334. name: 'admin.upgrade.abort',
  335. sender: this,
  336. data: {
  337. upgradeId: this.get('upgradeId')
  338. }
  339. });
  340. },
  341. /**
  342. * make call to start upgrade process and show popup with current progress
  343. * @param {object} version
  344. */
  345. upgrade: function (version) {
  346. this.set('requestInProgress', true);
  347. App.ajax.send({
  348. name: 'admin.upgrade.start',
  349. sender: this,
  350. data: version,
  351. success: 'upgradeSuccessCallback',
  352. callback: function() {
  353. this.sender.set('requestInProgress', false);
  354. }
  355. });
  356. this.setDBProperty('currentVersion', this.get('currentVersion'));
  357. },
  358. /**
  359. * success callback of <code>upgrade()</code>
  360. * @param {object} data
  361. */
  362. upgradeSuccessCallback: function (data, opt, params) {
  363. this.set('upgradeData', null);
  364. this.set('upgradeId', data.resources[0].Upgrade.request_id);
  365. this.set('upgradeVersion', params.label);
  366. this.set('isDowngrade', !!params.isDowngrade);
  367. this.setDBProperty('upgradeVersion', params.label);
  368. this.setDBProperty('upgradeId', data.resources[0].Upgrade.request_id);
  369. this.setDBProperty('upgradeState', 'PENDING');
  370. this.setDBProperty('isDowngrade', !!params.isDowngrade);
  371. App.set('upgradeState', 'PENDING');
  372. App.clusterStatus.setClusterStatus({
  373. wizardControllerName: this.get('name'),
  374. localdb: App.db.data
  375. });
  376. this.load();
  377. this.openUpgradeDialog();
  378. },
  379. /**
  380. * upgrade confirmation popup
  381. * @param {object} version
  382. * @return App.ModalPopup
  383. */
  384. confirmUpgrade: function (version) {
  385. var self = this;
  386. return App.showConfirmationPopup(
  387. function () {
  388. self.runPreUpgradeCheck.call(self, version);
  389. },
  390. Em.I18n.t('admin.stackUpgrade.upgrade.confirm.body').format(version.get('displayName')),
  391. null,
  392. Em.I18n.t('admin.stackUpgrade.dialog.header').format(version.get('displayName'))
  393. );
  394. },
  395. /**
  396. * send request for pre upgrade check
  397. * @param version
  398. */
  399. runPreUpgradeCheck: function(version) {
  400. var params = {
  401. value: version.get('repositoryVersion'),
  402. label: version.get('displayName')
  403. };
  404. if (App.get('supports.preUpgradeCheck')) {
  405. this.set('requestInProgress', true);
  406. App.ajax.send({
  407. name: "admin.rolling_upgrade.pre_upgrade_check",
  408. sender: this,
  409. data: params,
  410. success: "runPreUpgradeCheckSuccess",
  411. error: "runPreUpgradeCheckError"
  412. });
  413. } else {
  414. this.upgrade(params);
  415. }
  416. },
  417. /**
  418. * success callback of <code>runPreUpgradeCheckSuccess()</code>
  419. * if there are some fails - it shows popup else run upgrade
  420. * @param data {object}
  421. * @param opt {object}
  422. * @param params {object}
  423. * @returns {App.ModalPopup|undefined}
  424. */
  425. runPreUpgradeCheckSuccess: function (data, opt, params) {
  426. if (data.items.someProperty('UpgradeChecks.status', "FAIL")) {
  427. this.set('requestInProgress', false);
  428. var header = Em.I18n.t('popup.clusterCheck.Upgrade.header').format(params.label);
  429. var title = Em.I18n.t('popup.clusterCheck.Upgrade.title');
  430. var alert = Em.I18n.t('popup.clusterCheck.Upgrade.alert');
  431. App.showClusterCheckPopup(data, header, title, alert);
  432. } else if (data.items.someProperty('UpgradeChecks.id', "CONFIG_MERGE") && Em.get(data.items.findProperty('UpgradeChecks.id', "CONFIG_MERGE"), 'UpgradeChecks.status') == 'WARNING') {
  433. var self = this,
  434. configsMergeCheckData = Em.get(data.items.findProperty('UpgradeChecks.id', "CONFIG_MERGE"), 'UpgradeChecks.failed_detail');
  435. this.set('requestInProgress', false);
  436. App.showUpgradeConfigsMergePopup(configsMergeCheckData, params.label, function () {
  437. self.upgrade(params);
  438. });
  439. } else {
  440. this.upgrade(params);
  441. }
  442. },
  443. runPreUpgradeCheckError: function() {
  444. this.set('requestInProgress', false);
  445. },
  446. /**
  447. * confirmation popup before install repository version
  448. */
  449. installRepoVersionConfirmation: function (repo) {
  450. var self = this;
  451. return App.showConfirmationPopup(function () {
  452. self.installRepoVersion(repo);
  453. },
  454. Em.I18n.t('admin.stackVersions.version.install.confirm').format(repo.get('displayName'))
  455. );
  456. },
  457. /**
  458. * sends request to install repoVersion to the cluster
  459. * and create clusterStackVersion resourse
  460. * @param {Em.Object} repo
  461. * @return {$.ajax}
  462. * @method installRepoVersion
  463. */
  464. installRepoVersion: function (repo) {
  465. this.set('requestInProgress', true);
  466. var data = {
  467. ClusterStackVersions: {
  468. stack: repo.get('stackVersionType'),
  469. version: repo.get('stackVersionNumber'),
  470. repository_version: repo.get('repositoryVersion')
  471. },
  472. id: repo.get('id')
  473. };
  474. return App.ajax.send({
  475. name: 'admin.stack_version.install.repo_version',
  476. sender: this,
  477. data: data,
  478. success: 'installRepoVersionSuccess',
  479. callback: function() {
  480. this.sender.set('requestInProgress', false);
  481. }
  482. });
  483. },
  484. /**
  485. * transform repo data into json for
  486. * saving changes to repository version
  487. * @param {Em.Object} repo
  488. * @returns {{operating_systems: Array}}
  489. */
  490. prepareRepoForSaving: function(repo) {
  491. var repoVersion = { "operating_systems": [] };
  492. repo.get('operatingSystems').forEach(function (os, k) {
  493. repoVersion.operating_systems.push({
  494. "OperatingSystems": {
  495. "os_type": os.get("osType")
  496. },
  497. "repositories": []
  498. });
  499. os.get('repositories').forEach(function (repository) {
  500. repoVersion.operating_systems[k].repositories.push({
  501. "Repositories": {
  502. "base_url": repository.get('baseUrl'),
  503. "repo_id": repository.get('repoId'),
  504. "repo_name": repository.get('repoName')
  505. }
  506. });
  507. });
  508. });
  509. return repoVersion;
  510. },
  511. /**
  512. * perform validation if <code>skip<code> is false and run save if
  513. * validation successfull or run save without validation is <code>skip<code> is true
  514. * @param {Em.Object} repo
  515. * @param {boolean} skip
  516. * @returns {$.Deferred}
  517. */
  518. saveRepoOS: function (repo, skip) {
  519. var self = this;
  520. var deferred = $.Deferred();
  521. this.validateRepoVersions(repo, skip).done(function(data) {
  522. if (data.length > 0) {
  523. deferred.resolve(data);
  524. } else {
  525. var repoVersion = self.prepareRepoForSaving(repo);
  526. App.ajax.send({
  527. name: 'admin.stack_versions.edit.repo',
  528. sender: this,
  529. data: {
  530. stackName: App.get('currentStackName'),
  531. stackVersion: App.get('currentStackVersionNumber'),
  532. repoVersionId: repo.get('repoVersionId'),
  533. repoVersion: repoVersion
  534. }
  535. }).success(function() {
  536. deferred.resolve([]);
  537. });
  538. }
  539. });
  540. return deferred.promise();
  541. },
  542. /**
  543. * send request for validation for each repository
  544. * @param {Em.Object} repo
  545. * @param {boolean} skip
  546. * @returns {*}
  547. */
  548. validateRepoVersions: function(repo, skip) {
  549. var deferred = $.Deferred(),
  550. totalCalls = 0,
  551. invalidUrls = [];
  552. if (skip) {
  553. deferred.resolve(invalidUrls);
  554. } else {
  555. repo.get('operatingSystems').forEach(function (os) {
  556. if (os.get('isSelected')) {
  557. os.get('repositories').forEach(function (repo) {
  558. totalCalls++;
  559. App.ajax.send({
  560. name: 'admin.stack_versions.validate.repo',
  561. sender: this,
  562. data: {
  563. repo: repo,
  564. repoId: repo.get('repoId'),
  565. baseUrl: repo.get('baseUrl'),
  566. osType: os.get('osType'),
  567. stackName: App.get('currentStackName'),
  568. stackVersion: App.get('currentStackVersionNumber')
  569. }
  570. })
  571. .success(function () {
  572. totalCalls--;
  573. if (totalCalls === 0) deferred.resolve(invalidUrls);
  574. })
  575. .error(function () {
  576. repo.set('hasError', true);
  577. invalidUrls.push(repo);
  578. totalCalls--;
  579. if (totalCalls === 0) deferred.resolve(invalidUrls);
  580. });
  581. });
  582. } else {
  583. return deferred.resolve(invalidUrls);
  584. }
  585. });
  586. }
  587. return deferred.promise();
  588. },
  589. /**
  590. * success callback for <code>installRepoVersion()<code>
  591. * saves request id to the db
  592. * @param data
  593. * @param opt
  594. * @param params
  595. * @method installStackVersionSuccess
  596. */
  597. installRepoVersionSuccess: function (data, opt, params) {
  598. var version = App.RepositoryVersion.find(params.id);
  599. App.db.set('repoVersionInstall', 'id', [data.Requests.id]);
  600. App.clusterStatus.setClusterStatus({
  601. wizardControllerName: this.get('name'),
  602. localdb: App.db.data
  603. });
  604. version.set('defaultStatus', 'INSTALLING');
  605. if (version.get('stackVersion')) {
  606. version.set('stackVersion.state', 'INSTALLING');
  607. }
  608. },
  609. /**
  610. * opens a popup with installations state per host
  611. * @param {Em.Object} version
  612. * @method showProgressPopup
  613. */
  614. showProgressPopup: function(version) {
  615. var popupTitle = Em.I18n.t('admin.stackVersions.details.install.hosts.popup.title').format(version.get('displayName'));
  616. var requestIds = App.get('testMode') ? [1] : App.db.get('repoVersionInstall', 'id');
  617. var hostProgressPopupController = App.router.get('highAvailabilityProgressPopupController');
  618. hostProgressPopupController.initPopup(popupTitle, requestIds, this);
  619. },
  620. /**
  621. * reset upgradeState to INIT when upgrade is COMPLETED
  622. * and clean auxiliary data
  623. */
  624. finish: function () {
  625. if (App.get('upgradeState') === 'COMPLETED') {
  626. this.setDBProperty('upgradeId', undefined);
  627. this.setDBProperty('upgradeState', 'INIT');
  628. this.setDBProperty('upgradeVersion', undefined);
  629. this.setDBProperty('currentVersion', undefined);
  630. this.setDBProperty('isDowngrade', undefined);
  631. App.clusterStatus.setClusterStatus({
  632. localdb: App.db.data
  633. });
  634. App.set('upgradeState', 'INIT');
  635. }
  636. }.observes('App.upgradeState'),
  637. /**
  638. * show dialog with tasks of upgrade
  639. * @return {App.ModalPopup}
  640. */
  641. openUpgradeDialog: function () {
  642. App.router.transitionTo('admin.stackUpgrade');
  643. },
  644. /**
  645. * returns url to get data for repoVersion or clusterStackVersion
  646. * @param {Boolean} stack true if load clusterStackVersion
  647. * @param {Boolean} fullLoad true if load all data
  648. * @returns {String}
  649. * @method getUrl
  650. */
  651. getUrl: function(stack, fullLoad) {
  652. if (App.get('testMode')) {
  653. return stack ? this.get('mockStackUrl') : this.get('mockRepoUrl')
  654. } else {
  655. if (fullLoad) {
  656. return stack ? this.get('realStackUrl') : this.get('realRepoUrl');
  657. } else {
  658. return this.get('realUpdateUrl');
  659. }
  660. }
  661. },
  662. /**
  663. * get stack versions from server and push it to model
  664. * @return {*}
  665. * @method loadStackVersionsToModel
  666. */
  667. loadStackVersionsToModel: function (fullLoad) {
  668. var dfd = $.Deferred();
  669. App.HttpClient.get(this.getUrl(true, fullLoad), App.stackVersionMapper, {
  670. complete: function () {
  671. dfd.resolve();
  672. }
  673. });
  674. return dfd.promise();
  675. },
  676. /**
  677. * get repo versions from server and push it to model
  678. * @return {*}
  679. * @params {Boolean} isUpdate - if true loads part of data that need to be updated
  680. * @method loadRepoVersionsToModel()
  681. */
  682. loadRepoVersionsToModel: function () {
  683. var dfd = $.Deferred();
  684. App.HttpClient.get(this.getUrl(false, true), App.repoVersionMapper, {
  685. complete: function () {
  686. dfd.resolve();
  687. }
  688. });
  689. return dfd.promise();
  690. },
  691. /**
  692. * set status to Upgrade item
  693. * @param item
  694. * @param status
  695. */
  696. setUpgradeItemStatus: function(item, status) {
  697. this.set('requestInProgress', true);
  698. return App.ajax.send({
  699. name: 'admin.upgrade.upgradeItem.setState',
  700. sender: this,
  701. data: {
  702. upgradeId: item.get('request_id'),
  703. itemId: item.get('stage_id'),
  704. groupId: item.get('group_id'),
  705. status: status
  706. },
  707. callback: function() {
  708. this.sender.set('requestInProgress', false);
  709. }
  710. }).done(function () {
  711. item.set('status', status);
  712. });
  713. },
  714. currentVersionObserver: function () {
  715. var versionNumber = this.get('currentVersion.repository_version');
  716. var currentVersionObject = App.RepositoryVersion.find().findProperty('status', 'CURRENT');
  717. var versionName = currentVersionObject && currentVersionObject.get('stackVersionType');
  718. App.set('isStormMetricsSupported', versionName != 'HDP' || stringUtils.compareVersions(versionNumber, '2.2.2') > -1 || !versionNumber);
  719. }.observes('currentVersion.repository_version'),
  720. /**
  721. * get the installed repositories of HDP from server
  722. */
  723. loadRepositories: function () {
  724. if (App.router.get('clusterController.isLoaded')) {
  725. var nameVersionCombo = App.get('currentStackVersion');
  726. var stackName = nameVersionCombo.split('-')[0];
  727. var stackVersion = nameVersionCombo.split('-')[1];
  728. App.ajax.send({
  729. name: 'cluster.load_repositories',
  730. sender: this,
  731. data: {
  732. stackName: stackName,
  733. stackVersion: stackVersion
  734. },
  735. success: 'loadRepositoriesSuccessCallback',
  736. error: 'loadRepositoriesErrorCallback'
  737. });
  738. }
  739. }.observes('App.router.clusterController.isLoaded'),
  740. loadRepositoriesSuccessCallback: function (data) {
  741. var allRepos = [];
  742. data.items.forEach(function (os) {
  743. os.repositories.forEach(function (repository) {
  744. var osType = repository.Repositories.os_type;
  745. var repo = Em.Object.create({
  746. baseUrl: repository.Repositories.base_url,
  747. osType: osType,
  748. repoId: repository.Repositories.repo_id,
  749. repoName : repository.Repositories.repo_name,
  750. stackName : repository.Repositories.stack_name,
  751. stackVersion : repository.Repositories.stack_version,
  752. isFirst: false
  753. });
  754. var group = allRepos.findProperty('name', osType);
  755. if (!group) {
  756. group = {
  757. name: osType,
  758. repositories: []
  759. };
  760. repo.set('isFirst', true);
  761. allRepos.push(group);
  762. }
  763. group.repositories.push(repo);
  764. });
  765. }, this);
  766. allRepos.stackVersion = App.get('currentStackVersionNumber');
  767. this.set('allRepos', allRepos);
  768. },
  769. loadRepositoriesErrorCallback: function (request, ajaxOptions, error) {
  770. console.log('Error message is: ' + request.responseText);
  771. }
  772. });