wizard.js 30 KB

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