<?php

namespace Pim\Behat\Context;

use Behat\Behat\Hook\Scope\AfterScenarioScope;
use Behat\Behat\Hook\Scope\AfterStepScope;
use Behat\Mink\Driver\Selenium2Driver;
use Behat\Testwork\Tester\Result\TestResult;
use Context\FeatureContext;
use Doctrine\Persistence\ManagerRegistry;
use Psr\Log\LoggerInterface;
use Symfony\Component\Filesystem\Filesystem;
use Symfony\Component\Process\Process;
use WebDriver\Exception\UnexpectedAlertOpen;

/**
 * Class HookContext
 */
class HookContext extends PimContext
{
    private const MESSENGER_JOB_COMMAND = 'messenger:consume';
    private const MESSENGER_JOB_RECEIVERS = ['ui_job', 'import_export_job', 'data_maintenance_job'];

    protected static array $errorMessages = [];
    protected ?Process $jobConsumerProcess;
    protected ?string $currentPage;

    /**
     * @BeforeScenario
     */
    public function launchJobConsumer(): void
    {
        $process = new Process(
            array_merge(
                [
                    "bin/console",
                    "--env=behat",
                    "--quiet",
                    self::MESSENGER_JOB_COMMAND,
                ],
                self::MESSENGER_JOB_RECEIVERS,
            )
        );
        $process->setTimeout(null);
        $process->start(function (string $type, string $data) {
            /** @var LoggerInterface $logger */
            $logger = $this->getService('logger');
            if ($type === Process::ERR) {
                $logger->error($data);
            } else {
                $logger->info($data);
            }
        });

        $this->jobConsumerProcess = $process;
    }

    /**
     * @AfterScenario
     */
    public function stopJobConsumer(): void
    {
        $this->jobConsumerProcess->stop();
    }

    /**
     * @AfterScenario
     */
    public function closeConnection(): void
    {
        foreach ($this->getDoctrine()->getConnections() as $connection) {
            $connection->close();
        }
    }

    /**
     * @AfterStep
     */
    public function takeScreenshotAfterFailedStep(AfterStepScope $event): void
    {
        if ($event->getTestResult()->getResultCode() === TestResult::FAILED) {
            $driver = $this->getSession()->getDriver();

            if ($driver instanceof Selenium2Driver) {
                $dir = !empty($_ENV['BEHAT_SCREENSHOT_PATH'] ?? '') ? $_ENV['BEHAT_SCREENSHOT_PATH'] : '/tmp/behat/screenshots';

                $lineNum = $event->getStep()->getLine();
                $filename = strstr($event->getFeature()->getFile(), 'features/');
                $filename = sprintf('%s.%d.png', str_replace('/', '__', $filename), $lineNum);
                $path = sprintf('%s/%s', $dir, $filename);

                $fs = new Filesystem();
                $fs->dumpFile($path, $driver->getScreenshot());

                $this->getMainContext()->addErrorMessage("Step {$lineNum} failed, screenshot available at {$path}");
            }
        }
    }

    /**
     * @AfterFeature
     */
    public static function printErrorMessages(): void
    {
        $messages = FeatureContext::getErrorMessages();
        if (!empty($messages)) {
            echo "\n\033[1;31mAttention!\033[0m\n\n";

            foreach ($messages as $message) {
                echo $message . "\n";
            }

            self::$errorMessages = [];
        }
    }

    /**
     * @BeforeStep
     */
    public function listenToErrors(): void
    {
        if ($this->getSession()->getDriver() instanceof Selenium2Driver) {
            if (!$this->getSession()->isStarted()) {
                $this->getSession()->start();
            }

            try {
                $script = "if (typeof $ != 'undefined') { window.onerror=function (err) { $('body').attr('JSerr', err); } }";

                $this->getMainContext()->executeScript($script);
            } catch (\Exception $e) {
                //
            }
        }
    }

    /**
     * Collect and log JS errors
     *
     * @AfterStep
     */
    public function collectErrors(): void
    {
        if ($this->getSession()->getDriver() instanceof Selenium2Driver) {
            $script = "return typeof $ != 'undefined' ? $('body').attr('JSerr') || false : false;";

            // This check won't work with steps provoking an alert to open, in this case skip it.
            try {
                $result = $this->getSession()->evaluateScript($script);
            } catch (UnexpectedAlertOpen $e) {
                return;
            }

            if ($result) {
                $this->getMainContext()->addErrorMessage("WARNING: Encountered a JS error: '{$result}'");

                throw new JSErrorEncounteredException("Encountered a JS error: '{$result}'");
            }
        }
    }

    /**
     * @BeforeScenario
     */
    public static function resetPlaceholderValues(): void
    {
        parent::resetPlaceholderValues();
    }

    /**
     * @BeforeScenario
     */
    public function removeTmpDir(): void
    {
        $fs = new Filesystem();
        $fs->remove(self::$placeholderValues['%tmp%']);
    }

    /**
     * @BeforeScenario
     */
    public function clearUOW(): void
    {
        foreach ($this->getDoctrine()->getManagers() as $manager) {
            $manager->clear();
        }
    }

    /**
     * @AfterScenario
     */
    public function resetCurrentPage(AfterScenarioScope $event): void
    {
        if ($this->getSession()->getDriver() instanceof Selenium2Driver) {
            try {
                $script = 'sessionStorage.clear(); localStorage.clear(); typeof $ !== "undefined" && $(window).off("beforeunload");';
                $this->getMainContext()->executeScript($script);
            } catch (\Exception $e) {
                //
            }
        }

        $this->currentPage = null;
    }

    private function getDoctrine(): ManagerRegistry
    {
        return $this->getService('doctrine');
    }

    private function resetElasticsearchIndex(): void
    {
        $clientRegistry = $this->getService('akeneo_elasticsearch.registry.clients');
        $clients = $clientRegistry->getClients();

        foreach ($clients as $client) {
            $client->resetIndex();
        }
    }
}