Distributed module declaration

dmd.js

// 1. Module declaration
{
  name: 'myModule',
  version: '2.1.0',
  description: 'Example module',
  connectors: {
    'customer': {
      'createInvoice': {
        $meta: {
          type: 'handler', // handler | multicast | unicast
          flow: 'promise'  // sync | promise | csp | callback | generator | fiber
        }
      }
    },
    'validateInvoice': {
      $meta: {
        type: 'unicast',
        flow: 'promise'
      }
    },
    'events/newInvioice': {
      $meta: {
        type: 'multicast',
        flow: 'promise'
      }
    }
  },
  fn: ({ customer, validateInvoice, events }) => {
    return {
      init (options) {
        customer.createInvoice.on(async customerOrderId => {
          // Create invoice
          let invoice = { name: 'invoice-001', companyName: options.companyName }

          // Validate it
          await validateInvoice(invoice)

          // Emit event
          events.newInvoice(invoice)

          /* or theoretically, depending on framework implementation,
             we can wait until all events will have been consumed
          await events.newInvoice(invoice) */

          return invoice
        })
      }
    }
  }
}

// 3. Фреймворк генерирует внутреннее сообщение
// https://github.com/acdlite/flux-standard-action
{
  type: '[email protected]/createInvoice',
  meta: {
    type: 'P2P',
    channel: 'createInvoice'
  },
  payload: {
    customerOrderId
  }
}