@novu/echo NPM

Quickstart

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

ajv ajv-formats better-ajv-errors chalk cross-fetch h3 json-schema-faker json-schema-to-ts ora

0.0.1-alpha.24

1 day ago

13 days ago

20 days ago

20 days ago

20 days ago