# xbus

> simple microservice bus

Latest version **1.1.3** (published 2019-08-16) · ISC license · 0 weekly downloads

## Install

```sh
npm install xbus
pnpm add xbus
yarn add xbus
bun add xbus
```

Provides the command `server`.

## Health

**Score 15/100 (F)** — status: abandoned.

Positive: no vulnerabilities.

Warnings: low downloads; no types; no esm support.

Negative: abandoned; low maintenance score.

## Facts

| | |
|---|---|
| Version | 1.1.3 |
| Published | 2019-08-16 |
| First published | 2019-08-14 |
| Weekly downloads | 0 |
| License | ISC |
| TypeScript types | none |
| Module format | CommonJS |
| Node | >=12.0.0 |
| Dependencies | 0 |
| Unpacked size | 29.9 KB |
| Known vulnerabilities | 0 |
| Install scripts | no |
| Author | Aika |
| Maintainers | gabriel.zoroaster |
| Keywords | bus, microservice |

## Links

- npm: https://www.npmjs.com/package/xbus
- npm.io page: https://npm.io/package/xbus

## Recent versions

- 1.1.3 (latest) — 2019-08-16
- 1.1.2 — 2019-08-16
- 1.1.1 — 2019-08-16
- 1.1.0 — 2019-08-16
- 1.0.6 — 2019-08-15
- 1.0.5 — 2019-08-15
- 1.0.4 — 2019-08-14
- 1.0.3 — 2019-08-14
- 1.0.2 — 2019-08-14
- 1.0.1 — 2019-08-14
- 1.0.0 — 2019-08-14

## README

#Run xbus server

- Use ./bin/xbus script to run mircro-services server
- Use Service class
```js
	const { Server } = require('xbus');
	const server = new Server();
	server.listen();
```
Server listen on 7011 port

#Simple chat

```js

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])

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

###service.on(type, subscriber)

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

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

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

##Request-Response

###service.listen(type, listener)
Sync listener:
```js
	service.listen('sum', function({a, b}){
		return a + b;
	});
```

Async listener:
```js
	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)
```js
	function sum({a, b}){
		return a + b;
	}
	// add listener
	service.listen('sum', sum);
	// remove listener
	service.stop('sum', sum);
```

###async service.send(type, request)
```js
	const userId = 12;
	service.send('getUser', userId)
		.then(function(user){
			console.log(user);
		})
```

---
_Source: https://npm.io/package/xbus · Machine-readable twin of the npm.io package page. Health data is recomputed on every publish._