stack_and_upgrade_controller_test.js 60 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211121212131214121512161217121812191220122112221223122412251226122712281229123012311232123312341235123612371238123912401241124212431244124512461247124812491250125112521253125412551256125712581259126012611262126312641265126612671268126912701271127212731274127512761277127812791280128112821283128412851286128712881289129012911292129312941295129612971298129913001301130213031304130513061307130813091310131113121313131413151316131713181319132013211322132313241325132613271328132913301331133213331334133513361337133813391340134113421343134413451346134713481349135013511352135313541355135613571358135913601361136213631364136513661367136813691370137113721373137413751376137713781379138013811382138313841385138613871388138913901391139213931394139513961397139813991400140114021403140414051406140714081409141014111412141314141415141614171418141914201421142214231424142514261427142814291430143114321433143414351436143714381439144014411442144314441445144614471448144914501451145214531454145514561457145814591460146114621463146414651466146714681469147014711472147314741475147614771478147914801481148214831484148514861487148814891490149114921493149414951496149714981499150015011502150315041505150615071508150915101511151215131514151515161517151815191520152115221523152415251526152715281529153015311532153315341535153615371538153915401541154215431544154515461547154815491550155115521553155415551556155715581559156015611562156315641565156615671568156915701571157215731574157515761577157815791580158115821583158415851586158715881589159015911592159315941595159615971598159916001601160216031604160516061607160816091610161116121613161416151616161716181619162016211622162316241625162616271628162916301631163216331634163516361637163816391640164116421643164416451646164716481649165016511652165316541655165616571658165916601661166216631664166516661667166816691670167116721673167416751676167716781679168016811682168316841685168616871688168916901691169216931694169516961697169816991700170117021703170417051706170717081709171017111712171317141715171617171718171917201721172217231724172517261727172817291730173117321733173417351736173717381739174017411742174317441745174617471748174917501751175217531754175517561757175817591760176117621763176417651766176717681769177017711772177317741775177617771778177917801781178217831784178517861787178817891790179117921793179417951796179717981799180018011802180318041805180618071808180918101811181218131814181518161817181818191820182118221823182418251826182718281829183018311832183318341835183618371838183918401841184218431844184518461847184818491850185118521853185418551856185718581859186018611862186318641865186618671868186918701871187218731874187518761877187818791880188118821883188418851886188718881889189018911892189318941895189618971898189919001901190219031904190519061907190819091910191119121913191419151916191719181919192019211922192319241925192619271928192919301931193219331934193519361937193819391940194119421943194419451946194719481949195019511952195319541955
  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("#requestStatus", function() {
  69. it("state ABORTED", function() {
  70. controller.set('upgradeData', { Upgrade: {request_status: 'ABORTED'}});
  71. controller.propertyDidChange('requestStatus');
  72. expect(controller.get('requestStatus')).to.equal('SUSPENDED');
  73. });
  74. it("state not ABORTED", function() {
  75. controller.set('upgradeData', { Upgrade: {request_status: 'INIT'}});
  76. controller.propertyDidChange('requestStatus');
  77. expect(controller.get('requestStatus')).to.equal('INIT');
  78. });
  79. });
  80. describe("#load()", function() {
  81. before(function(){
  82. sinon.stub(controller, 'loadUpgradeData').returns({
  83. done: function(callback) {callback();}
  84. });
  85. sinon.stub(controller, 'loadStackVersionsToModel').returns({
  86. done: function(callback) {callback();}
  87. });
  88. sinon.stub(controller, 'loadRepoVersionsToModel').returns({
  89. done: function(callback) {callback();}
  90. });
  91. sinon.stub(App.StackVersion, 'find').returns([Em.Object.create({
  92. state: 'CURRENT',
  93. repositoryVersion: {
  94. repositoryVersion: '2.2',
  95. displayName: 'HDP-2.2'
  96. }
  97. })]);
  98. });
  99. after(function(){
  100. controller.loadUpgradeData.restore();
  101. controller.loadStackVersionsToModel.restore();
  102. controller.loadRepoVersionsToModel.restore();
  103. App.StackVersion.find.restore();
  104. });
  105. it("", function() {
  106. controller.load();
  107. expect(controller.loadUpgradeData.calledWith(true)).to.be.true;
  108. expect(controller.loadStackVersionsToModel.calledWith(true)).to.be.true;
  109. expect(controller.loadRepoVersionsToModel.calledOnce).to.be.true;
  110. expect(controller.get('currentVersion')).to.eql({
  111. "repository_version": "2.2",
  112. "repository_name": "HDP-2.2"
  113. });
  114. });
  115. });
  116. describe("#loadUpgradeData()", function() {
  117. beforeEach(function () {
  118. sinon.stub(App.ajax, 'send').returns({
  119. then: Em.K,
  120. complete: Em.K
  121. });
  122. });
  123. afterEach(function () {
  124. App.ajax.send.restore();
  125. });
  126. it("get entire data", function() {
  127. controller.set('upgradeId', 1);
  128. controller.loadUpgradeData();
  129. expect(App.ajax.send.getCall(0).args[0]).to.eql({
  130. name: 'admin.upgrade.data',
  131. sender: controller,
  132. data: {
  133. id: 1
  134. },
  135. success: 'loadUpgradeDataSuccessCallback'
  136. })
  137. });
  138. it("get only state", function() {
  139. controller.set('upgradeId', 1);
  140. controller.loadUpgradeData(true);
  141. expect(App.ajax.send.getCall(0).args[0]).to.eql({
  142. name: 'admin.upgrade.state',
  143. sender: controller,
  144. data: {
  145. id: 1
  146. },
  147. success: 'loadUpgradeDataSuccessCallback'
  148. })
  149. });
  150. it("upgrade id is null", function() {
  151. controller.set('upgradeId', null);
  152. controller.loadUpgradeData();
  153. expect(App.ajax.send.called).to.be.false;
  154. });
  155. });
  156. describe("#loadUpgradeDataSuccessCallback()", function() {
  157. var retryCases = [
  158. {
  159. isRetryPendingInitial: true,
  160. status: 'ABORTED',
  161. isRetryPending: true,
  162. requestInProgress: true,
  163. title: 'retry request not yet applied'
  164. },
  165. {
  166. isRetryPendingInitial: true,
  167. status: 'UPGRADING',
  168. isRetryPending: false,
  169. requestInProgress: false,
  170. title: 'retry request applied'
  171. },
  172. {
  173. isRetryPendingInitial: false,
  174. status: 'ABORTED',
  175. isRetryPending: false,
  176. requestInProgress: true,
  177. title: 'no retry request sent'
  178. },
  179. {
  180. isRetryPendingInitial: false,
  181. status: 'UPGRADING',
  182. isRetryPending: false,
  183. requestInProgress: true,
  184. title: 'upgrade wasn\'t aborted'
  185. }
  186. ];
  187. beforeEach(function () {
  188. sinon.stub(controller, 'updateUpgradeData', Em.K);
  189. sinon.stub(controller, 'setDBProperty', Em.K);
  190. });
  191. afterEach(function () {
  192. controller.updateUpgradeData.restore();
  193. controller.setDBProperty.restore();
  194. });
  195. it("correct data", function() {
  196. var data = {
  197. "Upgrade": {
  198. "request_status": "UPGRADED"
  199. },
  200. "upgrade_groups": [
  201. {
  202. "UpgradeGroup": {
  203. "id": 1
  204. },
  205. "upgrade_items": []
  206. }
  207. ]};
  208. controller.loadUpgradeDataSuccessCallback(data);
  209. expect(App.get('upgradeState')).to.equal('UPGRADED');
  210. expect(controller.updateUpgradeData.calledOnce).to.be.true;
  211. expect(controller.setDBProperty.calledWith('upgradeState', 'UPGRADED')).to.be.true;
  212. });
  213. it("data is null", function() {
  214. var data = null;
  215. controller.loadUpgradeDataSuccessCallback(data);
  216. expect(controller.updateUpgradeData.called).to.be.false;
  217. expect(controller.setDBProperty.called).to.be.false;
  218. });
  219. retryCases.forEach(function (item) {
  220. it(item.title, function () {
  221. var data = {
  222. "Upgrade": {
  223. "request_status": item.status
  224. }
  225. };
  226. controller.setProperties({
  227. isRetryPending: item.isRetryPendingInitial,
  228. requestInProgress: true
  229. });
  230. controller.loadUpgradeDataSuccessCallback(data);
  231. expect(controller.getProperties(['isRetryPending', 'requestInProgress'])).to.eql({
  232. isRetryPending: item.isRetryPending,
  233. requestInProgress: item.requestInProgress
  234. });
  235. });
  236. });
  237. });
  238. describe("#getUpgradeItem()", function() {
  239. beforeEach(function () {
  240. sinon.stub(App.ajax, 'send', Em.K);
  241. });
  242. afterEach(function () {
  243. App.ajax.send.restore();
  244. });
  245. it("default callback", function() {
  246. var item = Em.Object.create({
  247. request_id: 1,
  248. group_id: 2,
  249. stage_id: 3
  250. });
  251. controller.getUpgradeItem(item);
  252. expect(App.ajax.send.getCall(0).args[0]).to.eql({
  253. name: 'admin.upgrade.upgrade_item',
  254. sender: controller,
  255. data: {
  256. upgradeId: 1,
  257. groupId: 2,
  258. stageId: 3
  259. },
  260. success: 'getUpgradeItemSuccessCallback'
  261. });
  262. });
  263. it("custom callback", function() {
  264. var item = Em.Object.create({
  265. request_id: 1,
  266. group_id: 2,
  267. stage_id: 3
  268. });
  269. controller.getUpgradeItem(item, 'customCallback');
  270. expect(App.ajax.send.getCall(0).args[0]).to.eql({
  271. name: 'admin.upgrade.upgrade_item',
  272. sender: controller,
  273. data: {
  274. upgradeId: 1,
  275. groupId: 2,
  276. stageId: 3
  277. },
  278. success: 'customCallback'
  279. });
  280. });
  281. });
  282. describe("#openUpgradeDialog()", function () {
  283. before(function () {
  284. sinon.stub(App.router, 'transitionTo', Em.K);
  285. });
  286. after(function () {
  287. App.router.transitionTo.restore();
  288. });
  289. it("should open dialog", function () {
  290. controller.openUpgradeDialog();
  291. expect(App.router.transitionTo.calledWith('admin.stackUpgrade')).to.be.true;
  292. });
  293. });
  294. describe("#runPreUpgradeCheck()", function() {
  295. before(function () {
  296. sinon.stub(App.ajax, 'send', Em.K);
  297. });
  298. after(function () {
  299. App.ajax.send.restore();
  300. });
  301. it("make ajax call", function() {
  302. controller.runPreUpgradeCheck(Em.Object.create({
  303. repositoryVersion: '2.2',
  304. displayName: 'HDP-2.2',
  305. upgradeType: 'ROLLING',
  306. skipComponentFailures: false,
  307. skipSCFailures: false
  308. }));
  309. expect(App.ajax.send.getCall(0).args[0]).to.eql({
  310. name: "admin.upgrade.pre_upgrade_check",
  311. sender: controller,
  312. data: {
  313. value: '2.2',
  314. label: 'HDP-2.2',
  315. type: 'ROLLING',
  316. skipComponentFailures: 'false',
  317. skipSCFailures: 'false'
  318. },
  319. success: "runPreUpgradeCheckSuccess",
  320. error: "runPreUpgradeCheckError"
  321. });
  322. });
  323. });
  324. describe("#runPreUpgradeCheckSuccess()", function () {
  325. var cases = [
  326. {
  327. check: {
  328. "check": "Work-preserving RM/NM restart is enabled in YARN configs",
  329. "status": "FAIL",
  330. "reason": "FAIL",
  331. "failed_on": [],
  332. "check_type": "SERVICE"
  333. },
  334. showClusterCheckPopupCalledCount: 1,
  335. upgradeCalledCount: 0,
  336. title: 'popup is displayed if fails are present'
  337. },
  338. {
  339. check: {
  340. "check": "Configuration Merge Check",
  341. "status": "WARNING",
  342. "reason": "Conflict",
  343. "failed_on": [],
  344. "failed_detail": [
  345. {
  346. type: 't0',
  347. property: 'p0',
  348. current: 'c0',
  349. new_stack_value: 'n0',
  350. result_value: 'n0'
  351. },
  352. {
  353. type: 't1',
  354. property: 'p1',
  355. current: 'c1',
  356. new_stack_value: null,
  357. result_value: 'c1'
  358. },
  359. {
  360. type: 't2',
  361. property: 'p2',
  362. current: 'c2',
  363. new_stack_value: null,
  364. result_value: null
  365. }
  366. ],
  367. "check_type": "CLUSTER",
  368. "id": "CONFIG_MERGE"
  369. },
  370. showClusterCheckPopupCalledCount: 1,
  371. upgradeCalledCount: 0,
  372. configs: [
  373. {
  374. type: 't0',
  375. name: 'p0',
  376. currentValue: 'c0',
  377. recommendedValue: 'n0',
  378. resultingValue: 'n0',
  379. isDeprecated: false,
  380. willBeRemoved: false
  381. },
  382. {
  383. type: 't1',
  384. name: 'p1',
  385. currentValue: 'c1',
  386. recommendedValue: Em.I18n.t('popup.clusterCheck.Upgrade.configsMerge.deprecated'),
  387. resultingValue: 'c1',
  388. isDeprecated: true,
  389. willBeRemoved: false
  390. },
  391. {
  392. type: 't2',
  393. name: 'p2',
  394. currentValue: 'c2',
  395. recommendedValue: Em.I18n.t('popup.clusterCheck.Upgrade.configsMerge.deprecated'),
  396. resultingValue: Em.I18n.t('popup.clusterCheck.Upgrade.configsMerge.willBeRemoved'),
  397. isDeprecated: true,
  398. willBeRemoved: true
  399. }
  400. ],
  401. title: 'popup is displayed if warnings are present; configs merge conflicts'
  402. },
  403. {
  404. check: {
  405. "check": "Work-preserving RM/NM restart is enabled in YARN configs",
  406. "status": "PASS",
  407. "reason": "OK",
  408. "failed_on": [],
  409. "check_type": "SERVICE"
  410. },
  411. showClusterCheckPopupCalledCount: 0,
  412. upgradeCalledCount: 1,
  413. title: 'upgrade is started if fails and warnings are absent'
  414. }
  415. ];
  416. beforeEach(function () {
  417. sinon.stub(App, 'showClusterCheckPopup', Em.K);
  418. sinon.stub(controller, 'upgrade', Em.K);
  419. });
  420. afterEach(function () {
  421. App.showClusterCheckPopup.restore();
  422. controller.upgrade.restore();
  423. });
  424. cases.forEach(function (item) {
  425. it(item.title, function () {
  426. controller.runPreUpgradeCheckSuccess(
  427. {
  428. items: [
  429. {
  430. UpgradeChecks: item.check
  431. }
  432. ]
  433. }, null, {
  434. label: 'name'
  435. }
  436. );
  437. expect(controller.upgrade.callCount).to.equal(item.upgradeCalledCount);
  438. expect(App.showClusterCheckPopup.callCount).to.equal(item.showClusterCheckPopupCalledCount);
  439. if (item.check.id == 'CONFIG_MERGE') {
  440. expect(App.showClusterCheckPopup.firstCall.args[2]).to.eql(item.configs);
  441. }
  442. });
  443. });
  444. });
  445. describe("#initDBProperties()", function() {
  446. before(function () {
  447. this.mock = sinon.stub(controller, 'getDBProperties');
  448. });
  449. after(function () {
  450. this.mock.restore();
  451. });
  452. it("set string properties", function () {
  453. this.mock.returns({prop: 'string'});
  454. controller.initDBProperties();
  455. expect(controller.get('prop')).to.equal('string');
  456. });
  457. it("set number properties", function () {
  458. this.mock.returns({prop: 0});
  459. controller.initDBProperties();
  460. expect(controller.get('prop')).to.equal(0);
  461. });
  462. it("set boolean properties", function () {
  463. this.mock.returns({prop: false});
  464. controller.initDBProperties();
  465. expect(controller.get('prop')).to.be.false;
  466. });
  467. it("set undefined properties", function () {
  468. this.mock.returns({prop: undefined});
  469. controller.set('prop', 'value');
  470. controller.initDBProperties();
  471. expect(controller.get('prop')).to.equal('value');
  472. });
  473. it("set null properties", function () {
  474. this.mock.returns({prop: null});
  475. controller.set('prop', 'value');
  476. controller.initDBProperties();
  477. expect(controller.get('prop')).to.equal('value');
  478. });
  479. });
  480. describe("#init()", function() {
  481. before(function () {
  482. sinon.stub(controller, 'initDBProperties', Em.K);
  483. });
  484. after(function () {
  485. controller.initDBProperties.restore();
  486. });
  487. it("call initDBProperties", function () {
  488. controller.init();
  489. expect(controller.initDBProperties.calledOnce).to.be.true;
  490. });
  491. });
  492. describe("#upgrade()", function() {
  493. before(function () {
  494. sinon.stub(App.ajax, 'send', Em.K);
  495. sinon.stub(controller, 'setDBProperty', Em.K);
  496. });
  497. after(function () {
  498. App.ajax.send.restore();
  499. controller.setDBProperty.restore();
  500. });
  501. it("make ajax call", function() {
  502. controller.set('currentVersion', {
  503. repository_version: '2.2'
  504. });
  505. controller.upgrade({
  506. value: '2.2',
  507. label: 'HDP-2.2'
  508. });
  509. expect(App.ajax.send.getCall(0).args[0].data).to.eql({"value": '2.2', "label": 'HDP-2.2'});
  510. expect(App.ajax.send.getCall(0).args[0].name).to.eql('admin.upgrade.start');
  511. expect(App.ajax.send.getCall(0).args[0].sender).to.eql(controller);
  512. expect(App.ajax.send.getCall(0).args[0].success).to.eql('upgradeSuccessCallback');
  513. expect(App.ajax.send.getCall(0).args[0].callback).to.be.called;
  514. expect(controller.setDBProperty.calledWith('currentVersion', {
  515. repository_version: '2.2'
  516. })).to.be.true;
  517. });
  518. });
  519. describe("#upgradeSuccessCallback()", function() {
  520. before(function () {
  521. sinon.stub(App.clusterStatus, 'setClusterStatus', Em.K);
  522. sinon.stub(controller, 'openUpgradeDialog', Em.K);
  523. sinon.stub(controller, 'setDBProperties', Em.K);
  524. sinon.stub(controller, 'load', Em.K);
  525. });
  526. after(function () {
  527. App.clusterStatus.setClusterStatus.restore();
  528. controller.openUpgradeDialog.restore();
  529. controller.setDBProperties.restore();
  530. controller.load.restore();
  531. });
  532. it("open upgrade dialog", function() {
  533. var data = {
  534. resources: [
  535. {
  536. Upgrade: {
  537. request_id: 1
  538. }
  539. }
  540. ]
  541. };
  542. controller.upgradeSuccessCallback(data, {}, {label: 'HDP-2.2.1', isDowngrade: true});
  543. expect(controller.load.calledOnce).to.be.true;
  544. expect(controller.get('upgradeVersion')).to.equal('HDP-2.2.1');
  545. expect(controller.get('upgradeData')).to.be.null;
  546. expect(controller.get('isDowngrade')).to.be.true;
  547. expect(App.clusterStatus.setClusterStatus.calledOnce).to.be.true;
  548. expect(controller.openUpgradeDialog.calledOnce).to.be.true;
  549. });
  550. });
  551. describe("#updateUpgradeData()", function() {
  552. beforeEach(function () {
  553. sinon.stub(controller, 'initUpgradeData', Em.K);
  554. });
  555. afterEach(function () {
  556. controller.initUpgradeData.restore();
  557. });
  558. it("data loaded first time", function() {
  559. controller.set('upgradeData', null);
  560. controller.updateUpgradeData({});
  561. expect(controller.initUpgradeData.calledWith({})).to.be.true;
  562. });
  563. it("update loaded data", function() {
  564. var oldData = Em.Object.create({
  565. upgradeGroups: [
  566. Em.Object.create({
  567. group_id: 1,
  568. upgradeItems: [
  569. Em.Object.create({
  570. stage_id: 1
  571. })
  572. ]
  573. }),
  574. Em.Object.create({
  575. group_id: 2,
  576. upgradeItems: [
  577. Em.Object.create({
  578. stage_id: 2
  579. }),
  580. Em.Object.create({
  581. stage_id: 3
  582. })
  583. ]
  584. })
  585. ]
  586. });
  587. var newData = {
  588. Upgrade: {
  589. request_id: 1
  590. },
  591. upgrade_groups: [
  592. {
  593. UpgradeGroup: {
  594. group_id: 1,
  595. status: 'COMPLETED',
  596. progress_percent: 100,
  597. completed_task_count: 3
  598. },
  599. upgrade_items: [
  600. {
  601. UpgradeItem: {
  602. stage_id: 1,
  603. status: 'COMPLETED',
  604. progress_percent: 100
  605. }
  606. }
  607. ]
  608. },
  609. {
  610. UpgradeGroup: {
  611. group_id: 2,
  612. status: 'ABORTED',
  613. progress_percent: 50,
  614. completed_task_count: 1
  615. },
  616. upgrade_items: [
  617. {
  618. UpgradeItem: {
  619. stage_id: 2,
  620. status: 'ABORTED',
  621. progress_percent: 99
  622. }
  623. },
  624. {
  625. UpgradeItem: {
  626. stage_id: 3,
  627. status: 'PENDING',
  628. progress_percent: 0
  629. }
  630. }
  631. ]
  632. }
  633. ]
  634. };
  635. controller.set('upgradeData', oldData);
  636. controller.updateUpgradeData(newData);
  637. expect(controller.get('upgradeData.upgradeGroups')[0].get('status')).to.equal('COMPLETED');
  638. expect(controller.get('upgradeData.upgradeGroups')[0].get('progress_percent')).to.equal(100);
  639. expect(controller.get('upgradeData.upgradeGroups')[0].get('completed_task_count')).to.equal(3);
  640. expect(controller.get('upgradeData.upgradeGroups')[0].get('upgradeItems')[0].get('status')).to.equal('COMPLETED');
  641. expect(controller.get('upgradeData.upgradeGroups')[0].get('upgradeItems')[0].get('progress_percent')).to.equal(100);
  642. expect(controller.get('upgradeData.upgradeGroups')[0].get('hasExpandableItems')).to.be.true;
  643. expect(controller.get('upgradeData.upgradeGroups')[1].get('status')).to.equal('ABORTED');
  644. expect(controller.get('upgradeData.upgradeGroups')[1].get('progress_percent')).to.equal(50);
  645. expect(controller.get('upgradeData.upgradeGroups')[1].get('completed_task_count')).to.equal(1);
  646. expect(controller.get('upgradeData.upgradeGroups')[1].get('upgradeItems')[0].get('status')).to.equal('ABORTED');
  647. expect(controller.get('upgradeData.upgradeGroups')[1].get('upgradeItems')[1].get('status')).to.equal('PENDING');
  648. expect(controller.get('upgradeData.upgradeGroups')[1].get('upgradeItems')[0].get('progress_percent')).to.equal(99);
  649. expect(controller.get('upgradeData.upgradeGroups')[1].get('upgradeItems')[1].get('progress_percent')).to.equal(0);
  650. expect(controller.get('upgradeData.upgradeGroups')[1].get('hasExpandableItems')).to.be.false;
  651. });
  652. });
  653. describe("#initUpgradeData()", function() {
  654. beforeEach(function () {
  655. sinon.stub(controller, 'setDBProperty');
  656. });
  657. afterEach(function () {
  658. controller.setDBProperty.restore();
  659. });
  660. it("", function() {
  661. var newData = {
  662. Upgrade: {
  663. request_id: 1,
  664. downgrade_allowed: false
  665. },
  666. upgrade_groups: [
  667. {
  668. UpgradeGroup: {
  669. group_id: 1
  670. },
  671. upgrade_items: [
  672. {
  673. UpgradeItem: {
  674. stage_id: 1,
  675. status: 'IN_PROGRESS'
  676. }
  677. },
  678. {
  679. UpgradeItem: {
  680. stage_id: 2
  681. }
  682. }
  683. ]
  684. },
  685. {
  686. UpgradeGroup: {
  687. group_id: 2
  688. },
  689. upgrade_items: []
  690. },
  691. {
  692. UpgradeGroup: {
  693. group_id: 3
  694. },
  695. upgrade_items: [
  696. {
  697. UpgradeItem: {
  698. stage_id: 3,
  699. status: 'ABORTED'
  700. }
  701. },
  702. {
  703. UpgradeItem: {
  704. stage_id: 4,
  705. status: 'PENDING'
  706. }
  707. }
  708. ]
  709. }
  710. ]
  711. };
  712. controller.initUpgradeData(newData);
  713. expect(controller.setDBProperty.calledWith('downgradeAllowed', false)).to.be.true;
  714. expect(controller.get('downgradeAllowed')).to.be.false;
  715. expect(controller.get('upgradeData.Upgrade.request_id')).to.equal(1);
  716. expect(controller.get('upgradeData.upgradeGroups')[0].get('group_id')).to.equal(3);
  717. expect(controller.get('upgradeData.upgradeGroups')[1].get('group_id')).to.equal(2);
  718. expect(controller.get('upgradeData.upgradeGroups')[2].get('group_id')).to.equal(1);
  719. expect(controller.get('upgradeData.upgradeGroups')[2].get('upgradeItems')[0].get('stage_id')).to.equal(2);
  720. expect(controller.get('upgradeData.upgradeGroups')[2].get('upgradeItems')[1].get('stage_id')).to.equal(1);
  721. expect(controller.get('upgradeData.upgradeGroups')[0].get('hasExpandableItems')).to.be.false;
  722. expect(controller.get('upgradeData.upgradeGroups')[1].get('hasExpandableItems')).to.be.false;
  723. expect(controller.get('upgradeData.upgradeGroups')[2].get('hasExpandableItems')).to.be.true;
  724. });
  725. });
  726. describe.skip("#finish()", function() {
  727. before(function () {
  728. sinon.stub(App.clusterStatus, 'setClusterStatus', Em.K);
  729. sinon.stub(controller, 'setDBProperty', Em.K);
  730. });
  731. after(function () {
  732. App.clusterStatus.setClusterStatus.restore();
  733. controller.setDBProperty.restore();
  734. });
  735. it("upgradeState is not COMPLETED", function() {
  736. App.set('upgradeState', 'UPGRADING');
  737. controller.finish();
  738. expect(App.clusterStatus.setClusterStatus.called).to.be.false;
  739. });
  740. it("upgradeState is COMPLETED", function() {
  741. App.set('upgradeState', 'COMPLETED');
  742. controller.finish();
  743. expect(controller.setDBProperty.calledWith('upgradeId', undefined)).to.be.true;
  744. expect(controller.setDBProperty.calledWith('upgradeVersion', undefined)).to.be.true;
  745. expect(controller.setDBProperty.calledWith('upgradeState', 'INIT')).to.be.true;
  746. expect(controller.setDBProperty.calledWith('currentVersion', undefined)).to.be.true;
  747. expect(App.get('upgradeState')).to.equal('INIT');
  748. expect(App.clusterStatus.setClusterStatus.calledOnce).to.be.true;
  749. });
  750. });
  751. describe("#confirmDowngrade()", function() {
  752. before(function () {
  753. sinon.spy(App, 'showConfirmationPopup');
  754. sinon.stub(controller, 'downgrade', Em.K);
  755. });
  756. after(function () {
  757. App.showConfirmationPopup.restore();
  758. controller.downgrade.restore();
  759. });
  760. it("show confirmation popup", function() {
  761. controller.set('currentVersion', Em.Object.create({
  762. repository_version: '2.2',
  763. repository_name: 'HDP-2.2'
  764. }));
  765. var popup = controller.confirmDowngrade();
  766. expect(App.showConfirmationPopup.calledOnce).to.be.true;
  767. popup.onPrimary();
  768. expect(controller.downgrade.calledWith(Em.Object.create({
  769. repository_version: '2.2',
  770. repository_name: 'HDP-2.2'
  771. }))).to.be.true;
  772. });
  773. });
  774. describe("#upgradeOptions()", function() {
  775. before(function () {
  776. sinon.spy(App, 'ModalPopup');
  777. sinon.spy(App, 'showConfirmationFeedBackPopup');
  778. sinon.stub(controller, 'getSupportedUpgradeTypes').returns({
  779. done: function (callback) {
  780. callback([1]);
  781. return {
  782. always: function (alwaysCallback) {
  783. alwaysCallback();
  784. return {};
  785. }
  786. };
  787. }
  788. });
  789. sinon.stub(controller, 'runPreUpgradeCheck', Em.K);
  790. sinon.stub(App.RepositoryVersion, 'find').returns([
  791. Em.Object.create({
  792. status: 'CURRENT'
  793. })
  794. ]);
  795. });
  796. beforeEach(function () {
  797. controller.get('runningCheckRequests').clear();
  798. });
  799. after(function () {
  800. App.ModalPopup.restore();
  801. App.showConfirmationFeedBackPopup.restore();
  802. controller.runPreUpgradeCheck.restore();
  803. controller.getSupportedUpgradeTypes.restore();
  804. controller.get('upgradeMethods').setEach('selected', false);
  805. App.RepositoryVersion.find.restore();
  806. });
  807. it("show confirmation popup", function() {
  808. var version = Em.Object.create({displayName: 'HDP-2.2'});
  809. controller.set('isDowngrade', false);
  810. var popup = controller.upgradeOptions(false, version);
  811. expect(App.ModalPopup.calledOnce).to.be.true;
  812. expect(controller.get('upgradeMethods').everyProperty('isCheckRequestInProgress')).to.be.true;
  813. expect(controller.get('upgradeMethods').someProperty('selected')).to.be.false;
  814. controller.get('upgradeMethods')[0].set('selected', true);
  815. var confirmPopup = popup.onPrimary();
  816. expect(App.showConfirmationFeedBackPopup.calledOnce).to.be.true;
  817. confirmPopup.onPrimary();
  818. expect(controller.runPreUpgradeCheck.calledWith(version)).to.be.true;
  819. expect( controller.get('runningCheckRequests')).to.have.length(1);
  820. });
  821. it("NOT show confirmation popup on Downgrade", function() {
  822. var version = Em.Object.create({displayName: 'HDP-2.2'});
  823. controller.set('isDowngrade', true);
  824. controller.upgradeOptions(false, version);
  825. expect(App.ModalPopup.calledOnce).to.be.false;
  826. expect( controller.get('runningCheckRequests')).to.have.length(1);
  827. });
  828. });
  829. describe("#confirmUpgrade()", function() {
  830. before(function () {
  831. sinon.stub(controller, 'upgradeOptions', Em.K);
  832. });
  833. after(function () {
  834. controller.upgradeOptions.restore();
  835. });
  836. it("show show upgrade options popup window", function() {
  837. var version = Em.Object.create({displayName: 'HDP-2.2'});
  838. controller.confirmUpgrade(version);
  839. expect(controller.upgradeOptions.calledWith(false, version)).to.be.true;
  840. });
  841. });
  842. describe("#downgrade()", function() {
  843. before(function () {
  844. sinon.stub(App.ajax, 'send', Em.K);
  845. sinon.stub(controller, 'abortUpgrade');
  846. sinon.stub(App.RepositoryVersion, 'find').returns([
  847. Em.Object.create({
  848. displayName: 'HDP-2.3',
  849. repositoryVersion: '2.3'
  850. })
  851. ]);
  852. });
  853. after(function () {
  854. App.ajax.send.restore();
  855. controller.abortUpgrade.restore();
  856. App.RepositoryVersion.find.restore();
  857. });
  858. it("make ajax call", function() {
  859. controller.set('upgradeVersion', 'HDP-2.3');
  860. controller.set('upgradeType', 'NON_ROLLING');
  861. controller.downgrade(Em.Object.create({
  862. repository_version: '2.2',
  863. repository_name: 'HDP-2.2'
  864. }), {context: 'context'});
  865. expect(controller.abortUpgrade.calledOnce).to.be.true;
  866. expect(App.ajax.send.getCall(0).args[0].data).to.eql({
  867. from: '2.3',
  868. value: '2.2',
  869. label: 'HDP-2.2',
  870. isDowngrade: true,
  871. upgradeType: "NON_ROLLING"
  872. });
  873. expect(App.ajax.send.getCall(0).args[0].name).to.eql('admin.downgrade.start');
  874. expect(App.ajax.send.getCall(0).args[0].sender).to.eql(controller);
  875. expect(App.ajax.send.getCall(0).args[0].success).to.eql('upgradeSuccessCallback');
  876. expect(App.ajax.send.getCall(0).args[0].callback).to.be.called;
  877. });
  878. });
  879. describe("#installRepoVersionConfirmation()", function () {
  880. before(function () {
  881. sinon.stub(controller, 'installRepoVersion', Em.K);
  882. });
  883. after(function () {
  884. controller.installRepoVersion.restore();
  885. });
  886. it("show popup", function () {
  887. var repo = Em.Object.create({'displayName': 'HDP-2.2'});
  888. var popup = controller.installRepoVersionConfirmation(repo);
  889. popup.onPrimary();
  890. expect(controller.installRepoVersion.calledWith(repo)).to.be.true;
  891. });
  892. });
  893. describe("#installRepoVersion()", function () {
  894. before(function () {
  895. sinon.stub(App.ajax, 'send', Em.K);
  896. });
  897. after(function () {
  898. App.ajax.send.restore();
  899. });
  900. it("make ajax call", function () {
  901. var repo = Em.Object.create({
  902. stackVersionType: 'HDP',
  903. stackVersionNumber: '2.2',
  904. repositoryVersion: '2.2.1',
  905. repoId: 1
  906. });
  907. controller.installRepoVersion(repo);
  908. expect(App.ajax.send.calledOnce).to.be.true;
  909. });
  910. });
  911. describe("#installRepoVersionSuccess()", function() {
  912. var mock = Em.Object.create({
  913. id: 1,
  914. defaultStatus: 'INIT',
  915. stackVersion: {}
  916. });
  917. before(function () {
  918. sinon.spy(mock, 'set');
  919. sinon.stub(App.db, 'set', Em.K);
  920. sinon.stub(App.clusterStatus, 'setClusterStatus', Em.K);
  921. sinon.stub(App.RepositoryVersion, 'find').returns(mock);
  922. });
  923. after(function () {
  924. App.db.set.restore();
  925. App.clusterStatus.setClusterStatus.restore();
  926. App.RepositoryVersion.find.restore();
  927. });
  928. it("", function() {
  929. controller.installRepoVersionSuccess({Requests: {id: 1}}, {}, {id: 1});
  930. expect(App.db.set.calledWith('repoVersionInstall', 'id', [1])).to.be.true;
  931. expect(App.clusterStatus.setClusterStatus.calledOnce).to.be.true;
  932. expect(App.RepositoryVersion.find.calledWith(1)).to.be.true;
  933. expect(App.RepositoryVersion.find(1).get('defaultStatus')).to.equal('INSTALLING');
  934. expect(App.RepositoryVersion.find(1).get('stackVersion.state')).to.equal('INSTALLING');
  935. });
  936. });
  937. describe("#setUpgradeItemStatus()", function () {
  938. before(function () {
  939. sinon.stub(App.ajax, 'send', function () {
  940. return {
  941. done: function (callback) {
  942. callback();
  943. }
  944. }
  945. });
  946. });
  947. after(function () {
  948. App.ajax.send.restore();
  949. });
  950. it("", function () {
  951. var item = Em.Object.create({
  952. request_id: 1,
  953. stage_id: 1,
  954. group_id: 1
  955. });
  956. controller.setUpgradeItemStatus(item, 'PENDING');
  957. expect(App.ajax.send.getCall(0).args[0].data).to.eql({upgradeId: 1, itemId: 1, groupId: 1, status: 'PENDING'});
  958. expect(App.ajax.send.getCall(0).args[0].name).to.eql('admin.upgrade.upgradeItem.setState');
  959. expect(App.ajax.send.getCall(0).args[0].sender).to.eql(controller);
  960. expect(App.ajax.send.getCall(0).args[0].callback).to.be.called;
  961. expect(item.get('status')).to.equal('PENDING');
  962. });
  963. });
  964. describe("#prepareRepoForSaving()", function () {
  965. it("prepare date for saving", function () {
  966. var repo = Em.Object.create({
  967. operatingSystems: [
  968. Em.Object.create({
  969. osType: "redhat6",
  970. isDisabled: Ember.computed.not('isSelected'),
  971. repositories: [Em.Object.create({
  972. "baseUrl": "111121",
  973. "repoId": "HDP-2.2",
  974. "repoName": "HDP",
  975. hasError: false
  976. }),
  977. Em.Object.create({
  978. "baseUrl": "1",
  979. "repoId": "HDP-UTILS-1.1.0.20",
  980. "repoName": "HDP-UTILS",
  981. hasError: false
  982. })]
  983. })
  984. ]
  985. });
  986. var result = {
  987. "operating_systems": [
  988. {
  989. "OperatingSystems": {
  990. "os_type": "redhat6"
  991. },
  992. "repositories": [
  993. {
  994. "Repositories": {
  995. "base_url": "111121",
  996. "repo_id": "HDP-2.2",
  997. "repo_name": "HDP"
  998. }
  999. },
  1000. {
  1001. "Repositories": {
  1002. "base_url": "1",
  1003. "repo_id": "HDP-UTILS-1.1.0.20",
  1004. "repo_name": "HDP-UTILS"
  1005. }
  1006. }
  1007. ]
  1008. }
  1009. ]};
  1010. expect(controller.prepareRepoForSaving(repo)).to.eql(result);
  1011. });
  1012. });
  1013. describe("#getStackVersionNumber()", function(){
  1014. it("get stack version number", function(){
  1015. var repo = Em.Object.create({
  1016. "stackVersionType": 'HDP',
  1017. "stackVersion": '2.3',
  1018. "repositoryVersion": '2.2.1'
  1019. });
  1020. var stackVersion = controller.getStackVersionNumber(repo);
  1021. expect(stackVersion).to.equal('2.3');
  1022. });
  1023. it("get default stack version number", function(){
  1024. App.set('currentStackVersion', '1.2.3');
  1025. var repo = Em.Object.create({
  1026. "stackVersionType": 'HDP',
  1027. "repositoryVersion": '2.2.1'
  1028. });
  1029. var stackVersion = controller.getStackVersionNumber(repo);
  1030. expect(stackVersion).to.equal('1.2.3');
  1031. });
  1032. });
  1033. describe("#saveRepoOS()", function() {
  1034. before(function(){
  1035. this.mock = sinon.stub(controller, 'validateRepoVersions');
  1036. sinon.stub(controller, 'prepareRepoForSaving', Em.K);
  1037. sinon.stub(App.ajax, 'send').returns({success: Em.K});
  1038. });
  1039. after(function(){
  1040. this.mock.restore();
  1041. controller.prepareRepoForSaving.restore();
  1042. App.ajax.send.restore();
  1043. });
  1044. it("validation errors present", function() {
  1045. this.mock.returns({
  1046. done: function(callback) {callback([1]);}
  1047. });
  1048. controller.saveRepoOS(Em.Object.create({repoVersionId: 1}), true);
  1049. expect(controller.validateRepoVersions.calledWith(Em.Object.create({repoVersionId: 1}), true)).to.be.true;
  1050. expect(controller.prepareRepoForSaving.called).to.be.false;
  1051. expect(App.ajax.send.called).to.be.false;
  1052. });
  1053. it("no validation errors", function() {
  1054. this.mock.returns({
  1055. done: function(callback) {callback([]);}
  1056. });
  1057. controller.saveRepoOS(Em.Object.create({repoVersionId: 1}), true);
  1058. expect(controller.validateRepoVersions.calledWith(Em.Object.create({repoVersionId: 1}), true)).to.be.true;
  1059. expect(controller.prepareRepoForSaving.calledWith(Em.Object.create({repoVersionId: 1}))).to.be.true;
  1060. });
  1061. });
  1062. describe("#validateRepoVersions()", function () {
  1063. before(function () {
  1064. sinon.stub(App.ajax, 'send').returns({success: Em.K, error: Em.K});
  1065. });
  1066. after(function () {
  1067. App.ajax.send.restore();
  1068. });
  1069. it("skip validation", function () {
  1070. controller.validateRepoVersions(Em.Object.create({repoVersionId: 1}), true);
  1071. expect(App.ajax.send.called).to.be.false;
  1072. });
  1073. it("do validation", function () {
  1074. var repo = Em.Object.create({
  1075. repoVersionId: 1,
  1076. operatingSystems: [
  1077. Em.Object.create({
  1078. isSelected: true,
  1079. repositories: [
  1080. Em.Object.create()
  1081. ]
  1082. })
  1083. ]
  1084. });
  1085. controller.validateRepoVersions(repo, false);
  1086. expect(App.ajax.send.calledOnce).to.be.true;
  1087. });
  1088. });
  1089. describe("#showProgressPopup()", function () {
  1090. var mock = {
  1091. initPopup: Em.K
  1092. };
  1093. before(function () {
  1094. sinon.stub(App.router, 'get').withArgs('highAvailabilityProgressPopupController').returns(mock);
  1095. sinon.spy(mock, 'initPopup');
  1096. });
  1097. after(function () {
  1098. App.router.get.restore();
  1099. mock.initPopup.restore();
  1100. });
  1101. it("", function () {
  1102. controller.showProgressPopup(Em.Object.create());
  1103. expect(mock.initPopup.calledOnce).to.be.true;
  1104. });
  1105. });
  1106. describe("#getUrl()", function() {
  1107. beforeEach(function(){
  1108. controller.reopen({
  1109. realStackUrl: 'realStackUrl',
  1110. realRepoUrl: 'realRepoUrl',
  1111. realUpdateUrl: 'realUpdateUrl'
  1112. });
  1113. });
  1114. it("full load is true, stack is null", function() {
  1115. expect(controller.getUrl(null, true)).to.equal('realRepoUrl');
  1116. });
  1117. it("full load is true, stack is valid", function() {
  1118. expect(controller.getUrl({}, true)).to.equal('realStackUrl');
  1119. });
  1120. it("full load is false, stack is valid", function() {
  1121. expect(controller.getUrl({}, false)).to.equal('realUpdateUrl');
  1122. });
  1123. });
  1124. describe("#loadStackVersionsToModel()", function () {
  1125. before(function () {
  1126. sinon.stub(App.HttpClient, 'get');
  1127. });
  1128. after(function () {
  1129. App.HttpClient.get.restore();
  1130. });
  1131. it("", function () {
  1132. controller.loadStackVersionsToModel();
  1133. expect(App.HttpClient.get.calledOnce).to.be.true;
  1134. });
  1135. });
  1136. describe("#loadRepoVersionsToModel()", function () {
  1137. before(function () {
  1138. sinon.stub(App.HttpClient, 'get');
  1139. });
  1140. after(function () {
  1141. App.HttpClient.get.restore();
  1142. });
  1143. it("", function () {
  1144. controller.loadRepoVersionsToModel();
  1145. expect(App.HttpClient.get.calledOnce).to.be.true;
  1146. });
  1147. });
  1148. describe('#currentVersionObserver()', function () {
  1149. var cases = [
  1150. {
  1151. stackVersionType: 'HDP',
  1152. repoVersion: '2.2.1.1.0-1',
  1153. isStormMetricsSupported: false,
  1154. title: 'HDP < 2.2.2'
  1155. },
  1156. {
  1157. stackVersionType: 'HDP',
  1158. repoVersion: '2.2.2.1.0-1',
  1159. isStormMetricsSupported: true,
  1160. title: 'HDP 2.2.2'
  1161. },
  1162. {
  1163. stackVersionType: 'HDP',
  1164. repoVersion: '2.2.3.1.0-1',
  1165. isStormMetricsSupported: true,
  1166. title: 'HDP > 2.2.2'
  1167. },
  1168. {
  1169. stackVersionType: 'BIGTOP',
  1170. repoVersion: '0.8.1.1.0-1',
  1171. isStormMetricsSupported: true,
  1172. title: 'not HDP'
  1173. }
  1174. ];
  1175. afterEach(function () {
  1176. App.RepositoryVersion.find.restore();
  1177. });
  1178. cases.forEach(function (item) {
  1179. it(item.title, function () {
  1180. sinon.stub(App.RepositoryVersion, 'find').returns([
  1181. Em.Object.create({
  1182. status: 'CURRENT',
  1183. stackVersionType: item.stackVersionType
  1184. })
  1185. ]);
  1186. controller.set('currentVersion', {
  1187. repository_version: item.repoVersion
  1188. });
  1189. expect(App.get('isStormMetricsSupported')).to.equal(item.isStormMetricsSupported);
  1190. });
  1191. });
  1192. });
  1193. describe('#updateFinalize', function () {
  1194. beforeEach(function() {
  1195. sinon.stub($, 'ajax', Em.K);
  1196. controller.set('isFinalizeItem', true);
  1197. });
  1198. afterEach(function () {
  1199. $.ajax.restore();
  1200. });
  1201. it('should do ajax-request', function () {
  1202. sinon.stub(App, 'get').withArgs('upgradeState').returns('HOLDING');
  1203. controller.updateFinalize();
  1204. App.get.restore();
  1205. expect($.ajax.calledOnce).to.be.true;
  1206. });
  1207. it('shouldn\'t do ajax-request', function () {
  1208. sinon.stub(App, 'get').withArgs('upgradeState').returns('HOLDING_TIMEDOUT');
  1209. controller.updateFinalize();
  1210. App.get.restore();
  1211. expect(controller.get('isFinalizeItem')).to.be.false;
  1212. expect($.ajax.calledOnce).to.be.false;
  1213. });
  1214. });
  1215. describe('#updateFinalizeSuccessCallback', function () {
  1216. it('data exists and Finalize should be true', function() {
  1217. var data = {
  1218. items: [
  1219. {
  1220. upgrade_groups: [
  1221. {
  1222. upgrade_items: [
  1223. {
  1224. UpgradeItem: {
  1225. context: controller.get('finalizeContext'),
  1226. status: "HOLDING"
  1227. }
  1228. }
  1229. ]
  1230. }
  1231. ]
  1232. }
  1233. ]
  1234. };
  1235. controller.set('isFinalizeItem', false);
  1236. controller.updateFinalizeSuccessCallback(data);
  1237. expect(controller.get('isFinalizeItem')).to.be.true;
  1238. });
  1239. it('data exists and Finalize should be false', function() {
  1240. var data = {
  1241. upgrade_groups: [
  1242. {
  1243. upgrade_items: [
  1244. {
  1245. UpgradeItem: {
  1246. context: '!@#$%^&',
  1247. status: "HOLDING"
  1248. }
  1249. }
  1250. ]
  1251. }
  1252. ]
  1253. };
  1254. controller.set('isFinalizeItem', true);
  1255. controller.updateFinalizeSuccessCallback(data);
  1256. expect(controller.get('isFinalizeItem')).to.be.false;
  1257. });
  1258. it('data doesn\'t exist', function() {
  1259. var data = null;
  1260. controller.set('isFinalizeItem', true);
  1261. controller.updateFinalizeSuccessCallback(data);
  1262. expect(controller.get('isFinalizeItem')).to.be.false;
  1263. });
  1264. });
  1265. describe('#updateFinalizeErrorCallback', function () {
  1266. it('should set isFinalizeItem to false', function () {
  1267. controller.set('isFinalizeItem', true);
  1268. controller.updateFinalizeErrorCallback();
  1269. expect(controller.get('isFinalizeItem')).to.be.false;
  1270. });
  1271. });
  1272. describe("#suspendUpgrade()", function() {
  1273. beforeEach(function () {
  1274. sinon.stub(controller, 'abortUpgrade').returns({
  1275. done: function (callback) {
  1276. callback();
  1277. }
  1278. });
  1279. sinon.stub(controller, 'setDBProperty', Em.K);
  1280. sinon.stub(App.clusterStatus, 'setClusterStatus', Em.K);
  1281. });
  1282. afterEach(function () {
  1283. controller.abortUpgrade.restore();
  1284. controller.setDBProperty.restore();
  1285. App.clusterStatus.setClusterStatus.restore();
  1286. });
  1287. it("", function() {
  1288. controller.suspendUpgrade();
  1289. expect(controller.abortUpgrade.calledOnce).to.be.true;
  1290. expect(App.get('upgradeState')).to.equal('ABORTED');
  1291. expect(controller.setDBProperty.calledWith('upgradeState', 'ABORTED')).to.be.true;
  1292. expect(App.clusterStatus.setClusterStatus.calledOnce).to.be.true;
  1293. });
  1294. });
  1295. describe("#resumeUpgrade()", function() {
  1296. beforeEach(function () {
  1297. sinon.stub(controller, 'retryUpgrade').returns({
  1298. done: function (callback) {
  1299. callback();
  1300. }
  1301. });
  1302. sinon.stub(controller, 'setDBProperty', Em.K);
  1303. sinon.stub(App.clusterStatus, 'setClusterStatus', Em.K);
  1304. });
  1305. afterEach(function () {
  1306. controller.retryUpgrade.restore();
  1307. controller.setDBProperty.restore();
  1308. App.clusterStatus.setClusterStatus.restore();
  1309. });
  1310. it("", function() {
  1311. controller.resumeUpgrade();
  1312. expect(controller.retryUpgrade.calledOnce).to.be.true;
  1313. expect(App.get('upgradeState')).to.equal('PENDING');
  1314. expect(controller.setDBProperty.calledWith('upgradeState', 'PENDING')).to.be.true;
  1315. expect(App.clusterStatus.setClusterStatus.calledOnce).to.be.true;
  1316. });
  1317. });
  1318. describe("#runUpgradeMethodChecks()", function() {
  1319. beforeEach(function () {
  1320. sinon.stub(controller, 'runPreUpgradeCheckOnly');
  1321. });
  1322. afterEach(function () {
  1323. controller.runPreUpgradeCheckOnly.restore();
  1324. controller.get('upgradeMethods').setEach('allowed', true);
  1325. });
  1326. it("no allowed upgrade methods", function () {
  1327. controller.get('upgradeMethods').setEach('allowed', false);
  1328. controller.runUpgradeMethodChecks();
  1329. expect(controller.runPreUpgradeCheckOnly.called).to.be.false;
  1330. });
  1331. it("Rolling method allowed", function () {
  1332. controller.get('upgradeMethods').setEach('allowed', true);
  1333. controller.runUpgradeMethodChecks(Em.Object.create({
  1334. repositoryVersion: 'v1',
  1335. displayName: 'V1'
  1336. }));
  1337. expect(controller.runPreUpgradeCheckOnly.calledWith({
  1338. value: 'v1',
  1339. label: 'V1',
  1340. type: 'ROLLING'
  1341. })).to.be.true;
  1342. });
  1343. });
  1344. describe("#restoreLastUpgrade()", function () {
  1345. beforeEach(function () {
  1346. sinon.stub(App.RepositoryVersion, 'find').returns([Em.Object.create({
  1347. repositoryVersion: '1',
  1348. displayName: 'HDP-1'
  1349. })]);
  1350. sinon.stub(controller, 'setDBProperties');
  1351. sinon.stub(controller, 'loadRepoVersionsToModel', function () {
  1352. return {
  1353. done: function (callback) {
  1354. callback();
  1355. }
  1356. }
  1357. });
  1358. sinon.stub(controller, 'setDBProperty');
  1359. sinon.stub(controller, 'initDBProperties');
  1360. sinon.stub(controller, 'loadUpgradeData');
  1361. });
  1362. afterEach(function () {
  1363. App.RepositoryVersion.find.restore();
  1364. controller.setDBProperties.restore();
  1365. controller.loadRepoVersionsToModel.restore();
  1366. controller.setDBProperty.restore();
  1367. controller.initDBProperties.restore();
  1368. controller.loadUpgradeData.restore();
  1369. });
  1370. it("", function () {
  1371. var data = {
  1372. Upgrade: {
  1373. request_id: 1,
  1374. direction: 'UPGRADE',
  1375. request_status: 'PENDING',
  1376. upgrade_type: 'ROLLING',
  1377. downgrade_allowed: true,
  1378. skip_failures: true,
  1379. skip_service_check_failures: true,
  1380. to_version: '1'
  1381. }
  1382. };
  1383. controller.restoreLastUpgrade(data);
  1384. expect(controller.setDBProperties.getCall(0).args[0]).to.eql({
  1385. upgradeId: 1,
  1386. isDowngrade: false,
  1387. upgradeState: 'PENDING',
  1388. upgradeType: "ROLLING",
  1389. downgradeAllowed: true,
  1390. upgradeTypeDisplayName: Em.I18n.t('admin.stackVersions.version.upgrade.upgradeOptions.RU.title'),
  1391. failuresTolerance: Em.Object.create({
  1392. skipComponentFailures: true,
  1393. skipSCFailures: true
  1394. })
  1395. });
  1396. expect(controller.loadRepoVersionsToModel.calledOnce).to.be.true;
  1397. expect(controller.setDBProperty.calledWith('upgradeVersion', 'HDP-1')).to.be.true;
  1398. expect(controller.initDBProperties.calledOnce).to.be.true;
  1399. expect(controller.loadUpgradeData.calledWith(true)).to.be.true;
  1400. });
  1401. });
  1402. describe("#getServiceCheckItemSuccessCallback()", function() {
  1403. var testCases = [
  1404. {
  1405. title: 'no tasks',
  1406. data: {
  1407. tasks: []
  1408. },
  1409. expected: {
  1410. slaveComponentStructuredInfo: null,
  1411. serviceCheckFailuresServicenames: []
  1412. }
  1413. },
  1414. {
  1415. title: 'no structured_out property',
  1416. data: {
  1417. tasks: [
  1418. {
  1419. Tasks: {}
  1420. }
  1421. ]
  1422. },
  1423. expected: {
  1424. slaveComponentStructuredInfo: null,
  1425. serviceCheckFailuresServicenames: []
  1426. }
  1427. },
  1428. {
  1429. title: 'no failures',
  1430. data: {
  1431. tasks: [
  1432. {
  1433. Tasks: {
  1434. structured_out: {}
  1435. }
  1436. }
  1437. ]
  1438. },
  1439. expected: {
  1440. slaveComponentStructuredInfo: null,
  1441. serviceCheckFailuresServicenames: []
  1442. }
  1443. },
  1444. {
  1445. title: 'service check failures',
  1446. data: {
  1447. tasks: [
  1448. {
  1449. Tasks: {
  1450. structured_out: {
  1451. failures: {
  1452. service_check: ['HDSF', 'YARN']
  1453. }
  1454. }
  1455. }
  1456. }
  1457. ]
  1458. },
  1459. expected: {
  1460. slaveComponentStructuredInfo: {
  1461. hosts: [],
  1462. host_detail: {}
  1463. },
  1464. serviceCheckFailuresServicenames: ['HDSF', 'YARN']
  1465. }
  1466. },
  1467. {
  1468. title: 'host-component failures',
  1469. data: {
  1470. tasks: [
  1471. {
  1472. Tasks: {
  1473. structured_out: {
  1474. failures: {
  1475. service_check: ['HDSF'],
  1476. host_component: {
  1477. "host1": [
  1478. {
  1479. component: "DATANODE",
  1480. service: 'HDFS'
  1481. }
  1482. ]
  1483. }
  1484. }
  1485. }
  1486. }
  1487. }
  1488. ]
  1489. },
  1490. expected: {
  1491. slaveComponentStructuredInfo: {
  1492. hosts: ['host1'],
  1493. host_detail: {
  1494. "host1": [
  1495. {
  1496. component: "DATANODE",
  1497. service: 'HDFS'
  1498. }
  1499. ]
  1500. }
  1501. },
  1502. serviceCheckFailuresServicenames: ['HDSF']
  1503. }
  1504. }
  1505. ];
  1506. testCases.forEach(function(test) {
  1507. it(test.title, function() {
  1508. controller.set('slaveComponentStructuredInfo', null);
  1509. controller.set('serviceCheckFailuresServicenames', []);
  1510. controller.getServiceCheckItemSuccessCallback(test.data);
  1511. expect(controller.get('serviceCheckFailuresServicenames')).eql(test.expected.serviceCheckFailuresServicenames);
  1512. expect(controller.get('slaveComponentStructuredInfo')).eql(test.expected.slaveComponentStructuredInfo);
  1513. });
  1514. });
  1515. });
  1516. describe("#getSlaveComponentItemSuccessCallback()", function () {
  1517. var testCases = [
  1518. {
  1519. title: 'no tasks',
  1520. data: {
  1521. tasks: []
  1522. },
  1523. expected: {
  1524. slaveComponentStructuredInfo: null
  1525. }
  1526. },
  1527. {
  1528. title: 'structured_out property absent',
  1529. data: {
  1530. tasks: [
  1531. {
  1532. Tasks: {}
  1533. }
  1534. ]
  1535. },
  1536. expected: {
  1537. slaveComponentStructuredInfo: null
  1538. }
  1539. },
  1540. {
  1541. title: 'structured_out property present',
  1542. data: {
  1543. tasks: [
  1544. {
  1545. Tasks: {
  1546. "structured_out" : {
  1547. "hosts" : [
  1548. "host1"
  1549. ],
  1550. "host_detail" : {
  1551. "host1" : [
  1552. {
  1553. "service" : "FLUME",
  1554. "component" : "FLUME_HANDLER"
  1555. }
  1556. ]
  1557. }
  1558. }
  1559. }
  1560. }
  1561. ]
  1562. },
  1563. expected: {
  1564. slaveComponentStructuredInfo: {
  1565. "hosts" : [
  1566. "host1"
  1567. ],
  1568. "host_detail" : {
  1569. "host1" : [
  1570. {
  1571. "service" : "FLUME",
  1572. "component" : "FLUME_HANDLER"
  1573. }
  1574. ]
  1575. }
  1576. }
  1577. }
  1578. }
  1579. ];
  1580. testCases.forEach(function (test) {
  1581. it(test.title, function () {
  1582. controller.set('slaveComponentStructuredInfo', null);
  1583. controller.getSlaveComponentItemSuccessCallback(test.data);
  1584. expect(controller.get('slaveComponentStructuredInfo')).eql(test.expected.slaveComponentStructuredInfo);
  1585. });
  1586. });
  1587. });
  1588. describe('#getConfigsWarnings', function () {
  1589. var cases = [
  1590. {
  1591. configs: [],
  1592. title: 'no warning'
  1593. },
  1594. {
  1595. configsMergeWarning: {},
  1596. configs: [],
  1597. title: 'empty data'
  1598. },
  1599. {
  1600. configsMergeWarning: {
  1601. UpgradeChecks: {}
  1602. },
  1603. configs: [],
  1604. title: 'incomplete data'
  1605. },
  1606. {
  1607. configsMergeWarning: {
  1608. UpgradeChecks: {
  1609. failed_detail: {}
  1610. }
  1611. },
  1612. configs: [],
  1613. title: 'invalid data'
  1614. },
  1615. {
  1616. configsMergeWarning: {
  1617. UpgradeChecks: {
  1618. failed_detail: []
  1619. }
  1620. },
  1621. configs: [],
  1622. title: 'empty configs array'
  1623. },
  1624. {
  1625. configsMergeWarning: {
  1626. UpgradeChecks: {
  1627. status: 'FAIL',
  1628. failed_detail: [
  1629. {
  1630. type: 't0',
  1631. property: 'p0',
  1632. current: 'c0',
  1633. new_stack_value: 'n0',
  1634. result_value: 'r0'
  1635. },
  1636. {
  1637. type: 't1',
  1638. property: 'p1',
  1639. current: 'c1',
  1640. new_stack_value: 'n1'
  1641. },
  1642. {
  1643. type: 't2',
  1644. property: 'p2',
  1645. current: 'c2',
  1646. result_value: 'r2'
  1647. }
  1648. ]
  1649. }
  1650. },
  1651. configs: [],
  1652. title: 'not a warning'
  1653. },
  1654. {
  1655. configsMergeWarning: {
  1656. UpgradeChecks: {
  1657. status: 'WARNING',
  1658. failed_detail: [
  1659. {
  1660. type: 't0',
  1661. property: 'p0',
  1662. current: 'c0',
  1663. new_stack_value: 'n0',
  1664. result_value: 'r0'
  1665. },
  1666. {
  1667. type: 't1',
  1668. property: 'p1',
  1669. current: 'c1',
  1670. new_stack_value: 'n1'
  1671. },
  1672. {
  1673. type: 't2',
  1674. property: 'p2',
  1675. current: 'c2',
  1676. result_value: 'r2'
  1677. }
  1678. ]
  1679. }
  1680. },
  1681. configs: [
  1682. {
  1683. type: 't0',
  1684. name: 'p0',
  1685. currentValue: 'c0',
  1686. recommendedValue: 'n0',
  1687. isDeprecated: false,
  1688. resultingValue: 'r0',
  1689. willBeRemoved: false
  1690. },
  1691. {
  1692. type: 't1',
  1693. name: 'p1',
  1694. currentValue: 'c1',
  1695. recommendedValue: 'n1',
  1696. isDeprecated: false,
  1697. resultingValue: Em.I18n.t('popup.clusterCheck.Upgrade.configsMerge.willBeRemoved'),
  1698. willBeRemoved: true
  1699. },
  1700. {
  1701. type: 't2',
  1702. name: 'p2',
  1703. currentValue: 'c2',
  1704. recommendedValue: Em.I18n.t('popup.clusterCheck.Upgrade.configsMerge.deprecated'),
  1705. isDeprecated: true,
  1706. resultingValue: 'r2',
  1707. willBeRemoved: false
  1708. }
  1709. ],
  1710. title: 'normal case'
  1711. }
  1712. ];
  1713. cases.forEach(function (item) {
  1714. it(item.title, function () {
  1715. expect(controller.getConfigsWarnings(item.configsMergeWarning)).to.eql(item.configs);
  1716. });
  1717. });
  1718. });
  1719. describe('#runPreUpgradeCheckOnly', function () {
  1720. var appGetMock,
  1721. upgradeMethods = controller.get('upgradeMethods'),
  1722. cases = [
  1723. {
  1724. supportsPreUpgradeCheck: false,
  1725. ru: {
  1726. isCheckComplete: true,
  1727. isCheckRequestInProgress: false,
  1728. action: 'a'
  1729. },
  1730. eu: {
  1731. isCheckComplete: true,
  1732. isCheckRequestInProgress: false,
  1733. action: 'a'
  1734. },
  1735. ajaxCallCount: 0,
  1736. runningCheckRequestsLength: 0,
  1737. title: 'pre-upgrade checks not supported'
  1738. },
  1739. {
  1740. supportsPreUpgradeCheck: true,
  1741. ru: {
  1742. isCheckComplete: false,
  1743. isCheckRequestInProgress: true,
  1744. action: ''
  1745. },
  1746. eu: {
  1747. isCheckComplete: true,
  1748. isCheckRequestInProgress: false,
  1749. action: 'a'
  1750. },
  1751. ajaxCallCount: 1,
  1752. type: 'ROLLING',
  1753. runningCheckRequestsLength: 1,
  1754. title: 'rolling upgrade'
  1755. },
  1756. {
  1757. supportsPreUpgradeCheck: true,
  1758. ru: {
  1759. isCheckComplete: true,
  1760. isCheckRequestInProgress: false,
  1761. action: 'a'
  1762. },
  1763. eu: {
  1764. isCheckComplete: false,
  1765. isCheckRequestInProgress: true,
  1766. action: ''
  1767. },
  1768. ajaxCallCount: 1,
  1769. type: 'NON_ROLLING',
  1770. runningCheckRequestsLength: 1,
  1771. title: 'express upgrade'
  1772. }
  1773. ];
  1774. beforeEach(function () {
  1775. appGetMock = sinon.stub(App, 'get');
  1776. controller.get('runningCheckRequests').clear();
  1777. upgradeMethods.forEach(function (method) {
  1778. method.setProperties({
  1779. isCheckComplete: true,
  1780. isCheckRequestInProgress: false,
  1781. action: 'a'
  1782. });
  1783. });
  1784. sinon.stub(App.ajax, 'send').returns({});
  1785. });
  1786. afterEach(function () {
  1787. appGetMock.restore();
  1788. App.ajax.send.restore();
  1789. });
  1790. cases.forEach(function (item) {
  1791. it(item.title, function () {
  1792. var runningCheckRequests = controller.get('runningCheckRequests');
  1793. appGetMock.returns(item.supportsPreUpgradeCheck);
  1794. controller.runPreUpgradeCheckOnly({
  1795. type: item.type
  1796. });
  1797. expect(upgradeMethods.findProperty('type', 'ROLLING').getProperties('isCheckComplete', 'isCheckRequestInProgress', 'action')).to.eql(item.ru);
  1798. expect(upgradeMethods.findProperty('type', 'NON_ROLLING').getProperties('isCheckComplete', 'isCheckRequestInProgress', 'action')).to.eql(item.eu);
  1799. expect(App.ajax.send.callCount).to.equal(item.ajaxCallCount);
  1800. expect(runningCheckRequests).to.have.length(item.runningCheckRequestsLength);
  1801. if (item.runningCheckRequestsLength) {
  1802. expect(runningCheckRequests[0].type).to.equal(item.type);
  1803. }
  1804. });
  1805. });
  1806. });
  1807. describe("#openConfigsInNewWindow()", function () {
  1808. var mock = {
  1809. document: {
  1810. write: function () {}
  1811. },
  1812. focus: function () {}
  1813. };
  1814. before(function(){
  1815. sinon.stub(window, 'open', function () {
  1816. return mock;
  1817. });
  1818. sinon.spy(mock.document, 'write');
  1819. sinon.spy(mock, 'focus');
  1820. });
  1821. after(function(){
  1822. window.open.restore();
  1823. });
  1824. it("should open window and write table to it", function () {
  1825. controller.openConfigsInNewWindow({
  1826. context: [
  1827. {
  1828. type: 'type1',
  1829. name: 'name1',
  1830. currentValue: 'currentValue1',
  1831. recommendedValue: 'recommendedValue1',
  1832. resultingValue: 'resultingValue1'
  1833. },
  1834. {
  1835. type: 'type2',
  1836. name: 'name2',
  1837. currentValue: 'currentValue2',
  1838. recommendedValue: 'recommendedValue2',
  1839. resultingValue: 'resultingValue2'
  1840. }
  1841. ]
  1842. });
  1843. expect(window.open.calledOnce).to.be.true;
  1844. expect(mock.document.write.calledWith('<table style="text-align: left;"><thead><tr>' +
  1845. '<th>' + Em.I18n.t('popup.clusterCheck.Upgrade.configsMerge.configType') + '</th>' +
  1846. '<th>' + Em.I18n.t('popup.clusterCheck.Upgrade.configsMerge.propertyName') + '</th>' +
  1847. '<th>' + Em.I18n.t('popup.clusterCheck.Upgrade.configsMerge.currentValue') + '</th>' +
  1848. '<th>' + Em.I18n.t('popup.clusterCheck.Upgrade.configsMerge.recommendedValue') + '</th>' +
  1849. '<th>' + Em.I18n.t('popup.clusterCheck.Upgrade.configsMerge.resultingValue') + '</th>' +
  1850. '</tr></thead><tbody>' +
  1851. '<tr>' +
  1852. '<td>' + 'type1' + '</td>' +
  1853. '<td>' + 'name1' + '</td>' +
  1854. '<td>' + 'currentValue1' + '</td>' +
  1855. '<td>' + 'recommendedValue1' + '</td>' +
  1856. '<td>' + 'resultingValue1' + '</td>' +
  1857. '</tr>' +
  1858. '<tr>' +
  1859. '<td>' + 'type2' + '</td>' +
  1860. '<td>' + 'name2' + '</td>' +
  1861. '<td>' + 'currentValue2' + '</td>' +
  1862. '<td>' + 'recommendedValue2' + '</td>' +
  1863. '<td>' + 'resultingValue2' + '</td>' +
  1864. '</tr></tbody></table>')).to.be.true;
  1865. expect(mock.focus.calledOnce).to.be.true;
  1866. });
  1867. });
  1868. });