node-ipc example with high client->server reliability (no dropped messages)

client.js

const ipc = require("node-ipc");
const async = require("async");

const queue = async.queue((data, cb) => {
    // There is no way of checking if client is connected so just
    // catch and put it back in the queue if a bad happens.
    try {
        ipc.of.test.emit("message", data);
    } catch (err) {
        console.error(err);
        queue.unshift(data);
    }
    cb();
});

queue.pause();

let i = 0;

ipc.config.id = "test";
ipc.config.silent = true;

setInterval(() => {
    console.log(`Buffered message ${i}`);
    queue.push(i++);
}, 500);

ipc.connectToNet("test", () => {
    ipc.of.test.on("connect", () => {
        console.log("connected");
        queue.resume();
    });
    ipc.of.test.on("message", (data) => {
        console.log(data);
    });
    ipc.of.test.on("error", (err) => {
        queue.pause();
    })
});

server.js

const ipc = require("node-ipc");

ipc.config.id = "test";

ipc.serveNet(() => {
    ipc.server.on("connect", () => {
        ipc.server.broadcast("message", "yoyooyoyoy");
    });

    ipc.server.on("message", (data, socket) => {
        ipc.server.emit(socket, "message", data);
    });
});

ipc.server.start();