FinalRPC

A dumb (read simple) promise-aware RPC implementation with support for Pub/Sub for FinalPM. Only RPC implementation for node right now that works with unix domain sockets out of the box and has pub/sub.

const {Client, Server} = require('final-rpc');
 
const path = require('path');
const server = new Server();
 
server.register({
   add(client, a, b) {
      return new Promise((resolve) => {
         setTimeout(() => {
            resolve(a + b);
         }, 500);
      });
   },
   subscribe(client) {
      server.subscribe(client, 'news');
   },
   unsubscribe(client) {
      server.unsubscribe(client, 'news');
   }
});
 
setInterval(() => server.publish('news', 'hi'), 1000);
 
server.listen('ws+unix://' + path.resolve('rpc.sock')).then(startClient);
 
async function startClient() {
   const client = new Client('ws+unix://'+ path.resolve('rpc.sock'));
 
   client.pubsub.on('news', (msg) => console.log('News:', msg));
 
   await client.invoke('subscribe');
 
   console.log('Result:', await client.invoke('add', 5, 10));
}