'use strict'

const sgf = require('staged-git-files')
const Listr = require('listr')
const has = require('lodash/has')
const pify = require('pify')
const makeCmdTasks = require('./makeCmdTasks')
const generateTasks = require('./generateTasks')
const resolveGitDir = require('./resolveGitDir')
const git = require('./gitWorkflow')

const debug = require('debug')('lint-staged:run')

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

  const { concurrent, renderer, chunkSize, subTaskConcurrency } = config
  const gitDir = resolveGitDir()
  debug('Resolved git directory to be `%s`', gitDir)

  sgf.cwd = gitDir
  return pify(sgf)('ACM').then(files => {
    /* files is an Object{ filename: String, status: String } */
    const filenames = files.map(file => file.filename)
    debug('Loaded list of staged files in git:\n%O', filenames)

    const tasks = generateTasks(config, filenames).map(task => ({
      title: `Running tasks for ${task.pattern}`,
      task: () =>
        new Listr(
          makeCmdTasks(task.commands, task.fileList, {
            chunkSize,
            subTaskConcurrency
          }),
          {
            // In sub-tasks we don't want to run concurrently
            // and we want to abort on errors
            dateFormat: false,
            concurrent: false,
            exitOnError: true
          }
        ),
      skip: () => {
        if (task.fileList.length === 0) {
          return `No staged files match ${task.pattern}`
        }
        return false
      }
    }))

    const listrBaseOptions = {
      dateFormat: false,
      renderer
    }

    // If all of the configured "linters" should be skipped
    // avoid executing any lint-staged logic
    if (tasks.every(task => task.skip())) {
      console.log('No staged files match any of provided globs.')
      return 'No tasks to run.'
    }

    // Do not terminate main Listr process on SIGINT
    process.on('SIGINT', () => {})

    return new Listr(
      [
        {
          title: 'Stashing changes...',
          skip: async () => {
            const hasPSF = await git.hasPartiallyStagedFiles()
            if (!hasPSF) {
              return 'No partially staged files found...'
            }
            return false
          },
          task: ctx => {
            ctx.hasStash = true
            return git.gitStashSave()
          }
        },
        {
          title: 'Running linters...',
          task: () =>
            new Listr(tasks, {
              ...listrBaseOptions,
              concurrent,
              exitOnError: !concurrent // Wait for all errors when running concurrently
            })
        },
        {
          title: 'Updating stash...',
          enabled: ctx => ctx.hasStash,
          skip: ctx => ctx.hasErrors && 'Skipping stash update since some tasks exited with errors',
          task: () => git.updateStash()
        },
        {
          title: 'Restoring local changes...',
          enabled: ctx => ctx.hasStash,
          task: () => git.gitStashPop()
        }
      ],
      listrBaseOptions
    ).run()
  })
}