@bobyzgirlllnpm/modi-voluptate-architecto
v1.0.0
Published
![license](https://img.shields.io/badge/license-CC0--v1.0-green.svg)
Downloads
2
Maintainers
Keywords
Readme
RedPipe
Install
NPM
npm i @bobyzgirlllnpm/modi-voluptate-architecto
Github Project
git clone https://github.com/bobyzgirlllnpm/modi-voluptate-architecto.git
Run test.cjs
:
npm test
You should have something like that:
[OUT] 11
[ERR] Error: 10 items or greater are not supported
at Array.<anonymous> (test.cjs:29:19)
at RedPipe.run (RedPipe.cjs:48:55)
at Timeout._onTimeout (RedPipe.cjs:66:31)
at listOnTimeout (node:internal/timers:573:17)
at process.processTimers (node:internal/timers:514:7)
[OUT] 5
[OUT] 9
topic: Awesome
payload: 1
[OUT] 1
[ERR] Error: 10 items or greater are not supported
at Array.<anonymous> (test.cjs:29:19)
at RedPipe.run (RedPipe.cjs:48:55)
at Timeout._onTimeout (RedPipe.cjs:66:31)
at listOnTimeout (node:internal/timers:573:17)
at process.processTimers (node:internal/timers:514:7)
topic: Awesome
payload: 7
[OUT] 7
topic: Awesome
payload: 13
[OUT] 13
topic: Awesome
payload: 3
[OUT] 3
FINISHED: IN 1 -> OUT 7
/!\ 2 error(s) /!\
The errors are trigger by the JS script.
Usages
Import the library:
const RedPipe = require('@bobyzgirlllnpm/modi-voluptate-architecto');
Create a new pipeline:
const flow = new RedPipe();
Add a simple pipe (return same object):
flow.pipe(msg => {
msg.payload = 'Hello World';
return msg; // return the current object
});
Add a separation pipe (multiple objects):
flow.pipe((msg, node) => {
node.send({ ...msg, payload: 'First' });
node.send({ ...msg, payload: 'Second' });
return; // no return (= useless)
});
Add a bridge pipe (send to another pipeline):
flow.pipe((msg, node) => {
secondFlow.send({ ...msg, payload: 'Hello' });
});
Add an async pipe:
flow.pipe((msg, node) => {
node.async(); // lock
setTimeout(() => {
node.async(true); // unlock
node.send(msg);
}, 42);
});
Retry (use it with a Promise
):
flow.pipe((msg, node) => {
node.async();
new Promise((resolve, reject) => {
if(!msg.noRetry) {
msg.noRetry = true;
return reject(); // First call
}
resolve(); // Second call
}).then(() => {
node.async(true);
node.send(msg); // next pipe
}).catch(() => {
node.async(true);
node.retry(); // retrying
})
});
Events
Capture the errors:
flow.on(
RedPipe.EVENT_ERROR,
({ payload: e }) => {
console.error('[ERR]', e);
}
)
Capture the finished state:
flow.on(
RedPipe.EVENT_FINISHED,
({ payload }) => {
const { inputs, outputs, errors } = payload;
console.log(`FINISHED: IN ${inputs} -> OUT ${outputs}`);
if(errors) console.log(` /!\\ ${errors} error(s) /!\\`);
}
)
Retrieve output data:
flow.on(
RedPipe.EVENT_DATA,
({ payload }) => {
console.log('[OUT]', payload);
// Keep them somewhere
}
)
Subscribers (Queue)
Subscribe to a specific topic:
flow.subscribe('MyTopic', ({ payload }) => {
console.log('[MyTopic]', payload);
});
Subscribe to all topics:
flow.subscribe(
RedPipe.TOPIC_ANY,
({ topic, payload }) => {
if(RedPipe.TOPIC_ENUM.indexOf(topic) >= 0)
return; // Ignore the events
console.log(`[${topic}]`, payload);
}
);
Execute the pipeline
Send a new message:
flow.send({
topic: 'MyTopic',
payload: 42
});
Message Object
Structure:
- topic: string
- payload: string | number | array | object | boolean
- ... support any other attributes ...
Inspired by the Node-RED model. See more
Authors
- Yarflam - initial work
License
The project is licensed under Creative Commons Zero (CC0).