Northwoods\Broker\Broker

Complexity

Total Complexity

8

Size/Duplication

Total Lines	74
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	2

Test Coverage

Coverage

100%

Importance

Changes

0

6 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
A	handle()	0	6	1
A	process()	0	6	1
A	always()	0	4	1
A	when()	0	15	3
A	alwaysTrue()	0	6	1

<?php

namespace Northwoods\Broker;

use Interop\Http\ServerMiddleware\DelegateInterface;
use Interop\Http\ServerMiddleware\MiddlewareInterface;
use Psr\Container\ContainerInterface;
use Psr\Http\Message\ServerRequestInterface;
use SplObjectStorage;

class Broker implements MiddlewareInterface
{
    /**
     * @var ContainerInterface
     */
    private $container;

    /**
     * @var array
     */
    private $middleware = [];

    public function __construct(ContainerInterface $container = null)
    {
        $this->container = $container;
    }

    /**
     * @return \Psr\Http\Message\ResponseInterface
     */
    public function handle(ServerRequestInterface $request, callable $default)
    {
        $delegate = new CallableDelegate($default);

        return $this->process($request, $delegate);
    }

    // MiddlewareInterface
    public function process(ServerRequestInterface $request, DelegateInterface $delegate)
    {
        $delegate = new Delegate($this->middleware, $delegate, $this->container);

        return $delegate->process($request);
    }

    /**
     * @param array|string|MiddlewareInterface $middleware
     * @return self
     */
    public function always($middleware)
    {
        return $this->when($this->alwaysTrue(), $middleware);
    }

    /**
     * @param array|string|MiddlewareInterface $middleware
     * @return self
     */
    public function when(callable $condition, $middleware)
    {
        if (!is_array($middleware)) {
            $middleware = [$middleware];
        }

        foreach ($middleware as $mw) {
            $this->middleware[] = [
                $condition,
                $mw
            ];
        }

        return $this;
    }

    /**
     * @return callable
     */
    private function alwaysTrue()
    {
        return static function () {
            return true;
        };
    }
}