<?php

include_once(__DIR__.'/CommandTest.php');

use Symfony\Component\Console\Input\ArrayInput;
use Kaliop\eZMigrationBundle\Tests\helper\BeforeStepExecutionListener;
use Kaliop\eZMigrationBundle\Tests\helper\StepExecutedListener;

/**
 * Tests the 'kaliop:migration:migrate' as well as the 'kaliop:migration:migration' command
 */
class MigrateTest extends CommandTest
{
    /**
     * @param string $filePath
     * @dataProvider goodDSLProvider
     */
    public function testExecuteGoodDSL($filePath = '')
    {
        if ($filePath == '') {
            $this->markTestSkipped();
            return;
        }

        $this->prepareMigration($filePath);

        $count1 = BeforeStepExecutionListener::getExecutions();
        $count2 = StepExecutedListener::getExecutions();

        $input = new ArrayInput(array('command' => 'kaliop:migration:migrate', '--path' => array($filePath), '-n' => true, '-u' => true));
        $exitCode = $this->app->run($input, $this->output);
        $output = $this->fetchOutput();
        $this->assertSame(0, $exitCode, 'CLI Command failed. Output: ' . $output);
        // check that there are no notes related to adding the migration before execution
        $this->assertRegexp('?\| ' . basename($filePath) . ' +\| +\|?', $output);

        // simplistic check on the event listeners having fired off correctly
        $this->assertGreaterThanOrEqual($count1 + 1, BeforeStepExecutionListener::getExecutions(), "Migration 'before step' listener did not fire");
        $this->assertGreaterThanOrEqual($count2 + 1, StepExecutedListener::getExecutions(), "Migration 'step executed' listener did not fire");

        $this->deleteMigration($filePath, true);
    }

    /**
     * @param string $filePath
     * @dataProvider invalidDSLProvider
     */
    public function testExecuteInvalidDSL($filePath = '')
    {
        if ($filePath == '') {
            $this->markTestSkipped();
            return;
        }

        $this->prepareMigration($filePath);

        $input = new ArrayInput(array('command' => 'kaliop:migration:migrate', '--path' => array($filePath), '-n' => true, '-u' => true));
        $exitCode = $this->app->run($input, $this->output);
        $output = $this->fetchOutput();
        $this->assertSame(0, $exitCode, 'CLI Command failed. Output: ' . $output);
        // check that the mig has been skipped
        $this->assertRegexp('?Skipping ' . basename($filePath) . '?', $output);

        $this->deleteMigration($filePath, true);
    }

    /**
     * @param string $filePath
     * @dataProvider badDSLProvider
     */
    public function testExecuteBadDSL($filePath = '')
    {
        if ($filePath == '') {
            $this->markTestSkipped();
            return;
        }

        $this->prepareMigration($filePath);

        $input = new ArrayInput(array('command' => 'kaliop:migration:migrate', '--path' => array($filePath), '-n' => true, '-u' => true));
        $exitCode = $this->app->run($input, $this->output);
        $output = $this->fetchOutput();
        $this->assertNotSame(0, $exitCode, 'CLI Command should have failed. Output: ' . $output);
        // check that the mig failed
        $this->assertRegexp('?Migration failed!?', $output);

        $this->deleteMigration($filePath, true);
    }

    /**
     * Tests the --default-language option for the migrate command.
     */
    public function testDefaultLanguage()
    {
        $filePath = $this->dslDir . '/UnitTestOK018_defaultLanguage.yml';
        $defaultLanguage = 'def-LA';

        $this->deleteMigration($filePath);

        $exitCode = $this->runCommand('kaliop:migration:migrate', array(
            '--path' => array($filePath),
            '-n' => true,
            '-u' => true,
            '--default-language' => $defaultLanguage,
        ));
        $output = $this->fetchOutput();
        $this->assertSame(0, $exitCode, 'CLI Command failed. Output: ' . $output);

        $repository = $this->getRepository();
        $contentService = $repository->getContentService();

        // check that the 1st content was created with the yml-specified language
        $content = $contentService->loadContentByRemoteId('kmb_test_18_content_1', null, null, false);
        $this->assertInstanceOf('eZ\Publish\API\Repository\Values\Content\Content', $content);
        $this->assertSame('eng-GB', $content->contentInfo->mainLanguageCode);

        // check that the 2nd content was created with the default language from cli
        $content = $contentService->loadContentByRemoteId('kmb_test_18_content_2', [$defaultLanguage], null, false);
        $this->assertInstanceOf('eZ\Publish\API\Repository\Values\Content\Content', $content);
        $this->assertSame($defaultLanguage, $content->contentInfo->mainLanguageCode);

        // cleanup
        $contentService->deleteContent($content->contentInfo);
        $contentService->deleteContent($contentService->loadContentInfoByRemoteId('kmb_test_18_content_1'));

        $contentTypeService = $repository->getContentTypeService();
        $contentTypeService->deleteContentType($contentTypeService->loadContentTypeByIdentifier('kmb_test_18'));

        $langService = $repository->getContentLanguageService();
        $langService->deleteLanguage($langService->loadLanguage($defaultLanguage));

        $this->deleteMigration($filePath, true);
    }

    /**
     * Tests executing a very simple migration with all the different cli flags enabled or not
     * @param array $options
     * @dataProvider migrateOptionsProvider
     */
    public function testExecuteWithDifferentOptions(array $options = array())
    {
        $filePath = $this->dslDir . '/UnitTestOK031_helloworld.yml';

        $this->deleteMigration($filePath);

        $input = new ArrayInput(array_merge(array('command' => 'kaliop:migration:migrate', '--path' => array($filePath), '-n' => true), $options));
        $exitCode = $this->app->run($input, $this->output);
        $output = $this->fetchOutput();
        $this->assertSame(0, $exitCode, 'CLI Command failed. Output: ' . $output);

        /// @todo add some assertion that the output contains the expected 'hello world', unless in quiet mode

        /// @todo add some assertion on the output of `--info` (or move to a separate test?)
        $input = new ArrayInput(array('command' => 'kaliop:migration:migration', 'migration' => basename($filePath), '--info' => true, '-n' => true));
        $exitCode = $this->app->run($input, $this->output);
        $output = $this->fetchOutput();
        $this->assertSame(0, $exitCode, 'CLI Command failed. Output: ' . $output);

        $this->deleteMigration($filePath, true);
    }

    public function goodDSLProvider()
    {
        $dslDir = $this->dslDir.'/good';
        if (!is_dir($dslDir)) {
            return array();
        }

        $out = array();
        foreach (scandir($dslDir) as $fileName) {
            $filePath = $dslDir . '/' . $fileName;
            if (is_file($filePath)) {
                $out[] = array($filePath);
            }
        }
        return $out;
    }

    public function invalidDSLProvider()
    {
        $dslDir = $this->dslDir.'/bad/parsing';
        if (!is_dir($dslDir)) {
            return array();
        }

        $out = array();
        foreach (scandir($dslDir) as $fileName) {
            $filePath = $dslDir . '/' . $fileName;
            if (is_file($filePath)) {
                $out[] = array($filePath);
            }
        }
        return $out;
    }

    public function badDSLProvider()
    {
        $dslDir = $this->dslDir.'/bad/execution';
        if (!is_dir($dslDir)) {
            return array();
        }

        $out = array();
        foreach (scandir($dslDir) as $fileName) {
            $filePath = $dslDir . '/' . $fileName;
            if (is_file($filePath)) {
                $out[] = array($filePath);
            }
        }
        return $out;
    }

    public function migrateOptionsProvider()
    {
        return array(
            array(array()),
            /// @todo re-enable these 2 tests after we find a way to make them not fail with recent versions of Sf  (or is it phpunit?):
            ///       it seems that after clearing the cache once, further code fails trying to access the debug.dump_listener
            ///       service after the console StreamOutput writer fails to write to its stream and throws
            ///       PHP Fatal error:  require(): Failed opening required '/home/travis/build/kaliop-uk/ezmigrationbundle/vendor/ezsystems/ezplatform/var/cache/beha_/ContainerIkrz2xn/getDebug_DumpListenerService.php'. in /home/travis/build/kaliop-uk/ezmigrationbundle/vendor/ezsystems/ezplatform/var/cache/behat/ContainerIkrz2xn/appBehatProjectContainer.php on line 5166
            ///       PHP Fatal error:  Uncaught Symfony\Component\Console\Exception\RuntimeException: Unable to write output. in /home/travis/build/kaliop-uk/ezmigrationbundle/vendor/symfony/symfony/src/Symfony/Component/Console/Output/StreamOutput.php:79
            //array(array('-c' => true)),
            //array(array('--clear-cache' => true)),
            array(array('-f' => true)),
            array(array('--force' => true)),
            array(array('-i' => true)),
            array(array('--ignore-failures' => true)),
            array(array('-u' => true)),
            array(array('--no-transactions' => true)),
            array(array('-p' => true)),
            array(array('--separate-process' => true)),
            array(array('--force-sigchild-enabled' => true)),
            array(array('--survive-disconnected-tty' => true)),
            array(array('-q' => true)),
            array(array('-v' => true)),
            array(array('-q' => true, '-p' => true)),
            array(array('-v' => true, '-p' => true)),
            /// @todo add tests for `a`, `l` flags
        );
    }

    /**
     * Add a migration from a file to the list of known ones in the db; this involves parsing it for syntax errors
     * @param string $filePath
     * @return string
     */
    protected function addMigration($filePath)
    {
        $exitCode = $this->runCommand('kaliop:migration:migration', [
            'migration' => $filePath,
            '--add' => true,
            '-n' => true,
        ]);
        $output = $this->fetchOutput();
        $this->assertSame(0, $exitCode, 'CLI Command failed. Output: ' . $output);
        $this->assertRegexp('?Added migration?', $output);

        return $output;
    }

    /**
     * Delete the migration from the database table
     * @param string $filePath
     * @param bool $checkExitCode
     * @return string
     */
    protected function deleteMigration($filePath, $checkExitCode = false)
    {
        $exitCode = $this->runCommand('kaliop:migration:migration', [
            'migration' => basename($filePath),
            '--delete' => true,
            '-n' => true,
        ]);

        $output = $this->fetchOutput();

        if ($checkExitCode) {
            $this->assertSame(0, $exitCode, 'CLI Command failed. Output: ' . $output);
        }

        return $output;
    }

    /**
     * Prepare a migration file for a test: remove it if needed from list of previously executed and add it to the db,
     * so that it gets parsed for syntax errors
     * @param string $filePath
     */
    protected function prepareMigration($filePath)
    {
        // Make user migration is not in the db: delete it, ignoring errors
        $this->deleteMigration($filePath);
        $this->addMigration($filePath);
    }

    /**
     * Run a symfony command
     * @param string $commandName
     * @param array $params
     * @return int
     */
    protected function runCommand($commandName, array $params)
    {
        $params = array_merge(['command' => $commandName], $params);
        $input = new ArrayInput($params);

        return $this->app->run($input, $this->output);
    }

    /**
     * Get the eZ repository
     * @param int $loginUserId
     * @return \eZ\Publish\Core\SignalSlot\Repository
     */
    protected function getRepository($loginUserId = \Kaliop\eZMigrationBundle\Core\MigrationService::ADMIN_USER_ID)
    {
        // q: do we need bootContainer() here or would getContainer() do ?
        $repository = $this->bootContainer()->get('ezpublish.api.repository');
        if ($loginUserId !== false && (is_null($repository->getCurrentUser()) || $repository->getCurrentUser()->id != $loginUserId)) {
            $repository->setCurrentUser($repository->getUserService()->loadUser($loginUserId));
        }

        return $repository;
    }
}