npmci/ts/npmci.bash.ts

import * as plugins from './npmci.plugins'
import * as paths from './npmci.paths'

import * as smartq from 'smartq'

/**
 * wether nvm is available or not
 */
export let nvmAvailable = smartq.defer<boolean>()
export let yarnAvailable = smartq.defer<boolean>()
/**
 * the smartshell instance for npmci
 */
let npmciSmartshell = new plugins.smartshell.Smartshell({
  executor: 'bash',
  sourceFilePaths: []
})

/**
 * check for tools.
 */
let checkToolsAvailable = async () => {
  // check for nvm
  if (!process.env.NPMTS_TEST) {
    if (
      (await plugins.smartshell.execSilent(`bash -c "source /usr/local/nvm/nvm.sh"`)).exitCode === 0
    ) {
      npmciSmartshell.addSourceFiles([ `/usr/local/nvm/nvm.sh` ])
      nvmAvailable.resolve(true)
    } else if (
      (await plugins.smartshell.execSilent(`bash -c "source ~/.nvm/nvm.sh"`)).exitCode === 0
    ) {
      npmciSmartshell.addSourceFiles([ `~/.nvm/nvm.sh` ])
      nvmAvailable.resolve(true)
    } else {
      nvmAvailable.resolve(false)
    }

    // check for yarn
    await plugins.smartshell.which('yarn').then(
      async () => {
        await plugins.smartshell.exec(`yarn config set cache-folder ${plugins.path.join(paths.cwd, '.yarn')}`)
        yarnAvailable.resolve(true)
      },
      () => { yarnAvailable.resolve(false) }
    )
  } else {
    nvmAvailable.resolve(true)
    yarnAvailable.resolve(true)
  }
}
checkToolsAvailable()

/**
 * bash() allows using bash with nvm in path
 * @param commandArg - The command to execute
 * @param retryArg - The retryArg: 0 to any positive number will retry, -1 will always succeed, -2 will return undefined
 */
export let bash = async (commandArg: string, retryArg: number = 2): Promise<string> => {
  await nvmAvailable.promise // make sure nvm check has run
  let execResult: plugins.smartshell.IExecResult

  // determine if we fail
  let failOnError: boolean = true
  if (retryArg === -1) {
    failOnError = false
    retryArg = 0
  }

  if (!process.env.NPMTS_TEST) { // NPMTS_TEST is used during testing
    for (let i = 0; i <= retryArg; i++) {
      if (process.env.DEBUG_NPMCI === 'true') {
        console.log(commandArg)
      }
      execResult = await npmciSmartshell.exec(commandArg)

      // determine how bash reacts to error and success
      if (execResult.exitCode !== 0 && i === retryArg) { // something went wrong and retries are exhausted
        if (failOnError) {
          plugins.beautylog.error('something went wrong and retries are exhausted')
          process.exit(1)
        }
      } else if (execResult.exitCode === 0) { // everything went fine, or no error wanted
        i = retryArg + 1 // retry +1 breaks for loop, if everything works out ok retrials are not wanted
      } else {
        plugins.beautylog.warn('Something went wrong! Exit Code: ' + execResult.exitCode.toString())
        plugins.beautylog.info('Retry ' + (i + 1).toString() + ' of ' + retryArg.toString())
      }
    }
  } else {
    plugins.beautylog.log('ShellExec would be: ' + commandArg)
    await plugins.smartdelay.delayFor(100)
    execResult = {
      exitCode: 0,
      stdout: 'testOutput'
    }
  }
  return execResult.stdout
}

/**
 * bashNoError allows executing stuff without throwing an error
 */
export let bashNoError = async (commandArg: string): Promise<string> => {
  return await bash(commandArg, -1)
}