1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195 |
- /**
- * 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 Ember = require('ember');
- var App = require('app');
- require('controllers/wizard/step5_controller');
- var modelSetup = require('test/init_model_test');
- require('utils/ajax/ajax');
- var c;
- describe('App.WizardStep5Controller', function () {
- beforeEach(function () {
- c = App.WizardStep5Controller.create();
- });
- var controller = App.WizardStep5Controller.create();
- controller.set('content', {});
- var cpu = 2, memory = 4;
- controller.set('content', {});
- describe('#sortHosts', function () {
- var tests = Em.A([
- {
- hosts: [
- Em.Object.create({memory: 4, cpu: 1, host_name: 'host1', id: 1}),
- Em.Object.create({memory: 3, cpu: 1, host_name: 'host2', id: 2}),
- Em.Object.create({memory: 2, cpu: 1, host_name: 'host3', id: 3}),
- Em.Object.create({memory: 1, cpu: 1, host_name: 'host4', id: 4})
- ],
- m: 'memory',
- e: [1, 2, 3, 4]
- },
- {
- hosts: [
- Em.Object.create({memory: 1, cpu: 4, host_name: 'host1', id: 1}),
- Em.Object.create({memory: 1, cpu: 3, host_name: 'host2', id: 2}),
- Em.Object.create({memory: 1, cpu: 2, host_name: 'host3', id: 3}),
- Em.Object.create({memory: 1, cpu: 1, host_name: 'host4', id: 4})
- ],
- m: 'cpu',
- e: [1, 2, 3, 4]
- },
- {
- hosts: [
- Em.Object.create({memory: 1, cpu: 1, host_name: 'host4', id: 1}),
- Em.Object.create({memory: 1, cpu: 1, host_name: 'host2', id: 2}),
- Em.Object.create({memory: 1, cpu: 1, host_name: 'host3', id: 3}),
- Em.Object.create({memory: 1, cpu: 1, host_name: 'host1', id: 4})
- ],
- m: 'host_name',
- e: [4, 2, 3, 1]
- },
- {
- hosts: [
- Em.Object.create({memory: 2, cpu: 1, host_name: 'host1', id: 1}),
- Em.Object.create({memory: 1, cpu: 2, host_name: 'host3', id: 2}),
- Em.Object.create({memory: 1, cpu: 1, host_name: 'host4', id: 3}),
- Em.Object.create({memory: 1, cpu: 1, host_name: 'host2', id: 4})
- ],
- m: 'mix',
- e: [1, 2, 4, 3]
- }
- ]);
- tests.forEach(function (test) {
- it(test.m, function () {
- var hosts = Em.copy(test.hosts);
- controller.sortHosts(hosts);
- expect(Em.A(hosts).mapProperty('id')).to.eql(test.e);
- });
- });
- });
- describe('#renderHostInfo', function () {
- var tests = Em.A([
- {
- hosts: {
- h1: {memory: 4, cpu: 1, name: 'host1', bootStatus: 'INIT'},
- h2: {memory: 3, cpu: 1, name: 'host2', bootStatus: 'INIT'},
- h3: {memory: 2, cpu: 1, name: 'host3', bootStatus: 'INIT'},
- h4: {memory: 1, cpu: 1, name: 'host4', bootStatus: 'INIT'}
- },
- m: 'no one host is REGISTERED',
- e: []
- },
- {
- hosts: {
- h1: {memory: 4, cpu: 1, name: 'host1', bootStatus: 'REGISTERED'},
- h2: {memory: 3, cpu: 1, name: 'host2', bootStatus: 'REGISTERED'},
- h3: {memory: 2, cpu: 1, name: 'host3', bootStatus: 'REGISTERED'},
- h4: {memory: 1, cpu: 1, name: 'host4', bootStatus: 'REGISTERED'}
- },
- m: 'all hosts are REGISTERED, memory',
- e: ['host1', 'host2', 'host3', 'host4']
- },
- {
- hosts: {
- h1: {memory: 1, cpu: 4, name: 'host1', bootStatus: 'REGISTERED'},
- h2: {memory: 1, cpu: 3, name: 'host2', bootStatus: 'REGISTERED'},
- h3: {memory: 1, cpu: 2, name: 'host3', bootStatus: 'REGISTERED'},
- h4: {memory: 1, cpu: 1, name: 'host4', bootStatus: 'REGISTERED'}
- },
- m: 'all hosts are REGISTERED, cpu',
- e: ['host1', 'host2', 'host3', 'host4']
- },
- {
- hosts: {
- h1: {memory: 1, cpu: 1, name: 'host4', bootStatus: 'REGISTERED'},
- h2: {memory: 1, cpu: 1, name: 'host2', bootStatus: 'REGISTERED'},
- h3: {memory: 1, cpu: 1, name: 'host3', bootStatus: 'REGISTERED'},
- h4: {memory: 1, cpu: 1, name: 'host1', bootStatus: 'REGISTERED'}
- },
- m: 'all hosts are REGISTERED, host_name',
- e: ['host1', 'host2', 'host3', 'host4']
- },
- {
- hosts: {
- h1: {memory: 2, cpu: 1, name: 'host1', bootStatus: 'REGISTERED'},
- h2: {memory: 1, cpu: 2, name: 'host3', bootStatus: 'INIT'},
- h3: {memory: 1, cpu: 1, name: 'host4', bootStatus: 'REGISTERED'},
- h4: {memory: 1, cpu: 1, name: 'host2', bootStatus: 'INIT'}
- },
- m: 'mix',
- e: ['host1', 'host4']
- }
- ]);
- tests.forEach(function (test) {
- it(test.m, function () {
- controller.set('content', {hosts: test.hosts});
- controller.renderHostInfo();
- var r = controller.get('hosts');
- expect(Em.A(r).mapProperty('host_name')).to.eql(test.e);
- });
- });
- });
- describe('#last', function () {
- var tests = Em.A([
- {
- selectedServicesMasters: Em.A([
- {component_name: 'c1', indx: 1},
- {component_name: 'c2', indx: 2},
- {component_name: 'c1', indx: 2}
- ]),
- m: 'Components exists',
- c: 'c1',
- e: 2
- },
- {
- selectedServicesMasters: Em.A([
- {component_name: 'c1', indx: 1},
- {component_name: 'c2', indx: 2},
- {component_name: 'c1', indx: 2}
- ]),
- m: 'Components don\'t exists',
- c: 'c3',
- e: null
- }
- ]);
- tests.forEach(function (test) {
- it(test.m, function () {
- controller.set('selectedServicesMasters', test.selectedServicesMasters);
- if (!Em.isNone(test.e)) {
- expect(controller.last(test.c).indx).to.equal(test.e);
- }
- else {
- expect(Em.isNone(controller.last(test.c))).to.equal(true);
- }
- })
- });
- });
- describe('#remainingHosts', function () {
- it('should show count of hosts without masters', function () {
- c.reopen({masterHostMapping: [
- {}
- ]});
- c.set('hosts', [
- {},
- {},
- {}
- ]);
- expect(c.get('remainingHosts')).to.equal(2);
- });
- });
- describe('#clearStep', function () {
- var tests = Em.A([
- {p: 'hosts'},
- {p: 'selectedServicesMasters'},
- {p: 'servicesMasters'}
- ]);
- tests.forEach(function (test) {
- it('should cleanup ' + test.p, function () {
- c.set(test.p, [Em.Object.create({}), Em.Object.create({})]);
- c.clearStep();
- expect(c.get(test.p).length).to.equal(0);
- });
- });
- });
- describe('#updateComponent', function () {
- var tests = Em.A([
- {
- componentName: 'HBASE_SERVER',
- serviceComponents: [
- Em.Object.create({
- componentName: 'HBASE_SERVER',
- stackService: Em.Object.create({isInstalled: true, serviceName: 'HBASE'})
- })
- ],
- selectedServicesMasters: Em.A([
- Em.Object.create({showAddControl: false, showRemoveControl: true, component_name: 'HBASE_SERVER'}),
- Em.Object.create({showAddControl: true, showRemoveControl: false, component_name: 'HBASE_SERVER'})
- ]),
- hosts: Em.A([
- Em.Object.create({})
- ]),
- controllerName: 'addServiceController',
- m: 'service is installed',
- e: {
- showAddControl: true,
- showRemoveControl: false
- }
- },
- {
- componentName: 'HBASE_SERVER',
- serviceComponents: [
- Em.Object.create({
- componentName: 'HBASE_SERVER',
- stackService: Em.Object.create({isInstalled: false, serviceName: 'HBASE'})
- })
- ],
- selectedServicesMasters: Em.A([
- Em.Object.create({showAddControl: true, showRemoveControl: false, component_name: 'HBASE_SERVER'})
- ]),
- hosts: Em.A([
- Em.Object.create({})
- ]),
- controllerName: 'addServiceController',
- m: 'service not installed, but all host already have provided component',
- e: {
- showAddControl: true,
- showRemoveControl: false
- }
- },
- {
- componentName: 'HBASE_SERVER',
- serviceComponents: [
- Em.Object.create({
- componentName: 'HBASE_SERVER',
- stackService: Em.Object.create({isInstalled: false, serviceName: 'HBASE'})
- })
- ],
- selectedServicesMasters: Em.A([
- Em.Object.create({showAddControl: false, showRemoveControl: true, component_name: 'HBASE_SERVER'})
- ]),
- hosts: Em.A([
- Em.Object.create({}),
- Em.Object.create({})
- ]),
- controllerName: 'reassignMasterController',
- m: 'service not installed, not all host already have provided component, but is reassignMasterController',
- e: {
- showAddControl: false,
- showRemoveControl: false
- }
- }
- ]);
- tests.forEach(function (test) {
- it(test.m, function () {
- sinon.stub(App.StackServiceComponent, 'find', function () {
- return test.serviceComponents;
- });
- c.reopen({
- content: Em.Object.create({
- controllerName: test.controllerName
- }),
- selectedServicesMasters: test.selectedServicesMasters,
- hosts: test.hosts
- });
- c.updateComponent(test.componentName);
- App.StackServiceComponent.find.restore();
- Em.keys(test.e).forEach(function (k) {
- expect(c.last(test.componentName).get(k)).to.equal(test.e[k]);
- });
- });
- });
- });
- describe('#renderComponents', function () {
- var tests = Em.A([
- {
- masterComponents: Em.A([
- {component_name: 'ZOOKEEPER_SERVER'}
- ]),
- services: Em.A([
- Em.Object.create({serviceName: 'ZOOKEEPER', isInstalled: false, isSelected: true})
- ]),
- controllerName: 'reassignMasterController',
- m: 'One component',
- isHaEnabled: false,
- component_name: 'ZOOKEEPER_SERVER',
- e: {
- selectedServicesMasters: ['ZOOKEEPER_SERVER'],
- servicesMasters: ['ZOOKEEPER_SERVER'],
- showRemoveControl: [false],
- isInstalled: [false],
- serviceComponentId: [1]
- }
- },
- {
- masterComponents: Em.A([
- {component_name: 'ZOOKEEPER_SERVER'}
- ]),
- services: Em.A([
- Em.Object.create({serviceName: 'ZOOKEEPER', isInstalled: false, isSelected: true})
- ]),
- controllerName: 'addServiceController',
- m: 'One component, service is not installed',
- component_name: 'ZOOKEEPER_SERVER',
- e: {
- selectedServicesMasters: ['ZOOKEEPER_SERVER'],
- servicesMasters: ['ZOOKEEPER_SERVER'],
- showRemoveControl: [false],
- serviceComponentId: [1]
- }
- },
- {
- masterComponents: Em.A([
- {component_name: 'ZOOKEEPER_SERVER'},
- {component_name: 'ZOOKEEPER_SERVER'}
- ]),
- services: Em.A([
- Em.Object.create({serviceName: 'ZOOKEEPER', isInstalled: true})
- ]),
- controllerName: 'addServiceController',
- m: 'Two components, but service is installed',
- component_name: 'ZOOKEEPER_SERVER',
- e: {
- selectedServicesMasters: ['ZOOKEEPER_SERVER', 'ZOOKEEPER_SERVER'],
- servicesMasters: ['ZOOKEEPER_SERVER', 'ZOOKEEPER_SERVER'],
- showRemoveControl: [false, false],
- serviceComponentId: [1, 2]
- }
- }
- ]);
- tests.forEach(function (test) {
- beforeEach(function () {
- App.reopen({isHaEnabled: test.isHaEnabled});
- });
- it(test.m, function () {
- modelSetup.setupStackServiceComponent();
- sinon.stub(App.StackService, 'find', function () {
- return test.services;
- });
- App.set('isHaEnabled', test.isHaEnabled);
- c.reopen({
- content: Em.Object.create({
- services: test.services,
- controllerName: test.controllerName,
- reassign: {component_name: test.component_name}
- })
- });
- c.renderComponents(test.masterComponents);
- App.StackService.find.restore();
- modelSetup.cleanStackServiceComponent();
- expect(c.get('selectedServicesMasters').mapProperty('component_name')).to.eql(test.e.selectedServicesMasters);
- expect(c.get('servicesMasters').mapProperty('component_name')).to.eql(test.e.servicesMasters);
- expect(c.get('selectedServicesMasters').mapProperty('showRemoveControl')).to.eql(test.e.showRemoveControl);
- expect(c.get('selectedServicesMasters').mapProperty('serviceComponentId')).to.eql(test.e.serviceComponentId);
- if (c.get('isReasignController')) {
- expect(c.get('servicesMasters').mapProperty('isInstalled')).to.eql(test.e.isInstalled);
- }
- });
- });
- });
- describe('#assignHostToMaster', function () {
- var tests = Em.A([
- {
- componentName: 'c1',
- selectedHost: 'h2',
- serviceComponentId: '1',
- e: {
- indx: 0
- }
- },
- {
- componentName: 'c2',
- selectedHost: 'h3',
- serviceComponentId: '2',
- e: {
- indx: 3
- }
- },
- {
- componentName: 'c3',
- selectedHost: 'h1',
- e: {
- indx: 2
- }
- },
- {
- componentName: 'c2',
- selectedHost: 'h4',
- e: {
- indx: 1
- }
- }
- ]),
- selectedServicesMasters = Em.A([
- Em.Object.create({component_name: 'c1', serviceComponentId: '1', selectedHost: 'h1'}),
- Em.Object.create({component_name: 'c2', serviceComponentId: '1', selectedHost: 'h1'}),
- Em.Object.create({component_name: 'c3', serviceComponentId: '1', selectedHost: 'h3'}),
- Em.Object.create({component_name: 'c2', serviceComponentId: '2', selectedHost: 'h2'})
- ]);
- tests.forEach(function (test) {
- it(test.componentName + ' ' + test.selectedHost + ' ' + test.serviceComponentId, function () {
- c.set('selectedServicesMasters', selectedServicesMasters);
- c.assignHostToMaster(test.componentName, test.selectedHost, test.serviceComponentId);
- expect(c.get('selectedServicesMasters').objectAt(test.e.indx).get('selectedHost')).to.equal(test.selectedHost);
- })
- });
- });
- describe('#removeComponent', function () {
- beforeEach(function () {
- sinon.stub(c, 'getMaxNumberOfMasters', function () {
- return Infinity;
- });
- });
- afterEach(function(){
- c.getMaxNumberOfMasters.restore();
- });
- var tests = Em.A([
- {
- componentName: 'c1',
- serviceComponentId: 1,
- selectedServicesMasters: Em.A([]),
- hosts: [],
- m: 'empty selectedServicesMasters',
- e: false
- },
- {
- componentName: 'ZOOKEPEER_SERVER',
- serviceComponentId: 1,
- selectedServicesMasters: Em.A([
- Em.Object.create({serviceComponentId: 1, component_name: 'HBASE_SERVER'})
- ]),
- hosts: [],
- m: 'no such components',
- e: false
- },
- {
- componentName: 'ZOOKEPEER_SERVER',
- serviceComponentId: 1,
- selectedServicesMasters: Em.A([
- Em.Object.create({serviceComponentId: 1, component_name: 'ZOOKEPEER_SERVER'})
- ]),
- hosts: [],
- m: 'component is only 1',
- e: false
- },
- {
- componentName: 'ZOOKEPEER_SERVER',
- serviceComponentId: 2,
- selectedServicesMasters: Em.A([
- Em.Object.create({serviceComponentId: 1, component_name: 'ZOOKEPEER_SERVER', showAddControl: false, showRemoveControl: false}),
- Em.Object.create({serviceComponentId: 2, component_name: 'ZOOKEPEER_SERVER', showAddControl: false, showRemoveControl: false})
- ]),
- hosts: [
- {},
- {}
- ],
- m: 'two components, add allowed, remove not allowed',
- e: true,
- showAddControl: true,
- showRemoveControl: false
- },
- {
- componentName: 'ZOOKEPEER_SERVER',
- serviceComponentId: 2,
- selectedServicesMasters: Em.A([
- Em.Object.create({serviceComponentId: 1, component_name: 'ZOOKEPEER_SERVER', showAddControl: false, showRemoveControl: false}),
- Em.Object.create({serviceComponentId: 2, component_name: 'ZOOKEPEER_SERVER', showAddControl: false, showRemoveControl: false}),
- Em.Object.create({serviceComponentId: 3, component_name: 'ZOOKEPEER_SERVER', showAddControl: false, showRemoveControl: true})
- ]),
- hosts: [
- {},
- {},
- {}
- ],
- m: 'three components, add allowed, remove allowed',
- e: true,
- showAddControl: true,
- showRemoveControl: true
- }
- ]);
- tests.forEach(function (test) {
- it(test.m, function () {
- c.set('selectedServicesMasters', test.selectedServicesMasters);
- c.set('hosts', test.hosts);
- expect(c.removeComponent(test.componentName, test.serviceComponentId)).to.equal(test.e);
- if (test.e) {
- expect(c.get('selectedServicesMasters.lastObject.showRemoveControl')).to.equal(test.showRemoveControl);
- expect(c.get('selectedServicesMasters.lastObject.showAddControl')).to.equal(test.showAddControl);
- }
- })
- });
- });
- describe('#addComponent', function () {
- beforeEach(function () {
- sinon.stub(c, 'getMaxNumberOfMasters', function () {
- return Infinity;
- });
- });
- afterEach(function(){
- c.getMaxNumberOfMasters.restore();
- });
- var tests = Em.A([
- {
- componentName: 'c1',
- selectedServicesMasters: Em.A([]),
- hosts: [],
- m: 'empty selectedServicesMasters',
- e: false
- },
- {
- componentName: 'ZOOKEPEER_SERVER',
- selectedServicesMasters: Em.A([
- Em.Object.create({serviceComponentId: 1, component_name: 'HBASE_SERVER'})
- ]),
- hosts: [],
- m: 'no such components',
- e: false
- },
- {
- componentName: 'ZOOKEPEER_SERVER',
- selectedServicesMasters: Em.A([
- Em.Object.create({serviceComponentId: 1, component_name: 'ZOOKEPEER_SERVER', showAddControl: false, showRemoveControl: false}),
- Em.Object.create({serviceComponentId: 2, component_name: 'ZOOKEPEER_SERVER', showAddControl: false, showRemoveControl: false})
- ]),
- hosts: [Em.Object.create({}), Em.Object.create({}), Em.Object.create({})],
- m: 'two components, 3 hosts',
- e: true
- }
- ]);
- tests.forEach(function (test) {
- it(test.m, function () {
- c.set('selectedServicesMasters', test.selectedServicesMasters);
- c.set('hosts', test.hosts);
- expect(c.addComponent(test.componentName)).to.equal(test.e);
- });
- });
- });
- describe('#masterHostMapping', function () {
- Em.A([
- {
- selectedServicesMasters: [
- Em.Object.create({selectedHost: 'h1'}),
- Em.Object.create({selectedHost: 'h2'}),
- Em.Object.create({selectedHost: 'h1'})
- ],
- hosts: [
- Em.Object.create({host_name: 'h1', host_info: {}}),
- Em.Object.create({host_name: 'h2', host_info: {}})
- ],
- m: 'Two hosts',
- e: [
- {host_name: 'h1', hostInfo: {}, masterServices: [
- {},
- {}
- ]},
- {host_name: 'h2', hostInfo: {}, masterServices: [
- {}
- ]}
- ]
- },
- {
- selectedServicesMasters: [],
- hosts: [],
- m: 'No hosts',
- e: []
- },
- {
- selectedServicesMasters: [
- Em.Object.create({selectedHost: 'h1'}),
- Em.Object.create({selectedHost: 'h1'})
- ],
- hosts: [
- Em.Object.create({host_name: 'h1', host_info: {}})
- ],
- m: 'One host',
- e: [
- {host_name: 'h1', hostInfo: {}, masterServices: [
- {},
- {}
- ]}
- ]
- }
- ]).forEach(function (test) {
- it(test.m, function () {
- c.reopen({
- selectedServicesMasters: test.selectedServicesMasters,
- hosts: test.hosts
- });
- var result = c.get('masterHostMapping');
- expect(result.length).to.equal(test.e.length);
- result.forEach(function (r, i) {
- expect(r.get('host_name')).to.equal(test.e[i].host_name);
- expect(r.get('masterServices.length')).to.equal(test.e[i].masterServices.length);
- expect(r.get('hostInfo')).to.be.an.object;
- });
- });
- });
- });
- describe('#anyError', function () {
- Em.A([
- {
- servicesMasters: [
- Em.Object.create({errorMessage: 'some message'}),
- Em.Object.create({errorMessage: ''})
- ],
- generalErrorMessages: [],
- e: true
- },
- {
- servicesMasters: [
- Em.Object.create({errorMessage: ''}),
- Em.Object.create({errorMessage: ''})
- ],
- generalErrorMessages: [],
- e: false
- },
- {
- servicesMasters: [
- Em.Object.create({errorMessage: 'some message'}),
- Em.Object.create({errorMessage: 'some message 2'})
- ],
- generalErrorMessages: ['some message'],
- e: true
- },
- {
- servicesMasters: [
- Em.Object.create({errorMessage: ''}),
- Em.Object.create({errorMessage: ''})
- ],
- generalErrorMessages: ['some message'],
- e: true
- }
- ]).forEach(function (test, i) {
- it('test #' + i.toString(), function () {
- c.setProperties({
- servicesMasters: test.servicesMasters,
- generalErrorMessages: test.generalErrorMessages
- });
- expect(c.get('anyError')).to.equal(test.e);
- });
- });
- });
- describe('#anyWarning', function () {
- Em.A([
- {
- servicesMasters: [
- Em.Object.create({warnMessage: 'some message'}),
- Em.Object.create({warnMessage: ''})
- ],
- generalWarningMessages: [],
- e: true
- },
- {
- servicesMasters: [
- Em.Object.create({warnMessage: ''}),
- Em.Object.create({warnMessage: ''})
- ],
- generalWarningMessages: [],
- e: false
- },
- {
- servicesMasters: [
- Em.Object.create({warnMessage: 'some message'}),
- Em.Object.create({warnMessage: 'some message 2'})
- ],
- generalWarningMessages: ['some message'],
- e: true
- },
- {
- servicesMasters: [
- Em.Object.create({warnMessage: ''}),
- Em.Object.create({warnMessage: ''})
- ],
- generalWarningMessages: ['some message'],
- e: true
- }
- ]).forEach(function (test, i) {
- it('test #' + i.toString(), function () {
- c.setProperties({
- servicesMasters: test.servicesMasters,
- generalWarningMessages: test.generalWarningMessages
- });
- expect(c.get('anyWarning')).to.equal(test.e);
- });
- });
- });
- describe('#clearRecommendations', function () {
- it('should clear content.recommendations', function () {
- c.set('content', {recommendations: {'s': {}}});
- c.clearRecommendations();
- expect(c.get('content.recommendations')).to.be.null;
- });
- });
- describe('#updateIsSubmitDisabled', function () {
- var clearCases = [
- {
- isHostNameValid: true,
- isInitialLayout: true,
- isInitialLayoutResulting: false,
- clearRecommendationsCallCount: 0,
- recommendAndValidateCallCount: 1,
- title: 'initial masters-hosts layout'
- },
- {
- isHostNameValid: true,
- isInitialLayout: false,
- isInitialLayoutResulting: false,
- clearRecommendationsCallCount: 1,
- recommendAndValidateCallCount: 1,
- title: 'master-hosts layout changed'
- },
- {
- isHostNameValid: false,
- isInitialLayout: false,
- isInitialLayoutResulting: false,
- clearRecommendationsCallCount: 0,
- recommendAndValidateCallCount: 0,
- title: 'invalid host name specified'
- }
- ];
- beforeEach(function () {
- c.set('selectedServicesMasters', [
- {isInstalled: false}
- ]);
- sinon.stub(c, 'clearRecommendations', Em.K);
- sinon.stub(c, 'recommendAndValidate', Em.K);
- });
- afterEach(function () {
- c.clearRecommendations.restore();
- c.recommendAndValidate.restore();
- });
- it('shouldn\'t change submitDisabled if thereIsNoMasters returns false', function () {
- c.set('selectedServicesMasters', [
- {isInstalled: true}
- ]);
- c.set('submitDisabled', false);
- c.updateIsSubmitDisabled();
- expect(c.get('submitDisabled')).to.equal(false);
- });
- it('should check servicesMasters.@each.isHostNameValid if useServerValidation is false', function () {
- c.set('useServerValidation', false);
- c.set('servicesMasters', [
- {isHostNameValid: false},
- {isHostNameValid: true}
- ]);
- c.updateIsSubmitDisabled();
- expect(c.get('submitDisabled')).to.equal(true);
- c.set('servicesMasters', [
- {isHostNameValid: true},
- {isHostNameValid: true}
- ]);
- c.updateIsSubmitDisabled();
- expect(c.get('submitDisabled')).to.equal(false);
- });
- clearCases.forEach(function (item) {
- it(item.title, function () {
- c.setProperties({
- isInitialLayout: item.isInitialLayout,
- servicesMasters: [{
- isHostNameValid: item.isHostNameValid
- }]
- });
- expect(c.get('isInitialLayout')).to.equal(item.isInitialLayoutResulting);
- expect(c.clearRecommendations.callCount).to.equal(item.clearRecommendationsCallCount);
- expect(c.recommendAndValidate.callCount).to.equal(item.recommendAndValidateCallCount);
- });
- });
- });
- describe('#isHostNameValid', function () {
- beforeEach(function () {
- c.setProperties({
- hosts: [
- {host_name: 'h1'},
- {host_name: 'h2'},
- {host_name: 'h3'}
- ],
- selectedServicesMasters: [
- {component_name: 'c1', selectedHost: 'h1'},
- {component_name: 'c2', selectedHost: 'h2'},
- {component_name: 'c3', selectedHost: 'h3'},
- {component_name: 'c3', selectedHost: 'h1'}
- ]
- });
- });
- Em.A([
- {
- componentName: 'c1',
- selectedHost: ' ',
- m: 'empty hostName is invalid',
- e: false
- },
- {
- componentName: 'c1',
- selectedHost: 'h4',
- m: 'hostName not exists',
- e: false
- },
- {
- componentName: 'c4',
- selectedHost: 'h3',
- m: 'component not exists on host',
- e: true
- }
- ]).forEach(function (test) {
- it(test.m, function () {
- expect(c.isHostNameValid(test.componentName, test.selectedHost)).to.equal(test.e);
- });
- });
- });
- describe('#createComponentInstallationObject', function () {
- afterEach(function () {
- App.StackServiceComponent.find.restore();
- });
- Em.A([
- {
- fullComponent: Em.Object.create({
- componentName: 'c1',
- serviceName: 's1'
- }),
- hostName: 'h1',
- mastersToMove: ['c1'],
- savedComponent: {
- hostName: 'h2',
- isInstalled: true
- },
- stackServiceComponents: [Em.Object.create({componentName: 'c1', isCoHostedComponent: true})],
- e: {
- component_name: 'c1',
- display_name: 'C1',
- serviceId: 's1',
- selectedHost: 'h2',
- isInstalled: true,
- isServiceCoHost: false
- }
- },
- {
- fullComponent: Em.Object.create({
- componentName: 'c1',
- serviceName: 's1'
- }),
- hostName: 'h1',
- mastersToMove: [],
- stackServiceComponents: [Em.Object.create({componentName: 'c1', isCoHostedComponent: false})],
- e: {
- component_name: 'c1',
- display_name: 'C1',
- serviceId: 's1',
- selectedHost: 'h1',
- isInstalled: false,
- isServiceCoHost: false
- }
- },
- {
- fullComponent: Em.Object.create({
- componentName: 'c1',
- serviceName: 's1'
- }),
- hostName: 'h1',
- mastersToMove: [],
- stackServiceComponents: [Em.Object.create({componentName: 'c1', isCoHostedComponent: true})],
- e: {
- component_name: 'c1',
- display_name: 'C1',
- serviceId: 's1',
- selectedHost: 'h1',
- isInstalled: false,
- isServiceCoHost: true
- }
- }
- ]).forEach(function (test, i) {
- it('test #' + i, function () {
- sinon.stub(App.StackServiceComponent, 'find', function () {
- return test.stackServiceComponents;
- });
- c.set('mastersToMove', test.mastersToMove);
- c.set('content', {controllerName: test.controllerName});
- expect(c.createComponentInstallationObject(test.fullComponent, test.hostName, test.savedComponent)).to.eql(test.e);
- });
- });
- });
- describe('#createComponentInstallationObjects', function () {
- beforeEach(function() {
- sinon.stub(App.StackServiceComponent, 'find', function() {
- return [
- Em.Object.create({isShownOnAddServiceAssignMasterPage: true, componentName: 'c1', serviceName: 's1'}),
- Em.Object.create({isShownOnAddServiceAssignMasterPage: true, componentName: 'c2', serviceName: 's2'}),
- Em.Object.create({isShownOnAddServiceAssignMasterPage: true, componentName: 'c4', serviceName: 's2'}),
- Em.Object.create({isShownOnInstallerAssignMasterPage: true, componentName: 'c1', serviceName: 's1'}),
- Em.Object.create({isShownOnInstallerAssignMasterPage: true, componentName: 'c2', serviceName: 's2'}),
- Em.Object.create({isShownOnInstallerAssignMasterPage: true, componentName: 'c4', serviceName: 's2'})
- ];
- });
- c.set('content', {
- masterComponentHosts: [],
- services: [
- {serviceName: 's1', isSelected: true, isInstalled: false},
- {serviceName: 's2', isSelected: true, isInstalled: false}
- ],
- recommendations: {
- "blueprint": {
- "host_groups": [
- {
- "name": "host-group-1",
- "components": [ {"name": "c1"}, {"name": "c2"} ]
- },
- {
- "name": "host-group-2",
- "components": [ {"name": "c1"}, {"name": "c2"} ]
- },
- {
- "name": "host-group-3",
- "components": [ {"name": "c1"} ]
- }
- ]
- },
- "blueprint_cluster_binding": {
- "host_groups": [
- {
- "name": "host-group-1",
- "hosts": [ {"fqdn": "h1"} ]
- },
- {
- "name": "host-group-2",
- "hosts": [ {"fqdn": "h2"} ]
- },
- {
- "name": "host-group-3",
- "hosts": [ {"fqdn": "h3"} ]
- }
- ]
- }
- }
- });
- });
- afterEach(function() {
- App.StackServiceComponent.find.restore();
- });
- it('simple map without nothing stored/saved etc', function() {
- var r = c.createComponentInstallationObjects();
- expect(r.mapProperty('component_name')).to.eql(['c1', 'c2', 'c1', 'c2', 'c1']);
- expect(r.mapProperty('serviceId')).to.eql(['s1', 's2', 's1', 's2', 's1']);
- expect(r.mapProperty('selectedHost')).to.eql(['h1', 'h1', 'h2', 'h2', 'h3']);
- });
- it('some saved components exist', function() {
- c.set('content.controllerName', 'addServiceController');
- c.get('multipleComponents').push('c4');
- c.set('content.masterComponentHosts', [
- {hostName: 'h3', component: 'c4'}
- ]);
- c.get('content.recommendations.blueprint.host_groups')[2].components.push({name: 'c4'});
- var r = c.createComponentInstallationObjects();
- expect(r.mapProperty('component_name')).to.eql(['c1', 'c2', 'c1', 'c2', 'c1', 'c4']);
- expect(r.mapProperty('serviceId')).to.eql(['s1', 's2', 's1', 's2', 's1', 's2']);
- expect(r.mapProperty('selectedHost')).to.eql(['h1', 'h1', 'h2', 'h2', 'h3', 'h3']);
- });
- });
- describe('#getCurrentBlueprint', function () {
- beforeEach(function() {
- sinon.stub(c, 'getCurrentSlaveBlueprint', function() {
- return {
- blueprint_cluster_binding: {
- host_groups: []
- },
- blueprint: {
- host_groups: []
- }
- };
- });
- });
- afterEach(function() {
- c.getCurrentSlaveBlueprint.restore();
- });
- it('should map masterHostMapping', function () {
- c.reopen({masterHostMapping: [
- {host_name: 'h1', hostInfo:{}, masterServices: [
- {serviceId: 's1', component_name: 'c1'},
- {serviceId: 's2', component_name: 'c2'}
- ]},
- {host_name: 'h2', hostInfo:{}, masterServices: [
- {serviceId: 's1', component_name: 'c1'},
- {serviceId: 's3', component_name: 'c3'}
- ]}
- ]});
- var r = c.getCurrentBlueprint();
- expect(r).to.eql({"blueprint": {"host_groups": [
- {"name": "host-group-1", "components": [
- {"name": "c1"},
- {"name": "c2"}
- ]},
- {"name": "host-group-2", "components": [
- {"name": "c1"},
- {"name": "c3"}
- ]}
- ]}, "blueprint_cluster_binding": {"host_groups": [
- {"name": "host-group-1", "hosts": [
- {"fqdn": "h1"}
- ]},
- {"name": "host-group-2", "hosts": [
- {"fqdn": "h2"}
- ]}
- ]}}
- );
- });
- });
- describe('#updateValidationsSuccessCallback', function() {
- beforeEach(function() {
- sinon.stub(App.HostComponent, 'find', function() {
- return [];
- });
- });
- afterEach(function() {
- App.HostComponent.find.restore();
- });
- it('should map messages to generalErrorMessages, generalWarningMessages', function() {
- var data = [
- {
- type: 'host-component',
- 'component-name': 'c1',
- host: 'h1',
- level: 'ERROR',
- message: 'm1'
- },
- {
- type: 'host-component',
- 'component-name': 'c2',
- host: 'h2',
- level: 'WARN',
- message: 'm2'
- },
- {
- type: 'host-component',
- 'component-name': 'c3',
- host: 'h3',
- level: 'ERROR',
- message: 'm3'
- },
- {
- type: 'host-component',
- 'component-name': 'c4',
- host: 'h4',
- level: 'WARN',
- message: 'm4'
- }
- ],
- servicesMasters = [
- Em.Object.create({selectedHost: 'h1', component_name: 'c1'}),
- Em.Object.create({selectedHost: 'h2', component_name: 'c2'})
- ];
- c.set('servicesMasters', servicesMasters);
- c.updateValidationsSuccessCallback({resources: [{items: data}]});
- expect(c.get('submitDisabled')).to.equal(false);
- expect(c.get('servicesMasters').findProperty('component_name', 'c1').get('errorMessage')).to.equal('m1');
- expect(c.get('servicesMasters').findProperty('component_name', 'c2').get('warnMessage')).to.equal('m2');
- expect(c.get('generalErrorMessages')).to.be.empty;
- expect(c.get('generalWarningMessages')).to.be.empty;
- });
- });
- describe('#sortComponentsByServiceName', function () {
- var components = [{
- "component_name": "METRICS_COLLECTOR",
- "serviceId": "AMBARI_METRICS"
- }, {"component_name": "ZOOKEEPER_SERVER", "serviceId": "ZOOKEEPER"}, {
- "component_name": "NAMENODE",
- "serviceId": "HDFS"
- }, {"component_name": "DRPC_SERVER", "serviceId": "STORM"}, {
- "component_name": "APP_TIMELINE_SERVER",
- "serviceId": "YARN"
- }, {"component_name": "RESOURCEMANAGER", "serviceId": "YARN"}, {
- "component_name": "SECONDARY_NAMENODE",
- "serviceId": "HDFS"
- }, {"component_name": "ZOOKEEPER_SERVER", "serviceId": "ZOOKEEPER"}, {
- "component_name": "HISTORYSERVER",
- "serviceId": "MAPREDUCE2"
- }, {"component_name": "NIMBUS", "serviceId": "STORM"}, {"component_name": "STORM_UI_SERVER", "serviceId": "STORM"}];
- it('ZKS should be one after anothert', function () {
- var sorted = c.sortComponentsByServiceName(components);
- expect(sorted.mapProperty('component_name').join('|').contains('ZOOKEEPER_SERVER|ZOOKEEPER_SERVER')).to.be.true;
- });
- });
- });
|