From ad69e230713aa9441d6e1a5b2ba6415a039deea4 Mon Sep 17 00:00:00 2001
From: cgray <cgray@yammer-inc.com>
Date: Tue, 6 Oct 2015 11:03:03 -0700
Subject: [PATCH] Merging in latest changes to monitor.html to:

https://github.com/Netflix/Hystrix/pull/919
https://github.com/Netflix/Hystrix/pull/921
---
 .../resources/assets/monitor/monitor.html     | 99 ++++++-------------
 1 file changed, 31 insertions(+), 68 deletions(-)

diff --git a/breakerbox-dashboard/src/main/resources/assets/monitor/monitor.html b/breakerbox-dashboard/src/main/resources/assets/monitor/monitor.html
index 0b43cfc..3193146 100644
--- a/breakerbox-dashboard/src/main/resources/assets/monitor/monitor.html
+++ b/breakerbox-dashboard/src/main/resources/assets/monitor/monitor.html
@@ -56,7 +56,7 @@
 		<div id="dependencies" class="row dependencies"><span class="loading">Loading ...</span></div>
 		
 		<div class="spacer"></div>
-		
+
 		<div class="row">
 			<div class="menubar">
 				<div class="title">
@@ -73,53 +73,55 @@
 
 
 
-<script>
+	<script>
 		/**
 		 * Queue up the monitor to start once the page has finished loading.
 		 * 
 		 * This is an inline script and expects to execute once on page load.
 		 */ 
-		 
+	 
 		 // commands
 		var hystrixMonitor = new HystrixCommandMonitor('dependencies', {includeDetailIcon:false});
-		
+		var dependencyThreadPoolMonitor = new HystrixThreadPoolMonitor('dependencyThreadPools');		
+
 		var stream = getUrlVars()["stream"];
-		
+	
 		if(stream != undefined) {
 			if(getUrlVars()["delay"] != undefined) {
 				stream = stream + "&delay=" + getUrlVars()["delay"];
 			}
 
 			if(getUrlVars()["title"] != undefined) {
-				$('#title_name').html("Hystrix Stream: " + decodeURIComponent(getUrlVars()["title"]))
+				$('#title_name').text("Hystrix Stream: " + decodeURIComponent(getUrlVars()["title"]))
 			} else {
-				$('#title_name').html("Hystrix Stream: " + decodeURIComponent(stream))
+				$('#title_name').text("Hystrix Stream: " + decodeURIComponent(stream))
 			}
 
-            //do not show authorization in stream title
-            if(getUrlVars()["authorization"] != undefined) {
-                stream = stream + "&authorization=" + getUrlVars()["authorization"];
-            }
+			//do not show authorization in stream title
+			if(getUrlVars()["authorization"] != undefined) {
+				stream = stream + "&authorization=" + getUrlVars()["authorization"];
+			}
 
-			var commandStream = "/tenacity/proxy.stream?origin=" + stream;
-			var poolStream = "/tenacity/proxy.stream?origin=" + stream;
+			var proxyStream = "/tenacity/proxy.stream?origin=" + stream;
 		}
-				
+
 		$(window).load(function() { // within load with a setTimeout to prevent the infinite spinner
 			setTimeout(function() {
-				if(commandStream == undefined) {
-						console.log("commandStream is undefined")
+				if(proxyStream == undefined) {
+						console.log("proxyStream is undefined")
 						$("#dependencies .loading").html("The 'stream' argument was not provided.");
 						$("#dependencies .loading").addClass("failed");
 				} else {
 					// sort by error+volume by default
 					hystrixMonitor.sortByErrorThenVolume();
-					
+					dependencyThreadPoolMonitor.sortByVolume();
+
 					// start the EventSource which will open a streaming connection to the server
-					var source = new EventSource(commandStream);
-					
+					var source = new EventSource(proxyStream);
+
 					// add the listener that will process incoming events
 					source.addEventListener('message', hystrixMonitor.eventSourceMessageListener, false);
+					source.addEventListener('message', dependencyThreadPoolMonitor.eventSourceMessageListener, false);
 
 					//	source.addEventListener('open', function(e) {
 					//		console.console.log(">>> opened connection, phase: " + e.eventPhase);
@@ -139,59 +141,20 @@
 				}
 			},0);
 		});
-		
-		// thread pool
-		var dependencyThreadPoolMonitor = new HystrixThreadPoolMonitor('dependencyThreadPools');
 
-		$(window).load(function() { // within load with a setTimeout to prevent the infinite spinner
-			setTimeout(function() {
-				if(poolStream == undefined) {
-						console.log("poolStream is undefined")
-						$("#dependencyThreadPools .loading").html("The 'stream' argument was not provided.");
-						$("#dependencyThreadPools .loading").addClass("failed");
-				} else {
-					dependencyThreadPoolMonitor.sortByVolume();
-					
-					// start the EventSource which will open a streaming connection to the server
-					var source = new EventSource(poolStream);
-					
-					// add the listener that will process incoming events
-					source.addEventListener('message', dependencyThreadPoolMonitor.eventSourceMessageListener, false);
-	
-					//	source.addEventListener('open', function(e) {
-					//		console.console.log(">>> opened connection, phase: " + e.eventPhase);
-					//	    // Connection was opened.
-					//	}, false);
-	
-					source.addEventListener('error', function(e) {
-						$("#dependencyThreadPools .loading").html("Unable to connect to Thread Pool Metric Stream.");
-						$("#dependencyThreadPools .loading").addClass("failed");
-					  if (e.eventPhase == EventSource.CLOSED) {
-					    // Connection was closed.
-						  console.log("Connection was closed on error: " + e);
-					  } else {
-						  console.log("Error occurred while streaming: " + e);
-					  }
-					}, false);
-				}
-			},0);
-		});
-		
 		//Read a page's GET URL variables and return them as an associative array.
 		// from: http://jquery-howto.blogspot.com/2009/09/get-url-parameters-values-with-jquery.html
-		function getUrlVars()
-		{
-		    var vars = [], hash;
-		    var hashes = window.location.href.slice(window.location.href.indexOf('?') + 1).split('&');
-		    for(var i = 0; i < hashes.length; i++)
-		    {
-		        hash = hashes[i].split('=');
-		        vars.push(hash[0]);
-		        vars[hash[0]] = hash[1];
-		    }
-		    return vars;
+		function getUrlVars() {
+			var vars = [], hash;
+			var hashes = window.location.href.slice(window.location.href.indexOf('?') + 1).split('&');
+			for(var i = 0; i < hashes.length; i++) {
+				hash = hashes[i].split('=');
+				vars.push(hash[0]);
+				vars[hash[0]] = hash[1];
+			}
+			return vars;
 		}
-		
+	
 	</script>