4.4.0 • Published 4 years ago

reconnecting-websocket v4.4.0

Weekly downloads
68,590
License
MIT
Repository
github
Last release
4 years ago

Reconnecting WebSocket

Build Status Coverage Status

WebSocket that will automatically reconnect if the connection is closed.

Features

  • WebSocket API compatible (same interface, Level0 and Level2 event model)
  • Fully configurable
  • Multi-platform (Web, ServiceWorkers, Node.js, React Native)
  • Dependency free (does not depend on Window, DOM or any EventEmitter library)
  • Handle connection timeouts
  • Allows changing server URL between reconnections
  • Buffering. Will send accumulated messages on open
  • Multiple builds available (see dist folder)
  • Debug mode

Install

npm install --save reconnecting-websocket

Usage

Compatible with WebSocket Browser API

So this documentation should be valid: MDN WebSocket API.

Ping me if you find any problems. Or, even better, write a test for your case and make a pull request :)

Simple usage

import ReconnectingWebSocket from 'reconnecting-websocket';

const rws = new ReconnectingWebSocket('ws://my.site.com');

rws.addEventListener('open', () => {
    rws.send('hello!');
});

Update URL

The url parameter will be resolved before connecting, possible types:

  • string
  • () => string
  • () => Promise<string>
import ReconnectingWebSocket from 'reconnecting-websocket';

const urls = ['ws://my.site.com', 'ws://your.site.com', 'ws://their.site.com'];
let urlIndex = 0;

// round robin url provider
const urlProvider = () => urls[urlIndex++ % urls.length];

const rws = new ReconnectingWebSocket(urlProvider);
import ReconnectingWebSocket from 'reconnecting-websocket';

// async url provider
const urlProvider = async () => {
    const token = await getSessionToken();
    return `wss://my.site.com/${token}`;
};

const rws = new ReconnectingWebSocket(urlProvider);

Options

Sample with custom options

import ReconnectingWebSocket from 'reconnecting-websocket';
import WS from 'ws';

const options = {
    WebSocket: WS, // custom WebSocket constructor
    connectionTimeout: 1000,
    maxRetries: 10,
};
const rws = new ReconnectingWebSocket('ws://my.site.com', [], options);

Available options

type Options = {
    WebSocket?: any; // WebSocket constructor, if none provided, defaults to global WebSocket
    maxReconnectionDelay?: number; // max delay in ms between reconnections
    minReconnectionDelay?: number; // min delay in ms between reconnections
    reconnectionDelayGrowFactor?: number; // how fast the reconnection delay grows
    minUptime?: number; // min time in ms to consider connection as stable
    connectionTimeout?: number; // retry connect if not connected after this time, in ms
    maxRetries?: number; // maximum number of retries
    maxEnqueuedMessages?: number; // maximum number of messages to buffer until reconnection
    startClosed?: boolean; // start websocket in CLOSED state, call `.reconnect()` to connect
    debug?: boolean; // enables debug output
};

Default values

WebSocket: undefined,
maxReconnectionDelay: 10000,
minReconnectionDelay: 1000 + Math.random() * 4000,
reconnectionDelayGrowFactor: 1.3,
minUptime: 5000,
connectionTimeout: 4000,
maxRetries: Infinity,
maxEnqueuedMessages: Infinity,
startClosed: false,
debug: false,

API

Methods

constructor(url: UrlProvider, protocols?: string | string[], options?: Options)

close(code?: number, reason?: string)
reconnect(code?: number, reason?: string)

send(data: string | ArrayBuffer | Blob | ArrayBufferView)

addEventListener(type: 'open' | 'close' | 'message' | 'error', listener: EventListener)
removeEventListener(type:  'open' | 'close' | 'message' | 'error', listener: EventListener)

Attributes

More info

binaryType: string;
bufferedAmount: number;
extensions: string;
onclose: EventListener;
onerror: EventListener;
onmessage: EventListener;
onopen: EventListener;
protocol: string;
readyState: number;
url: string;
retryCount: number;

Constants

CONNECTING 0 The connection is not yet open.
OPEN       1 The connection is open and ready to communicate.
CLOSING    2 The connection is in the process of closing.
CLOSED     3 The connection is closed or couldn't be opened.

Contributing

Read here

License

MIT

@estanalytical/vasconnect@gitpod/gitpod-protocolflokhex-ocean-django-channelsbinance-api-node-fullboydog-client@anadyme/lavva-widgetsve-playerdogehouse-jsdogehouse.js-staged@faceit/nodejs-server-plugin@mcgordonite/theia-corepublishtestformeinreactnativewebtestcomponentalias-client@radar/chain-watchers-bitcoin@fungi-realtime/core@tumakot/orion-trading-sdkexchange-connectormixineos-walletcpe-video-ad-break-uicybex-game-addongjw-livechatgjw-livechat-v2valkyriecoms-jshamro-chat-sdkjs-34@infinitebrahmanuniverse/nolb-reco@sdv-streaming/common@civfund/fund-librariesfzmtoolroam-dev-serverrxdbnanocurrency.js@everything-registry/sub-chunk-2632teller-sdk@gedit/connectionlets-notifyhomebridge-grafanahomebridge-leviton-home-awayhomebridge-dreohomebridge-dreo-clay-testhomebridge-dreo-enhancedhomebridge-dreo2homebridge-orbit-irrigationhik-dmaphik-maphubot-traqhudshydrocarbon-client-modulekcnkclkmopoframework-uius-binance-api-nodegraphql-api-clientkucoin-websocket-apikucoin-websocketsincent-api-sdkinfinidesk-web-widgetiirose-botide-pluginipsaveljnpf-webjoplin-plugin-bundlejoplin-plugin-readcube-papersliuaoyun-sdk-demolivequrl-clientmiks-collaborative-editornanomemotoolsnightfall-sdknightfall-sdk-fork-2-luizoamorimnightfall-sdk-luizoamorim-2022node-bitstampnode-crypto-comnode-binance-usnode-red-contrib-aprsnode-red-contrib-aprs2mari-jsmarijamisskey-jsmprdevhelix-chathomeassistant-rxhomebridge-freeathome-localhomebridge-platform-orbitinsight-kitjwjsmy-combined-crypto-apismytosis-websocketmy-kurento-clientlx_web_designlx_web_design_devmeixincoremaputnikns2-front-module-commonmcashscan-frontendec-printetebaseelektroflipper-frontend-coreflipper-server-clientflipper-server
4.4.0

4 years ago

4.3.0

4 years ago

4.2.0

5 years ago

4.1.10

5 years ago

4.1.9

5 years ago

4.1.8

5 years ago

4.1.7

5 years ago

4.1.6

5 years ago

4.1.5

5 years ago

4.1.4

5 years ago

4.1.3

5 years ago

4.1.2

5 years ago

4.1.1

5 years ago

4.1.0

5 years ago

4.0.0-rc5

6 years ago

4.0.0-rc4

6 years ago

4.0.0-rc3

6 years ago

4.0.0-rc2

6 years ago

4.0.0-rc1

6 years ago

3.2.2

7 years ago

3.2.1

7 years ago

3.2.0

7 years ago

3.1.1

7 years ago

3.1.0

7 years ago

3.0.7

7 years ago

3.0.6

7 years ago

3.0.5

7 years ago

3.0.4

7 years ago

3.0.3

7 years ago

3.0.2

7 years ago

3.0.1

7 years ago

3.0.0

7 years ago

2.0.0

8 years ago

1.4.4

8 years ago

1.4.3

8 years ago

1.4.2

8 years ago

1.4.0

8 years ago

1.3.2

8 years ago

1.3.0

8 years ago

1.2.0

8 years ago

1.1.0

8 years ago

1.0.0

8 years ago

1.0.4

8 years ago

1.0.3

8 years ago

1.0.2

8 years ago