/** * 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/wizard/step7_controller'); App.KerberosWizardStep4Controller = App.WizardStep7Controller.extend(App.AddSecurityConfigs, { name: 'kerberosWizardStep4Controller', adminPropertyNames: [{name: 'admin_principal', displayName: 'Admin principal'}, {name: 'admin_password', displayName: 'Admin password'}], clearStep: function() { this.set('isRecommendedLoaded', false); this.set('selectedService', null); this.set('stepConfigs', []); }, loadStep: function() { if (this.get('wizardController.skipConfigureIdentitiesStep')) { App.router.send('next'); return; } var self = this; this.clearStep(); this.getDescriptorConfigs().then(function(properties) { self.setStepConfigs(properties); self.set('isRecommendedLoaded', true); }); }, /** * Create service config object for Kerberos service. * * @param {App.ServiceConfigProperty[]} configs * @returns {Em.Object} */ createServiceConfig: function(configs) { // Identity configs related to user principal var clusterConfigs = configs.filterProperty('serviceName','Cluster'); var nonClusterConfigs = configs.rejectProperty('serviceName','Cluster'); var categoryForClusterConfigs = [ App.ServiceConfigCategory.create({ name: 'Global', displayName: 'Global'}), App.ServiceConfigCategory.create({ name: 'Ambari Principals', displayName: 'Ambari Principals'}) ]; var categoryForNonClusterConfigs = this.createCategoryForServices(); return [ App.ServiceConfig.create({ displayName: 'General', name: 'GENERAL', serviceName: 'KERBEROS_GENERAL', configCategories: categoryForClusterConfigs, configs: clusterConfigs, showConfig: true }), App.ServiceConfig.create({ displayName: 'Advanced', name: 'ADVANCED', serviceName: 'KERBEROS_ADVANCED', configCategories: categoryForNonClusterConfigs, configs: nonClusterConfigs, showConfig: true }) ]; }, /** * creates categories for advanced secure configs * @returns {[App.ServiceConfigCategory]} */ createCategoryForServices: function() { var services = App.StackService.find().filter(function(s) { return s.get('isInstalled') || (s.get('isSelected') && this.get('wizardController.name') == 'addServiceController'); }, this); return services.map(function(item) { return App.ServiceConfigCategory.create({ name: item.get('serviceName'), displayName: item.get('displayName'), collapsedByDefault: true}); }) }, /** * Prepare step configs using stack descriptor properties. * * @param {App.ServiceConfigProperty[]} configs */ setStepConfigs: function(configs) { var configProperties = this.prepareConfigProperties(configs); if (this.get('wizardController.name') == 'addServiceController') { // config properties for installed services should be disabled on Add Service Wizard configProperties.forEach(function(item) { if (this.get('adminPropertyNames').mapProperty('name').contains(item.get('name'))) return; if (this.get('installedServiceNames').contains(item.get('serviceName')) || item.get('serviceName') == 'Cluster') { item.set('isEditable', false); } }, this); } this.get('stepConfigs').pushObjects(this.createServiceConfig(configProperties)); this.set('selectedService', this.get('stepConfigs')[0]); }, /** * Filter configs by installed services for Kerberos Wizard or by installed + selected services * for Add Service Wizard. * Set property value observer. * Set realm property with value from previous configuration step. * Set appropriate category for all configs. * * @param {App.ServiceConfigProperty[]} configs * @returns {App.ServiceConfigProperty[]} */ prepareConfigProperties: function(configs) { var self = this; var storedServiceConfigs = this.get('wizardController').getDBProperty('serviceConfigProperties'); var installedServiceNames = ['Cluster'].concat(App.Service.find().mapProperty('serviceName')); var adminProps = []; var configProperties = configs.slice(0); var siteProperties = App.config.get('preDefinedSiteProperties'); if (this.get('wizardController.name') == 'addServiceController') { installedServiceNames = installedServiceNames.concat(this.get('selectedServiceNames')); this.get('adminPropertyNames').forEach(function(item) { var property = storedServiceConfigs.filterProperty('filename', 'krb5-conf.xml').findProperty('name', item.name); if (!!property) { var _prop = App.ServiceConfigProperty.create($.extend({}, property, { name: item.name, value: '', defaultValue: '', serviceName: 'Cluster', displayName: item.displayName})); _prop.validate(); adminProps.push(_prop); } }); configProperties = adminProps.concat(configProperties); } configProperties = configProperties.filter(function(item) { return installedServiceNames.contains(item.get('serviceName')); }); if (this.get('wizardController.name') != 'addServiceController') { var realmValue = storedServiceConfigs.findProperty('name', 'realm').value; configProperties.findProperty('name', 'realm').set('value', realmValue); configProperties.findProperty('name', 'realm').set('defaultValue', realmValue); } configProperties.setEach('isSecureConfig', false); configProperties.forEach(function(property, item, allConfigs) { if (['spnego_keytab', 'spnego_principal'].contains(property.get('name'))) { property.addObserver('value', self, 'spnegoPropertiesObserver'); } if (property.get('observesValueFrom')) { var observedValue = allConfigs.findProperty('name', property.get('observesValueFrom')).get('value'); property.set('value', observedValue); property.set('defaultValue', observedValue); } if (property.get('serviceName') == 'Cluster') { property.set('category', 'Global'); } else { property.set('category', property.get('serviceName')); } // All user identity should be grouped under "Ambari Principals" category if (property.get('identityType') == 'user') property.set('category', 'Ambari Principals'); var siteProperty = siteProperties.findProperty('name', property.get('name')); if (siteProperty) { if (siteProperty.category === property.get('category')) { property.set('displayName',siteProperty.displayName); if (siteProperty.index) { property.set('index', siteProperty.index); } } } }); return configProperties; }, /** * Sync up values between inherited property and its reference. * * @param {App.ServiceConfigProperty} configProperty */ spnegoPropertiesObserver: function(configProperty) { var self = this; var stepConfig = this.get('stepConfigs').findProperty('name', 'ADVANCED'); stepConfig.get('configs').forEach(function(config) { if (config.get('observesValueFrom') == configProperty.get('name')) { Em.run.once(self, function() { config.set('value', configProperty.get('value')); config.set('defaultValue', configProperty.get('value')); }); } }); }, submit: function() { this.saveConfigurations(); App.router.send('next'); }, saveConfigurations: function() { var kerberosDescriptor = this.get('kerberosDescriptor'); var configs = []; this.get('stepConfigs').forEach(function(_stepConfig){ configs = configs.concat(_stepConfig.get('configs')); }); this.updateKerberosDescriptor(kerberosDescriptor, configs); App.get('router.kerberosWizardController').saveKerberosDescriptorConfigs(kerberosDescriptor); } });