RequestListener::getSubscribedEvents()   A
last analyzed

Complexity

Conditions 1
Paths 1

Size

Total Lines 6
Code Lines 3

Duplication

Lines 0
Ratio 0 %

Code Coverage

Tests 2
CRAP Score 1

Importance

Changes 0
Metric Value
dl 0
loc 6
ccs 2
cts 2
cp 1
rs 9.4285
c 0
b 0
f 0
cc 1
eloc 3
nc 1
nop 0
crap 1
1
<?php
2
3
namespace Thruster\Bundle\SymfonyJsonBodyParserBundle;
4
5
use Symfony\Component\EventDispatcher\EventSubscriberInterface;
6
use Symfony\Component\HttpFoundation\JsonResponse;
7
use Symfony\Component\HttpKernel\Event\GetResponseEvent;
8
use Symfony\Component\HttpKernel\KernelEvents;
9
10
/**
11
 * Class RequestListener
12
 *
13
 * @package Thruster\Bundle\SymfonyJsonBodyParserBundle
14
 * @author  Aurimas Niekis <[email protected]>
15
 */
16
class RequestListener implements EventSubscriberInterface
17
{
18 1
    public static function getSubscribedEvents()
19
    {
20
        return [
21 1
            KernelEvents::REQUEST => ['onRequest', 4096]
22
        ];
23
    }
24
25 5
    public function onRequest(GetResponseEvent $event)
26
    {
27 5
        $request = $event->getRequest();
28
29 5
        if (false === strpos($request->getContentType(), 'json')) {
30 1
            return;
31
        }
32
33 4
        if ($request->attributes->has('_ignore_json_body')) {
34 1
            return;
35
        }
36
37 3
        $content = $request->getContent(false);
38
39 3
        if (empty($content)) {
40 1
            return;
41
        }
42
43 2
        if (false === ($params = $this->parseJson($content))) {
44 1
            $event->setResponse(new JsonResponse(['error' => 'Unable to parse JSON'], 400));
45 1
            return;
46
        }
47
48 1
        $request->request->replace($params);
49 1
    }
50
51 2
    private function parseJson($content)
52
    {
53 2
        $data = json_decode($content, true);
54
55 2
        if (json_last_error() !== JSON_ERROR_NONE) {
56 1
            return false;
57
        }
58
59 1
        return $data;
60
    }
61
}
62