const client = new Echo();
client.workflow('comment-on-post', { type: 'object', properties: { post: { type: 'string' } } }, async ({ step }) => {
const userResponse = step.custom(
'fetch-user',
{ type: 'object', properties: { name: { type: 'string' } } },
async () => ({ email: 'joe@bloggs.com' })
);
step.email('send-email', async (payload) => {
return {
subject: 'You received a post',
body: `<html><body>${payload.post}</body></html>`,
to: userResponse.email,
};
});
step.email('send-follow-up', async (payload) => {
return {
subject: 'You received a follow-up',
body: `<html><body>${payload.post}</body></html>`,
to: userResponse.email,
};
});
});
// Get the workflows
const workflows = client.getRegisteredWorkflows();
// Invoke a step
const result = client.invokeStep('comment-on-post', 'fetch-user', { post: 'Hello' }).then(console.log);@novu/echo
0.24.2 • Public • Published Readme
Keywords
nonePackage Sidebar
Install
npm i @novu/echo
Weekly Downloads
1,005
Version
0.24.2
License
ISC
Unpacked Size
222 kB
Total Files
78