installer.js 26 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848
  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. masterComponentHosts: null,
  189. serviceConfigProperties: null,
  190. advancedServiceConfig: null,
  191. controllerName: 'installerController'
  192. }),
  193. /**
  194. * Load clusterInfo(step1) to model
  195. */
  196. loadClusterInfo: function () {
  197. var cStatus = App.db.getClusterStatus() || {status: "", isCompleted: false};
  198. var cluster = {
  199. name: App.db.getClusterName() || "",
  200. status: cStatus.status,
  201. isCompleted: cStatus.isCompleted,
  202. requestId: cStatus.requestId,
  203. installStartTime: cStatus.installStartTime,
  204. installTime: cStatus.installTime
  205. };
  206. this.set('content.cluster', cluster);
  207. console.log("InstallerController:loadClusterInfo: loaded data ", cluster);
  208. },
  209. /**
  210. * Save all info about cluster to model
  211. * @param stepController Step1WizardController
  212. */
  213. saveClusterInfo: function (stepController) {
  214. var cluster = stepController.get('content.cluster');
  215. var clusterStatus = {
  216. status: cluster.status,
  217. isCompleted: cluster.isCompleted
  218. };
  219. App.db.setClusterName(cluster.name);
  220. App.db.setClusterStatus(clusterStatus);
  221. console.log("InstallerController:saveClusterInfo: saved data ", 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. * bootRequestId: ''
  259. * }
  260. */
  261. loadInstallOptions: function () {
  262. if (!this.content.hosts) {
  263. this.content.hosts = Em.Object.create();
  264. }
  265. //TODO : rewire it as model. or not :)
  266. var hostsInfo = Em.Object.create();
  267. hostsInfo.hostNames = App.db.getAllHostNames() || ''; //empty string if undefined
  268. //TODO : should we check installType for add host wizard????
  269. var installType = App.db.getInstallType();
  270. //false if installType not equals 'manual'
  271. hostsInfo.manualInstall = installType && installType.installType === 'manual' || false;
  272. var softRepo = App.db.getSoftRepo();
  273. if (softRepo && softRepo.repoType === 'local') {
  274. hostsInfo.localRepo = true;
  275. hostsInfo.localRepopath = softRepo.repoPath;
  276. } else {
  277. hostsInfo.localRepo = false;
  278. hostsInfo.localRepoPath = '';
  279. }
  280. hostsInfo.bootRequestId = App.db.getBootRequestId() || null;
  281. hostsInfo.sshKey = '';
  282. hostsInfo.passphrase = '';
  283. hostsInfo.confirmPassphrase = '';
  284. this.set('content.hosts', hostsInfo);
  285. console.log("InstallerController:loadHosts: loaded data ", hostsInfo);
  286. },
  287. /**
  288. * Save data, which user filled, to main controller
  289. * @param stepController App.WizardStep2Controller
  290. */
  291. saveHosts: function (stepController) {
  292. //TODO: put data to content.hosts and only then save it)
  293. //App.db.setBootStatus(false);
  294. App.db.setAllHostNames(stepController.get('hostNames'));
  295. App.db.setBootRequestId(stepController.get('bootRequestId'));
  296. App.db.setHosts(stepController.getHostInfo());
  297. if (stepController.get('manualInstall') === false) {
  298. App.db.setInstallType({installType: 'ambari' });
  299. } else {
  300. App.db.setInstallType({installType: 'manual' });
  301. }
  302. if (stepController.get('localRepo') === false) {
  303. App.db.setSoftRepo({ 'repoType': 'remote', 'repoPath': null});
  304. } else {
  305. App.db.setSoftRepo({ 'repoType': 'local', 'repoPath': stepController.get('localRepoPath') });
  306. }
  307. },
  308. /**
  309. * Remove host from model. Used at <code>Confirm hosts(step2)</code> step
  310. * @param hosts Array of hosts, which we want to delete
  311. */
  312. removeHosts: function (hosts) {
  313. //todo Replace this code with real logic
  314. App.db.removeHosts(hosts);
  315. },
  316. /**
  317. * Save data, which user filled, to main controller
  318. * @param stepController App.WizardStep3Controller
  319. */
  320. saveConfirmedHosts: function (stepController) {
  321. var hostInfo = {};
  322. stepController.get('content.hostsInfo').forEach(function (_host) {
  323. hostInfo[_host.name] = {
  324. name: _host.name,
  325. cpu: _host.cpu,
  326. memory: _host.memory,
  327. bootStatus: _host.bootStatus,
  328. isInstalled: false
  329. };
  330. });
  331. console.log('installerController:saveConfirmedHosts: save hosts ', hostInfo);
  332. App.db.setHosts(hostInfo);
  333. this.set('content.hostsInfo', hostInfo);
  334. },
  335. /**
  336. * Load confirmed hosts.
  337. * Will be used at <code>Assign Masters(step5)</code> step
  338. */
  339. loadConfirmedHosts: function () {
  340. this.set('content.hostsInfo', App.db.getHosts() || []);
  341. },
  342. /**
  343. * Save data after installation to main controller
  344. * @param stepController App.WizardStep9Controller
  345. */
  346. saveInstalledHosts: function (stepController) {
  347. var hosts = stepController.get('hosts');
  348. var hostInfo = App.db.getHosts();
  349. for (var index in hostInfo) {
  350. var host = hosts.findProperty('name', hostInfo[index].name);
  351. if (host) {
  352. hostInfo[index].status = host.status;
  353. hostInfo[index].logTasks = host.logTasks;
  354. hostInfo[index].tasks = host.tasks;
  355. hostInfo[index].message = host.message;
  356. hostInfo[index].progress = host.progress;
  357. }
  358. }
  359. App.db.setHosts(hostInfo);
  360. this.set('content.hostsInfo', hostInfo);
  361. },
  362. /**
  363. * Remove all data for hosts
  364. */
  365. clearHosts: function () {
  366. var hosts = this.get('content').get('hosts');
  367. if (hosts) {
  368. hosts.set('hostNames', '');
  369. hosts.set('manualInstall', false);
  370. hosts.set('localRepo', '');
  371. hosts.set('localRepopath', '');
  372. hosts.set('sshKey', '');
  373. hosts.set('passphrase', '');
  374. hosts.set('confirmPassphrase', '');
  375. }
  376. App.db.setHosts(null);
  377. App.db.setAllHostNames(null);
  378. },
  379. /**
  380. * Load services data. Will be used at <code>Select services(step4)</code> step
  381. */
  382. loadServices: function () {
  383. var servicesInfo = App.db.getService();
  384. servicesInfo.forEach(function (item, index) {
  385. servicesInfo[index] = Em.Object.create(item);
  386. servicesInfo[index].isInstalled = false;
  387. });
  388. this.set('content.services', servicesInfo);
  389. console.log('installerController.loadServices: loaded data ', servicesInfo);
  390. console.log('selected services ', servicesInfo.filterProperty('isSelected', true).mapProperty('serviceName'));
  391. },
  392. /**
  393. * Save data to model
  394. * @param stepController App.WizardStep4Controller
  395. */
  396. saveServices: function (stepController) {
  397. var serviceNames = [];
  398. App.db.setService(stepController.get('content'));
  399. stepController.filterProperty('isSelected', true).forEach(function (item) {
  400. serviceNames.push(item.serviceName);
  401. });
  402. this.set('content.selectedServiceNames', serviceNames);
  403. App.db.setSelectedServiceNames(serviceNames);
  404. console.log('installerController.saveServices: saved data ', serviceNames);
  405. },
  406. /**
  407. * Save Master Component Hosts data to Main Controller
  408. * @param stepController App.WizardStep5Controller
  409. */
  410. saveMasterComponentHosts: function (stepController) {
  411. var obj = stepController.get('selectedServicesMasters');
  412. var masterComponentHosts = [];
  413. obj.forEach(function (_component) {
  414. masterComponentHosts.push({
  415. display_name: _component.get('display_name'),
  416. component: _component.get('component_name'),
  417. hostName: _component.get('selectedHost'),
  418. serviceId: _component.get('serviceId'),
  419. isInstalled: false
  420. });
  421. });
  422. console.log("installerController.saveMasterComponentHosts: saved hosts ", masterComponentHosts);
  423. App.db.setMasterComponentHosts(masterComponentHosts);
  424. this.set('content.masterComponentHosts', masterComponentHosts);
  425. },
  426. /**
  427. * Load master component hosts data for using in required step controllers
  428. */
  429. loadMasterComponentHosts: function () {
  430. var masterComponentHosts = App.db.getMasterComponentHosts() || [];
  431. this.set("content.masterComponentHosts", masterComponentHosts);
  432. console.log("InstallerController.loadMasterComponentHosts: loaded hosts ", masterComponentHosts);
  433. },
  434. /**
  435. * Save slaveHostComponents to main controller
  436. * @param stepController
  437. */
  438. saveSlaveComponentHosts: function (stepController) {
  439. var hosts = stepController.get('hosts');
  440. var isMrSelected = stepController.get('isMrSelected');
  441. var isHbSelected = stepController.get('isHbSelected');
  442. var dataNodeHosts = [];
  443. var taskTrackerHosts = [];
  444. var regionServerHosts = [];
  445. var clientHosts = [];
  446. hosts.forEach(function (host) {
  447. if (host.get('isDataNode')) {
  448. dataNodeHosts.push({
  449. hostName: host.hostName,
  450. group: 'Default',
  451. isInstalled: false
  452. });
  453. }
  454. if (isMrSelected && host.get('isTaskTracker')) {
  455. taskTrackerHosts.push({
  456. hostName: host.hostName,
  457. group: 'Default',
  458. isInstalled: false
  459. });
  460. }
  461. if (isHbSelected && host.get('isRegionServer')) {
  462. regionServerHosts.push({
  463. hostName: host.hostName,
  464. group: 'Default',
  465. isInstalled: false
  466. });
  467. }
  468. if (host.get('isClient')) {
  469. clientHosts.pushObject({
  470. hostName: host.hostName,
  471. group: 'Default',
  472. isInstalled: false
  473. });
  474. }
  475. }, this);
  476. var slaveComponentHosts = [];
  477. slaveComponentHosts.push({
  478. componentName: 'DATANODE',
  479. displayName: 'DataNode',
  480. hosts: dataNodeHosts
  481. });
  482. if (isMrSelected) {
  483. slaveComponentHosts.push({
  484. componentName: 'TASKTRACKER',
  485. displayName: 'TaskTracker',
  486. hosts: taskTrackerHosts
  487. });
  488. }
  489. if (isHbSelected) {
  490. slaveComponentHosts.push({
  491. componentName: 'HBASE_REGIONSERVER',
  492. displayName: 'RegionServer',
  493. hosts: regionServerHosts
  494. });
  495. }
  496. slaveComponentHosts.pushObject({
  497. componentName: 'CLIENT',
  498. displayName: 'client',
  499. hosts: clientHosts
  500. });
  501. App.db.setSlaveComponentHosts(slaveComponentHosts);
  502. this.set('content.slaveComponentHosts', slaveComponentHosts);
  503. console.log("InstallerController.saveSlaveComponentHosts: saved hosts ", slaveComponentHosts);
  504. },
  505. /**
  506. * Load master component hosts data for using in required step controllers
  507. */
  508. loadSlaveComponentHosts: function () {
  509. var slaveComponentHosts = App.db.getSlaveComponentHosts() || null;
  510. this.set("content.slaveComponentHosts", slaveComponentHosts);
  511. console.log("InstallerController.loadSlaveComponentHosts: loaded hosts ", slaveComponentHosts);
  512. },
  513. /**
  514. * Save config properties
  515. * @param stepController Step7WizardController
  516. */
  517. saveServiceConfigProperties: function (stepController) {
  518. var serviceConfigProperties = [];
  519. stepController.get('stepConfigs').forEach(function (_content) {
  520. _content.get('configs').forEach(function (_configProperties) {
  521. var displayType = _configProperties.get('displayType');
  522. if (displayType === 'directories' || displayType === 'directory') {
  523. var value = _configProperties.get('value').split(/\s+/g).join(',');
  524. _configProperties.set('value', value);
  525. }
  526. var configProperty = {
  527. id: _configProperties.get('id'),
  528. name: _configProperties.get('name'),
  529. value: _configProperties.get('value'),
  530. defaultValue: _configProperties.get('defaultValue'),
  531. service: _configProperties.get('serviceName'),
  532. filename: _configProperties.get('filename')
  533. };
  534. serviceConfigProperties.push(configProperty);
  535. }, this);
  536. }, this);
  537. App.db.setServiceConfigProperties(serviceConfigProperties);
  538. this.set('content.serviceConfigProperties', serviceConfigProperties);
  539. },
  540. /**
  541. * Load serviceConfigProperties to model
  542. */
  543. loadServiceConfigProperties: function () {
  544. var serviceConfigProperties = App.db.getServiceConfigProperties();
  545. this.set('content.serviceConfigProperties', serviceConfigProperties);
  546. console.log("InstallerController.loadServiceConfigProperties: loaded config ", serviceConfigProperties);
  547. this.set('content.advancedServiceConfig', App.db.getAdvancedServiceConfig());
  548. },
  549. /**
  550. * Load information about hosts with clients components
  551. */
  552. loadClients: function () {
  553. var clients = App.db.getClientsForSelectedServices();
  554. this.set('content.clients', clients);
  555. console.log("InstallerController.loadClients: loaded list ", clients);
  556. },
  557. /**
  558. * Generate clients list for selected services and save it to model
  559. * @param stepController step4WizardController
  560. */
  561. saveClients: function (stepController) {
  562. var clients = [];
  563. var serviceComponents = require('data/service_components');
  564. stepController.get('content').filterProperty('isSelected', true).forEach(function (_service) {
  565. var client = serviceComponents.filterProperty('service_name', _service.serviceName).findProperty('isClient', true);
  566. if (client) {
  567. clients.pushObject({
  568. component_name: client.component_name,
  569. display_name: client.display_name,
  570. isInstalled: false
  571. });
  572. }
  573. }, this);
  574. App.db.setClientsForSelectedServices(clients);
  575. this.set('content.clients', clients);
  576. console.log("InstallerController.saveClients: saved list ", clients);
  577. },
  578. /**
  579. * Load data for all steps until <code>current step</code>
  580. */
  581. loadAllPriorSteps: function () {
  582. var step = this.get('currentStep');
  583. switch (step) {
  584. case '10':
  585. case '9':
  586. case '8':
  587. case '7':
  588. this.loadServiceConfigProperties();
  589. case '6':
  590. this.loadSlaveComponentHosts();
  591. this.loadClients();
  592. case '5':
  593. this.loadMasterComponentHosts();
  594. this.loadConfirmedHosts();
  595. case '4':
  596. this.loadServices();
  597. case '3':
  598. this.loadConfirmedHosts();
  599. case '2':
  600. this.loadInstallOptions();
  601. case '1':
  602. this.loadClusterInfo();
  603. }
  604. },
  605. /**
  606. * Generate serviceComponents as pr the stack definition and save it to localdata
  607. * called form stepController step4WizardController
  608. */
  609. loadComponents: function (stepController) {
  610. var self = this;
  611. var method = 'GET';
  612. var url = (App.testMode) ? '/data/wizard/stack/hdp/version0.1.json' : App.apiPrefix + '/stacks/HDP/version/1.2.0'; // TODO: get this url from the stack selected by the user in Install Options page
  613. $.ajax({
  614. type: method,
  615. url: url,
  616. async: false,
  617. dataType: 'text',
  618. timeout: App.timeout,
  619. success: function (data) {
  620. var jsonData = jQuery.parseJSON(data);
  621. console.log("TRACE: STep5 -> In success function for the getServiceComponents call");
  622. console.log("TRACE: STep5 -> value of the url is: " + url);
  623. var serviceComponents = [];
  624. jsonData.services.forEach(function (_service) {
  625. }, this);
  626. stepController.set('components', jsonData.services);
  627. console.log('TRACE: service components: ' + JSON.stringify(stepController.get('components')));
  628. },
  629. error: function (request, ajaxOptions, error) {
  630. console.log("TRACE: STep5 -> In error function for the getServiceComponents call");
  631. console.log("TRACE: STep5 -> value of the url is: " + url);
  632. console.log("TRACE: STep5 -> error code status is: " + request.status);
  633. console.log('Step8: Error message is: ' + request.responseText);
  634. },
  635. statusCode: require('data/statusCodes')
  636. });
  637. },
  638. loadAdvancedConfigs: function () {
  639. var configs = [];
  640. App.db.getSelectedServiceNames().forEach(function (_serviceName) {
  641. var serviceComponents = this.loadAdvancedConfig(_serviceName);
  642. configs = configs.concat(serviceComponents);
  643. }, this);
  644. this.set('content.advancedServiceConfig', configs);
  645. App.db.setAdvancedServiceConfig(configs);
  646. },
  647. /**
  648. * Generate serviceProperties save it to localdata
  649. * called form stepController step6WizardController
  650. */
  651. loadAdvancedConfig: function (serviceName) {
  652. var self = this;
  653. var url = (App.testMode) ? '/data/wizard/stack/hdp/version01/' + serviceName + '.json' : App.apiPrefix + '/stacks/HDP/version/1.2.0/services/' + serviceName; // TODO: get this url from the stack selected by the user in Install Options page
  654. var method = 'GET';
  655. var serviceComponents;
  656. $.ajax({
  657. type: method,
  658. url: url,
  659. async: false,
  660. dataType: 'text',
  661. timeout: App.timeout,
  662. success: function (data) {
  663. var jsonData = jQuery.parseJSON(data);
  664. console.log("TRACE: Step6 submit -> In success function for the loadAdvancedConfig call");
  665. console.log("TRACE: Step6 submit -> value of the url is: " + url);
  666. serviceComponents = jsonData.properties;
  667. serviceComponents.setEach('serviceName', serviceName);
  668. console.log('TRACE: servicename: ' + serviceName);
  669. },
  670. error: function (request, ajaxOptions, error) {
  671. console.log("TRACE: STep6 submit -> In error function for the loadAdvancedConfig call");
  672. console.log("TRACE: STep6 submit-> value of the url is: " + url);
  673. console.log("TRACE: STep6 submit-> error code status is: " + request.status);
  674. console.log('Step6 submit: Error message is: ' + request.responseText);
  675. },
  676. statusCode: require('data/statusCodes')
  677. });
  678. return serviceComponents;
  679. },
  680. /**
  681. * Generate clients list for selected services and save it to model
  682. * called form stepController step8WizardController or step9WizardController
  683. */
  684. installServices: function (isRetry) {
  685. if(!isRetry && this.get('content.cluster.requestId')){
  686. return;
  687. }
  688. var self = this;
  689. var clusterName = this.get('content.cluster.name');
  690. var url = (App.testMode) ? '/data/wizard/deploy/poll_1.json' : App.apiPrefix + '/clusters/' + clusterName + '/services?state=INIT';
  691. var method = (App.testMode) ? 'GET' : 'PUT';
  692. var data = '{"ServiceInfo": {"state": "INSTALLED"}}';
  693. $.ajax({
  694. type: method,
  695. url: url,
  696. data: data,
  697. async: false,
  698. dataType: 'text',
  699. timeout: App.timeout,
  700. success: function (data) {
  701. var jsonData = jQuery.parseJSON(data);
  702. var installStartTime = new Date().getTime();
  703. console.log("TRACE: In success function for the installService call");
  704. console.log("TRACE: value of the url is: " + url);
  705. if (jsonData) {
  706. var requestId = jsonData.href.match(/.*\/(.*)$/)[1];
  707. console.log('requestId is: ' + requestId);
  708. var clusterStatus = {
  709. status: 'PENDING',
  710. requestId: requestId,
  711. isInstallError: false,
  712. isCompleted: false,
  713. installStartTime: installStartTime
  714. };
  715. self.saveClusterStatus(clusterStatus);
  716. } else {
  717. console.log('ERROR: Error occurred in parsing JSON data');
  718. }
  719. },
  720. error: function (request, ajaxOptions, error) {
  721. console.log("TRACE: In error function for the installService call");
  722. console.log("TRACE: value of the url is: " + url);
  723. console.log("TRACE: error code status is: " + request.status);
  724. console.log('Error message is: ' + request.responseText);
  725. var clusterStatus = {
  726. status: 'PENDING',
  727. isInstallError: false,
  728. isCompleted: false
  729. };
  730. self.saveClusterStatus(clusterStatus);
  731. },
  732. statusCode: require('data/statusCodes')
  733. });
  734. },
  735. /**
  736. * Clear all temporary data
  737. */
  738. finish: function () {
  739. this.setCurrentStep('1', false);
  740. App.db.setService(undefined); //not to use this data at AddService page
  741. App.db.setHosts(undefined);
  742. App.db.setMasterComponentHosts(undefined);
  743. App.db.setSlaveComponentHosts(undefined);
  744. App.db.setClusterStatus(undefined);
  745. App.db.setAllHostNames(undefined);
  746. }
  747. });