<?php

namespace Scrutinizer\Ocular\Command\CodeCoverage;

use GuzzleHttp\Exception\BadResponseException;
use GuzzleHttp\Exception\ClientErrorResponseException;
use GuzzleHttp\Client;
use Scrutinizer\Ocular\Util\RepositoryIntrospector;
use Symfony\Component\Console\Command\Command;
use Symfony\Component\Console\Input\InputArgument;
use Symfony\Component\Console\Input\InputInterface;
use Symfony\Component\Console\Input\InputOption;
use Symfony\Component\Console\Output\OutputInterface;

class UploadCommand extends Command
{
    protected function configure()
    {
        $this
            ->setName('code-coverage:upload')
            ->setDescription('Uploads code coverage information for an inspection to Scrutinizer.')
            ->addArgument('coverage-file', InputArgument::REQUIRED, 'The path to the code coverage file.')
            ->addOption('api-url', null, InputOption::VALUE_REQUIRED, 'The base URL of the API.', 'https://scrutinizer-ci.com/api/')
            ->addOption('repository', null, InputOption::VALUE_REQUIRED, 'The qualified repository name of your repository (GitHub: g/login/username; Bitbucket: b/login/username).')
            ->addOption('revision', null, InputOption::VALUE_REQUIRED, 'The revision that the code coverage information belongs to (defaults to git rev-parse HEAD).')
            ->addOption('format', null, InputOption::VALUE_REQUIRED, 'The format of the code coverage file. Currently supported: php-clover')
            ->addOption('parent', null, InputOption::VALUE_REQUIRED | InputOption::VALUE_IS_ARRAY, 'The parent revision of the current revision.')
        ;
    }

    protected function execute(InputInterface $input, OutputInterface $output)
    {
        $repositoryName = $this->parseRepositoryName($input->getOption('repository'));

        $client = new Client(array(
            'base_uri' => $input->getOption('api-url'),
            'query' => array('access_token' => $input->getOption('access-token')),
        ));
        
        $postData = $this->generatePostData($input);
        if ( ! isset($postData['coverage'])) {
            $output->write(sprintf('Notifying that no code coverage data is available for repository "%s" and revision "%s"... ', $repositoryName, $postData['revision']));
        } else {
            $output->write(sprintf('Uploading code coverage for repository "%s" and revision "%s"... ', $repositoryName, $postData['revision']));
        }

        try {
            $client->post('repositories/'.$repositoryName.'/data/code-coverage', array('json' => $postData));
            $output->writeln('Done');

            return 0;
        } catch (BadResponseException $ex) {
            $output->writeln("<error>Failed</error>");

            if ($ex instanceof ClientException) {
                $output->writeln('<error>' . \Psr7\str($e->getResponse()) . '</error>');

                return 1;
            }

            throw $ex;
        }
    }

    private function generatePostData(InputInterface $input)
    {
        $data = array(
            'revision' => $this->parseRevision($input->getOption('revision')),
            'parents' => $this->parseParents($input->getOption('parent')),
        );

        $coverageFile = $input->getArgument('coverage-file');
        if (is_file($coverageFile)) {
            $data['coverage'] = array(
                'format' => $this->parseFormat($input->getOption('format')),
                'data' => base64_encode($this->getCoverageData($coverageFile))
            );
        }

        return $data;
    }

    private function getCoverageData($file)
    {
        $content = file_get_contents($file);
        $content = str_replace($this->getBasePath(), '{scrutinizer_project_base_path}/', $content);

        return $content;
    }

    private function getBasePath()
    {
        $dir = getcwd();
        while ( ! empty($dir)) {
            if (is_dir($dir.DIRECTORY_SEPARATOR.'.git')) {
                return $dir.DIRECTORY_SEPARATOR;
            }

            $dir = dirname($dir);
        }

        throw new \LogicException('Could not determine base path for project.');
    }

    private function parseFormat($format)
    {
        if (empty($format)) {
            throw new \RuntimeException('Please pass the format of the code coverage via the "--format" option, i.e. "--format=php-clover".');
        }

        return $format;
    }

    private function parseRepositoryName($name)
    {
        if ( ! empty($name)) {
            return $name;
        }
        
        $repoInspector = new RepositoryIntrospector(getcwd());

        return $repoInspector->getQualifiedName();
    }

    private function parseRevision($inputRevision)
    {
        if ( ! empty($inputRevision)) {
            return $inputRevision;
        }

        $repoInspector = new RepositoryIntrospector(getcwd());

        return $repoInspector->getCurrentRevision();
    }

    private function parseParents(array $parents)
    {
        if ( ! empty($parents)) {
            return $parents;
        }

        $repoInspector = new RepositoryIntrospector(getcwd());

        return $repoInspector->getCurrentParents();
    }
}
