RequestProcessor.php 2.1 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566
  1. <?php
  2. /**
  3. * @package Grav\Common\Processors
  4. *
  5. * @copyright Copyright (c) 2015 - 2023 Trilby Media, LLC. All rights reserved.
  6. * @license MIT License; see LICENSE file for details.
  7. */
  8. namespace Grav\Common\Processors;
  9. use Grav\Common\Processors\Events\RequestHandlerEvent;
  10. use Grav\Common\Uri;
  11. use Grav\Common\Utils;
  12. use Psr\Http\Message\ResponseInterface;
  13. use Psr\Http\Message\ServerRequestInterface;
  14. use Psr\Http\Server\RequestHandlerInterface;
  15. /**
  16. * Class RequestProcessor
  17. * @package Grav\Common\Processors
  18. */
  19. class RequestProcessor extends ProcessorBase
  20. {
  21. /** @var string */
  22. public $id = 'request';
  23. /** @var string */
  24. public $title = 'Request';
  25. /**
  26. * @param ServerRequestInterface $request
  27. * @param RequestHandlerInterface $handler
  28. * @return ResponseInterface
  29. */
  30. public function process(ServerRequestInterface $request, RequestHandlerInterface $handler): ResponseInterface
  31. {
  32. $this->startTimer();
  33. $header = $request->getHeaderLine('Content-Type');
  34. $type = trim(strstr($header, ';', true) ?: $header);
  35. if ($type === 'application/json') {
  36. $request = $request->withParsedBody(json_decode($request->getBody()->getContents(), true));
  37. }
  38. $uri = $request->getUri();
  39. $ext = mb_strtolower(Utils::pathinfo($uri->getPath(), PATHINFO_EXTENSION));
  40. $request = $request
  41. ->withAttribute('grav', $this->container)
  42. ->withAttribute('time', $_SERVER['REQUEST_TIME_FLOAT'] ?? GRAV_REQUEST_TIME)
  43. ->withAttribute('route', Uri::getCurrentRoute()->withExtension($ext))
  44. ->withAttribute('referrer', $this->container['uri']->referrer());
  45. $event = new RequestHandlerEvent(['request' => $request, 'handler' => $handler]);
  46. /** @var RequestHandlerEvent $event */
  47. $event = $this->container->fireEvent('onRequestHandlerInit', $event);
  48. $response = $event->getResponse();
  49. $this->stopTimer();
  50. if ($response) {
  51. return $response;
  52. }
  53. return $handler->handle($request);
  54. }
  55. }