Added back EventSource to the client, writing to console.log() for now

marquette.js

@@ -116,29 +116,29 @@ client.on('message', function(topic, payload) {
     });
 });
 
-// Send a ping every 25 seconds to the browsers to keep the HTTP connections open
+
+// Send a ping every 20 seconds to the browsers to keep the HTTP connections open
 setInterval(function() {
     browsers.forEach(function(res) {
         res.write(": ping\n\n");
     });
-}, 25000);
+}, 20000);
 
 
 app.get('/update-stream', function(req, res) {
-    req.socket.setTimeout(Infinity);
-
+    req.socket.setNoDelay(true);
     res.writeHead(200, {
         'Content-Type': 'text/event-stream',
         'Cache-Control': 'no-cache'
     });
-    res.write("\n");
+    res.write(":\n");
+
     browsers.push(res);
 
     req.on("close", function() {
         index = browsers.indexOf(req);
         browsers.splice(index, 1);
     });
-
 });
 
 

public/index.html

@@ -9,6 +9,7 @@
 
     <script src="./js/jquery-1.11.1.min.js"></script>
     <script src="./js/jquery.gridster.min.js"></script>
+    <script src="./js/eventsource.min.js"></script>
     <script src="./js/marquette.js"></script>
   </head>
 

public/js/marquette.js

@@ -54,6 +54,23 @@ $(function(){ //DOM Ready
         init_gridster();
     });
 
+
+    var source = new EventSource('/update-stream');
+    console.log("EventSource="+source);
+
+    source.onopen = function(e) {
+      console.log("EventSource connection open");
+    };
+
+    source.onmessage = function(e) {
+      var obj = JSON.parse(e.data);
+      console.log(obj);
+    };
+
+    source.onerror = function(e) {
+      console.log("Event source error: "+e);
+    };
+
 });