storm-core/src/ui/public/js/script.js - storm - Git at Google

 /**
  * Licensed to the Apache Software Foundation (ASF) under one
  * or more contributor license agreements.  See the NOTICE file
  * distributed with this work for additional information
  * regarding copyright ownership.  The ASF licenses this file
  * to you under the Apache License, Version 2.0 (the
  * "License"); you may not use this file except in compliance
  * with the License.  You may obtain a copy of the License at
  *
  * http://www.apache.org/licenses/LICENSE-2.0
  *
  * Unless required by applicable law or agreed to in writing, software
  * distributed under the License is distributed on an "AS IS" BASIS,
  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
 $(function () {
     $(".js-only").show();
 });

 //Add in custom sorting for some data types
 $.extend( $.fn.dataTableExt.oSort, {
   "time-str-pre": function (raw) {
     var s = $(raw).text();
     if (s == "") {
       s = raw;
     }
     if (s.search('All time') != -1) {
       return 1000000000;
     }
     var total = 0;
     $.each(s.split(' '), function (i, v) {
        var amt = parseInt(v);
        if (v.search('ms') != -1) {
          total += amt;
        } else if (v.search('s') != -1) {
          total += amt * 1000;
        } else if (v.search('m') != -1) {
          total += amt * 1000 * 60;
        } else if (v.search('h') != -1) {
          total += amt * 1000 * 60 * 60;
        } else if (v.search('d') != -1) {
          total += amt * 1000 * 60 * 60 * 24;
        }
      });
      return total;
    },
    "time-str-asc": function ( a, b ) {
       return ((a < b) ? -1 : ((a > b) ? 1 : 0));
     },
     "time-str-desc": function ( a, b ) {
       return ((a < b) ? 1 : ((a > b) ? -1 : 0));
     }
 });

 function dtAutoPage(selector, conf) {
   if ($(selector.concat(" tr")).length <= 20) {
     $.extend(conf, {paging: false});
   }
   return $(selector).DataTable(conf);
 }

 function toggleSys() {
     var sys = $.cookies.get('sys') || false;
     sys = !sys;

     var exDate = new Date();
     exDate.setDate(exDate.getDate() + 365);

     $.cookies.set('sys', sys, {'path':'/', 'expiresAt':exDate.toUTCString()});
     window.location = window.location;
 }

 function ensureInt(n) {
     var isInt = /^\d+$/.test(n);
     if (!isInt) {
         alert("'" + n + "' is not integer.");
     }

     return isInt;
 }

 function confirmComponentAction(topologyId, componentId, componentName, action, param, defaultParamValue, paramText, actionText) {
     var opts = {
         type:'POST',
         url:'/api/v1/topology/' + topologyId + '/component/' + componentId + '/' + action
     };
     if (actionText === undefined) {
         actionText = action;
     }
     if (param) {
         var paramValue = prompt('Do you really want to ' + actionText + ' component "' + componentName + '"? ' +
                                   'If yes, please, specify ' + paramText + ':',
                                   defaultParamValue);
         if (paramValue != null && paramValue != "" && ensureInt(paramValue)) {
             opts.url += '/' + paramValue;
         } else {
             return false;
         }
     } else {
         if (typeof defaultParamValue !== 'undefined') {
             opts.url +=  '/' + defaultParamValue;
         }
         if (!confirm('Do you really want to ' + actionText + ' component "' + componentName + '"?')) {
             return false;
         }
     }

     $("input[type=button]").attr("disabled", "disabled");
     $.ajax(opts).always(function () {
         window.location.reload();
     }).fail(function () {
         alert("Error while communicating with Nimbus.");
     });

     return false;
 }

 function confirmAction(id, name, action, param, defaultParamValue, paramText, actionText) {
     var opts = {
         type:'POST',
         url:'/api/v1/topology/' + id + '/' + action
     };
     if (actionText === undefined) {
         actionText = action;
     }
     if (param) {
         var paramValue = prompt('Do you really want to ' + actionText + ' topology "' + name + '"? ' +
                               'If yes, please, specify ' + paramText + ':',
                               defaultParamValue);

         if (paramValue != null && paramValue != "" && ensureInt(paramValue)) {
             opts.url += '/' + paramValue;
         } else {
             return false;
         }
     } else {
         if (typeof defaultParamValue !== 'undefined') {
             opts.url +=  '/' + defaultParamValue;
         }
         if (!confirm('Do you really want to ' + actionText + ' topology "' + name + '"?')) {
             return false;
         }
     }

     $("input[type=button]").attr("disabled", "disabled");
     $.ajax(opts).always(function () {
         window.location.reload();
     }).fail(function () {
         alert("Error while communicating with Nimbus.");
     });

     return false;
 }

 $(function () {
   $('[data-toggle="tooltip"]').tooltip()
 })

 function formatConfigData(data) {
     var mustacheFormattedData = {'config':[]};
     for (var prop in data) {
        if(data.hasOwnProperty(prop)) {
            mustacheFormattedData['config'].push({
                'key': prop,
                'value': JSON.stringify(data[prop])
            });
        }
     }
     return mustacheFormattedData;
 }

 function formatErrorTimeSecs(response){
     var errors = response["componentErrors"];
     for(var i = 0 ; i < errors.length ; i++){
         var time = errors[i]['time'];
         errors[i]['time'] = moment.utc(time).local().format("ddd, DD MMM YYYY HH:mm:ss Z");
     }
     return response;
 }


 function renderToggleSys(div) {
     var sys = $.cookies.get("sys") || false;
     if(sys) {
        div.append("<span data-original-title=\"Use this to toggle inclusion of storm system components.\" class=\"tip right\"><input onclick=\"toggleSys()\" value=\"Hide System Stats\" type=\"button\" class=\"btn btn-default\"></span>");
     } else {
        div.append("<span class=\"tip right\" title=\"Use this to toggle inclusion of storm system components.\"><input onclick=\"toggleSys()\" value=\"Show System Stats\" type=\"button\" class=\"btn btn-default\"></span>");
     }
 }

 function topologyActionJson(id, encodedId, name, status, msgTimeout, debug, samplingPct) {
     var jsonData = {};
     jsonData["id"] = id;
     jsonData["encodedId"] = encodedId;
     jsonData["name"] = name;
     jsonData["msgTimeout"] = msgTimeout;
     jsonData["activateStatus"] = (status === "INACTIVE") ? "enabled" : "disabled";
     jsonData["deactivateStatus"] = (status === "ACTIVE") ? "enabled" : "disabled";
     jsonData["rebalanceStatus"] = (status === "ACTIVE" || status === "INACTIVE" ) ? "enabled" : "disabled";
     jsonData["killStatus"] = (status !== "KILLED") ? "enabled" : "disabled";
     jsonData["startDebugStatus"] = (status === "ACTIVE" && !debug) ? "enabled" : "disabled";
     jsonData["stopDebugStatus"] = (status === "ACTIVE" && debug) ? "enabled" : "disabled";
     jsonData["currentSamplingPct"] = samplingPct;
     return jsonData;
 }

 function componentActionJson(encodedTopologyId, encodedId, componentName, status, debug, samplingPct) {
     var jsonData = {};
     jsonData["encodedTopologyId"] = encodedTopologyId;
     jsonData["encodedId"] = encodedId;
     jsonData["componentName"] = componentName;
     jsonData["startDebugStatus"] = (status === "ACTIVE" && !debug) ? "enabled" : "disabled";
     jsonData["stopDebugStatus"] = (status === "ACTIVE" && debug) ? "enabled" : "disabled";
     jsonData["currentSamplingPct"] = samplingPct;
     return jsonData;
 }

 function topologyActionButton(id,name,status,actionLabel,command,wait,defaultWait) {
     var buttonData = {};
     buttonData["buttonStatus"] = status ;
     buttonData["actionLabel"] = actionLabel;
     buttonData["command"] = command;
     buttonData["isWait"] = wait;
     buttonData["defaultWait"] = defaultWait;
     return buttonData;
 }

 $.blockUI.defaults.css = {
     border: 'none',
     padding: '15px',
     backgroundColor: '#000',
     '-webkit-border-radius': '10px',
     '-moz-border-radius': '10px',
     'border-radius': '10px',
     opacity: .5,
     color: '#fff',margin:0,width:"30%",top:"40%",left:"35%",textAlign:"center"
 };
	/**
	* Licensed to the Apache Software Foundation (ASF) under one
	* or more contributor license agreements. See the NOTICE file
	* distributed with this work for additional information
	* regarding copyright ownership. The ASF licenses this file
	* to you under the Apache License, Version 2.0 (the
	* "License"); you may not use this file except in compliance
	* with the License. You may obtain a copy of the License at
	*
	* http://www.apache.org/licenses/LICENSE-2.0
	*
	* Unless required by applicable law or agreed to in writing, software
	* distributed under the License is distributed on an "AS IS" BASIS,
	* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
	* See the License for the specific language governing permissions and
	* limitations under the License.
	*/
	$(function () {
	$(".js-only").show();
	});

	//Add in custom sorting for some data types
	$.extend( $.fn.dataTableExt.oSort, {
	"time-str-pre": function (raw) {
	var s = $(raw).text();
	if (s == "") {
	s = raw;
	}
	if (s.search('All time') != -1) {
	return 1000000000;
	}
	var total = 0;
	$.each(s.split(' '), function (i, v) {
	var amt = parseInt(v);
	if (v.search('ms') != -1) {
	total += amt;
	} else if (v.search('s') != -1) {
	total += amt * 1000;
	} else if (v.search('m') != -1) {
	total += amt * 1000 * 60;
	} else if (v.search('h') != -1) {
	total += amt * 1000 * 60 * 60;
	} else if (v.search('d') != -1) {
	total += amt * 1000 * 60 * 60 * 24;
	}
	});
	return total;
	},
	"time-str-asc": function ( a, b ) {
	return ((a < b) ? -1 : ((a > b) ? 1 : 0));
	},
	"time-str-desc": function ( a, b ) {
	return ((a < b) ? 1 : ((a > b) ? -1 : 0));
	}
	});

	function dtAutoPage(selector, conf) {
	if ($(selector.concat(" tr")).length <= 20) {
	$.extend(conf, {paging: false});
	}
	return $(selector).DataTable(conf);
	}

	function toggleSys() {
	var sys = $.cookies.get('sys') \|\| false;
	sys = !sys;

	var exDate = new Date();
	exDate.setDate(exDate.getDate() + 365);

	$.cookies.set('sys', sys, {'path':'/', 'expiresAt':exDate.toUTCString()});
	window.location = window.location;
	}

	function ensureInt(n) {
	var isInt = /^\d+$/.test(n);
	if (!isInt) {
	alert("'" + n + "' is not integer.");
	}

	return isInt;
	}

	function confirmComponentAction(topologyId, componentId, componentName, action, param, defaultParamValue, paramText, actionText) {
	var opts = {
	type:'POST',
	url:'/api/v1/topology/' + topologyId + '/component/' + componentId + '/' + action
	};
	if (actionText === undefined) {
	actionText = action;
	}
	if (param) {
	var paramValue = prompt('Do you really want to ' + actionText + ' component "' + componentName + '"? ' +
	'If yes, please, specify ' + paramText + ':',
	defaultParamValue);
	if (paramValue != null && paramValue != "" && ensureInt(paramValue)) {
	opts.url += '/' + paramValue;
	} else {
	return false;
	}
	} else {
	if (typeof defaultParamValue !== 'undefined') {
	opts.url += '/' + defaultParamValue;
	}
	if (!confirm('Do you really want to ' + actionText + ' component "' + componentName + '"?')) {
	return false;
	}
	}

	$("input[type=button]").attr("disabled", "disabled");
	$.ajax(opts).always(function () {
	window.location.reload();
	}).fail(function () {
	alert("Error while communicating with Nimbus.");
	});

	return false;
	}

	function confirmAction(id, name, action, param, defaultParamValue, paramText, actionText) {
	var opts = {
	type:'POST',
	url:'/api/v1/topology/' + id + '/' + action
	};
	if (actionText === undefined) {
	actionText = action;
	}
	if (param) {
	var paramValue = prompt('Do you really want to ' + actionText + ' topology "' + name + '"? ' +
	'If yes, please, specify ' + paramText + ':',
	defaultParamValue);

	if (paramValue != null && paramValue != "" && ensureInt(paramValue)) {
	opts.url += '/' + paramValue;
	} else {
	return false;
	}
	} else {
	if (typeof defaultParamValue !== 'undefined') {
	opts.url += '/' + defaultParamValue;
	}
	if (!confirm('Do you really want to ' + actionText + ' topology "' + name + '"?')) {
	return false;
	}
	}

	$("input[type=button]").attr("disabled", "disabled");
	$.ajax(opts).always(function () {
	window.location.reload();
	}).fail(function () {
	alert("Error while communicating with Nimbus.");
	});

	return false;
	}

	$(function () {
	$('[data-toggle="tooltip"]').tooltip()
	})

	function formatConfigData(data) {
	var mustacheFormattedData = {'config':[]};
	for (var prop in data) {
	if(data.hasOwnProperty(prop)) {
	mustacheFormattedData['config'].push({
	'key': prop,
	'value': JSON.stringify(data[prop])
	});
	}
	}
	return mustacheFormattedData;
	}

	function formatErrorTimeSecs(response){
	var errors = response["componentErrors"];
	for(var i = 0 ; i < errors.length ; i++){
	var time = errors[i]['time'];
	errors[i]['time'] = moment.utc(time).local().format("ddd, DD MMM YYYY HH:mm:ss Z");
	}
	return response;
	}


	function renderToggleSys(div) {
	var sys = $.cookies.get("sys") \|\| false;
	if(sys) {
	div.append("<span data-original-title=\"Use this to toggle inclusion of storm system components.\" class=\"tip right\"><input onclick=\"toggleSys()\" value=\"Hide System Stats\" type=\"button\" class=\"btn btn-default\"></span>");
	} else {
	div.append("<span class=\"tip right\" title=\"Use this to toggle inclusion of storm system components.\"><input onclick=\"toggleSys()\" value=\"Show System Stats\" type=\"button\" class=\"btn btn-default\"></span>");
	}
	}

	function topologyActionJson(id, encodedId, name, status, msgTimeout, debug, samplingPct) {
	var jsonData = {};
	jsonData["id"] = id;
	jsonData["encodedId"] = encodedId;
	jsonData["name"] = name;
	jsonData["msgTimeout"] = msgTimeout;
	jsonData["activateStatus"] = (status === "INACTIVE") ? "enabled" : "disabled";
	jsonData["deactivateStatus"] = (status === "ACTIVE") ? "enabled" : "disabled";
	jsonData["rebalanceStatus"] = (status === "ACTIVE" \|\| status === "INACTIVE" ) ? "enabled" : "disabled";
	jsonData["killStatus"] = (status !== "KILLED") ? "enabled" : "disabled";
	jsonData["startDebugStatus"] = (status === "ACTIVE" && !debug) ? "enabled" : "disabled";
	jsonData["stopDebugStatus"] = (status === "ACTIVE" && debug) ? "enabled" : "disabled";
	jsonData["currentSamplingPct"] = samplingPct;
	return jsonData;
	}

	function componentActionJson(encodedTopologyId, encodedId, componentName, status, debug, samplingPct) {
	var jsonData = {};
	jsonData["encodedTopologyId"] = encodedTopologyId;
	jsonData["encodedId"] = encodedId;
	jsonData["componentName"] = componentName;
	jsonData["startDebugStatus"] = (status === "ACTIVE" && !debug) ? "enabled" : "disabled";
	jsonData["stopDebugStatus"] = (status === "ACTIVE" && debug) ? "enabled" : "disabled";
	jsonData["currentSamplingPct"] = samplingPct;
	return jsonData;
	}

	function topologyActionButton(id,name,status,actionLabel,command,wait,defaultWait) {
	var buttonData = {};
	buttonData["buttonStatus"] = status ;
	buttonData["actionLabel"] = actionLabel;
	buttonData["command"] = command;
	buttonData["isWait"] = wait;
	buttonData["defaultWait"] = defaultWait;
	return buttonData;
	}

	$.blockUI.defaults.css = {
	border: 'none',
	padding: '15px',
	backgroundColor: '#000',
	'-webkit-border-radius': '10px',
	'-moz-border-radius': '10px',
	'border-radius': '10px',
	opacity: .5,
	color: '#fff',margin:0,width:"30%",top:"40%",left:"35%",textAlign:"center"
	};