AsyncSockets\RequestExecutor\CallbackEventHandler

Complexity

Total Complexity

18

Size/Duplication

Total Lines	105
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	0

Test Coverage

Coverage

100%

Importance

Changes

0

7 Methods

Rating	Name	Duplication	Size	Complexity
A	removeAll()	0	4	1
A	addHandler()	0	9	4
B	removeHandler()	0	16	6
A	removeForEvent()	0	6	2
A	__construct()	0	4	1
A	invokeEvent()	0	12	3
A	count()	0	4	1

<?php
/**
 * Async sockets
 *
 * @copyright Copyright (c) 2015-2017, Efimov Evgenij <edefimov.it@gmail.com>
 *
 * This source file is subject to the MIT license that is bundled
 * with this source code in the file LICENSE.
 */
namespace AsyncSockets\RequestExecutor;

use AsyncSockets\Event\Event;
use AsyncSockets\Socket\SocketInterface;

/**
 * Class CallbackEventHandler
 */
class CallbackEventHandler implements \Countable, EventHandlerInterface
{
    /**
     * List of callables in this bag indexed by event name
     *
     * @var array
     */
    private $handlers = [];

    /**
     * CallbackEventHandler constructor.
     *
     * @param array $events Events to handle: [ "eventName" => callable|callable[], ... ]
     */
    public function __construct(array $events = [])
    {
        $this->addHandler($events);
    }


    /**
     * Add handler into this bag
     *
     * @param array $events Events to handle: [ "eventName" => callable|callable[], ... ]
     *
     * @return void
     */
    public function addHandler(array $events)
    {
        foreach ($events as $eventName => $subscriber) {
            $this->handlers[$eventName] = array_merge(
                isset($this->handlers[$eventName]) ? $this->handlers[$eventName] : [],
                is_callable($subscriber) ? [$subscriber] : $subscriber
            );
        }
    }

    /**
     * Remove specified handlers from this bag
     *
     * @param array $events Events to remove: [ "eventName" => callable|callable[], ... ]
     *
     * @return void
     */
    public function removeHandler(array $events)
    {
        foreach ($events as $eventName => $subscribers) {
            if (!isset($this->handlers[$eventName])) {
                continue;
            }

            $subscribers = is_callable($subscribers) ? [$subscribers] : $subscribers;
            foreach ($subscribers as $subscriber) {
                $key = array_search($subscriber, $this->handlers[$eventName], true);
                if ($key !== false) {
                    unset($this->handlers[$eventName][$key]);
                }
            }
        }
    }

    /**
     * Remove all handlers from bag
     *
     * @return void
     */
    public function removeAll()
    {
        $this->handlers = [];
    }

    /**
     * Remove all handlers for given event name
     *
     * @param string $eventName Event name to remove handlers
     *
     * @return void
     */
    public function removeForEvent($eventName)
    {
        if (isset($this->handlers[$eventName])) {
            unset($this->handlers[$eventName]);
        }
    }

    /** {@inheritdoc} */
    public function invokeEvent(
        Event $event,
        RequestExecutorInterface $executor,
        SocketInterface $socket,
        ExecutionContext $context
    ) {
        $eventName   = $event->getType();
        $subscribers = isset($this->handlers[$eventName]) ? $this->handlers[$eventName] : [];
        foreach ($subscribers as $subscriber) {
            call_user_func($subscriber, $event, $executor, $socket, $context);
        }
    }

    /** {@inheritdoc} */
    public function count()
    {
        return count($this->handlers);
    }
}