wizard.js 37 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129
  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. require('models/host');
  20. App.WizardController = Em.Controller.extend(App.LocalStorage, {
  21. isStepDisabled: null,
  22. /**
  23. * map of actions which load data required by which step
  24. * used by <code>loadAllPriorSteps</code>
  25. */
  26. loadMap: {},
  27. /**
  28. * Wizard properties in local storage, which should be cleaned right after wizard has been finished
  29. */
  30. dbPropertiesToClean: [
  31. 'service',
  32. 'hosts',
  33. 'masterComponentHosts',
  34. 'slaveComponentHosts',
  35. 'cluster',
  36. 'allHostNames',
  37. 'installOptions',
  38. 'allHostNamesPattern',
  39. 'serviceComponents'
  40. ],
  41. init: function () {
  42. this.set('isStepDisabled', []);
  43. this.clusters = App.Cluster.find();
  44. this.get('isStepDisabled').pushObject(Ember.Object.create({
  45. step: 1,
  46. value: false
  47. }));
  48. for (var i = 2; i <= this.get('totalSteps'); i++) {
  49. this.get('isStepDisabled').pushObject(Ember.Object.create({
  50. step: i,
  51. value: true
  52. }));
  53. }
  54. },
  55. slaveComponents: function () {
  56. return App.StackServiceComponent.find().filterProperty('isSlave', true);
  57. }.property('App.router.clusterController.isLoaded'),
  58. allHosts: function () {
  59. var dbHosts = this.get('content.hosts');
  60. var hosts = [];
  61. var hostComponents = [];
  62. for (var hostName in dbHosts) {
  63. hostComponents = [];
  64. var disksOverallCapacity = 0;
  65. var diskFree = 0;
  66. dbHosts[hostName].hostComponents.forEach(function (componentName) {
  67. hostComponents.push(Em.Object.create({
  68. componentName: componentName,
  69. displayName: App.format.role(componentName)
  70. }));
  71. });
  72. dbHosts[hostName].disk_info.forEach(function (disk) {
  73. disksOverallCapacity += parseFloat(disk.size);
  74. diskFree += parseFloat(disk.available);
  75. });
  76. hosts.push(Em.Object.create({
  77. id: hostName,
  78. hostName: hostName,
  79. publicHostName: hostName,
  80. diskInfo: dbHosts[hostName].disk_info,
  81. diskTotal: disksOverallCapacity / (1024 * 1024),
  82. diskFree: diskFree / (1024 * 1024),
  83. disksMounted: dbHosts[hostName].disk_info.length,
  84. cpu: dbHosts[hostName].cpu,
  85. memory: dbHosts[hostName].memory,
  86. osType: dbHosts[hostName].osType ? dbHosts[hostName].osType: 0,
  87. osArch: dbHosts[hostName].osArch ? dbHosts[hostName].osArch : 0,
  88. ip: dbHosts[hostName].ip ? dbHosts[hostName].ip: 0,
  89. hostComponents: hostComponents
  90. }))
  91. }
  92. return hosts;
  93. }.property('content.hosts'),
  94. setStepsEnable: function () {
  95. for (var i = 1; i <= this.totalSteps; i++) {
  96. var step = this.get('isStepDisabled').findProperty('step', i);
  97. if (i <= this.get('currentStep')) {
  98. step.set('value', false);
  99. } else {
  100. step.set('value', true);
  101. }
  102. }
  103. }.observes('currentStep'),
  104. setLowerStepsDisable: function (stepNo) {
  105. for (var i = 1; i < stepNo; i++) {
  106. var step = this.get('isStepDisabled').findProperty('step', i);
  107. step.set('value', true);
  108. }
  109. },
  110. /**
  111. * Set current step to new value.
  112. * Method moved from App.router.setInstallerCurrentStep
  113. * @param currentStep
  114. * @param completed
  115. */
  116. currentStep: function () {
  117. return App.get('router').getWizardCurrentStep(this.get('name').substr(0, this.get('name').length - 10));
  118. }.property(),
  119. /**
  120. * Set current step to new value.
  121. * Method moved from App.router.setInstallerCurrentStep
  122. * @param currentStep
  123. * @param completed
  124. */
  125. setCurrentStep: function (currentStep, completed) {
  126. App.db.setWizardCurrentStep(this.get('name').substr(0, this.get('name').length - 10), currentStep, completed);
  127. this.set('currentStep', currentStep);
  128. },
  129. clusters: null,
  130. isStep0: function () {
  131. return this.get('currentStep') == 0;
  132. }.property('currentStep'),
  133. isStep1: function () {
  134. return this.get('currentStep') == 1;
  135. }.property('currentStep'),
  136. isStep2: function () {
  137. return this.get('currentStep') == 2;
  138. }.property('currentStep'),
  139. isStep3: function () {
  140. return this.get('currentStep') == 3;
  141. }.property('currentStep'),
  142. isStep4: function () {
  143. return this.get('currentStep') == 4;
  144. }.property('currentStep'),
  145. isStep5: function () {
  146. return this.get('currentStep') == 5;
  147. }.property('currentStep'),
  148. isStep6: function () {
  149. return this.get('currentStep') == 6;
  150. }.property('currentStep'),
  151. isStep7: function () {
  152. return this.get('currentStep') == 7;
  153. }.property('currentStep'),
  154. isStep8: function () {
  155. return this.get('currentStep') == 8;
  156. }.property('currentStep'),
  157. isStep9: function () {
  158. return this.get('currentStep') == 9;
  159. }.property('currentStep'),
  160. isStep10: function () {
  161. return this.get('currentStep') == 10;
  162. }.property('currentStep'),
  163. gotoStep: function (step, disableNaviWarning) {
  164. if (this.get('isStepDisabled').findProperty('step', step).get('value') !== false) {
  165. return false;
  166. }
  167. // if going back from Step 9 in Install Wizard, delete the checkpoint so that the user is not redirected
  168. // to Step 9
  169. if (this.get('content.controllerName') == 'installerController' && this.get('currentStep') === '9' && step < 9) {
  170. App.clusterStatus.setClusterStatus({
  171. clusterName: this.get('clusterName'),
  172. clusterState: 'CLUSTER_NOT_CREATED_1',
  173. wizardControllerName: 'installerController',
  174. localdb: App.db.data
  175. });
  176. }
  177. if ((this.get('currentStep') - step) > 1 && !disableNaviWarning) {
  178. App.ModalPopup.show({
  179. header: Em.I18n.t('installer.navigation.warning.header'),
  180. onPrimary: function () {
  181. App.router.send('gotoStep' + step);
  182. this.hide();
  183. },
  184. body: "If you proceed to go back to Step " + step + ", you will lose any changes you have made beyond this step"
  185. });
  186. } else {
  187. App.router.send('gotoStep' + step);
  188. }
  189. return true;
  190. },
  191. gotoStep0: function () {
  192. this.gotoStep(0);
  193. },
  194. gotoStep1: function () {
  195. this.gotoStep(1);
  196. },
  197. gotoStep2: function () {
  198. this.gotoStep(2);
  199. },
  200. gotoStep3: function () {
  201. this.gotoStep(3);
  202. },
  203. gotoStep4: function () {
  204. this.gotoStep(4);
  205. },
  206. gotoStep5: function () {
  207. this.gotoStep(5);
  208. },
  209. gotoStep6: function () {
  210. this.gotoStep(6);
  211. },
  212. gotoStep7: function () {
  213. this.gotoStep(7);
  214. },
  215. gotoStep8: function () {
  216. this.gotoStep(8);
  217. },
  218. gotoStep9: function () {
  219. this.gotoStep(9);
  220. },
  221. gotoStep10: function () {
  222. this.gotoStep(10);
  223. },
  224. /**
  225. * Initialize host status info for step9
  226. */
  227. setInfoForStep9: function () {
  228. var hostInfo = this.getDBProperty('hosts');
  229. for (var index in hostInfo) {
  230. hostInfo[index].status = "pending";
  231. hostInfo[index].message = 'Waiting';
  232. hostInfo[index].logTasks = [];
  233. hostInfo[index].tasks = [];
  234. hostInfo[index].progress = '0';
  235. }
  236. this.setDBProperty('hosts', hostInfo);
  237. },
  238. /**
  239. * Remove all data for installOptions step
  240. */
  241. clearInstallOptions: function () {
  242. var installOptions = this.getInstallOptions();
  243. this.set('content.installOptions', installOptions);
  244. this.setDBProperty('installOptions', installOptions);
  245. this.set('content.hosts', {});
  246. this.setDBProperty('hosts', {});
  247. },
  248. toObject: function (object) {
  249. var result = {};
  250. for (var i in object) {
  251. if (object.hasOwnProperty(i)) {
  252. result[i] = object[i];
  253. }
  254. }
  255. return result;
  256. },
  257. /**
  258. * save status of the cluster. This is called from step8 and step9 to persist install and start requestId
  259. * @param clusterStatus object with status, isCompleted, requestId, isInstallError and isStartError field.
  260. */
  261. saveClusterStatus: function (clusterStatus) {
  262. var oldStatus = this.toObject(this.get('content.cluster'));
  263. clusterStatus = jQuery.extend(oldStatus, clusterStatus);
  264. if (clusterStatus.requestId &&
  265. clusterStatus.oldRequestsId.indexOf(clusterStatus.requestId) === -1) {
  266. clusterStatus.oldRequestsId.push(clusterStatus.requestId);
  267. }
  268. this.set('content.cluster', clusterStatus);
  269. this.setDBProperty('cluster', clusterStatus);
  270. },
  271. /**
  272. * Invoke installation of selected services to the server and saves the request id returned by the server.
  273. * @param isRetry
  274. */
  275. installServices: function (isRetry, callback) {
  276. // clear requests since we are installing services
  277. // and we don't want to get tasks for previous install attempts
  278. this.set('content.cluster.oldRequestsId', []);
  279. var data;
  280. callback = callback || Em.K;
  281. if (isRetry) {
  282. data = {
  283. context: Em.I18n.t('requestInfo.installComponents'),
  284. HostRoles: {"state": "INSTALLED"},
  285. urlParams: "HostRoles/state=INSTALLED"
  286. }
  287. } else {
  288. data = {
  289. context: Em.I18n.t('requestInfo.installServices'),
  290. ServiceInfo: {"state": "INSTALLED"},
  291. urlParams: "ServiceInfo/state=INIT"
  292. }
  293. }
  294. App.ajax.send({
  295. name: isRetry ? 'common.host_components.update' : 'common.services.update',
  296. sender: this,
  297. data: data,
  298. success: 'installServicesSuccessCallback',
  299. error: 'installServicesErrorCallback'
  300. }).then(callback, callback);
  301. },
  302. installServicesSuccessCallback: function (jsonData) {
  303. var installStartTime = App.dateTime();
  304. console.log("TRACE: In success function for the installService call");
  305. if (jsonData) {
  306. var requestId = jsonData.Requests.id;
  307. console.log('requestId is: ' + requestId);
  308. var clusterStatus = {
  309. status: 'PENDING',
  310. requestId: requestId,
  311. isInstallError: false,
  312. isCompleted: false,
  313. installStartTime: installStartTime
  314. };
  315. this.saveClusterStatus(clusterStatus);
  316. } else {
  317. console.log('ERROR: Error occurred in parsing JSON data');
  318. }
  319. },
  320. installServicesErrorCallback: function (request, ajaxOptions, error) {
  321. console.log("TRACE: In error function for the installService call");
  322. console.log("TRACE: error code status is: " + request.status);
  323. console.log('Error message is: ' + request.responseText);
  324. var clusterStatus = {
  325. status: 'PENDING',
  326. requestId: this.get('content.cluster.requestId'),
  327. isInstallError: true,
  328. isCompleted: false
  329. };
  330. this.saveClusterStatus(clusterStatus);
  331. App.showAlertPopup(Em.I18n.t('common.errorPopup.header'), request.responseText);
  332. },
  333. /**
  334. * show popup, that display status of bootstrap launching
  335. * @param callback
  336. * @return {Object}
  337. */
  338. showLaunchBootstrapPopup: function (callback) {
  339. return App.ModalPopup.show({
  340. header: Em.I18n.t('installer.step2.bootStrap.header'),
  341. isError: false,
  342. serverError: null,
  343. bodyClass: Em.View.extend({
  344. templateName: require('templates/wizard/bootstrap_call_popup')
  345. }),
  346. showFooter: false,
  347. showCloseButton: false,
  348. secondary: null,
  349. /**
  350. * handle requestId when call is completed,
  351. * if it's correct call callback and hide popup
  352. * otherwise notify error and enable buttons to close popup
  353. * @param requestId
  354. * @param serverError
  355. */
  356. finishLoading: function (requestId, serverError) {
  357. if (Em.isNone(requestId)) {
  358. this.set('isError', true);
  359. this.set('showFooter', true);
  360. this.set('showCloseButton', true);
  361. this.set('serverError', serverError);
  362. } else {
  363. callback(requestId);
  364. this.hide();
  365. }
  366. }
  367. });
  368. },
  369. /**
  370. * Bootstrap selected hosts.
  371. * @param bootStrapData
  372. * @param callback
  373. * @return {Object}
  374. */
  375. launchBootstrap: function (bootStrapData, callback) {
  376. var popup = this.showLaunchBootstrapPopup(callback);
  377. App.ajax.send({
  378. name: 'wizard.launch_bootstrap',
  379. sender: this,
  380. data: {
  381. bootStrapData: bootStrapData,
  382. popup: popup
  383. },
  384. success: 'launchBootstrapSuccessCallback',
  385. error: 'launchBootstrapErrorCallback'
  386. });
  387. return popup;
  388. },
  389. launchBootstrapSuccessCallback: function (data, opt, params) {
  390. console.log("TRACE: POST bootstrap succeeded");
  391. params.popup.finishLoading(data.requestId, null);
  392. },
  393. launchBootstrapErrorCallback: function (request, ajaxOptions, error, opt, params) {
  394. console.log("ERROR: POST bootstrap failed");
  395. params.popup.finishLoading(null, error);
  396. },
  397. /**
  398. * Load <code>content.<name></code> variable from localStorage, if wasn't loaded before.
  399. * If you specify <code>reload</code> to true - it will reload it.
  400. * @param name
  401. * @param reload
  402. * @return {Boolean}
  403. */
  404. load: function (name, reload) {
  405. if (this.get('content.' + name) && !reload) {
  406. return false;
  407. }
  408. var result = this.getDBProperty(name);
  409. if (!result) {
  410. if (this['get' + name.capitalize()]) {
  411. result = this['get' + name.capitalize()]();
  412. this.setDBProperty(name, result);
  413. console.log(this.get('name') + ": created " + name, result);
  414. }
  415. else {
  416. console.debug('get' + name.capitalize(), ' not defined in the ' + this.get('name'));
  417. }
  418. }
  419. this.set('content.' + name, result);
  420. console.log(this.get('name') + ": loaded " + name, result);
  421. },
  422. save: function (name) {
  423. var value = this.toObject(this.get('content.' + name));
  424. this.setDBProperty(name, value);
  425. console.log(this.get('name') + ": saved " + name, value);
  426. },
  427. clear: function () {
  428. this.set('content', Ember.Object.create({
  429. 'controllerName': this.get('content.controllerName')
  430. }));
  431. this.set('currentStep', 0);
  432. this.clearStorageData();
  433. },
  434. clusterStatusTemplate: {
  435. name: "",
  436. status: "PENDING",
  437. isCompleted: false,
  438. requestId: null,
  439. installStartTime: null,
  440. installTime: null,
  441. isInstallError: false,
  442. isStartError: false,
  443. oldRequestsId: []
  444. },
  445. clearStorageData: function () {
  446. this.get('dbPropertiesToClean').forEach(function (key) {
  447. this.setDBProperty(key, undefined);
  448. }, this);
  449. },
  450. getInstallOptions: function() {
  451. return jQuery.extend({}, App.get('isHadoopWindowsStack') ? this.get('installWindowsOptionsTemplate') : this.get('installOptionsTemplate'));
  452. },
  453. installOptionsTemplate: {
  454. hostNames: "", //string
  455. manualInstall: false, //true, false
  456. useSsh: true, //bool
  457. javaHome: App.defaultJavaHome, //string
  458. localRepo: false, //true, false
  459. sshKey: "", //string
  460. bootRequestId: null, //string
  461. sshUser: "root", //string
  462. agentUser: "root" //string
  463. },
  464. installWindowsOptionsTemplate: {
  465. hostNames: "", //string
  466. manualInstall: true, //true, false
  467. useSsh: false, //bool
  468. javaHome: App.defaultJavaHome, //string
  469. localRepo: false, //true, false
  470. sshKey: "", //string
  471. bootRequestId: null, //string
  472. sshUser: "", //string
  473. agentUser: "" //string
  474. },
  475. loadedServiceComponents: null,
  476. /**
  477. * Generate serviceComponents as pr the stack definition and save it to localdata
  478. * called form stepController step4WizardController
  479. */
  480. loadServiceComponents: function () {
  481. return App.ajax.send({
  482. name: 'wizard.service_components',
  483. sender: this,
  484. data: {
  485. stackUrl: App.get('stackVersionURL'),
  486. stackVersion: App.get('currentStackVersionNumber')
  487. },
  488. success: 'loadServiceComponentsSuccessCallback',
  489. error: 'loadServiceComponentsErrorCallback'
  490. });
  491. },
  492. loadServiceComponentsSuccessCallback: function (jsonData) {
  493. var savedSelectedServices = this.getDBProperty('selectedServiceNames');
  494. var savedInstalledServices = this.getDBProperty('installedServiceNames');
  495. this.set('content.selectedServiceNames', savedSelectedServices);
  496. this.set('content.installedServiceNames', savedInstalledServices);
  497. if (!savedSelectedServices) {
  498. jsonData.items.forEach(function (service) {
  499. service.StackServices.is_selected = true;
  500. }, this);
  501. } else {
  502. jsonData.items.forEach(function (service) {
  503. if (savedSelectedServices.contains(service.StackServices.service_name))
  504. service.StackServices.is_selected = true;
  505. else
  506. service.StackServices.is_selected = false;
  507. }, this);
  508. }
  509. if (!savedInstalledServices) {
  510. jsonData.items.forEach(function (service) {
  511. service.StackServices.is_installed = false;
  512. }, this);
  513. } else {
  514. jsonData.items.forEach(function (service) {
  515. if (savedInstalledServices.contains(service.StackServices.service_name))
  516. service.StackServices.is_installed = true;
  517. else
  518. service.StackServices.is_installed = false;
  519. }, this);
  520. }
  521. App.stackServiceMapper.mapStackServices(jsonData);
  522. },
  523. loadServiceComponentsErrorCallback: function (request, ajaxOptions, error) {
  524. console.log("TRACE: STep5 -> In error function for the getServiceComponents call");
  525. console.log("TRACE: STep5 -> error code status is: " + request.status);
  526. console.log('Step8: Error message is: ' + request.responseText);
  527. },
  528. /**
  529. * Load config groups from local DB
  530. */
  531. loadServiceConfigGroups: function () {
  532. var serviceConfigGroups = this.getDBProperty('serviceConfigGroups'),
  533. hosts = this.getDBProperty('hosts'),
  534. host_names = Em.keys(hosts);
  535. if (Em.isNone(serviceConfigGroups)) {
  536. serviceConfigGroups = [];
  537. }
  538. else {
  539. serviceConfigGroups.forEach(function(group) {
  540. var hostNames = group.hosts.map(function(host_id) {
  541. for (var i = 0; i < host_names.length; i++) {
  542. if (hosts[host_names[i]].id === host_id) {
  543. return host_names[i];
  544. }
  545. }
  546. Em.assert('host is missing!!!!', false);
  547. });
  548. Em.set(group, 'hosts', hostNames);
  549. });
  550. }
  551. this.set('content.configGroups', serviceConfigGroups);
  552. console.log("InstallerController.configGroups: loaded config ", serviceConfigGroups);
  553. },
  554. registerErrPopup: function (header, message) {
  555. App.ModalPopup.show({
  556. header: header,
  557. secondary: false,
  558. bodyClass: Ember.View.extend({
  559. template: Ember.Handlebars.compile('<p>{{view.message}}</p>'),
  560. message: message
  561. })
  562. });
  563. },
  564. /**
  565. * Save hosts that the user confirmed to proceed with from step 3
  566. * @param stepController App.WizardStep3Controller
  567. */
  568. saveConfirmedHosts: function (stepController) {
  569. var hosts = this.get('content.hosts'),
  570. indx = 1;
  571. //add previously installed hosts
  572. for (var hostName in hosts) {
  573. if (!hosts[hostName].isInstalled) {
  574. delete hosts[hostName];
  575. }
  576. }
  577. stepController.get('confirmedHosts').forEach(function (_host) {
  578. if (_host.bootStatus == 'REGISTERED') {
  579. hosts[_host.name] = {
  580. name: _host.name,
  581. cpu: _host.cpu,
  582. memory: _host.memory,
  583. disk_info: _host.disk_info,
  584. os_type: _host.os_type,
  585. os_arch: _host.os_arch,
  586. ip: _host.ip,
  587. bootStatus: _host.bootStatus,
  588. isInstalled: false,
  589. id: indx++
  590. };
  591. }
  592. });
  593. console.log('wizardController:saveConfirmedHosts: save hosts ', hosts);
  594. this.setDBProperty('hosts', hosts);
  595. this.set('content.hosts', hosts);
  596. },
  597. /**
  598. * Save data after installation to main controller
  599. * @param stepController App.WizardStep9Controller
  600. */
  601. saveInstalledHosts: function (stepController) {
  602. var hosts = stepController.get('hosts');
  603. var hostInfo = this.getDBProperty('hosts');
  604. for (var index in hostInfo) {
  605. hostInfo[index].status = "pending";
  606. var host = hosts.findProperty('name', hostInfo[index].name);
  607. if (host) {
  608. hostInfo[index].status = host.status;
  609. hostInfo[index].message = host.message;
  610. hostInfo[index].progress = host.progress;
  611. }
  612. }
  613. this.set('content.hosts', hostInfo);
  614. this.setDBProperty('hosts', hostInfo);
  615. console.log('wizardController:saveInstalledHosts: save hosts ', hostInfo);
  616. },
  617. /**
  618. * Save slaveHostComponents to main controller
  619. * @param stepController
  620. */
  621. saveSlaveComponentHosts: function (stepController) {
  622. var hosts = stepController.get('hosts'),
  623. dbHosts = this.getDBProperty('hosts'),
  624. headers = stepController.get('headers');
  625. var formattedHosts = Ember.Object.create();
  626. headers.forEach(function (header) {
  627. formattedHosts.set(header.get('name'), []);
  628. });
  629. hosts.forEach(function (host) {
  630. var checkboxes = host.get('checkboxes');
  631. headers.forEach(function (header) {
  632. var cb = checkboxes.findProperty('title', header.get('label'));
  633. if (cb.get('checked')) {
  634. formattedHosts.get(header.get('name')).push({
  635. group: 'Default',
  636. isInstalled: cb.get('isInstalled'),
  637. host_id: dbHosts[host.hostName].id
  638. });
  639. }
  640. });
  641. });
  642. var slaveComponentHosts = [];
  643. headers.forEach(function (header) {
  644. slaveComponentHosts.push({
  645. componentName: header.get('name'),
  646. displayName: header.get('label').replace(/\s/g, ''),
  647. hosts: formattedHosts.get(header.get('name'))
  648. });
  649. });
  650. this.setDBProperty('slaveComponentHosts', slaveComponentHosts);
  651. console.log('wizardController.slaveComponentHosts: saved hosts', slaveComponentHosts);
  652. this.set('content.slaveComponentHosts', slaveComponentHosts);
  653. },
  654. /**
  655. * Return true if cluster data is loaded and false otherwise.
  656. * This is used for all wizard controllers except for installer wizard.
  657. */
  658. dataLoading: function () {
  659. var dfd = $.Deferred();
  660. this.connectOutlet('loading');
  661. if (App.router.get('clusterController.isLoaded')) {
  662. dfd.resolve();
  663. } else {
  664. var interval = setInterval(function () {
  665. if (App.router.get('clusterController.isLoaded')) {
  666. dfd.resolve();
  667. clearInterval(interval);
  668. }
  669. }, 50);
  670. }
  671. return dfd.promise();
  672. },
  673. /**
  674. * Return true if user data is loaded via App.MainServiceInfoConfigsController
  675. * This function is used in reassign master wizard right now.
  676. */
  677. usersLoading: function () {
  678. var self = this;
  679. var dfd = $.Deferred();
  680. var miscController = App.MainAdminServiceAccountsController.create({content: self.get('content')});
  681. miscController.loadUsers();
  682. var interval = setInterval(function () {
  683. if (miscController.get('dataIsLoaded')) {
  684. if (self.get("content.hdfsUser")) {
  685. self.set('content.hdfsUser', miscController.get('content.hdfsUser'));
  686. }
  687. dfd.resolve();
  688. clearInterval(interval);
  689. }
  690. }, 10);
  691. return dfd.promise();
  692. },
  693. /**
  694. * Save cluster status before going to deploy step
  695. * @param name cluster state. Unique for every wizard
  696. */
  697. saveClusterState: function (name) {
  698. App.clusterStatus.setClusterStatus({
  699. clusterName: this.get('content.cluster.name'),
  700. clusterState: name,
  701. wizardControllerName: this.get('content.controllerName'),
  702. localdb: App.db.data
  703. });
  704. },
  705. /**
  706. * load advanced configs from server
  707. */
  708. loadAdvancedConfigs: function (dependentController) {
  709. var self = this;
  710. var loadServiceConfigsFn = function(clusterProperties) {
  711. var stackServices = self.get('content.services').filter(function (service) {
  712. return service.get('isInstalled') || service.get('isSelected');
  713. });
  714. var counter = stackServices.length;
  715. var loadAdvancedConfigResult = [];
  716. dependentController.set('isAdvancedConfigLoaded', false);
  717. stackServices.forEach(function (service) {
  718. var serviceName = service.get('serviceName');
  719. App.config.loadAdvancedConfig(serviceName, function (properties) {
  720. var supportsFinal = App.config.getConfigTypesInfoFromService(service).supportsFinal;
  721. function shouldSupportFinal(filename) {
  722. var matchingConfigType = supportsFinal.find(function (configType) {
  723. return filename.startsWith(configType);
  724. });
  725. return !!matchingConfigType;
  726. }
  727. properties.forEach(function (property) {
  728. property.supportsFinal = shouldSupportFinal(property.filename);
  729. });
  730. loadAdvancedConfigResult.pushObjects(properties);
  731. counter--;
  732. //pass configs to controller after last call is completed
  733. if (counter === 0) {
  734. loadAdvancedConfigResult.pushObjects(clusterProperties);
  735. self.set('content.advancedServiceConfig', loadAdvancedConfigResult);
  736. self.setDBProperty('advancedServiceConfig', loadAdvancedConfigResult);
  737. dependentController.set('isAdvancedConfigLoaded', true);
  738. }
  739. });
  740. }, this);
  741. };
  742. App.config.loadClusterConfig(loadServiceConfigsFn);
  743. },
  744. /**
  745. * Load serviceConfigProperties to model
  746. */
  747. loadServiceConfigProperties: function () {
  748. var serviceConfigProperties = this.getDBProperty('serviceConfigProperties');
  749. this.set('content.serviceConfigProperties', serviceConfigProperties);
  750. console.log("AddHostController.loadServiceConfigProperties: loaded config ", serviceConfigProperties);
  751. },
  752. /**
  753. * Save config properties
  754. * @param stepController Step7WizardController
  755. */
  756. saveServiceConfigProperties: function (stepController) {
  757. var serviceConfigProperties = [];
  758. var fileNamesToUpdate = [];
  759. stepController.get('stepConfigs').forEach(function (_content) {
  760. if (_content.serviceName === 'YARN') {
  761. _content.set('configs', App.config.textareaIntoFileConfigs(_content.get('configs'), 'capacity-scheduler.xml'));
  762. }
  763. _content.get('configs').forEach(function (_configProperties) {
  764. var configProperty = {
  765. id: _configProperties.get('id'),
  766. name: _configProperties.get('name'),
  767. value: _configProperties.get('value'),
  768. defaultValue: _configProperties.get('defaultValue'),
  769. description: _configProperties.get('description'),
  770. serviceName: _configProperties.get('serviceName'),
  771. domain: _configProperties.get('domain'),
  772. isVisible: _configProperties.get('isVisible'),
  773. isFinal: _configProperties.get('isFinal'),
  774. defaultIsFinal: _configProperties.get('isFinal'),
  775. supportsFinal: _configProperties.get('supportsFinal'),
  776. filename: _configProperties.get('filename'),
  777. displayType: _configProperties.get('displayType'),
  778. isRequiredByAgent: _configProperties.get('isRequiredByAgent'),
  779. hasInitialValue: !!_configProperties.get('hasInitialValue'),
  780. isRequired: _configProperties.get('isRequired'), // flag that allow saving property with empty value
  781. group: !!_configProperties.get('group') ? _configProperties.get('group.name') : null,
  782. showLabel: _configProperties.get('showLabel'),
  783. category: _configProperties.get('category')
  784. };
  785. serviceConfigProperties.push(configProperty);
  786. }, this);
  787. // check for configs that need to update for installed services
  788. if (stepController.get('installedServiceNames') && stepController.get('installedServiceNames').contains(_content.get('serviceName'))) {
  789. // get only modified configs
  790. var configs = _content.get('configs').filter(function (config) {
  791. if (config.get('isNotDefaultValue') || (config.get('defaultValue') === null)) {
  792. var notAllowed = ['masterHost', 'masterHosts', 'slaveHosts', 'slaveHost'];
  793. return !notAllowed.contains(config.get('displayType')) && !!config.filename;
  794. }
  795. return false;
  796. });
  797. // if modified configs detected push all service's configs for update
  798. if (configs.length) {
  799. fileNamesToUpdate = fileNamesToUpdate.concat(configs.mapProperty('filename').uniq());
  800. }
  801. // watch for properties that are not modified but have to be updated
  802. if (_content.get('configs').someProperty('forceUpdate')) {
  803. // check for already added modified properties
  804. var forceUpdatedFileNames = _content.get('configs').filterProperty('forceUpdate', true).mapProperty('filename').uniq();
  805. fileNamesToUpdate = fileNamesToUpdate.concat(forceUpdatedFileNames).uniq();
  806. }
  807. }
  808. }, this);
  809. this.setDBProperty('serviceConfigProperties', serviceConfigProperties);
  810. this.set('content.serviceConfigProperties', serviceConfigProperties);
  811. this.setDBProperty('fileNamesToUpdate', fileNamesToUpdate);
  812. },
  813. /**
  814. * save Config groups
  815. * @param stepController
  816. * @param isAddService
  817. */
  818. saveServiceConfigGroups: function (stepController, isAddService) {
  819. var serviceConfigGroups = [],
  820. isForInstalledService = false,
  821. hosts = isAddService ? App.router.get('addServiceController').getDBProperty('hosts') : this.getDBProperty('hosts');
  822. stepController.get('stepConfigs').forEach(function (service) {
  823. // mark group of installed service
  824. if (service.get('selected') === false) isForInstalledService = true;
  825. service.get('configGroups').forEach(function (configGroup) {
  826. var properties = [];
  827. configGroup.get('properties').forEach(function (property) {
  828. properties.push({
  829. isRequiredByAgent: property.get('isRequiredByAgent'),
  830. name: property.get('name'),
  831. value: property.get('value'),
  832. isFinal: property.get('isFinal'),
  833. filename: property.get('filename')
  834. })
  835. });
  836. //configGroup copied into plain JS object to avoid Converting circular structure to JSON
  837. var hostNames = configGroup.get('hosts').map(function(host_name) {return hosts[host_name].id;});
  838. serviceConfigGroups.push({
  839. id: configGroup.get('id'),
  840. name: configGroup.get('name'),
  841. description: configGroup.get('description'),
  842. hosts: hostNames,
  843. publicHosts: configGroup.get('hosts').map(function(hostName) {return App.router.get('manageConfigGroupsController').hostsToPublic(hostName); }),
  844. properties: properties,
  845. isDefault: configGroup.get('isDefault'),
  846. isForInstalledService: isForInstalledService,
  847. isForUpdate: configGroup.isForUpdate || configGroup.get('hash') != this.getConfigGroupHash(configGroup, hostNames),
  848. service: {id: configGroup.get('service.id')}
  849. });
  850. }, this)
  851. }, this);
  852. this.setDBProperty('serviceConfigGroups', serviceConfigGroups);
  853. this.set('content.configGroups', serviceConfigGroups);
  854. },
  855. /**
  856. * generate string hash for config group
  857. * @param {Object} configGroup
  858. * @param {Array|undefined} hosts
  859. * @returns {String|null}
  860. * @method getConfigGroupHash
  861. */
  862. getConfigGroupHash: function(configGroup, hosts) {
  863. if (!Em.get(configGroup, 'properties.length') && !Em.get(configGroup, 'hosts.length') && !hosts) {
  864. return null;
  865. }
  866. var hash = {};
  867. Em.get(configGroup, 'properties').forEach(function (config) {
  868. hash[Em.get(config, 'name')] = {value: Em.get(config, 'value'), isFinal: Em.get(config, 'isFinal')};
  869. });
  870. hash['hosts'] = hosts || Em.get(configGroup, 'hosts');
  871. return JSON.stringify(hash);
  872. },
  873. /**
  874. * return slaveComponents bound to hosts
  875. * @return {Array}
  876. */
  877. getSlaveComponentHosts: function () {
  878. var components = this.get('slaveComponents');
  879. var result = [];
  880. var installedServices = App.Service.find().mapProperty('serviceName');
  881. var selectedServices = App.StackService.find().filterProperty('isSelected', true).mapProperty('serviceName');
  882. var installedComponentsMap = {};
  883. var uninstalledComponents = [];
  884. components.forEach(function (component) {
  885. if (installedServices.contains(component.get('serviceName'))) {
  886. installedComponentsMap[component.get('componentName')] = [];
  887. } else if (selectedServices.contains(component.get('serviceName'))) {
  888. uninstalledComponents.push(component);
  889. }
  890. }, this);
  891. installedComponentsMap['HDFS_CLIENT'] = [];
  892. App.HostComponent.find().forEach(function (hostComponent) {
  893. if (installedComponentsMap[hostComponent.get('componentName')]) {
  894. installedComponentsMap[hostComponent.get('componentName')].push(hostComponent.get('hostName'));
  895. }
  896. }, this);
  897. for (var componentName in installedComponentsMap) {
  898. var name = (componentName === 'HDFS_CLIENT') ? 'CLIENT' : componentName;
  899. var component = {
  900. componentName: name,
  901. displayName: App.format.role(name),
  902. hosts: [],
  903. isInstalled: true
  904. };
  905. installedComponentsMap[componentName].forEach(function (hostName) {
  906. component.hosts.push({
  907. group: "Default",
  908. hostName: hostName,
  909. isInstalled: true
  910. });
  911. }, this);
  912. result.push(component);
  913. }
  914. uninstalledComponents.forEach(function (component) {
  915. var hosts = jQuery.extend(true, [], result.findProperty('componentName', 'DATANODE').hosts);
  916. hosts.setEach('isInstalled', false);
  917. result.push({
  918. componentName: component.get('componentName'),
  919. displayName: App.format.role(component.get('componentName')),
  920. hosts: hosts,
  921. isInstalled: false
  922. })
  923. });
  924. return result;
  925. },
  926. /**
  927. * Load master component hosts data for using in required step controllers
  928. */
  929. loadMasterComponentHosts: function () {
  930. var masterComponentHosts = this.getDBProperty('masterComponentHosts');
  931. var stackMasterComponents = App.get('components.masters').uniq();
  932. if (!masterComponentHosts) {
  933. masterComponentHosts = [];
  934. App.HostComponent.find().filter(function(component) {
  935. return stackMasterComponents.contains(component.get('componentName'));
  936. }).forEach(function (item) {
  937. masterComponentHosts.push({
  938. component: item.get('componentName'),
  939. hostName: item.get('hostName'),
  940. isInstalled: true,
  941. serviceId: item.get('service.id'),
  942. display_name: item.get('displayName')
  943. })
  944. });
  945. this.setDBProperty('masterComponentHosts', masterComponentHosts);
  946. }
  947. this.set("content.masterComponentHosts", masterComponentHosts);
  948. },
  949. /**
  950. * Load information about hosts with clients components
  951. */
  952. loadClients: function () {
  953. var clients = this.getDBProperty('clientInfo');
  954. this.set('content.clients', clients);
  955. console.log(this.get('content.controllerName') + ".loadClients: loaded list ", clients);
  956. },
  957. /**
  958. * load methods assigned to each step
  959. * methods executed in exact order as they described in map
  960. * @return {object}
  961. */
  962. loadAllPriorSteps: function () {
  963. var currentStep = this.get('currentStep');
  964. var loadMap = this.get('loadMap');
  965. var operationStack = [];
  966. var dfd = $.Deferred();
  967. for (var s in loadMap) {
  968. if (parseInt(s) <= parseInt(currentStep)) {
  969. operationStack.pushObjects(loadMap[s]);
  970. }
  971. }
  972. var sequence = App.actionSequence.create({context: this});
  973. sequence.setSequence(operationStack).onFinish(function () {
  974. dfd.resolve();
  975. }).start();
  976. return dfd.promise();
  977. },
  978. /**
  979. * return new object extended from clusterStatusTemplate
  980. * @return Object
  981. */
  982. getCluster: function () {
  983. return jQuery.extend({}, this.get('clusterStatusTemplate'), {name: App.router.getClusterName()});
  984. },
  985. /**
  986. * Load services data from server.
  987. */
  988. loadServicesFromServer: function () {
  989. var services = this.getDBProperty('services');
  990. if (!services) {
  991. services = {
  992. selectedServices: [],
  993. installedServices: []
  994. };
  995. App.StackService.find().forEach(function(item){
  996. var isInstalled = App.Service.find().someProperty('id', item.get('serviceName'));
  997. item.set('isSelected', isInstalled);
  998. item.set('isInstalled', isInstalled);
  999. if (isInstalled) {
  1000. services.selectedServices.push(item.get('serviceName'));
  1001. services.installedServices.push(item.get('serviceName'));
  1002. }
  1003. },this);
  1004. this.setDBProperty('services',services);
  1005. } else {
  1006. App.StackService.find().forEach(function(item) {
  1007. var isSelected = services.selectedServices.contains(item.get('serviceName'));
  1008. var isInstalled = services.installedServices.contains(item.get('serviceName'));
  1009. item.set('isSelected', isSelected);
  1010. item.set('isInstalled', isInstalled);
  1011. },this);
  1012. }
  1013. this.set('content.services', App.StackService.find());
  1014. },
  1015. /**
  1016. * Load confirmed hosts.
  1017. * Will be used at <code>Assign Masters(step5)</code> step
  1018. */
  1019. loadConfirmedHosts: function () {
  1020. var hosts = App.db.getHosts();
  1021. if (hosts) {
  1022. this.set('content.hosts', hosts);
  1023. }
  1024. }
  1025. });