OniBus\BusChain

Complexity

Total Complexity

3

Size/Duplication

Total Lines	33
Duplicated Lines	0 %

Importance

Changes

0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	hp$0 ➔ dispatch()	0	2	1
A	__construct()	0	11	3
	dummyBus()	0	5	?
A	hp$0 ➔ dummyBus()	0	5	1
	dispatch()	0	3	?

<?php
declare(strict_types=1);

namespace OniBus;

use InvalidArgumentException;

class BusChain implements Bus
{
    /**
     * @var Chain[]
     */
    protected $buses = [];

    public function __construct(Chain ...$buses)
    {
        if (empty($buses)) {
            throw new InvalidArgumentException('Bus Chain cannot be empty.');
        }

        $this->buses = $buses;
        $count = count($buses);
        for ($i = 0; $i < $count; $i++) {
            $nextBus = $this->buses[$i + 1] ?? $this->dummyBus();
            $this->buses[$i]->setNext($nextBus);
        }
    }

    protected function dummyBus(): Bus
    {
        return new class implements Bus {
            public function dispatch(Message $message)
            {
            }
        };
    }

    public function dispatch(Message $message)
    {
        return $this->buses[0]->dispatch($message);
    }
}