config.js 32 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800
  1. /**
  2. * Licensed to the Apache Software Foundation (ASF) under one
  3. * or more contributor license agreements. See the NOTICE file
  4. * distributed with this work for additional information
  5. * regarding copyright ownership. The ASF licenses this file
  6. * to you under the Apache License, Version 2.0 (the
  7. * "License"); you may not use this file except in compliance
  8. * with the License. You may obtain a copy of the License at
  9. *
  10. * http://www.apache.org/licenses/LICENSE-2.0
  11. *
  12. * Unless required by applicable law or agreed to in writing, software
  13. * distributed under the License is distributed on an "AS IS" BASIS,
  14. * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  15. * See the License for the specific language governing permissions and
  16. * limitations under the License.
  17. */
  18. var App = require('app');
  19. var stringUtils = require('utils/string_utils');
  20. var serviceComponents = {};
  21. var configGroupsByTag = [];
  22. var globalPropertyToServicesMap = null;
  23. App.config = Em.Object.create({
  24. preDefinedServiceConfigs: function(){
  25. var configs = this.get('preDefinedConfigProperties');
  26. var services = [];
  27. require('data/service_configs').forEach(function(service){
  28. service.configs = configs.filterProperty('serviceName', service.serviceName);
  29. services.push(service);
  30. });
  31. return services;
  32. }.property('preDefinedConfigProperties'),
  33. configMapping: function() {
  34. if (stringUtils.compareVersions(App.get('currentStackVersionNumber'), "2.0") === 1 ||
  35. stringUtils.compareVersions(App.get('currentStackVersionNumber'), "2.0") === 0) {
  36. return require('data/HDP2/config_mapping');
  37. }
  38. return require('data/config_mapping');
  39. }.property('App.currentStackVersionNumber'),
  40. preDefinedConfigProperties: function() {
  41. if (stringUtils.compareVersions(App.get('currentStackVersionNumber'), "2.0") === 1 ||
  42. stringUtils.compareVersions(App.get('currentStackVersionNumber'), "2.0") === 0) {
  43. return require('data/HDP2/config_properties').configProperties;
  44. }
  45. return require('data/config_properties').configProperties;
  46. }.property('App.currentStackVersionNumber'),
  47. preDefinedCustomConfigs: require('data/custom_configs'),
  48. //categories which contain custom configs
  49. categoriesWithCustom: ['CapacityScheduler'],
  50. //configs with these filenames go to appropriate category not in Advanced
  51. customFileNames: function() {
  52. if (App.supports.capacitySchedulerUi) {
  53. return ['capacity-scheduler.xml', 'mapred-queue-acls.xml'];
  54. } else {
  55. return [];
  56. }
  57. }.property(''),
  58. /**
  59. * Cache of loaded configurations. This is useful in not loading
  60. * same configuration multiple times. It is populated in multiple
  61. * places.
  62. *
  63. * Example:
  64. * {
  65. * 'global_version1': {...},
  66. * 'global_version2': {...},
  67. * 'hdfs-site_version3': {...},
  68. * }
  69. */
  70. loadedConfigurationsCache: {},
  71. /**
  72. * Array of global "service/desired_tag/actual_tag" strings which
  73. * indicate different configurations. We cache these so that
  74. * we dont have to recalculate if two tags are difference.
  75. */
  76. differentGlobalTagsCache:[],
  77. identifyCategory: function(config){
  78. var category = null;
  79. var serviceConfigMetaData = this.get('preDefinedServiceConfigs').findProperty('serviceName', config.serviceName);
  80. if (serviceConfigMetaData) {
  81. serviceConfigMetaData.configCategories.forEach(function (_category) {
  82. if (_category.siteFileNames && Array.isArray(_category.siteFileNames) && _category.siteFileNames.contains(config.filename)) {
  83. category = _category;
  84. }
  85. });
  86. category = (category == null) ? serviceConfigMetaData.configCategories.findProperty('siteFileName', config.filename) : category;
  87. }
  88. return category;
  89. },
  90. /**
  91. * additional handling for special properties such as
  92. * checkbox and digital which values with 'm' at the end
  93. * @param config
  94. */
  95. handleSpecialProperties: function(config){
  96. if (config.displayType === 'int' && /\d+m$/.test(config.value)) {
  97. config.value = config.value.slice(0, config.value.length - 1);
  98. config.defaultValue = config.value;
  99. }
  100. if (config.displayType === 'checkbox') {
  101. config.value = (config.value === 'true') ? config.defaultValue = true : config.defaultValue = false;
  102. }
  103. },
  104. /**
  105. * calculate config properties:
  106. * category, filename, isRequired, isUserProperty
  107. * @param config
  108. * @param isAdvanced
  109. * @param advancedConfigs
  110. */
  111. calculateConfigProperties: function(config, isAdvanced, advancedConfigs){
  112. if (!isAdvanced || this.get('customFileNames').contains(config.filename)) {
  113. var categoryMetaData = this.identifyCategory(config);
  114. if (categoryMetaData != null) {
  115. config.category = categoryMetaData.get('name');
  116. if(!isAdvanced) config.isUserProperty = true;
  117. }
  118. } else {
  119. config.category = 'Advanced';
  120. config.filename = isAdvanced && advancedConfigs.findProperty('name', config.name).filename;
  121. config.isRequired = true;
  122. }
  123. },
  124. /**
  125. * return:
  126. * configs,
  127. * globalConfigs,
  128. * mappingConfigs
  129. *
  130. * @param configGroups
  131. * @param advancedConfigs
  132. * @param tags
  133. * @param serviceName
  134. * @return {object}
  135. */
  136. mergePreDefinedWithLoaded: function (configGroups, advancedConfigs, tags, serviceName) {
  137. var configs = [];
  138. var globalConfigs = [];
  139. var preDefinedConfigs = this.get('preDefinedConfigProperties');
  140. var mappingConfigs = [];
  141. tags.forEach(function (_tag) {
  142. var isAdvanced = null;
  143. var properties = configGroups.filter(function (serviceConfigProperties) {
  144. return _tag.tagName === serviceConfigProperties.tag && _tag.siteName === serviceConfigProperties.type;
  145. });
  146. properties = (properties.length) ? properties.objectAt(0).properties : {};
  147. for (var index in properties) {
  148. var configsPropertyDef = preDefinedConfigs.findProperty('name', index) || null;
  149. var serviceConfigObj = App.ServiceConfig.create({
  150. name: index,
  151. value: properties[index],
  152. defaultValue: properties[index],
  153. filename: _tag.siteName + ".xml",
  154. isUserProperty: false,
  155. isOverridable: true,
  156. serviceName: serviceName,
  157. belongsToService: []
  158. });
  159. if (configsPropertyDef) {
  160. serviceConfigObj.displayType = configsPropertyDef.displayType;
  161. serviceConfigObj.isRequired = (configsPropertyDef.isRequired !== undefined) ? configsPropertyDef.isRequired : true;
  162. serviceConfigObj.isReconfigurable = (configsPropertyDef.isReconfigurable !== undefined) ? configsPropertyDef.isReconfigurable : true;
  163. serviceConfigObj.isVisible = (configsPropertyDef.isVisible !== undefined) ? configsPropertyDef.isVisible : true;
  164. serviceConfigObj.unit = (configsPropertyDef.unit !== undefined) ? configsPropertyDef.unit : undefined;
  165. serviceConfigObj.description = (configsPropertyDef.description !== undefined) ? configsPropertyDef.description : undefined;
  166. serviceConfigObj.isOverridable = configsPropertyDef.isOverridable === undefined ? true : configsPropertyDef.isOverridable;
  167. serviceConfigObj.serviceName = configsPropertyDef ? configsPropertyDef.serviceName : null;
  168. serviceConfigObj.index = configsPropertyDef.index;
  169. serviceConfigObj.isSecureConfig = configsPropertyDef.isSecureConfig === undefined ? false : configsPropertyDef.isSecureConfig;
  170. serviceConfigObj.belongsToService = configsPropertyDef.belongsToService;
  171. }
  172. // MAPREDUCE contains core-site properties but doesn't show them
  173. if(serviceConfigObj.serviceName === 'MAPREDUCE' && serviceConfigObj.filename === 'core-site.xml'){
  174. serviceConfigObj.isVisible = false;
  175. }
  176. if (_tag.siteName === 'global') {
  177. if (configsPropertyDef) {
  178. this.handleSpecialProperties(serviceConfigObj);
  179. } else {
  180. serviceConfigObj.isVisible = false; // if the global property is not defined on ui metadata config_properties.js then it shouldn't be a part of errorCount
  181. }
  182. serviceConfigObj.id = 'puppet var';
  183. serviceConfigObj.displayName = configsPropertyDef ? configsPropertyDef.displayName : null;
  184. serviceConfigObj.category = configsPropertyDef ? configsPropertyDef.category : null;
  185. serviceConfigObj.options = configsPropertyDef ? configsPropertyDef.options : null;
  186. globalConfigs.push(serviceConfigObj);
  187. } else if (!this.get('configMapping').computed().someProperty('name', index)) {
  188. isAdvanced = advancedConfigs.someProperty('name', index);
  189. serviceConfigObj.id = 'site property';
  190. serviceConfigObj.displayType = stringUtils.isSingleLine(serviceConfigObj.value) ? 'advanced' : 'multiLine';
  191. serviceConfigObj.displayName = configsPropertyDef ? configsPropertyDef.displayName : index;
  192. this.calculateConfigProperties(serviceConfigObj, isAdvanced, advancedConfigs);
  193. configs.push(serviceConfigObj);
  194. } else {
  195. mappingConfigs.push(serviceConfigObj);
  196. }
  197. }
  198. }, this);
  199. return {
  200. configs: configs,
  201. globalConfigs: globalConfigs,
  202. mappingConfigs: mappingConfigs
  203. }
  204. },
  205. /**
  206. * merge stored configs with pre-defined
  207. * @param storedConfigs
  208. * @param advancedConfigs
  209. * @return {*}
  210. */
  211. mergePreDefinedWithStored: function (storedConfigs, advancedConfigs) {
  212. var mergedConfigs = [];
  213. var preDefinedConfigs = $.extend(true, [], this.get('preDefinedConfigProperties'));
  214. var preDefinedNames = [];
  215. var storedNames = [];
  216. var names = [];
  217. var categoryMetaData = null;
  218. storedConfigs = (storedConfigs) ? storedConfigs : [];
  219. preDefinedNames = this.get('preDefinedConfigProperties').mapProperty('name');
  220. storedNames = storedConfigs.mapProperty('name');
  221. names = preDefinedNames.concat(storedNames).uniq();
  222. names.forEach(function (name) {
  223. var stored = storedConfigs.findProperty('name', name);
  224. var preDefined = preDefinedConfigs.findProperty('name', name);
  225. var configData = {};
  226. var isAdvanced = advancedConfigs.someProperty('name', name);
  227. if (preDefined && stored) {
  228. configData = preDefined;
  229. configData.value = stored.value;
  230. configData.overrides = stored.overrides;
  231. } else if (!preDefined && stored) {
  232. configData = {
  233. id: stored.id,
  234. name: stored.name,
  235. displayName: stored.name,
  236. serviceName: stored.serviceName,
  237. value: stored.value,
  238. defaultValue: stored.defaultValue,
  239. displayType: stringUtils.isSingleLine(stored.value) ? 'advanced' : 'multiLine',
  240. filename: stored.filename,
  241. category: 'Advanced',
  242. isUserProperty: stored.isUserProperty === true,
  243. isOverridable: true,
  244. overrides: stored.overrides,
  245. isRequired: true
  246. };
  247. this.calculateConfigProperties(configData, isAdvanced, advancedConfigs);
  248. } else if (preDefined && !stored) {
  249. configData = preDefined;
  250. if (isAdvanced) {
  251. configData.filename = advancedConfigs.findProperty('name', configData.name).filename;
  252. }
  253. }
  254. mergedConfigs.push(configData);
  255. }, this);
  256. return mergedConfigs;
  257. },
  258. /**
  259. * look over advanced configs and add missing configs to serviceConfigs
  260. * filter fetched configs by service if passed
  261. * @param serviceConfigs
  262. * @param advancedConfigs
  263. * @param serviceName
  264. */
  265. addAdvancedConfigs: function (serviceConfigs, advancedConfigs, serviceName) {
  266. var configsToVerifying = (serviceName) ? serviceConfigs.filterProperty('serviceName', serviceName) : serviceConfigs;
  267. advancedConfigs.forEach(function (_config) {
  268. var configCategory = 'Advanced';
  269. var categoryMetaData = null;
  270. if (_config) {
  271. if (this.get('configMapping').computed().someProperty('name', _config.name)) {
  272. } else if (!(configsToVerifying.someProperty('name', _config.name))) {
  273. if(this.get('customFileNames').contains(_config.filename)){
  274. categoryMetaData = this.identifyCategory(_config);
  275. if (categoryMetaData != null) {
  276. configCategory = categoryMetaData.get('name');
  277. }
  278. }
  279. _config.id = "site property";
  280. _config.category = configCategory;
  281. _config.displayName = _config.name;
  282. _config.defaultValue = _config.value;
  283. // make all advanced configs optional and populated by default
  284. /*
  285. * if (/\${.*}/.test(_config.value) || (service.serviceName !==
  286. * 'OOZIE' && service.serviceName !== 'HBASE')) { _config.isRequired =
  287. * false; _config.value = ''; } else if
  288. * (/^\s+$/.test(_config.value)) { _config.isRequired = false; }
  289. */
  290. _config.isRequired = true;
  291. _config.displayType = 'advanced';
  292. serviceConfigs.push(_config);
  293. }
  294. }
  295. }, this);
  296. },
  297. /**
  298. * Render a custom conf-site box for entering properties that will be written in *-site.xml files of the services
  299. */
  300. addCustomConfigs: function (configs) {
  301. var preDefinedCustomConfigs = $.extend(true, [], this.get('preDefinedCustomConfigs'));
  302. var stored = configs.filter(function (_config) {
  303. if (this.get('categoriesWithCustom').contains(_config.category)) return true;
  304. }, this);
  305. var queueProperties = stored.filter(function (_config) {
  306. if ((_config.name.indexOf('mapred.capacity-scheduler.queue.') !== -1) ||
  307. (/mapred.queue.[a-z]([\_\-a-z0-9]{0,50}).acl-administer-jobs/i.test(_config.name)) ||
  308. (/mapred.queue.[a-z]([\_\-a-z0-9]{0,50}).acl-submit-job/i.test(_config.name))) {
  309. return true;
  310. }
  311. });
  312. if (queueProperties.length) {
  313. queueProperties.setEach('isQueue', true);
  314. } else {
  315. queueProperties = preDefinedCustomConfigs.filterProperty('isQueue');
  316. queueProperties.forEach(function (customConfig) {
  317. this.setDefaultQueue(customConfig, 'default');
  318. configs.push(customConfig);
  319. }, this);
  320. }
  321. },
  322. /**
  323. * set values to properties of queue
  324. * @param customConfig
  325. * @param queueName
  326. */
  327. setDefaultQueue: function (customConfig, queueName) {
  328. customConfig.name = customConfig.name.replace(/<queue-name>/, queueName);
  329. //default values of queue
  330. switch (customConfig.name) {
  331. case 'mapred.capacity-scheduler.queue.' + queueName + '.capacity':
  332. customConfig.value = '100';
  333. break;
  334. case 'mapred.capacity-scheduler.queue.' + queueName + '.maximum-capacity':
  335. customConfig.value = '100';
  336. break;
  337. case 'mapred.capacity-scheduler.queue.' + queueName + '.minimum-user-limit-percent':
  338. customConfig.value = '100';
  339. break;
  340. case 'mapred.capacity-scheduler.queue.' + queueName + '.user-limit-factor':
  341. customConfig.value = '1';
  342. break;
  343. case 'mapred.capacity-scheduler.queue.' + queueName + '.maximum-initialized-active-tasks':
  344. customConfig.value = '200000';
  345. break;
  346. case 'mapred.capacity-scheduler.queue.' + queueName + '.maximum-initialized-active-tasks-per-user':
  347. customConfig.value = '100000';
  348. break;
  349. case 'mapred.capacity-scheduler.queue.' + queueName + '.init-accept-jobs-factor':
  350. customConfig.value = '10';
  351. break;
  352. case 'mapred.capacity-scheduler.queue.' + queueName + '.supports-priority':
  353. customConfig.value = 'false';
  354. break;
  355. case 'mapred.queue.' + queueName + '.acl-submit-job':
  356. customConfig.value = '*';
  357. break;
  358. case 'mapred.queue.' + queueName + '.acl-administer-jobs':
  359. customConfig.value = '*';
  360. break;
  361. }
  362. },
  363. miscConfigVisibleProperty: function (configs, serviceToShow) {
  364. configs.forEach(function(item) {
  365. item.set("isVisible", item.belongsToService.some(function(cur){return serviceToShow.contains(cur)}));
  366. });
  367. return configs;
  368. },
  369. /**
  370. * render configs, distribute them by service
  371. * and wrap each in ServiceConfigProperty object
  372. * @param configs
  373. * @param allInstalledServiceNames
  374. * @param selectedServiceNames
  375. * @return {Array}
  376. */
  377. renderConfigs: function (configs, allInstalledServiceNames, selectedServiceNames) {
  378. var renderedServiceConfigs = [];
  379. var localDB = {
  380. hosts: App.db.getHosts(),
  381. masterComponentHosts: App.db.getMasterComponentHosts(),
  382. slaveComponentHosts: App.db.getSlaveComponentHosts()
  383. };
  384. var services = [];
  385. this.get('preDefinedServiceConfigs').forEach(function (serviceConfig) {
  386. if (allInstalledServiceNames.contains(serviceConfig.serviceName) || serviceConfig.serviceName === 'MISC') {
  387. console.log('pushing ' + serviceConfig.serviceName, serviceConfig);
  388. if (selectedServiceNames.contains(serviceConfig.serviceName) || serviceConfig.serviceName === 'MISC') {
  389. serviceConfig.showConfig = true;
  390. }
  391. services.push(serviceConfig);
  392. }
  393. });
  394. services.forEach(function (service) {
  395. var serviceConfig = {};
  396. var configsByService = [];
  397. var serviceConfigs = configs.filterProperty('serviceName', service.serviceName);
  398. serviceConfigs.forEach(function (_config) {
  399. var serviceConfigProperty = {};
  400. _config.isOverridable = (_config.isOverridable === undefined) ? true : _config.isOverridable;
  401. serviceConfigProperty = App.ServiceConfigProperty.create(_config);
  402. this.updateHostOverrides(serviceConfigProperty, _config);
  403. serviceConfigProperty.initialValue(localDB);
  404. this.tweakDynamicDefaults(localDB, serviceConfigProperty, _config);
  405. serviceConfigProperty.validate();
  406. configsByService.pushObject(serviceConfigProperty);
  407. }, this);
  408. serviceConfig = this.createServiceConfig(service.serviceName);
  409. serviceConfig.set('showConfig', service.showConfig);
  410. serviceConfig.set('configs', configsByService);
  411. renderedServiceConfigs.push(serviceConfig);
  412. }, this);
  413. return renderedServiceConfigs;
  414. },
  415. /**
  416. Takes care of the "dynamic defaults" for the HCFS configs. Sets
  417. some of the config defaults to previously user-entered data.
  418. **/
  419. tweakDynamicDefaults: function (localDB, serviceConfigProperty, config) {
  420. console.log("Step7: Tweaking Dynamic defaults");
  421. var firstHost = null;
  422. for(var host in localDB.hosts) {
  423. firstHost = host;
  424. break;
  425. }
  426. try {
  427. if (typeof(config == "string") && config.defaultValue.indexOf("{firstHost}") >= 0) {
  428. serviceConfigProperty.set('value', serviceConfigProperty.value.replace(new RegExp("{firstHost}"), firstHost));
  429. serviceConfigProperty.set('defaultValue', serviceConfigProperty.defaultValue.replace(new RegExp("{firstHost}"), firstHost));
  430. }
  431. } catch (err) {
  432. // Nothing to worry about here, most likely trying indexOf on a non-string
  433. }
  434. },
  435. /**
  436. * create new child configs from overrides, attach them to parent config
  437. * override - value of config, related to particular host(s)
  438. * @param configProperty
  439. * @param storedConfigProperty
  440. */
  441. updateHostOverrides: function (configProperty, storedConfigProperty) {
  442. if (storedConfigProperty.overrides != null && storedConfigProperty.overrides.length > 0) {
  443. var overrides = [];
  444. storedConfigProperty.overrides.forEach(function (overrideEntry) {
  445. // create new override with new value
  446. var newSCP = App.ServiceConfigProperty.create(configProperty);
  447. newSCP.set('value', overrideEntry.value);
  448. newSCP.set('isOriginalSCP', false); // indicated this is overridden value,
  449. newSCP.set('parentSCP', configProperty);
  450. var hostsArray = Ember.A([]);
  451. overrideEntry.hosts.forEach(function (host) {
  452. hostsArray.push(host);
  453. });
  454. newSCP.set('selectedHostOptions', hostsArray);
  455. overrides.pushObject(newSCP);
  456. });
  457. configProperty.set('overrides', overrides);
  458. }
  459. },
  460. /**
  461. * create new ServiceConfig object by service name
  462. * @param serviceName
  463. */
  464. createServiceConfig: function (serviceName) {
  465. var preDefinedServiceConfig = App.config.get('preDefinedServiceConfigs').findProperty('serviceName', serviceName);
  466. var serviceConfig = App.ServiceConfig.create({
  467. filename: preDefinedServiceConfig.filename,
  468. serviceName: preDefinedServiceConfig.serviceName,
  469. displayName: preDefinedServiceConfig.displayName,
  470. configCategories: preDefinedServiceConfig.configCategories,
  471. configs: []
  472. });
  473. serviceConfig.configCategories.filterProperty('isCustomView', true).forEach(function (category) {
  474. switch (category.name) {
  475. case 'CapacityScheduler':
  476. category.set('customView', App.ServiceConfigCapacityScheduler);
  477. break;
  478. }
  479. }, this);
  480. return serviceConfig;
  481. },
  482. /**
  483. * GETs all cluster level sites in one call.
  484. *
  485. * @return Array of all site configs
  486. */
  487. loadConfigsByTags: function (tags) {
  488. var urlParams = [];
  489. tags.forEach(function (_tag) {
  490. urlParams.push('(type=' + _tag.siteName + '&tag=' + _tag.tagName + ')');
  491. });
  492. var params = urlParams.join('|');
  493. App.ajax.send({
  494. name: 'config.on_site',
  495. sender: this,
  496. data: {
  497. params: params
  498. },
  499. success: 'loadConfigsByTagsSuccess'
  500. });
  501. return configGroupsByTag;
  502. },
  503. loadConfigsByTagsSuccess: function (data) {
  504. if (data.items) {
  505. configGroupsByTag = [];
  506. data.items.forEach(function (item) {
  507. this.loadedConfigurationsCache[item.type + "_" + item.tag] = item.properties;
  508. configGroupsByTag.push(item);
  509. }, this);
  510. }
  511. },
  512. /**
  513. * Generate serviceProperties save it to localDB
  514. * called form stepController step6WizardController
  515. *
  516. * @param serviceName
  517. * @return {*}
  518. */
  519. loadAdvancedConfig: function (serviceName) {
  520. App.ajax.send({
  521. name: 'config.advanced',
  522. sender: this,
  523. data: {
  524. serviceName: serviceName,
  525. stack2VersionUrl: App.get('stack2VersionURL'),
  526. stackVersion: App.get('currentStackVersionNumber')
  527. },
  528. success: 'loadAdvancedConfigSuccess'
  529. });
  530. return serviceComponents[serviceName];
  531. //TODO clean serviceComponents
  532. },
  533. loadAdvancedConfigSuccess: function (data, opt, params) {
  534. console.log("TRACE: In success function for the loadAdvancedConfig; url is ", opt.url);
  535. var properties = [];
  536. if (data.items.length) {
  537. data.items.forEach(function (item) {
  538. item = item.StackConfigurations;
  539. item.isVisible = item.type !== 'global.xml';
  540. properties.push({
  541. serviceName: item.service_name,
  542. name: item.property_name,
  543. value: item.property_value,
  544. description: item.property_description,
  545. isVisible: item.isVisible,
  546. filename: item.filename || item.type
  547. });
  548. }, this);
  549. serviceComponents[data.items[0].StackConfigurations.service_name] = properties;
  550. }
  551. },
  552. /**
  553. * Determine the map which shows which services
  554. * each global property effects.
  555. *
  556. * @return {*}
  557. * Example:
  558. * {
  559. * 'hive_pid_dir': ['HIVE'],
  560. * ...
  561. * }
  562. */
  563. loadGlobalPropertyToServicesMap: function () {
  564. if (globalPropertyToServicesMap == null) {
  565. App.ajax.send({
  566. name: 'config.advanced.global',
  567. sender: this,
  568. data: {
  569. stack2VersionUrl: App.get('stack2VersionURL')
  570. },
  571. success: 'loadGlobalPropertyToServicesMapSuccess'
  572. });
  573. }
  574. return globalPropertyToServicesMap;
  575. },
  576. loadGlobalPropertyToServicesMapSuccess: function (data) {
  577. globalPropertyToServicesMap = {};
  578. if(data.items!=null){
  579. data.items.forEach(function(service){
  580. service.configurations.forEach(function(config){
  581. if("global.xml" === config.StackConfigurations.type){
  582. if(!(config.StackConfigurations.property_name in globalPropertyToServicesMap)){
  583. globalPropertyToServicesMap[config.StackConfigurations.property_name] = [];
  584. }
  585. globalPropertyToServicesMap[config.StackConfigurations.property_name].push(service.StackServices.service_name);
  586. }
  587. });
  588. });
  589. }
  590. },
  591. /**
  592. * When global configuration changes, not all services are effected
  593. * by all properties. This method determines if a given service
  594. * is effected by the difference in desired and actual configs.
  595. *
  596. * This method might make a call to server to determine the actual
  597. * key/value pairs involved.
  598. */
  599. isServiceEffectedByGlobalChange: function (service, desiredTag, actualTag) {
  600. var effected = false;
  601. if (service != null && desiredTag != null && actualTag != null) {
  602. if(this.differentGlobalTagsCache.indexOf(service+"/"+desiredTag+"/"+actualTag) < 0){
  603. this.loadGlobalPropertyToServicesMap();
  604. var desiredConfigs = this.loadedConfigurationsCache['global_' + desiredTag];
  605. var actualConfigs = this.loadedConfigurationsCache['global_' + actualTag];
  606. var requestTags = [];
  607. if (!desiredConfigs) {
  608. requestTags.push({
  609. siteName: 'global',
  610. tagName: desiredTag
  611. });
  612. }
  613. if (!actualConfigs) {
  614. requestTags.push({
  615. siteName: 'global',
  616. tagName: actualTag
  617. });
  618. }
  619. if (requestTags.length > 0) {
  620. this.loadConfigsByTags(requestTags);
  621. desiredConfigs = this.loadedConfigurationsCache['global_' + desiredTag];
  622. actualConfigs = this.loadedConfigurationsCache['global_' + actualTag];
  623. }
  624. if (desiredConfigs != null && actualConfigs != null) {
  625. for ( var property in desiredConfigs) {
  626. if (!effected) {
  627. var dpv = desiredConfigs[property];
  628. var apv = actualConfigs[property];
  629. if (dpv !== apv && globalPropertyToServicesMap[property] != null) {
  630. effected = globalPropertyToServicesMap[property].indexOf(service) > -1;
  631. if(effected){
  632. this.differentGlobalTagsCache.push(service+"/"+desiredTag+"/"+actualTag);
  633. }
  634. }
  635. }
  636. }
  637. }
  638. }else{
  639. effected = true; // We already know they are different
  640. }
  641. }
  642. return effected;
  643. },
  644. /**
  645. * Hosts can override service configurations per property. This method GETs
  646. * the overriden configurations and sets only the changed properties into
  647. * the 'overrides' of serviceConfig.
  648. *
  649. *
  650. */
  651. loadServiceConfigHostsOverrides: function (serviceConfigs, loadedHostToOverrideSiteToTagMap) {
  652. var configKeyToConfigMap = {};
  653. serviceConfigs.forEach(function (item) {
  654. configKeyToConfigMap[item.name] = item;
  655. });
  656. var typeTagToHostMap = {};
  657. var urlParams = [];
  658. for (var hostname in loadedHostToOverrideSiteToTagMap) {
  659. var overrideTypeTags = loadedHostToOverrideSiteToTagMap[hostname];
  660. for (var type in overrideTypeTags) {
  661. var tag = overrideTypeTags[type];
  662. typeTagToHostMap[type + "///" + tag] = hostname;
  663. urlParams.push('(type=' + type + '&tag=' + tag + ')');
  664. }
  665. }
  666. var params = urlParams.join('|');
  667. if (urlParams.length) {
  668. App.ajax.send({
  669. name: 'config.host_overrides',
  670. sender: this,
  671. data: {
  672. params: params,
  673. configKeyToConfigMap: configKeyToConfigMap,
  674. typeTagToHostMap: typeTagToHostMap
  675. },
  676. success: 'loadServiceConfigHostsOverridesSuccess'
  677. });
  678. }
  679. },
  680. loadServiceConfigHostsOverridesSuccess: function (data, opt, params) {
  681. console.debug("loadServiceConfigHostsOverrides: Data=", data);
  682. data.items.forEach(function (config) {
  683. App.config.loadedConfigurationsCache[config.type + "_" + config.tag] = config.properties;
  684. var hostname = params.typeTagToHostMap[config.type + "///" + config.tag];
  685. var properties = config.properties;
  686. for (var prop in properties) {
  687. var serviceConfig = params.configKeyToConfigMap[prop];
  688. var hostOverrideValue = properties[prop];
  689. if (serviceConfig && serviceConfig.displayType === 'int') {
  690. if (/\d+m$/.test(hostOverrideValue)) {
  691. hostOverrideValue = hostOverrideValue.slice(0, hostOverrideValue.length - 1);
  692. }
  693. } else if (serviceConfig && serviceConfig.displayType === 'checkbox') {
  694. switch (hostOverrideValue) {
  695. case 'true':
  696. hostOverrideValue = true;
  697. break;
  698. case 'false':
  699. hostOverrideValue = false;
  700. break;
  701. }
  702. }
  703. if (serviceConfig) {
  704. // Value of this property is different for this host.
  705. var overrides = 'overrides';
  706. if (!(overrides in serviceConfig)) {
  707. serviceConfig.overrides = {};
  708. }
  709. if (!(hostOverrideValue in serviceConfig.overrides)) {
  710. serviceConfig.overrides[hostOverrideValue] = [];
  711. }
  712. console.log("loadServiceConfigHostsOverrides(): [" + hostname + "] OVERRODE(" + serviceConfig.name + "): " + serviceConfig.value + " -> " + hostOverrideValue);
  713. serviceConfig.overrides[hostOverrideValue].push(hostname);
  714. }
  715. }
  716. });
  717. console.log("loadServiceConfigHostsOverrides(): Finished loading.");
  718. },
  719. /**
  720. * Set all site property that are derived from other site-properties
  721. */
  722. setConfigValue: function (mappedConfigs, allConfigs, config, globalConfigs) {
  723. var globalValue;
  724. if (config.value == null) {
  725. return;
  726. }
  727. var fkValue = config.value.match(/<(foreignKey.*?)>/g);
  728. var fkName = config.name.match(/<(foreignKey.*?)>/g);
  729. var templateValue = config.value.match(/<(templateName.*?)>/g);
  730. if (fkValue) {
  731. fkValue.forEach(function (_fkValue) {
  732. var index = parseInt(_fkValue.match(/\[([\d]*)(?=\])/)[1]);
  733. if (mappedConfigs.someProperty('name', config.foreignKey[index])) {
  734. globalValue = mappedConfigs.findProperty('name', config.foreignKey[index]).value;
  735. config.value = config.value.replace(_fkValue, globalValue);
  736. } else if (allConfigs.someProperty('name', config.foreignKey[index])) {
  737. if (allConfigs.findProperty('name', config.foreignKey[index]).value === '') {
  738. globalValue = allConfigs.findProperty('name', config.foreignKey[index]).defaultValue;
  739. } else {
  740. globalValue = allConfigs.findProperty('name', config.foreignKey[index]).value;
  741. }
  742. config.value = config.value.replace(_fkValue, globalValue);
  743. }
  744. }, this);
  745. }
  746. // config._name - formatted name from original config name
  747. if (fkName) {
  748. fkName.forEach(function (_fkName) {
  749. var index = parseInt(_fkName.match(/\[([\d]*)(?=\])/)[1]);
  750. if (mappedConfigs.someProperty('name', config.foreignKey[index])) {
  751. globalValue = mappedConfigs.findProperty('name', config.foreignKey[index]).value;
  752. config._name = config.name.replace(_fkName, globalValue);
  753. } else if (allConfigs.someProperty('name', config.foreignKey[index])) {
  754. if (allConfigs.findProperty('name', config.foreignKey[index]).value === '') {
  755. globalValue = allConfigs.findProperty('name', config.foreignKey[index]).defaultValue;
  756. } else {
  757. globalValue = allConfigs.findProperty('name', config.foreignKey[index]).value;
  758. }
  759. config._name = config.name.replace(_fkName, globalValue);
  760. }
  761. }, this);
  762. }
  763. //For properties in the configMapping file having foreignKey and templateName properties.
  764. if (templateValue) {
  765. templateValue.forEach(function (_value) {
  766. var index = parseInt(_value.match(/\[([\d]*)(?=\])/)[1]);
  767. if (globalConfigs.someProperty('name', config.templateName[index])) {
  768. var globalValue = globalConfigs.findProperty('name', config.templateName[index]).value;
  769. config.value = config.value.replace(_value, globalValue);
  770. } else {
  771. config.value = null;
  772. }
  773. }, this);
  774. }
  775. }
  776. });