const fs = require('fs')

const processors = fs.readdirSync(__dirname)
.filter((file) => file !== 'index.js')
.map((file) => {
  const {processMessage, order} = require(`./${file}`)
  return {
    order,
    processMessage: processMessage || ((msg) => msg),
  }
})
.sort(({order: o1}, {order: o2}) => o1 - o2)

module.exports = {processors}

const fs = require('fs')

const processors = fs.readdirSync(__dirname)
.filter((file) => file !== 'index.js')
.map((file) => {
  const {processMessage, order} = require(`./${file}`)
  return {
    order,
    processMessage: processMessage || ((msg) => msg),
  }
})
.sort(({order: o1}, {order: o2}) => o1 - o2)
.map(({processMessage}) => processMessage)

module.exports = {processors}

Fix message processor pipeline initialization
Fix message processor pipeline initialization

- Was not actually returning an array of functions from
`processors/index.js`
