fix: example display-messages compatible with MSHTML / Windows

Author: Matthew Forrester

examples/display-messages/display-messages.html

@@ -9,6 +9,22 @@ <h1>Hello, World!</h1>
   let headers = new Map();
   let lineNumbers = new Map();
   let running = new Set();
+  let requestCount = 0;
+
+  function merge(a, b) {
+    var r = {};
+    for (var k in a) {
+      if (a.hasOwnProperty(k)) {
+        r[k] = a[k];
+      }
+    }
+    for (var k in b) {
+      if (b.hasOwnProperty(k)) {
+        r[k] = b[k];
+      }
+    }
+    return r;
+  }
 
 
   // Display a message so ther user can see it
@@ -38,8 +54,13 @@ <h1>Hello, World!</h1>
       throw new Error("Have no record of " + streamName);
     }
     return headers.get(streamName).reduce(
-      (acc, k, i) => {
-        return { ...acc, [k]: csvRow[i] };
+      function (acc, k, i) {
+        const r = {};
+        if ((!csvRow) || (!csvRow.length) || (csvRow.length < i)) {
+          return acc;
+        }
+        r[k] = csvRow[i];
+        return merge(acc, r);
       },
       {}
     );
@@ -65,7 +86,7 @@ <h1>Hello, World!</h1>
 
       // Decorate the data received with the stream name and the row number.
       lineNumbers.set(msg.name, lineNumbers.get(msg.name) + 1);
-      const j = Object.assign(
+      const j = merge(
         {
           "Stream Name": msg.name,
           "Line Number": lineNumbers.get(msg.name),
@@ -83,16 +104,26 @@ <h1>Hello, World!</h1>
 
     // If there is a parameter "request_count" then use that as the amount of
     // lines to request.
+
+    function filterForRequestCount(ob) {
+      if (ob && ob.name && ob.name == "request_count") {
+        return true;
+      }
+      return false;
+    }
+
     if (msg.type == "params") {
-      msg.params.filter(({ name }) => name == "request_count").forEach(({ value }) => {
-        requestCount = parseInt(value, 10);
-      });
+      msg.params.filter(filterForRequestCount).forEach(
+        function(ob) {
+          requestCount = parseInt(ob.value, 10);
+        }
+      );
       send({"msg":"streamList"});
     }
 
     // Start all streams that don't include the word "in".
     if (msg.type == "streamList") {
-      msg.streams.forEach((strm) => {
+      msg.streams.forEach(function(strm) {
         send({ msg: "streamStart", name: strm, count: requestCount });
         running.add(strm);
       });
@@ -101,8 +132,8 @@ <h1>Hello, World!</h1>
     // All data from WV Linewise is processed immediately (with no promises or
     // callbacks) so as soon as a stream pauses, start it right back up again.
     if (msg.type == "paused") {
-      setTimeout(() => {
-        send({"msg":"streamContinue","name":msg.name});
+      setTimeout(function() {
+        send({ "msg": "streamContinue", "name" :msg.name });
       }, 1000);
     }
 
@@ -115,21 +146,22 @@ <h1>Hello, World!</h1>
       running.delete(msg.name);
       if (running.size == 0) {
         disp('SENDING \'{"msg":"exit", "status": 0}\' - in 10 seconds');
-        setTimeout(() => {
+        setTimeout(function() {
           send({"msg":"exit", "status": 0});
         }, 10000);
       }
     }
 
   }
 
-  window.onerror = (e) => disp(e && e.msg || e);
+  window.onerror = function(e) { disp(e && e.msg || e) };
 
-  setInterval(() => {
+  setInterval(function() {
     document.querySelector("h1").innerText = new Date();
   }, 1000);
 
   send({"msg":"params"});
 
   </script>
 </html>
+