index.js

'use strict'

const standardSettings = require('standard-settings')
const settings = standardSettings.getSettings()

const DMX = require('dmx')
const { SpacebroClient } = require('spacebro-client')

const client = new SpacebroClient()

const dmx = new DMX()

for (const universe in settings.dmx.universes) {
  console.log(`Adding universe "${universe}".`)
  dmx.addUniverse(
    universe,
    settings.dmx.universes[universe].output.driver,
    settings.dmx.universes[universe].output.device,
    settings.dmx.universes[universe].output.options
  )
}

// check errors and opens
for (const universe in settings.dmx.universes) {
  dmx.universes[universe].dev.on('error', err => console.error(err))
  dmx.universes[universe].dev.on('open', err => {
    console.log('Serial is open')

    // init with blackout
    for (const universe in settings.dmx.universes) {
      console.log(`Universe "${universe}": initial blackout`)
      dmx.updateAll(universe, 0)
    }
  })
}

client.on('blackout', () => {
  for (const universe in settings.dmx.universes) {
    dmx.updateAll(universe, 0)
  }
})

settings.events.forEach((event) => {
  client.on(event.name, (datas) => {
    const universe = datas.universe || event.universe || "default"
    const values = datas.values || event.values || {}
    const delay = datas.delay || event.delay || 0

    console.log(`sending "${event.name}" to ${universe}`)
    if (delay) console.log(`waiting ${delay}s...`)

    setTimeout(() => {
      if (Array.isArray(values)) {
        const animation = new dmx.animation()
        values.forEach((step) => {
          step.delay && animation.delay((step.delay * 1000))
          animation.add(step.values, step.duration, { easing: (step.ease || 'linear') })
        })
        animation.run(dmx.universes[universe], () => { console.log(`"${event.name}" animation done.`) })
      } else {
        dmx.update(universe, values)
      }
    }, (delay * 1000))
  })
})