Net\Bazzline\Component\ProcessPipe\Pipe

Complexity

Total Complexity

7

Size/Duplication

Total Lines	60
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	1

Importance

Changes

0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	8	2
A	execute()	0	8	2
A	pipe()	0	16	3

<?php
/**
 * @author stev leibelt <artodeto@bazzline.net>
 * @since 2014-11-07 
 */

namespace Net\Bazzline\Component\ProcessPipe;

/**
 * Class ProcessPipe
 * @package Net\Bazzline\Component\ProcessPipe
 */
class Pipe implements PipeInterface
{
    /** @var array|ExecutableInterface[] */
    private $processes;

    /**
     * Adds one or more process to the pipe
     *
     * @param ExecutableInterface $process - or more
     * @param ExecutableInterface $_ [optional]
     * @throws InvalidArgumentException
     */
    public function __construct(ExecutableInterface $process = null, $_ = null)

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

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

    {
        $this->processes = array();

        if (func_num_args() > 0) {
            call_user_func_array(array($this, 'pipe'), func_get_args());
        }
    }

    /**
     * @param mixed $input
     * @return mixed
     * @throws ExecutableException
     */
    public function execute($input = null)
    {
        foreach ($this->processes as $process) {
            $input = $process->execute($input);
        }

        return $input;
    }

    /**
     * Adds one or more process to the pipe
     *
     * @param ExecutableInterface $process - or more
     * @param ExecutableInterface $_ [optional]
     * @throws InvalidArgumentException
     * @return $this
     */
    public function pipe(ExecutableInterface $process, $_ = null)
    {
        foreach (func_get_args() as $index => $process) {
            if ($process instanceof ExecutableInterface) {
                $this->processes[] = $process;
            } else {
                $message = 'Argument ' . $index . ' passed to ' . __METHOD__ .
                    '() must implement interface ' .
                    'Net\Bazzline\Component\ProcessPipe\ExecutableInterface' .
                    ', instance of ' . get_class($process) . ' given';
                throw new InvalidArgumentException($message);
            }
        }

        return $this;
    }
}