rpc-websocket-client

Fast JSON RPC 2.0 written in TypeScript.

TypeScript JSON RPC 2.0 WebSocket implementation with async-await Promises.

Description

I really lacked typescript support or type definitions of rpc-websockets. I kept everything as simple as possible for best performance and used fast-json-strongify for much faster JSON communication. Under the hood id-generation for requests is done using uuid/v1 to provide id uniqueness as an additional feature.

Installation

npm i rpc-websocket-client

Features

• TypeScript with documentation in comments.
• Fast JSON parsing of incoming requests by fast-json-strongify.
• Unique RPC identifiers by uuid/v1.
• Lightweight. Allows you to call noRpc() method to prevent sending jsonrpc: '2.0' overhead from all messages if you'd like to ignore the JSON RPC 2.0 standard for better performance.
• Option to connect RpcWebSocketClient with already existing WebSocket with changeSocket() and listenMessages() methods. Useful if you use REST or GraphQL implementation from another library and want to handle JSON RPC 2.0 when communicating from server to client (that was my use case to develop this package).

Basic Usage

import { RpcWebSocketClient } from 'rpc-websocket-client';

(async () => {

    const rpc = new RpcWebSocketClient();

    await rpc.connect(`ws://localhost:4000/`);
    // connection established

    // let's hope there will be no error or it will be catched in some wrapper
    await rpc.call(`auth.login`, [`rpcMaster`, `mySecretPassword`]);

    // now lets be pesimistic
    await rpc.call(`auth.login`, [`rpcMaster`, `mySecretPassword`]).then(() => {
        // woohoo, user logged!
    }).catch((err) => {

        // err is typeof RpcError (code: number, message: string, data?: any)
        await rpc.call(`auth.signup`, {
            login: `rpcMaster`,
            password: `mySecretPassword`,
        });

    });

    rpc.notify(`btw.iHateYou`, [`over and out`]);
})();

Advanced Usage

(async () => {
    // lets say you use WebSocket implementation for GraphQL Client -> Server communication
    // e.g. Apollo, and it's already connected
    // but you want to handle some of the Server -> Client communication with RPC

    const ws = (apollo as any).client.wsImpl;
    const rpc = new RpcWebSocketClient();

    rpc.onRequest((data) => {       // data is typeof RpcRequest
        // controller-like stuff
    });

    rpc.onNotification((data) => {  // data is typeof RpcNotification
        // notification handling
    });

    // here goes magic for listening to already-connected socket
    rpc.changeSocket(ws);
    rpc.listenMessages();
})();