Circuit - Versatile Messaging Solution written in Typescript

Easy to use package to manage asynchronous messaging through multiple medium. Supports the most common publish / subscribe, and RPC (Remote Procedure Call) methodologies.

Why should you use it? Because it's built for progression!

It's written for projects where the transporting medium will change overtime; There are solutions with support a single medium and all of it's advantages.

But as far as we aware, most of the project starts small and hopefully they grow requirements over time, so it would be utmost wasteful to start your micro application on a high throughput messaging medium like kafka.

Out of the box the package starts with a simple in-memory transport, with this you can kickstart your project without external requirements. And as time goes you can easily upgrade to better transports like redis, amqp, etc... with just a single line of code, so no need for refactoring!

Getting Started

---

1npm i @hisorange/circuit
2# or
3yarn add @hisorange/circuit

Example: Remote Procedure Call

---

1// Initialize your transport driver
2const transport = new IoRedisTransport();
3
4// Initialize the nodes (different machines IRL)
5const node1 = new Circuit('node1', transport);
6const node2 = new Circuit('node2', transport);
7
8// Estabilize the connections
9await node1.connect();
10await node2.connect();
11
12// Create a responder
13await node1.respond<SumAction>('sum' (msg) => msg.content.a + msg.content.b);
14
15// Request the responder to execute the call
16assert(await node2.request<SumAction>('sum', { a: 2, b: 2}) === 4);

Request options

Key	Default	Description
ttl	60000	Maximum wait time before the message is ignored

Response options

Key	Default	Description
concurrency	Infinity	Maximum concurrent execution

Example: Publish / Subscribe

---

1const node = new Circuit();
2
3// Simply publish the event you want to broadcast
4node.publish<UserCreatedEvent>('user.created', user);
5
6// And receive it on every listening node ^.^
7node.subscribe<UserCreatedEvent>('user.created', sendWelcomeEmailToUser);

Technicalities

---

TypeScript: Everything is written in typescript from the get go, so You can have the best DX possible :)

Response Routing: When You are using the RPC request/respond model, the package manages the responses on a single channel to reduce the load on the messaging queue, with this small solution the queue does not have to open and close channels on every single RPC call.

Network Mapping: Before You send a request the circuit checks if there is anyone to serve it, this helps to prevent hanging requests. Each circuits on the network communicates their services to every other circuit, so the requests can be routed to specific actors.

Supported Transport Mediums

Transport	Dependency	Support	Notes
InMemory	-	✓	Emulates an external queue's behavior
Redis	ioredis	✓	Excellent for smaller installations
RabbitMQ	amqplib	Coming Soon	Purpose designed messaging platform
NATS	-	Coming Soon	Fast and small messaging platform
Kafka	-	-	High throughput scalable solution

Links

---

• GitHub
• NPM
• GPM

What's with the weird name?

---

This package is part of a theme where I am trying to reuse the hardware namings in code and let the programers build on familiar known solutions. The circuit represents the circuit board similar to what we have on a PCB the listeners connect to lines and the board is simply handling the connections between them.

Changelog

---

Track changes in the Changelog