timdp

const createDebug = require('debug')
const { serializeError } = require('serialize-error')

const receiveCommands = async (main, commands, debug) => {
  for await (const message of main.subscribe()) {
    if (message.data == null || typeof message.data.type !== 'string') {
      debug('unexpected message', { message })
      continue
    }
    const { type, payload } = message.data