installer.js 27 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862
  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. App.InstallerController = Em.Controller.extend({
  20. name: 'installerController',
  21. isStepDisabled: [],
  22. totalSteps: 10,
  23. init: function () {
  24. this.clusters = App.Cluster.find();
  25. this.isStepDisabled.pushObject(Ember.Object.create({
  26. step: 1,
  27. value: false
  28. }));
  29. for (var i = 2; i <= this.totalSteps; i++) {
  30. this.isStepDisabled.pushObject(Ember.Object.create({
  31. step: i,
  32. value: true
  33. }));
  34. }
  35. // window.onbeforeunload = function () {
  36. // return "You have not saved your document yet. If you continue, your work will not be saved."
  37. //}
  38. },
  39. setStepsEnable: function () {
  40. for (var i = 2; i <= this.totalSteps; i++) {
  41. var step = this.get('isStepDisabled').findProperty('step', i);
  42. if (i <= this.get('currentStep')) {
  43. step.set('value', false);
  44. } else {
  45. step.set('value', true);
  46. }
  47. }
  48. }.observes('currentStep'),
  49. setLowerStepsDisable: function (stepNo) {
  50. for (var i = 1; i < stepNo; i++) {
  51. var step = this.get('isStepDisabled').findProperty('step', i);
  52. step.set('value', true);
  53. }
  54. },
  55. prevInstallStatus: function () {
  56. console.log('Inside the prevInstallStep function: The name is ' + App.router.get('loginController.loginName'));
  57. var result = App.db.isCompleted()
  58. if (result == '1') {
  59. return true;
  60. }
  61. }.property('App.router.loginController.loginName'),
  62. /**
  63. * Set current step to new value.
  64. * Method moved from App.router.setInstallerCurrentStep
  65. * @param currentStep
  66. * @param completed
  67. */
  68. currentStep: function () {
  69. return App.get('router').getWizardCurrentStep('installer');
  70. }.property(),
  71. /**
  72. * Set current step to new value.
  73. * Method moved from App.router.setInstallerCurrentStep
  74. * @param currentStep
  75. * @param completed
  76. */
  77. setCurrentStep: function (currentStep, completed) {
  78. App.db.setWizardCurrentStep('installer', currentStep, completed);
  79. this.set('currentStep', currentStep);
  80. },
  81. clusters: null,
  82. isStep1: function () {
  83. return this.get('currentStep') == 1;
  84. }.property('currentStep'),
  85. isStep2: function () {
  86. return this.get('currentStep') == 2;
  87. }.property('currentStep'),
  88. isStep3: function () {
  89. return this.get('currentStep') == 3;
  90. }.property('currentStep'),
  91. isStep4: function () {
  92. return this.get('currentStep') == 4;
  93. }.property('currentStep'),
  94. isStep5: function () {
  95. return this.get('currentStep') == 5;
  96. }.property('currentStep'),
  97. isStep6: function () {
  98. return this.get('currentStep') == 6;
  99. }.property('currentStep'),
  100. isStep7: function () {
  101. return this.get('currentStep') == 7;
  102. }.property('currentStep'),
  103. isStep8: function () {
  104. return this.get('currentStep') == 8;
  105. }.property('currentStep'),
  106. isStep9: function () {
  107. return this.get('currentStep') == 9;
  108. }.property('currentStep'),
  109. isStep10: function () {
  110. return this.get('currentStep') == 10;
  111. }.property('currentStep'),
  112. gotoStep1: function () {
  113. if (this.get('isStepDisabled').findProperty('step', 1).get('value') === true) {
  114. return;
  115. } else {
  116. App.router.send('gotoStep1');
  117. }
  118. },
  119. gotoStep2: function () {
  120. if (this.get('isStepDisabled').findProperty('step', 2).get('value') === true) {
  121. return;
  122. } else {
  123. App.router.send('gotoStep2');
  124. }
  125. },
  126. gotoStep3: function () {
  127. if (this.get('isStepDisabled').findProperty('step', 3).get('value') === true) {
  128. return;
  129. } else {
  130. App.router.send('gotoStep3');
  131. }
  132. },
  133. gotoStep4: function () {
  134. if (this.get('isStepDisabled').findProperty('step', 4).get('value') === true) {
  135. return;
  136. } else {
  137. App.router.send('gotoStep4');
  138. }
  139. },
  140. gotoStep5: function () {
  141. if (this.get('isStepDisabled').findProperty('step', 5).get('value') === true) {
  142. return;
  143. } else {
  144. App.router.send('gotoStep5');
  145. }
  146. },
  147. gotoStep6: function () {
  148. if (this.get('isStepDisabled').findProperty('step', 6).get('value') === true) {
  149. return;
  150. } else {
  151. App.router.send('gotoStep6');
  152. }
  153. },
  154. gotoStep7: function () {
  155. if (this.get('isStepDisabled').findProperty('step', 7).get('value') === true) {
  156. return;
  157. } else {
  158. App.router.send('gotoStep7');
  159. }
  160. },
  161. gotoStep8: function () {
  162. if (this.get('isStepDisabled').findProperty('step', 8).get('value') === true) {
  163. return;
  164. } else {
  165. App.router.send('gotoStep8');
  166. }
  167. },
  168. gotoStep9: function () {
  169. if (this.get('isStepDisabled').findProperty('step', 9).get('value') === true) {
  170. return;
  171. } else {
  172. App.router.send('gotoStep9');
  173. }
  174. },
  175. gotoStep10: function () {
  176. if (this.get('isStepDisabled').findProperty('step', 10).get('value') === true) {
  177. return;
  178. } else {
  179. App.router.send('gotoStep10');
  180. }
  181. },
  182. content: Em.Object.create({
  183. cluster: null,
  184. hosts: null,
  185. services: null,
  186. hostsInfo: [],
  187. slaveComponentHosts: null,
  188. hostSlaveComponents: null,
  189. masterComponentHosts: null,
  190. hostToMasterComponent: null,
  191. serviceConfigProperties: null,
  192. advancedServiceConfig: null
  193. }),
  194. /**
  195. * Load clusterInfo(step1) to model
  196. */
  197. loadClusterInfo: function () {
  198. var cStatus = App.db.getClusterStatus() || {status: "", isCompleted: false};
  199. var cluster = {
  200. name: App.db.getClusterName() || "",
  201. status: cStatus.status,
  202. isCompleted: cStatus.isCompleted
  203. };
  204. this.set('content.cluster', cluster);
  205. console.log("InstallerController:loadClusterInfo: loaded data ", cluster);
  206. },
  207. /**
  208. * Save all info about cluster to model
  209. * @param stepController Step1WizardController
  210. */
  211. saveClusterInfo: function (stepController) {
  212. var cluster = stepController.get('content.cluster');
  213. var clusterStatus = {
  214. status: cluster.status,
  215. isCompleted: cluster.isCompleted
  216. };
  217. App.db.setClusterName(cluster.name);
  218. App.db.setClusterStatus(clusterStatus);
  219. console.log("InstallerController:saveClusterInfo: saved data ", cluster);
  220. //probably next line is extra work - need to check it
  221. //this.set('content.cluster', cluster);
  222. },
  223. /**
  224. * save status of the cluster. This is called from step8 and step9 to persist install and start requestId
  225. * @param clusterStatus object with status, isCompleted, requestId, isInstallError and isStartError field.
  226. */
  227. saveClusterStatus: function (clusterStatus) {
  228. clusterStatus.name = this.get('content.cluster.name');
  229. this.set('content.cluster', clusterStatus);
  230. console.log('called saveClusterStatus ' + JSON.stringify(clusterStatus));
  231. App.db.setClusterStatus(clusterStatus);
  232. },
  233. /**
  234. * Temporary function for wizardStep9, before back-end integration
  235. */
  236. setInfoForStep9: function () {
  237. var hostInfo = App.db.getHosts();
  238. for (var index in hostInfo) {
  239. hostInfo[index].status = "pending";
  240. hostInfo[index].message = 'Waiting';
  241. hostInfo[index].logTasks = [];
  242. hostInfo[index].tasks = [];
  243. hostInfo[index].progress = '0';
  244. }
  245. App.db.setHosts(hostInfo);
  246. },
  247. /**
  248. * Load all data for <code>Specify Host(install step2)</code> step
  249. * Data Example:
  250. * {
  251. * hostNames: '',
  252. * manualInstall: false,
  253. * sshKey: '',
  254. * passphrase: '',
  255. * confirmPassphrase: '',
  256. * localRepo: false,
  257. * localRepoPath: ''
  258. * }
  259. */
  260. loadInstallOptions: function () {
  261. if (!this.content.hosts) {
  262. this.content.hosts = Em.Object.create();
  263. }
  264. //TODO : rewire it as model. or not :)
  265. var hostsInfo = Em.Object.create();
  266. hostsInfo.hostNames = App.db.getAllHostNames() || ''; //empty string if undefined
  267. //TODO : should we check installType for add host wizard????
  268. var installType = App.db.getInstallType();
  269. //false if installType not equals 'manual'
  270. hostsInfo.manualInstall = installType && installType.installType === 'manual' || false;
  271. var softRepo = App.db.getSoftRepo();
  272. if (softRepo && softRepo.repoType === 'local') {
  273. hostsInfo.localRepo = true;
  274. hostsInfo.localRepopath = softRepo.repoPath;
  275. } else {
  276. hostsInfo.localRepo = false;
  277. hostsInfo.localRepoPath = '';
  278. }
  279. hostsInfo.sshKey = '';
  280. hostsInfo.passphrase = '';
  281. hostsInfo.confirmPassphrase = '';
  282. this.set('content.hosts', hostsInfo);
  283. console.log("InstallerController:loadHosts: loaded data ", hostsInfo);
  284. },
  285. /**
  286. * Save data, which user filled, to main controller
  287. * @param stepController App.WizardStep2Controller
  288. */
  289. saveHosts: function (stepController) {
  290. //TODO: put data to content.hosts and only then save it)
  291. //App.db.setBootStatus(false);
  292. App.db.setAllHostNames(stepController.get('hostNames'));
  293. App.db.setHosts(stepController.getHostInfo());
  294. if (stepController.get('manualInstall') === false) {
  295. App.db.setInstallType({installType: 'ambari' });
  296. } else {
  297. App.db.setInstallType({installType: 'manual' });
  298. }
  299. if (stepController.get('localRepo') === false) {
  300. App.db.setSoftRepo({ 'repoType': 'remote', 'repoPath': null});
  301. } else {
  302. App.db.setSoftRepo({ 'repoType': 'local', 'repoPath': stepController.get('localRepoPath') });
  303. }
  304. },
  305. /**
  306. * Remove host from model. Used at <code>Confirm hosts(step2)</code> step
  307. * @param hosts Array of hosts, which we want to delete
  308. */
  309. removeHosts: function (hosts) {
  310. //todo Replace this code with real logic
  311. App.db.removeHosts(hosts);
  312. },
  313. /**
  314. * Save data, which user filled, to main controller
  315. * @param stepController App.WizardStep3Controller
  316. */
  317. saveConfirmedHosts: function (stepController) {
  318. var hostInfo = {};
  319. stepController.get('content.hostsInfo').forEach(function (_host) {
  320. hostInfo[_host.name] = {
  321. name: _host.name,
  322. cpu: _host.cpu,
  323. memory: _host.memory,
  324. bootStatus: _host.bootStatus
  325. };
  326. });
  327. console.log('installerController:saveConfirmedHosts: save hosts ', hostInfo);
  328. App.db.setHosts(hostInfo);
  329. this.set('content.hostsInfo', hostInfo);
  330. },
  331. /**
  332. * Load confirmed hosts.
  333. * Will be used at <code>Assign Masters(step5)</code> step
  334. */
  335. loadConfirmedHosts: function () {
  336. this.set('content.hostsInfo', App.db.getHosts());
  337. },
  338. /**
  339. * Save data after installation to main controller
  340. * @param stepController App.WizardStep9Controller
  341. */
  342. saveInstalledHosts: function (stepController) {
  343. var hosts = stepController.get('hosts');
  344. var hostInfo = App.db.getHosts();
  345. for (var index in hostInfo) {
  346. var host = hosts.findProperty('name', hostInfo[index].name);
  347. if (host) {
  348. hostInfo[index].status = host.status;
  349. hostInfo[index].logTasks = host.logTasks;
  350. hostInfo[index].tasks = host.tasks;
  351. hostInfo[index].message = host.message;
  352. hostInfo[index].progress = host.progress;
  353. }
  354. }
  355. App.db.setHosts(hostInfo);
  356. this.set('content.hostsInfo', hostInfo);
  357. },
  358. /**
  359. * Remove all data for hosts
  360. */
  361. clearHosts: function () {
  362. var hosts = this.get('content').get('hosts');
  363. if (hosts) {
  364. hosts.set('hostNames', '');
  365. hosts.set('manualInstall', false);
  366. hosts.set('localRepo', '');
  367. hosts.set('localRepopath', '');
  368. hosts.set('sshKey', '');
  369. hosts.set('passphrase', '');
  370. hosts.set('confirmPassphrase', '');
  371. }
  372. App.db.setHosts(null);
  373. App.db.setAllHostNames(null);
  374. },
  375. /**
  376. * Load services data. Will be used at <code>Select services(step4)</code> step
  377. */
  378. loadServices: function () {
  379. var servicesInfo = App.db.getService();
  380. servicesInfo.forEach(function (item, index) {
  381. servicesInfo[index] = Em.Object.create(item);
  382. });
  383. this.set('content.services', servicesInfo);
  384. console.log('installerController.loadServices: loaded data ', servicesInfo);
  385. console.log('selected services ', servicesInfo.filterProperty('isSelected', true).mapProperty('serviceName'));
  386. },
  387. /**
  388. * Save data to model
  389. * @param stepController App.WizardStep4Controller
  390. */
  391. saveServices: function (stepController) {
  392. var serviceNames = [];
  393. // we can also do it without stepController since all data,
  394. // changed at page, automatically changes in model(this.content.services)
  395. App.db.setService(stepController.get('content'));
  396. stepController.filterProperty('isSelected', true).forEach(function (item) {
  397. serviceNames.push(item.serviceName);
  398. });
  399. App.db.setSelectedServiceNames(serviceNames);
  400. console.log('installerController.saveServices: saved data ', serviceNames);
  401. },
  402. /**
  403. * Save Master Component Hosts data to Main Controller
  404. * @param stepController App.WizardStep5Controller
  405. */
  406. saveMasterComponentHosts: function (stepController) {
  407. var obj = stepController.get('selectedServicesMasters');
  408. console.log("installerController.selectedServicesMasters: saved hosts ", stepController.get('selectedServicesMasters'));
  409. var masterComponentHosts = [];
  410. obj.forEach(function (_component) {
  411. masterComponentHosts.push({
  412. display_name: _component.get('display_name'),
  413. component: _component.get('component_name'),
  414. hostName: _component.get('selectedHost')
  415. });
  416. });
  417. console.log("installerController.saveComponentHosts: saved hosts ", masterComponentHosts);
  418. App.db.setMasterComponentHosts(masterComponentHosts);
  419. this.set('content.masterComponentHosts', masterComponentHosts);
  420. var hosts = masterComponentHosts.mapProperty('hostName').uniq();
  421. var hostsMasterServicesMapping = [];
  422. hosts.forEach(function (_host) {
  423. var componentsOnHost = masterComponentHosts.filterProperty('hostName', _host).mapProperty('component');
  424. hostsMasterServicesMapping.push({
  425. hostname: _host,
  426. components: componentsOnHost
  427. });
  428. }, this);
  429. console.log("installerController.setHostToMasterComponent: saved hosts ", hostsMasterServicesMapping);
  430. App.db.setHostToMasterComponent(hostsMasterServicesMapping);
  431. this.set('content.hostToMasterComponent', hostsMasterServicesMapping);
  432. },
  433. /**
  434. * Load master component hosts data for using in required step controllers
  435. */
  436. loadMasterComponentHosts: function () {
  437. var masterComponentHosts = App.db.getMasterComponentHosts();
  438. this.set("content.masterComponentHosts", masterComponentHosts);
  439. console.log("InstallerController.loadMasterComponentHosts: loaded hosts ", masterComponentHosts);
  440. var hostsMasterServicesMapping = App.db.getHostToMasterComponent();
  441. this.set("content.hostToMasterComponent", hostsMasterServicesMapping);
  442. console.log("InstallerController.loadHostToMasterComponent: loaded hosts ", hostsMasterServicesMapping);
  443. },
  444. /**
  445. * Save slaveHostComponents to main controller
  446. * @param stepController
  447. */
  448. saveSlaveComponentHosts: function (stepController) {
  449. var hosts = stepController.get('hosts');
  450. var isMrSelected = stepController.get('isMrSelected');
  451. var isHbSelected = stepController.get('isHbSelected');
  452. App.db.setHostSlaveComponents(hosts);
  453. this.set('content.hostSlaveComponents', hosts);
  454. var dataNodeHosts = [];
  455. var taskTrackerHosts = [];
  456. var regionServerHosts = [];
  457. var clientHosts = [];
  458. hosts.forEach(function (host) {
  459. if (host.get('isDataNode')) {
  460. dataNodeHosts.push({
  461. hostname: host.hostname,
  462. group: 'Default'
  463. });
  464. }
  465. if (isMrSelected && host.get('isTaskTracker')) {
  466. taskTrackerHosts.push({
  467. hostname: host.hostname,
  468. group: 'Default'
  469. });
  470. }
  471. if (isHbSelected && host.get('isRegionServer')) {
  472. regionServerHosts.push({
  473. hostname: host.hostname,
  474. group: 'Default'
  475. });
  476. }
  477. if (host.get('isClient')) {
  478. clientHosts.pushObject({
  479. hostname: host.hostname,
  480. group: 'Default'
  481. });
  482. }
  483. }, this);
  484. var slaveComponentHosts = [];
  485. slaveComponentHosts.push({
  486. componentName: 'DATANODE',
  487. displayName: 'DataNode',
  488. hosts: dataNodeHosts
  489. });
  490. if (isMrSelected) {
  491. slaveComponentHosts.push({
  492. componentName: 'TASKTRACKER',
  493. displayName: 'TaskTracker',
  494. hosts: taskTrackerHosts
  495. });
  496. }
  497. if (isHbSelected) {
  498. slaveComponentHosts.push({
  499. componentName: 'HBASE_REGIONSERVER',
  500. displayName: 'RegionServer',
  501. hosts: regionServerHosts
  502. });
  503. }
  504. slaveComponentHosts.pushObject({
  505. componentName: 'CLIENT',
  506. displayName: 'client',
  507. hosts: clientHosts
  508. });
  509. App.db.setSlaveComponentHosts(slaveComponentHosts);
  510. this.set('content.slaveComponentHosts', slaveComponentHosts);
  511. },
  512. /**
  513. * Load master component hosts data for using in required step controllers
  514. */
  515. loadSlaveComponentHosts: function () {
  516. var slaveComponentHosts = App.db.getSlaveComponentHosts();
  517. if (slaveComponentHosts !== undefined) {
  518. this.set("content.slaveComponentHosts", slaveComponentHosts);
  519. console.log("InstallerController.loadSlaveComponentHosts: loaded hosts ", slaveComponentHosts);
  520. } else {
  521. this.set("content.slaveComponentHosts", null);
  522. }
  523. var hostSlaveComponents = App.db.getHostSlaveComponents();
  524. if (hostSlaveComponents !== undefined) {
  525. this.set('content.hostSlaveComponents', hostSlaveComponents);
  526. console.log("InstallerController.loadSlaveComponentHosts: loaded hosts ", hostSlaveComponents);
  527. } else {
  528. this.set("content.hostSlaveComponents", null);
  529. }
  530. },
  531. /**
  532. * Save config properties
  533. * @param stepController Step7WizardController
  534. */
  535. saveServiceConfigProperties: function (stepController) {
  536. var serviceConfigProperties = [];
  537. stepController.get('stepConfigs').forEach(function (_content) {
  538. _content.get('configs').forEach(function (_configProperties) {
  539. var displayType = _configProperties.get('displayType');
  540. if(displayType === 'directories' || displayType === 'advanced' || displayType === 'directory') {
  541. var value = _configProperties.get('value').replace(/[\s,]+/g,',');
  542. _configProperties.set('value',value);
  543. }
  544. var configProperty = {
  545. id: _configProperties.get('id'),
  546. name: _configProperties.get('name'),
  547. value: _configProperties.get('value'),
  548. defaultValue: _configProperties.get('defaultValue'),
  549. service: _configProperties.get('serviceName'),
  550. filename: _configProperties.get('filename')
  551. };
  552. serviceConfigProperties.push(configProperty);
  553. }, this);
  554. }, this);
  555. App.db.setServiceConfigProperties(serviceConfigProperties);
  556. this.set('content.serviceConfigProperties', serviceConfigProperties);
  557. },
  558. /**
  559. * Load serviceConfigProperties to model
  560. */
  561. loadServiceConfigProperties: function () {
  562. var serviceConfigProperties = App.db.getServiceConfigProperties();
  563. this.set('content.serviceConfigProperties', serviceConfigProperties);
  564. console.log("InstallerController.loadServiceConfigProperties: loaded config ", serviceConfigProperties);
  565. },
  566. /**
  567. * Load information about hosts with clients components
  568. */
  569. loadClients: function () {
  570. var clients = App.db.getClientsForSelectedServices();
  571. this.set('content.clients', clients);
  572. console.log("InstallerController.loadClients: loaded list ", clients);
  573. },
  574. /**
  575. * Generate clients list for selected services and save it to model
  576. * @param stepController step4WizardController
  577. */
  578. saveClients: function (stepController) {
  579. var clients = [];
  580. var serviceComponents = require('data/service_components');
  581. stepController.get('content').filterProperty('isSelected', true).forEach(function (_service) {
  582. var client = serviceComponents.filterProperty('service_name', _service.serviceName).findProperty('isClient', true);
  583. if (client) {
  584. clients.pushObject({
  585. component_name: client.component_name,
  586. display_name: client.display_name
  587. });
  588. }
  589. }, this);
  590. App.db.setClientsForSelectedServices(clients);
  591. this.set('content.clients', clients);
  592. console.log("InstallerController.saveClients: saved list ", clients);
  593. },
  594. /**
  595. * Load HostToMasterComponent array
  596. */
  597. loadHostToMasterComponent: function () {
  598. var list = App.db.getHostToMasterComponent();
  599. this.set('content.hostToMasterComponent', list);
  600. console.log("InstallerController.loadHostToMasterComponent: loaded list ", list);
  601. },
  602. /**
  603. * Load data for all steps until <code>current step</code>
  604. */
  605. loadAllPriorSteps: function () {
  606. var step = this.get('currentStep');
  607. switch (step) {
  608. case '10':
  609. case '9':
  610. case '8':
  611. case '7':
  612. this.loadServiceConfigProperties();
  613. case '6':
  614. this.loadSlaveComponentHosts();
  615. case '5':
  616. this.loadMasterComponentHosts();
  617. this.loadHostToMasterComponent();
  618. this.loadConfirmedHosts();
  619. case '4':
  620. this.loadServices();
  621. this.loadClients();
  622. case '3':
  623. this.loadConfirmedHosts();
  624. case '2':
  625. this.loadInstallOptions();
  626. case '1':
  627. this.loadClusterInfo();
  628. }
  629. },
  630. /**
  631. * Generate serviceComponents as pr the stack definition and save it to localdata
  632. * called form stepController step4WizardController
  633. */
  634. loadComponents: function (stepController) {
  635. var self = this;
  636. var method = 'GET';
  637. var url = (App.testMode) ? '/data/wizard/stack/hdp/version0.1.json' : '/api/stacks/HDP/version/1.2.0'; // TODO: get this url from the stack selected by the user in Install Options page
  638. $.ajax({
  639. type: method,
  640. url: url,
  641. async: false,
  642. dataType: 'text',
  643. timeout: 5000,
  644. success: function (data) {
  645. var jsonData = jQuery.parseJSON(data);
  646. console.log("TRACE: STep5 -> In success function for the getServiceComponents call");
  647. console.log("TRACE: STep5 -> value of the url is: " + url);
  648. var serviceComponents = [];
  649. jsonData.services.forEach(function (_service) {
  650. }, this);
  651. stepController.set('components', jsonData.services);
  652. console.log('TRACE: service components: ' + JSON.stringify(stepController.get('components')));
  653. },
  654. error: function (request, ajaxOptions, error) {
  655. console.log("TRACE: STep5 -> In error function for the getServiceComponents call");
  656. console.log("TRACE: STep5 -> value of the url is: " + url);
  657. console.log("TRACE: STep5 -> error code status is: " + request.status);
  658. console.log('Step8: Error message is: ' + request.responseText);
  659. },
  660. statusCode: require('data/statusCodes')
  661. });
  662. },
  663. loadAdvancedConfigs: function () {
  664. App.db.getSelectedServiceNames().forEach(function (_serviceName) {
  665. this.loadAdvancedConfig(_serviceName);
  666. }, this);
  667. },
  668. /**
  669. * Generate serviceProperties save it to localdata
  670. * called form stepController step6WizardController
  671. */
  672. loadAdvancedConfig: function (serviceName) {
  673. var self = this;
  674. var url = (App.testMode) ? '/data/wizard/stack/hdp/version01/' + serviceName + '.json' : '/api/stacks/HDP/version/1.2.0/services/' + serviceName; // TODO: get this url from the stack selected by the user in Install Options page
  675. var method = 'GET';
  676. $.ajax({
  677. type: method,
  678. url: url,
  679. async: false,
  680. dataType: 'text',
  681. timeout: 5000,
  682. success: function (data) {
  683. var jsonData = jQuery.parseJSON(data);
  684. console.log("TRACE: Step6 submit -> In success function for the loadAdvancedConfig call");
  685. console.log("TRACE: Step6 submit -> value of the url is: " + url);
  686. var serviceComponents = jsonData.properties;
  687. serviceComponents.setEach('serviceName', serviceName);
  688. var configs;
  689. if (App.db.getAdvancedServiceConfig()) {
  690. configs = App.db.getAdvancedServiceConfig();
  691. } else {
  692. configs = [];
  693. }
  694. configs = configs.concat(serviceComponents);
  695. self.set('content.advancedServiceConfig', configs);
  696. App.db.setAdvancedServiceConfig(configs);
  697. console.log('TRACE: servicename: ' + serviceName);
  698. },
  699. error: function (request, ajaxOptions, error) {
  700. console.log("TRACE: STep6 submit -> In error function for the loadAdvancedConfig call");
  701. console.log("TRACE: STep6 submit-> value of the url is: " + url);
  702. console.log("TRACE: STep6 submit-> error code status is: " + request.status);
  703. console.log('Step6 submit: Error message is: ' + request.responseText);
  704. },
  705. statusCode: require('data/statusCodes')
  706. });
  707. },
  708. /**
  709. * Generate clients list for selected services and save it to model
  710. * called form stepController step8WizardController or step9WizardController
  711. */
  712. installServices: function () {
  713. var self = this;
  714. var clusterName = this.get('content.cluster.name');
  715. var url = (App.testMode) ? '/data/wizard/deploy/poll_1.json' : '/api/clusters/' + clusterName + '/services?state=INIT';
  716. var method = (App.testMode) ? 'GET' : 'PUT';
  717. var data = '{"ServiceInfo": {"state": "INSTALLED"}}';
  718. $.ajax({
  719. type: method,
  720. url: url,
  721. data: data,
  722. async: false,
  723. dataType: 'text',
  724. timeout: 5000,
  725. success: function (data) {
  726. var jsonData = jQuery.parseJSON(data);
  727. var installSartTime = new Date().getTime();
  728. console.log("TRACE: In success function for the installService call");
  729. console.log("TRACE: value of the url is: " + url);
  730. if (jsonData) {
  731. var requestId = jsonData.href.match(/.*\/(.*)$/)[1];
  732. console.log('requestId is: ' + requestId);
  733. var clusterStatus = {
  734. status: 'PENDING',
  735. requestId: requestId,
  736. isInstallError: false,
  737. isCompleted: false,
  738. installStartTime: installSartTime
  739. };
  740. self.saveClusterStatus(clusterStatus);
  741. } else {
  742. console.log('ERROR: Error occurred in parsing JSON data');
  743. }
  744. },
  745. error: function (request, ajaxOptions, error) {
  746. console.log("TRACE: STep8 -> In error function for the installService call");
  747. console.log("TRACE: STep8 -> value of the url is: " + url);
  748. console.log("TRACE: STep8 -> error code status is: " + request.status);
  749. console.log('Step8: Error message is: ' + request.responseText);
  750. var clusterStatus = {
  751. status: 'PENDING',
  752. isInstallError: true,
  753. isCompleted: false
  754. };
  755. self.saveClusterStatus(clusterStatus);
  756. },
  757. statusCode: require('data/statusCodes')
  758. });
  759. }
  760. });