123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922 |
- /**
- * 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/admin/stack_and_upgrade_controller');
- require('utils/string_utils');
- describe('App.MainAdminStackAndUpgradeController', function() {
- var controller = App.MainAdminStackAndUpgradeController.create({
- getDBProperty: Em.K,
- setDBProperty: Em.K
- });
- describe("#realRepoUrl", function() {
- before(function () {
- this.mock = sinon.stub(App, 'get');
- });
- after(function () {
- this.mock.restore();
- });
- it("", function() {
- this.mock.withArgs('apiPrefix').returns('apiPrefix');
- this.mock.withArgs('stackVersionURL').returns('stackVersionURL');
- controller.propertyDidChange('realRepoUrl');
- expect(controller.get('realRepoUrl')).to.equal('apiPrefixstackVersionURL/compatible_repository_versions?fields=*,operating_systems/*,operating_systems/repositories/*');
- });
- });
- describe("#realStackUrl", function() {
- before(function () {
- this.mock = sinon.stub(App, 'get');
- });
- after(function () {
- this.mock.restore();
- });
- it("", function() {
- this.mock.withArgs('apiPrefix').returns('apiPrefix');
- this.mock.withArgs('clusterName').returns('clusterName');
- controller.propertyDidChange('realStackUrl');
- expect(controller.get('realStackUrl')).to.equal('apiPrefix/clusters/clusterName/stack_versions?fields=*,repository_versions/*,repository_versions/operating_systems/repositories/*');
- });
- });
- describe("#realUpdateUrl", function() {
- before(function () {
- this.mock = sinon.stub(App, 'get');
- });
- after(function () {
- this.mock.restore();
- });
- it("", function() {
- this.mock.withArgs('apiPrefix').returns('apiPrefix');
- this.mock.withArgs('clusterName').returns('clusterName');
- controller.propertyDidChange('realUpdateUrl');
- expect(controller.get('realUpdateUrl')).to.equal('apiPrefix/clusters/clusterName/stack_versions?fields=ClusterStackVersions/*');
- });
- });
- describe("#load()", function() {
- before(function(){
- sinon.stub(controller, 'loadUpgradeData').returns({
- done: function(callback) {callback();}
- });
- sinon.stub(controller, 'loadStackVersionsToModel').returns({
- done: function(callback) {callback();}
- });
- sinon.stub(controller, 'loadRepoVersionsToModel').returns({
- done: function(callback) {callback();}
- });
- sinon.stub(App.StackVersion, 'find').returns([Em.Object.create({
- state: 'CURRENT',
- repositoryVersion: {
- repositoryVersion: '2.2',
- displayName: 'HDP-2.2'
- }
- })]);
- });
- after(function(){
- controller.loadUpgradeData.restore();
- controller.loadStackVersionsToModel.restore();
- controller.loadRepoVersionsToModel.restore();
- App.StackVersion.find.restore();
- });
- it("", function() {
- controller.load();
- expect(controller.loadUpgradeData.calledWith(true)).to.be.true;
- expect(controller.loadStackVersionsToModel.calledWith(true)).to.be.true;
- expect(controller.loadRepoVersionsToModel.calledOnce).to.be.true;
- expect(controller.get('currentVersion')).to.eql({
- "repository_version": "2.2",
- "repository_name": "HDP-2.2"
- });
- });
- });
- describe("#loadUpgradeData()", function() {
- beforeEach(function () {
- sinon.stub(App.ajax, 'send').returns({
- then: Em.K
- });
- });
- afterEach(function () {
- App.ajax.send.restore();
- });
- it("get entire data", function() {
- controller.set('upgradeId', 1);
- controller.loadUpgradeData();
- expect(App.ajax.send.getCall(0).args[0]).to.eql({
- name: 'admin.upgrade.data',
- sender: controller,
- data: {
- id: 1
- },
- success: 'loadUpgradeDataSuccessCallback'
- })
- });
- it("get only state", function() {
- controller.set('upgradeId', 1);
- controller.loadUpgradeData(true);
- expect(App.ajax.send.getCall(0).args[0]).to.eql({
- name: 'admin.upgrade.state',
- sender: controller,
- data: {
- id: 1
- },
- success: 'loadUpgradeDataSuccessCallback'
- })
- });
- it("upgrade id is null", function() {
- controller.set('upgradeId', null);
- controller.loadUpgradeData();
- expect(App.ajax.send.called).to.be.false;
- });
- });
- describe("#loadUpgradeDataSuccessCallback()", function() {
- beforeEach(function () {
- sinon.stub(controller, 'updateUpgradeData', Em.K);
- sinon.stub(controller, 'setDBProperty', Em.K);
- });
- afterEach(function () {
- controller.updateUpgradeData.restore();
- controller.setDBProperty.restore();
- });
- it("correct data", function() {
- var data = {
- "Upgrade": {
- "request_status": "UPGRADED"
- },
- "upgrade_groups": [
- {
- "UpgradeGroup": {
- "id": 1
- },
- "upgrade_items": []
- }
- ]};
- controller.loadUpgradeDataSuccessCallback(data);
- expect(App.get('upgradeState')).to.equal('UPGRADED');
- expect(controller.updateUpgradeData.calledOnce).to.be.true;
- expect(controller.setDBProperty.calledWith('upgradeState', 'UPGRADED')).to.be.true;
- });
- it("data is null", function() {
- var data = null;
- controller.loadUpgradeDataSuccessCallback(data);
- expect(controller.updateUpgradeData.called).to.be.false;
- expect(controller.setDBProperty.called).to.be.false;
- });
- });
- describe("#getUpgradeItem()", function() {
- beforeEach(function () {
- sinon.stub(App.ajax, 'send', Em.K);
- });
- afterEach(function () {
- App.ajax.send.restore();
- });
- it("", function() {
- var item = Em.Object.create({
- request_id: 1,
- group_id: 2,
- stage_id: 3
- });
- controller.getUpgradeItem(item);
- expect(App.ajax.send.getCall(0).args[0]).to.eql({
- name: 'admin.upgrade.upgrade_item',
- sender: controller,
- data: {
- upgradeId: 1,
- groupId: 2,
- stageId: 3
- },
- success: 'getUpgradeItemSuccessCallback'
- });
- });
- });
- describe("#openUpgradeDialog()", function () {
- before(function () {
- sinon.stub(App.router, 'transitionTo', Em.K);
- });
- after(function () {
- App.router.transitionTo.restore();
- });
- it("should open dialog", function () {
- controller.openUpgradeDialog();
- expect(App.router.transitionTo.calledWith('admin.stackUpgrade')).to.be.true;
- });
- });
- describe("#runPreUpgradeCheck()", function() {
- before(function () {
- sinon.stub(App.ajax, 'send', Em.K);
- });
- after(function () {
- App.ajax.send.restore();
- });
- it("make ajax call", function() {
- controller.runPreUpgradeCheck(Em.Object.create({
- repositoryVersion: '2.2',
- displayName: 'HDP-2.2'
- }));
- expect(App.ajax.send.getCall(0).args[0]).to.eql({
- name: "admin.rolling_upgrade.pre_upgrade_check",
- sender: controller,
- data: {
- value: '2.2',
- label: 'HDP-2.2'
- },
- success: "runPreUpgradeCheckSuccess",
- error: "runPreUpgradeCheckError"
- });
- });
- });
- describe("#runPreUpgradeCheckSuccess()", function () {
- var cases = [
- {
- check: {
- "check": "Work-preserving RM/NM restart is enabled in YARN configs",
- "status": "FAIL",
- "reason": "FAIL",
- "failed_on": [],
- "check_type": "SERVICE"
- },
- showClusterCheckPopupCalledCount: 1,
- showUpgradeConfigsMergePopupCalledCount: 0,
- upgradeCalledCount: 0,
- title: 'error popup is displayed is errors are present'
- },
- {
- check: {
- "check": "Configuration Merge Check",
- "status": "WARNING",
- "reason": "Conflict",
- "failed_on": [],
- "failed_detail": [],
- "check_type": "CLUSTER",
- "id": "CONFIG_MERGE"
- },
- showClusterCheckPopupCalledCount: 0,
- showUpgradeConfigsMergePopupCalledCount: 1,
- upgradeCalledCount: 0,
- title: 'warnings popup is displayed is configs merge conflicts are present'
- },
- {
- check: {
- "check": "Work-preserving RM/NM restart is enabled in YARN configs",
- "status": "PASS",
- "reason": "OK",
- "failed_on": [],
- "check_type": "SERVICE"
- },
- showClusterCheckPopupCalledCount: 0,
- showUpgradeConfigsMergePopupCalledCount: 0,
- upgradeCalledCount: 1,
- title: 'upgrade is started if errors and configs merge conflicts are absent'
- }
- ];
- beforeEach(function () {
- sinon.stub(App, 'showClusterCheckPopup', Em.K);
- sinon.stub(App, 'showUpgradeConfigsMergePopup', Em.K);
- sinon.stub(controller, 'upgrade', Em.K);
- });
- afterEach(function () {
- App.showClusterCheckPopup.restore();
- App.showUpgradeConfigsMergePopup.restore();
- controller.upgrade.restore();
- });
- cases.forEach(function (item) {
- it(item.title, function () {
- controller.runPreUpgradeCheckSuccess(
- {
- items: [
- {
- UpgradeChecks: item.check
- }
- ]
- }, null, {
- label: 'name'
- }
- );
- expect(controller.upgrade.callCount).to.equal(item.upgradeCalledCount);
- expect(App.showClusterCheckPopup.callCount).to.equal(item.showClusterCheckPopupCalledCount);
- expect(App.showUpgradeConfigsMergePopup.callCount).to.equal(item.showUpgradeConfigsMergePopupCalledCount);
- });
- });
- });
- describe("#initDBProperties()", function() {
- before(function () {
- sinon.stub(controller, 'getDBProperty', function (prop) {
- return prop;
- });
- });
- after(function () {
- controller.getDBProperty.restore();
- });
- it("set properties", function () {
- controller.set('wizardStorageProperties', ['prop1']);
- controller.initDBProperties();
- expect(controller.get('prop1')).to.equal('prop1');
- });
- });
- describe("#init()", function() {
- before(function () {
- sinon.stub(controller, 'initDBProperties', Em.K);
- });
- after(function () {
- controller.initDBProperties.restore();
- });
- it("call initDBProperties", function () {
- controller.init();
- expect(controller.initDBProperties.calledOnce).to.be.true;
- });
- });
- describe("#upgrade()", function() {
- before(function () {
- sinon.stub(App.ajax, 'send', Em.K);
- sinon.stub(controller, 'setDBProperty', Em.K);
- });
- after(function () {
- App.ajax.send.restore();
- controller.setDBProperty.restore();
- });
- it("make ajax call", function() {
- controller.set('currentVersion', {
- repository_version: '2.2'
- });
- controller.upgrade({
- value: '2.2',
- label: 'HDP-2.2'
- });
- expect(App.ajax.send.getCall(0).args[0].data).to.eql({"value": '2.2', "label": 'HDP-2.2'});
- expect(App.ajax.send.getCall(0).args[0].name).to.eql('admin.upgrade.start');
- expect(App.ajax.send.getCall(0).args[0].sender).to.eql(controller);
- expect(App.ajax.send.getCall(0).args[0].success).to.eql('upgradeSuccessCallback');
- expect(App.ajax.send.getCall(0).args[0].callback).to.be.called;
- expect(controller.setDBProperty.calledWith('currentVersion', {
- repository_version: '2.2'
- })).to.be.true;
- });
- });
- describe("#upgradeSuccessCallback()", function() {
- before(function () {
- sinon.stub(App.clusterStatus, 'setClusterStatus', Em.K);
- sinon.stub(controller, 'openUpgradeDialog', Em.K);
- sinon.stub(controller, 'setDBProperty', Em.K);
- sinon.stub(controller, 'load', Em.K);
- });
- after(function () {
- App.clusterStatus.setClusterStatus.restore();
- controller.openUpgradeDialog.restore();
- controller.setDBProperty.restore();
- controller.load.restore();
- });
- it("open upgrade dialog", function() {
- var data = {
- resources: [
- {
- Upgrade: {
- request_id: 1
- }
- }
- ]
- };
- controller.upgradeSuccessCallback(data, {}, {label: 'HDP-2.2.1', isDowngrade: true});
- expect(controller.setDBProperty.calledWith('upgradeId', 1)).to.be.true;
- expect(controller.setDBProperty.calledWith('upgradeVersion', 'HDP-2.2.1')).to.be.true;
- expect(controller.setDBProperty.calledWith('isDowngrade', true)).to.be.true;
- expect(controller.load.calledOnce).to.be.true;
- expect(controller.get('upgradeVersion')).to.equal('HDP-2.2.1');
- expect(controller.get('upgradeData')).to.be.null;
- expect(controller.get('isDowngrade')).to.be.true;
- expect(App.clusterStatus.setClusterStatus.calledOnce).to.be.true;
- expect(controller.openUpgradeDialog.calledOnce).to.be.true;
- });
- });
- describe("#updateUpgradeData()", function() {
- beforeEach(function () {
- sinon.stub(controller, 'initUpgradeData', Em.K);
- });
- afterEach(function () {
- controller.initUpgradeData.restore();
- });
- it("data loaded first time", function() {
- controller.set('upgradeData', null);
- controller.updateUpgradeData({});
- expect(controller.initUpgradeData.calledWith({})).to.be.true;
- });
- it("update loaded data", function() {
- var oldData = Em.Object.create({
- upgradeGroups: [
- Em.Object.create({
- group_id: 1,
- upgradeItems: [
- Em.Object.create({
- stage_id: 1
- })
- ]
- })
- ]
- });
- var newData = {
- Upgrade: {
- request_id: 1
- },
- upgrade_groups: [
- {
- UpgradeGroup: {
- group_id: 1,
- status: 'COMPLETED',
- progress_percent: 100,
- completed_task_count: 3
- },
- upgrade_items: [
- {
- UpgradeItem: {
- stage_id: 1,
- status: 'COMPLETED',
- progress_percent: 100
- }
- }
- ]
- }
- ]
- };
- controller.set('upgradeData', oldData);
- controller.updateUpgradeData(newData);
- expect(controller.get('upgradeData.upgradeGroups')[0].get('status')).to.equal('COMPLETED');
- expect(controller.get('upgradeData.upgradeGroups')[0].get('progress_percent')).to.equal(100);
- expect(controller.get('upgradeData.upgradeGroups')[0].get('completed_task_count')).to.equal(3);
- expect(controller.get('upgradeData.upgradeGroups')[0].get('upgradeItems')[0].get('status')).to.equal('COMPLETED');
- expect(controller.get('upgradeData.upgradeGroups')[0].get('upgradeItems')[0].get('progress_percent')).to.equal(100);
- });
- });
- describe("#initUpgradeData()", function() {
- it("", function() {
- var newData = {
- Upgrade: {
- request_id: 1
- },
- upgrade_groups: [
- {
- UpgradeGroup: {
- group_id: 1
- },
- upgrade_items: [
- {
- UpgradeItem: {
- stage_id: 1
- }
- },
- {
- UpgradeItem: {
- stage_id: 2
- }
- }
- ]
- },
- {
- UpgradeGroup: {
- group_id: 2
- },
- upgrade_items: []
- }
- ]
- };
- controller.initUpgradeData(newData);
- expect(controller.get('upgradeData.Upgrade.request_id')).to.equal(1);
- expect(controller.get('upgradeData.upgradeGroups')[0].get('group_id')).to.equal(2);
- expect(controller.get('upgradeData.upgradeGroups')[1].get('group_id')).to.equal(1);
- expect(controller.get('upgradeData.upgradeGroups')[1].get('upgradeItems')[0].get('stage_id')).to.equal(2);
- expect(controller.get('upgradeData.upgradeGroups')[1].get('upgradeItems')[1].get('stage_id')).to.equal(1);
- });
- });
- describe.skip("#finish()", function() {
- before(function () {
- sinon.stub(App.clusterStatus, 'setClusterStatus', Em.K);
- sinon.stub(controller, 'setDBProperty', Em.K);
- });
- after(function () {
- App.clusterStatus.setClusterStatus.restore();
- controller.setDBProperty.restore();
- });
- it("upgradeState is not COMPLETED", function() {
- App.set('upgradeState', 'UPGRADING');
- controller.finish();
- expect(App.clusterStatus.setClusterStatus.called).to.be.false;
- });
- it("upgradeState is COMPLETED", function() {
- App.set('upgradeState', 'COMPLETED');
- controller.finish();
- expect(controller.setDBProperty.calledWith('upgradeId', undefined)).to.be.true;
- expect(controller.setDBProperty.calledWith('upgradeVersion', undefined)).to.be.true;
- expect(controller.setDBProperty.calledWith('upgradeState', 'INIT')).to.be.true;
- expect(controller.setDBProperty.calledWith('currentVersion', undefined)).to.be.true;
- expect(App.get('upgradeState')).to.equal('INIT');
- expect(App.clusterStatus.setClusterStatus.calledOnce).to.be.true;
- });
- });
- describe("#confirmDowngrade()", function() {
- before(function () {
- sinon.spy(App, 'showConfirmationPopup');
- sinon.stub(controller, 'downgrade', Em.K);
- });
- after(function () {
- App.showConfirmationPopup.restore();
- controller.downgrade.restore();
- });
- it("show confirmation popup", function() {
- controller.set('currentVersion', Em.Object.create({
- repository_version: '2.2',
- repository_name: 'HDP-2.2'
- }));
- var popup = controller.confirmDowngrade();
- expect(App.showConfirmationPopup.calledOnce).to.be.true;
- popup.onPrimary();
- expect(controller.downgrade.calledWith(Em.Object.create({
- repository_version: '2.2',
- repository_name: 'HDP-2.2'
- }))).to.be.true;
- });
- });
- describe("#confirmUpgrade()", function() {
- before(function () {
- sinon.spy(App, 'showConfirmationPopup');
- sinon.stub(controller, 'runPreUpgradeCheck', Em.K);
- });
- after(function () {
- App.showConfirmationPopup.restore();
- controller.runPreUpgradeCheck.restore();
- });
- it("show confirmation popup", function() {
- var version = Em.Object.create({displayName: 'HDP-2.2'});
- var popup = controller.confirmUpgrade(version);
- expect(App.showConfirmationPopup.calledOnce).to.be.true;
- popup.onPrimary();
- expect(controller.runPreUpgradeCheck.calledWith(version)).to.be.true;
- });
- });
- describe("#downgrade()", function() {
- before(function () {
- sinon.stub(App.ajax, 'send', Em.K);
- sinon.stub(controller, 'abortUpgrade');
- });
- after(function () {
- App.ajax.send.restore();
- controller.abortUpgrade.restore();
- });
- it("make ajax call", function() {
- controller.downgrade(Em.Object.create({
- repository_version: '2.2',
- repository_name: 'HDP-2.2'
- }), {context: 'context'});
- expect(controller.abortUpgrade.calledOnce).to.be.true;
- expect(App.ajax.send.getCall(0).args[0].data).to.eql({"value": '2.2', "label": 'HDP-2.2', isDowngrade: true});
- expect(App.ajax.send.getCall(0).args[0].name).to.eql('admin.downgrade.start');
- expect(App.ajax.send.getCall(0).args[0].sender).to.eql(controller);
- expect(App.ajax.send.getCall(0).args[0].success).to.eql('upgradeSuccessCallback');
- expect(App.ajax.send.getCall(0).args[0].callback).to.be.called;
- });
- });
- describe("#installRepoVersionConfirmation()", function () {
- before(function () {
- sinon.stub(controller, 'installRepoVersion', Em.K);
- });
- after(function () {
- controller.installRepoVersion.restore();
- });
- it("show popup", function () {
- var repo = Em.Object.create({'displayName': 'HDP-2.2'});
- var popup = controller.installRepoVersionConfirmation(repo);
- popup.onPrimary();
- expect(controller.installRepoVersion.calledWith(repo)).to.be.true;
- });
- });
- describe("#installRepoVersion()", function () {
- before(function () {
- sinon.stub(App.ajax, 'send', Em.K);
- });
- after(function () {
- App.ajax.send.restore();
- });
- it("make ajax call", function () {
- var repo = Em.Object.create({
- stackVersionType: 'HDP',
- stackVersionNumber: '2.2',
- repositoryVersion: '2.2.1',
- repoId: 1
- });
- controller.installRepoVersion(repo);
- expect(App.ajax.send.calledOnce).to.be.true;
- });
- });
- describe("#installRepoVersionSuccess()", function() {
- var mock = Em.Object.create({
- id: 1,
- defaultStatus: 'INIT',
- stackVersion: {}
- });
- before(function () {
- sinon.spy(mock, 'set');
- sinon.stub(App.db, 'set', Em.K);
- sinon.stub(App.clusterStatus, 'setClusterStatus', Em.K);
- sinon.stub(App.RepositoryVersion, 'find').returns(mock);
- });
- after(function () {
- App.db.set.restore();
- App.clusterStatus.setClusterStatus.restore();
- App.RepositoryVersion.find.restore();
- });
- it("", function() {
- controller.installRepoVersionSuccess({Requests: {id: 1}}, {}, {id: 1});
- expect(App.db.set.calledWith('repoVersionInstall', 'id', [1])).to.be.true;
- expect(App.clusterStatus.setClusterStatus.calledOnce).to.be.true;
- expect(App.RepositoryVersion.find.calledWith(1)).to.be.true;
- expect(App.RepositoryVersion.find(1).get('defaultStatus')).to.equal('INSTALLING');
- expect(App.RepositoryVersion.find(1).get('stackVersion.state')).to.equal('INSTALLING');
- });
- });
- describe("#setUpgradeItemStatus()", function () {
- before(function () {
- sinon.stub(App.ajax, 'send', function () {
- return {
- done: function (callback) {
- callback();
- }
- }
- });
- });
- after(function () {
- App.ajax.send.restore();
- });
- it("", function () {
- var item = Em.Object.create({
- request_id: 1,
- stage_id: 1,
- group_id: 1
- });
- controller.setUpgradeItemStatus(item, 'PENDING');
- expect(App.ajax.send.getCall(0).args[0].data).to.eql({upgradeId: 1, itemId: 1, groupId: 1, status: 'PENDING'});
- expect(App.ajax.send.getCall(0).args[0].name).to.eql('admin.upgrade.upgradeItem.setState');
- expect(App.ajax.send.getCall(0).args[0].sender).to.eql(controller);
- expect(App.ajax.send.getCall(0).args[0].callback).to.be.called;
- expect(item.get('status')).to.equal('PENDING');
- });
- });
- describe("#prepareRepoForSaving()", function () {
- it("prepare date for saving", function () {
- var repo = Em.Object.create({
- operatingSystems: [
- Em.Object.create({
- osType: "redhat6",
- isDisabled: Ember.computed.not('isSelected'),
- repositories: [Em.Object.create({
- "baseUrl": "111121",
- "repoId": "HDP-2.2",
- "repoName": "HDP",
- hasError: false
- }),
- Em.Object.create({
- "baseUrl": "1",
- "repoId": "HDP-UTILS-1.1.0.20",
- "repoName": "HDP-UTILS",
- hasError: false
- })]
- })
- ]
- });
- var result = {
- "operating_systems": [
- {
- "OperatingSystems": {
- "os_type": "redhat6"
- },
- "repositories": [
- {
- "Repositories": {
- "base_url": "111121",
- "repo_id": "HDP-2.2",
- "repo_name": "HDP"
- }
- },
- {
- "Repositories": {
- "base_url": "1",
- "repo_id": "HDP-UTILS-1.1.0.20",
- "repo_name": "HDP-UTILS"
- }
- }
- ]
- }
- ]};
- expect(controller.prepareRepoForSaving(repo)).to.eql(result);
- });
- });
- describe("#saveRepoOS()", function() {
- before(function(){
- this.mock = sinon.stub(controller, 'validateRepoVersions');
- sinon.stub(controller, 'prepareRepoForSaving', Em.K);
- sinon.stub(App.ajax, 'send').returns({success: Em.K});
- });
- after(function(){
- this.mock.restore();
- controller.prepareRepoForSaving.restore();
- App.ajax.send.restore();
- });
- it("validation errors present", function() {
- this.mock.returns({
- done: function(callback) {callback([1]);}
- });
- controller.saveRepoOS(Em.Object.create({repoVersionId: 1}), true);
- expect(controller.validateRepoVersions.calledWith(Em.Object.create({repoVersionId: 1}), true)).to.be.true;
- expect(controller.prepareRepoForSaving.called).to.be.false;
- expect(App.ajax.send.called).to.be.false;
- });
- it("no validation errors", function() {
- this.mock.returns({
- done: function(callback) {callback([]);}
- });
- controller.saveRepoOS(Em.Object.create({repoVersionId: 1}), true);
- expect(controller.validateRepoVersions.calledWith(Em.Object.create({repoVersionId: 1}), true)).to.be.true;
- expect(controller.prepareRepoForSaving.calledWith(Em.Object.create({repoVersionId: 1}))).to.be.true;
- expect(App.ajax.send.calledOnce).to.be.true;
- });
- });
- describe("#validateRepoVersions()", function () {
- before(function () {
- sinon.stub(App.ajax, 'send').returns({success: Em.K, error: Em.K});
- });
- after(function () {
- App.ajax.send.restore();
- });
- it("skip validation", function () {
- controller.validateRepoVersions(Em.Object.create({repoVersionId: 1}), true);
- expect(App.ajax.send.called).to.be.false;
- });
- it("do validation", function () {
- var repo = Em.Object.create({
- repoVersionId: 1,
- operatingSystems: [
- Em.Object.create({
- isSelected: true,
- repositories: [
- Em.Object.create()
- ]
- })
- ]
- });
- controller.validateRepoVersions(repo, false);
- expect(App.ajax.send.calledOnce).to.be.true;
- });
- });
- describe("#showProgressPopup()", function () {
- var mock = {
- initPopup: Em.K
- };
- before(function () {
- sinon.stub(App.router, 'get').withArgs('highAvailabilityProgressPopupController').returns(mock);
- sinon.spy(mock, 'initPopup');
- });
- after(function () {
- App.router.get.restore();
- mock.initPopup.restore();
- });
- it("", function () {
- controller.showProgressPopup(Em.Object.create());
- expect(mock.initPopup.calledOnce).to.be.true;
- });
- });
- describe("#getUrl()", function() {
- beforeEach(function(){
- controller.reopen({
- realStackUrl: 'realStackUrl',
- realRepoUrl: 'realRepoUrl',
- realUpdateUrl: 'realUpdateUrl'
- });
- });
- it("full load is true, stack is null", function() {
- expect(controller.getUrl(null, true)).to.equal('realRepoUrl');
- });
- it("full load is true, stack is valid", function() {
- expect(controller.getUrl({}, true)).to.equal('realStackUrl');
- });
- it("full load is false, stack is valid", function() {
- expect(controller.getUrl({}, false)).to.equal('realUpdateUrl');
- });
- });
- describe("#loadStackVersionsToModel()", function () {
- before(function () {
- sinon.stub(App.HttpClient, 'get');
- });
- after(function () {
- App.HttpClient.get.restore();
- });
- it("", function () {
- controller.loadStackVersionsToModel();
- expect(App.HttpClient.get.calledOnce).to.be.true;
- });
- });
- describe("#loadRepoVersionsToModel()", function () {
- before(function () {
- sinon.stub(App.HttpClient, 'get');
- });
- after(function () {
- App.HttpClient.get.restore();
- });
- it("", function () {
- controller.loadRepoVersionsToModel();
- expect(App.HttpClient.get.calledOnce).to.be.true;
- });
- });
- describe('#currentVersionObserver()', function () {
- var cases = [
- {
- stackVersionType: 'HDP',
- repoVersion: '2.2.1.1.0-1',
- isStormMetricsSupported: false,
- title: 'HDP < 2.2.2'
- },
- {
- stackVersionType: 'HDP',
- repoVersion: '2.2.2.1.0-1',
- isStormMetricsSupported: true,
- title: 'HDP 2.2.2'
- },
- {
- stackVersionType: 'HDP',
- repoVersion: '2.2.3.1.0-1',
- isStormMetricsSupported: true,
- title: 'HDP > 2.2.2'
- },
- {
- stackVersionType: 'BIGTOP',
- repoVersion: '0.8.1.1.0-1',
- isStormMetricsSupported: true,
- title: 'not HDP'
- }
- ];
- afterEach(function () {
- App.RepositoryVersion.find.restore();
- });
- cases.forEach(function (item) {
- it(item.title, function () {
- sinon.stub(App.RepositoryVersion, 'find').returns([
- Em.Object.create({
- status: 'CURRENT',
- stackVersionType: item.stackVersionType
- })
- ]);
- controller.set('currentVersion', {
- repository_version: item.repoVersion
- });
- expect(App.get('isStormMetricsSupported')).to.equal(item.isStormMetricsSupported);
- });
- });
- });
- });
|