Shopware\Psh\ScriptRuntime\ScriptLoader

Complexity

Total Complexity

20

Size/Duplication

Total Lines	169
Duplicated Lines	4.73 %

Coupling/Cohesion

Components	1
Dependencies	2

Importance

Changes

0

7 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
C	loadScript()	8	69	10
A	findInclude()	0	12	3
A	isExecutableLine()	0	14	3
A	removeFromStart()	0	4	1
A	startsWith()	0	4	1
A	loadFileContents()	0	4	1

<?php declare(strict_types=1);


namespace Shopware\Psh\ScriptRuntime;

use Shopware\Psh\Listing\Script;

/**
 * Load scripts and parse it into commands
 */
class ScriptLoader
{
    const MODIFIER_IS_TTY = 'TTY: ';

    const MODIFIER_IGNORE_ERROR_PREFIX = 'I: ';

    const MODIFIER_DEFERRED_EXECUTION_PREFIX = 'D: ';

    const INCLUDE_STATEMENT_PREFIX = 'INCLUDE: ';

    const WAIT_STATEMENT = 'WAIT:';

    const TEMPLATE_STATEMENT_PREFIX = 'TEMPLATE: ';

    const CONCATENATE_PREFIX = '   ';

    /**
     * @var CommandBuilder
     */
    private $commandBuilder;

    /**
     * @param CommandBuilder $commandBuilder
     */
    public function __construct(CommandBuilder $commandBuilder)
    {
        $this->commandBuilder = $commandBuilder;
    }

    /**
     * @param Script $script
     * @return Command[]
     */
    public function loadScript(Script $script): array
    {
        $content = $this->loadFileContents($script->getPath());
        $lines = explode("\n", $content);

        foreach ($lines as $lineNumber => $currentLine) {
            $ignoreError = false;
            $tty = false;
            $deferred = false;

            if (!$this->isExecutableLine($currentLine)) {
                continue;
            }

            if ($this->startsWith(self::CONCATENATE_PREFIX, $currentLine)) {
                $this->commandBuilder->add($currentLine);
                continue;
            }

            if ($this->startsWith(self::INCLUDE_STATEMENT_PREFIX, $currentLine)) {
                $path = $this->findInclude($script, $this->removeFromStart(self::INCLUDE_STATEMENT_PREFIX, $currentLine));
                $includeScript = new Script(pathinfo($path, PATHINFO_DIRNAME), pathinfo($path, PATHINFO_BASENAME));

                $commands = $this->loadScript($includeScript);
                $this->commandBuilder->setCommands($commands);

                continue;
            }

            if ($this->startsWith(self::TEMPLATE_STATEMENT_PREFIX, $currentLine)) {
                $definition = $this->removeFromStart(self::TEMPLATE_STATEMENT_PREFIX, $currentLine);
                list($rawSource, $rawDestination) = explode(':', $definition);

                $source = $script->getDirectory() . '/' . $rawSource;
                $destination = $script->getDirectory() . '/' . $rawDestination;

                $this->commandBuilder
                    ->addTemplateCommand($source, $destination, $lineNumber);

                continue;
            }

            if ($this->startsWith(self::WAIT_STATEMENT, $currentLine)) {
                $this->commandBuilder
                    ->addWaitCommand($lineNumber);
                continue;
            }

            if ($this->startsWith(self::MODIFIER_IGNORE_ERROR_PREFIX, $currentLine)) {
                $currentLine = $this->removeFromStart(self::MODIFIER_IGNORE_ERROR_PREFIX, $currentLine);
                $ignoreError = true;
            }

            if ($this->startsWith(self::MODIFIER_IS_TTY, $currentLine)) {

This code seems to be duplicated across your project.

                $currentLine = $this->removeFromStart(self::MODIFIER_IS_TTY, $currentLine);
                $tty = true;
            }

            if ($this->startsWith(self::MODIFIER_DEFERRED_EXECUTION_PREFIX, $currentLine)) {

This code seems to be duplicated across your project.

                $currentLine = $this->removeFromStart(self::MODIFIER_DEFERRED_EXECUTION_PREFIX, $currentLine);
                $deferred = true;
            }

            $this->commandBuilder
                ->next($currentLine, $lineNumber, $ignoreError, $tty, $deferred);
        }

        return $this->commandBuilder->getAll();
    }

    /**
     * @param Script $fromScript
     * @param string $includeStatement
     * @return string
     */
    private function findInclude(Script $fromScript, string $includeStatement): string
    {
        if (file_exists($includeStatement)) {
            return $includeStatement;
        }

        if (file_exists($fromScript->getDirectory() . '/' . $includeStatement)) {
            return $fromScript->getDirectory() . '/' . $includeStatement;
        }

        throw new \RuntimeException('Unable to parse include statement "' . $includeStatement . '" in "' . $fromScript->getPath() . '"');
    }

    /**
     * @param string $command
     * @return bool
     */
    private function isExecutableLine(string $command): bool
    {
        $command = trim($command);

        if (!$command) {
            return false;
        }

        if ($this->startsWith('#', $command)) {
            return false;
        }

        return true;
    }

    /**
     * @param string $needle
     * @param string $haystack
     * @return string
     */
    private function removeFromStart(string $needle, string $haystack): string
    {
        return substr($haystack, strlen($needle));
    }

    /**
     * @param string $needle
     * @param string $haystack
     * @return bool
     */
    private function startsWith(string $needle, string $haystack): bool
    {
        return strpos($haystack, $needle) === 0;
    }

    /**
     * @param string $file
     * @return string
     */
    protected function loadFileContents(string $file): string
    {
        return file_get_contents($file);
    }
}