config_test.js 38 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249
  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/service/info/configs');
  20. var batchUtils = require('utils/batch_scheduled_requests');
  21. var mainServiceInfoConfigsController = null;
  22. describe("App.MainServiceInfoConfigsController", function () {
  23. beforeEach(function () {
  24. mainServiceInfoConfigsController = App.MainServiceInfoConfigsController.create({});
  25. });
  26. describe("#showSavePopup", function () {
  27. var tests = [
  28. {
  29. path: false,
  30. event: false,
  31. action: "onSave",
  32. m: "save configs without path/event",
  33. results: [
  34. {
  35. method: "restartServicePopup",
  36. called: true
  37. },
  38. {
  39. method: "selectConfigGroup",
  40. called: false
  41. }
  42. ]
  43. },
  44. {
  45. path: true,
  46. event: true,
  47. action: "onSave",
  48. m: "save configs with path/event",
  49. results: [
  50. {
  51. method: "restartServicePopup",
  52. called: true
  53. },
  54. {
  55. method: "selectConfigGroup",
  56. called: false
  57. }
  58. ]
  59. },
  60. {
  61. path: false,
  62. event: false,
  63. action: "onDiscard",
  64. m: "discard changes without path/event",
  65. results: [
  66. {
  67. method: "restartServicePopup",
  68. called: false
  69. },
  70. {
  71. method: "selectConfigGroup",
  72. called: false
  73. }
  74. ]
  75. },
  76. {
  77. path: false,
  78. event: true,
  79. action: "onDiscard",
  80. m: "discard changes with event",
  81. results: [
  82. {
  83. method: "restartServicePopup",
  84. called: false
  85. },
  86. {
  87. method: "selectConfigGroup",
  88. called: true
  89. },
  90. {
  91. field: "hash",
  92. value: "hash"
  93. }
  94. ]
  95. },
  96. {
  97. path: true,
  98. event: false,
  99. action: "onDiscard",
  100. m: "discard changes with path",
  101. results: [
  102. {
  103. method: "restartServicePopup",
  104. called: false
  105. },
  106. {
  107. method: "selectConfigGroup",
  108. called: false
  109. },
  110. {
  111. field: "forceTransition",
  112. value: true
  113. }
  114. ]
  115. }
  116. ];
  117. beforeEach(function () {
  118. sinon.stub(mainServiceInfoConfigsController, "restartServicePopup", Em.K);
  119. sinon.stub(mainServiceInfoConfigsController, "selectConfigGroup", Em.K);
  120. sinon.stub(mainServiceInfoConfigsController, "getHash", function () {
  121. return "hash"
  122. });
  123. App.router.route = Em.K;
  124. });
  125. afterEach(function () {
  126. mainServiceInfoConfigsController.restartServicePopup.restore();
  127. mainServiceInfoConfigsController.selectConfigGroup.restore();
  128. mainServiceInfoConfigsController.getHash.restore();
  129. });
  130. tests.forEach(function (t) {
  131. t.results.forEach(function (r) {
  132. it(t.m + " " + r.method + " " + r.field, function () {
  133. mainServiceInfoConfigsController.showSavePopup(t.path, t.event)[t.action]();
  134. if (r.method) {
  135. expect(mainServiceInfoConfigsController[r.method].calledOnce).to.equal(r.called);
  136. } else if (r.field) {
  137. expect(mainServiceInfoConfigsController.get(r.field)).to.equal(r.value);
  138. }
  139. }, this);
  140. });
  141. }, this);
  142. });
  143. describe("#hasUnsavedChanges", function () {
  144. beforeEach(function () {
  145. sinon.stub(mainServiceInfoConfigsController, "getHash", function () {
  146. return "hash"
  147. });
  148. });
  149. afterEach(function () {
  150. mainServiceInfoConfigsController.getHash.restore();
  151. });
  152. it("with unsaved", function () {
  153. mainServiceInfoConfigsController.set("hash", "hash1");
  154. expect(mainServiceInfoConfigsController.hasUnsavedChanges()).to.equal(true);
  155. });
  156. it("without unsaved", function () {
  157. mainServiceInfoConfigsController.set("hash", "hash");
  158. expect(mainServiceInfoConfigsController.hasUnsavedChanges()).to.equal(false);
  159. });
  160. });
  161. describe("#selectConfigGroup", function () {
  162. var tests = [
  163. {
  164. event: {
  165. context: "cfgGroup"
  166. },
  167. isInit: true,
  168. showPopup: false,
  169. m: "setup new cfg group"
  170. },
  171. {
  172. event: {
  173. context: "cfgGroup"
  174. },
  175. isInit: false,
  176. hash: "hash",
  177. showPopup: false,
  178. m: "setup new cfg group, has some changes"
  179. },
  180. {
  181. event: {
  182. context: "cfgGroup"
  183. },
  184. isInit: false,
  185. hash: "hash1",
  186. showPopup: true,
  187. m: "show popup, doesn't setup new cfg group"
  188. }
  189. ];
  190. beforeEach(function () {
  191. sinon.stub(mainServiceInfoConfigsController, "showSavePopup", Em.K);
  192. sinon.stub(mainServiceInfoConfigsController, "getHash", function () {
  193. return "hash"
  194. });
  195. sinon.stub(mainServiceInfoConfigsController, "onConfigGroupChange", Em.K);
  196. });
  197. afterEach(function () {
  198. mainServiceInfoConfigsController.showSavePopup.restore();
  199. mainServiceInfoConfigsController.getHash.restore();
  200. mainServiceInfoConfigsController.onConfigGroupChange.restore();
  201. });
  202. tests.forEach(function (t) {
  203. it(t.m, function () {
  204. mainServiceInfoConfigsController.set("isInit", t.isInit);
  205. mainServiceInfoConfigsController.set("hash", t.hash);
  206. mainServiceInfoConfigsController.selectConfigGroup(t.event);
  207. if (!t.showPopup) {
  208. expect(mainServiceInfoConfigsController.get("selectedConfigGroup")).to.equal(t.event.context);
  209. expect(mainServiceInfoConfigsController.showSavePopup.calledOnce).to.equal(false);
  210. } else {
  211. expect(mainServiceInfoConfigsController.showSavePopup.calledWith(null, t.event)).to.equal(true);
  212. }
  213. });
  214. });
  215. });
  216. describe("#manageConfigurationGroup", function () {
  217. beforeEach(function () {
  218. sinon.stub(mainServiceInfoConfigsController, "manageConfigurationGroups", Em.K);
  219. });
  220. afterEach(function () {
  221. mainServiceInfoConfigsController.manageConfigurationGroups.restore();
  222. });
  223. it("run manageConfigurationGroups", function () {
  224. mainServiceInfoConfigsController.manageConfigurationGroup();
  225. expect(mainServiceInfoConfigsController.manageConfigurationGroups.calledOnce).to.equal(true);
  226. });
  227. });
  228. describe("#addOverrideProperty", function () {
  229. var serviceConfigProperty = Em.Object.create({
  230. overrides: []
  231. });
  232. var newSCP = App.ServiceConfigProperty.create(serviceConfigProperty);
  233. newSCP.set('value', '');
  234. newSCP.set('isOriginalSCP', false);
  235. newSCP.set('parentSCP', serviceConfigProperty);
  236. newSCP.set('isEditable', true);
  237. it("add new overridden property", function () {
  238. mainServiceInfoConfigsController.addOverrideProperty(serviceConfigProperty);
  239. expect(serviceConfigProperty.get("overrides")[0]).to.eql(newSCP);
  240. });
  241. });
  242. describe("#showComponentsShouldBeRestarted", function () {
  243. var tests = [
  244. {
  245. input: {
  246. 'publicHostName1': ['TaskTracker'],
  247. 'publicHostName2': ['JobTracker', 'TaskTracker']
  248. },
  249. components: "2 TaskTrackers, 1 JobTracker",
  250. text: Em.I18n.t('service.service.config.restartService.shouldBeRestarted').format(Em.I18n.t('common.components'))
  251. },
  252. {
  253. input: {
  254. 'publicHostName1': ['TaskTracker']
  255. },
  256. components: "1 TaskTracker",
  257. text: Em.I18n.t('service.service.config.restartService.shouldBeRestarted').format(Em.I18n.t('common.component'))
  258. }
  259. ];
  260. beforeEach(function () {
  261. sinon.stub(mainServiceInfoConfigsController, "showItemsShouldBeRestarted", Em.K);
  262. mainServiceInfoConfigsController.set("content", {restartRequiredHostsAndComponents: ""});
  263. });
  264. afterEach(function () {
  265. mainServiceInfoConfigsController.showItemsShouldBeRestarted.restore();
  266. mainServiceInfoConfigsController.set("content", undefined);
  267. });
  268. tests.forEach(function (t) {
  269. it("trigger showItemsShouldBeRestarted popup with components", function () {
  270. mainServiceInfoConfigsController.set("content.restartRequiredHostsAndComponents", t.input);
  271. mainServiceInfoConfigsController.showComponentsShouldBeRestarted();
  272. expect(mainServiceInfoConfigsController.showItemsShouldBeRestarted.calledWith(t.components, t.text)).to.equal(true);
  273. });
  274. });
  275. });
  276. describe("#showHostsShouldBeRestarted", function () {
  277. var tests = [
  278. {
  279. input: {
  280. 'publicHostName1': ['TaskTracker'],
  281. 'publicHostName2': ['JobTracker', 'TaskTracker']
  282. },
  283. hosts: "publicHostName1, publicHostName2",
  284. text: Em.I18n.t('service.service.config.restartService.shouldBeRestarted').format(Em.I18n.t('common.hosts'))
  285. },
  286. {
  287. input: {
  288. 'publicHostName1': ['TaskTracker']
  289. },
  290. hosts: "publicHostName1",
  291. text: Em.I18n.t('service.service.config.restartService.shouldBeRestarted').format(Em.I18n.t('common.host'))
  292. }
  293. ];
  294. beforeEach(function () {
  295. sinon.stub(mainServiceInfoConfigsController, "showItemsShouldBeRestarted", Em.K);
  296. mainServiceInfoConfigsController.set("content", {restartRequiredHostsAndComponents: ""});
  297. });
  298. afterEach(function () {
  299. mainServiceInfoConfigsController.showItemsShouldBeRestarted.restore();
  300. mainServiceInfoConfigsController.set("content", undefined);
  301. });
  302. tests.forEach(function (t) {
  303. it("trigger showItemsShouldBeRestarted popup with hosts", function () {
  304. mainServiceInfoConfigsController.set("content.restartRequiredHostsAndComponents", t.input);
  305. mainServiceInfoConfigsController.showHostsShouldBeRestarted();
  306. expect(mainServiceInfoConfigsController.showItemsShouldBeRestarted.calledWith(t.hosts, t.text)).to.equal(true);
  307. });
  308. });
  309. });
  310. describe("rollingRestartStaleConfigSlaveComponents", function () {
  311. var tests = [
  312. {
  313. componentName: {
  314. context: "ComponentName"
  315. },
  316. displayName: "displayName",
  317. passiveState: "ON"
  318. },
  319. {
  320. componentName: {
  321. context: "ComponentName1"
  322. },
  323. displayName: "displayName1",
  324. passiveState: "OFF"
  325. }
  326. ];
  327. beforeEach(function () {
  328. mainServiceInfoConfigsController.set("content", {displayName: "", passiveState: ""});
  329. sinon.stub(batchUtils, "launchHostComponentRollingRestart", Em.K);
  330. });
  331. afterEach(function () {
  332. batchUtils.launchHostComponentRollingRestart.restore();
  333. });
  334. tests.forEach(function (t) {
  335. it("trigger rollingRestartStaleConfigSlaveComponents", function () {
  336. mainServiceInfoConfigsController.set("content.displayName", t.displayName);
  337. mainServiceInfoConfigsController.set("content.passiveState", t.passiveState);
  338. mainServiceInfoConfigsController.rollingRestartStaleConfigSlaveComponents(t.componentName);
  339. expect(batchUtils.launchHostComponentRollingRestart.calledWith(t.componentName.context, t.displayName, t.passiveState == "ON", true)).to.equal(true);
  340. });
  341. });
  342. });
  343. describe("#restartAllStaleConfigComponents", function () {
  344. beforeEach(function () {
  345. sinon.stub(batchUtils, "restartAllServiceHostComponents", Em.K);
  346. });
  347. afterEach(function () {
  348. batchUtils.restartAllServiceHostComponents.restore();
  349. });
  350. it("trigger restartAllServiceHostComponents", function () {
  351. mainServiceInfoConfigsController.restartAllStaleConfigComponents().onPrimary();
  352. expect(batchUtils.restartAllServiceHostComponents.calledOnce).to.equal(true);
  353. });
  354. });
  355. describe("#doCancel", function () {
  356. beforeEach(function () {
  357. sinon.stub(Em.run, 'once', Em.K);
  358. });
  359. afterEach(function () {
  360. Em.run.once.restore();
  361. });
  362. it("trigger onConfigGroupChange", function () {
  363. mainServiceInfoConfigsController.doCancel();
  364. expect(Em.run.once.calledWith(mainServiceInfoConfigsController, "onConfigGroupChange")).to.equal(true);
  365. });
  366. });
  367. describe("#getCurrentServiceComponents", function () {
  368. var t = Em.Object.create({
  369. content: Em.Object.create({
  370. hostComponents: [
  371. Em.Object.create({
  372. componentName: "componentName1",
  373. displayName: "displayName1"
  374. }),
  375. Em.Object.create({
  376. componentName: "componentName2",
  377. displayName: "displayName2"
  378. })
  379. ]
  380. }),
  381. validComponents: Em.A([
  382. Em.Object.create({
  383. componentName: "componentName1",
  384. displayName: "displayName1",
  385. selected: false
  386. }),
  387. Em.Object.create({
  388. componentName: "componentName2",
  389. displayName: "displayName2",
  390. selected: false
  391. })
  392. ])
  393. });
  394. beforeEach(function () {
  395. mainServiceInfoConfigsController.set("content", { hostComponents: Em.A([])});
  396. });
  397. it("get current service components", function () {
  398. mainServiceInfoConfigsController.get("content.hostComponents").push(t.content.hostComponents[0]);
  399. var com = mainServiceInfoConfigsController.get("getCurrentServiceComponents");
  400. expect(com[0]).to.eql(t.validComponents[0]);
  401. });
  402. });
  403. describe("#getMasterComponentHostValue", function () {
  404. var tests = [
  405. {
  406. content: {
  407. hostComponents: [
  408. Em.Object.create({
  409. componentName: "componentName1",
  410. hostName: "hostName"
  411. })
  412. ]
  413. },
  414. result: "hostName",
  415. multiple: false,
  416. m: "returns hostname"
  417. },
  418. {
  419. content: {
  420. hostComponents: [
  421. Em.Object.create({
  422. componentName: "componentName2",
  423. hostName: "hostName1"
  424. }),
  425. Em.Object.create({
  426. componentName: "componentName2",
  427. hostName: "hostName2"
  428. })
  429. ]
  430. },
  431. result: ["hostName1","hostName2"],
  432. multiple: true,
  433. m: "returns hostnames"
  434. }
  435. ];
  436. tests.forEach(function(t){
  437. beforeEach(function () {
  438. mainServiceInfoConfigsController.set("content", { hostComponents: []});
  439. });
  440. it(t.m, function () {
  441. mainServiceInfoConfigsController.set("content.hostComponents", t.content.hostComponents);
  442. expect(mainServiceInfoConfigsController.getMasterComponentHostValue(t.content.hostComponents[0].componentName, t.multiple)).to.eql(t.result);
  443. });
  444. });
  445. });
  446. describe("#setServerConfigValue", function () {
  447. it("parsing storm.zookeeper.servers property in non standart method", function () {
  448. expect(mainServiceInfoConfigsController.setServerConfigValue("storm.zookeeper.servers", ["a", "b"])).to.equal('[\'a\',\'b\']');
  449. });
  450. it("parsing default properties", function () {
  451. expect(mainServiceInfoConfigsController.setServerConfigValue("any.other.property", "value")).to.equal("value");
  452. });
  453. });
  454. describe("#createSiteObj", function () {
  455. var tests = [
  456. {
  457. siteName: "hdfs-site",
  458. tagName: "version1",
  459. siteObj: Em.A([
  460. {
  461. name: "property1",
  462. value: "value1"
  463. },
  464. {
  465. name: "property2",
  466. value: "value2<"
  467. }
  468. ]),
  469. result: {
  470. "type": "hdfs-site",
  471. "tag": "version1",
  472. "properties": {
  473. "property1": "value1",
  474. "property2": "value2<"
  475. }
  476. },
  477. m: "default"
  478. },
  479. {
  480. siteName: "falcon-startup.properties",
  481. tagName: "version1",
  482. siteObj: Em.A([
  483. {
  484. name: "property1",
  485. value: "value1"
  486. },
  487. {
  488. name: "property2",
  489. value: "value2<"
  490. }
  491. ]),
  492. result: {
  493. "type": "falcon-startup.properties",
  494. "tag": "version1",
  495. "properties": {
  496. "property1": "value1",
  497. "property2": "value2<"
  498. }
  499. },
  500. m: "for falcon-startup.properties"
  501. }
  502. ];
  503. tests.forEach(function (t) {
  504. it("create site object " + t.m, function () {
  505. expect(mainServiceInfoConfigsController.createSiteObj(t.siteName, t.tagName, t.siteObj)).to.deep.eql(t.result)
  506. });
  507. });
  508. });
  509. describe("#createCoreSiteObj", function () {
  510. var tests = [
  511. {
  512. tagName: "version1",
  513. uiConfigs: Em.A([
  514. Em.Object.create({
  515. name: "property1",
  516. value: "value1",
  517. filename: "core-site.xml"
  518. }),
  519. Em.Object.create({
  520. name: "property2",
  521. value: "value2<",
  522. filename: "core-site.xml"
  523. })
  524. ]),
  525. result: {
  526. "type": "core-site",
  527. "tag": "version1",
  528. "properties": {
  529. "property1": "value1",
  530. "property2": "value2<"
  531. }
  532. }
  533. }
  534. ];
  535. tests.forEach(function (t) {
  536. it("create core object", function () {
  537. mainServiceInfoConfigsController.set("uiConfigs", t.uiConfigs);
  538. expect(mainServiceInfoConfigsController.createCoreSiteObj(t.tagName)).to.deep.eql(t.result);
  539. });
  540. });
  541. });
  542. describe("#doPUTClusterConfigurationSites", function () {
  543. var sc = [
  544. Em.Object.create({
  545. configs: [
  546. Em.Object.create({
  547. name: '_heapsize',
  548. value: '1024m'
  549. }),
  550. Em.Object.create({
  551. name: '_newsize',
  552. value: '1024m'
  553. }),
  554. Em.Object.create({
  555. name: '_maxnewsize',
  556. value: '1024m'
  557. })
  558. ]
  559. })
  560. ],
  561. scExc = [
  562. Em.Object.create({
  563. configs: [
  564. Em.Object.create({
  565. name: 'hadoop_heapsize',
  566. value: '1024m'
  567. }),
  568. Em.Object.create({
  569. name: 'yarn_heapsize',
  570. value: '1024m'
  571. }),
  572. Em.Object.create({
  573. name: 'nodemanager_heapsize',
  574. value: '1024m'
  575. }),
  576. Em.Object.create({
  577. name: 'resourcemanager_heapsize',
  578. value: '1024m'
  579. }),
  580. Em.Object.create({
  581. name: 'apptimelineserver_heapsize',
  582. value: '1024m'
  583. }),
  584. Em.Object.create({
  585. name: 'jobhistory_heapsize',
  586. value: '1024m'
  587. })
  588. ]
  589. })
  590. ];
  591. beforeEach(function () {
  592. sinon.stub(App.router, 'getClusterName', function() {
  593. return 'clName';
  594. });
  595. sinon.stub(App.ajax, "send", Em.K);
  596. });
  597. afterEach(function () {
  598. App.ajax.send.restore();
  599. App.router.getClusterName.restore();
  600. });
  601. it("ajax request to put clsuter cfg", function () {
  602. mainServiceInfoConfigsController.set('stepConfigs', sc);
  603. expect(mainServiceInfoConfigsController.doPUTClusterConfigurationSites([])).to.equal(mainServiceInfoConfigsController.get("doPUTClusterConfigurationSiteResult"));
  604. expect(App.ajax.send.calledOnce).to.be.true;
  605. });
  606. it('values should be parsed', function () {
  607. mainServiceInfoConfigsController.set('stepConfigs', sc);
  608. mainServiceInfoConfigsController.doPUTClusterConfigurationSites([]);
  609. expect(mainServiceInfoConfigsController.get('stepConfigs')[0].get('configs').mapProperty('value').uniq()).to.eql(['1024']);
  610. });
  611. it('values should not be parsed', function () {
  612. mainServiceInfoConfigsController.set('stepConfigs', scExc);
  613. mainServiceInfoConfigsController.doPUTClusterConfigurationSites([]);
  614. expect(mainServiceInfoConfigsController.get('stepConfigs')[0].get('configs').mapProperty('value').uniq()).to.eql(['1024m']);
  615. });
  616. });
  617. describe("#isConfigChanged", function () {
  618. var tests = [
  619. {
  620. loadedConfig: {
  621. apptimelineserver_heapsize: "1024",
  622. hbase_log_dir: "/var/log/hbase",
  623. lzo_enabled: "true"
  624. },
  625. savingConfig: {
  626. apptimelineserver_heapsize: "1024",
  627. hbase_log_dir: "/var/log/hbase",
  628. lzo_enabled: "true"
  629. },
  630. m: "configs doesn't changed",
  631. res: false
  632. },
  633. {
  634. loadedConfig: {
  635. apptimelineserver_heapsize: "1024",
  636. hbase_log_dir: "/var/log/hbase",
  637. lzo_enabled: "true"
  638. },
  639. savingConfig: {
  640. apptimelineserver_heapsize: "1024",
  641. hbase_log_dir: "/var/log/hbase",
  642. lzo_enabled: "false"
  643. },
  644. m: "configs changed",
  645. res: true
  646. },
  647. {
  648. loadedConfig: {
  649. apptimelineserver_heapsize: "1024",
  650. hbase_log_dir: "/var/log/hbase"
  651. },
  652. savingConfig: {
  653. apptimelineserver_heapsize: "1024",
  654. hbase_log_dir: "/var/log/hbase",
  655. lzo_enabled: "false"
  656. },
  657. m: "add new config",
  658. res: true
  659. }
  660. ];
  661. tests.forEach(function(t){
  662. it(t.m, function () {
  663. expect(mainServiceInfoConfigsController.isConfigChanged(t.loadedConfig, t.savingConfig)).to.equal(t.res);
  664. });
  665. });
  666. });
  667. describe("#addDynamicProperties", function() {
  668. var tests = [
  669. {
  670. stepConfigs: [Em.Object.create({
  671. serviceName: "HIVE",
  672. configs: []
  673. })],
  674. content: Em.Object.create({
  675. serviceName: "HIVE"
  676. }),
  677. m: "add dynamic property",
  678. addDynamic: true
  679. },
  680. {
  681. stepConfigs: [Em.Object.create({
  682. serviceName: "HIVE",
  683. configs: [
  684. Em.Object.create({
  685. name: "templeton.hive.properties"
  686. })
  687. ]
  688. })],
  689. content: Em.Object.create({
  690. serviceName: "HIVE"
  691. }),
  692. m: "don't add dynamic property (already included)",
  693. addDynamic: false
  694. },
  695. {
  696. stepConfigs: [Em.Object.create({
  697. serviceName: "HDFS",
  698. configs: []
  699. })],
  700. content: Em.Object.create({
  701. serviceName: "HDFS"
  702. }),
  703. m: "don't add dynamic property (wrong service)",
  704. addDynamic: false
  705. }
  706. ];
  707. var dynamicProperty = {
  708. "name": "templeton.hive.properties",
  709. "templateName": ["hivemetastore_host"],
  710. "foreignKey": null,
  711. "value": "hive.metastore.local=false,hive.metastore.uris=thrift://<templateName[0]>:9083,hive.metastore.sasl.enabled=yes,hive.metastore.execute.setugi=true,hive.metastore.warehouse.dir=/apps/hive/warehouse",
  712. "filename": "webhcat-site.xml"
  713. };
  714. tests.forEach(function(t) {
  715. it(t.m, function() {
  716. mainServiceInfoConfigsController.set("content", t.content);
  717. mainServiceInfoConfigsController.set("stepConfigs", t.stepConfigs);
  718. var configs = [];
  719. mainServiceInfoConfigsController.addDynamicProperties(configs);
  720. if (t.addDynamic){
  721. expect(configs.findProperty("name","templeton.hive.properties")).to.deep.eql(dynamicProperty);
  722. }
  723. });
  724. });
  725. });
  726. describe("#loadUiSideConfigs", function () {
  727. var t = {
  728. configMapping: [
  729. {
  730. foreignKey: null,
  731. templateName: "",
  732. value: "default",
  733. name: "name1",
  734. filename: "filename1"
  735. },
  736. {
  737. foreignKey: "notNull",
  738. templateName: "",
  739. value: "default2",
  740. name: "name2",
  741. filename: "filename2"
  742. }
  743. ],
  744. configMappingf: [
  745. {
  746. foreignKey: null,
  747. templateName: "",
  748. value: "default",
  749. name: "name1",
  750. filename: "filename1"
  751. }
  752. ],
  753. valueWithOverrides: {
  754. "value": "default",
  755. "overrides": {
  756. "value1": "value1",
  757. "value2": "value2"
  758. }
  759. },
  760. uiConfigs: [
  761. {
  762. "id": "site property",
  763. "name": "name1",
  764. "value": "default",
  765. "filename": "filename1",
  766. "overrides": {
  767. "value1": "value1",
  768. "value2": "value2"
  769. }
  770. }
  771. ]
  772. };
  773. beforeEach(function(){
  774. sinon.stub(mainServiceInfoConfigsController, "addDynamicProperties", Em.K);
  775. sinon.stub(mainServiceInfoConfigsController, "getGlobConfigValueWithOverrides", function () {
  776. return t.valueWithOverrides
  777. });
  778. });
  779. afterEach(function(){
  780. mainServiceInfoConfigsController.addDynamicProperties.restore();
  781. mainServiceInfoConfigsController.getGlobConfigValueWithOverrides.restore();
  782. });
  783. it("load ui config", function() {
  784. expect(mainServiceInfoConfigsController.loadUiSideConfigs(t.configMapping)[0]).to.deep.equal(t.uiConfigs[0]);
  785. expect(mainServiceInfoConfigsController.addDynamicProperties.calledWith(t.configMappingf)).to.equal(true);
  786. });
  787. });
  788. describe("#formatConfigValues", function () {
  789. var t = {
  790. configs: [
  791. Em.Object.create({ name: "p1", value: " v1 v1 ", displayType: "" }),
  792. Em.Object.create({ name: "p2", value: true, displayType: "" }),
  793. Em.Object.create({ name: "p3", value: " d1 ", displayType: "directory" }),
  794. Em.Object.create({ name: "p4", value: " d1 d2 d3 ", displayType: "directories" }),
  795. Em.Object.create({ name: "p5", value: " v1 ", displayType: "password" }),
  796. Em.Object.create({ name: "p6", value: " v ", displayType: "host" }),
  797. Em.Object.create({ name: "javax.jdo.option.ConnectionURL", value: " v1 ", displayType: "advanced" }),
  798. Em.Object.create({ name: "oozie.service.JPAService.jdbc.url", value: " v1 ", displayType: "advanced" })
  799. ],
  800. result: [
  801. Em.Object.create({ name: "p1", value: " v1 v1", displayType: "" }),
  802. Em.Object.create({ name: "p2", value: "true", displayType: "" }),
  803. Em.Object.create({ name: "p3", value: "d1", displayType: "directory" }),
  804. Em.Object.create({ name: "p4", value: "d1,d2,d3", displayType: "directories" }),
  805. Em.Object.create({ name: "p5", value: " v1 ", displayType: "password" }),
  806. Em.Object.create({ name: "p6", value: "v", displayType: "host" }),
  807. Em.Object.create({ name: "javax.jdo.option.ConnectionURL", value: " v1", displayType: "advanced" }),
  808. Em.Object.create({ name: "oozie.service.JPAService.jdbc.url", value: " v1", displayType: "advanced" })
  809. ]
  810. };
  811. it("format config values", function () {
  812. mainServiceInfoConfigsController.formatConfigValues(t.configs);
  813. expect(t.configs).to.deep.equal(t.result);
  814. });
  815. });
  816. describe("#createConfigObject", function() {
  817. var tests = [
  818. {
  819. siteName: "core-site",
  820. serviceName: "HDFS",
  821. method: "createCoreSiteObj"
  822. },
  823. {
  824. siteName: "core-site",
  825. serviceName: "ANY",
  826. method: false
  827. },
  828. {
  829. siteName: "any",
  830. method: "createSiteObj"
  831. },
  832. {
  833. siteName: "mapred-queue-acls",
  834. method: false,
  835. capacitySchedulerUi: false
  836. },
  837. {
  838. siteName: "mapred-queue-acls",
  839. method: "createSiteObj",
  840. capacitySchedulerUi: true
  841. }
  842. ];
  843. var capacitySchedulerUi = App.supports.capacitySchedulerUi;
  844. beforeEach(function() {
  845. sinon.stub(mainServiceInfoConfigsController, "createCoreSiteObj", Em.K);
  846. sinon.stub(mainServiceInfoConfigsController, "createSiteObj", Em.K);
  847. mainServiceInfoConfigsController.set("content", {});
  848. });
  849. afterEach(function() {
  850. mainServiceInfoConfigsController.createCoreSiteObj.restore();
  851. mainServiceInfoConfigsController.createSiteObj.restore();
  852. App.supports.capacitySchedulerUi = capacitySchedulerUi;
  853. });
  854. tests.forEach(function(t) {
  855. it("create object for " + t.siteName + " run method " + t.method, function() {
  856. App.supports.capacitySchedulerUi = t.capacitySchedulerUi;
  857. mainServiceInfoConfigsController.set("content.serviceName", t.serviceName);
  858. mainServiceInfoConfigsController.createConfigObject(t.siteName, "versrion1");
  859. if (t.method) {
  860. expect(mainServiceInfoConfigsController[t.method].calledOnce).to.equal(true);
  861. } else {
  862. expect(mainServiceInfoConfigsController["createCoreSiteObj"].calledOnce).to.equal(false);
  863. expect(mainServiceInfoConfigsController["createSiteObj"].calledOnce).to.equal(false);
  864. }
  865. });
  866. });
  867. });
  868. describe("#putConfigGroupChanges", function() {
  869. var t = {
  870. data: {
  871. ConfigGroup: {
  872. id: "id"
  873. }
  874. },
  875. request: [{
  876. ConfigGroup: {
  877. id: "id"
  878. }
  879. }]
  880. };
  881. beforeEach(function() {
  882. sinon.spy($,"ajax");
  883. });
  884. afterEach(function() {
  885. $.ajax.restore();
  886. });
  887. it("updates configs groups", function() {
  888. mainServiceInfoConfigsController.putConfigGroupChanges(t.data);
  889. expect(JSON.parse($.ajax.args[0][0].data)).to.deep.equal(t.request);
  890. });
  891. });
  892. describe("#setValueForCheckBox", function() {
  893. var tests = [
  894. {
  895. serviceConfigPropertyInput: Em.Object.create({
  896. value: "true",
  897. defaultValue: "true",
  898. displayType: 'checkbox'
  899. }),
  900. serviceConfigProperty: Em.Object.create({
  901. value: true,
  902. defaultValue: true,
  903. displayType: 'checkbox'
  904. })
  905. },
  906. {
  907. serviceConfigPropertyInput: Em.Object.create({
  908. value: "false",
  909. defaultValue: "false",
  910. displayType: 'checkbox'
  911. }),
  912. serviceConfigProperty: Em.Object.create({
  913. value: false,
  914. defaultValue: false,
  915. displayType: 'checkbox'
  916. })
  917. },
  918. {
  919. serviceConfigPropertyInput: Em.Object.create({
  920. value: "false",
  921. defaultValue: "false"
  922. }),
  923. serviceConfigProperty: Em.Object.create({
  924. value: "false",
  925. defaultValue: "false"
  926. })
  927. }
  928. ];
  929. tests.forEach(function(t) {
  930. it("set " + t.serviceConfigPropertyInput.value, function(){
  931. var serviceConfigProperty = t.serviceConfigPropertyInput;
  932. mainServiceInfoConfigsController.setValueForCheckBox(serviceConfigProperty);
  933. expect(serviceConfigProperty).to.eql(t.serviceConfigProperty);
  934. });
  935. });
  936. });
  937. describe("#setEditability", function () {
  938. var tests = [
  939. {
  940. isAdmin: true,
  941. isHostsConfigsPage: false,
  942. defaultGroupSelected: true,
  943. isReconfigurable: true,
  944. isEditable: true,
  945. m: ""
  946. },
  947. {
  948. isAdmin: false,
  949. isHostsConfigsPage: false,
  950. defaultGroupSelected: true,
  951. isReconfigurable: true,
  952. isEditable: false,
  953. m: "(non admin)"
  954. },
  955. {
  956. isAdmin: true,
  957. isHostsConfigsPage: true,
  958. defaultGroupSelected: true,
  959. isReconfigurable: true,
  960. isEditable: false,
  961. m: "(isHostsConfigsPage)"
  962. },
  963. {
  964. isAdmin: true,
  965. isHostsConfigsPage: false,
  966. defaultGroupSelected: false,
  967. isReconfigurable: true,
  968. isEditable: false,
  969. m: "(defaultGroupSelected is false)"
  970. },
  971. {
  972. isAdmin: true,
  973. isHostsConfigsPage: false,
  974. defaultGroupSelected: true,
  975. isReconfigurable: false,
  976. isEditable: false,
  977. m: "(isReconfigurable is false)"
  978. }
  979. ];
  980. var a = App.get('isAdmin');
  981. afterEach(function () {
  982. App.set('isAdmin', a);
  983. });
  984. tests.forEach(function(t) {
  985. it("set isEditable " + t.isEditable + t.m, function(){
  986. App.set('isAdmin', t.isAdmin);
  987. mainServiceInfoConfigsController.set("isHostsConfigsPage", t.isHostsConfigsPage);
  988. var serviceConfigProperty = Em.Object.create({
  989. isReconfigurable: t.isReconfigurable
  990. });
  991. mainServiceInfoConfigsController.setEditability(serviceConfigProperty, t.defaultGroupSelected);
  992. expect(serviceConfigProperty.get("isEditable")).to.equal(t.isEditable);
  993. });
  994. });
  995. });
  996. describe("#checkOverrideProperty", function () {
  997. var tests = [{
  998. overrideToAdd: {
  999. name: "name1",
  1000. filename: "filename1"
  1001. },
  1002. componentConfig: {
  1003. configs: [
  1004. {
  1005. name: "name1",
  1006. filename: "filename2"
  1007. },
  1008. {
  1009. name: "name1",
  1010. filename: "filename1"
  1011. }
  1012. ]
  1013. },
  1014. add: true,
  1015. m: "add property"
  1016. },
  1017. {
  1018. overrideToAdd: {
  1019. name: "name1"
  1020. },
  1021. componentConfig: {
  1022. configs: [
  1023. {
  1024. name: "name2"
  1025. }
  1026. ]
  1027. },
  1028. add: false,
  1029. m: "don't add property, different names"
  1030. },
  1031. {
  1032. overrideToAdd: {
  1033. name: "name1",
  1034. filename: "filename1"
  1035. },
  1036. componentConfig: {
  1037. configs: [
  1038. {
  1039. name: "name1",
  1040. filename: "filename2"
  1041. }
  1042. ]
  1043. },
  1044. add: false,
  1045. m: "don't add property, different filenames"
  1046. },
  1047. {
  1048. overrideToAdd: null,
  1049. componentConfig: {},
  1050. add: false,
  1051. m: "don't add property, overrideToAdd is null"
  1052. }];
  1053. beforeEach(function() {
  1054. sinon.stub(mainServiceInfoConfigsController,"addOverrideProperty", Em.K)
  1055. });
  1056. afterEach(function() {
  1057. mainServiceInfoConfigsController.addOverrideProperty.restore();
  1058. });
  1059. tests.forEach(function(t) {
  1060. it(t.m, function() {
  1061. mainServiceInfoConfigsController.set("overrideToAdd", t.overrideToAdd);
  1062. mainServiceInfoConfigsController.checkOverrideProperty(t.componentConfig);
  1063. if(t.add) {
  1064. expect(mainServiceInfoConfigsController.addOverrideProperty.calledWith(t.overrideToAdd)).to.equal(true);
  1065. expect(mainServiceInfoConfigsController.get("overrideToAdd")).to.equal(null);
  1066. } else {
  1067. expect(mainServiceInfoConfigsController.addOverrideProperty.calledOnce).to.equal(false);
  1068. }
  1069. });
  1070. });
  1071. });
  1072. describe("#setValuesForOverrides", function() {
  1073. var tests = [
  1074. {
  1075. overrides: [
  1076. {name: "override1"},
  1077. {name: "override2"}
  1078. ],
  1079. _serviceConfigProperty: {},
  1080. serviceConfigProperty: Em.Object.create({overrides: Em.A([])}),
  1081. defaultGroupSelected: true
  1082. }
  1083. ];
  1084. beforeEach(function() {
  1085. sinon.stub(mainServiceInfoConfigsController, "createNewSCP", function(override) {return {name: override.name}})
  1086. });
  1087. afterEach(function() {
  1088. mainServiceInfoConfigsController.createNewSCP.restore();
  1089. });
  1090. tests.forEach(function(t) {
  1091. it("set values for overrides. use createNewSCP method to do this", function() {
  1092. var serviceConfigProperty = t.serviceConfigProperty;
  1093. mainServiceInfoConfigsController.setValuesForOverrides(t.overrides, serviceConfigProperty, t.serviceConfigProperty, t.defaultGroupSelected);
  1094. expect(serviceConfigProperty.get("overrides")[0]).to.eql(t.overrides[0]);
  1095. expect(serviceConfigProperty.get("overrides")[1]).to.eql(t.overrides[1]);
  1096. });
  1097. });
  1098. });
  1099. describe("#createConfigProperty", function() {
  1100. var tests = [
  1101. {
  1102. _serviceConfigProperty: {
  1103. overrides: {
  1104. }
  1105. },
  1106. defaultGroupSelected: true,
  1107. restartData: {},
  1108. serviceConfigsData: {},
  1109. serviceConfigProperty: {
  1110. overrides: null,
  1111. isOverridable: true
  1112. }
  1113. }];
  1114. beforeEach(function() {
  1115. sinon.stub(mainServiceInfoConfigsController, "setValueForCheckBox", Em.K);
  1116. sinon.stub(mainServiceInfoConfigsController, "setValidator", Em.K);
  1117. sinon.stub(mainServiceInfoConfigsController, "setValuesForOverrides", Em.K);
  1118. sinon.stub(mainServiceInfoConfigsController, "setEditability", Em.K);
  1119. });
  1120. afterEach(function() {
  1121. mainServiceInfoConfigsController.setValueForCheckBox.restore();
  1122. mainServiceInfoConfigsController.setValidator.restore();
  1123. mainServiceInfoConfigsController.setValuesForOverrides.restore();
  1124. mainServiceInfoConfigsController.setEditability.restore();
  1125. });
  1126. tests.forEach(function(t) {
  1127. it("create service config. run methods to correctly set object fileds", function() {
  1128. var result = mainServiceInfoConfigsController.createConfigProperty(t._serviceConfigProperty, t.defaultGroupSelected, t.restartData, t.serviceConfigsData);
  1129. expect(mainServiceInfoConfigsController.setValueForCheckBox.calledWith(t.serviceConfigProperty));
  1130. expect(mainServiceInfoConfigsController.setValidator.calledWith(t.serviceConfigProperty, t.serviceConfigsData));
  1131. expect(mainServiceInfoConfigsController.setValuesForOverrides.calledWith(t._serviceConfigProperty.overrides, t._serviceConfigProperty, t.serviceConfigProperty, t.defaultGroupSelected));
  1132. expect(mainServiceInfoConfigsController.setValidator.calledWith(t.serviceConfigProperty, t.defaultGroupSelected));
  1133. expect(result.getProperties('overrides','isOverridable')).to.eql(t.serviceConfigProperty);
  1134. });
  1135. });
  1136. });
  1137. describe("#createNewSCP", function() {
  1138. var tests = [
  1139. {
  1140. overrides: {
  1141. value: "value",
  1142. group: {
  1143. value: "group1"
  1144. }
  1145. },
  1146. _serviceConfigProperty: {},
  1147. serviceConfigProperty: Em.Object.create({
  1148. value: "parentSCP",
  1149. supportsFinal: true
  1150. }),
  1151. defaultGroupSelected: true,
  1152. newSCP: {
  1153. value: "value",
  1154. isOriginalSCP: false,
  1155. parentSCP:Em.Object.create({
  1156. value: "parentSCP",
  1157. supportsFinal: true
  1158. }),
  1159. group: {
  1160. value: "group1"
  1161. },
  1162. isEditable: false
  1163. }
  1164. }
  1165. ];
  1166. tests.forEach(function(t) {
  1167. it("", function() {
  1168. var newSCP = mainServiceInfoConfigsController.createNewSCP(t.overrides, t._serviceConfigProperty, t.serviceConfigProperty, t.defaultGroupSelected);
  1169. expect(newSCP.getProperties("value", "isOriginalSCP", "parentSCP", "group", "isEditable")).to.eql(t.newSCP);
  1170. });
  1171. });
  1172. });
  1173. });