MallardDuck\DynamicEcho\ChannelManager

Complexity

Total Complexity

7

Size/Duplication

Total Lines	74
Duplicated Lines	0 %

Test Coverage

Coverage

19.23%

Importance

Changes	1
Bugs	0	Features	0

6 Methods

Rating	Name	Duplication	Size	Complexity
A	getChannelEventCollection()	0	3	1
A	pushEventDtos()	0	5	1
A	registeredChannelInfo()	0	26	2
A	pushEventDto()	0	5	1
A	__construct()	0	3	1
A	registeredChannelNames()	0	3	1

<?php

namespace MallardDuck\DynamicEcho;

use MallardDuck\DynamicEcho\Loader\LoadedEventDTO;
use MallardDuck\DynamicEcho\Collections\{
    ChannelEventCollection,
    ChannelAwareEventCollection
};

class ChannelManager
{
    /**
     * @var ChannelAwareEventCollection
     */
    private ChannelAwareEventCollection $channelCollection;

    public function __construct()
    {
        $this->channelCollection = new ChannelAwareEventCollection();
    }

    public function getChannelEventCollection(): ChannelAwareEventCollection
    {
        return $this->channelCollection;
    }

    /**
     * @param LoadedEventDTO $newItem
     *
     * @return $this
     */
    public function pushEventDto(LoadedEventDTO $newItem): self
    {
        $this->channelCollection = $this->channelCollection->push($newItem);

        return $this;
    }

    /**
     * Push multiple EventDTOs into the channel collection.
     *
     * @param LoadedEventDTO|LoadedEventDTO[] $newItems,...
     *
     * @return $this
     */
    public function pushEventDtos(...$newItems): self
    {
        $this->channelCollection = $this->channelCollection->push(...$newItems);

        return $this;
    }

    public function registeredChannelNames()
    {
        return $this->channelCollection->keys();
    }

    public function registeredChannelInfo()
    {
        /**
         * @var ChannelEventCollection $channelGroup
         */
        return $this->channelCollection->map(static function ($channelGroup, $key) {
            $first = true;
            $channelInfo = [
                'authName' => $key,
                'type' => null,
                'authCallback' => null,
            ];
            /**
             * @var LoadedEventDTO $val
             */
            $events = $channelGroup->map(static function ($val) use (&$first, &$channelInfo) {
                if ($first) {
                    $first = false;
                    $channelInfo['type'] = $val->getParameter('channelType');
                    $channelInfo['authCallback'] = $val->getParameter('channelAuthCallback');
                }
                return $val->fullEventName;
            })->toArray();
            $channelInfo['events'] = $events;

            return $channelInfo;
        });
    }
}