PHPSu\ShellCommandBuilder\ShellBuilder

Complexity

Total Complexity

44

Size/Duplication

Total Lines	311
Duplicated Lines	0 %

Importance

Changes	2
Bugs	0	Features	0

27 Methods

Rating	Name	Duplication	Size	Complexity
A	pipe()	0	4	1
B	__toString()	0	34	8
A	runAsynchronously()	0	4	2
A	jsonSerialize()	0	3	1
A	redirectError()	0	5	1
A	createProcessSubstition()	0	5	1
A	command()	0	3	1
A	redirectDescriptor()	0	5	1
A	parseCommand()	0	11	3
A	__construct()	0	3	1
A	redirect()	0	5	1
A	and()	0	4	1
A	async()	0	4	1
A	or()	0	4	1
A	validateCommand()	0	4	3
A	redirectErrorToOutput()	0	4	1
A	createGroup()	0	3	2
A	add()	0	9	2
A	new()	0	3	1
A	redirectInput()	0	5	1
A	addCondition()	0	4	1
A	addFileEnding()	0	8	1
A	pipeWithForward()	0	4	1
A	createCommandSubstition()	0	5	1
A	createCommand()	0	3	2
A	__toArray()	0	7	3
A	redirectOutput()	0	5	1

<?php

declare(strict_types=1);

namespace PHPSu\ShellCommandBuilder;

use PHPSu\ShellCommandBuilder\Collection\CollectionTuple;
use PHPSu\ShellCommandBuilder\Collection\Pipeline;
use PHPSu\ShellCommandBuilder\Collection\Redirection;
use PHPSu\ShellCommandBuilder\Collection\ShellList;
use PHPSu\ShellCommandBuilder\Conditional\BasicExpression;
use PHPSu\ShellCommandBuilder\Definition\ControlOperator;
use PHPSu\ShellCommandBuilder\Definition\GroupType;
use PHPSu\ShellCommandBuilder\Exception\ShellBuilderException;
use TypeError;

final class ShellBuilder implements ShellInterface, \JsonSerializable
{
    /** @var array<ShellInterface|CollectionTuple>  */
    private $commandList = [];
    /** @var int */
    private $groupType;
    /**
     * name of the coprocess - empty string means anonymous
     * @var null|string
     */
    private $asynchronously;
    /** @var bool */
    private $processSubstitution = false;
    /** @var bool */
    private $commandSubstitution = false;

    /**
     * This is a shortcut for quicker fluid access to the shell builder
     * @return static
     */
    public static function new(): self
    {
        return new ShellBuilder();
    }

    /**
     * This is a shortcut for quicker fluid access to the command api
     * @param string $executable
     * @return ShellCommand
     */
    public static function command(string $executable): ShellCommand
    {
        return new ShellCommand($executable, new self());
    }

    public function __construct(int $groupType = GroupType::NO_GROUP)
    {
        $this->groupType = $groupType;
    }

    public function createCommand(string $name, bool $withNewBuilder = false): ShellCommand
    {
        return new ShellCommand($name, $withNewBuilder ? new self() : $this);
    }

    public function runAsynchronously(bool $isAsync = true, string $name = ''): self
    {
        $this->asynchronously = $isAsync ? $name : null;
        return $this;
    }

    /**
     * @param string|ShellInterface $command
     * @return $this
     * @throws ShellBuilderException
     */
    public function add($command): self
    {
        $command = $this->parseCommand($command, true);
        if (empty($this->commandList)) {
            $this->commandList[] = $command;
            return $this;
        }
        $this->commandList[] = ShellList::add($command);
        return $this;
    }

    /**
     * @param string|ShellInterface $command
     * @return $this
     * @throws ShellBuilderException
     */
    public function and($command): self
    {
        $this->commandList[] = ShellList::addAnd($this->parseCommand($command));
        return $this;
    }

    /**
     * @param string|ShellInterface $command
     * @return $this
     * @throws ShellBuilderException
     */
    public function or($command): self
    {
        $this->commandList[] = ShellList::addOr($this->parseCommand($command));
        return $this;
    }

    /**
     * @param string|ShellInterface $command
     * @return $this
     * @throws ShellBuilderException
     */
    public function async($command = ''): self
    {
        $this->commandList[] = ShellList::async($this->parseCommand($command));
        return $this;
    }

    /**
     * @param string|ShellInterface $command
     * @return $this
     * @throws ShellBuilderException
     */
    public function pipe($command): self
    {
        $this->commandList[] = Pipeline::pipe($this->parseCommand($command));
        return $this;
    }

    /**
     * @param string|ShellInterface $command
     * @return $this
     * @throws ShellBuilderException
     */
    public function pipeWithForward($command): self
    {
        $this->commandList[] = Pipeline::pipeErrorForward($this->parseCommand($command));
        return $this;
    }

    /**
     * @param string|ShellInterface $command
     * @param bool $append
     * @return $this
     * @throws ShellBuilderException
     */
    public function redirectOutput($command, bool $append = false): self
    {
        $command = $this->parseCommand($command);
        $this->commandList[] = Redirection::redirectOutput($command, $append);
        return $this;
    }

    /**
     * @param string|ShellInterface $command
     * @return $this
     * @throws ShellBuilderException
     */
    public function redirectInput($command): self
    {
        $command = $this->parseCommand($command);
        $this->commandList[] = Redirection::redirectInput($command);
        return $this;
    }

    /**
     * @param string|ShellInterface $command
     * @return $this
     * @throws ShellBuilderException
     */
    public function redirectError($command): self
    {
        $command = $this->parseCommand($command);
        $this->commandList[] = Redirection::redirectError($command);
        return $this;
    }

    /**
     * @param string|ShellInterface $command
     * @param bool $toLeft
     * @return $this
     * @throws ShellBuilderException
     */
    public function redirect($command, bool $toLeft = true): self
    {
        $command = $this->parseCommand($command);
        $this->commandList[] = Redirection::redirectBetweenFiles($command, $toLeft);
        return $this;
    }

    /**
     * @param ShellInterface|string $command
     * @param bool $toLeft
     * @param null|int $firstDescriptor
     * @param null|int $secondDescriptor
     * @return static
     * @throws ShellBuilderException
     */
    public function redirectDescriptor($command, bool $toLeft, int $firstDescriptor = null, int $secondDescriptor = null): self
    {
        $command = $this->parseCommand($command);
        $this->commandList[] = Redirection::redirectBetweenDescriptors($command, $toLeft, $firstDescriptor, $secondDescriptor);
        return $this;
    }

    public function redirectErrorToOutput(): self
    {
        $this->commandList[] = Redirection::redirectErrorToOutput();
        return $this;
    }

    public function addCondition(BasicExpression $condition): self
    {
        $this->commandList[] = $condition;
        return $this;
    }

    /**
     * @param string|ShellInterface $fileEnding
     * @return ShellBuilder
     * @throws ShellBuilderException
     */
    public function addFileEnding($fileEnding): self
    {
        $tuple = CollectionTuple::create($fileEnding, '.');
        $tuple
            ->noSpaceAfterJoin(true)
            ->noSpaceBeforeJoin(true);
        $this->commandList[] = $tuple;
        return $this;
    }

    public function createGroup(bool $inSameShell = false): self
    {
        return new self($inSameShell ? GroupType::SAMESHELL_GROUP : GroupType::SUBSHELL_GROUP);
    }

    public function createProcessSubstition(): self
    {
        $builder = new self(GroupType::SUBSHELL_GROUP);
        $builder->processSubstitution = true;
        return $builder;
    }

    public function createCommandSubstition(): self
    {
        $builder = new self(GroupType::SUBSHELL_GROUP);
        $builder->commandSubstitution = true;
        return $builder;
    }

    /**
     * @param string|ShellInterface $command
     * @param bool $allowEmpty
     * @return ShellInterface
     * @throws ShellBuilderException
     */
    private function parseCommand($command, bool $allowEmpty = false): ShellInterface
    {
        if (is_string($command)) {
            $command = $this->createCommand($command);
        }
        try {
            $this->validateCommand($command, $allowEmpty);
        } catch (TypeError $typeError) {
            throw new ShellBuilderException('Provided the wrong type - only ShellCommand and ShellBuilder allowed');
        }
        return $command;
    }

    /** @noinspection PhpUnusedParameterInspection */
    private function validateCommand(ShellInterface $command, bool $allowEmpty): void

The parameter $command is not used and could be removed.

    {
        if (!$allowEmpty && empty($this->commandList)) {
            throw new ShellBuilderException('You have to first add a command before you can combine it');
        }
    }

    public function jsonSerialize(): array
    {
        return $this->__toArray();
    }

    /**
     * @return array<mixed>
     */
    public function __toArray(): array
    {
        $commands = [];
        foreach ($this->commandList as $item) {
            $commands[] = $item instanceof ShellInterface ? $item->__toArray() : $item;
        }
        return $commands;
    }

    public function __toString(): string
    {
        $result = '';
        if ($this->asynchronously !== null) {
            $result = sprintf('coproc %s%s', $this->asynchronously, $this->asynchronously !== '' ? ' ' : '');
        }
        foreach ($this->commandList as $command) {
            $result .= $command;
        }
        if ($this->groupType === GroupType::SAMESHELL_GROUP) {
            return sprintf(
                '%s%s;%s',
                ControlOperator::CURLY_BLOCK_DEFINITON_OPEN,
                $result,
                ControlOperator::CURLY_BLOCK_DEFINITON_CLOSE
            );
        }
        if ($this->groupType === GroupType::SUBSHELL_GROUP) {
            $substitionType = '';
            if ($this->commandSubstitution) {
                $substitionType = '$';
            }
            if ($this->processSubstitution) {
                $substitionType = '<';
            }
            return sprintf(
                '%s%s%s%s',
                $substitionType,
                ControlOperator::BLOCK_DEFINITON_OPEN,
                $result,
                ControlOperator::BLOCK_DEFINITON_CLOSE
            );
        }
        return rtrim($result);
    }
}