StableSocket

A web socket that reconnects.

Installation

$ npm install @github/stable-socket

Usage

1import {StableSocket} from '@github/stable-socket'
2
3const delegate = {
4  socketDidOpen(socket: Socket) {
5    // Socket is ready to write.
6    socket.send('Hello')
7  },
8  socketDidClose(socket: Socket, code?: number, reason?: string) {
9    // Socket closed and will retry the connection.
10  },
11  socketDidFinish(socket: Socket) {
12    // Socket closed for good and will not retry.
13  },
14  socketDidReceiveMessage(socket: Socket, message: string) {
15    // Socket read data from the connection.
16  },
17  socketShouldRetry(socket: Socket, code: number): boolean {
18    // Socket reconnects unless server returns the policy violation code.
19    return code !== 1008
20  }
21}
22
23const policy = {
24  timeout: 4000,
25  attempts: Infinity,
26  maxDelay: 60000
27}
28
29const url = 'wss://live.example.com'
30const socket = new StableSocket(url , delegate, policy)
31socket.open()

BufferedSocket

Writing to a StableSocket while it is in the opening or closed states discards the message data. Use a BufferedSocket to buffer writes to be sent when it opens.

1import {BufferedSocket, StableSocket} from '@github/stable-socket'
2const socket = new BufferedSocket(new StableSocket(url, delegate, policy))
3socket.open()
4socket.send('hello') // Will be sent when the socket is open.

Asynchronous connections

StableSocket and BufferedSocket are abstractions over a WebSocket that maintain an internal state machine, managing reconnects and preventing writes to closed sockets. However, sometimes we need direct access to an open WebSocket in async functions.

connect

Asynchronously connects to a web socket port or fails after a timeout. The socket is open, and writable with send, when its promise is fulfilled. Returns a Promise fulfilled with an open WebSocket or rejected with a connection failure.

1import {connect} from '@github/stable-socket'
2
3try {
4  const socket = await connect('wss://live.example.com', 100)
5  socket.send('hi')
6} catch (e) {
7  console.log('Socket connection failed', e)
8}

connectWithRetry

Asynchronously connects to a web socket port, retrying failed connections with exponential backoff. Returns a Promise fulfilled with an open WebSocket or rejected with a connection failure.

1import {connectWithRetry} from '@github/stable-socket'
2
3try {
4  const policy = {timeout: 100, attempts: Infinity, maxDelay: 60000}
5  const socket = await connectWithRetry('wss://live.example.com', policy)
6  socket.send('hi')
7} catch (e) {
8  console.log('Socket connection failed', e)
9}

Development

npm install
npm test

License

Distributed under the MIT license. See LICENSE for details.