Lit\Bolt\Middlewares\EventsHub

Complexity

Total Complexity

8

Size/Duplication

Total Lines	57
Duplicated Lines	0 %

Test Coverage

Coverage

58.62%

Importance

Changes	3
Bugs	0	Features	0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	main()	0	24	4
A	addListener()	0	4	1
A	dispatch()	0	4	1
A	__construct()	0	3	1
A	getEventDispatcher()	0	4	1

<?php

declare(strict_types=1);

namespace Lit\Bolt\Middlewares;

use Lit\Bolt\BoltEvent;
use Lit\Nimo\Middlewares\AbstractMiddleware;
use Psr\Http\Message\ResponseInterface;
use Symfony\Component\EventDispatcher\Event;
use Symfony\Component\EventDispatcher\EventDispatcher;

/**
 * Middleware for pub-sub pattern
 * @deprecated
 */
class EventsHub extends AbstractMiddleware
{
    /**
     * @var EventDispatcher
     */
    protected $eventDispatcher;

    public function __construct(EventDispatcher $eventDispatcher)
    {
        $this->eventDispatcher = $eventDispatcher;
    }

    /**
     * @return EventDispatcher
     */
    public function getEventDispatcher(): EventDispatcher
    {
        @trigger_error('EventsHub is deprecated', E_USER_DEPRECATED);
        return $this->eventDispatcher;
    }

    public function addListener($eventName, $listener, $priority = 0)
    {
        @trigger_error('EventsHub is deprecated', E_USER_DEPRECATED);
        $this->eventDispatcher->addListener($eventName, $listener, $priority);
    }

    public function dispatch($eventName, Event $event = null)
    {
        @trigger_error('EventsHub is deprecated', E_USER_DEPRECATED);
        $this->eventDispatcher->dispatch($eventName, $event);
    }

    protected function main(): ResponseInterface
    {
        $this->attachToRequest();

        $beforeEvent = BoltEvent::of($this, [
            'request' => $this->request,
        ]);
        $this->eventDispatcher->dispatch(BoltEvent::EVENT_BEFORE_LOGIC, $beforeEvent);

        $this->request = $beforeEvent->getRequest() ?: $this->request;
        $interceptedResponse = $beforeEvent->getResponse();
        if ($interceptedResponse) {
            $response = $interceptedResponse;
        } else {
            $response = $this->delegate();
        }

        $afterEvent = BoltEvent::of($this, [
            'request' => $this->request,
            'response' => $response,
        ]);
        $this->eventDispatcher->dispatch(BoltEvent::EVENT_AFTER_LOGIC, $afterEvent);

        return $afterEvent->getResponse() ?: $response;
    }
}