jschreuder\Middle\ServerMiddleware\JsonRequestParserMiddleware

Complexity

Total Complexity

8

Size/Duplication

Total Lines	33
Duplicated Lines	0 %

Test Coverage

Coverage

100%

Importance

Changes	3
Bugs	0	Features	0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	3	1
A	isJsonRequest()	0	8	3
A	process()	0	6	2
A	parseBody()	0	8	2

<?php declare(strict_types=1);

namespace jschreuder\Middle\ServerMiddleware;

use Psr\Http\Message\ResponseInterface;
use Psr\Http\Message\ServerRequestInterface;
use Psr\Http\Server\MiddlewareInterface;
use Psr\Http\Server\RequestHandlerInterface;

final class JsonRequestParserMiddleware implements MiddlewareInterface
{
    /** @param  string[]  $jsonContentTypes  array of regexes to check against content-types */
    public function __construct(
        private readonly array $jsonContentTypes = ['#^application\/json(;|$)#iD']
    ) {}

    public function process(ServerRequestInterface $request, RequestHandlerInterface $requestHandler): ResponseInterface
    {
        if ($this->isJsonRequest($request->getHeaderLine('Content-Type'))) {
            $request = $request->withParsedBody($this->parseBody($request));
        }
        return $requestHandler->handle($request);
    }

    private function isJsonRequest(string $requestContentType) : bool
    {
        foreach ($this->jsonContentTypes as $jsonContentType) {
            if (preg_match($jsonContentType, $requestContentType) > 0) {
                return true;
            }
        }
        return false;
    }

    private function parseBody(ServerRequestInterface $request) : array
    {
        $parsedBody = json_decode($request->getBody()->getContents(), true);
        if (json_last_error() !== JSON_ERROR_NONE) {
            throw new \InvalidArgumentException('Could not decode JSON body: ' . json_last_error_msg());
        }

        return $parsedBody;
    }
}