HtmlCompressMiddleware::process()   A
last analyzed

Complexity

Conditions 4
Paths 2

Size

Total Lines 16
Code Lines 9

Duplication

Lines 0
Ratio 0 %

Code Coverage

Tests 9
CRAP Score 4

Importance

Changes 2
Bugs 0 Features 1
Metric Value
c 2
b 0
f 1
dl 0
loc 16
ccs 9
cts 9
cp 1
rs 9.2
cc 4
eloc 9
nc 2
nop 2
crap 4
1
<?php
2
3
namespace SteffenBrand\HtmlCompressMiddleware;
4
5
use Psr\Http\Message\ResponseInterface;
6
use Psr\Http\Message\ServerRequestInterface;
7
use Psr\Http\Server\MiddlewareInterface;
8
use Psr\Http\Server\RequestHandlerInterface;
9
use WyriHaximus\HtmlCompress\Parser;
10
use Zend\Diactoros\Stream;
11
12
/**
13
 * Class HtmlCompressMiddleware
14
 * @package SteffenBrand\HtmlCompressMiddleware
15
 */
16
class HtmlCompressMiddleware implements MiddlewareInterface
17
{
18
    /**
19
     * @var Parser
20
     */
21
    private $parser;
22
23
    /**
24
     * @var bool
25
     */
26
    private $debug;
27
28
    /**
29
     * HtmlCompressMiddleware constructor.
30
     * @param Parser $parser
31
     * @param bool $debug
32
     */
33 3
    public function __construct(Parser $parser, bool $debug)
34
    {
35 3
        $this->parser = $parser;
36 3
        $this->debug = $debug;
37 3
     }
38
39
    /**
40
     * @param ServerRequestInterface $request
41
     * @param RequestHandlerInterface $handler
42
     * @return ResponseInterface
43
     * @throws \InvalidArgumentException
44
     */
45 3
    public function process(ServerRequestInterface $request, RequestHandlerInterface $handler): ResponseInterface
46
    {
47 3
        $response = $handler->handle($request);
48
49 3
        if ($this->debug === true ||
50 2
            strpos($response->getHeaderLine('Content-Type'), 'text/html') === false ||
51 3
            $response->getBody()->getSize() < 1)
52
        {
53 2
            return $response;
54
        }
55
56 1
        $compressedBody = $this->parser->compress($response->getBody()->getContents());
57 1
        $streamBody = fopen('data:text/plain,' . $compressedBody, 'rb');
58
59 1
        return $response->withBody(new Stream($streamBody));
60
    }
61
}
62