123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123 |
- <?php declare(strict_types=1);
- /**
- * @package Grav\Framework\RequestHandler
- *
- * @copyright Copyright (c) 2015 - 2022 Trilby Media, LLC. All rights reserved.
- * @license MIT License; see LICENSE file for details.
- */
- namespace Grav\Framework\RequestHandler\Middlewares;
- use Grav\Framework\Psr7\UploadedFile;
- use Nyholm\Psr7\Stream;
- use Psr\Http\Message\ResponseInterface;
- use Psr\Http\Message\ServerRequestInterface;
- use Psr\Http\Message\UploadedFileInterface;
- use Psr\Http\Server\MiddlewareInterface;
- use Psr\Http\Server\RequestHandlerInterface;
- use function array_slice;
- use function count;
- use function in_array;
- use function is_array;
- use function strlen;
- /**
- * Multipart request support for PUT and PATCH.
- */
- class MultipartRequestSupport implements MiddlewareInterface
- {
- /**
- * @param ServerRequestInterface $request
- * @param RequestHandlerInterface $handler
- * @return ResponseInterface
- */
- public function process(ServerRequestInterface $request, RequestHandlerInterface $handler): ResponseInterface
- {
- $contentType = $request->getHeaderLine('content-type');
- $method = $request->getMethod();
- if (!str_starts_with($contentType, 'multipart/form-data') || !in_array($method, ['PUT', 'PATH'], true)) {
- return $handler->handle($request);
- }
- $boundary = explode('; boundary=', $contentType, 2)[1] ?? '';
- $parts = explode("--{$boundary}", $request->getBody()->getContents());
- $parts = array_slice($parts, 1, count($parts) - 2);
- $params = [];
- $files = [];
- foreach ($parts as $part) {
- $this->processPart($params, $files, $part);
- }
- return $handler->handle($request->withParsedBody($params)->withUploadedFiles($files));
- }
- /**
- * @param array $params
- * @param array $files
- * @param string $part
- * @return void
- */
- protected function processPart(array &$params, array &$files, string $part): void
- {
- $part = ltrim($part, "\r\n");
- [$rawHeaders, $body] = explode("\r\n\r\n", $part, 2);
- // Parse headers.
- $rawHeaders = explode("\r\n", $rawHeaders);
- $headers = array_reduce(
- $rawHeaders,
- static function (array $headers, $header) {
- [$name, $value] = explode(':', $header);
- $headers[strtolower($name)] = ltrim($value, ' ');
- return $headers;
- },
- []
- );
- if (!isset($headers['content-disposition'])) {
- return;
- }
- // Parse content disposition header.
- $contentDisposition = $headers['content-disposition'];
- preg_match('/^(.+); *name="([^"]+)"(; *filename="([^"]+)")?/', $contentDisposition, $matches);
- $name = $matches[2];
- $filename = $matches[4] ?? null;
- if ($filename !== null) {
- $stream = Stream::create($body);
- $this->addFile($files, $name, new UploadedFile($stream, strlen($body), UPLOAD_ERR_OK, $filename, $headers['content-type'] ?? null));
- } elseif (strpos($contentDisposition, 'filename') !== false) {
- // Not uploaded file.
- $stream = Stream::create('');
- $this->addFile($files, $name, new UploadedFile($stream, 0, UPLOAD_ERR_NO_FILE));
- } else {
- // Regular field.
- $params[$name] = substr($body, 0, -2);
- }
- }
- /**
- * @param array $files
- * @param string $name
- * @param UploadedFileInterface $file
- * @return void
- */
- protected function addFile(array &$files, string $name, UploadedFileInterface $file): void
- {
- if (strpos($name, '[]') === strlen($name) - 2) {
- $name = substr($name, 0, -2);
- if (isset($files[$name]) && is_array($files[$name])) {
- $files[$name][] = $file;
- } else {
- $files[$name] = [$file];
- }
- } else {
- $files[$name] = $file;
- }
- }
- }
|