step7_controller.js 30 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786
  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 numberUtils = require('utils/number_utils');
  20. /**
  21. * By Step 7, we have the following information stored in App.db and set on this
  22. * controller by the router.
  23. *
  24. * selectedServices: App.db.selectedServices (the services that the user selected in Step 4)
  25. * masterComponentHosts: App.db.masterComponentHosts (master-components-to-hosts mapping the user selected in Step 5)
  26. * slaveComponentHosts: App.db.slaveComponentHosts (slave-components-to-hosts mapping the user selected in Step 6)
  27. *
  28. */
  29. App.WizardStep7Controller = Em.Controller.extend({
  30. name: 'wizardStep7Controller',
  31. stepConfigs: [], //contains all field properties that are viewed in this step
  32. selectedService: null,
  33. slaveHostToGroup: null,
  34. secureConfigs: require('data/secure_mapping'),
  35. miscModalVisible: false, //If miscConfigChange Modal is shown
  36. gangliaAvailableSpace: null,
  37. gangliaMoutDir:'/',
  38. overrideToAdd: null,
  39. isInstaller: true,
  40. configGroups: [],
  41. groupsToDelete: [],
  42. selectedConfigGroup: null,
  43. /**
  44. * config tags of actually installed services
  45. */
  46. serviceConfigTags: [],
  47. serviceConfigsData: require('data/service_configs'),
  48. isSubmitDisabled: function () {
  49. return (!this.stepConfigs.filterProperty('showConfig', true).everyProperty('errorCount', 0) || this.get("miscModalVisible"));
  50. }.property('stepConfigs.@each.errorCount', 'miscModalVisible'),
  51. selectedServiceNames: function () {
  52. return this.get('content.services').filterProperty('isSelected', true).filterProperty('isInstalled', false).mapProperty('serviceName');
  53. }.property('content.services').cacheable(),
  54. allSelectedServiceNames: function () {
  55. return this.get('content.services').filterProperty('isSelected').mapProperty('serviceName');
  56. }.property('content.services').cacheable(),
  57. installedServiceNames: function () {
  58. return this.get('content.services').filterProperty('isInstalled').mapProperty('serviceName');
  59. }.property('content.services').cacheable(),
  60. masterComponentHosts: function () {
  61. return this.get('content.masterComponentHosts');
  62. }.property('content.masterComponentHosts'),
  63. slaveComponentHosts: function () {
  64. return this.get('content.slaveGroupProperties');
  65. }.property('content.slaveGroupProperties', 'content.slaveComponentHosts'),
  66. customData: [],
  67. clearStep: function () {
  68. this.get('serviceConfigTags').clear();
  69. this.get('stepConfigs').clear();
  70. this.set('filter', '');
  71. this.get('filterColumns').setEach('selected', false);
  72. },
  73. /**
  74. * Load config groups for installed services
  75. */
  76. loadInstalledServicesConfigGroups: function (servicesNames) {
  77. if (servicesNames.indexOf('MISC') > -1)
  78. servicesNames.splice(servicesNames.indexOf('MISC'), 1);
  79. servicesNames.forEach(function(serviceName) {
  80. App.ajax.send({
  81. name: 'config.tags_and_groups',
  82. sender: this,
  83. data: {
  84. serviceName: serviceName,
  85. serviceConfigsDef: App.config.get('preDefinedServiceConfigs').findProperty('serviceName', serviceName)
  86. },
  87. success: 'loadServiceTagsSuccess'
  88. });
  89. }, this);
  90. },
  91. /**
  92. * Load config groups success callback
  93. */
  94. loadServiceTagsSuccess: function (data, opt, params) {
  95. var serviceConfigsDef = params.serviceConfigsDef;
  96. var serviceName = params.serviceName;
  97. var service = this.get('stepConfigs').findProperty('serviceName', serviceName);
  98. // Create default configuration group
  99. var defaultConfigGroupHosts = App.Host.find().mapProperty('hostName');
  100. var selectedConfigGroup;
  101. var siteToTagMap = {};
  102. for (var site in data.Clusters.desired_configs) {
  103. if (serviceConfigsDef.sites.indexOf(site) > -1) {
  104. siteToTagMap[site] = data.Clusters.desired_configs[site].tag;
  105. }
  106. }
  107. this.loadedClusterSiteToTagMap = siteToTagMap;
  108. //parse loaded config groups
  109. if (App.supports.hostOverrides) {
  110. var configGroups = [];
  111. if (data.config_groups.length) {
  112. data.config_groups.forEach(function (item) {
  113. item = item.ConfigGroup;
  114. if (item.tag === serviceName) {
  115. var groupHosts = item.hosts.mapProperty('host_name');
  116. var newConfigGroup = App.ConfigGroup.create({
  117. id: item.id,
  118. name: item.group_name,
  119. description: item.description,
  120. isDefault: false,
  121. parentConfigGroup: null,
  122. service: App.Service.find().findProperty('serviceName', item.tag),
  123. hosts: groupHosts,
  124. configSiteTags: []
  125. });
  126. groupHosts.forEach(function (host) {
  127. defaultConfigGroupHosts = defaultConfigGroupHosts.without(host);
  128. }, this);
  129. item.desired_configs.forEach(function (config) {
  130. newConfigGroup.configSiteTags.push(App.ConfigSiteTag.create({
  131. site: config.type,
  132. tag: config.tag
  133. }));
  134. }, this);
  135. configGroups.push(newConfigGroup);
  136. }
  137. }, this);
  138. }
  139. }
  140. var defaultConfigGroup = App.ConfigGroup.create({
  141. name: App.Service.DisplayNames[serviceName] + " Default",
  142. description: "Default cluster level " + serviceName + " configuration",
  143. isDefault: true,
  144. hosts: defaultConfigGroupHosts,
  145. parentConfigGroup: null,
  146. service: Em.Object.create({
  147. id: serviceName
  148. }),
  149. serviceName: serviceName,
  150. configSiteTags: []
  151. });
  152. if (!selectedConfigGroup) {
  153. selectedConfigGroup = defaultConfigGroup;
  154. }
  155. configGroups.sort(function(configGroupA, configGroupB){
  156. return (configGroupA.name > configGroupB.name);
  157. });
  158. configGroups.unshift(defaultConfigGroup);
  159. if (App.supports.hostOverrides) {
  160. service.set('configGroups', configGroups);
  161. var loadedGroupToOverrideSiteToTagMap = {};
  162. if (App.supports.hostOverrides) {
  163. var configGroupsWithOverrides = selectedConfigGroup.get('isDefault') ? service.get('configGroups') : [selectedConfigGroup];
  164. configGroupsWithOverrides.forEach(function (item) {
  165. var groupName = item.get('name');
  166. loadedGroupToOverrideSiteToTagMap[groupName] = {};
  167. item.get('configSiteTags').forEach(function (siteTag) {
  168. var site = siteTag.get('site');
  169. loadedGroupToOverrideSiteToTagMap[groupName][site] = siteTag.get('tag');
  170. }, this);
  171. }, this);
  172. }
  173. App.config.loadServiceConfigHostsOverrides(service.get('configs'), loadedGroupToOverrideSiteToTagMap, service.get('configGroups'));
  174. var serviceConfig = App.config.createServiceConfig(serviceName);
  175. if (serviceConfig.get('serviceName') === 'HDFS') {
  176. App.config.OnNnHAHideSnn(serviceConfig);
  177. }
  178. service.set('selectedConfigGroup', selectedConfigGroup);
  179. this.loadComponentConfigs(service.get('configs'), serviceConfig, service);
  180. }
  181. service.set('configs', serviceConfig.get('configs'));
  182. },
  183. loadComponentConfigs: function (configs, componentConfig, component) {
  184. var localDB = App.router.get('mainServiceInfoConfigsController').getInfoForDefaults();
  185. var recommendedDefaults = {};
  186. var s = this.get('serviceConfigsData').findProperty('serviceName', component.get('serviceName'));
  187. var defaultGroupSelected = component.get('selectedConfigGroup.isDefault');
  188. var defaults = [];
  189. if (s.defaultsProviders) {
  190. s.defaultsProviders.forEach(function(defaultsProvider) {
  191. var d = defaultsProvider.getDefaults(localDB);
  192. defaults.push(d);
  193. for (var name in d) {
  194. recommendedDefaults[name] = d[name];
  195. }
  196. });
  197. }
  198. if (s.configsValidator) {
  199. s.configsValidator.set('recommendedDefaults', recommendedDefaults);
  200. }
  201. configs.forEach(function (serviceConfigProperty) {
  202. console.log("config", serviceConfigProperty);
  203. if (!serviceConfigProperty) return;
  204. var overrides = serviceConfigProperty.get('overrides');
  205. // we will populate the override properties below
  206. serviceConfigProperty.set('overrides', null);
  207. if (serviceConfigProperty.isOverridable === undefined) {
  208. serviceConfigProperty.set('isOverridable', true);
  209. }
  210. if (serviceConfigProperty.displayType === 'checkbox') {
  211. switch (serviceConfigProperty.value) {
  212. case 'true':
  213. serviceConfigProperty.set('value', true);
  214. serviceConfigProperty.set('defaultValue', true);
  215. break;
  216. case 'false':
  217. serviceConfigProperty.set('value', false);
  218. serviceConfigProperty.set('defaultValue', false);
  219. break;
  220. }
  221. }
  222. if (serviceConfigProperty.get('serviceName') === component.get('serviceName')) {
  223. if (s.configsValidator) {
  224. var validators = s.configsValidator.get('configValidators');
  225. for (var validatorName in validators) {
  226. if (serviceConfigProperty.name == validatorName) {
  227. serviceConfigProperty.set('serviceValidator', s.configsValidator);
  228. }
  229. }
  230. }
  231. serviceConfigProperty.set('isVisible', true);
  232. console.log("config result", serviceConfigProperty);
  233. } else {
  234. serviceConfigProperty.set('isVisible', false);
  235. }
  236. if (overrides != null) {
  237. overrides.forEach(function (override) {
  238. var newSCP = App.ServiceConfigProperty.create(serviceConfigProperty);
  239. newSCP.set('value', override.value);
  240. newSCP.set('isOriginalSCP', false); // indicated this is overridden value,
  241. newSCP.set('parentSCP', serviceConfigProperty);
  242. if (App.supports.hostOverrides && defaultGroupSelected) {
  243. var group = component.get('configGroups').findProperty('name', override.group.get('name'));
  244. // prevent cycle in proto object, clean link
  245. if (group.get('properties').length == 0)
  246. group.set('properties', Em.A([]));
  247. group.get('properties').push(newSCP);
  248. newSCP.set('group', override.group);
  249. newSCP.set('isEditable', false);
  250. }
  251. var parentOverridesArray = serviceConfigProperty.get('overrides');
  252. if (parentOverridesArray == null) {
  253. parentOverridesArray = Ember.A([]);
  254. serviceConfigProperty.set('overrides', parentOverridesArray);
  255. }
  256. serviceConfigProperty.get('overrides').pushObject(newSCP);
  257. console.debug("createOverrideProperty(): Added:", newSCP, " to main-property:", serviceConfigProperty)
  258. }, this);
  259. } else {
  260. serviceConfigProperty.set('overrides', Ember.A([]));
  261. }
  262. if (App.get('isAdmin')) {
  263. if(defaultGroupSelected && !this.get('isHostsConfigsPage')){
  264. serviceConfigProperty.set('isEditable', serviceConfigProperty.get('isReconfigurable'));
  265. } else {
  266. serviceConfigProperty.set('isEditable', false);
  267. }
  268. } else {
  269. serviceConfigProperty.set('isEditable', false);
  270. }
  271. componentConfig.get('configs').pushObject(serviceConfigProperty);
  272. serviceConfigProperty.validate();
  273. }, this);
  274. var overrideToAdd = this.get('overrideToAdd');
  275. if (overrideToAdd) {
  276. overrideToAdd = componentConfig.configs.findProperty('name', overrideToAdd.name);
  277. if (overrideToAdd) {
  278. this.addOverrideProperty(overrideToAdd);
  279. component.set('overrideToAdd', null);
  280. }
  281. }
  282. },
  283. /**
  284. * Resolve dependency between configs.
  285. * @param serviceName {String}
  286. * @param configs {Mixed}
  287. */
  288. resolveServiceDependencyConfigs: function (serviceName, configs) {
  289. switch (serviceName) {
  290. case 'STORM':
  291. this.resolveStormConfigs(configs);
  292. break;
  293. default:
  294. break;
  295. }
  296. },
  297. resolveStormConfigs: function(configs) {
  298. var dependentConfigs, gangliaServerHost;
  299. dependentConfigs = ['nimbus.childopts', 'supervisor.childopts', 'worker.childopts'];
  300. // if Ganglia selected or installed, set ganglia host to configs
  301. if (this.get('installedServiceNames').contains('STORM') && this.get('installedServiceNames').contains('GANGLIA')) return;
  302. if (this.get('allSelectedServiceNames').contains('GANGLIA') || this.get('installedServiceNames').contains('GANGLIA')) {
  303. gangliaServerHost = this.get('wizardController').getDBProperty('masterComponentHosts').findProperty('component', 'GANGLIA_SERVER').hostName;
  304. dependentConfigs.forEach(function(configName){
  305. var config = configs.findProperty('name', configName);
  306. config.value = config.defaultValue.format(gangliaServerHost);
  307. }, this);
  308. } else {
  309. // if Ganglia not selected remove config
  310. dependentConfigs.forEach(function(configName){
  311. configs.removeAt(configs.indexOf(configs.findProperty('name', configName)));
  312. }, this);
  313. }
  314. },
  315. /**
  316. * On load function
  317. */
  318. loadStep: function () {
  319. console.log("TRACE: Loading step7: Configure Services");
  320. this.clearStep();
  321. //STEP 1: Load advanced configs
  322. var advancedConfigs = this.get('content.advancedServiceConfig');
  323. //STEP 2: Load on-site configs by service from local DB
  324. var storedConfigs = this.get('content.serviceConfigProperties');
  325. //STEP 3: Merge pre-defined configs with loaded on-site configs
  326. var configs = App.config.mergePreDefinedWithStored(storedConfigs, advancedConfigs);
  327. //STEP 4: Add advanced configs
  328. App.config.addAdvancedConfigs(configs, advancedConfigs);
  329. //STEP 5: Add custom configs
  330. App.config.addCustomConfigs(configs);
  331. //put properties from capacity-scheduler.xml into one config with textarea view
  332. if (this.get('allSelectedServiceNames').contains('YARN') && !App.supports.capacitySchedulerUi) {
  333. configs = App.config.fileConfigsIntoTextarea(configs, 'capacity-scheduler.xml');
  334. }
  335. this.set('groupsToDelete', this.get('wizardController').getDBProperty('groupsToDelete') || []);
  336. var localDB = {
  337. hosts: this.get('wizardController').getDBProperty('hosts'),
  338. masterComponentHosts: this.get('wizardController').getDBProperty('masterComponentHosts'),
  339. slaveComponentHosts: this.get('wizardController').getDBProperty('slaveComponentHosts')
  340. };
  341. if (this.get('wizardController.name') === 'addServiceController') {
  342. this.getConfigTags();
  343. this.setInstalledServiceConfigs(this.get('serviceConfigTags'), configs);
  344. }
  345. if (this.get('allSelectedServiceNames').contains('STORM') || this.get('installedServiceNames').contains('STORM')) {
  346. this.resolveServiceDependencyConfigs('STORM', configs);
  347. }
  348. //STEP 6: Distribute configs by service and wrap each one in App.ServiceConfigProperty (configs -> serviceConfigs)
  349. var serviceConfigs = App.config.renderConfigs(configs, storedConfigs, this.get('allSelectedServiceNames'), this.get('installedServiceNames'), localDB);
  350. if (this.get('wizardController.name') === 'addServiceController') {
  351. serviceConfigs.setEach('showConfig', true);
  352. serviceConfigs.setEach('selected', false);
  353. this.get('selectedServiceNames').forEach(function(serviceName) {
  354. if(!serviceConfigs.findProperty('serviceName', serviceName)) return;
  355. serviceConfigs.findProperty('serviceName', serviceName).set('selected', true);
  356. });
  357. // Remove SNameNode if HA is enabled
  358. if (App.get('isHaEnabled')) {
  359. configs = serviceConfigs.findProperty('serviceName', 'HDFS').configs;
  360. var removedConfigs = configs.filterProperty('category', 'SNameNode');
  361. removedConfigs.map(function(config) {
  362. configs = configs.without(config);
  363. });
  364. serviceConfigs.findProperty('serviceName', 'HDFS').configs = configs;
  365. }
  366. }
  367. this.set('stepConfigs', serviceConfigs);
  368. if (App.supports.hostOverridesInstaller) {
  369. this.loadConfigGroups(this.get('content.configGroups'));
  370. var installedServicesConfigs = this.get('stepConfigs').filterProperty('selected', false);
  371. if (installedServicesConfigs.length > 0 && !storedConfigs)
  372. this.loadInstalledServicesConfigGroups(installedServicesConfigs.mapProperty('serviceName'));
  373. }
  374. this.activateSpecialConfigs();
  375. this.set('selectedService', this.get('stepConfigs').filterProperty('showConfig', true).objectAt(0));
  376. if (this.get('content.skipConfigStep')) {
  377. App.router.send('next');
  378. }
  379. },
  380. getConfigTags: function() {
  381. App.ajax.send({
  382. name: 'config.tags.sync',
  383. sender: this,
  384. success: 'getConfigTagsSuccess'
  385. });
  386. },
  387. getConfigTagsSuccess: function (data, opt, params) {
  388. var installedServiceSites = [];
  389. this.get('serviceConfigsData').filter(function (service) {
  390. if (this.get('installedServiceNames').contains(service.serviceName)){
  391. installedServiceSites = installedServiceSites.concat(service.sites);
  392. }
  393. }, this);
  394. installedServiceSites = installedServiceSites.uniq();
  395. var serviceConfigTags = [];
  396. for (var site in data.Clusters.desired_configs) {
  397. if (installedServiceSites.contains(site)) {
  398. serviceConfigTags.push({
  399. siteName: site,
  400. tagName: data.Clusters.desired_configs[site].tag,
  401. newTagName: null
  402. });
  403. }
  404. }
  405. this.set('serviceConfigTags', serviceConfigTags);
  406. },
  407. /**
  408. * set configs actual values from server
  409. * @param serviceConfigTags
  410. * @param configs
  411. */
  412. setInstalledServiceConfigs: function (serviceConfigTags, configs) {
  413. var configsMap = {};
  414. App.router.get('configurationController').getConfigsByTags(serviceConfigTags).forEach(function(configSite){
  415. $.extend(configsMap, configSite.properties);
  416. });
  417. configs.forEach(function (_config) {
  418. if (configsMap[_config.name] !== undefined) {
  419. _config.value = configsMap[_config.name];
  420. _config.defaultValue = configsMap[_config.name];
  421. App.config.handleSpecialProperties(_config);
  422. }
  423. })
  424. },
  425. setGroupsToDelete: function(groups) {
  426. var groupsToDelete = this.get('groupsToDelete');
  427. groups.forEach(function(group) {
  428. if (group.get('id'))
  429. groupsToDelete.push({
  430. id: group.get('id')
  431. });
  432. });
  433. this.get('wizardController').setDBProperty('groupsToDelete', groupsToDelete);
  434. },
  435. selectedServiceObserver: function () {
  436. if (App.supports.hostOverridesInstaller && this.get('selectedService') && (this.get('selectedService.serviceName') !== 'MISC')) {
  437. var serviceGroups = this.get('selectedService.configGroups');
  438. serviceGroups.forEach(function (item, index, array) {
  439. if (item.isDefault) {
  440. array.unshift(item);
  441. array.splice(index + 1, 1);
  442. }
  443. });
  444. this.set('configGroups', serviceGroups);
  445. this.set('selectedConfigGroup', serviceGroups.findProperty('isDefault'));
  446. }
  447. }.observes('selectedService.configGroups.@each'),
  448. /**
  449. * load default groups for each service in case of initial load
  450. * @param serviceConfigGroups
  451. */
  452. loadConfigGroups: function (serviceConfigGroups) {
  453. var services = this.get('stepConfigs');
  454. var hosts = this.get('getAllHosts').mapProperty('hostName');
  455. services.forEach(function (service) {
  456. if (service.get('serviceName') === 'MISC') return;
  457. var serviceRawGroups = serviceConfigGroups.filterProperty('service.id', service.serviceName);
  458. if (!serviceRawGroups.length) {
  459. service.set('configGroups', [
  460. App.ConfigGroup.create({
  461. name: App.Service.DisplayNames[service.serviceName] + " Default",
  462. description: "Default cluster level " + service.serviceName + " configuration",
  463. isDefault: true,
  464. hosts: Em.copy(hosts),
  465. service: Em.Object.create({
  466. id: service.serviceName
  467. }),
  468. serviceName: service.serviceName
  469. })
  470. ]);
  471. } else {
  472. var defaultGroup = App.ConfigGroup.create(serviceRawGroups.findProperty('isDefault'));
  473. var serviceGroups = service.get('configGroups');
  474. serviceRawGroups.filterProperty('isDefault', false).forEach(function (configGroup) {
  475. var readyGroup = App.ConfigGroup.create(configGroup);
  476. var wrappedProperties = [];
  477. readyGroup.get('properties').forEach(function(property){
  478. wrappedProperties.pushObject(App.ServiceConfigProperty.create(property));
  479. });
  480. wrappedProperties.setEach('group', readyGroup);
  481. readyGroup.set('properties', wrappedProperties);
  482. readyGroup.set('parentConfigGroup', defaultGroup);
  483. serviceGroups.pushObject(readyGroup);
  484. });
  485. defaultGroup.set('childConfigGroups', serviceGroups);
  486. serviceGroups.pushObject(defaultGroup);
  487. }
  488. });
  489. },
  490. selectConfigGroup: function (event) {
  491. this.set('selectedConfigGroup', event.context);
  492. },
  493. /**
  494. * rebuild list of configs switch of config group:
  495. * on default - display all configs from default group and configs from non-default groups as disabled
  496. * on non-default - display all from default group as disabled and configs from selected non-default group
  497. */
  498. switchConfigGroupConfigs: function () {
  499. var serviceConfigs = this.get('selectedService.configs');
  500. var selectedGroup = this.get('selectedConfigGroup');
  501. var overrideToAdd = this.get('overrideToAdd');
  502. var isServiceInstalled = this.get('installedServiceNames').contains(this.get('selectedService.serviceName'));
  503. if(!selectedGroup) return;
  504. var displayedConfigGroups = (selectedGroup.get('isDefault')) ?
  505. this.get('selectedService.configGroups').filterProperty('isDefault', false) :
  506. [this.get('selectedConfigGroup')];
  507. var overrides = [];
  508. displayedConfigGroups.forEach(function (group) {
  509. overrides.pushObjects(group.get('properties'));
  510. });
  511. serviceConfigs.forEach(function (config) {
  512. var configOverrides = overrides.filterProperty('name', config.get('name'));
  513. var isEditable = config.get('isEditable');
  514. if (isServiceInstalled) {
  515. isEditable = (!isEditable && !config.get('isReconfigurable')) ? false : selectedGroup.get('isDefault');
  516. } else {
  517. isEditable = selectedGroup.get('isDefault');
  518. }
  519. config.set('isEditable', isEditable);
  520. if (overrideToAdd && overrideToAdd.get('name') === config.get('name')) {
  521. configOverrides.push(this.addOverrideProperty(config));
  522. this.set('overrideToAdd', null);
  523. }
  524. configOverrides.setEach('isEditable', !selectedGroup.get('isDefault'));
  525. configOverrides.setEach('parentSCP', config);
  526. config.set('overrides', configOverrides);
  527. }, this);
  528. }.observes('selectedConfigGroup'),
  529. /**
  530. * create overriden property and push it into Config group
  531. * @param serviceConfigProperty
  532. * @return {*}
  533. */
  534. addOverrideProperty: function (serviceConfigProperty) {
  535. var overrides = serviceConfigProperty.get('overrides') || [];
  536. var newSCP = App.ServiceConfigProperty.create(serviceConfigProperty);
  537. var group = this.get('selectedService.configGroups').findProperty('name', this.get('selectedConfigGroup.name'));
  538. newSCP.set('group', group);
  539. newSCP.set('value', '');
  540. newSCP.set('isOriginalSCP', false); // indicated this is overridden value,
  541. newSCP.set('parentSCP', serviceConfigProperty);
  542. newSCP.set('isEditable', true);
  543. group.get('properties').pushObject(newSCP);
  544. overrides.pushObject(newSCP);
  545. return newSCP;
  546. },
  547. manageConfigurationGroup: function () {
  548. App.router.get('mainServiceInfoConfigsController').manageConfigurationGroups(this);
  549. },
  550. /**
  551. * Filter text will be located here
  552. */
  553. filter: '',
  554. /**
  555. * Dropdown menu items in filter combobox
  556. */
  557. filterColumns: function () {
  558. var result = [];
  559. for (var i = 1; i < 2; i++) {
  560. result.push(Ember.Object.create({
  561. name: this.t('common.combobox.dropdown.' + i),
  562. selected: false
  563. }));
  564. }
  565. return result;
  566. }.property(),
  567. /**
  568. * make some configs visible depending on active services
  569. */
  570. activateSpecialConfigs: function () {
  571. var miscConfigs = this.get('stepConfigs').findProperty('serviceName', 'MISC').configs;
  572. miscConfigs = App.config.miscConfigVisibleProperty(miscConfigs, this.get('selectedServiceNames'));
  573. },
  574. /**
  575. * @param {String} siteProperty
  576. * @param {Array} displayNames An array of display names
  577. */
  578. setDisplayMessage: function (siteProperty, displayNames) {
  579. var displayMsg = null;
  580. if (displayNames && displayNames.length) {
  581. if (displayNames.length === 1) {
  582. displayMsg = siteProperty + ' ' + Em.I18n.t('as') + ' ' + displayNames[0];
  583. } else {
  584. var name = null;
  585. displayNames.forEach(function (_name, index) {
  586. if (index === 0) {
  587. name = _name;
  588. } else if (index === displayNames.length - 1) {
  589. name = name + ' ' + Em.I18n.t('and') + ' ' + _name;
  590. } else {
  591. name = name + ', ' + _name;
  592. }
  593. }, this);
  594. displayMsg = siteProperty + ' ' + Em.I18n.t('as') + ' ' + name;
  595. }
  596. } else {
  597. displayMsg = siteProperty;
  598. }
  599. return displayMsg;
  600. },
  601. /**
  602. * Set display names of the property tfrom he puppet/global names
  603. * @param {Array} displayNames a field to be set with displayNames
  604. * @param {Array} names array of property puppet/global names
  605. * @param {Array} configProperties array of config properties of the respective service to the name param
  606. */
  607. setPropertyDisplayNames: function (displayNames, names, configProperties) {
  608. names.forEach(function (_name, index) {
  609. if (configProperties.someProperty('name', _name)) {
  610. displayNames.push(configProperties.findProperty('name', _name).displayName);
  611. }
  612. }, this);
  613. },
  614. /**
  615. * Display Error Message with service name, its custom configuration name and displaynames on the page
  616. * @param {Array} customConfig array with custom configuration, serviceName and displayNames relative to custom configuration
  617. */
  618. showCustomConfigErrMsg: function (customConfig) {
  619. App.ModalPopup.show({
  620. header: Em.I18n.t('installer.step7.ConfigErrMsg.header'),
  621. primary: Em.I18n.t('ok'),
  622. secondary: null,
  623. bodyClass: Ember.View.extend({
  624. message: Em.I18n.t('installer.step7.ConfigErrMsg.message'),
  625. siteProperties: customConfig,
  626. getDisplayMessage: function () {
  627. }.property('customConfig.@each.siteProperties.@each.siteProperty'),
  628. customConfig: customConfig,
  629. templateName: require('templates/wizard/step7_custom_config_error')
  630. })
  631. });
  632. },
  633. submit: function () {
  634. if (!this.get('isSubmitDisabled')) {
  635. App.router.send('next');
  636. }
  637. },
  638. /**
  639. * Provides service component name and display-name information for
  640. * the current selected service.
  641. */
  642. getCurrentServiceComponents: function () {
  643. var selectedServiceName = this.get('selectedService.serviceName');
  644. var masterComponents = this.get('content.masterComponentHosts');
  645. var slaveComponents = this.get('content.slaveComponentHosts');
  646. var scMaps = require('data/service_components');
  647. var validComponents = Ember.A([]);
  648. var seenComponents = {};
  649. masterComponents.forEach(function(component){
  650. var cn = component.component;
  651. var cdn = component.display_name;
  652. if(component.serviceId===selectedServiceName && !seenComponents[cn]){
  653. validComponents.pushObject(Ember.Object.create({
  654. componentName: cn,
  655. displayName: cdn,
  656. selected: false
  657. }));
  658. seenComponents[cn] = cn;
  659. }
  660. });
  661. slaveComponents.forEach(function(component){
  662. var cn = component.componentName;
  663. var cdn = component.displayName;
  664. var componentDef = scMaps.findProperty('component_name', cn);
  665. if(componentDef!=null && selectedServiceName===componentDef.service_name && !seenComponents[cn]){
  666. validComponents.pushObject(Ember.Object.create({
  667. componentName: cn,
  668. displayName: cdn,
  669. selected: false
  670. }));
  671. seenComponents[cn] = cn;
  672. }
  673. });
  674. return validComponents;
  675. }.property('content'),
  676. getAllHosts: function () {
  677. if (App.Host.find().content.length > 0) {
  678. return App.Host.find();
  679. }
  680. var hosts = this.get('content.hosts');
  681. var masterComponents = this.get('content.masterComponentHosts');
  682. var slaveComponents = this.get('content.slaveComponentHosts');
  683. masterComponents.forEach(function (component) {
  684. App.HostComponent.createRecord({
  685. id: component.component + '_' + component.hostName,
  686. componentName: component.component,
  687. host_id: component.hostName
  688. });
  689. if (!hosts[component.hostName].hostComponents) {
  690. hosts[component.hostName].hostComponents = [];
  691. }
  692. hosts[component.hostName].hostComponents.push(component.component + '_' + component.hostName);
  693. });
  694. slaveComponents.forEach(function (component) {
  695. component.hosts.forEach(function (host) {
  696. App.HostComponent.createRecord({
  697. id: component.componentName + '_' + host.hostName,
  698. componentName: component.componentName,
  699. host_id: host.hostName
  700. });
  701. if (!hosts[host.hostName].hostComponents) {
  702. hosts[host.hostName].hostComponents = [];
  703. }
  704. hosts[host.hostName].hostComponents.push(component.componentName + '_' + host.hostName);
  705. });
  706. });
  707. for (var hostName in hosts) {
  708. var host = hosts[hostName];
  709. var disksOverallCapacity = 0;
  710. var diskFree = 0;
  711. host.disk_info.forEach(function(disk) {
  712. disksOverallCapacity += parseFloat(disk.size);
  713. diskFree += parseFloat(disk.available);
  714. });
  715. App.store.load(App.Host,
  716. {
  717. id: host.name,
  718. ip: host.ip,
  719. os_type: host.os_type,
  720. os_arch: host.os_arch,
  721. host_name: host.name,
  722. public_host_name: host.name,
  723. cpu: host.cpu,
  724. memory: host.memory,
  725. disk_info: host.disk_info,
  726. disk_total: disksOverallCapacity / (1024 * 1024),
  727. disk_free: diskFree / (1024 * 1024),
  728. host_components: host.hostComponents
  729. }
  730. )
  731. }
  732. return App.Host.find();
  733. }.property('content.hosts')
  734. });