1 |
|
2 | import WebSocketClient from "./clients/WebSocketClient.js";
|
3 | import { log } from "./utils/log.js";
|
4 |
|
5 |
|
6 |
|
7 | var Client =
|
8 | typeof __webpack_dev_server_client__ !== "undefined" ? typeof __webpack_dev_server_client__.default !== "undefined" ? __webpack_dev_server_client__.default : __webpack_dev_server_client__ : WebSocketClient;
|
9 |
|
10 |
|
11 | var retries = 0;
|
12 | var maxRetries = 10;
|
13 |
|
14 |
|
15 |
|
16 | export var client = null;
|
17 |
|
18 |
|
19 |
|
20 |
|
21 |
|
22 |
|
23 | var socket = function initSocket(url, handlers, reconnect) {
|
24 | client = new Client(url);
|
25 | client.onOpen(function () {
|
26 | retries = 0;
|
27 |
|
28 | if (typeof reconnect !== "undefined") {
|
29 | maxRetries = reconnect;
|
30 | }
|
31 | });
|
32 | client.onClose(function () {
|
33 | if (retries === 0) {
|
34 | handlers.close();
|
35 | }
|
36 |
|
37 |
|
38 | client = null;
|
39 |
|
40 | if (retries < maxRetries) {
|
41 |
|
42 |
|
43 |
|
44 | var retryInMs = 1000 * Math.pow(2, retries) + Math.random() * 100;
|
45 | retries += 1;
|
46 | log.info("Trying to reconnect...");
|
47 | setTimeout(function () {
|
48 | socket(url, handlers, reconnect);
|
49 | }, retryInMs);
|
50 | }
|
51 | });
|
52 | client.onMessage(
|
53 | |
54 |
|
55 |
|
56 | function (data) {
|
57 | var message = JSON.parse(data);
|
58 |
|
59 | if (handlers[message.type]) {
|
60 | handlers[message.type](message.data, message.params);
|
61 | }
|
62 | });
|
63 | };
|
64 |
|
65 | export default socket; |
\ | No newline at end of file |