1 files changed, 51 insertions, 0 deletions
diff --git a/node_modules/webpack-hot-client/client/socket.js b/node_modules/webpack-hot-client/client/socket.js
new file mode 100644
index 00000000..31847255
--- /dev/null
+++ b/node_modules/webpack-hot-client/client/socket.js
@@ -0,0 +1,51 @@
+'use strict';
+
+var url = require('url');
+
+var log = require('./log');
+
+var maxRetries = 10;
+var retry = maxRetries;
+
+module.exports = function connect(options, handler) {
+  var socketUrl = url.format({
+    protocol: options.https ? 'wss' : 'ws',
+    hostname: options.webSocket.host,
+    port: options.webSocket.port,
+    slashes: true
+  });
+  var open = false;
+  var socket = new WebSocket(socketUrl);
+  socket.addEventListener('open', function () {
+    open = true;
+    retry = maxRetries;
+    log.info('WebSocket connected');
+  });
+  socket.addEventListener('close', function () {
+    log.warn('WebSocket closed');
+    open = false;
+    socket = null; // exponentation operator ** isn't supported by IE at all
+    // eslint-disable-next-line no-restricted-properties
+
+    var timeout = 1000 * Math.pow(maxRetries - retry, 2) + Math.random() * 100;
+
+    if (open || retry <= 0) {
+      log.warn("WebSocket: ending reconnect after ".concat(maxRetries, " attempts"));
+      return;
+    }
+
+    log.info("WebSocket: attempting reconnect in ".concat(parseInt(timeout / 1000, 10), "s"));
+    setTimeout(function () {
+      retry -= 1;
+      connect(options, handler);
+    }, timeout);
+  });
+  socket.addEventListener('message', function (event) {
+    log.debug('WebSocket: message:', event.data);
+    var message = JSON.parse(event.data);
+
+    if (handler[message.type]) {
+      handler[message.type](message.data);
+    }
+  });
+};
+\ No newline at end of file