Run xbus server

• Use ./bin/xbus script to run mircro-services server
• Use Service class

    const { Server } = require('xbus');
    const server = new Server();
    server.listen();

Server listen on 7011 port

Simple chat

const { Service } = require('xubs');

const chat = new Service('chat');

const user = 'Jim';

chat.on('message', message => {
    console.log(`${message.user}: ${message.text}`);
});

process.stdin.on('data', data => {
    const text = data.toString().trimRight();
    chat.emit('message', {user, text});
});

Service

Publish-Subscribe (Events)

new Service(name [, target])

    const { Service } = require('xbus');
    const service = Service('my-servise');

service.on(type, subscriber)

    service.on('add-user', function(user){
        console.log(user);
    });

service.off(type, subscriber)

    // add subscriber
    service.on('add-user', console.log);
    // remove subscriber
    service.off('add-user', console.log);

service.emit(type, event)

    const user = {id: 1, name: 'Jim'};
    service.emit('add-user', user);

Request-Response

service.listen(type, listener)

Sync listener:

    service.listen('sum', function({a, b}){
        return a + b;
    });

Async listener:

    const fs = require('fs');
    const fsPromises = fs.promises;

    service.listen('readFile', async function(fileName){
        const contents = await fsPromises.readFile(fileName);
        return contents;
    });

service.stop(type, listener)

    function sum({a, b}){
        return a + b;
    }
    // add listener
    service.listen('sum', sum);
    // remove listener
    service.stop('sum', sum);

async service.send(type, request)

    const userId = 12;
    service.send('getUser', userId)
        .then(function(user){
            console.log(user);
        })