ZilaWS is a blazingly fast and very lightweight library that provides an extremely easy-to-use way to transmit data via websockets between client-side and server-side using eventhandlers and async waiters
Test status badge MIT License coverage label for branches coverage label for functions coverage label for lines of code coverage label for statements
Looking for the zilaws-client package?
The ZilaWS Server can accept WS connections from non-ZilaWS clients but won't work as expected.
ZilaWS has a unique function called waiter. Waiters (as their name suggests) can be awaited.
They resolve when the client side MessageHandler resolves or returns thus making it perfect for retrieving data from a client.
However if the client does not respond in time, waiters will resolve as undefined.
There are also broadcastWaiters.
Regular waiters wait for a response for the amount of time specified by the maxWaiterTime property. This is a property of the ZilaServer class. This property can be set while creating the server through the options object or anytime with its property.
identifier: The name of the MessageHandler on the other side of the connection....data: A waiter (or a send) can be given any number of any data.
socket.waiter<T>(identifier: string, ...data: any[]): Promise<T | undefined>
maxWaitingTime: This paramater overrides the maximum waiting time for the correspondingwaiterorbroadcastWaiter. The value is in miliseconds.
socket.waiterTimeout<T>(identifier: string, maxWaitingTime: number, ...data: any[]): Promise<T | undefined>
const client = await connectTo("wss://yourhost.com:6589"); console.log(await client.waiter("GetValueOfPI", "Some string") as number); // --> 3.141592653589793 console.log(await client.waiterTimeout("GetValueOfPI", 1200, "Some string") as number); // --> 3.141592653589793
const server = new ZilaServer({ port: 6589, https: { pathToCert: "cert/fullchain.pem", pathToKey: "cert/privkey.pem" } }); server.setMessageHandler("GetValueOfPI", (param1: string) => { console.log(param1); // --> Some string return Math.PI; });
You have the ability to extend the ZilaClient which is a class for storing server side data and functions of a WS connection. Extending is good for storing extra data (or even declaring functions) associated with a client thus making it the best way to handle authentication.
/*You should not use the WebSocketClient constructor since it's a part of the `ws` npm package, and is only exported to make the extending easier.*/ import { ZilaServer, ZilaClient, WebSocketClient, IncomingHttpHeaders } from "zilaws-server"; class MyClient extends ZilaClient { public clientData: { rank: "admin" | "user"; username: string; } //In order to get access to the cookies, sadly you need to define the constructor by hand. constructor( socket: WebSocketClient, ip: string | undefined, server: ZilaServer, isBrowser: boolean, headers: IncomingHttpHeaders, cookies?: Map<string, string> ) { super(socket, ip, server, isBrowser, headers, cookies); //This is the best place to authenticate the user. if(isBrowser && !AuthUserByBrowser(cookies?.get("loginToken"))) { this.kick("Wrong token"); return; }else if (!AuthUserByHeader(headers["authorization"])) { this.kick("Wrong token"); return; } this.clientData = { rank: "admin", username: "SomeUsername" } } } //Defining both the generic type and the clientClass is needed. const server = new ZilaServer<MyClient>({ port: 6589, logger: true, verbose: true, clientClass: MyClient }); server.onceMessageHandler("Anything", (socket) => { socket.clientData.rank == "admin"; //--> true socket.clientData.username == "SomeUsername"; //--> true });
You also have the ability to extend the ZilaServer class if you need to. This comes in handy if for example you need to convert data automatically.
import { IServerSettings, ZilaClient, ZilaServer, ZilaWSCallback } from "zilaws-server"; enum MessageHandlers { Register, Login, //... } class MyServer<T extends ZilaClient> extends ZilaServer<T> { constructor(settings: IServerSettings) { super(settings); } setMessageHandler(identifier: MessageHandlers | string, callback: ZilaWSCallback<T>): void { super.setMessageHandler(identifier.toString(), callback); } } const server = new MyServer<MyClient>({ port: 80, clientClass: MyClient }); server.setMessageHandler(MessageHandlers.Login, async (socket: MyClient, username: string, password: string) => { //Logging in a user const dbUser = await CheckLoginCredentials(username, password); if(dbUser) { const loginToken = generateToken(); socket.setCookie({ name: "LoginToken", value: loginToken, expires: new Date(Date.now() + 1000 * 60 * 60 * 24 * 30) }); socket.clientData = dbUser; return "SUCCESS"; }else{ return "BAD_CREDENTIALS"; } });
ZilaWS offers much more. Check out the documentation!