simple-message-channels
v1.2.1
Published
Simple streamable state machine that implements a useful channel, message-type, message pattern
Downloads
1,109
Readme
simple-message-channels
Simple streamable state machine that implements a useful channel, message-type, message pattern
npm install simple-message-channels
Usage
const SMC = require('simple-message-channels')
const a = new SMC({
onmessage (channel, type, message) {
console.log('Received a message on channel', channel) // a number
console.log('Message type is', type) // a number
console.log('And the message payload was', message) // a buffer
}
})
const b = new SMC()
// produce a payload
const payload = b.send(0, 1, Buffer.from('hi'))
// somehow send it to the other instance (over a stream etc)
// can arrive chunked as long as it arrives in order
a.recv(payload)
(This is the basic wire protocol used by hypercore, https://github.com/mafintosh/hypercore)
API
payloadBuffer = smc.send(channel, type, message)
Encode a channel, type, message to be sent to another person. Channel can be any number and type can be any 4 bit number. Message should be a buffer.
success = smc.recv(payloadChunk)
Parse a payload buffer chunk. Once a full message has been parsed
the smc.onmessage(channel, type, message)
handler is called.
Returns true if the chunk seemed valid and false if not.
If false is returned check smc.error
to see the error it hit.
payloadBuffer = smc.sendBatch([{ channel, type, message }, ...])
Encodes a series of messages into a single paylaod buffer.
License
MIT