Phrest\Middleware\JsonRequestBody

Complexity

Total Complexity

6

Size/Duplication

Total Lines	49
Duplicated Lines	0 %

Test Coverage

Coverage

0%

Importance

Changes	1
Bugs	0	Features	0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	match()	0	5	1
B	process()	0	25	5

<?php

namespace Phrest\Middleware;

class JsonRequestBody implements \Interop\Http\ServerMiddleware\MiddlewareInterface
{
    const RAW_BODY_ATTRIBUTE = self::class . '::RAW_BODY_ATTRIBUTE';
    const JSON_OBJECT_ATTRIBUTE = self::class . '::JSON_OBJECT_ATTRIBUTE';

    static private $jsonDecodeErrorMapping = [
        \JSON_ERROR_DEPTH => \Phrest\API\ErrorCodes::JSON_DECODE_ERROR_DEPTH,
        \JSON_ERROR_STATE_MISMATCH => \Phrest\API\ErrorCodes::JSON_DECODE_ERROR_STATE_MISMATCH,
        \JSON_ERROR_CTRL_CHAR => \Phrest\API\ErrorCodes::JSON_DECODE_ERROR_CTRL_CHAR,
        \JSON_ERROR_SYNTAX => \Phrest\API\ErrorCodes::JSON_DECODE_ERROR_SYNTAX,
        \JSON_ERROR_UTF8 => \Phrest\API\ErrorCodes::JSON_DECODE_ERROR_UTF8,
        \JSON_ERROR_RECURSION => \Phrest\API\ErrorCodes::JSON_DECODE_ERROR_RECURSION,
        \JSON_ERROR_INF_OR_NAN => \Phrest\API\ErrorCodes::JSON_DECODE_ERROR_INF_OR_NAN,
        \JSON_ERROR_UNSUPPORTED_TYPE => \Phrest\API\ErrorCodes::JSON_DECODE_ERROR_UNSUPPORTED_TYPE,
    ];

    public function process(\Psr\Http\Message\ServerRequestInterface $request, \Interop\Http\ServerMiddleware\DelegateInterface $delegate)
    {
        $match = $this->match($request->getHeaderLine('Content-Type'));
        if (!$match || in_array($request->getMethod(), ['GET', 'HEAD', 'OPTIONS'])) {
            return $delegate->process($request);
        }

        $rawBody = (string)$request->getBody();
        $parsedBody = json_decode($rawBody, true);
        if (!empty($rawBody) && json_last_error() !== JSON_ERROR_NONE) {
            $errorEntryCode = self::$jsonDecodeErrorMapping[json_last_error()] ?? \Phrest\API\ErrorCodes::UNKNOWN;
            throw \Phrest\Http\Exception::BadRequest(
                new \Phrest\API\Error(
                    \Phrest\API\ErrorCodes::JSON_DECODE_ERROR,
                    'json decode error',
                    new \Phrest\API\ErrorEntry($errorEntryCode, '{body}', json_last_error_msg(), '')
                )
            );
        }

        return $delegate->process(
            $request
                ->withAttribute(self::RAW_BODY_ATTRIBUTE, $rawBody)
                ->withAttribute(self::JSON_OBJECT_ATTRIBUTE, json_decode($rawBody))
                ->withParsedBody($parsedBody)
        );
    }

    private function match($contentType)
    {
        $parts = explode(';', $contentType);
        $mime = array_shift($parts);
        return (bool)preg_match('#[/+]json$#', trim($mime));
    }
}