Websocket Provider

This code is intended to be a basic abstraction of the base websocket API which you can then build your websocket around. This code is written with the intent that it be taken and changed as needed to fit the needs of your individual projects. Hence why it does not have an npm repository set up.

WebSocket Server

Creating a new WebSocket server instance is as easy as calling new WebsocketProvider(port) you can then set parameters and event listeners.

const init = async (): void => {
    const socket: WebsocketProvider = new WebsocketProvider(8080);

    socket.on("message",(message: string) => {
        console.log(message);
    });

    if(!(await socket.connect())) return console.error('Unable to start the connection!');

    socket.send('hello world');
}
init();

Event Listeners

There are four events that you can listen for; connect, message, close, and error.

NOTE: Event listeners must be defined before you start the WebSocket connection

`connect`

socket.on('connect',(connection: WebSocket) => {
    
});

`message`

socket.on('message',(message: string) => {
    
});

`close`

socket.on('close',() => {
    
});

`error`

socket.on('error',() => {
    
});

Methods

`.on()`

Listen for an event to fire.

`.connect()`

Open the WebSocket connection.

`.send()`

Send a message over the connection.

param message - The message to be sent.
throws - An error if you try to send a message when the connection is closed.

`.ping()`

Ping the connection.

throws - An error if you try to ping the connection while it's closed.

`.close()`

Close the connection.

WebSocket Subscriber

Creating a subscriber is as easy as making a provider.

const init = async (): void => {
    const uri = new URIBuilder()
                    .setProtocol(StandardProtocol.WS)
                    .setHostname("localhost")
                    .setPort(8080)
                    .build();

    const socket = new WebsocketSubscriber(uri);
    socket.reconnect(2);

    socket.on("message",(message: string) => {
        console.log(message);
    });
    
    if(!(await socket.connect())) throw new Error('Unable to start the connection!');
}
init();