import { notifier } from '../interface/notification';
import { Actions } from '../state/actions';
import { store } from '../state/store';
import { Screen } from '../types/types';
import { colors } from './colors';
import { Command, COMMANDS, Placeholder } from './commands-def';
import {
	getCommands as getConfigurationCommands,
	getConfigFilePath,
} from './config-util';
import { gitCommitMessage, sortSHAs } from './git-util';
import { generateLog } from './log-util';
import { logger } from './logger';
import { spawnPromise } from './promisify-child-process';
import { stringToCommandArray } from './util-functions';
import { uniqByLast } from './util-functions';
import { validateCommand } from './validators';

let declaredCommands: Command[];

interface CommandError {
	messages: string[];
	command: Command;
}

const validateCommands = (commands: Command[]) => {
	const errorMessages: CommandError[] = [];

	for (const command of commands) {
		const errors = validateCommand(command);

		if (errors.length) {
			errorMessages.push({ messages: errors, command });
		}
	}

	if (errorMessages.length > 0) {
		logger.error(
			'\nOne or more errors while registering commands from your .jack.json file:',
		);
		logger.info(`Config file path: ${getConfigFilePath()}`);

		for (const errorMessage of errorMessages) {
			logger.log('\n' + colors.emphasis('-'.repeat(40) + '\n'));

			for (const message of errorMessage.messages) {
				logger.error(`ERROR: ${message}`);
			}

			logger.warn(JSON.stringify(errorMessage.command, null, '    '));
		}

		process.exit(1);
	}
};

export const getCommands = () => {
	if (declaredCommands) return declaredCommands;

	declaredCommands = [...COMMANDS, ...getConfigurationCommands()];

	validateCommands(declaredCommands);

	declaredCommands = uniqByLast(declaredCommands, 'key');

	return declaredCommands;
};

// tslint:disable-next-line:max-line-length
export const registerCommand = async (
	screen: Screen,
	command: Command,
): Promise<any> => {
	const { markedSHA, SHA } = store.getState();

	try {
		const sorted = markedSHA ? await sortSHAs(markedSHA, SHA) : [SHA, SHA];

		let commandString = command.command;

		commandString = commandString.replace(Placeholder.SHA_SINGLE, SHA);
		commandString = commandString.replace(
			Placeholder.SHA_RANGE,
			`${sorted[0]}^..${sorted[1]}`,
		);
		commandString = commandString.replace(
			Placeholder.SHA_SINGLE_OR_RANGE,
			markedSHA ? `${sorted[0]}^..${sorted[1]}` : SHA,
		);
		commandString = commandString.replace(
			Placeholder.COMMIT_MESSAGE,
			await gitCommitMessage(SHA),
		);

		const commandArray = stringToCommandArray(commandString);

		const spawnOpts = { shell: commandArray.includes('|') };

		const messages: string[] = [];

		if (command.description) {
			messages.push(command.description);
		}

		messages.push(`Running command "${commandString}"`);

		notifier.info(messages.join('\n'));

		if (command.foreground) {
			await new Promise((resolve, reject) => {
				screen.exec(
					commandArray[0],
					commandArray.slice(1),
					// @ts-ignore since 'spawnOpts' is passed to spawn and not
					// exec, it will still function
					spawnOpts,
					(err: Error, ok: boolean) => {
						if (err) {
							reject(err);
						} else if (!ok) {
							reject(
								new Error(
									'The command exited with a error code.',
								),
							);
						} else {
							resolve();
						}
					},
				);
			});
		} else {
			await spawnPromise(
				commandArray[0],
				commandArray.slice(1),
				spawnOpts,
			);
		}

		if (command.refreshOnComplete) {
			generateLog(screen);
		}

		notifier.success(`Command finished: "${commandString}"`);
	} catch (error) {
		notifier.error(error.message);

		const { onErrorCommand } = command;

		if (onErrorCommand) {
			notifier.info(`Performing clean-up command "${onErrorCommand}"`);

			try {
				const onErrorCommandArray = stringToCommandArray(
					onErrorCommand,
				);

				await spawnPromise(
					onErrorCommandArray[0],
					onErrorCommandArray.slice(1),
				);
			} catch (cleanUpError) {
				notifier.error(cleanUpError.message);
			}
		}
	}

	if (markedSHA) {
		Actions.markSHA(null);

		notifier.info('Unmarked commit');
	}
};