12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211121212131214121512161217121812191220122112221223122412251226122712281229123012311232123312341235123612371238123912401241124212431244124512461247124812491250125112521253125412551256125712581259126012611262126312641265126612671268126912701271127212731274127512761277127812791280128112821283128412851286128712881289129012911292129312941295129612971298129913001301130213031304130513061307130813091310131113121313131413151316131713181319132013211322132313241325132613271328132913301331133213331334133513361337133813391340134113421343134413451346134713481349135013511352135313541355135613571358135913601361136213631364136513661367136813691370137113721373137413751376137713781379138013811382138313841385138613871388138913901391139213931394139513961397139813991400140114021403140414051406140714081409141014111412141314141415141614171418141914201421142214231424142514261427142814291430143114321433143414351436143714381439144014411442144314441445 |
- /**
- * 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');
- /**
- * Abstract view for config fields.
- * Add popover support to control
- */
- App.ServiceConfigPopoverSupport = Ember.Mixin.create({
- /**
- * Config object. It will instance of App.ServiceConfigProperty
- */
- serviceConfig: null,
- attributeBindings:['readOnly'],
- isPopoverEnabled: true,
- didInsertElement: function () {
- $('body').tooltip({
- selector: '[data-toggle=tooltip]',
- placement: 'top'
- });
- // if description for this serviceConfig not exist, then no need to show popover
- if (this.get('isPopoverEnabled') !== 'false' && this.get('serviceConfig.description')) {
- App.popover(this.$(), {
- title: Em.I18n.t('installer.controls.serviceConfigPopover.title').format(
- this.get('serviceConfig.displayName'),
- (this.get('serviceConfig.displayName') == this.get('serviceConfig.name')) ? '' : this.get('serviceConfig.name')
- ),
- content: this.get('serviceConfig.description'),
- placement: 'right',
- trigger: 'hover'
- });
- }
- },
- willDestroyElement: function() {
- this.$().popover('destroy');
- },
- readOnly: function () {
- return !this.get('serviceConfig.isEditable');
- }.property('serviceConfig.isEditable')
- });
- App.supportsDependentConfigs = Ember.Mixin.create({
- /**
- * method send request to check if some of dependent configs was changes
- * and in case there was changes shows popup with info about changed configs
- */
- sendRequestRorDependentConfigs: function() {
- if (App.get('supports.enhancedConfigs') && this.get('controller.name') === 'mainServiceInfoConfigsController') {
- var name = this.get('serviceConfig.name');
- var type = App.config.getConfigTagFromFileName(this.get('serviceConfig.filename'));
- var p = App.StackConfigProperty.find(name + '_' + type);
- if (p && p.get('propertyDependedBy.length') > 0) {
- this.get('controller').getRecommendationsForDependencies([{
- "type": type,
- "name": name
- }]);
- }
- }
- }
- });
- /**
- * mixin set class that serve as unique element identificator,
- * id not used in order to avoid collision with ember ids
- */
- App.ServiceConfigCalculateId = Ember.Mixin.create({
- idClass: Ember.computed(function () {
- var label = Em.get(this, 'serviceConfig.name') ? Em.get(this, 'serviceConfig.name').toLowerCase().replace(/\./g, '-') : '',
- fileName = Em.get(this, 'serviceConfig.filename') ? Em.get(this, 'serviceConfig.filename').toLowerCase().replace(/\./g, '-') : '',
- group = Em.get(this, 'serviceConfig.group.name') || 'default';
- isOrigin = Em.get(this, 'serviceConfig.compareConfigs.length') > 0 ? '-origin' : '';
- return 'service-config-' + label + '-' + fileName + '-' + group + isOrigin;
- }),
- classNameBindings: 'idClass'
- });
- /**
- * Default input control
- * @type {*}
- */
- App.ServiceConfigTextField = Ember.TextField.extend(App.ServiceConfigPopoverSupport, App.ServiceConfigCalculateId, App.supportsDependentConfigs, {
- valueBinding: 'serviceConfig.value',
- classNameBindings: 'textFieldClassName',
- placeholderBinding: 'serviceConfig.defaultValue',
- keyPress: function (event) {
- if (event.keyCode == 13) {
- return false;
- }
- },
- //Set editDone true for last edited config text field parameter
- focusOut: function (event) {
- if (this.get('serviceConfig.isNotDefaultValue')) {
- this.sendRequestRorDependentConfigs();
- }
- this.get('serviceConfig').set("editDone", true);
- },
- //Set editDone false for all current category config text field parameter
- focusIn: function (event) {
- if (!this.get('serviceConfig.isOverridden') && !this.get('serviceConfig.isComparison')) {
- this.get("parentView.categoryConfigsAll").setEach("editDone", false);
- }
- },
- textFieldClassName: function () {
- if (this.get('serviceConfig.unit')) {
- return ['input-small'];
- } else if (this.get('serviceConfig.displayType') === 'principal') {
- return ['span12'];
- } else {
- return ['span9'];
- }
- }.property('serviceConfig.displayType', 'serviceConfig.unit')
- });
- /**
- * Customized input control with Units type specified
- * @type {Em.View}
- */
- App.ServiceConfigTextFieldWithUnit = Ember.View.extend(App.ServiceConfigPopoverSupport, App.supportsDependentConfigs, {
- valueBinding: 'serviceConfig.value',
- classNames: ['input-append', 'with-unit'],
- placeholderBinding: 'serviceConfig.defaultValue',
- //Set editDone true for last edited config text field parameter
- focusOut: function (event) {
- if (this.get('serviceConfig.isNotDefaultValue')) {
- this.sendRequestRorDependentConfigs();
- }
- },
- templateName: require('templates/wizard/controls_service_config_textfield_with_unit')
- });
- /**
- * Password control
- * @type {*}
- */
- App.ServiceConfigPasswordField = Ember.TextField.extend({
- serviceConfig: null,
- type: 'password',
- attributeBindings:['readOnly'],
- valueBinding: 'serviceConfig.value',
- classNames: [ 'span4' ],
- placeholder: Em.I18n.t('form.item.placeholders.typePassword'),
- template: Ember.Handlebars.compile('{{view view.retypePasswordView}}'),
- keyPress: function (event) {
- if (event.keyCode == 13) {
- return false;
- }
- },
- retypePasswordView: Ember.TextField.extend({
- placeholder: Em.I18n.t('form.passwordRetype'),
- attributeBindings:['readOnly'],
- type: 'password',
- classNames: [ 'span4', 'retyped-password' ],
- keyPress: function (event) {
- if (event.keyCode == 13) {
- return false;
- }
- },
- valueBinding: 'parentView.serviceConfig.retypedPassword',
- readOnly: function () {
- return !this.get('parentView.serviceConfig.isEditable');
- }.property('parentView.serviceConfig.isEditable')
- }),
- readOnly: function () {
- return !this.get('serviceConfig.isEditable');
- }.property('serviceConfig.isEditable')
- });
- /**
- * Textarea control
- * @type {*}
- */
- App.ServiceConfigTextArea = Ember.TextArea.extend(App.ServiceConfigPopoverSupport, App.ServiceConfigCalculateId, {
- valueBinding: 'serviceConfig.value',
- rows: 4,
- classNames: ['span9', 'directories']
- });
- /**
- * Textarea control for content type
- * @type {*}
- */
- App.ServiceConfigTextAreaContent = Ember.TextArea.extend(App.ServiceConfigPopoverSupport, App.ServiceConfigCalculateId, {
- valueBinding: 'serviceConfig.value',
- rows: 20,
- classNames: ['span10']
- });
- /**
- * Textarea control with bigger height
- * @type {*}
- */
- App.ServiceConfigBigTextArea = App.ServiceConfigTextArea.extend(App.ServiceConfigCalculateId, {
- rows: 10
- });
- /**
- * Checkbox control
- * @type {*}
- */
- App.ServiceConfigCheckbox = Ember.Checkbox.extend(App.ServiceConfigPopoverSupport, App.ServiceConfigCalculateId, {
- allowedPairs: {
- 'trueFalse': ["true", "false"],
- 'YesNo': ["Yes", "No"],
- 'YESNO': ["YES", "NO"],
- 'yesNo': ["yes", "no"]
- },
- trueValue: true,
- falseValue: false,
- checked: false,
- /**
- * set appropriate config values pair
- * to define which value is positive (checked) property
- * and what value is negative (unchecked) proeprty
- */
- didInsertElement: function() {
- this._super();
- this.addObserver('serviceConfig.value', this, 'toggleChecker');
- Object.keys(this.get('allowedPairs')).forEach(function(key) {
- if (this.get('allowedPairs')[key].contains(this.get('serviceConfig.value'))) {
- this.set('trueValue', this.get('allowedPairs')[key][0]);
- this.set('falseValue', this.get('allowedPairs')[key][1]);
- }
- }, this);
- this.set('checked', this.get('serviceConfig.value') === this.get('trueValue'))
- },
- willDestroyElement: function() {
- this.removeObserver('serviceConfig.value', this, 'checkedBinding');
- },
- /***
- * defines if checkbox value appropriate to the config value
- * @returns {boolean}
- */
- isNotAppropriateValue: function() {
- return this.get('serviceConfig.value') !== this.get(this.get('checked') + 'Value');
- },
- /**
- * change service config value if click on checkbox
- */
- toggleValue: function() {
- if (this.isNotAppropriateValue()){
- this.set('serviceConfig.value', this.get(this.get('checked') + 'Value'));
- this.get('serviceConfig').set("editDone", true);
- }
- }.observes('checked'),
- /**
- * change checkbox value if click on undo
- */
- toggleChecker: function() {
- if (this.isNotAppropriateValue())
- this.set('checked', !this.get('checked'));
- },
- disabled: function () {
- return !this.get('serviceConfig.isEditable');
- }.property('serviceConfig.isEditable'),
- //Set editDone false for all current category config text field parameter
- focusIn: function (event) {
- if (!this.get('serviceConfig.isOverridden') && !this.get('serviceConfig.isComparison')) {
- this.get("parentView.categoryConfigsAll").setEach("editDone", false);
- }
- }
- });
- /**
- * Checkbox control which can hide or show dependent properties
- * @type {*|void}
- */
- App.ServiceConfigCheckboxWithDependencies = App.ServiceConfigCheckbox.extend({
- toggleDependentConfigs: function() {
- if (this.get('serviceConfig.dependentConfigPattern')) {
- if (this.get('serviceConfig.dependentConfigPattern') === "CATEGORY") {
- this.disableEnableCategoryConfigs();
- } else {
- this.showHideDependentConfigs();
- }
- }
- }.observes('checked'),
- disableEnableCategoryConfigs: function () {
- this.get('categoryConfigsAll').setEach('isEditable', this.get('checked'));
- this.set('serviceConfig.isEditable', true);
- },
- showHideDependentConfigs: function () {
- this.get('categoryConfigsAll').forEach(function (c) {
- if (c.get('name').match(this.get('serviceConfig.dependentConfigPattern')) && c.get('name') != this.get('serviceConfig.name'))
- c.set('isVisible', this.get('checked'))
- }, this);
- }
- });
- App.ServiceConfigRadioButtons = Ember.View.extend(App.ServiceConfigCalculateId, {
- templateName: require('templates/wizard/controls_service_config_radio_buttons'),
- didInsertElement: function () {
- // on page render, automatically populate JDBC URLs only for default database settings
- // so as to not lose the user's customizations on these fields
- if (['addServiceController', 'installerController'].contains(this.get('controller.wizardController.name'))) {
- if (/^New\s\w+\sDatabase$/.test(this.get('serviceConfig.value')) || this.dontUseHandleDbConnection.contains(this.get('serviceConfig.name'))) {
- this.onOptionsChange();
- } else {
- this.handleDBConnectionProperty();
- }
- }
- },
- /**
- * properties with these names don'use handleDBConnectionProperty mathod
- */
- dontUseHandleDbConnection: ['DB_FLAVOR', 'authentication_method'],
- configs: function () {
- if (this.get('controller.name') == 'mainServiceInfoConfigsController') return this.get('categoryConfigsAll');
- return this.get('categoryConfigsAll').filterProperty('isObserved', true);
- }.property('categoryConfigsAll'),
- serviceConfig: null,
- categoryConfigsAll: null,
- onOptionsChange: function () {
- // The following if condition will be satisfied only for installer wizard flow
- if (this.get('configs').length) {
- var connectionUrl = this.get('connectionUrl');
- if (connectionUrl) {
- var dbClass = this.get('dbClass');
- var hostName = this.get('hostName');
- var databaseName = this.get('databaseName');
- var hostNameDefault;
- var databaseNameDefault;
- var connectionUrlValue = connectionUrl.get('value');
- var connectionUrlDefaultValue = connectionUrl.get('defaultValue');
- var dbClassValue = dbClass.get('value');
- var serviceName = this.get('serviceConfig.serviceName');
- var isServiceInstalled = App.Service.find().someProperty('serviceName', serviceName);
- var postgresUrl = 'jdbc:postgresql://{0}:5432/{1}';
- var oracleUrl = 'jdbc:oracle:thin:@//{0}:1521/{1}';
- var mssqlUrl = 'jdbc:sqlserver://{0};databaseName={1}';
- var mssqlIntegratedAuthUrl = 'jdbc:sqlserver://{0};databaseName={1};integratedSecurity=true';
- var isNotExistingMySQLServer = this.get('serviceConfig.value') !== 'Existing MSSQL Server database with integrated authentication';
- var categoryConfigsAll = this.get('categoryConfigsAll');
- if (isServiceInstalled) {
- hostNameDefault = this.get('hostNameProperty.defaultValue');
- databaseNameDefault = this.get('databaseNameProperty.defaultValue');
- } else {
- hostNameDefault = hostName;
- databaseNameDefault = databaseName;
- }
- switch (serviceName) {
- case 'HIVE':
- var hiveDbType = this.get('parentView.serviceConfigs').findProperty('name', 'hive_database_type');
- var mysqlUrl = 'jdbc:mysql://{0}/{1}?createDatabaseIfNotExist=true';
- switch (this.get('serviceConfig.value')) {
- case 'New MySQL Database':
- case 'Existing MySQL Database':
- connectionUrlValue = mysqlUrl.format(hostName, databaseName);
- connectionUrlDefaultValue = mysqlUrl.format(hostNameDefault, databaseNameDefault);
- dbClassValue = 'com.mysql.jdbc.Driver';
- Em.set(hiveDbType, 'value', 'mysql');
- break;
- case Em.I18n.t('services.service.config.hive.oozie.postgresql'):
- connectionUrlValue = postgresUrl.format(hostName, databaseName);
- connectionUrlDefaultValue = postgresUrl.format(hostNameDefault, databaseNameDefault);
- dbClassValue = 'org.postgresql.Driver';
- Em.set(hiveDbType, 'value', 'postgres');
- break;
- case 'Existing Oracle Database':
- connectionUrlValue = oracleUrl.format(hostName, databaseName);
- connectionUrlDefaultValue = oracleUrl.format(hostNameDefault, databaseNameDefault);
- dbClassValue = 'oracle.jdbc.driver.OracleDriver';
- Em.set(hiveDbType, 'value', 'oracle');
- break;
- case 'Existing MSSQL Server database with SQL authentication':
- connectionUrlValue = mssqlUrl.format(hostName, databaseName);
- connectionUrlDefaultValue = mssqlUrl.format(hostNameDefault, databaseNameDefault);
- dbClassValue = 'com.microsoft.sqlserver.jdbc.SQLServerDriver';
- Em.set(hiveDbType, 'value', 'mssql');
- break;
- case 'Existing MSSQL Server database with integrated authentication':
- connectionUrlValue = mssqlIntegratedAuthUrl.format(hostName, databaseName);
- connectionUrlDefaultValue = mssqlIntegratedAuthUrl.format(hostNameDefault, databaseNameDefault);
- dbClassValue = 'com.microsoft.sqlserver.jdbc.SQLServerDriver';
- Em.set(hiveDbType, 'value', 'mssql');
- break;
- }
- categoryConfigsAll.findProperty('name', 'javax.jdo.option.ConnectionUserName').setProperties({
- isVisible: isNotExistingMySQLServer,
- isRequired: isNotExistingMySQLServer
- });
- categoryConfigsAll.findProperty('name', 'javax.jdo.option.ConnectionPassword').setProperties({
- isVisible: isNotExistingMySQLServer,
- isRequired: isNotExistingMySQLServer
- });
- break;
- case 'OOZIE':
- var derbyUrl = 'jdbc:derby:${oozie.data.dir}/${oozie.db.schema.name}-db;create=true';
- var mysqlUrl = 'jdbc:mysql://{0}/{1}';
- switch (this.get('serviceConfig.value')) {
- case 'New Derby Database':
- connectionUrlValue = derbyUrl;
- connectionUrlDefaultValue = derbyUrl;
- dbClassValue = 'org.apache.derby.jdbc.EmbeddedDriver';
- break;
- case 'Existing MySQL Database':
- connectionUrlValue = mysqlUrl.format(hostName, databaseName);
- connectionUrlDefaultValue = mysqlUrl.format(hostNameDefault, databaseNameDefault);
- dbClassValue = 'com.mysql.jdbc.Driver';
- break;
- case Em.I18n.t('services.service.config.hive.oozie.postgresql'):
- connectionUrlValue = postgresUrl.format(hostName, databaseName);
- connectionUrlDefaultValue = postgresUrl.format(hostNameDefault, databaseNameDefault);
- dbClassValue = 'org.postgresql.Driver';
- break;
- case 'Existing Oracle Database':
- connectionUrlValue = oracleUrl.format(hostName, databaseName);
- connectionUrlDefaultValue = oracleUrl.format(hostNameDefault, databaseNameDefault);
- dbClassValue = 'oracle.jdbc.driver.OracleDriver';
- break;
- case 'Existing MSSQL Server database with SQL authentication':
- connectionUrlValue = mssqlUrl.format(hostName, databaseName);
- connectionUrlDefaultValue = mssqlUrl.format(hostNameDefault, databaseNameDefault);
- dbClassValue = 'com.microsoft.sqlserver.jdbc.SQLServerDriver';
- break;
- case 'Existing MSSQL Server database with integrated authentication':
- connectionUrlValue = mssqlIntegratedAuthUrl.format(hostName, databaseName);
- connectionUrlDefaultValue = mssqlIntegratedAuthUrl.format(hostNameDefault, databaseNameDefault);
- dbClassValue = 'com.microsoft.sqlserver.jdbc.SQLServerDriver';
- break;
- }
- categoryConfigsAll.findProperty('name', 'oozie.service.JPAService.jdbc.username').setProperties({
- isVisible: isNotExistingMySQLServer,
- isRequired: isNotExistingMySQLServer
- });
- categoryConfigsAll.findProperty('name', 'oozie.service.JPAService.jdbc.password').setProperties({
- isVisible: isNotExistingMySQLServer,
- isRequired: isNotExistingMySQLServer
- });
- break;
- }
- connectionUrl.set('value', connectionUrlValue);
- connectionUrl.set('defaultValue', connectionUrlDefaultValue);
- dbClass.set('value', dbClassValue);
- }
- }
- }.observes('databaseName', 'hostName'),
- nameBinding: 'serviceConfig.radioName',
- databaseNameProperty: function () {
- switch (this.get('serviceConfig.serviceName')) {
- case 'HIVE':
- return this.get('categoryConfigsAll').findProperty('name', 'ambari.hive.db.schema.name');
- case 'OOZIE':
- return this.get('categoryConfigsAll').findProperty('name', 'oozie.db.schema.name');
- default:
- return null;
- }
- }.property('serviceConfig.serviceName'),
- databaseName: function () {
- return this.get('databaseNameProperty.value');
- }.property('databaseNameProperty.value'),
- hostNameProperty: function () {
- var value = this.get('serviceConfig.value');
- var returnValue;
- var hostname;
- if (this.get('serviceConfig.serviceName') === 'HIVE') {
- switch (value) {
- case 'New MySQL Database':
- hostname = this.get('categoryConfigsAll').findProperty('name', 'hive_ambari_host');
- break;
- case 'Existing MySQL Database':
- hostname = this.get('categoryConfigsAll').findProperty('name', 'hive_existing_mysql_host');
- break;
- case Em.I18n.t('services.service.config.hive.oozie.postgresql'):
- hostname = this.get('categoryConfigsAll').findProperty('name', 'hive_existing_postgresql_host');
- break;
- case 'Existing Oracle Database':
- hostname = this.get('categoryConfigsAll').findProperty('name', 'hive_existing_oracle_host');
- break;
- case 'Existing MSSQL Server database with SQL authentication':
- hostname = this.get('categoryConfigsAll').findProperty('name', 'hive_existing_mssql_server_host');
- break;
- case 'Existing MSSQL Server database with integrated authentication':
- hostname = this.get('categoryConfigsAll').findProperty('name', 'hive_existing_mssql_server_2_host');
- break;
- }
- if (hostname) {
- Em.set(hostname, 'isUserProperty', false);
- returnValue = hostname;
- } else {
- returnValue = this.get('categoryConfigsAll').findProperty('name', 'hive_hostname');
- }
- } else if (this.get('serviceConfig.serviceName') === 'OOZIE') {
- switch (value) {
- case 'New Derby Database':
- hostname = this.get('categoryConfigsAll').findProperty('name', 'oozie_ambari_host');
- break;
- case 'Existing MySQL Database':
- hostname = this.get('categoryConfigsAll').findProperty('name', 'oozie_existing_mysql_host');
- break;
- case Em.I18n.t('services.service.config.hive.oozie.postgresql'):
- hostname = this.get('categoryConfigsAll').findProperty('name', 'oozie_existing_postgresql_host');
- break;
- case 'Existing Oracle Database':
- hostname = this.get('categoryConfigsAll').findProperty('name', 'oozie_existing_oracle_host');
- break;
- case 'Existing MSSQL Server database with SQL authentication':
- hostname = this.get('categoryConfigsAll').findProperty('name', 'oozie_existing_mssql_server_host');
- break;
- case 'Existing MSSQL Server database with integrated authentication':
- hostname = this.get('categoryConfigsAll').findProperty('name', 'oozie_existing_mssql_server_2_host');
- break;
- }
- if (hostname) {
- Em.set(hostname, 'isUserProperty', false);
- returnValue = hostname;
- } else {
- returnValue = this.get('categoryConfigsAll').findProperty('name', 'oozie_hostname');
- }
- }
- return returnValue;
- }.property('serviceConfig.serviceName', 'serviceConfig.value'),
- hostName: function () {
- return this.get('hostNameProperty.value');
- }.property('hostNameProperty.value'),
- connectionUrl: function () {
- if (this.get('serviceConfig.serviceName') === 'HIVE') {
- return this.get('categoryConfigsAll').findProperty('name', 'javax.jdo.option.ConnectionURL');
- } else {
- return this.get('categoryConfigsAll').findProperty('name', 'oozie.service.JPAService.jdbc.url');
- }
- }.property('serviceConfig.serviceName'),
- dbClass: function () {
- if (this.get('serviceConfig.serviceName') === 'HIVE') {
- return this.get('categoryConfigsAll').findProperty('name', 'javax.jdo.option.ConnectionDriverName');
- } else {
- return this.get('categoryConfigsAll').findProperty('name', 'oozie.service.JPAService.jdbc.driver');
- }
- }.property('serviceConfig.serviceName'),
- /**
- * `Observer` that add <code>additionalView</code> to <code>App.ServiceConfigProperty</code>
- * that responsible for (if existing db selected)
- * 1. checking database connection
- * 2. showing jdbc driver setup warning msg.
- *
- * @method handleDBConnectionProperty
- **/
- handleDBConnectionProperty: function() {
- if (this.dontUseHandleDbConnection.contains(this.get('serviceConfig.name')))
- return;
- var handledProperties = ['oozie_database', 'hive_database'];
- var currentValue = this.get('serviceConfig.value');
- var databases = /MySQL|PostgreSQL|Oracle|Derby|MSSQL/gi;
- var currentDB = currentValue.match(databases)[0];
- var databasesTypes = /MySQL|PostgreS|Oracle|Derby|MSSQL/gi;
- var currentDBType = currentValue.match(databasesTypes)[0];
- var existingDatabase = /existing/gi.test(currentValue);
- // db connection check button show up if existed db selected
- var propertyAppendTo1 = this.get('categoryConfigsAll').findProperty('displayName', 'Database URL');
- if (currentDB && existingDatabase) {
- if (handledProperties.contains(this.get('serviceConfig.name'))) {
- if (propertyAppendTo1) propertyAppendTo1.set('additionalView', App.CheckDBConnectionView.extend({databaseName: currentDB}));
- }
- } else {
- propertyAppendTo1.set('additionalView', null);
- }
- // warning msg under database type radio buttons, to warn the user to setup jdbc driver if existed db selected
- var propertyHive = this.get('categoryConfigsAll').findProperty('displayName', 'Hive Database');
- var propertyOozie = this.get('categoryConfigsAll').findProperty('displayName', 'Oozie Database');
- var propertyAppendTo2 = propertyHive ? propertyHive : propertyOozie;
- if (currentDB && existingDatabase) {
- if (handledProperties.contains(this.get('serviceConfig.name'))) {
- if (propertyAppendTo2) {
- propertyAppendTo2.set('additionalView', Ember.View.extend({
- template: Ember.Handlebars.compile('<div class="alert">{{{view.message}}}</div>'),
- message: Em.I18n.t('services.service.config.database.msg.jdbcSetup').format(currentDBType.toLowerCase(), currentDBType.toLowerCase())
- }));
- }
- }
- } else {
- propertyAppendTo2.set('additionalView', null);
- }
- }.observes('serviceConfig.value'),
- optionsBinding: 'serviceConfig.options'
- });
- App.ServiceConfigRadioButton = Ember.Checkbox.extend({
- tagName: 'input',
- attributeBindings: ['type', 'name', 'value', 'checked', 'disabled'],
- checked: false,
- type: 'radio',
- name: null,
- value: null,
- didInsertElement: function () {
- console.debug('App.ServiceConfigRadioButton.didInsertElement');
- if (this.get('parentView.serviceConfig.value') === this.get('value')) {
- console.debug(this.get('name') + ":" + this.get('value') + ' is checked');
- this.set('checked', true);
- }
- },
- click: function () {
- this.set('checked', true);
- console.debug('App.ServiceConfigRadioButton.click');
- this.onChecked();
- },
- onChecked: function () {
- // Wrapping the call with Ember.run.next prevents a problem where setting isVisible on component
- // causes JS error due to re-rendering. For example, this occurs when switching the Config Group
- // in Service Config page
- Em.run.next(this, function() {
- console.debug('App.ServiceConfigRadioButton.onChecked');
- this.set('parentView.serviceConfig.value', this.get('value'));
- var components = this.get('parentView.serviceConfig.options');
- if (components) {
- components.forEach(function (_component) {
- if (_component.foreignKeys) {
- _component.foreignKeys.forEach(function (_componentName) {
- if (this.get('parentView.parentView.serviceConfigs').someProperty('name', _componentName)) {
- var component = this.get('parentView.parentView.serviceConfigs').findProperty('name', _componentName);
- component.set('isVisible', _component.displayName === this.get('value'));
- }
- }, this);
- }
- }, this);
- }
- });
- }.observes('checked'),
- disabled: function () {
- return !this.get('parentView.serviceConfig.isEditable') ||
- !['addServiceController', 'installerController'].contains(this.get('controller.wizardController.name')) && /^New\s\w+\sDatabase$/.test(this.get('value'));
- }.property('parentView.serviceConfig.isEditable')
- });
- App.ServiceConfigComboBox = Ember.Select.extend(App.ServiceConfigPopoverSupport, App.ServiceConfigCalculateId, {
- contentBinding: 'serviceConfig.options',
- selectionBinding: 'serviceConfig.value',
- placeholderBinding: 'serviceConfig.defaultValue',
- classNames: [ 'span3' ]
- });
- /**
- * Base component for host config with popover support
- */
- App.ServiceConfigHostPopoverSupport = Ember.Mixin.create({
- /**
- * Config object. It will instance of App.ServiceConfigProperty
- */
- serviceConfig: null,
- didInsertElement: function () {
- App.popover(this.$(), {
- title: this.get('serviceConfig.displayName'),
- content: this.get('serviceConfig.description'),
- placement: 'right',
- trigger: 'hover'
- });
- }
- });
- /**
- * Master host component.
- * Show hostname without ability to edit it
- * @type {*}
- */
- App.ServiceConfigMasterHostView = Ember.View.extend(App.ServiceConfigHostPopoverSupport, App.ServiceConfigCalculateId, {
- classNames: ['master-host', 'span6'],
- valueBinding: 'serviceConfig.value',
- template: Ember.Handlebars.compile('{{value}}')
- });
- /**
- * text field property view that enables possibility
- * for check connectio
- * @type {*}
- */
- App.checkConnectionView = App.ServiceConfigTextField.extend({
- didInsertElement: function() {
- this._super();
- var kdc = this.get('categoryConfigsAll').findProperty('name', 'kdc_type');
- var propertyAppendTo = this.get('categoryConfigsAll').findProperty('name', 'domains');
- if (propertyAppendTo) propertyAppendTo.set('additionalView', App.CheckDBConnectionView.extend({databaseName: kdc && kdc.get('value')}));
- }
- });
- /**
- * Show value as plain label in italics
- * @type {*}
- */
- App.ServiceConfigLabelView = Ember.View.extend(App.ServiceConfigHostPopoverSupport, App.ServiceConfigCalculateId, {
- classNames: ['master-host', 'span6'],
- valueBinding: 'serviceConfig.value',
- template: Ember.Handlebars.compile('<i>{{view.value}}</i>')
- });
- /**
- * Base component to display Multiple hosts
- * @type {*}
- */
- App.ServiceConfigMultipleHostsDisplay = Ember.Mixin.create(App.ServiceConfigHostPopoverSupport, App.ServiceConfigCalculateId, {
- hasNoHosts: function () {
- console.log('view', this.get('viewName')); //to know which View cause errors
- console.log('controller', this.get('controller').name); //should be slaveComponentGroupsController
- if (!this.get('value')) {
- return true;
- }
- return this.get('value').length === 0;
- }.property('value'),
- hasOneHost: function () {
- return this.get('value').length === 1;
- }.property('value'),
- hasMultipleHosts: function () {
- return this.get('value').length > 1;
- }.property('value'),
- otherLength: function () {
- var len = this.get('value').length;
- if (len > 2) {
- return Em.I18n.t('installer.controls.serviceConfigMultipleHosts.others').format(len - 1);
- } else {
- return Em.I18n.t('installer.controls.serviceConfigMultipleHosts.other');
- }
- }.property('value')
- });
- /**
- * Multiple master host component.
- * Show hostnames without ability to edit it
- * @type {*}
- */
- App.ServiceConfigMasterHostsView = Ember.View.extend(App.ServiceConfigMultipleHostsDisplay, App.ServiceConfigCalculateId, {
- viewName: "serviceConfigMasterHostsView",
- valueBinding: 'serviceConfig.value',
- classNames: ['master-hosts', 'span6'],
- templateName: require('templates/wizard/master_hosts'),
- /**
- * Onclick handler for link
- */
- showHosts: function () {
- var serviceConfig = this.get('serviceConfig');
- App.ModalPopup.show({
- header: Em.I18n.t('installer.controls.serviceConfigMasterHosts.header').format(serviceConfig.category),
- bodyClass: Ember.View.extend({
- serviceConfig: serviceConfig,
- templateName: require('templates/wizard/master_hosts_popup')
- }),
- secondary: null
- });
- }
- });
- /**
- * Show tabs list for slave hosts
- * @type {*}
- */
- App.SlaveComponentGroupsMenu = Em.CollectionView.extend(App.ServiceConfigCalculateId, {
- content: function () {
- return this.get('controller.componentGroups');
- }.property('controller.componentGroups'),
- tagName: 'ul',
- classNames: ["nav", "nav-tabs"],
- itemViewClass: Em.View.extend({
- classNameBindings: ["active"],
- active: function () {
- return this.get('content.active');
- }.property('content.active'),
- errorCount: function () {
- return this.get('content.properties').filterProperty('isValid', false).filterProperty('isVisible', true).get('length');
- }.property('content.properties.@each.isValid', 'content.properties.@each.isVisible'),
- templateName: require('templates/wizard/controls_slave_component_groups_menu')
- })
- });
- /**
- * <code>Add group</code> button
- * @type {*}
- */
- App.AddSlaveComponentGroupButton = Ember.View.extend(App.ServiceConfigCalculateId, {
- tagName: 'span',
- slaveComponentName: null,
- didInsertElement: function () {
- App.popover(this.$(), {
- title: Em.I18n.t('installer.controls.addSlaveComponentGroupButton.title').format(this.get('slaveComponentName')),
- content: Em.I18n.t('installer.controls.addSlaveComponentGroupButton.content').format(this.get('slaveComponentName'), this.get('slaveComponentName'), this.get('slaveComponentName')),
- placement: 'right',
- trigger: 'hover'
- });
- }
- });
- /**
- * Multiple Slave Hosts component
- * @type {*}
- */
- App.ServiceConfigSlaveHostsView = Ember.View.extend(App.ServiceConfigMultipleHostsDisplay, App.ServiceConfigCalculateId, {
- viewName: 'serviceConfigSlaveHostsView',
- classNames: ['slave-hosts', 'span6'],
- valueBinding: 'serviceConfig.value',
- templateName: require('templates/wizard/slave_hosts'),
- /**
- * Onclick handler for link
- */
- showHosts: function () {
- var serviceConfig = this.get('serviceConfig');
- App.ModalPopup.show({
- header: Em.I18n.t('installer.controls.serviceConfigMasterHosts.header').format(serviceConfig.category),
- bodyClass: Ember.View.extend({
- serviceConfig: serviceConfig,
- templateName: require('templates/wizard/master_hosts_popup')
- }),
- secondary: null
- });
- }
- });
- /**
- * properties for present active slave group
- * @type {*}
- */
- App.SlaveGroupPropertiesView = Ember.View.extend(App.ServiceConfigCalculateId, {
- viewName: 'serviceConfigSlaveHostsView',
- group: function () {
- return this.get('controller.activeGroup');
- }.property('controller.activeGroup'),
- groupConfigs: function () {
- console.log("************************************************************************");
- console.log("The value of group is: " + this.get('group'));
- console.log("************************************************************************");
- return this.get('group.properties');
- }.property('group.properties.@each').cacheable(),
- errorCount: function () {
- return this.get('group.properties').filterProperty('isValid', false).filterProperty('isVisible', true).get('length');
- }.property('configs.@each.isValid', 'configs.@each.isVisible')
- });
- /**
- * DropDown component for <code>select hosts for groups</code> popup
- * @type {*}
- */
- App.SlaveComponentDropDownGroupView = Ember.View.extend(App.ServiceConfigCalculateId, {
- viewName: "slaveComponentDropDownGroupView",
- /**
- * On change handler for <code>select hosts for groups</code> popup
- * @param event
- */
- changeGroup: function (event) {
- var host = this.get('content');
- var groupName = $('#' + this.get('elementId') + ' select').val();
- this.get('controller').changeHostGroup(host, groupName);
- },
- optionTag: Ember.View.extend({
- /**
- * Whether current value(OptionTag value) equals to host value(assigned to SlaveComponentDropDownGroupView.content)
- */
- selected: function () {
- return this.get('parentView.content.group') === this.get('content');
- }.property('content')
- })
- });
- /**
- * Show info about current group
- * @type {*}
- */
- App.SlaveComponentChangeGroupNameView = Ember.View.extend(App.ServiceConfigCalculateId, {
- contentBinding: 'controller.activeGroup',
- classNames: ['control-group'],
- classNameBindings: 'error',
- error: false,
- setError: function () {
- this.set('error', false);
- }.observes('controller.activeGroup'),
- errorMessage: function () {
- return this.get('error') ? Em.I18n.t('installer.controls.slaveComponentChangeGroupName.error') : '';
- }.property('error'),
- /**
- * Onclick handler for saving updated group name
- * @param event
- */
- changeGroupName: function (event) {
- var inputVal = $('#' + this.get('elementId') + ' input[type="text"]').val();
- if (inputVal !== this.get('content.name')) {
- var result = this.get('controller').changeSlaveGroupName(this.get('content'), inputVal);
- this.set('error', result);
- }
- }
- });
- /**
- * View for testing connection to database.
- **/
- App.CheckDBConnectionView = Ember.View.extend({
- templateName: require('templates/common/form/check_db_connection'),
- /** @property {string} btnCaption - text for button **/
- btnCaption: function() {
- return this.get('parentView.service.serviceName') === 'KERBEROS'
- ? Em.I18n.t('services.service.config.kdc.btn.idle')
- : Em.I18n.t('services.service.config.database.btn.idle')
- }.property('parentView.service.serviceName'),
- /** @property {string} responseCaption - text for status link **/
- responseCaption: null,
- /** @property {boolean} isConnecting - is request to server activated **/
- isConnecting: false,
- /** @property {boolean} isValidationPassed - check validation for required fields **/
- isValidationPassed: null,
- /** @property {string} databaseName- name of current database **/
- databaseName: null,
- /** @property {boolean} isRequestResolved - check for finished request to server **/
- isRequestResolved: false,
- /** @property {boolean} isConnectionSuccess - check for successful connection to database **/
- isConnectionSuccess: null,
- /** @property {string} responseFromServer - message from server response **/
- responseFromServer: null,
- /** @property {Object} ambariRequiredProperties - properties that need for custom action request **/
- ambariRequiredProperties: null,
- /** @property {Number} currentRequestId - current custom action request id **/
- currentRequestId: null,
- /** @property {Number} currentTaskId - current custom action task id **/
- currentTaskId: null,
- /** @property {jQuery.Deferred} request - current $.ajax request **/
- request: null,
- /** @property {Number} pollInterval - timeout interval for ajax polling **/
- pollInterval: 3000,
- /** @property {string} hostNameProperty - host name property based on service and database names **/
- hostNameProperty: function() {
- if (!/wizard/i.test(this.get('controller.name')) && this.get('parentView.service.serviceName') === 'HIVE') {
- return this.get('parentView.service.serviceName').toLowerCase() + '_hostname';
- } else if (this.get('parentView.service.serviceName') === 'KERBEROS') {
- return 'kdc_host';
- }
- return '{0}_existing_{1}_host'.format(this.get('parentView.service.serviceName').toLowerCase(), this.get('databaseName').toLowerCase());
- }.property('databaseName'),
- /** @property {boolean} isBtnDisabled - disable button on failed validation or active request **/
- isBtnDisabled: function() {
- return !this.get('isValidationPassed') || this.get('isConnecting');
- }.property('isValidationPassed', 'isConnecting'),
- /** @property {object} requiredProperties - properties that necessary for database connection **/
- requiredProperties: function() {
- var propertiesMap = {
- OOZIE: ['oozie.db.schema.name','oozie.service.JPAService.jdbc.username','oozie.service.JPAService.jdbc.password','oozie.service.JPAService.jdbc.driver','oozie.service.JPAService.jdbc.url'],
- HIVE: ['ambari.hive.db.schema.name','javax.jdo.option.ConnectionUserName','javax.jdo.option.ConnectionPassword','javax.jdo.option.ConnectionDriverName','javax.jdo.option.ConnectionURL'],
- KERBEROS: ['kdc_host']
- };
- return propertiesMap[this.get('parentView.service.serviceName')];
- }.property(),
- /** @property {Object} propertiesPattern - check pattern according to type of connection properties **/
- propertiesPattern: function() {
- var patterns = {
- db_connection_url: /jdbc\.url|connectionurl|kdc_host/ig
- };
- if (this.get('parentView.service.serviceName') != "KERBEROS") {
- patterns.user_name = /(username|dblogin)$/ig;
- patterns.user_passwd = /(dbpassword|password)$/ig;
- }
- return patterns;
- }.property('parentView.service.serviceName'),
- /** @property {String} masterHostName - host name location of Master Component related to Service **/
- masterHostName: function() {
- var serviceMasterMap = {
- 'OOZIE': 'oozie_ambari_host',
- 'HDFS': 'hadoop_host',
- 'HIVE': 'hive_ambari_host',
- 'KERBEROS': 'kdc_host'
- };
- return this.get('parentView.categoryConfigsAll').findProperty('name', serviceMasterMap[this.get('parentView.service.serviceName')]).get('value');
- }.property('parentView.service.serviceName', 'parentView.categoryConfigsAll.@each.value'),
- /** @property {Object} connectionProperties - service specific config values mapped for custom action request **/
- connectionProperties: function() {
- var propObj = {};
- for (var key in this.get('propertiesPattern')) {
- propObj[key] = this.getConnectionProperty(this.get('propertiesPattern')[key]);
- }
- return propObj;
- }.property('parentView.categoryConfigsAll.@each.value'),
- /**
- * Properties that stores in local storage used for handling
- * last success connection.
- *
- * @property {Object} preparedDBProperties
- **/
- preparedDBProperties: function() {
- var propObj = {};
- for (var key in this.get('propertiesPattern')) {
- var propName = this.getConnectionProperty(this.get('propertiesPattern')[key], true);
- propObj[propName] = this.get('parentView.categoryConfigsAll').findProperty('name', propName).get('value');
- }
- return propObj;
- }.property(),
- /** Check validation and load ambari properties **/
- didInsertElement: function() {
- var kdc = this.get('parentView.categoryConfigsAll').findProperty('name', 'kdc_type');
- if (kdc) {
- var name = kdc.get('value') == 'Existing MIT KDC' ? 'KDC' : 'AD';
- App.popover(this.$(), {
- title: Em.I18n.t('services.service.config.database.btn.idle'),
- content: Em.I18n.t('installer.controls.checkConnection.popover').format(name),
- placement: 'right',
- trigger: 'hover'
- });
- }
- this.handlePropertiesValidation();
- this.getAmbariProperties();
- },
- /** On view destroy **/
- willDestroyElement: function() {
- this.set('isConnecting', false);
- this._super();
- },
- /**
- * Observer that take care about enabling/disabling button based on required properties validation.
- *
- * @method handlePropertiesValidation
- **/
- handlePropertiesValidation: function() {
- this.restore();
- var isValid = true;
- var properties = [].concat(this.get('requiredProperties'));
- properties.push(this.get('hostNameProperty'));
- properties.forEach(function(propertyName) {
- var property = this.get('parentView.categoryConfigsAll').findProperty('name', propertyName);
- if(property && !property.get('isValid')) isValid = false;
- }, this);
- this.set('isValidationPassed', isValid);
- }.observes('parentView.categoryConfigsAll.@each.isValid', 'parentView.categoryConfigsAll.@each.value', 'databaseName'),
- getConnectionProperty: function(regexp, isGetName) {
- var _this = this;
- var propertyName = _this.get('requiredProperties').filter(function(item) {
- return regexp.test(item);
- })[0];
- return (isGetName) ? propertyName : _this.get('parentView.categoryConfigsAll').findProperty('name', propertyName).get('value');
- },
- /**
- * Set up ambari properties required for custom action request
- *
- * @method getAmbariProperties
- **/
- getAmbariProperties: function() {
- var clusterController = App.router.get('clusterController');
- var _this = this;
- if (!App.isEmptyObject(App.db.get('tmp', 'ambariProperties')) && !this.get('ambariProperties')) {
- this.set('ambariProperties', App.db.get('tmp', 'ambariProperties'));
- return;
- }
- if (App.isEmptyObject(clusterController.get('ambariProperties'))) {
- clusterController.loadAmbariProperties().done(function(data) {
- _this.formatAmbariProperties(data.RootServiceComponents.properties);
- });
- } else {
- this.formatAmbariProperties(clusterController.get('ambariProperties'));
- }
- },
- formatAmbariProperties: function(properties) {
- var defaults = {
- threshold: "60",
- ambari_server_host: location.hostname,
- check_execute_list : "db_connection_check"
- };
- var properties = App.permit(properties, ['jdk.name','jdk_location','java.home']);
- var renameKey = function(oldKey, newKey) {
- if (properties[oldKey]) {
- defaults[newKey] = properties[oldKey];
- delete properties[oldKey];
- }
- };
- renameKey('java.home', 'java_home');
- renameKey('jdk.name', 'jdk_name');
- $.extend(properties, defaults);
- App.db.set('tmp', 'ambariProperties', properties);
- this.set('ambariProperties', properties);
- },
- /**
- * `Action` method for starting connect to current database.
- *
- * @method connectToDatabase
- **/
- connectToDatabase: function() {
- if (this.get('isBtnDisabled')) return;
- this.set('isRequestResolved', false);
- App.db.set('tmp', this.get('parentView.service.serviceName') + '_connection', {});
- this.setConnectingStatus(true);
- if (App.get('testMode')) {
- this.startPolling();
- } else {
- this.runCheckConnection();
- }
- },
- /**
- * runs check connections methods depending on service
- * @return {void}
- * @method runCheckConnection
- */
- runCheckConnection: function() {
- if (this.get('parentView.service.serviceName') === 'KERBEROS') {
- this.runKDCCheck();
- } else {
- this.createCustomAction();
- }
- },
- /**
- * send ajax request to perforn kdc host check
- * @return {App.ajax}
- * @method runKDCCheck
- */
- runKDCCheck: function() {
- return App.ajax.send({
- name: 'admin.kerberos_security.test_connection',
- sender: this,
- data: {
- kdcHostname: this.get('masterHostName')
- },
- success: 'onRunKDCCheckSuccess',
- error: 'onCreateActionError'
- });
- },
- /**
- *
- * @param data
- */
- onRunKDCCheckSuccess: function(data) {
- var statusCode = {
- success: 'REACHABLE',
- failed: 'UNREACHABLE'
- };
- if (data == statusCode['success']) {
- this.setResponseStatus('success');
- } else {
- this.setResponseStatus('failed');
- }
- this.set('responseFromServer', data);
- },
- /**
- * Run custom action for database connection.
- *
- * @method createCustomAction
- **/
- createCustomAction: function() {
- var dbName = this.get('databaseName').toLowerCase() === 'postgresql' ? 'postgres' : this.get('databaseName').toLowerCase();
- var params = $.extend(true, {}, { db_name: dbName }, this.get('connectionProperties'), this.get('ambariProperties'));
- App.ajax.send({
- name: 'custom_action.create',
- sender: this,
- data: {
- requestInfo: {
- parameters: params
- },
- filteredHosts: [this.get('masterHostName')]
- },
- success: 'onCreateActionSuccess',
- error: 'onCreateActionError'
- });
- },
- /**
- * Run updater if task is created successfully.
- *
- * @method onConnectActionS
- **/
- onCreateActionSuccess: function(data) {
- this.set('currentRequestId', data.Requests.id);
- App.ajax.send({
- name: 'custom_action.request',
- sender: this,
- data: {
- requestId: this.get('currentRequestId')
- },
- success: 'setCurrentTaskId'
- });
- },
- setCurrentTaskId: function(data) {
- this.set('currentTaskId', data.items[0].Tasks.id);
- this.startPolling();
- },
- startPolling: function() {
- if (this.get('isConnecting'))
- this.getTaskInfo();
- },
- getTaskInfo: function() {
- var request = App.ajax.send({
- name: 'custom_action.request',
- sender: this,
- data: {
- requestId: this.get('currentRequestId'),
- taskId: this.get('currentTaskId')
- },
- success: 'getTaskInfoSuccess'
- });
- this.set('request', request);
- },
- getTaskInfoSuccess: function(data) {
- var task = data.Tasks;
- this.set('responseFromServer', {
- stderr: task.stderr,
- stdout: task.stdout
- });
- if (task.status === 'COMPLETED') {
- var structuredOut = task.structured_out.db_connection_check;
- if (structuredOut.exit_code != 0) {
- this.set('responseFromServer', {
- stderr: task.stderr,
- stdout: task.stdout,
- structuredOut: structuredOut.message
- });
- this.setResponseStatus('failed');
- } else {
- App.db.set('tmp', this.get('parentView.service.serviceName') + '_connection', this.get('preparedDBProperties'));
- this.setResponseStatus('success');
- }
- }
- if (task.status === 'FAILED') {
- this.setResponseStatus('failed');
- }
- if (/PENDING|QUEUED|IN_PROGRESS/.test(task.status)) {
- Em.run.later(this, function() {
- this.startPolling();
- }, this.get('pollInterval'));
- }
- },
- onCreateActionError: function(jqXhr, status, errorMessage) {
- this.setResponseStatus('failed');
- this.set('responseFromServer', errorMessage);
- },
- setResponseStatus: function(isSuccess) {
- var isSuccess = isSuccess == 'success';
- this.setConnectingStatus(false);
- this.set('responseCaption', isSuccess ? Em.I18n.t('services.service.config.database.connection.success') : Em.I18n.t('services.service.config.database.connection.failed'));
- this.set('isConnectionSuccess', isSuccess);
- this.set('isRequestResolved', true);
- },
- /**
- * Switch captions and statuses for active/non-active request.
- *
- * @method setConnectionStatus
- * @param {Boolean} [active]
- */
- setConnectingStatus: function(active) {
- if (active) {
- this.set('responseCaption', Em.I18n.t('services.service.config.database.connection.inProgress'));
- }
- this.set('controller.testConnectionInProgress', !!active);
- this.set('btnCaption', !!active ? Em.I18n.t('services.service.config.database.btn.connecting') : Em.I18n.t('services.service.config.database.btn.idle'));
- this.set('isConnecting', !!active);
- },
- /**
- * Set view to init status.
- *
- * @method restore
- **/
- restore: function() {
- if (this.get('request')) {
- this.get('request').abort();
- this.set('request', null);
- }
- this.set('responseCaption', null);
- this.set('responseFromServer', null);
- this.setConnectingStatus(false);
- this.set('isRequestResolved', false);
- },
- /**
- * `Action` method for showing response from server in popup.
- *
- * @method showLogsPopup
- **/
- showLogsPopup: function() {
- if (this.get('isConnectionSuccess')) return;
- var _this = this;
- var popup = App.showAlertPopup('Error: {0} connection'.format(this.get('databaseName')));
- if (typeof this.get('responseFromServer') == 'object') {
- popup.set('bodyClass', Em.View.extend({
- templateName: require('templates/common/error_log_body'),
- openedTask: _this.get('responseFromServer')
- }));
- } else {
- popup.set('body', this.get('responseFromServer'));
- }
- return popup;
- }
- });
- /**
- * View with input field used to repo-version URLs
- * @type {*}
- */
- App.BaseUrlTextField = Ember.TextField.extend({
- layout: Ember.Handlebars.compile('<div class="pull-left">{{yield}}</div> {{#if view.valueWasChanged}}<div class="pull-right"><a class="btn btn-small" {{action "restoreValue" target="view"}}><i class="icon-undo"></i></a></div>{{/if}}'),
- /**
- * Binding in the template
- * @type {App.RepositoryVersion}
- */
- repository: null,
- /**
- * @type {string}
- */
- valueBinding: 'repository.baseUrl',
- /**
- * @type {string}
- */
- defaultValue: '',
- /**
- * Determines if user have put some new value
- * @type {boolean}
- */
- valueWasChanged: false,
- didInsertElement: function () {
- this.set('defaultValue', this.get('value'));
- this.addObserver('value', this, this.valueWasChangedObs);
- },
- valueWasChangedObs: function () {
- var value = this.get('value'),
- defaultValue = this.get('defaultValue');
- this.set('valueWasChanged', value !== defaultValue);
- },
- /**
- * Restore value and unset error-flag
- * @method restoreValue
- */
- restoreValue: function () {
- this.set('value', this.get('defaultValue'));
- this.keyUp();
- },
- /**
- * Remove error-highlight after user puts some new value
- * @method keyUp
- */
- keyUp: function () {
- if (Em.get(this, 'repository.hasError')) {
- Em.set(this, 'repository.hasError', false);
- }
- }
- });
|