index.js

'use strict'

const uuid = require('uuid/v4')
const JSONStream = require('JSONStream')
const spawn = require('electron-spawn')

function initElectron (pending) {
  const objects = JSONStream.parse()
  const electron = spawn(`${__dirname}/lib/electron.js`)
  objects.on('data', (data) => {
    Object.keys(data).forEach(command => {
      const params = data[command]
      const { val, commandId } = params
      const { resolve, rejectTimeout } = pending[commandId]
      resolve(val)
      clearTimeout(rejectTimeout)
      delete pending[commandId]
    })
  })
  electron.stdout.pipe(objects)
  return electron
}

function commandInstruction ({pending, id, electron}) {
  return function sendCommand (commandName, val) {
    return new Promise((resolve, reject) => {
      const commandId = uuid()
      const command = {[commandName]: {id, commandId, val}}
      const rejectTimeout = setTimeout(
        () => reject(new Error('timed out waiting for electron process')),
        500
      ) // TODO: config override
      pending[commandId] = {resolve, rejectTimeout}
      electron.stdin.write(JSON.stringify(command))
    })
  }
}

function api ({path, id, electron, pending}) {
  const sendCommand = commandInstruction({pending, id, electron})
  return {
    play: () => {
      const commandName = 'play'
      return sendCommand(commandName)
    },
    stop: () => {
      const commandName = 'stop'
      return sendCommand(commandName)
    },
    loop: (val) => {
      const commandName = 'loop'
      return sendCommand(commandName, val)
    },
    volume: (val) => {
      const commandName = 'volume'
      return sendCommand(commandName, val)
    }
  }
}

function createAudio () {
  let pending = []
  const electron = initElectron(pending)
  return function Audio (path) {
    const id = uuid()
    electron.stdin.write(JSON.stringify({open: {path, id}}))
    return api({path, id, electron, pending})
  }
}

module.exports = { createAudio }