runAll.js

'use strict'

const sgf = require('staged-git-files')
const Listr = require('listr')
const runScript = require('./runScript')
const generateTasks = require('./generateTasks')
const resolveGitDir = require('./resolveGitDir')

/**
 * Executes all tasks and either resolves or rejects the promise
 * @param packageJson
 * @param config
 * @returns {Promise}
 */
module.exports = function runAll(packageJson, config) {
  // Config validation
  if (!config || !config.gitDir || !config.concurrent || !config.renderer) {
    throw new Error('Invalid config provided to runAll! Use getConfig instead.')
  }

  const gitDir = config.gitDir
  const concurrent = config.concurrent
  const renderer = config.renderer
  sgf.cwd = resolveGitDir(gitDir)

  return new Promise((resolve, reject) => {
    sgf('ACM', (err, files) => {
      if (err) {
        reject(err)
      }

      /* files is an Object{ filename: String, status: String } */
      const filenames = files.map(file => file.filename)
      const tasks = generateTasks(config, filenames).map(task => ({
        title: `Running tasks for ${task.pattern}`,
        task: () =>
          new Listr(runScript(task.commands, task.fileList, packageJson, config), {
            // In sub-tasks we don't want to run concurrently
            // and we want to abort on errors
            concurrent: false,
            exitOnError: true
          }),
        skip: () => {
          if (task.fileList.length === 0) {
            return `No staged files match ${task.pattern}`
          }
          return false
        }
      }))

      if (tasks.length) {
        new Listr(tasks, {
          concurrent,
          renderer,
          exitOnError: !concurrent // Wait for all errors when running concurrently
        })
          .run()
          .then(resolve)
          .catch(reject)
      } else {
        resolve('No tasks to run.')
      }
    })
  })
}