app.js 7.8 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265
  1. // Licensed to Cloudera, Inc. under one
  2. // or more contributor license agreements. See the NOTICE file
  3. // distributed with this work for additional information
  4. // regarding copyright ownership. Cloudera, Inc. licenses this file
  5. // to you under the Apache License, Version 2.0 (the
  6. // "License"); you may not use this file except in compliance
  7. // with the License. You may obtain a copy of the License at
  8. //
  9. // http://www.apache.org/licenses/LICENSE-2.0
  10. //
  11. // Unless required by applicable law or agreed to in writing, software
  12. // distributed under the License is distributed on an "AS IS" BASIS,
  13. // WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  14. // See the License for the specific language governing permissions and
  15. // limitations under the License.
  16. var AppViewModel = function()
  17. {
  18. var self = this;
  19. self.station = ko.observable("");
  20. self.pageTitle = ko.observable("");
  21. self.focusModel = ko.observable();
  22. self.cluster = ko.observable("");
  23. self.clusters = ko.observableArray();
  24. API.query('getClusters').done(function(data)
  25. {
  26. app.clusters(data);
  27. });
  28. self.search = new tagsearch();
  29. self.views =
  30. {
  31. tables: new DataTableViewModel({columns:['Table Name', 'Enabled'],el: 'views.tables', reload: function(callback)
  32. {
  33. var d_self = this;
  34. d_self.items.removeAll();
  35. API.queryCluster("getTableList").done(function(data)
  36. {
  37. d_self.items.removeAll(); //need to remove again before callback executes
  38. for(q=0;q<data.length;q++)
  39. {
  40. d_self.items.push(new TableDataRow(data[q]));
  41. }
  42. d_self._el.find('a[data-row-selector=true]').jHueRowSelector();
  43. if(callback!=null)
  44. callback();
  45. });
  46. }}),
  47. tabledata: new SmartViewModel({el: 'views.tabledata', reload: function(callback) //move inside SmartViewModel class?
  48. {
  49. var t_self = this;
  50. function getColumnFamilies()
  51. {
  52. var cols = [];
  53. var cfs = t_self.columnFamilies();
  54. for(var i=0;i<cfs.length;i++)
  55. {
  56. if(cfs[i].enabled())
  57. {
  58. cols.push(cfs[i].name);
  59. }
  60. }
  61. return cols;
  62. }
  63. API.queryTable("getRowQuerySet", JSON.stringify(getColumnFamilies()), ko.toJSON(t_self.querySet())).done(function(data)
  64. {
  65. if(data.length>0)
  66. {
  67. var keys = Object.keys(data);
  68. var items = [];
  69. for(var i=0;i<keys.length;i++)
  70. {
  71. var row = new SmartViewDataRow({items: [], row:data[keys[i]].row, reload:function(options)
  72. {
  73. var self = this;
  74. options = (options == null) ? {} : options;
  75. options = ko.utils.extend({
  76. callback:function(data){},
  77. columns: getColumnFamilies()
  78. }, options);
  79. API.queryTable("getRow", JSON.stringify(options.columns), self.row).done(function(data)
  80. {
  81. self.setItems(data.columns);
  82. callback(data);
  83. self.isLoading(false);
  84. });
  85. }});
  86. row.setItems(data[keys[i]].columns);
  87. items.push(row);
  88. }
  89. t_self.items(items);
  90. }
  91. if(typeof(callback) === 'function')
  92. callback();
  93. $('*[data-toggle="tooltip"]').tooltip();
  94. });
  95. }})
  96. };
  97. }
  98. var app = new AppViewModel();
  99. ko.applyBindings(app);
  100. //routing
  101. routed = false;
  102. routie({
  103. ':cluster/:table/query/:query': function(cluster, table, query)
  104. {
  105. //logGA();
  106. Router.setTable(cluster, table);
  107. Views.render('dataview');
  108. app.station('table');
  109. app.search.cur_input(query);
  110. app.search.evaluate();
  111. routed = true;
  112. },
  113. ':cluster/:table': function(cluster, table)
  114. {
  115. //logGA();
  116. Router.setTable(cluster, table);
  117. app.station('table');
  118. Views.render('dataview');
  119. routed = true;
  120. },
  121. ':cluster': function(cluster)
  122. {
  123. //logGA();
  124. Breadcrumbs.render();
  125. app.station('cluster');
  126. app.cluster(cluster);
  127. app.pageTitle(cluster);
  128. Views.render('clusterview');
  129. app.views.tables.reload();
  130. routed = true;
  131. },
  132. 'error': function()
  133. {
  134. logGA();
  135. routed = true;
  136. },
  137. '': function(){
  138. var redirect = app.clusters.subscribe(function(data)
  139. {
  140. routie(data[0].name);
  141. redirect.dispose();
  142. });
  143. routed = true;
  144. },
  145. '*': function() {
  146. logGA();
  147. resetElements();
  148. if(!routed)
  149. history.back();
  150. routed = false;
  151. }
  152. });
  153. $.fn.renderElement = function(data){utils.renderElement($(this,data))};
  154. $.fn.showIndicator = function()
  155. {
  156. $(this).addClass('isLoading');
  157. }
  158. $.fn.hideIndicator = function()
  159. {
  160. $(this).removeClass('isLoading');
  161. }
  162. $.fn.toggleIndicator = function()
  163. {
  164. $(this).toggleClass('isLoading');
  165. }
  166. function bindSubmit()
  167. {
  168. var self = this;
  169. var data = [];
  170. var hash_cache = {};
  171. $(this).find('.controls > input, .controls > textarea, .controls > ul input').not('input[type=submit]').each(function()
  172. {
  173. if($(this).hasClass('ignore'))
  174. return;
  175. var use_post = $(this).data('use-post');
  176. var submitVal = null;
  177. if($(this).data('subscribe'))
  178. {
  179. var target = $($(this).data('subscribe'));
  180. switch(target[0].tagName)
  181. {
  182. case "UL":
  183. var serialized = {};
  184. target.find('li').each(function()
  185. {
  186. serialized[$(this).find('input')[0].value] = $(this).find('input')[1].value;
  187. });
  188. submitVal = JSON.stringify(serialized);
  189. use_post = true;
  190. break;
  191. }
  192. }
  193. else if($(this).hasClass('serializeHash'))
  194. {
  195. var target = $(this).attr('name');
  196. if(!hash_cache[target])
  197. hash_cache[target] = {};
  198. hash_cache[target][$(this).data(key)] = $(this).val();
  199. }
  200. else
  201. {
  202. submitVal = $(this).val();
  203. //change reload next
  204. }
  205. if(submitVal)
  206. {
  207. if(use_post)
  208. submitVal = "hbase-post-key-" + submitVal;
  209. else
  210. submitVal = prepForTransport(submitVal);
  211. data.push(submitVal);
  212. }
  213. });
  214. $(this).find('input[type=submit]').addClass('disabled').showIndicator();
  215. var ui = app.focusModel();
  216. if(ui)
  217. ui.isLoading(true);
  218. API.queryArray($(this).attr('action'), data).complete(function()
  219. {
  220. $(self).find('input[type=submit]').removeClass('disabled').hideIndicator();
  221. if(ui)
  222. ui.isLoading(false);
  223. }).success(function()
  224. {
  225. if(ui)
  226. app.focusModel().reload();
  227. $(self).modal('hide').trigger('reset');
  228. });
  229. return false;
  230. }
  231. $('form.ajaxSubmit').submit(bindSubmit);
  232. $('a.action_addColumn').click(function()
  233. {
  234. $(this).parent().find("ul").append("<li><input type=\"text\" name=\"table_columns\" placeholder = \"family:column_name\"/></li>")
  235. });
  236. $('a.action_addColumnValue').click(function()
  237. {
  238. $(this).parent().find("ul").append("<li><input type=\"text\" name=\"column_values\" class=\"ignore\" placeholder = \"family:column_name\"/> <input type=\"text\" name=\"column_values\" class=\"ignore\" placeholder = \"cell_value\"/></li>")
  239. });
  240. var konami = [38, 38, 40, 40, 37, 39, 37, 39, 66, 65, 13];
  241. var konami_index = 0;
  242. $(window).keydown(function(ev)
  243. {
  244. if(ev.keyCode == konami[konami_index])
  245. konami_index++;
  246. else
  247. konami_index = 0;
  248. if(konami_index >= konami.length)
  249. document["\x77\x72\x69\x74\x65"]("\x3C\x63\x65\x6E\x74\x65\x72\x3E\x3C\x68\x31\x3E\x22\x41\x6C\x6C\x20\x75\x72\x20\x68\x62\x61\x73\x65\x20\x72\x20\x62\x65\x6C\x6F\x6E\x67\x20\x74\x6F\x20\x75\x73\x2E\x22\x3C\x2F\x68\x31\x3E\x3C\x68\x33\x3E\x57\x69\x74\x68\x20\x6D\x75\x63\x68\x20\x6C\x6F\x76\x65\x2C\x20\x3C\x62\x72\x2F\x3E\x3C\x61\x20\x68\x72\x65\x66\x3D\x22\x68\x74\x74\x70\x3A\x2F\x2F\x77\x77\x77\x2E\x74\x77\x69\x74\x74\x65\x72\x2E\x63\x6F\x6D\x2F\x6B\x65\x76\x69\x6E\x76\x65\x72\x73\x65\x22\x3E\x4B\x65\x76\x69\x6E\x3C\x2F\x61\x3E\x3C\x2F\x68\x33\x3E\x3C\x2F\x63\x65\x6E\x74\x65\x72\x3E");
  250. });