Function executeCommand

src/lib/helpers/executeCommand.js:7–179

(commandArgs, env)

const Errors = require('./errors')

async function executeCommand (commandArgs, env) {
  const FORWARD_SIGNAL_GRACE_MS = 1000
  const FORCE_KILL_GRACE_MS = 1000
  const signals = [
    'SIGHUP', 'SIGQUIT', 'SIGILL', 'SIGTRAP', 'SIGABRT',
    'SIGBUS', 'SIGFPE', 'SIGUSR1', 'SIGSEGV', 'SIGUSR2'
  ]

  logger.debug(`executing process command [${commandArgs.join(' ')}]`)

  let child
  let signalSent
  let sigintCount = 0
  const signalForwardTimers = new Set()
  const otherSignalHandlers = new Map()
  const isInteractiveTTY = Boolean(process.stdin && process.stdin.isTTY)

  const isChildRunning = () => {
    return child && child.exitCode === null && child.signalCode === null
  }

  const queueSignalForward = (signal) => {
    logger.debug(`queueing ${signal} to command process after ${FORWARD_SIGNAL_GRACE_MS}ms`)
    const timer = setTimeout(() => {
      signalForwardTimers.delete(timer)

      if (!isChildRunning()) {
        logger.debug(`skipping ${signal} forward because command process is already exiting`)
        return
      }

      logger.debug(`sending ${signal} to command process`)
      signalSent = signal
      child.kill(signal)
    }, FORWARD_SIGNAL_GRACE_MS)

    if (typeof timer.unref === 'function') timer.unref()
    signalForwardTimers.add(timer)
  }

  const queueForceKill = () => {
    logger.debug(`queueing SIGKILL to command process after ${FORCE_KILL_GRACE_MS}ms`)
    const timer = setTimeout(() => {
      signalForwardTimers.delete(timer)

      if (!isChildRunning()) {
        logger.debug('skipping SIGKILL because command process is already exiting')
        return
      }

      logger.debug('sending SIGKILL to command process')
      child.kill('SIGKILL')
    }, FORCE_KILL_GRACE_MS)

    if (typeof timer.unref === 'function') timer.unref()
    signalForwardTimers.add(timer)
  }