Interfaces\Gitter\Middleware\Storage

Complexity

Total Complexity

5

Size/Duplication

Total Lines	69
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	2

3 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	5	1
A	add()	0	9	1
A	handle()	0	15	3

<?php
/**
 * This file is part of GitterBot package.
 *
 * @author Serafim <nesk@xakep.ru>
 * @date 24.09.2015 15:27
 *
 * For the full copyright and license information, please view the LICENSE
 * file that was distributed with this source code.
 */

namespace Interfaces\Gitter\Middleware;

use Interfaces\Gitter\Support\PriorityList;
use Illuminate\Console\OutputStyle;
use Illuminate\Contracts\Container\Container;
use Symfony\Component\Console\Output\OutputInterface;

/**
 * Class Storage
 */
class Storage
{
    const PRIORITY_MINIMAL = 1; // Lower priority
    const PRIORITY_DEFAULT = 2;
    const PRIORITY_MAXIMAL = 3; // Maximal priority (?)

38% of this comment could be valid code. Did you maybe forget this after debugging?

    // Middleware response for stopping iterations
    const SIGNAL_STOP = null;


    /**
     * @var MiddlewareInterface[]|PriorityList
     */
    protected $storage;


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


    /**
     * @param Container $container
     */
    public function __construct(Container $container)
    {
        $this->container = $container;
        $this->storage = new PriorityList();
    }


    /**
     * @param string $class
     * @param int $priority
     * @return Storage
     */
    public function add($class, $priority = self::PRIORITY_DEFAULT): Storage
    {
        $this->container->bind($class, $class);
        $instance = $this->container->make($class);

        $this->storage->insert($instance, $priority);

        return $this;
    }


    /**
     * @param Model|mixed $data
     * @return Storage
     */
    public function handle($data): Storage
    {
        foreach ($this->storage as $middleware) {
            $response = $middleware->handle($data);

            if ($response === static::SIGNAL_STOP) {
                return $this;
            }

            // Update data
            $data = $response;
        }

        return $this;
    }
}