Passed
Push — master ( dacfd6...8e9cf7 )
by mcfog
01:53
created

MiddlewarePipe::append()   A

Complexity

Conditions 1
Paths 1

Size

Total Lines 5
Code Lines 3

Duplication

Lines 0
Ratio 0 %

Code Coverage

Tests 3
CRAP Score 1

Importance

Changes 1
Bugs 0 Features 0
Metric Value
c 1
b 0
f 0
dl 0
loc 5
ccs 3
cts 3
cp 1
rs 9.4285
cc 1
eloc 3
nc 1
nop 1
crap 1
1
<?php namespace Nimo;
2
3
use Interop\Http\Server\MiddlewareInterface;
4
use Nimo\Handlers\CallableHandler;
5
use Nimo\Middlewares\CallableMiddleware;
6
use Psr\Http\Message\ResponseInterface;
7
use Psr\Http\Message\ServerRequestInterface;
8
9
/**
10
 * User: mcfog
11
 * Date: 15/9/4
12
 */
13
class MiddlewarePipe extends AbstractMiddleware
14
{
15
    /**
16
     * @var CallableHandler
17
     */
18
    protected $nextHandler;
19
    /**
20
     * @var MiddlewareInterface[]
21
     */
22
    protected $stack = [];
23
    protected $index;
24
25
    public function __construct()
26
    {
27 3
        $this->nextHandler = CallableHandler::wrap(function (ServerRequestInterface $request) {
28 2
            return $this->loop($request);
29 3
        });
30 3
    }
31
32
33
    /**
34
     * append $middleware
35
     * return $this
36
     * note this method would modify $this
37
     *
38
     * @param mixed $middleware
39
     * @return $this
40
     */
41 1
    public function append($middleware): MiddlewarePipe
42
    {
43 1
        $this->stack[] = CallableMiddleware::wrap($middleware);
44 1
        return $this;
45
    }
46
47
    /**
48
     * prepend $middleware
49
     * return $this
50
     * note this method would modify $this
51
     *
52
     * @param $middleware
53
     * @return $this
54
     */
55 1
    public function prepend($middleware): MiddlewarePipe
56
    {
57 1
        array_unshift($this->stack, CallableMiddleware::wrap($middleware));
58 1
        return $this;
59
    }
60
61 3
    protected function main(): ResponseInterface
62
    {
63 3
        $this->index = 0;
64
65 3
        return $this->loop($this->request);
66
    }
67
68
    /**
69
     * @param ServerRequestInterface $request
70
     * @return ResponseInterface
71
     */
72 3
    protected function loop(ServerRequestInterface $request): ResponseInterface
73
    {
74 3
        if (!isset($this->stack[$this->index])) {
75 3
            return $this->delegate($request);
76
        }
77
78 2
        return $this->stack[$this->index++]->process($request, $this->nextHandler);
79
    }
80
}
81