config_test.js 36 KB

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