App\Gitter\Extensions\Middlewares\Container

Complexity

Total Complexity

9

Size/Duplication

Total Lines	101
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	7	1
A	register()	0	9	1
A	fire()	0	15	4
A	fireMiddleware()	0	21	3

<?php
namespace App\Gitter\Extensions\Middlewares;

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

/**
 * Class Container
 * @package App\Gitter\Extensions\Middlewares
 */
class Container implements ContainerInterface
{
    /**
     * @var array
     */
    protected $items = [];

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

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

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

    /**
     * @var MessageBus
     */
    protected $messageBus;

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

    /**
     * @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()) {
                if (app(Client::class)->isFallbackMode()) {
                    $response->after(
                        '_Gitter Stream API недоступен. ' .
                        'Я работаю с некоторой задержкой, простите =(_', true);
                }

                $this->messageBus->send($this->room, $response->getContent());
            }
        }
    }

    /**
     * @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;
            },
        ]);
    }
}