App\Gitter\MiddlewaresExtension

Complexity

Total Complexity

9

Size/Duplication

Total Lines	97
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	4

Importance

Changes	1
Bugs	0	Features	0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	6	1
A	register()	0	9	1
A	fire()	0	17	4
A	fireMiddleware()	0	21	3

<?php
namespace App\Gitter;

use App\Message;
use App\Room;
use Gitter\Client;
use Gitter\Models\Room as GitterRoom;
use Illuminate\Contracts\Container\Container;

/**
 * Class MiddlewaresExtension
 * @package App\Gitter\Middleware
 */
class MiddlewaresExtension implements ExtensionInterface
{
    /**
     * @var array
     */
    protected $items = [];

    /**
     * @var Container
     */
    protected $container;

    /**
     * @var GitterRoom
     */
    protected $room;

    /**
     * @var Room
     */
    protected $roomObject;

    /**
     * Repository constructor.
     * @param GitterRoom $room
     * @param Container $container
     */
    public function __construct(GitterRoom $room, Container $container)
    {
        $this->room = $room;
        $this->roomObject = Room::make($this->room);
        $this->container = $container;
    }

    /**
     * @param $middleware
     * @return $this
     */
    public function register(string $middleware)
    {
        $this->items[] = $this->container->make($middleware, [
            'room'   => $this->roomObject,
            'gitter' => $this->room,
        ]);

        return $this;
    }

    /**
     * @param Message $message
     * @return mixed
     */
    public function fire(Message $message)
    {
        if (count($this->items)) {
            $response = new Response($this->fireMiddleware(0, $message));

            if (!$response->isEmpty()) {
                $content = $response->getContent();
                $this->room->sendMessage($content);

                if (app(Client::class)->isFallbackMode()) {
                    $this->room->sendMessage(
                        '_Gitter Stream API недоступен. Я работаю с некоторой задержкой, простите =(_'
                    );
                }
            }
        }
    }

    /**
     * @param int $number
     * @param Message $message
     * @return mixed
     */
    protected function fireMiddleware(int $number, Message $message)
    {
        if (!array_key_exists($number, $this->items)) {
            return new Response;
        }

        $middleware = $this->items[$number];

        return $this->container->call([$middleware, 'handle'], [
            'message' => $message,
            'next'    => function (Message $message) use ($number) {
                $result = $this->fireMiddleware(++$number, $message);

                if (!($result instanceof Response)) {
                    return new Response($result);
                }

                return $result;
            },
        ]);
    }
}