config_test.js 38 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252
  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(mainServiceInfoConfigsController, "loadStep", Em.K);
  358. });
  359. afterEach(function () {
  360. mainServiceInfoConfigsController.loadStep.restore();
  361. });
  362. it("trigger loadStep", function () {
  363. mainServiceInfoConfigsController.doCancel();
  364. expect(mainServiceInfoConfigsController.loadStep.calledOnce).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 content property in non standart method", function () {
  451. expect(mainServiceInfoConfigsController.setServerConfigValue("content", "value")).to.equal("value");
  452. });
  453. it("parsing default properties", function () {
  454. expect(mainServiceInfoConfigsController.setServerConfigValue("any.other.property", "value&lt;")).to.equal("value<");
  455. });
  456. });
  457. describe("#createSiteObj", function () {
  458. var tests = [
  459. {
  460. siteName: "hdfs-site",
  461. tagName: "version1",
  462. siteObj: Em.A([
  463. {
  464. name: "property1",
  465. value: "value1"
  466. },
  467. {
  468. name: "property2",
  469. value: "value2&lt;"
  470. }
  471. ]),
  472. result: {
  473. "type": "hdfs-site",
  474. "tag": "version1",
  475. "properties": {
  476. "property1": "value1",
  477. "property2": "value2<"
  478. }
  479. },
  480. m: "default"
  481. },
  482. {
  483. siteName: "falcon-startup.properties",
  484. tagName: "version1",
  485. siteObj: Em.A([
  486. {
  487. name: "property1",
  488. value: "value1"
  489. },
  490. {
  491. name: "property2",
  492. value: "value2&lt;"
  493. }
  494. ]),
  495. result: {
  496. "type": "falcon-startup.properties",
  497. "tag": "version1",
  498. "properties": {
  499. "property1": "value1",
  500. "property2": "value2&lt;"
  501. }
  502. },
  503. m: "for falcon-startup.properties"
  504. }
  505. ];
  506. tests.forEach(function (t) {
  507. it("create site object " + t.m, function () {
  508. expect(mainServiceInfoConfigsController.createSiteObj(t.siteName, t.tagName, t.siteObj)).to.deep.eql(t.result)
  509. });
  510. });
  511. });
  512. describe("#createCoreSiteObj", function () {
  513. var tests = [
  514. {
  515. tagName: "version1",
  516. uiConfigs: Em.A([
  517. Em.Object.create({
  518. name: "property1",
  519. value: "value1",
  520. filename: "core-site.xml"
  521. }),
  522. Em.Object.create({
  523. name: "property2",
  524. value: "value2&lt;",
  525. filename: "core-site.xml"
  526. })
  527. ]),
  528. result: {
  529. "type": "core-site",
  530. "tag": "version1",
  531. "properties": {
  532. "property1": "value1",
  533. "property2": "value2<"
  534. }
  535. }
  536. }
  537. ];
  538. tests.forEach(function (t) {
  539. it("create core object", function () {
  540. mainServiceInfoConfigsController.set("uiConfigs", t.uiConfigs);
  541. expect(mainServiceInfoConfigsController.createCoreSiteObj(t.tagName)).to.deep.eql(t.result);
  542. });
  543. });
  544. });
  545. describe("#doPUTClusterConfigurationSites", function () {
  546. var sc = [
  547. Em.Object.create({
  548. configs: [
  549. Em.Object.create({
  550. name: '_heapsize',
  551. value: '1024m'
  552. }),
  553. Em.Object.create({
  554. name: '_newsize',
  555. value: '1024m'
  556. }),
  557. Em.Object.create({
  558. name: '_maxnewsize',
  559. value: '1024m'
  560. })
  561. ]
  562. })
  563. ],
  564. scExc = [
  565. Em.Object.create({
  566. configs: [
  567. Em.Object.create({
  568. name: 'hadoop_heapsize',
  569. value: '1024m'
  570. }),
  571. Em.Object.create({
  572. name: 'yarn_heapsize',
  573. value: '1024m'
  574. }),
  575. Em.Object.create({
  576. name: 'nodemanager_heapsize',
  577. value: '1024m'
  578. }),
  579. Em.Object.create({
  580. name: 'resourcemanager_heapsize',
  581. value: '1024m'
  582. }),
  583. Em.Object.create({
  584. name: 'apptimelineserver_heapsize',
  585. value: '1024m'
  586. }),
  587. Em.Object.create({
  588. name: 'jobhistory_heapsize',
  589. value: '1024m'
  590. })
  591. ]
  592. })
  593. ];
  594. beforeEach(function () {
  595. sinon.stub(App.router, 'getClusterName', function() {
  596. return 'clName';
  597. });
  598. sinon.stub(App.ajax, "send", Em.K);
  599. });
  600. afterEach(function () {
  601. App.ajax.send.restore();
  602. App.router.getClusterName.restore();
  603. });
  604. it("ajax request to put clsuter cfg", function () {
  605. mainServiceInfoConfigsController.set('stepConfigs', sc);
  606. expect(mainServiceInfoConfigsController.doPUTClusterConfigurationSites([])).to.equal(mainServiceInfoConfigsController.get("doPUTClusterConfigurationSiteResult"));
  607. expect(App.ajax.send.calledOnce).to.be.true;
  608. });
  609. it('values should be parsed', function () {
  610. mainServiceInfoConfigsController.set('stepConfigs', sc);
  611. mainServiceInfoConfigsController.doPUTClusterConfigurationSites([]);
  612. expect(mainServiceInfoConfigsController.get('stepConfigs')[0].get('configs').mapProperty('value').uniq()).to.eql(['1024']);
  613. });
  614. it('values should not be parsed', function () {
  615. mainServiceInfoConfigsController.set('stepConfigs', scExc);
  616. mainServiceInfoConfigsController.doPUTClusterConfigurationSites([]);
  617. expect(mainServiceInfoConfigsController.get('stepConfigs')[0].get('configs').mapProperty('value').uniq()).to.eql(['1024m']);
  618. });
  619. });
  620. describe("#isConfigChanged", function () {
  621. var tests = [
  622. {
  623. loadedConfig: {
  624. apptimelineserver_heapsize: "1024",
  625. hbase_log_dir: "/var/log/hbase",
  626. lzo_enabled: "true"
  627. },
  628. savingConfig: {
  629. apptimelineserver_heapsize: "1024",
  630. hbase_log_dir: "/var/log/hbase",
  631. lzo_enabled: "true"
  632. },
  633. m: "configs doesn't changed",
  634. res: false
  635. },
  636. {
  637. loadedConfig: {
  638. apptimelineserver_heapsize: "1024",
  639. hbase_log_dir: "/var/log/hbase",
  640. lzo_enabled: "true"
  641. },
  642. savingConfig: {
  643. apptimelineserver_heapsize: "1024",
  644. hbase_log_dir: "/var/log/hbase",
  645. lzo_enabled: "false"
  646. },
  647. m: "configs changed",
  648. res: true
  649. },
  650. {
  651. loadedConfig: {
  652. apptimelineserver_heapsize: "1024",
  653. hbase_log_dir: "/var/log/hbase"
  654. },
  655. savingConfig: {
  656. apptimelineserver_heapsize: "1024",
  657. hbase_log_dir: "/var/log/hbase",
  658. lzo_enabled: "false"
  659. },
  660. m: "add new config",
  661. res: true
  662. }
  663. ];
  664. tests.forEach(function(t){
  665. it(t.m, function () {
  666. expect(mainServiceInfoConfigsController.isConfigChanged(t.loadedConfig, t.savingConfig)).to.equal(t.res);
  667. });
  668. });
  669. });
  670. describe("#addDynamicProperties", function() {
  671. var tests = [
  672. {
  673. stepConfigs: [Em.Object.create({
  674. serviceName: "WEBHCAT",
  675. configs: []
  676. })],
  677. content: Em.Object.create({
  678. serviceName: "WEBHCAT"
  679. }),
  680. m: "add dynamic property",
  681. addDynamic: true
  682. },
  683. {
  684. stepConfigs: [Em.Object.create({
  685. serviceName: "WEBHCAT",
  686. configs: [
  687. Em.Object.create({
  688. name: "templeton.hive.properties"
  689. })
  690. ]
  691. })],
  692. content: Em.Object.create({
  693. serviceName: "WEBHCAT"
  694. }),
  695. m: "don't add dynamic property (already included)",
  696. addDynamic: false
  697. },
  698. {
  699. stepConfigs: [Em.Object.create({
  700. serviceName: "HDFS",
  701. configs: []
  702. })],
  703. content: Em.Object.create({
  704. serviceName: "HDFS"
  705. }),
  706. m: "don't add dynamic property (wrong service)",
  707. addDynamic: false
  708. }
  709. ];
  710. var dynamicProperty = {
  711. "name": "templeton.hive.properties",
  712. "templateName": ["hivemetastore_host"],
  713. "foreignKey": null,
  714. "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",
  715. "filename": "webhcat-site.xml"
  716. };
  717. tests.forEach(function(t) {
  718. it(t.m, function() {
  719. mainServiceInfoConfigsController.set("content", t.content);
  720. mainServiceInfoConfigsController.set("stepConfigs", t.stepConfigs);
  721. var configs = [];
  722. mainServiceInfoConfigsController.addDynamicProperties(configs);
  723. if (t.addDynamic){
  724. expect(configs.findProperty("name","templeton.hive.properties")).to.deep.eql(dynamicProperty);
  725. }
  726. });
  727. });
  728. });
  729. describe("#loadUiSideConfigs", function () {
  730. var t = {
  731. configMapping: [
  732. {
  733. foreignKey: null,
  734. templateName: "",
  735. value: "default",
  736. name: "name1",
  737. filename: "filename1"
  738. },
  739. {
  740. foreignKey: "notNull",
  741. templateName: "",
  742. value: "default2",
  743. name: "name2",
  744. filename: "filename2"
  745. }
  746. ],
  747. configMappingf: [
  748. {
  749. foreignKey: null,
  750. templateName: "",
  751. value: "default",
  752. name: "name1",
  753. filename: "filename1"
  754. }
  755. ],
  756. valueWithOverrides: {
  757. "value": "default",
  758. "overrides": {
  759. "value1": "value1",
  760. "value2": "value2"
  761. }
  762. },
  763. uiConfigs: [
  764. {
  765. "id": "site property",
  766. "name": "name1",
  767. "value": "default",
  768. "filename": "filename1",
  769. "overrides": {
  770. "value1": "value1",
  771. "value2": "value2"
  772. }
  773. }
  774. ]
  775. };
  776. beforeEach(function(){
  777. sinon.stub(mainServiceInfoConfigsController, "addDynamicProperties", Em.K);
  778. sinon.stub(mainServiceInfoConfigsController, "getGlobConfigValueWithOverrides", function () {
  779. return t.valueWithOverrides
  780. });
  781. });
  782. afterEach(function(){
  783. mainServiceInfoConfigsController.addDynamicProperties.restore();
  784. mainServiceInfoConfigsController.getGlobConfigValueWithOverrides.restore();
  785. });
  786. it("load ui config", function() {
  787. expect(mainServiceInfoConfigsController.loadUiSideConfigs(t.configMapping)[0]).to.deep.equal(t.uiConfigs[0]);
  788. expect(mainServiceInfoConfigsController.addDynamicProperties.calledWith(t.configMappingf)).to.equal(true);
  789. });
  790. });
  791. describe("#formatConfigValues", function () {
  792. var t = {
  793. configs: [
  794. Em.Object.create({ name: "p1", value: " v1 v1 ", displayType: "" }),
  795. Em.Object.create({ name: "p2", value: true, displayType: "" }),
  796. Em.Object.create({ name: "p3", value: " d1 ", displayType: "directory" }),
  797. Em.Object.create({ name: "p4", value: " d1 d2 d3 ", displayType: "directories" }),
  798. Em.Object.create({ name: "p5", value: " v1 ", displayType: "password" }),
  799. Em.Object.create({ name: "p6", value: " v ", displayType: "host" }),
  800. Em.Object.create({ name: "javax.jdo.option.ConnectionURL", value: " v1 ", displayType: "advanced" }),
  801. Em.Object.create({ name: "oozie.service.JPAService.jdbc.url", value: " v1 ", displayType: "advanced" })
  802. ],
  803. result: [
  804. Em.Object.create({ name: "p1", value: " v1 v1", displayType: "" }),
  805. Em.Object.create({ name: "p2", value: "true", displayType: "" }),
  806. Em.Object.create({ name: "p3", value: "d1", displayType: "directory" }),
  807. Em.Object.create({ name: "p4", value: "d1,d2,d3", displayType: "directories" }),
  808. Em.Object.create({ name: "p5", value: " v1 ", displayType: "password" }),
  809. Em.Object.create({ name: "p6", value: "v", displayType: "host" }),
  810. Em.Object.create({ name: "javax.jdo.option.ConnectionURL", value: " v1", displayType: "advanced" }),
  811. Em.Object.create({ name: "oozie.service.JPAService.jdbc.url", value: " v1", displayType: "advanced" })
  812. ]
  813. };
  814. it("format config values", function () {
  815. mainServiceInfoConfigsController.formatConfigValues(t.configs);
  816. expect(t.configs).to.deep.equal(t.result);
  817. });
  818. });
  819. describe("#createConfigObject", function() {
  820. var tests = [
  821. {
  822. siteName: "core-site",
  823. serviceName: "HDFS",
  824. method: "createCoreSiteObj"
  825. },
  826. {
  827. siteName: "core-site",
  828. serviceName: "ANY",
  829. method: false
  830. },
  831. {
  832. siteName: "any",
  833. method: "createSiteObj"
  834. },
  835. {
  836. siteName: "mapred-queue-acls",
  837. method: false,
  838. capacitySchedulerUi: false
  839. },
  840. {
  841. siteName: "mapred-queue-acls",
  842. method: "createSiteObj",
  843. capacitySchedulerUi: true
  844. }
  845. ];
  846. var capacitySchedulerUi = App.supports.capacitySchedulerUi;
  847. beforeEach(function() {
  848. sinon.stub(mainServiceInfoConfigsController, "createCoreSiteObj", Em.K);
  849. sinon.stub(mainServiceInfoConfigsController, "createSiteObj", Em.K);
  850. mainServiceInfoConfigsController.set("content", {});
  851. });
  852. afterEach(function() {
  853. mainServiceInfoConfigsController.createCoreSiteObj.restore();
  854. mainServiceInfoConfigsController.createSiteObj.restore();
  855. App.supports.capacitySchedulerUi = capacitySchedulerUi;
  856. });
  857. tests.forEach(function(t) {
  858. it("create object for " + t.siteName + " run method " + t.method, function() {
  859. App.supports.capacitySchedulerUi = t.capacitySchedulerUi;
  860. mainServiceInfoConfigsController.set("content.serviceName", t.serviceName);
  861. mainServiceInfoConfigsController.createConfigObject(t.siteName, "versrion1");
  862. if (t.method) {
  863. expect(mainServiceInfoConfigsController[t.method].calledOnce).to.equal(true);
  864. } else {
  865. expect(mainServiceInfoConfigsController["createCoreSiteObj"].calledOnce).to.equal(false);
  866. expect(mainServiceInfoConfigsController["createSiteObj"].calledOnce).to.equal(false);
  867. }
  868. });
  869. });
  870. });
  871. describe("#putConfigGroupChanges", function() {
  872. var t = {
  873. data: {
  874. ConfigGroup: {
  875. id: "id"
  876. }
  877. },
  878. request: [{
  879. ConfigGroup: {
  880. id: "id"
  881. }
  882. }]
  883. };
  884. beforeEach(function() {
  885. sinon.spy($,"ajax");
  886. });
  887. afterEach(function() {
  888. $.ajax.restore();
  889. });
  890. it("updates configs groups", function() {
  891. mainServiceInfoConfigsController.putConfigGroupChanges(t.data);
  892. expect(JSON.parse($.ajax.args[0][0].data)).to.deep.equal(t.request);
  893. });
  894. });
  895. describe("#setValueForCheckBox", function() {
  896. var tests = [
  897. {
  898. serviceConfigPropertyInput: Em.Object.create({
  899. value: "true",
  900. defaultValue: "true",
  901. displayType: 'checkbox'
  902. }),
  903. serviceConfigProperty: Em.Object.create({
  904. value: true,
  905. defaultValue: true,
  906. displayType: 'checkbox'
  907. })
  908. },
  909. {
  910. serviceConfigPropertyInput: Em.Object.create({
  911. value: "false",
  912. defaultValue: "false",
  913. displayType: 'checkbox'
  914. }),
  915. serviceConfigProperty: Em.Object.create({
  916. value: false,
  917. defaultValue: false,
  918. displayType: 'checkbox'
  919. })
  920. },
  921. {
  922. serviceConfigPropertyInput: Em.Object.create({
  923. value: "false",
  924. defaultValue: "false"
  925. }),
  926. serviceConfigProperty: Em.Object.create({
  927. value: "false",
  928. defaultValue: "false"
  929. })
  930. }
  931. ];
  932. tests.forEach(function(t) {
  933. it("set " + t.serviceConfigPropertyInput.value, function(){
  934. var serviceConfigProperty = t.serviceConfigPropertyInput;
  935. mainServiceInfoConfigsController.setValueForCheckBox(serviceConfigProperty);
  936. expect(serviceConfigProperty).to.eql(t.serviceConfigProperty);
  937. });
  938. });
  939. });
  940. describe("#setEditability", function () {
  941. var tests = [
  942. {
  943. isAdmin: true,
  944. isHostsConfigsPage: false,
  945. defaultGroupSelected: true,
  946. isReconfigurable: true,
  947. isEditable: true,
  948. m: ""
  949. },
  950. {
  951. isAdmin: false,
  952. isHostsConfigsPage: false,
  953. defaultGroupSelected: true,
  954. isReconfigurable: true,
  955. isEditable: false,
  956. m: "(non admin)"
  957. },
  958. {
  959. isAdmin: true,
  960. isHostsConfigsPage: true,
  961. defaultGroupSelected: true,
  962. isReconfigurable: true,
  963. isEditable: false,
  964. m: "(isHostsConfigsPage)"
  965. },
  966. {
  967. isAdmin: true,
  968. isHostsConfigsPage: false,
  969. defaultGroupSelected: false,
  970. isReconfigurable: true,
  971. isEditable: false,
  972. m: "(defaultGroupSelected is false)"
  973. },
  974. {
  975. isAdmin: true,
  976. isHostsConfigsPage: false,
  977. defaultGroupSelected: true,
  978. isReconfigurable: false,
  979. isEditable: false,
  980. m: "(isReconfigurable is false)"
  981. }
  982. ];
  983. var a = App.get('isAdmin');
  984. afterEach(function () {
  985. App.set('isAdmin', a);
  986. });
  987. tests.forEach(function(t) {
  988. it("set isEditable " + t.isEditable + t.m, function(){
  989. App.set('isAdmin', t.isAdmin);
  990. mainServiceInfoConfigsController.set("isHostsConfigsPage", t.isHostsConfigsPage);
  991. var serviceConfigProperty = Em.Object.create({
  992. isReconfigurable: t.isReconfigurable
  993. });
  994. mainServiceInfoConfigsController.setEditability(serviceConfigProperty, t.defaultGroupSelected);
  995. expect(serviceConfigProperty.get("isEditable")).to.equal(t.isEditable);
  996. });
  997. });
  998. });
  999. describe("#checkOverrideProperty", function () {
  1000. var tests = [{
  1001. overrideToAdd: {
  1002. name: "name1",
  1003. filename: "filename1"
  1004. },
  1005. componentConfig: {
  1006. configs: [
  1007. {
  1008. name: "name1",
  1009. filename: "filename2"
  1010. },
  1011. {
  1012. name: "name1",
  1013. filename: "filename1"
  1014. }
  1015. ]
  1016. },
  1017. add: true,
  1018. m: "add property"
  1019. },
  1020. {
  1021. overrideToAdd: {
  1022. name: "name1"
  1023. },
  1024. componentConfig: {
  1025. configs: [
  1026. {
  1027. name: "name2"
  1028. }
  1029. ]
  1030. },
  1031. add: false,
  1032. m: "don't add property, different names"
  1033. },
  1034. {
  1035. overrideToAdd: {
  1036. name: "name1",
  1037. filename: "filename1"
  1038. },
  1039. componentConfig: {
  1040. configs: [
  1041. {
  1042. name: "name1",
  1043. filename: "filename2"
  1044. }
  1045. ]
  1046. },
  1047. add: false,
  1048. m: "don't add property, different filenames"
  1049. },
  1050. {
  1051. overrideToAdd: null,
  1052. componentConfig: {},
  1053. add: false,
  1054. m: "don't add property, overrideToAdd is null"
  1055. }];
  1056. beforeEach(function() {
  1057. sinon.stub(mainServiceInfoConfigsController,"addOverrideProperty", Em.K)
  1058. });
  1059. afterEach(function() {
  1060. mainServiceInfoConfigsController.addOverrideProperty.restore();
  1061. });
  1062. tests.forEach(function(t) {
  1063. it(t.m, function() {
  1064. mainServiceInfoConfigsController.set("overrideToAdd", t.overrideToAdd);
  1065. mainServiceInfoConfigsController.checkOverrideProperty(t.componentConfig);
  1066. if(t.add) {
  1067. expect(mainServiceInfoConfigsController.addOverrideProperty.calledWith(t.overrideToAdd)).to.equal(true);
  1068. expect(mainServiceInfoConfigsController.get("overrideToAdd")).to.equal(null);
  1069. } else {
  1070. expect(mainServiceInfoConfigsController.addOverrideProperty.calledOnce).to.equal(false);
  1071. }
  1072. });
  1073. });
  1074. });
  1075. describe("#setValuesForOverrides", function() {
  1076. var tests = [
  1077. {
  1078. overrides: [
  1079. {name: "override1"},
  1080. {name: "override2"}
  1081. ],
  1082. _serviceConfigProperty: {},
  1083. serviceConfigProperty: Em.Object.create({overrides: Em.A([])}),
  1084. defaultGroupSelected: true
  1085. }
  1086. ];
  1087. beforeEach(function() {
  1088. sinon.stub(mainServiceInfoConfigsController, "createNewSCP", function(override) {return {name: override.name}})
  1089. });
  1090. afterEach(function() {
  1091. mainServiceInfoConfigsController.createNewSCP.restore();
  1092. });
  1093. tests.forEach(function(t) {
  1094. it("set values for overrides. use createNewSCP method to do this", function() {
  1095. var serviceConfigProperty = t.serviceConfigProperty;
  1096. mainServiceInfoConfigsController.setValuesForOverrides(t.overrides, serviceConfigProperty, t.serviceConfigProperty, t.defaultGroupSelected);
  1097. expect(serviceConfigProperty.get("overrides")[0]).to.eql(t.overrides[0]);
  1098. expect(serviceConfigProperty.get("overrides")[1]).to.eql(t.overrides[1]);
  1099. });
  1100. });
  1101. });
  1102. describe("#createConfigProperty", function() {
  1103. var tests = [
  1104. {
  1105. _serviceConfigProperty: {
  1106. overrides: {
  1107. }
  1108. },
  1109. defaultGroupSelected: true,
  1110. restartData: {},
  1111. serviceConfigsData: {},
  1112. serviceConfigProperty: {
  1113. overrides: null,
  1114. isOverridable: true
  1115. }
  1116. }];
  1117. beforeEach(function() {
  1118. sinon.stub(mainServiceInfoConfigsController, "setValueForCheckBox", Em.K);
  1119. sinon.stub(mainServiceInfoConfigsController, "setValidator", Em.K);
  1120. sinon.stub(mainServiceInfoConfigsController, "setValuesForOverrides", Em.K);
  1121. sinon.stub(mainServiceInfoConfigsController, "setEditability", Em.K);
  1122. });
  1123. afterEach(function() {
  1124. mainServiceInfoConfigsController.setValueForCheckBox.restore();
  1125. mainServiceInfoConfigsController.setValidator.restore();
  1126. mainServiceInfoConfigsController.setValuesForOverrides.restore();
  1127. mainServiceInfoConfigsController.setEditability.restore();
  1128. });
  1129. tests.forEach(function(t) {
  1130. it("create service config. run methods to correctly set object fileds", function() {
  1131. var result = mainServiceInfoConfigsController.createConfigProperty(t._serviceConfigProperty, t.defaultGroupSelected, t.restartData, t.serviceConfigsData);
  1132. expect(mainServiceInfoConfigsController.setValueForCheckBox.calledWith(t.serviceConfigProperty));
  1133. expect(mainServiceInfoConfigsController.setValidator.calledWith(t.serviceConfigProperty, t.serviceConfigsData));
  1134. expect(mainServiceInfoConfigsController.setValuesForOverrides.calledWith(t._serviceConfigProperty.overrides, t._serviceConfigProperty, t.serviceConfigProperty, t.defaultGroupSelected));
  1135. expect(mainServiceInfoConfigsController.setValidator.calledWith(t.serviceConfigProperty, t.defaultGroupSelected));
  1136. expect(result.getProperties('overrides','isOverridable')).to.eql(t.serviceConfigProperty);
  1137. });
  1138. });
  1139. });
  1140. describe("#createNewSCP", function() {
  1141. var tests = [
  1142. {
  1143. overrides: {
  1144. value: "value",
  1145. group: {
  1146. value: "group1"
  1147. }
  1148. },
  1149. _serviceConfigProperty: {},
  1150. serviceConfigProperty: Em.Object.create({
  1151. value: "parentSCP",
  1152. supportsFinal: true
  1153. }),
  1154. defaultGroupSelected: true,
  1155. newSCP: {
  1156. value: "value",
  1157. isOriginalSCP: false,
  1158. parentSCP:Em.Object.create({
  1159. value: "parentSCP",
  1160. supportsFinal: true
  1161. }),
  1162. group: {
  1163. value: "group1"
  1164. },
  1165. isEditable: false
  1166. }
  1167. }
  1168. ];
  1169. tests.forEach(function(t) {
  1170. it("", function() {
  1171. var newSCP = mainServiceInfoConfigsController.createNewSCP(t.overrides, t._serviceConfigProperty, t.serviceConfigProperty, t.defaultGroupSelected);
  1172. expect(newSCP.getProperties("value", "isOriginalSCP", "parentSCP", "group", "isEditable")).to.eql(t.newSCP);
  1173. });
  1174. });
  1175. });
  1176. });