EdwinLuijten\Ekko\Broadcast\BroadcastManager

Complexity

Total Complexity

11

Size/Duplication

Total Lines	96
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	0

Test Coverage

Coverage

100%

Importance

Changes

0

8 Methods

Rating	Name	Duplication	Size	Complexity
A	connection()	0	4	1
A	broadcaster()	0	4	1
A	get()	0	12	3
A	add()	0	4	1
A	getDefaultBroadcaster()	0	10	2
A	setDefaultBroadcaster()	0	4	1
A	getBroadcasters()	0	4	1
A	__call()	0	4	1

<?php

namespace EdwinLuijten\Ekko\Broadcast;

use EdwinLuijten\Ekko\Broadcast\Broadcasters\BroadcasterInterface;

class BroadcastManager
{
    /**
     * @var array
     */
    protected $broadcasters = [];

    /**
     * @var BroadcasterInterface
     */
    private $default;

    /**
     * @param string $broadcaster
     * @return BroadcasterInterface
     */
    public function connection($broadcaster = null)
    {
        return $this->broadcaster($broadcaster);
    }

    /**
     * @param string $broadcaster
     * @return BroadcasterInterface
     */
    public function broadcaster($broadcaster = null)
    {
        return $this->broadcasters[$broadcaster] = $this->get($broadcaster);
    }

    /**
     * @param string $broadcaster
     * @return BroadcasterInterface
     */
    protected function get($broadcaster)
    {
        if (is_null($broadcaster)) {
            return $this->default;
        }

        if (!isset($this->broadcasters[$broadcaster])) {
            throw new \InvalidArgumentException(sprintf('Broadcaster [%s] is not defined.', $broadcaster));
        }

        return $this->broadcasters[$broadcaster];
    }

    /**
     * @param string $name
     * @param BroadcasterInterface $broadcaster
     */
    public function add($name, BroadcasterInterface $broadcaster)
    {
        $this->broadcasters[$name] = $broadcaster;
    }

    /**
     * @return BroadcasterInterface
     */
    public function getDefaultBroadcaster()
    {
        if (!$this->default instanceof BroadcasterInterface) {
            throw new \InvalidArgumentException(
                sprintf('Default broadcaster not set or does not implement %s', BroadcasterInterface::class)
            );
        }

        return $this->default;
    }

    /**
     * @param BroadcasterInterface $broadcaster
     */
    public function setDefaultBroadcaster(BroadcasterInterface $broadcaster)
    {
        $this->default = $broadcaster;
    }

    /**
     * @return array
     */
    public function getBroadcasters()
    {
        return $this->broadcasters;
    }

    /**
     * @param $method
     * @param $arguments
     * @return mixed
     */
    public function __call($method, $arguments)
    {
        return call_user_func_array([$this->default, $method], $arguments);
    }
}