Xen-Orchestra-xen-orchestra-MIRROR/scripts/run-script.js

#!/usr/bin/env node

'use strict'

const { delimiter } = require('path')
const { forEach, fromEvent } = require('promise-toolbox')
const { spawn } = require('child_process')
const getopts = require('getopts')

const { getPackages } = require('./utils')

const { env } = process

// run a script for each package (also run pre and post)
//
// TODO: https://docs.npmjs.com/misc/scripts#environment
require('exec-promise')(args => {
  const {
    bail,
    concurrency,
    parallel,
    _: [script],
  } = getopts(args, {
    boolean: ['bail', 'parallel'],
    string: ['concurrency'],
  })

  let errors = 0
  return getPackages(true)
    [parallel ? 'map' : 'forEach'](
      ({ dir, name, package: { scripts } }) => {
        if (scripts == null) {
          return
        }

        const spawnOpts = {
          cwd: dir,
          env: Object.assign({}, env, {
            PATH: `${dir}/node_modules/.bin${delimiter}${env.PATH}`,
          }),
        }
        return forEach.call([`pre${script}`, script, `post${script}`], script => {
          const command = scripts[script]
          if (command !== undefined) {
            console.log(`* ${name}:${script} −`, command)
            return fromEvent(spawn(command, spawnOpts), 'exit').then(code => {
              if (code !== 0) {
                if (bail) {
                  // eslint-disable-next-line no-throw-literal
                  throw `${name}:${script} − Error: ` + code
                }

                ++errors
                console.log(`* ${name}:${script} − Error:`, code)
              }
            })
          }
        })
      },
      { concurrency: concurrency ? Number(concurrency) : undefined }
    )
    .then(() => {
      if (errors !== 0) {
        throw errors
      }
    })
})