123456789101112131415161718192021222324252627282930313233343536373839404142434445 |
- 'use strict';
- var SockJS = require('sockjs-client/dist/sockjs');
- var retries = 0;
- var sock = null;
- var socket = function initSocket(url, handlers) {
- sock = new SockJS(url);
- sock.onopen = function onopen() {
- retries = 0;
- };
- sock.onclose = function onclose() {
- if (retries === 0) {
- handlers.close();
- }
- sock = null;
- if (retries <= 10) {
-
-
-
- var retryInMs = 1000 * Math.pow(2, retries) + Math.random() * 100;
- retries += 1;
- setTimeout(function () {
- socket(url, handlers);
- }, retryInMs);
- }
- };
- sock.onmessage = function onmessage(e) {
-
- var msg = JSON.parse(e.data);
- if (handlers[msg.type]) {
- handlers[msg.type](msg.data);
- }
- };
- };
- module.exports = socket;
|