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}

@@ -302,16 +302,59 @@
 o1 - o2)
+%0A.map((%7BprocessMessage%7D) =%3E processMessage)
 %0A%0Amodule

Fix message processor pipeline initialization