WSW\BrowserAutomation\Pipeline\Pipeline

Complexity

Total Complexity

4

Size/Duplication

Total Lines	45
Duplicated Lines	0 %

Test Coverage

Coverage

100%

Importance

Changes

0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	process()	0	9	2
A	__construct()	0	4	1
A	pipe()	0	5	1

<?php

declare(strict_types=1);

namespace WSW\BrowserAutomation\Pipeline;

use Facebook\WebDriver\WebDriver;
use SplObjectStorage;
use WSW\BrowserAutomation\Task\TaskInterface;

/**
 * Class Pipeline
 *
 * @package WSW\BrowserAutomation\Pipeline
 */
class Pipeline implements PipelineInterface
{
    /**
     * @var SplObjectStorage
     */
    private $storage;

    /**
     * @var ProcessorInterface
     */
    private $processor;

    /**
     * Pipeline constructor.
     *
     * @param ProcessorInterface $processor
     */
    public function __construct(ProcessorInterface $processor = null)
    {
        $this->storage = new SplObjectStorage();
        $this->processor = $processor ?? new Processor();
    }

    /**
     * {@inheritdoc}
     */
    public function pipe(TaskInterface $task): PipelineInterface
    {
        $this->storage->attach($task);

        return $this;
    }

    /**
     * {@inheritdoc}
     */
    public function process(WebDriver $driver): array
    {
        $result = [];

        foreach ($this->storage as $task) {
            $result[] = $this->processor->process($task, $driver);
        }

        return $result;
    }
}