pinary v1.4.4

pinary

Introduction

Yet another RPC client and server, with minimalistic publish/subscribe implementation.

• Server

  • TCP or TLS, as you want (TLS require certificates, see https://github.com/jfromaniello/selfsigned )
  • Persistant connection
  • Binary frames (fast)
  • Optional ZLIB compression
  • Minimalistic JSON Schema implementation (input integrity)
  • Handle Max Clients
  • Basic publish/subscribe support

• Client

  • Automatic reconnect
  • Internal RPC calls queue
    • Allow lazy client connect
    • Store calls when not connected and play calls when reconnect

Install

npm install pinary

Server

Server: instantiation

const PinaryServer = require('pinary').server;
const server = new PinaryServer();

// with options (see below)
// const server = new PinaryServer({port:64000});

(1) under the hood, a "client" is in fact 2 sockets, one for writing, one for reading.

Client

Client: instantiation

const PinaryClient = require('pinary').client;
const client = new PinaryClient(); // auto connect

// with a TCP url
// const client = new PinaryClient('tcp://localhost:64000',[options]);

// with a TLS url
// const client = new PinaryClient('tls://localhost:64000',[options]);

Client: trigger a method

// using callback
client.rpc('myMethod', (err, result) => {
    if (err) throw err;
    console.log(result);
});

// using async/await
async function letsgo() {
    let result;
    try {
        result = await client.rpcPromise('myMethod');
    } catch(e) {
        // something wrong
    }
    console.log(result);
}

Note: if not yet connected or while the client is trying to reconnect, RPC calls are stored in a queue and played when client is connected.

Client: events

Publish/Subscribe (PUBSUB)

Client to clients

const Server = require('pinary').server;
const Client = require('pinary').client;

const server = new Server();
const client1 = new Client();
const client2 = new Client();

const channel = '/myChannel';

server.start();

client1.subscribe('/bla', (data) => {
    console.log(data);
    process.exit();
});

client2.publish('/bla', { foo:'bar' });

Server to clients

const Server = require('pinary').server;
const Client = require('pinary').client;

const server = new Server();
const client = new Client();

const channel = '/myChannel';

server.start();

client.subscribe(channel, (data) => {
    console.log(data);
    process.exit();
});

server.publish(channel, { foo:'bar' });

The actual implementation is minimalistic:

• a channel is considered as an ID, you cannot use wildcards like redis or faye

TODO

• finish doc
  • events emitted (server)
  • server methods registration (see test/tests/102.methodExist.js, or examples/ for moment)