reassign_controller.js 9.5 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300
  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.ReassignMasterController = App.WizardController.extend({
  20. name: 'reassignMasterController',
  21. totalSteps: 7,
  22. /**
  23. * Used for hiding back button in wizard
  24. */
  25. hideBackButton: true,
  26. /**
  27. * All wizards data will be stored in this variable
  28. *
  29. * cluster - cluster name
  30. * installOptions - ssh key, repo info, etc.
  31. * services - services list
  32. * hosts - list of selected hosts
  33. * slaveComponentHosts, - info about slave hosts
  34. * masterComponentHosts - info about master hosts
  35. * config??? - to be described later
  36. */
  37. content: Em.Object.create({
  38. cluster: null,
  39. hosts: null,
  40. installOptions: null,
  41. services: null,
  42. slaveComponentHosts: null,
  43. masterComponentHosts: null,
  44. serviceConfigProperties: null,
  45. advancedServiceConfig: null,
  46. controllerName: 'reassignMasterController',
  47. serviceName: 'MISC',
  48. hdfsUser: "hdfs",
  49. group: "hadoop",
  50. reassign: null,
  51. componentsWithManualCommands: ['NAMENODE', 'SECONDARY_NAMENODE', 'OOZIE_SERVER', 'MYSQL_SERVER', 'APP_TIMELINE_SERVER'],
  52. hasManualSteps: false,
  53. hasCheckDBStep: false,
  54. componentsWithCheckDBStep: ['HIVE_METASTORE', 'HIVE_SERVER', 'OOZIE_SERVER'],
  55. componentsWithoutSecurityConfigs: ['MYSQL_SERVER']
  56. }),
  57. /**
  58. * Wizard properties in local storage, which should be cleaned right after wizard has been finished
  59. */
  60. dbPropertiesToClean: [
  61. 'cluster',
  62. 'hosts',
  63. 'installOptions',
  64. 'masterComponentHosts',
  65. 'serviceComponents',
  66. 'masterComponent',
  67. 'currentStep',
  68. 'reassignHosts',
  69. 'tasksStatuses',
  70. 'tasksRequestIds',
  71. 'requestIds'
  72. ],
  73. addManualSteps: function () {
  74. this.set('content.hasManualSteps', this.get('content.componentsWithManualCommands').contains(this.get('content.reassign.component_name')));
  75. }.observes('content.reassign.component_name'),
  76. addCheckDBStep: function () {
  77. this.set('content.hasCheckDBStep', this.get('content.componentsWithCheckDBStep').contains(this.get('content.reassign.component_name')));
  78. }.observes('content.reassign.component_name'),
  79. /**
  80. * Load tasks statuses for step5 of Reassign Master Wizard to restore installation
  81. */
  82. loadTasksStatuses: function () {
  83. var statuses = App.db.getReassignTasksStatuses();
  84. this.set('content.tasksStatuses', statuses);
  85. console.log('ReassignMasterController.loadTasksStatuses: loaded statuses', statuses);
  86. },
  87. /**
  88. * save status of the cluster.
  89. * @param clusterStatus object with status,requestId fields.
  90. */
  91. saveClusterStatus: function (clusterStatus) {
  92. var oldStatus = this.toObject(this.get('content.cluster'));
  93. clusterStatus = jQuery.extend(oldStatus, clusterStatus);
  94. if (clusterStatus.requestId) {
  95. clusterStatus.requestId.forEach(function (requestId) {
  96. if (clusterStatus.oldRequestsId.indexOf(requestId) === -1) {
  97. clusterStatus.oldRequestsId.push(requestId)
  98. }
  99. }, this);
  100. }
  101. this.set('content.cluster', clusterStatus);
  102. this.save('cluster');
  103. },
  104. /**
  105. * Save Master Component Hosts data to Main Controller
  106. * @param stepController App.WizardStep5Controller
  107. */
  108. saveMasterComponentHosts: function (stepController) {
  109. var obj = stepController.get('selectedServicesMasters');
  110. var masterComponentHosts = [];
  111. obj.forEach(function (_component) {
  112. masterComponentHosts.push({
  113. display_name: _component.get('display_name'),
  114. component: _component.get('component_name'),
  115. hostName: _component.get('selectedHost'),
  116. serviceId: _component.get('serviceId'),
  117. isInstalled: true
  118. });
  119. });
  120. App.db.setMasterComponentHosts(masterComponentHosts);
  121. this.set('content.masterComponentHosts', masterComponentHosts);
  122. this.setDBProperty('masterComponentHosts', masterComponentHosts);
  123. },
  124. loadComponentToReassign: function () {
  125. var masterComponent = App.db.getMasterToReassign();
  126. if (masterComponent) {
  127. this.set('content.reassign', masterComponent);
  128. }
  129. },
  130. saveComponentToReassign: function (masterComponent) {
  131. var component = {
  132. component_name: masterComponent.get('componentName'),
  133. display_name: masterComponent.get('displayName'),
  134. service_id: masterComponent.get('service.serviceName'),
  135. host_id: masterComponent.get('hostName')
  136. };
  137. App.db.setMasterToReassign(component);
  138. },
  139. saveTasksStatuses: function (statuses) {
  140. App.db.setReassignTasksStatuses(statuses);
  141. this.set('content.tasksStatuses', statuses);
  142. console.log('ReassignMasterController.saveTasksStatuses: saved statuses', statuses);
  143. },
  144. loadTasksRequestIds: function () {
  145. var requestIds = App.db.getReassignTasksRequestIds();
  146. this.set('content.tasksRequestIds', requestIds);
  147. },
  148. saveTasksRequestIds: function (requestIds) {
  149. App.db.setReassignTasksRequestIds(requestIds);
  150. this.set('content.tasksRequestIds', requestIds);
  151. },
  152. loadRequestIds: function () {
  153. var requestIds = App.db.getReassignMasterWizardRequestIds();
  154. this.set('content.requestIds', requestIds);
  155. },
  156. saveRequestIds: function (requestIds) {
  157. App.db.setReassignMasterWizardRequestIds(requestIds);
  158. this.set('content.requestIds', requestIds);
  159. },
  160. saveComponentDir: function (componentDir) {
  161. App.db.setReassignMasterWizardComponentDir(componentDir);
  162. this.set('content.componentDir', componentDir);
  163. },
  164. loadComponentDir: function () {
  165. var componentDir = App.db.getReassignMasterWizardComponentDir();
  166. this.set('content.componentDir', componentDir);
  167. },
  168. saveReassignHosts: function (reassignHosts) {
  169. App.db.setReassignMasterWizardReassignHosts(reassignHosts);
  170. this.set('content.reassignHosts', reassignHosts);
  171. },
  172. loadReassignHosts: function () {
  173. var reassignHosts = App.db.getReassignMasterWizardReassignHosts();
  174. this.set('content.reassignHosts', reassignHosts);
  175. },
  176. saveSecureConfigs: function (secureConfigs) {
  177. this.setDBProperty('secureConfigs', secureConfigs);
  178. this.set('content.secureConfigs', secureConfigs);
  179. },
  180. loadSecureConfigs: function () {
  181. var secureConfigs = this.getDBProperty('secureConfigs');
  182. this.set('content.secureConfigs', secureConfigs);
  183. },
  184. saveServiceProperties: function (properties) {
  185. this.setDBProperty('serviceProperties', properties);
  186. this.set('content.serviceProperties', properties);
  187. },
  188. loadServiceProperties: function () {
  189. var serviceProperties = this.getDBProperty('serviceProperties');
  190. this.set('content.serviceProperties', serviceProperties);
  191. },
  192. saveDatabaseType: function (type) {
  193. this.setDBProperty('databaseType', type);
  194. this.set('content.databaseType', type);
  195. },
  196. loadDatabaseType: function () {
  197. var databaseType = this.getDBProperty('databaseType');
  198. this.set('content.databaseType', databaseType);
  199. var component = this.get('content.reassign.component_name');
  200. if (component === 'OOZIE_SERVER') {
  201. if (this.get('content.hasCheckDBStep') && databaseType && databaseType !== 'derby') {
  202. // components with manual commands
  203. var manual = App.router.reassignMasterController.get('content.componentsWithManualCommands').without('OOZIE_SERVER');
  204. App.router.reassignMasterController.set('content.hasManualSteps', false);
  205. App.router.reassignMasterController.set('content.componentsWithManualCommands', manual);
  206. }
  207. }
  208. },
  209. /**
  210. * Load data for all steps until <code>current step</code>
  211. */
  212. loadAllPriorSteps: function () {
  213. var step = this.get('currentStep');
  214. switch (step) {
  215. case '7':
  216. case '6':
  217. case '5':
  218. this.loadSecureConfigs();
  219. this.loadComponentDir();
  220. case '4':
  221. this.loadTasksStatuses();
  222. this.loadTasksRequestIds();
  223. this.loadRequestIds();
  224. case '3':
  225. this.loadReassignHosts();
  226. case '2':
  227. this.loadServicesFromServer();
  228. this.loadMasterComponentHosts();
  229. this.loadConfirmedHosts();
  230. case '1':
  231. this.loadComponentToReassign();
  232. this.loadDatabaseType();
  233. this.loadServiceProperties();
  234. this.load('cluster');
  235. }
  236. },
  237. /**
  238. * Remove all loaded data.
  239. * Created as copy for App.router.clearAllSteps
  240. */
  241. clearAllSteps: function () {
  242. this.clearInstallOptions();
  243. // clear temporary information stored during the install
  244. this.set('content.cluster', this.getCluster());
  245. },
  246. setCurrentStep: function (currentStep, completed) {
  247. this._super(currentStep, completed);
  248. App.clusterStatus.setClusterStatus({
  249. clusterName: this.get('content.cluster.name'),
  250. wizardControllerName: 'reassignMasterController',
  251. localdb: App.db.data
  252. });
  253. },
  254. /**
  255. * Clear all temporary data
  256. */
  257. finish: function () {
  258. this.clearAllSteps();
  259. this.clearStorageData();
  260. this.resetDbNamespace();
  261. App.router.get('updateController').updateAll();
  262. }
  263. });