stack_and_upgrade_controller_test.js 8.1 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271
  1. /**
  2. * Licensed to the Apache Software Foundation (ASF) under one
  3. * or more contributor license agreements. See the NOTICE file
  4. * distributed with this work for additional information
  5. * regarding copyright ownership. The ASF licenses this file
  6. * to you under the Apache License, Version 2.0 (the
  7. * "License"); you may not use this file except in compliance
  8. * with the License. You may obtain a copy of the License at
  9. *
  10. * http://www.apache.org/licenses/LICENSE-2.0
  11. *
  12. * Unless required by applicable law or agreed to in writing, software
  13. * distributed under the License is distributed on an "AS IS" BASIS,
  14. * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  15. * See the License for the specific language governing permissions and
  16. * limitations under the License.
  17. */
  18. var App = require('app');
  19. var controller;
  20. require('controllers/main/admin/stack_and_upgrade_controller');
  21. describe('App.MainAdminStackAndUpgradeController', function() {
  22. beforeEach(function() {
  23. controller = App.MainAdminStackAndUpgradeController.create({});
  24. });
  25. describe("#services", function () {
  26. before(function () {
  27. sinon.stub(App.StackService, 'find').returns([
  28. Em.Object.create({serviceName: 'S1', isInstalled: false}),
  29. Em.Object.create({serviceName: 'S2', isInstalled: false})
  30. ]);
  31. sinon.stub(App.Service, 'find').returns([
  32. Em.Object.create({serviceName: 'S1'})
  33. ]);
  34. });
  35. after(function () {
  36. App.StackService.find.restore();
  37. App.Service.find.restore();
  38. });
  39. it("", function () {
  40. controller.propertyDidChange('services');
  41. expect(controller.get('services')).to.eql([
  42. Em.Object.create({serviceName: 'S1', isInstalled: true}),
  43. Em.Object.create({serviceName: 'S2', isInstalled: false})
  44. ])
  45. });
  46. });
  47. describe("#goToAddService()" , function() {
  48. beforeEach(function() {
  49. sinon.stub(App.get('router'), 'transitionTo', Em.K);
  50. });
  51. afterEach(function() {
  52. App.get('router').transitionTo.restore();
  53. });
  54. it("routes to Add Service Wizard", function() {
  55. controller.goToAddService({context: "serviceName"});
  56. expect(App.get('router').transitionTo.calledOnce).to.be.true;
  57. expect(controller.get('serviceToInstall')).to.be.equal("serviceName");
  58. });
  59. });
  60. describe("#loadVersionsInfo()", function() {
  61. before(function () {
  62. sinon.stub(App.ajax, 'send', Em.K);
  63. });
  64. after(function () {
  65. App.ajax.send.restore();
  66. });
  67. it("make ajax call", function() {
  68. controller.loadVersionsInfo();
  69. expect(App.ajax.send.getCall(0).args[0]).to.eql({
  70. name: 'admin.stack_versions.all',
  71. sender: controller,
  72. data: {},
  73. success: 'loadVersionsInfoSuccessCallback'
  74. })
  75. });
  76. });
  77. describe("#loadVersionsInfoSuccessCallback()", function() {
  78. beforeEach(function(){
  79. sinon.stub(controller, 'parseVersionsData', function (data) {
  80. return data;
  81. });
  82. });
  83. afterEach(function(){
  84. controller.parseVersionsData.restore();
  85. });
  86. it("target version installed and higher than current", function() {
  87. var data = [
  88. {
  89. "state": "CURRENT",
  90. "repository_version": "2.2.0.1-885"
  91. },
  92. {
  93. "state": "INSTALLED",
  94. "repository_version": "2.2.1.1-885"
  95. }
  96. ];
  97. controller.loadVersionsInfoSuccessCallback(data);
  98. expect(controller.get('currentVersion')).to.eql({
  99. "state": "CURRENT",
  100. "repository_version": "2.2.0.1-885"
  101. });
  102. expect(controller.get('targetVersions')).to.eql([{
  103. "state": "INSTALLED",
  104. "repository_version": "2.2.1.1-885"
  105. }]);
  106. });
  107. it("target version installed and lower than current", function() {
  108. var data = [
  109. {
  110. "state": "CURRENT",
  111. "repository_version": "2.2.0.1-885"
  112. },
  113. {
  114. "state": "INSTALLED",
  115. "repository_version" : "2.2.0.1-885"
  116. }
  117. ];
  118. controller.loadVersionsInfoSuccessCallback(data);
  119. expect(controller.get('currentVersion')).to.eql({
  120. "state": "CURRENT",
  121. "repository_version": "2.2.0.1-885"
  122. });
  123. expect(controller.get('targetVersions')).to.be.empty;
  124. });
  125. it("target version not installed and lower than current", function() {
  126. var data = [
  127. {
  128. "state": "CURRENT",
  129. "repository_version": "2.2.0.1-885"
  130. },
  131. {
  132. "state": "INIT",
  133. "repository_version" : "2.2.0.1-885"
  134. }
  135. ];
  136. controller.loadVersionsInfoSuccessCallback(data);
  137. expect(controller.get('currentVersion')).to.eql({
  138. "state": "CURRENT",
  139. "repository_version": "2.2.0.1-885"
  140. });
  141. expect(controller.get('targetVersions')).to.be.empty;
  142. });
  143. });
  144. describe("#loadUpgradeData()", function() {
  145. beforeEach(function () {
  146. sinon.stub(App.ajax, 'send').returns({
  147. then: Em.K
  148. });
  149. });
  150. afterEach(function () {
  151. App.ajax.send.restore();
  152. });
  153. it("get entire data", function() {
  154. controller.set('upgradeId', 1);
  155. controller.loadUpgradeData();
  156. expect(App.ajax.send.getCall(0).args[0]).to.eql({
  157. name: 'admin.upgrade.data',
  158. sender: controller,
  159. data: {
  160. id: 1
  161. },
  162. success: 'loadUpgradeDataSuccessCallback'
  163. })
  164. });
  165. it("get only state", function() {
  166. controller.set('upgradeId', 1);
  167. controller.loadUpgradeData(true);
  168. expect(App.ajax.send.getCall(0).args[0]).to.eql({
  169. name: 'admin.upgrade.state',
  170. sender: controller,
  171. data: {
  172. id: 1
  173. },
  174. success: 'loadUpgradeDataSuccessCallback'
  175. })
  176. });
  177. });
  178. describe("#loadUpgradeDataSuccessCallback()", function() {
  179. it("", function() {
  180. var data = {
  181. "Upgrade": {
  182. "request_status": "COMPLETED"
  183. },
  184. "upgrade_groups": [
  185. {
  186. "UpgradeGroup": {
  187. "id": 1
  188. },
  189. "upgrade_items": []
  190. }
  191. ]};
  192. controller.loadUpgradeDataSuccessCallback(data);
  193. expect(controller.get('upgradeData')).to.eql(data);
  194. expect(App.get('upgradeState')).to.equal('COMPLETED');
  195. });
  196. });
  197. describe("#openUpgradeDialog()", function () {
  198. before(function () {
  199. sinon.stub(App.router, 'transitionTo', Em.K);
  200. });
  201. after(function () {
  202. App.router.transitionTo.restore();
  203. });
  204. it("should open dialog", function () {
  205. controller.openUpgradeDialog();
  206. expect(App.router.transitionTo.calledWith('admin.stackUpgrade')).to.be.true;
  207. });
  208. });
  209. describe("#runPreUpgradeCheck()", function() {
  210. before(function () {
  211. sinon.stub(App.ajax, 'send', Em.K);
  212. });
  213. after(function () {
  214. App.ajax.send.restore();
  215. });
  216. it("make ajax call", function() {
  217. controller.runPreUpgradeCheck("2.2.1");
  218. expect(App.ajax.send.calledOnce).to.be.true;
  219. });
  220. });
  221. describe("#runPreUpgradeCheckSuccess()", function () {
  222. beforeEach(function () {
  223. sinon.stub(App.ModalPopup, 'show', Em.K);
  224. sinon.stub(controller, 'upgrade', Em.K);
  225. });
  226. afterEach(function () {
  227. App.ModalPopup.show.restore();
  228. controller.upgrade.restore();
  229. });
  230. it("shows popup", function () {
  231. var check = {UpgradeChecks: [{
  232. "check": "Work-preserving RM/NM restart is enabled in YARN configs",
  233. "status": "FAIL",
  234. "reason": "FAIL",
  235. "failed_on": [],
  236. "check_type": "SERVICE"
  237. }]};
  238. controller.runPreUpgradeCheckSuccess(check,null,{label: "name"});
  239. expect(controller.upgrade.calledOnce).to.be.false;
  240. expect(App.ModalPopup.show.calledOnce).to.be.true;
  241. });
  242. it("runs upgrade popup", function () {
  243. var check = {UpgradeChecks: [{
  244. "check": "Work-preserving RM/NM restart is enabled in YARN configs",
  245. "status": "PASS",
  246. "reason": "OK",
  247. "failed_on": [],
  248. "check_type": "SERVICE"
  249. }]};
  250. controller.runPreUpgradeCheckSuccess(check,null,{label: "name"});
  251. expect(controller.upgrade.calledOnce).to.be.true;
  252. expect(App.ModalPopup.show.calledOnce).to.be.false;
  253. });
  254. });
  255. });