123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293129412951296129712981299130013011302130313041305130613071308130913101311131213131314131513161317131813191320132113221323132413251326132713281329133013311332133313341335133613371338133913401341134213431344134513461347134813491350135113521353135413551356135713581359136013611362136313641365136613671368136913701371137213731374137513761377137813791380138113821383138413851386138713881389139013911392139313941395139613971398139914001401140214031404140514061407140814091410141114121413141414151416141714181419142014211422142314241425142614271428142914301431143214331434143514361437143814391440144114421443144414451446144714481449145014511452145314541455145614571458145914601461146214631464146514661467146814691470147114721473147414751476 |
- /**
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
- var App = require('app');
- require('controllers/main/service/info/configs');
- var batchUtils = require('utils/batch_scheduled_requests');
- var mainServiceInfoConfigsController = null;
- describe("App.MainServiceInfoConfigsController", function () {
- beforeEach(function () {
- mainServiceInfoConfigsController = App.MainServiceInfoConfigsController.create({});
- });
- describe("#showSavePopup", function () {
- var tests = [
- {
- path: false,
- callback: null,
- action: "onSave",
- m: "save configs without path/callback",
- results: [
- {
- method: "restartServicePopup",
- called: true
- }
- ]
- },
- {
- path: true,
- callback: true,
- action: "onSave",
- m: "save configs with path/callback",
- results: [
- {
- method: "restartServicePopup",
- called: true
- }
- ]
- },
- {
- path: false,
- callback: false,
- action: "onDiscard",
- m: "discard changes without path/callback",
- results: [
- {
- method: "restartServicePopup",
- called: false
- }
- ]
- },
- {
- path: false,
- callback: true,
- action: "onDiscard",
- m: "discard changes with callback",
- results: [
- {
- method: "restartServicePopup",
- called: false
- },
- {
- method: "callback",
- called: true
- },
- {
- field: "hash",
- value: "hash"
- }
- ]
- },
- {
- path: true,
- callback: null,
- action: "onDiscard",
- m: "discard changes with path",
- results: [
- {
- method: "restartServicePopup",
- called: false
- },
- {
- field: "forceTransition",
- value: true
- }
- ]
- }
- ];
- beforeEach(function () {
- sinon.stub(mainServiceInfoConfigsController, "restartServicePopup", Em.K);
- sinon.stub(mainServiceInfoConfigsController, "getHash", function () {
- return "hash"
- });
- App.router.route = Em.K;
- });
- afterEach(function () {
- mainServiceInfoConfigsController.restartServicePopup.restore();
- mainServiceInfoConfigsController.getHash.restore();
- });
- tests.forEach(function (t) {
- t.results.forEach(function (r) {
- it(t.m + " " + r.method + " " + r.field, function () {
- if (t.callback) {
- t.callback = sinon.stub();
- }
- mainServiceInfoConfigsController.showSavePopup(t.path, t.callback)[t.action]();
- if (r.method) {
- if (r.method === 'callback') {
- expect(t.callback.calledOnce).to.equal(r.called);
- } else {
- expect(mainServiceInfoConfigsController[r.method].calledOnce).to.equal(r.called);
- }
- } else if (r.field) {
- expect(mainServiceInfoConfigsController.get(r.field)).to.equal(r.value);
- }
- }, this);
- });
- }, this);
- });
- describe("#hasUnsavedChanges", function () {
- beforeEach(function () {
- sinon.stub(mainServiceInfoConfigsController, "getHash", function () {
- return "hash"
- });
- });
- afterEach(function () {
- mainServiceInfoConfigsController.getHash.restore();
- });
- it("with unsaved", function () {
- mainServiceInfoConfigsController.set("hash", "hash1");
- expect(mainServiceInfoConfigsController.hasUnsavedChanges()).to.equal(true);
- });
- it("without unsaved", function () {
- mainServiceInfoConfigsController.set("hash", "hash");
- expect(mainServiceInfoConfigsController.hasUnsavedChanges()).to.equal(false);
- });
- });
- describe("#manageConfigurationGroup", function () {
- beforeEach(function () {
- sinon.stub(mainServiceInfoConfigsController, "manageConfigurationGroups", Em.K);
- });
- afterEach(function () {
- mainServiceInfoConfigsController.manageConfigurationGroups.restore();
- });
- it("run manageConfigurationGroups", function () {
- mainServiceInfoConfigsController.manageConfigurationGroup();
- expect(mainServiceInfoConfigsController.manageConfigurationGroups.calledOnce).to.equal(true);
- });
- });
- describe("#addOverrideProperty", function () {
- var serviceConfigProperty = Em.Object.create({
- overrides: []
- });
- var newSCP = App.ServiceConfigProperty.create(serviceConfigProperty);
- newSCP.set('value', '');
- newSCP.set('isOriginalSCP', false);
- newSCP.set('parentSCP', serviceConfigProperty);
- newSCP.set('isEditable', true);
- it("add new overridden property", function () {
- mainServiceInfoConfigsController.addOverrideProperty(serviceConfigProperty);
- expect(serviceConfigProperty.get("overrides")[0]).to.eql(newSCP);
- });
- });
- describe("#showComponentsShouldBeRestarted", function () {
- var tests = [
- {
- input: {
- 'publicHostName1': ['TaskTracker'],
- 'publicHostName2': ['JobTracker', 'TaskTracker']
- },
- components: "2 TaskTrackers, 1 JobTracker",
- text: Em.I18n.t('service.service.config.restartService.shouldBeRestarted').format(Em.I18n.t('common.components'))
- },
- {
- input: {
- 'publicHostName1': ['TaskTracker']
- },
- components: "1 TaskTracker",
- text: Em.I18n.t('service.service.config.restartService.shouldBeRestarted').format(Em.I18n.t('common.component'))
- }
- ];
- beforeEach(function () {
- sinon.stub(mainServiceInfoConfigsController, "showItemsShouldBeRestarted", Em.K);
- mainServiceInfoConfigsController.set("content", {restartRequiredHostsAndComponents: ""});
- });
- afterEach(function () {
- mainServiceInfoConfigsController.showItemsShouldBeRestarted.restore();
- mainServiceInfoConfigsController.set("content", undefined);
- });
- tests.forEach(function (t) {
- it("trigger showItemsShouldBeRestarted popup with components", function () {
- mainServiceInfoConfigsController.set("content.restartRequiredHostsAndComponents", t.input);
- mainServiceInfoConfigsController.showComponentsShouldBeRestarted();
- expect(mainServiceInfoConfigsController.showItemsShouldBeRestarted.calledWith(t.components, t.text)).to.equal(true);
- });
- });
- });
- describe("#showHostsShouldBeRestarted", function () {
- var tests = [
- {
- input: {
- 'publicHostName1': ['TaskTracker'],
- 'publicHostName2': ['JobTracker', 'TaskTracker']
- },
- hosts: "publicHostName1, publicHostName2",
- text: Em.I18n.t('service.service.config.restartService.shouldBeRestarted').format(Em.I18n.t('common.hosts'))
- },
- {
- input: {
- 'publicHostName1': ['TaskTracker']
- },
- hosts: "publicHostName1",
- text: Em.I18n.t('service.service.config.restartService.shouldBeRestarted').format(Em.I18n.t('common.host'))
- }
- ];
- beforeEach(function () {
- sinon.stub(mainServiceInfoConfigsController, "showItemsShouldBeRestarted", Em.K);
- mainServiceInfoConfigsController.set("content", {restartRequiredHostsAndComponents: ""});
- });
- afterEach(function () {
- mainServiceInfoConfigsController.showItemsShouldBeRestarted.restore();
- mainServiceInfoConfigsController.set("content", undefined);
- });
- tests.forEach(function (t) {
- it("trigger showItemsShouldBeRestarted popup with hosts", function () {
- mainServiceInfoConfigsController.set("content.restartRequiredHostsAndComponents", t.input);
- mainServiceInfoConfigsController.showHostsShouldBeRestarted();
- expect(mainServiceInfoConfigsController.showItemsShouldBeRestarted.calledWith(t.hosts, t.text)).to.equal(true);
- });
- });
- });
- describe("#rollingRestartStaleConfigSlaveComponents", function () {
- var tests = [
- {
- componentName: {
- context: "ComponentName"
- },
- displayName: "displayName",
- passiveState: "ON"
- },
- {
- componentName: {
- context: "ComponentName1"
- },
- displayName: "displayName1",
- passiveState: "OFF"
- }
- ];
- beforeEach(function () {
- mainServiceInfoConfigsController.set("content", {displayName: "", passiveState: ""});
- sinon.stub(batchUtils, "launchHostComponentRollingRestart", Em.K);
- });
- afterEach(function () {
- batchUtils.launchHostComponentRollingRestart.restore();
- });
- tests.forEach(function (t) {
- it("trigger rollingRestartStaleConfigSlaveComponents", function () {
- mainServiceInfoConfigsController.set("content.displayName", t.displayName);
- mainServiceInfoConfigsController.set("content.passiveState", t.passiveState);
- mainServiceInfoConfigsController.rollingRestartStaleConfigSlaveComponents(t.componentName);
- expect(batchUtils.launchHostComponentRollingRestart.calledWith(t.componentName.context, t.displayName, t.passiveState == "ON", true)).to.equal(true);
- });
- });
- });
- describe("#restartAllStaleConfigComponents", function () {
- beforeEach(function () {
- sinon.stub(batchUtils, "restartAllServiceHostComponents", Em.K);
- });
- afterEach(function () {
- batchUtils.restartAllServiceHostComponents.restore();
- });
- it("trigger restartAllServiceHostComponents", function () {
- mainServiceInfoConfigsController.restartAllStaleConfigComponents().onPrimary();
- expect(batchUtils.restartAllServiceHostComponents.calledOnce).to.equal(true);
- });
- });
- describe("#doCancel", function () {
- beforeEach(function () {
- sinon.stub(Em.run, 'once', Em.K);
- });
- afterEach(function () {
- Em.run.once.restore();
- });
- it("trigger onConfigGroupChange", function () {
- mainServiceInfoConfigsController.doCancel();
- expect(Em.run.once.calledWith(mainServiceInfoConfigsController, "onConfigGroupChange")).to.equal(true);
- });
- });
- describe("#getCurrentServiceComponents", function () {
- var t = Em.Object.create({
- content: Em.Object.create({
- hostComponents: [
- Em.Object.create({
- componentName: "componentName1",
- displayName: "displayName1"
- }),
- Em.Object.create({
- componentName: "componentName2",
- displayName: "displayName2"
- })
- ]
- }),
- validComponents: Em.A([
- Em.Object.create({
- componentName: "componentName1",
- displayName: "displayName1",
- selected: false
- }),
- Em.Object.create({
- componentName: "componentName2",
- displayName: "displayName2",
- selected: false
- })
- ])
- });
- beforeEach(function () {
- mainServiceInfoConfigsController.set("content", { hostComponents: Em.A([])});
- });
- it("get current service components", function () {
- mainServiceInfoConfigsController.get("content.hostComponents").push(t.content.hostComponents[0]);
- var com = mainServiceInfoConfigsController.get("getCurrentServiceComponents");
- expect(com[0]).to.eql(t.validComponents[0]);
- });
- });
- describe("#getMasterComponentHostValue", function () {
- var tests = [
- {
- content: {
- hostComponents: [
- Em.Object.create({
- componentName: "componentName1",
- hostName: "hostName"
- })
- ]
- },
- result: "hostName",
- multiple: false,
- m: "returns hostname"
- },
- {
- content: {
- hostComponents: [
- Em.Object.create({
- componentName: "componentName2",
- hostName: "hostName1"
- }),
- Em.Object.create({
- componentName: "componentName2",
- hostName: "hostName2"
- })
- ]
- },
- result: ["hostName1","hostName2"],
- multiple: true,
- m: "returns hostnames"
- }
- ];
- tests.forEach(function(t){
- beforeEach(function () {
- mainServiceInfoConfigsController.set("content", { hostComponents: []});
- });
- it(t.m, function () {
- mainServiceInfoConfigsController.set("content.hostComponents", t.content.hostComponents);
- expect(mainServiceInfoConfigsController.getMasterComponentHostValue(t.content.hostComponents[0].componentName, t.multiple)).to.eql(t.result);
- });
- });
- });
- describe("#setServerConfigValue", function () {
- it("parsing storm.zookeeper.servers property in non standart method", function () {
- expect(mainServiceInfoConfigsController.setServerConfigValue("storm.zookeeper.servers", ["a", "b"])).to.equal('[\'a\',\'b\']');
- });
- it("parsing default properties", function () {
- expect(mainServiceInfoConfigsController.setServerConfigValue("any.other.property", "value")).to.equal("value");
- });
- });
- describe("#createSiteObj", function () {
- var tests = [
- {
- siteName: "hdfs-site",
- tagName: "version1",
- siteObj: Em.A([
- {
- name: "property1",
- value: "value1"
- },
- {
- name: "property2",
- value: "value2<"
- },
- {
- name: "property_heapsize",
- value: "value3"
- },
- {
- name: "property_permsize",
- value: "value4m"
- }
- ]),
- result: {
- "type": "hdfs-site",
- "tag": "version1",
- "properties": {
- "property1": "value1",
- "property2": "value2<",
- "property_heapsize": "value3m",
- "property_permsize": "value4m"
- }
- },
- m: "default"
- },
- {
- siteName: "falcon-startup.properties",
- tagName: "version1",
- siteObj: Em.A([
- {
- name: "property1",
- value: "value1"
- },
- {
- name: "property2",
- value: "value2<"
- }
- ]),
- result: {
- "type": "falcon-startup.properties",
- "tag": "version1",
- "properties": {
- "property1": "value1",
- "property2": "value2<"
- }
- },
- m: "for falcon-startup.properties"
- }
- ];
- tests.forEach(function (t) {
- it("create site object " + t.m, function () {
- expect(mainServiceInfoConfigsController.createSiteObj(t.siteName, t.tagName, t.siteObj)).to.deep.eql(t.result)
- });
- });
- });
- describe("#createCoreSiteObj", function () {
- var tests = [
- {
- tagName: "version1",
- uiConfigs: Em.A([
- Em.Object.create({
- name: "property1",
- value: "value1",
- filename: "core-site.xml"
- }),
- Em.Object.create({
- name: "property2",
- value: "value2<",
- filename: "core-site.xml"
- })
- ]),
- result: {
- "type": "core-site",
- "tag": "version1",
- "properties": {
- "property1": "value1",
- "property2": "value2<"
- }
- }
- }
- ];
- tests.forEach(function (t) {
- it("create core object", function () {
- mainServiceInfoConfigsController.set("uiConfigs", t.uiConfigs);
- expect(mainServiceInfoConfigsController.createCoreSiteObj(t.tagName)).to.deep.eql(t.result);
- });
- });
- });
- describe("#doPUTClusterConfigurationSites", function () {
- var sc = [
- Em.Object.create({
- configs: [
- Em.Object.create({
- name: '_heapsize',
- value: '1024m'
- }),
- Em.Object.create({
- name: '_newsize',
- value: '1024m'
- }),
- Em.Object.create({
- name: '_maxnewsize',
- value: '1024m'
- })
- ]
- })
- ],
- scExc = [
- Em.Object.create({
- configs: [
- Em.Object.create({
- name: 'hadoop_heapsize',
- value: '1024m'
- }),
- Em.Object.create({
- name: 'yarn_heapsize',
- value: '1024m'
- }),
- Em.Object.create({
- name: 'nodemanager_heapsize',
- value: '1024m'
- }),
- Em.Object.create({
- name: 'resourcemanager_heapsize',
- value: '1024m'
- }),
- Em.Object.create({
- name: 'apptimelineserver_heapsize',
- value: '1024m'
- }),
- Em.Object.create({
- name: 'jobhistory_heapsize',
- value: '1024m'
- })
- ]
- })
- ];
- beforeEach(function () {
- sinon.stub(App.router, 'getClusterName', function() {
- return 'clName';
- });
- sinon.stub(App.ajax, "send", Em.K);
- });
- afterEach(function () {
- App.ajax.send.restore();
- App.router.getClusterName.restore();
- });
- it("ajax request to put clsuter cfg", function () {
- mainServiceInfoConfigsController.set('stepConfigs', sc);
- expect(mainServiceInfoConfigsController.doPUTClusterConfigurationSites([])).to.equal(mainServiceInfoConfigsController.get("doPUTClusterConfigurationSiteResult"));
- expect(App.ajax.send.calledOnce).to.be.true;
- });
- it('values should be parsed', function () {
- mainServiceInfoConfigsController.set('stepConfigs', sc);
- mainServiceInfoConfigsController.doPUTClusterConfigurationSites([]);
- expect(mainServiceInfoConfigsController.get('stepConfigs')[0].get('configs').mapProperty('value').uniq()).to.eql(['1024m']);
- });
- it('values should not be parsed', function () {
- mainServiceInfoConfigsController.set('stepConfigs', scExc);
- mainServiceInfoConfigsController.doPUTClusterConfigurationSites([]);
- expect(mainServiceInfoConfigsController.get('stepConfigs')[0].get('configs').mapProperty('value').uniq()).to.eql(['1024m']);
- });
- });
- describe("#isConfigChanged", function () {
- var tests = [
- {
- loadedConfig: {
- apptimelineserver_heapsize: "1024",
- hbase_log_dir: "/var/log/hbase",
- lzo_enabled: "true"
- },
- savingConfig: {
- apptimelineserver_heapsize: "1024",
- hbase_log_dir: "/var/log/hbase",
- lzo_enabled: "true"
- },
- m: "configs doesn't changed",
- res: false
- },
- {
- loadedConfig: {
- apptimelineserver_heapsize: "1024",
- hbase_log_dir: "/var/log/hbase",
- lzo_enabled: "true"
- },
- savingConfig: {
- apptimelineserver_heapsize: "1024",
- hbase_log_dir: "/var/log/hbase",
- lzo_enabled: "false"
- },
- m: "configs changed",
- res: true
- },
- {
- loadedConfig: {
- apptimelineserver_heapsize: "1024",
- hbase_log_dir: "/var/log/hbase"
- },
- savingConfig: {
- apptimelineserver_heapsize: "1024",
- hbase_log_dir: "/var/log/hbase",
- lzo_enabled: "false"
- },
- m: "add new config",
- res: true
- }
- ];
- tests.forEach(function(t){
- it(t.m, function () {
- expect(mainServiceInfoConfigsController.isConfigChanged(t.loadedConfig, t.savingConfig)).to.equal(t.res);
- });
- });
- });
- describe("#isDirChanged", function() {
- describe("when service name is HDFS", function() {
- beforeEach(function() {
- mainServiceInfoConfigsController.set('content', Ember.Object.create ({ serviceName: 'HDFS' }));
- });
- describe("when isHadoop2Stack is true", function() {
- var tests = [
- {
- it: "should set dirChanged to false if none of the properties exist",
- expect: false,
- config: Ember.Object.create ({})
- },
- {
- it: "should set dirChanged to true if dfs.namenode.name.dir is not default",
- expect: true,
- config: Ember.Object.create ({
- name: 'dfs.namenode.name.dir',
- isNotDefaultValue: true
- })
- },
- {
- it: "should set dirChanged to false if dfs.namenode.name.dir is default",
- expect: false,
- config: Ember.Object.create ({
- name: 'dfs.namenode.name.dir',
- isNotDefaultValue: false
- })
- },
- {
- it: "should set dirChanged to true if dfs.namenode.checkpoint.dir is not default",
- expect: true,
- config: Ember.Object.create ({
- name: 'dfs.namenode.checkpoint.dir',
- isNotDefaultValue: true
- })
- },
- {
- it: "should set dirChanged to false if dfs.namenode.checkpoint.dir is default",
- expect: false,
- config: Ember.Object.create ({
- name: 'dfs.namenode.checkpoint.dir',
- isNotDefaultValue: false
- })
- },
- {
- it: "should set dirChanged to true if dfs.datanode.data.dir is not default",
- expect: true,
- config: Ember.Object.create ({
- name: 'dfs.datanode.data.dir',
- isNotDefaultValue: true
- })
- },
- {
- it: "should set dirChanged to false if dfs.datanode.data.dir is default",
- expect: false,
- config: Ember.Object.create ({
- name: 'dfs.datanode.data.dir',
- isNotDefaultValue: false
- })
- }
- ];
- beforeEach(function() {
- sinon.stub(App, 'get').returns(true);
- });
- afterEach(function() {
- App.get.restore();
- });
- tests.forEach(function(test) {
- it(test.it, function() {
- mainServiceInfoConfigsController.set('stepConfigs', [Ember.Object.create ({ configs: [test.config], serviceName: 'HDFS' })]);
- expect(mainServiceInfoConfigsController.isDirChanged()).to.equal(test.expect);
- })
- });
- });
- describe("when isHadoop2Stack is false", function() {
- var tests = [
- {
- it: "should set dirChanged to false if none of the properties exist",
- expect: false,
- config: Ember.Object.create ({})
- },
- {
- it: "should set dirChanged to true if dfs.name.dir is not default",
- expect: true,
- config: Ember.Object.create ({
- name: 'dfs.name.dir',
- isNotDefaultValue: true
- })
- },
- {
- it: "should set dirChanged to false if dfs.name.dir is default",
- expect: false,
- config: Ember.Object.create ({
- name: 'dfs.name.dir',
- isNotDefaultValue: false
- })
- },
- {
- it: "should set dirChanged to true if fs.checkpoint.dir is not default",
- expect: true,
- config: Ember.Object.create ({
- name: 'fs.checkpoint.dir',
- isNotDefaultValue: true
- })
- },
- {
- it: "should set dirChanged to false if fs.checkpoint.dir is default",
- expect: false,
- config: Ember.Object.create ({
- name: 'fs.checkpoint.dir',
- isNotDefaultValue: false
- })
- },
- {
- it: "should set dirChanged to true if dfs.data.dir is not default",
- expect: true,
- config: Ember.Object.create ({
- name: 'dfs.data.dir',
- isNotDefaultValue: true
- })
- },
- {
- it: "should set dirChanged to false if dfs.data.dir is default",
- expect: false,
- config: Ember.Object.create ({
- name: 'dfs.data.dir',
- isNotDefaultValue: false
- })
- }
- ];
- beforeEach(function() {
- sinon.stub(App, 'get').returns(false);
- });
- afterEach(function() {
- App.get.restore();
- });
- tests.forEach(function(test) {
- it(test.it, function() {
- mainServiceInfoConfigsController.set('stepConfigs', [Ember.Object.create ({ configs: [test.config], serviceName: 'HDFS' })]);
- expect(mainServiceInfoConfigsController.isDirChanged()).to.equal(test.expect);
- })
- });
- });
- });
- describe("when service name is MAPREDUCE", function() {
- beforeEach(function() {
- mainServiceInfoConfigsController.set('content', Ember.Object.create ({ serviceName: 'MAPREDUCE' }));
- });
- var tests = [
- {
- it: "should set dirChanged to false if none of the properties exist",
- expect: false,
- config: Ember.Object.create ({})
- },
- {
- it: "should set dirChanged to true if mapred.local.dir is not default",
- expect: true,
- config: Ember.Object.create ({
- name: 'mapred.local.dir',
- isNotDefaultValue: true
- })
- },
- {
- it: "should set dirChanged to false if mapred.local.dir is default",
- expect: false,
- config: Ember.Object.create ({
- name: 'mapred.local.dir',
- isNotDefaultValue: false
- })
- },
- {
- it: "should set dirChanged to true if mapred.system.dir is not default",
- expect: true,
- config: Ember.Object.create ({
- name: 'mapred.system.dir',
- isNotDefaultValue: true
- })
- },
- {
- it: "should set dirChanged to false if mapred.system.dir is default",
- expect: false,
- config: Ember.Object.create ({
- name: 'mapred.system.dir',
- isNotDefaultValue: false
- })
- }
- ];
- tests.forEach(function(test) {
- it(test.it, function() {
- mainServiceInfoConfigsController.set('stepConfigs', [Ember.Object.create ({ configs: [test.config], serviceName: 'MAPREDUCE' })]);
- expect(mainServiceInfoConfigsController.isDirChanged()).to.equal(test.expect);
- })
- });
- });
- });
- describe("#addDynamicProperties", function() {
- var tests = [
- {
- stepConfigs: [Em.Object.create({
- serviceName: "HIVE",
- configs: []
- })],
- content: Em.Object.create({
- serviceName: "HIVE"
- }),
- m: "add dynamic property",
- addDynamic: true
- },
- {
- stepConfigs: [Em.Object.create({
- serviceName: "HIVE",
- configs: [
- Em.Object.create({
- name: "templeton.hive.properties"
- })
- ]
- })],
- content: Em.Object.create({
- serviceName: "HIVE"
- }),
- m: "don't add dynamic property (already included)",
- addDynamic: false
- },
- {
- stepConfigs: [Em.Object.create({
- serviceName: "HDFS",
- configs: []
- })],
- content: Em.Object.create({
- serviceName: "HDFS"
- }),
- m: "don't add dynamic property (wrong service)",
- addDynamic: false
- }
- ];
- var dynamicProperty = {
- "name": "templeton.hive.properties",
- "templateName": ["hivemetastore_host"],
- "foreignKey": null,
- "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",
- "filename": "webhcat-site.xml"
- };
- tests.forEach(function(t) {
- it(t.m, function() {
- mainServiceInfoConfigsController.set("content", t.content);
- mainServiceInfoConfigsController.set("stepConfigs", t.stepConfigs);
- var configs = [];
- mainServiceInfoConfigsController.addDynamicProperties(configs);
- if (t.addDynamic){
- expect(configs.findProperty("name","templeton.hive.properties")).to.deep.eql(dynamicProperty);
- }
- });
- });
- });
- describe("#loadUiSideConfigs", function () {
- var t = {
- configMapping: [
- {
- foreignKey: null,
- templateName: "",
- value: "default",
- name: "name1",
- filename: "filename1"
- },
- {
- foreignKey: "notNull",
- templateName: "",
- value: "default2",
- name: "name2",
- filename: "filename2"
- }
- ],
- configMappingf: [
- {
- foreignKey: null,
- templateName: "",
- value: "default",
- name: "name1",
- filename: "filename1"
- }
- ],
- valueWithOverrides: {
- "value": "default",
- "overrides": {
- "value1": "value1",
- "value2": "value2"
- }
- },
- uiConfigs: [
- {
- "id": "site property",
- "name": "name1",
- "value": "default",
- "filename": "filename1",
- "overrides": {
- "value1": "value1",
- "value2": "value2"
- }
- }
- ]
- };
- beforeEach(function(){
- sinon.stub(mainServiceInfoConfigsController, "addDynamicProperties", Em.K);
- sinon.stub(mainServiceInfoConfigsController, "getGlobConfigValueWithOverrides", function () {
- return t.valueWithOverrides
- });
- });
- afterEach(function(){
- mainServiceInfoConfigsController.addDynamicProperties.restore();
- mainServiceInfoConfigsController.getGlobConfigValueWithOverrides.restore();
- });
- it("load ui config", function() {
- expect(mainServiceInfoConfigsController.loadUiSideConfigs(t.configMapping)[0]).to.deep.equal(t.uiConfigs[0]);
- expect(mainServiceInfoConfigsController.addDynamicProperties.calledWith(t.configMappingf)).to.equal(true);
- });
- });
- describe("#formatConfigValues", function () {
- var t = {
- configs: [
- Em.Object.create({ name: "p1", value: " v1 v1 ", displayType: "" }),
- Em.Object.create({ name: "p2", value: true, displayType: "" }),
- Em.Object.create({ name: "p3", value: " d1 ", displayType: "directory" }),
- Em.Object.create({ name: "p4", value: " d1 d2 d3 ", displayType: "directories" }),
- Em.Object.create({ name: "p5", value: " v1 ", displayType: "password" }),
- Em.Object.create({ name: "p6", value: " v ", displayType: "host" }),
- Em.Object.create({ name: "javax.jdo.option.ConnectionURL", value: " v1 ", displayType: "advanced" }),
- Em.Object.create({ name: "oozie.service.JPAService.jdbc.url", value: " v1 ", displayType: "advanced" })
- ],
- result: [
- Em.Object.create({ name: "p1", value: " v1 v1", displayType: "" }),
- Em.Object.create({ name: "p2", value: "true", displayType: "" }),
- Em.Object.create({ name: "p3", value: "d1", displayType: "directory" }),
- Em.Object.create({ name: "p4", value: "d1,d2,d3", displayType: "directories" }),
- Em.Object.create({ name: "p5", value: " v1 ", displayType: "password" }),
- Em.Object.create({ name: "p6", value: "v", displayType: "host" }),
- Em.Object.create({ name: "javax.jdo.option.ConnectionURL", value: " v1", displayType: "advanced" }),
- Em.Object.create({ name: "oozie.service.JPAService.jdbc.url", value: " v1", displayType: "advanced" })
- ]
- };
- it("format config values", function () {
- mainServiceInfoConfigsController.formatConfigValues(t.configs);
- expect(t.configs).to.deep.equal(t.result);
- });
- });
- describe("#createConfigObject", function() {
- var tests = [
- {
- siteName: "core-site",
- serviceName: "HDFS",
- method: "createCoreSiteObj"
- },
- {
- siteName: "core-site",
- serviceName: "ANY",
- method: false
- },
- {
- siteName: "any",
- method: "createSiteObj"
- },
- {
- siteName: "mapred-queue-acls",
- method: false
- }
- ];
- beforeEach(function() {
- sinon.stub(mainServiceInfoConfigsController, "createCoreSiteObj", Em.K);
- sinon.stub(mainServiceInfoConfigsController, "createSiteObj", Em.K);
- mainServiceInfoConfigsController.set("content", {});
- });
- afterEach(function() {
- mainServiceInfoConfigsController.createCoreSiteObj.restore();
- mainServiceInfoConfigsController.createSiteObj.restore();
- });
- tests.forEach(function(t) {
- it("create object for " + t.siteName + " run method " + t.method, function() {
- mainServiceInfoConfigsController.set("content.serviceName", t.serviceName);
- mainServiceInfoConfigsController.createConfigObject(t.siteName, "versrion1");
- if (t.method) {
- expect(mainServiceInfoConfigsController[t.method].calledOnce).to.equal(true);
- } else {
- expect(mainServiceInfoConfigsController["createCoreSiteObj"].calledOnce).to.equal(false);
- expect(mainServiceInfoConfigsController["createSiteObj"].calledOnce).to.equal(false);
- }
- });
- });
- });
- describe("#putConfigGroupChanges", function() {
- var t = {
- data: {
- ConfigGroup: {
- id: "id"
- }
- },
- request: [{
- ConfigGroup: {
- id: "id"
- }
- }]
- };
- beforeEach(function() {
- sinon.spy($,"ajax");
- });
- afterEach(function() {
- $.ajax.restore();
- });
- it("updates configs groups", function() {
- mainServiceInfoConfigsController.putConfigGroupChanges(t.data);
- expect(JSON.parse($.ajax.args[0][0].data)).to.deep.equal(t.request);
- });
- });
- describe("#setValueForCheckBox", function() {
- var tests = [
- {
- serviceConfigPropertyInput: Em.Object.create({
- value: "true",
- defaultValue: "true",
- displayType: 'checkbox'
- }),
- serviceConfigProperty: Em.Object.create({
- value: true,
- defaultValue: true,
- displayType: 'checkbox'
- })
- },
- {
- serviceConfigPropertyInput: Em.Object.create({
- value: "false",
- defaultValue: "false",
- displayType: 'checkbox'
- }),
- serviceConfigProperty: Em.Object.create({
- value: false,
- defaultValue: false,
- displayType: 'checkbox'
- })
- },
- {
- serviceConfigPropertyInput: Em.Object.create({
- value: "false",
- defaultValue: "false"
- }),
- serviceConfigProperty: Em.Object.create({
- value: "false",
- defaultValue: "false"
- })
- }
- ];
- tests.forEach(function(t) {
- it("set " + t.serviceConfigPropertyInput.value, function(){
- var serviceConfigProperty = t.serviceConfigPropertyInput;
- mainServiceInfoConfigsController.setValueForCheckBox(serviceConfigProperty);
- expect(serviceConfigProperty).to.eql(t.serviceConfigProperty);
- });
- });
- });
- describe("#setEditability", function () {
- var tests = [
- {
- isAdmin: true,
- isHostsConfigsPage: false,
- defaultGroupSelected: true,
- isReconfigurable: true,
- isEditable: true,
- m: ""
- },
- {
- isAdmin: false,
- isHostsConfigsPage: false,
- defaultGroupSelected: true,
- isReconfigurable: true,
- isEditable: false,
- m: "(non admin)"
- },
- {
- isAdmin: true,
- isHostsConfigsPage: true,
- defaultGroupSelected: true,
- isReconfigurable: true,
- isEditable: false,
- m: "(isHostsConfigsPage)"
- },
- {
- isAdmin: true,
- isHostsConfigsPage: false,
- defaultGroupSelected: false,
- isReconfigurable: true,
- isEditable: false,
- m: "(defaultGroupSelected is false)"
- },
- {
- isAdmin: true,
- isHostsConfigsPage: false,
- defaultGroupSelected: true,
- isReconfigurable: false,
- isEditable: false,
- m: "(isReconfigurable is false)"
- }
- ];
- beforeEach(function(){
- this.mock = sinon.stub(App, 'isAccessible');
- });
- afterEach(function () {
- this.mock.restore();
- });
- tests.forEach(function(t) {
- it("set isEditable " + t.isEditable + t.m, function(){
- this.mock.returns(t.isAdmin);
- mainServiceInfoConfigsController.set("isHostsConfigsPage", t.isHostsConfigsPage);
- var serviceConfigProperty = Em.Object.create({
- isReconfigurable: t.isReconfigurable
- });
- mainServiceInfoConfigsController.setEditability(serviceConfigProperty, t.defaultGroupSelected);
- expect(serviceConfigProperty.get("isEditable")).to.equal(t.isEditable);
- });
- });
- });
- describe("#checkOverrideProperty", function () {
- var tests = [{
- overrideToAdd: {
- name: "name1",
- filename: "filename1"
- },
- componentConfig: {
- configs: [
- {
- name: "name1",
- filename: "filename2"
- },
- {
- name: "name1",
- filename: "filename1"
- }
- ]
- },
- add: true,
- m: "add property"
- },
- {
- overrideToAdd: {
- name: "name1"
- },
- componentConfig: {
- configs: [
- {
- name: "name2"
- }
- ]
- },
- add: false,
- m: "don't add property, different names"
- },
- {
- overrideToAdd: {
- name: "name1",
- filename: "filename1"
- },
- componentConfig: {
- configs: [
- {
- name: "name1",
- filename: "filename2"
- }
- ]
- },
- add: false,
- m: "don't add property, different filenames"
- },
- {
- overrideToAdd: null,
- componentConfig: {},
- add: false,
- m: "don't add property, overrideToAdd is null"
- }];
- beforeEach(function() {
- sinon.stub(mainServiceInfoConfigsController,"addOverrideProperty", Em.K)
- });
- afterEach(function() {
- mainServiceInfoConfigsController.addOverrideProperty.restore();
- });
- tests.forEach(function(t) {
- it(t.m, function() {
- mainServiceInfoConfigsController.set("overrideToAdd", t.overrideToAdd);
- mainServiceInfoConfigsController.checkOverrideProperty(t.componentConfig);
- if(t.add) {
- expect(mainServiceInfoConfigsController.addOverrideProperty.calledWith(t.overrideToAdd)).to.equal(true);
- expect(mainServiceInfoConfigsController.get("overrideToAdd")).to.equal(null);
- } else {
- expect(mainServiceInfoConfigsController.addOverrideProperty.calledOnce).to.equal(false);
- }
- });
- });
- });
- describe("#trackRequest()", function () {
- after(function(){
- mainServiceInfoConfigsController.set('requestInProgress', null);
- });
- it("should set requestInProgress", function () {
- mainServiceInfoConfigsController.trackRequest({'request': {}});
- expect(mainServiceInfoConfigsController.get('requestInProgress')).to.eql({'request': {}});
- });
- });
- describe("#setValuesForOverrides", function() {
- var tests = [
- {
- overrides: [
- {name: "override1"},
- {name: "override2"}
- ],
- _serviceConfigProperty: {},
- serviceConfigProperty: Em.Object.create({overrides: Em.A([])}),
- defaultGroupSelected: true
- }
- ];
- beforeEach(function() {
- sinon.stub(mainServiceInfoConfigsController, "createNewSCP", function(override) {return {name: override.name}})
- });
- afterEach(function() {
- mainServiceInfoConfigsController.createNewSCP.restore();
- });
- tests.forEach(function(t) {
- it("set values for overrides. use createNewSCP method to do this", function() {
- var serviceConfigProperty = t.serviceConfigProperty;
- mainServiceInfoConfigsController.setValuesForOverrides(t.overrides, serviceConfigProperty, t.serviceConfigProperty, t.defaultGroupSelected);
- expect(serviceConfigProperty.get("overrides")[0]).to.eql(t.overrides[0]);
- expect(serviceConfigProperty.get("overrides")[1]).to.eql(t.overrides[1]);
- });
- });
- });
- describe("#createConfigProperty", function() {
- var tests = [
- {
- _serviceConfigProperty: {
- overrides: {
- }
- },
- defaultGroupSelected: true,
- restartData: {},
- serviceConfigsData: {},
- serviceConfigProperty: {
- overrides: null,
- isOverridable: true
- }
- }];
- beforeEach(function() {
- sinon.stub(mainServiceInfoConfigsController, "setValueForCheckBox", Em.K);
- sinon.stub(mainServiceInfoConfigsController, "setValuesForOverrides", Em.K);
- sinon.stub(mainServiceInfoConfigsController, "setEditability", Em.K);
- });
- afterEach(function() {
- mainServiceInfoConfigsController.setValueForCheckBox.restore();
- mainServiceInfoConfigsController.setValuesForOverrides.restore();
- mainServiceInfoConfigsController.setEditability.restore();
- });
- tests.forEach(function(t) {
- it("create service config. run methods to correctly set object fileds", function() {
- var result = mainServiceInfoConfigsController.createConfigProperty(t._serviceConfigProperty, t.defaultGroupSelected, t.restartData, t.serviceConfigsData);
- expect(mainServiceInfoConfigsController.setValueForCheckBox.calledWith(t.serviceConfigProperty));
- expect(mainServiceInfoConfigsController.setValuesForOverrides.calledWith(t._serviceConfigProperty.overrides, t._serviceConfigProperty, t.serviceConfigProperty, t.defaultGroupSelected));
- expect(result.getProperties('overrides','isOverridable')).to.eql(t.serviceConfigProperty);
- });
- });
- });
- describe("#createNewSCP", function() {
- var tests = [
- {
- overrides: {
- value: "value",
- group: {
- value: "group1"
- }
- },
- _serviceConfigProperty: {},
- serviceConfigProperty: Em.Object.create({
- value: "parentSCP",
- supportsFinal: true
- }),
- defaultGroupSelected: true,
- newSCP: {
- value: "value",
- isOriginalSCP: false,
- parentSCP:Em.Object.create({
- value: "parentSCP",
- supportsFinal: true
- }),
- group: {
- value: "group1"
- },
- isEditable: false
- }
- }
- ];
- tests.forEach(function(t) {
- it("", function() {
- var newSCP = mainServiceInfoConfigsController.createNewSCP(t.overrides, t._serviceConfigProperty, t.serviceConfigProperty, t.defaultGroupSelected);
- expect(newSCP.getProperties("value", "isOriginalSCP", "parentSCP", "group", "isEditable")).to.eql(t.newSCP);
- });
- });
- });
- describe("#setCompareDefaultGroupConfig", function() {
- beforeEach(function() {
- sinon.stub(mainServiceInfoConfigsController, "getComparisonConfig").returns("compConfig");
- sinon.stub(mainServiceInfoConfigsController, "getMockComparisonConfig").returns("mockConfig");
- sinon.stub(mainServiceInfoConfigsController, "hasCompareDiffs").returns(true);
- });
- afterEach(function() {
- mainServiceInfoConfigsController.getComparisonConfig.restore();
- mainServiceInfoConfigsController.getMockComparisonConfig.restore();
- mainServiceInfoConfigsController.hasCompareDiffs.restore();
- });
- it("expect that setCompareDefaultGroupConfig will not run anything", function() {
- expect(mainServiceInfoConfigsController.setCompareDefaultGroupConfig({}).compareConfigs.length).to.equal(0);
- });
- it("expect that setCompareDefaultGroupConfig will not run anything", function() {
- expect(mainServiceInfoConfigsController.setCompareDefaultGroupConfig({},{}).compareConfigs.length).to.equal(0);
- });
- it("expect that serviceConfig.compareConfigs will be getMockComparisonConfig", function() {
- expect(mainServiceInfoConfigsController.setCompareDefaultGroupConfig({isUserProperty: true}, null)).to.eql({compareConfigs: ["mockConfig"], isUserProperty: true, isComparison: true, hasCompareDiffs: true});
- });
- it("expect that serviceConfig.compareConfigs will be getComparisonConfig", function() {
- expect(mainServiceInfoConfigsController.setCompareDefaultGroupConfig({isUserProperty: true}, {})).to.eql({compareConfigs: ["compConfig"], isUserProperty: true, isComparison: true, hasCompareDiffs: true});
- });
- it("expect that serviceConfig.compareConfigs will be getComparisonConfig", function() {
- expect(mainServiceInfoConfigsController.setCompareDefaultGroupConfig({isReconfigurable: true}, {})).to.eql({compareConfigs: ["compConfig"], isReconfigurable: true, isComparison: true, hasCompareDiffs: true});
- });
- it("expect that serviceConfig.compareConfigs will be getComparisonConfig", function() {
- expect(mainServiceInfoConfigsController.setCompareDefaultGroupConfig({isReconfigurable: true, isMock: true}, {})).to.eql({compareConfigs: ["compConfig"], isReconfigurable: true, isMock: true, isComparison: true, hasCompareDiffs: true});
- });
- });
- describe('#showSaveConfigsPopup', function () {
- var bodyView;
- describe('#bodyClass', function () {
- beforeEach(function() {
- sinon.stub(App.ajax, 'send', Em.K);
- // default implementation
- bodyView = mainServiceInfoConfigsController.showSaveConfigsPopup().get('bodyClass').create({
- parentView: Em.View.create()
- });
- });
- afterEach(function() {
- App.ajax.send.restore();
- });
- describe('#componentsFilterSuccessCallback', function () {
- it('check components with unknown state', function () {
- bodyView = mainServiceInfoConfigsController.showSaveConfigsPopup('', true, '', {}, '', 'unknown', '').get('bodyClass').create({
- parentView: Em.View.create()
- });
- bodyView.componentsFilterSuccessCallback({
- items: [
- {
- ServiceComponentInfo: {
- total_count: 4,
- started_count: 2,
- installed_count: 1,
- component_name: 'c1'
- },
- host_components: [
- {HostRoles: {host_name: 'h1'}}
- ]
- }
- ]
- });
- var unknownHosts = bodyView.get('unknownHosts');
- expect(unknownHosts.length).to.equal(1);
- expect(unknownHosts[0]).to.eql({name: 'h1', components: 'C1'});
- });
- });
- });
- });
- });
|