RequestListener::parseJson()   A
last analyzed

Complexity

Conditions 2
Paths 2

Size

Total Lines 10
Code Lines 5

Duplication

Lines 0
Ratio 0 %

Code Coverage

Tests 5
CRAP Score 2

Importance

Changes 0
Metric Value
dl 0
loc 10
ccs 5
cts 5
cp 1
rs 9.4285
c 0
b 0
f 0
cc 2
eloc 5
nc 2
nop 1
crap 2
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