hiapi\Core\Endpoint\Middleware\RepeatHandler

Complexity

Total Complexity

4

Size/Duplication

Total Lines	41
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	1

Importance

Changes

0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
A	execute()	0	13	1
A	ensureCommandIsIterable()	0	10	2

<?php

namespace hiapi\Core\Endpoint\Middleware;

use Doctrine\Common\Collections\ArrayCollection;
use League\Tactician\Middleware;

class RepeatHandler implements Middleware
{
    /**
     * @var callable
     */
    private $handler;

    public function __construct(callable $handler)
    {
        $this->handler = $handler;
    }

    /**
     * @inheritDoc
     * @throws \Exception
     */
    public function execute($command, callable $next)
    {
        $this->ensureCommandIsIterable($command);

        $handler = $this->handler;
        $items = iterator_to_array($command, true);

        return new ArrayCollection(
            array_map(static function ($item) use ($handler) {
                return $handler($item);
            }, $items)
        );
    }

    private function ensureCommandIsIterable($command): void
    {
        if (!$command instanceof \IteratorAggregate) {
            throw new \RuntimeException(sprintf(
                '%s expects command to be iterable, %s provided instead',
                self::class,
                get_class($command)
            ));
        }
    }
}