Completed
Pull Request — master (#128)
by Fabien
07:21 queued 05:28
created

DebugPluginDecorator::wrap()   A

Complexity

Conditions 1
Paths 1

Size

Total Lines 16
Code Lines 10

Duplication

Lines 0
Ratio 0 %

Code Coverage

Tests 0
CRAP Score 2

Importance

Changes 0
Metric Value
dl 0
loc 16
ccs 0
cts 12
cp 0
rs 9.4285
c 0
b 0
f 0
cc 1
eloc 10
nc 1
nop 2
crap 2
1
<?php
2
3
namespace Http\HttplugBundle\Collector;
4
5
use Closure;
6
use Http\Client\Common\Plugin;
7
use Http\Client\Exception;
8
use Psr\Http\Message\RequestInterface;
9
use Psr\Http\Message\ResponseInterface;
10
11
class DebugPluginDecorator implements Plugin
12
{
13
    /**
14
     * @var Plugin
15
     */
16
    private $plugin;
17
18
    /**
19
     * @var Collector
20
     */
21
    private $collector;
22
23
    /**
24
     * @param Plugin    $plugin
25
     * @param Collector $collector
26
     */
27
    public function __construct(Plugin $plugin, Collector $collector)
28
    {
29
        $this->plugin = $plugin;
30
        $this->collector = $collector;
31
    }
32
33
    /**
34
     * {@inheritdoc}
35
     */
36
    public function handleRequest(RequestInterface $request, callable $next, callable $first)
37
    {
38
        $this->plugin->handleRequest($request, $this->wrap($next, false), $this->wrap($first, true));
39
    }
40
41
    /**
42
     * @param callable $callable
43
     * @param bool     $first
44
     *
45
     * @return Closure
46
     */
47
    private function wrap(callable $callable, $first)
48
    {
49
        return function (RequestInterface $request) use ($callable, $first) {
50
            $profile = $this->collector->getProfile($this->plugin, $request);
51
            $profile->setFirst($first);
52
53
            return $callable($request)->then(function (ResponseInterface $response) use ($profile) {
54
                $profile->setResponse($response);
55
56
                return $response;
57
            }, function (Exception $exception) use ($profile) {
58
                $profile->setException($exception);
59
                throw $exception;
60
            });
61
        };
62
    }
63
}
64