stack_and_upgrade_controller_test.js 30 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937
  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. require('controllers/main/admin/stack_and_upgrade_controller');
  20. require('utils/string_utils');
  21. describe('App.MainAdminStackAndUpgradeController', function() {
  22. var controller = App.MainAdminStackAndUpgradeController.create({
  23. getDBProperty: Em.K,
  24. setDBProperty: Em.K
  25. });
  26. describe("#realRepoUrl", function() {
  27. before(function () {
  28. this.mock = sinon.stub(App, 'get');
  29. });
  30. after(function () {
  31. this.mock.restore();
  32. });
  33. it("", function() {
  34. this.mock.withArgs('apiPrefix').returns('apiPrefix');
  35. this.mock.withArgs('stackVersionURL').returns('stackVersionURL');
  36. controller.propertyDidChange('realRepoUrl');
  37. expect(controller.get('realRepoUrl')).to.equal('apiPrefixstackVersionURL/compatible_repository_versions?fields=*,operating_systems/*,operating_systems/repositories/*');
  38. });
  39. });
  40. describe("#realStackUrl", function() {
  41. before(function () {
  42. this.mock = sinon.stub(App, 'get');
  43. });
  44. after(function () {
  45. this.mock.restore();
  46. });
  47. it("", function() {
  48. this.mock.withArgs('apiPrefix').returns('apiPrefix');
  49. this.mock.withArgs('clusterName').returns('clusterName');
  50. controller.propertyDidChange('realStackUrl');
  51. expect(controller.get('realStackUrl')).to.equal('apiPrefix/clusters/clusterName/stack_versions?fields=*,repository_versions/*,repository_versions/operating_systems/repositories/*');
  52. });
  53. });
  54. describe("#realUpdateUrl", function() {
  55. before(function () {
  56. this.mock = sinon.stub(App, 'get');
  57. });
  58. after(function () {
  59. this.mock.restore();
  60. });
  61. it("", function() {
  62. this.mock.withArgs('apiPrefix').returns('apiPrefix');
  63. this.mock.withArgs('clusterName').returns('clusterName');
  64. controller.propertyDidChange('realUpdateUrl');
  65. expect(controller.get('realUpdateUrl')).to.equal('apiPrefix/clusters/clusterName/stack_versions?fields=ClusterStackVersions/*');
  66. });
  67. });
  68. describe("#load()", function() {
  69. before(function(){
  70. sinon.stub(controller, 'loadUpgradeData').returns({
  71. done: function(callback) {callback();}
  72. });
  73. sinon.stub(controller, 'loadStackVersionsToModel').returns({
  74. done: function(callback) {callback();}
  75. });
  76. sinon.stub(controller, 'loadRepoVersionsToModel').returns({
  77. done: function(callback) {callback();}
  78. });
  79. sinon.stub(App.StackVersion, 'find').returns([Em.Object.create({
  80. state: 'CURRENT',
  81. repositoryVersion: {
  82. repositoryVersion: '2.2',
  83. displayName: 'HDP-2.2'
  84. }
  85. })]);
  86. });
  87. after(function(){
  88. controller.loadUpgradeData.restore();
  89. controller.loadStackVersionsToModel.restore();
  90. controller.loadRepoVersionsToModel.restore();
  91. App.StackVersion.find.restore();
  92. });
  93. it("", function() {
  94. controller.load();
  95. expect(controller.loadUpgradeData.calledWith(true)).to.be.true;
  96. expect(controller.loadStackVersionsToModel.calledWith(true)).to.be.true;
  97. expect(controller.loadRepoVersionsToModel.calledOnce).to.be.true;
  98. expect(controller.get('currentVersion')).to.eql({
  99. "repository_version": "2.2",
  100. "repository_name": "HDP-2.2"
  101. });
  102. });
  103. });
  104. describe("#loadUpgradeData()", function() {
  105. beforeEach(function () {
  106. sinon.stub(App.ajax, 'send').returns({
  107. then: Em.K
  108. });
  109. });
  110. afterEach(function () {
  111. App.ajax.send.restore();
  112. });
  113. it("get entire data", function() {
  114. controller.set('upgradeId', 1);
  115. controller.loadUpgradeData();
  116. expect(App.ajax.send.getCall(0).args[0]).to.eql({
  117. name: 'admin.upgrade.data',
  118. sender: controller,
  119. data: {
  120. id: 1
  121. },
  122. success: 'loadUpgradeDataSuccessCallback'
  123. })
  124. });
  125. it("get only state", function() {
  126. controller.set('upgradeId', 1);
  127. controller.loadUpgradeData(true);
  128. expect(App.ajax.send.getCall(0).args[0]).to.eql({
  129. name: 'admin.upgrade.state',
  130. sender: controller,
  131. data: {
  132. id: 1
  133. },
  134. success: 'loadUpgradeDataSuccessCallback'
  135. })
  136. });
  137. it("upgrade id is null", function() {
  138. controller.set('upgradeId', null);
  139. controller.loadUpgradeData();
  140. expect(App.ajax.send.called).to.be.false;
  141. });
  142. });
  143. describe("#loadUpgradeDataSuccessCallback()", function() {
  144. beforeEach(function () {
  145. sinon.stub(controller, 'updateUpgradeData', Em.K);
  146. sinon.stub(controller, 'setDBProperty', Em.K);
  147. });
  148. afterEach(function () {
  149. controller.updateUpgradeData.restore();
  150. controller.setDBProperty.restore();
  151. });
  152. it("correct data", function() {
  153. var data = {
  154. "Upgrade": {
  155. "request_status": "UPGRADED"
  156. },
  157. "upgrade_groups": [
  158. {
  159. "UpgradeGroup": {
  160. "id": 1
  161. },
  162. "upgrade_items": []
  163. }
  164. ]};
  165. controller.loadUpgradeDataSuccessCallback(data);
  166. expect(App.get('upgradeState')).to.equal('UPGRADED');
  167. expect(controller.updateUpgradeData.calledOnce).to.be.true;
  168. expect(controller.setDBProperty.calledWith('upgradeState', 'UPGRADED')).to.be.true;
  169. });
  170. it("data is null", function() {
  171. var data = null;
  172. controller.loadUpgradeDataSuccessCallback(data);
  173. expect(controller.updateUpgradeData.called).to.be.false;
  174. expect(controller.setDBProperty.called).to.be.false;
  175. });
  176. });
  177. describe("#getUpgradeItem()", function() {
  178. beforeEach(function () {
  179. sinon.stub(App.ajax, 'send', Em.K);
  180. });
  181. afterEach(function () {
  182. App.ajax.send.restore();
  183. });
  184. it("", function() {
  185. var item = Em.Object.create({
  186. request_id: 1,
  187. group_id: 2,
  188. stage_id: 3
  189. });
  190. controller.getUpgradeItem(item);
  191. expect(App.ajax.send.getCall(0).args[0]).to.eql({
  192. name: 'admin.upgrade.upgrade_item',
  193. sender: controller,
  194. data: {
  195. upgradeId: 1,
  196. groupId: 2,
  197. stageId: 3
  198. },
  199. success: 'getUpgradeItemSuccessCallback'
  200. });
  201. });
  202. });
  203. describe("#openUpgradeDialog()", function () {
  204. before(function () {
  205. sinon.stub(App.router, 'transitionTo', Em.K);
  206. });
  207. after(function () {
  208. App.router.transitionTo.restore();
  209. });
  210. it("should open dialog", function () {
  211. controller.openUpgradeDialog();
  212. expect(App.router.transitionTo.calledWith('admin.stackUpgrade')).to.be.true;
  213. });
  214. });
  215. describe("#runPreUpgradeCheck()", function() {
  216. before(function () {
  217. sinon.stub(App.ajax, 'send', Em.K);
  218. });
  219. after(function () {
  220. App.ajax.send.restore();
  221. });
  222. it("make ajax call", function() {
  223. controller.runPreUpgradeCheck(Em.Object.create({
  224. repositoryVersion: '2.2',
  225. displayName: 'HDP-2.2'
  226. }));
  227. expect(App.ajax.send.getCall(0).args[0]).to.eql({
  228. name: "admin.rolling_upgrade.pre_upgrade_check",
  229. sender: controller,
  230. data: {
  231. value: '2.2',
  232. label: 'HDP-2.2'
  233. },
  234. success: "runPreUpgradeCheckSuccess",
  235. error: "runPreUpgradeCheckError"
  236. });
  237. });
  238. });
  239. describe("#runPreUpgradeCheckSuccess()", function () {
  240. var cases = [
  241. {
  242. check: {
  243. "check": "Work-preserving RM/NM restart is enabled in YARN configs",
  244. "status": "FAIL",
  245. "reason": "FAIL",
  246. "failed_on": [],
  247. "check_type": "SERVICE"
  248. },
  249. showClusterCheckPopupCalledCount: 1,
  250. showUpgradeConfigsMergePopupCalledCount: 0,
  251. upgradeCalledCount: 0,
  252. title: 'error popup is displayed is errors are present'
  253. },
  254. {
  255. check: {
  256. "check": "Configuration Merge Check",
  257. "status": "WARNING",
  258. "reason": "Conflict",
  259. "failed_on": [],
  260. "failed_detail": [],
  261. "check_type": "CLUSTER",
  262. "id": "CONFIG_MERGE"
  263. },
  264. showClusterCheckPopupCalledCount: 0,
  265. showUpgradeConfigsMergePopupCalledCount: 1,
  266. upgradeCalledCount: 0,
  267. title: 'warnings popup is displayed if configs merge conflicts are present'
  268. },
  269. {
  270. check: {
  271. "check": "Configuration Merge Check",
  272. "status": "PASS",
  273. "reason": "",
  274. "failed_on": [],
  275. "failed_detail": [],
  276. "check_type": "CLUSTER",
  277. "id": "CONFIG_MERGE"
  278. },
  279. showClusterCheckPopupCalledCount: 0,
  280. showUpgradeConfigsMergePopupCalledCount: 0,
  281. upgradeCalledCount: 1,
  282. title: 'upgrade is started if configs merge conflicts are absent'
  283. },
  284. {
  285. check: {
  286. "check": "Work-preserving RM/NM restart is enabled in YARN configs",
  287. "status": "PASS",
  288. "reason": "OK",
  289. "failed_on": [],
  290. "check_type": "SERVICE"
  291. },
  292. showClusterCheckPopupCalledCount: 0,
  293. showUpgradeConfigsMergePopupCalledCount: 0,
  294. upgradeCalledCount: 1,
  295. title: 'upgrade is started if errors and configs merge conflicts are absent'
  296. }
  297. ];
  298. beforeEach(function () {
  299. sinon.stub(App, 'showClusterCheckPopup', Em.K);
  300. sinon.stub(App, 'showUpgradeConfigsMergePopup', Em.K);
  301. sinon.stub(controller, 'upgrade', Em.K);
  302. });
  303. afterEach(function () {
  304. App.showClusterCheckPopup.restore();
  305. App.showUpgradeConfigsMergePopup.restore();
  306. controller.upgrade.restore();
  307. });
  308. cases.forEach(function (item) {
  309. it(item.title, function () {
  310. controller.runPreUpgradeCheckSuccess(
  311. {
  312. items: [
  313. {
  314. UpgradeChecks: item.check
  315. }
  316. ]
  317. }, null, {
  318. label: 'name'
  319. }
  320. );
  321. expect(controller.upgrade.callCount).to.equal(item.upgradeCalledCount);
  322. expect(App.showClusterCheckPopup.callCount).to.equal(item.showClusterCheckPopupCalledCount);
  323. expect(App.showUpgradeConfigsMergePopup.callCount).to.equal(item.showUpgradeConfigsMergePopupCalledCount);
  324. });
  325. });
  326. });
  327. describe("#initDBProperties()", function() {
  328. before(function () {
  329. sinon.stub(controller, 'getDBProperty', function (prop) {
  330. return prop;
  331. });
  332. });
  333. after(function () {
  334. controller.getDBProperty.restore();
  335. });
  336. it("set properties", function () {
  337. controller.set('wizardStorageProperties', ['prop1']);
  338. controller.initDBProperties();
  339. expect(controller.get('prop1')).to.equal('prop1');
  340. });
  341. });
  342. describe("#init()", function() {
  343. before(function () {
  344. sinon.stub(controller, 'initDBProperties', Em.K);
  345. });
  346. after(function () {
  347. controller.initDBProperties.restore();
  348. });
  349. it("call initDBProperties", function () {
  350. controller.init();
  351. expect(controller.initDBProperties.calledOnce).to.be.true;
  352. });
  353. });
  354. describe("#upgrade()", function() {
  355. before(function () {
  356. sinon.stub(App.ajax, 'send', Em.K);
  357. sinon.stub(controller, 'setDBProperty', Em.K);
  358. });
  359. after(function () {
  360. App.ajax.send.restore();
  361. controller.setDBProperty.restore();
  362. });
  363. it("make ajax call", function() {
  364. controller.set('currentVersion', {
  365. repository_version: '2.2'
  366. });
  367. controller.upgrade({
  368. value: '2.2',
  369. label: 'HDP-2.2'
  370. });
  371. expect(App.ajax.send.getCall(0).args[0].data).to.eql({"value": '2.2', "label": 'HDP-2.2'});
  372. expect(App.ajax.send.getCall(0).args[0].name).to.eql('admin.upgrade.start');
  373. expect(App.ajax.send.getCall(0).args[0].sender).to.eql(controller);
  374. expect(App.ajax.send.getCall(0).args[0].success).to.eql('upgradeSuccessCallback');
  375. expect(App.ajax.send.getCall(0).args[0].callback).to.be.called;
  376. expect(controller.setDBProperty.calledWith('currentVersion', {
  377. repository_version: '2.2'
  378. })).to.be.true;
  379. });
  380. });
  381. describe("#upgradeSuccessCallback()", function() {
  382. before(function () {
  383. sinon.stub(App.clusterStatus, 'setClusterStatus', Em.K);
  384. sinon.stub(controller, 'openUpgradeDialog', Em.K);
  385. sinon.stub(controller, 'setDBProperty', Em.K);
  386. sinon.stub(controller, 'load', Em.K);
  387. });
  388. after(function () {
  389. App.clusterStatus.setClusterStatus.restore();
  390. controller.openUpgradeDialog.restore();
  391. controller.setDBProperty.restore();
  392. controller.load.restore();
  393. });
  394. it("open upgrade dialog", function() {
  395. var data = {
  396. resources: [
  397. {
  398. Upgrade: {
  399. request_id: 1
  400. }
  401. }
  402. ]
  403. };
  404. controller.upgradeSuccessCallback(data, {}, {label: 'HDP-2.2.1', isDowngrade: true});
  405. expect(controller.setDBProperty.calledWith('upgradeId', 1)).to.be.true;
  406. expect(controller.setDBProperty.calledWith('upgradeVersion', 'HDP-2.2.1')).to.be.true;
  407. expect(controller.setDBProperty.calledWith('isDowngrade', true)).to.be.true;
  408. expect(controller.load.calledOnce).to.be.true;
  409. expect(controller.get('upgradeVersion')).to.equal('HDP-2.2.1');
  410. expect(controller.get('upgradeData')).to.be.null;
  411. expect(controller.get('isDowngrade')).to.be.true;
  412. expect(App.clusterStatus.setClusterStatus.calledOnce).to.be.true;
  413. expect(controller.openUpgradeDialog.calledOnce).to.be.true;
  414. });
  415. });
  416. describe("#updateUpgradeData()", function() {
  417. beforeEach(function () {
  418. sinon.stub(controller, 'initUpgradeData', Em.K);
  419. });
  420. afterEach(function () {
  421. controller.initUpgradeData.restore();
  422. });
  423. it("data loaded first time", function() {
  424. controller.set('upgradeData', null);
  425. controller.updateUpgradeData({});
  426. expect(controller.initUpgradeData.calledWith({})).to.be.true;
  427. });
  428. it("update loaded data", function() {
  429. var oldData = Em.Object.create({
  430. upgradeGroups: [
  431. Em.Object.create({
  432. group_id: 1,
  433. upgradeItems: [
  434. Em.Object.create({
  435. stage_id: 1
  436. })
  437. ]
  438. })
  439. ]
  440. });
  441. var newData = {
  442. Upgrade: {
  443. request_id: 1
  444. },
  445. upgrade_groups: [
  446. {
  447. UpgradeGroup: {
  448. group_id: 1,
  449. status: 'COMPLETED',
  450. progress_percent: 100,
  451. completed_task_count: 3
  452. },
  453. upgrade_items: [
  454. {
  455. UpgradeItem: {
  456. stage_id: 1,
  457. status: 'COMPLETED',
  458. progress_percent: 100
  459. }
  460. }
  461. ]
  462. }
  463. ]
  464. };
  465. controller.set('upgradeData', oldData);
  466. controller.updateUpgradeData(newData);
  467. expect(controller.get('upgradeData.upgradeGroups')[0].get('status')).to.equal('COMPLETED');
  468. expect(controller.get('upgradeData.upgradeGroups')[0].get('progress_percent')).to.equal(100);
  469. expect(controller.get('upgradeData.upgradeGroups')[0].get('completed_task_count')).to.equal(3);
  470. expect(controller.get('upgradeData.upgradeGroups')[0].get('upgradeItems')[0].get('status')).to.equal('COMPLETED');
  471. expect(controller.get('upgradeData.upgradeGroups')[0].get('upgradeItems')[0].get('progress_percent')).to.equal(100);
  472. });
  473. });
  474. describe("#initUpgradeData()", function() {
  475. it("", function() {
  476. var newData = {
  477. Upgrade: {
  478. request_id: 1
  479. },
  480. upgrade_groups: [
  481. {
  482. UpgradeGroup: {
  483. group_id: 1
  484. },
  485. upgrade_items: [
  486. {
  487. UpgradeItem: {
  488. stage_id: 1
  489. }
  490. },
  491. {
  492. UpgradeItem: {
  493. stage_id: 2
  494. }
  495. }
  496. ]
  497. },
  498. {
  499. UpgradeGroup: {
  500. group_id: 2
  501. },
  502. upgrade_items: []
  503. }
  504. ]
  505. };
  506. controller.initUpgradeData(newData);
  507. expect(controller.get('upgradeData.Upgrade.request_id')).to.equal(1);
  508. expect(controller.get('upgradeData.upgradeGroups')[0].get('group_id')).to.equal(2);
  509. expect(controller.get('upgradeData.upgradeGroups')[1].get('group_id')).to.equal(1);
  510. expect(controller.get('upgradeData.upgradeGroups')[1].get('upgradeItems')[0].get('stage_id')).to.equal(2);
  511. expect(controller.get('upgradeData.upgradeGroups')[1].get('upgradeItems')[1].get('stage_id')).to.equal(1);
  512. });
  513. });
  514. describe.skip("#finish()", function() {
  515. before(function () {
  516. sinon.stub(App.clusterStatus, 'setClusterStatus', Em.K);
  517. sinon.stub(controller, 'setDBProperty', Em.K);
  518. });
  519. after(function () {
  520. App.clusterStatus.setClusterStatus.restore();
  521. controller.setDBProperty.restore();
  522. });
  523. it("upgradeState is not COMPLETED", function() {
  524. App.set('upgradeState', 'UPGRADING');
  525. controller.finish();
  526. expect(App.clusterStatus.setClusterStatus.called).to.be.false;
  527. });
  528. it("upgradeState is COMPLETED", function() {
  529. App.set('upgradeState', 'COMPLETED');
  530. controller.finish();
  531. expect(controller.setDBProperty.calledWith('upgradeId', undefined)).to.be.true;
  532. expect(controller.setDBProperty.calledWith('upgradeVersion', undefined)).to.be.true;
  533. expect(controller.setDBProperty.calledWith('upgradeState', 'INIT')).to.be.true;
  534. expect(controller.setDBProperty.calledWith('currentVersion', undefined)).to.be.true;
  535. expect(App.get('upgradeState')).to.equal('INIT');
  536. expect(App.clusterStatus.setClusterStatus.calledOnce).to.be.true;
  537. });
  538. });
  539. describe("#confirmDowngrade()", function() {
  540. before(function () {
  541. sinon.spy(App, 'showConfirmationPopup');
  542. sinon.stub(controller, 'downgrade', Em.K);
  543. });
  544. after(function () {
  545. App.showConfirmationPopup.restore();
  546. controller.downgrade.restore();
  547. });
  548. it("show confirmation popup", function() {
  549. controller.set('currentVersion', Em.Object.create({
  550. repository_version: '2.2',
  551. repository_name: 'HDP-2.2'
  552. }));
  553. var popup = controller.confirmDowngrade();
  554. expect(App.showConfirmationPopup.calledOnce).to.be.true;
  555. popup.onPrimary();
  556. expect(controller.downgrade.calledWith(Em.Object.create({
  557. repository_version: '2.2',
  558. repository_name: 'HDP-2.2'
  559. }))).to.be.true;
  560. });
  561. });
  562. describe("#confirmUpgrade()", function() {
  563. before(function () {
  564. sinon.spy(App, 'showConfirmationPopup');
  565. sinon.stub(controller, 'runPreUpgradeCheck', Em.K);
  566. });
  567. after(function () {
  568. App.showConfirmationPopup.restore();
  569. controller.runPreUpgradeCheck.restore();
  570. });
  571. it("show confirmation popup", function() {
  572. var version = Em.Object.create({displayName: 'HDP-2.2'});
  573. var popup = controller.confirmUpgrade(version);
  574. expect(App.showConfirmationPopup.calledOnce).to.be.true;
  575. popup.onPrimary();
  576. expect(controller.runPreUpgradeCheck.calledWith(version)).to.be.true;
  577. });
  578. });
  579. describe("#downgrade()", function() {
  580. before(function () {
  581. sinon.stub(App.ajax, 'send', Em.K);
  582. sinon.stub(controller, 'abortUpgrade');
  583. });
  584. after(function () {
  585. App.ajax.send.restore();
  586. controller.abortUpgrade.restore();
  587. });
  588. it("make ajax call", function() {
  589. controller.downgrade(Em.Object.create({
  590. repository_version: '2.2',
  591. repository_name: 'HDP-2.2'
  592. }), {context: 'context'});
  593. expect(controller.abortUpgrade.calledOnce).to.be.true;
  594. expect(App.ajax.send.getCall(0).args[0].data).to.eql({"value": '2.2', "label": 'HDP-2.2', isDowngrade: true});
  595. expect(App.ajax.send.getCall(0).args[0].name).to.eql('admin.downgrade.start');
  596. expect(App.ajax.send.getCall(0).args[0].sender).to.eql(controller);
  597. expect(App.ajax.send.getCall(0).args[0].success).to.eql('upgradeSuccessCallback');
  598. expect(App.ajax.send.getCall(0).args[0].callback).to.be.called;
  599. });
  600. });
  601. describe("#installRepoVersionConfirmation()", function () {
  602. before(function () {
  603. sinon.stub(controller, 'installRepoVersion', Em.K);
  604. });
  605. after(function () {
  606. controller.installRepoVersion.restore();
  607. });
  608. it("show popup", function () {
  609. var repo = Em.Object.create({'displayName': 'HDP-2.2'});
  610. var popup = controller.installRepoVersionConfirmation(repo);
  611. popup.onPrimary();
  612. expect(controller.installRepoVersion.calledWith(repo)).to.be.true;
  613. });
  614. });
  615. describe("#installRepoVersion()", function () {
  616. before(function () {
  617. sinon.stub(App.ajax, 'send', Em.K);
  618. });
  619. after(function () {
  620. App.ajax.send.restore();
  621. });
  622. it("make ajax call", function () {
  623. var repo = Em.Object.create({
  624. stackVersionType: 'HDP',
  625. stackVersionNumber: '2.2',
  626. repositoryVersion: '2.2.1',
  627. repoId: 1
  628. });
  629. controller.installRepoVersion(repo);
  630. expect(App.ajax.send.calledOnce).to.be.true;
  631. });
  632. });
  633. describe("#installRepoVersionSuccess()", function() {
  634. var mock = Em.Object.create({
  635. id: 1,
  636. defaultStatus: 'INIT',
  637. stackVersion: {}
  638. });
  639. before(function () {
  640. sinon.spy(mock, 'set');
  641. sinon.stub(App.db, 'set', Em.K);
  642. sinon.stub(App.clusterStatus, 'setClusterStatus', Em.K);
  643. sinon.stub(App.RepositoryVersion, 'find').returns(mock);
  644. });
  645. after(function () {
  646. App.db.set.restore();
  647. App.clusterStatus.setClusterStatus.restore();
  648. App.RepositoryVersion.find.restore();
  649. });
  650. it("", function() {
  651. controller.installRepoVersionSuccess({Requests: {id: 1}}, {}, {id: 1});
  652. expect(App.db.set.calledWith('repoVersionInstall', 'id', [1])).to.be.true;
  653. expect(App.clusterStatus.setClusterStatus.calledOnce).to.be.true;
  654. expect(App.RepositoryVersion.find.calledWith(1)).to.be.true;
  655. expect(App.RepositoryVersion.find(1).get('defaultStatus')).to.equal('INSTALLING');
  656. expect(App.RepositoryVersion.find(1).get('stackVersion.state')).to.equal('INSTALLING');
  657. });
  658. });
  659. describe("#setUpgradeItemStatus()", function () {
  660. before(function () {
  661. sinon.stub(App.ajax, 'send', function () {
  662. return {
  663. done: function (callback) {
  664. callback();
  665. }
  666. }
  667. });
  668. });
  669. after(function () {
  670. App.ajax.send.restore();
  671. });
  672. it("", function () {
  673. var item = Em.Object.create({
  674. request_id: 1,
  675. stage_id: 1,
  676. group_id: 1
  677. });
  678. controller.setUpgradeItemStatus(item, 'PENDING');
  679. expect(App.ajax.send.getCall(0).args[0].data).to.eql({upgradeId: 1, itemId: 1, groupId: 1, status: 'PENDING'});
  680. expect(App.ajax.send.getCall(0).args[0].name).to.eql('admin.upgrade.upgradeItem.setState');
  681. expect(App.ajax.send.getCall(0).args[0].sender).to.eql(controller);
  682. expect(App.ajax.send.getCall(0).args[0].callback).to.be.called;
  683. expect(item.get('status')).to.equal('PENDING');
  684. });
  685. });
  686. describe("#prepareRepoForSaving()", function () {
  687. it("prepare date for saving", function () {
  688. var repo = Em.Object.create({
  689. operatingSystems: [
  690. Em.Object.create({
  691. osType: "redhat6",
  692. isDisabled: Ember.computed.not('isSelected'),
  693. repositories: [Em.Object.create({
  694. "baseUrl": "111121",
  695. "repoId": "HDP-2.2",
  696. "repoName": "HDP",
  697. hasError: false
  698. }),
  699. Em.Object.create({
  700. "baseUrl": "1",
  701. "repoId": "HDP-UTILS-1.1.0.20",
  702. "repoName": "HDP-UTILS",
  703. hasError: false
  704. })]
  705. })
  706. ]
  707. });
  708. var result = {
  709. "operating_systems": [
  710. {
  711. "OperatingSystems": {
  712. "os_type": "redhat6"
  713. },
  714. "repositories": [
  715. {
  716. "Repositories": {
  717. "base_url": "111121",
  718. "repo_id": "HDP-2.2",
  719. "repo_name": "HDP"
  720. }
  721. },
  722. {
  723. "Repositories": {
  724. "base_url": "1",
  725. "repo_id": "HDP-UTILS-1.1.0.20",
  726. "repo_name": "HDP-UTILS"
  727. }
  728. }
  729. ]
  730. }
  731. ]};
  732. expect(controller.prepareRepoForSaving(repo)).to.eql(result);
  733. });
  734. });
  735. describe("#saveRepoOS()", function() {
  736. before(function(){
  737. this.mock = sinon.stub(controller, 'validateRepoVersions');
  738. sinon.stub(controller, 'prepareRepoForSaving', Em.K);
  739. sinon.stub(App.ajax, 'send').returns({success: Em.K});
  740. });
  741. after(function(){
  742. this.mock.restore();
  743. controller.prepareRepoForSaving.restore();
  744. App.ajax.send.restore();
  745. });
  746. it("validation errors present", function() {
  747. this.mock.returns({
  748. done: function(callback) {callback([1]);}
  749. });
  750. controller.saveRepoOS(Em.Object.create({repoVersionId: 1}), true);
  751. expect(controller.validateRepoVersions.calledWith(Em.Object.create({repoVersionId: 1}), true)).to.be.true;
  752. expect(controller.prepareRepoForSaving.called).to.be.false;
  753. expect(App.ajax.send.called).to.be.false;
  754. });
  755. it("no validation errors", function() {
  756. this.mock.returns({
  757. done: function(callback) {callback([]);}
  758. });
  759. controller.saveRepoOS(Em.Object.create({repoVersionId: 1}), true);
  760. expect(controller.validateRepoVersions.calledWith(Em.Object.create({repoVersionId: 1}), true)).to.be.true;
  761. expect(controller.prepareRepoForSaving.calledWith(Em.Object.create({repoVersionId: 1}))).to.be.true;
  762. expect(App.ajax.send.calledOnce).to.be.true;
  763. });
  764. });
  765. describe("#validateRepoVersions()", function () {
  766. before(function () {
  767. sinon.stub(App.ajax, 'send').returns({success: Em.K, error: Em.K});
  768. });
  769. after(function () {
  770. App.ajax.send.restore();
  771. });
  772. it("skip validation", function () {
  773. controller.validateRepoVersions(Em.Object.create({repoVersionId: 1}), true);
  774. expect(App.ajax.send.called).to.be.false;
  775. });
  776. it("do validation", function () {
  777. var repo = Em.Object.create({
  778. repoVersionId: 1,
  779. operatingSystems: [
  780. Em.Object.create({
  781. isSelected: true,
  782. repositories: [
  783. Em.Object.create()
  784. ]
  785. })
  786. ]
  787. });
  788. controller.validateRepoVersions(repo, false);
  789. expect(App.ajax.send.calledOnce).to.be.true;
  790. });
  791. });
  792. describe("#showProgressPopup()", function () {
  793. var mock = {
  794. initPopup: Em.K
  795. };
  796. before(function () {
  797. sinon.stub(App.router, 'get').withArgs('highAvailabilityProgressPopupController').returns(mock);
  798. sinon.spy(mock, 'initPopup');
  799. });
  800. after(function () {
  801. App.router.get.restore();
  802. mock.initPopup.restore();
  803. });
  804. it("", function () {
  805. controller.showProgressPopup(Em.Object.create());
  806. expect(mock.initPopup.calledOnce).to.be.true;
  807. });
  808. });
  809. describe("#getUrl()", function() {
  810. beforeEach(function(){
  811. controller.reopen({
  812. realStackUrl: 'realStackUrl',
  813. realRepoUrl: 'realRepoUrl',
  814. realUpdateUrl: 'realUpdateUrl'
  815. });
  816. });
  817. it("full load is true, stack is null", function() {
  818. expect(controller.getUrl(null, true)).to.equal('realRepoUrl');
  819. });
  820. it("full load is true, stack is valid", function() {
  821. expect(controller.getUrl({}, true)).to.equal('realStackUrl');
  822. });
  823. it("full load is false, stack is valid", function() {
  824. expect(controller.getUrl({}, false)).to.equal('realUpdateUrl');
  825. });
  826. });
  827. describe("#loadStackVersionsToModel()", function () {
  828. before(function () {
  829. sinon.stub(App.HttpClient, 'get');
  830. });
  831. after(function () {
  832. App.HttpClient.get.restore();
  833. });
  834. it("", function () {
  835. controller.loadStackVersionsToModel();
  836. expect(App.HttpClient.get.calledOnce).to.be.true;
  837. });
  838. });
  839. describe("#loadRepoVersionsToModel()", function () {
  840. before(function () {
  841. sinon.stub(App.HttpClient, 'get');
  842. });
  843. after(function () {
  844. App.HttpClient.get.restore();
  845. });
  846. it("", function () {
  847. controller.loadRepoVersionsToModel();
  848. expect(App.HttpClient.get.calledOnce).to.be.true;
  849. });
  850. });
  851. describe('#currentVersionObserver()', function () {
  852. var cases = [
  853. {
  854. stackVersionType: 'HDP',
  855. repoVersion: '2.2.1.1.0-1',
  856. isStormMetricsSupported: false,
  857. title: 'HDP < 2.2.2'
  858. },
  859. {
  860. stackVersionType: 'HDP',
  861. repoVersion: '2.2.2.1.0-1',
  862. isStormMetricsSupported: true,
  863. title: 'HDP 2.2.2'
  864. },
  865. {
  866. stackVersionType: 'HDP',
  867. repoVersion: '2.2.3.1.0-1',
  868. isStormMetricsSupported: true,
  869. title: 'HDP > 2.2.2'
  870. },
  871. {
  872. stackVersionType: 'BIGTOP',
  873. repoVersion: '0.8.1.1.0-1',
  874. isStormMetricsSupported: true,
  875. title: 'not HDP'
  876. }
  877. ];
  878. afterEach(function () {
  879. App.RepositoryVersion.find.restore();
  880. });
  881. cases.forEach(function (item) {
  882. it(item.title, function () {
  883. sinon.stub(App.RepositoryVersion, 'find').returns([
  884. Em.Object.create({
  885. status: 'CURRENT',
  886. stackVersionType: item.stackVersionType
  887. })
  888. ]);
  889. controller.set('currentVersion', {
  890. repository_version: item.repoVersion
  891. });
  892. expect(App.get('isStormMetricsSupported')).to.equal(item.isStormMetricsSupported);
  893. });
  894. });
  895. });
  896. });