annotate vendor/symfony/psr-http-message-bridge/Factory/DiactorosFactory.php @ 19:fa3358dc1485 tip

Add ndrum files
author Chris Cannam
date Wed, 28 Aug 2019 13:14:47 +0100
parents af1871eacc83
children
rev   line source
Chris@0 1 <?php
Chris@0 2
Chris@0 3 /*
Chris@0 4 * This file is part of the Symfony package.
Chris@0 5 *
Chris@0 6 * (c) Fabien Potencier <fabien@symfony.com>
Chris@0 7 *
Chris@0 8 * For the full copyright and license information, please view the LICENSE
Chris@0 9 * file that was distributed with this source code.
Chris@0 10 */
Chris@0 11
Chris@0 12 namespace Symfony\Bridge\PsrHttpMessage\Factory;
Chris@0 13
Chris@17 14 use Psr\Http\Message\UploadedFileInterface;
Chris@0 15 use Symfony\Bridge\PsrHttpMessage\HttpMessageFactoryInterface;
Chris@0 16 use Symfony\Component\HttpFoundation\BinaryFileResponse;
Chris@0 17 use Symfony\Component\HttpFoundation\File\UploadedFile;
Chris@0 18 use Symfony\Component\HttpFoundation\Request;
Chris@0 19 use Symfony\Component\HttpFoundation\Response;
Chris@0 20 use Symfony\Component\HttpFoundation\StreamedResponse;
Chris@0 21 use Zend\Diactoros\Response as DiactorosResponse;
Chris@0 22 use Zend\Diactoros\ServerRequest;
Chris@0 23 use Zend\Diactoros\ServerRequestFactory as DiactorosRequestFactory;
Chris@0 24 use Zend\Diactoros\Stream as DiactorosStream;
Chris@0 25 use Zend\Diactoros\UploadedFile as DiactorosUploadedFile;
Chris@0 26
Chris@0 27 /**
Chris@0 28 * Builds Psr\HttpMessage instances using the Zend Diactoros implementation.
Chris@0 29 *
Chris@0 30 * @author Kévin Dunglas <dunglas@gmail.com>
Chris@0 31 */
Chris@0 32 class DiactorosFactory implements HttpMessageFactoryInterface
Chris@0 33 {
Chris@0 34 public function __construct()
Chris@0 35 {
Chris@0 36 if (!class_exists('Zend\Diactoros\ServerRequestFactory')) {
Chris@0 37 throw new \RuntimeException('Zend Diactoros must be installed to use the DiactorosFactory.');
Chris@0 38 }
Chris@0 39 }
Chris@0 40
Chris@0 41 /**
Chris@0 42 * {@inheritdoc}
Chris@0 43 */
Chris@0 44 public function createRequest(Request $symfonyRequest)
Chris@0 45 {
Chris@18 46 $server = method_exists('Zend\Diactoros\ServerRequestFactory', 'normalizeServer')
Chris@18 47 ? DiactorosRequestFactory::normalizeServer($symfonyRequest->server->all())
Chris@18 48 : \Zend\Diactoros\normalizeServer($symfonyRequest->server->all());
Chris@0 49 $headers = $symfonyRequest->headers->all();
Chris@0 50
Chris@0 51 if (PHP_VERSION_ID < 50600) {
Chris@0 52 $body = new DiactorosStream('php://temp', 'wb+');
Chris@0 53 $body->write($symfonyRequest->getContent());
Chris@0 54 } else {
Chris@0 55 $body = new DiactorosStream($symfonyRequest->getContent(true));
Chris@0 56 }
Chris@0 57
Chris@18 58 $files = method_exists('Zend\Diactoros\ServerRequestFactory', 'normalizeFiles')
Chris@18 59 ? DiactorosRequestFactory::normalizeFiles($this->getFiles($symfonyRequest->files->all()))
Chris@18 60 : \Zend\Diactoros\normalizeUploadedFiles($this->getFiles($symfonyRequest->files->all()));
Chris@18 61
Chris@0 62 $request = new ServerRequest(
Chris@0 63 $server,
Chris@18 64 $files,
Chris@12 65 $symfonyRequest->getSchemeAndHttpHost().$symfonyRequest->getRequestUri(),
Chris@0 66 $symfonyRequest->getMethod(),
Chris@0 67 $body,
Chris@0 68 $headers
Chris@0 69 );
Chris@0 70
Chris@0 71 $request = $request
Chris@0 72 ->withCookieParams($symfonyRequest->cookies->all())
Chris@0 73 ->withQueryParams($symfonyRequest->query->all())
Chris@0 74 ->withParsedBody($symfonyRequest->request->all())
Chris@12 75 ->withRequestTarget($symfonyRequest->getRequestUri())
Chris@0 76 ;
Chris@0 77
Chris@0 78 foreach ($symfonyRequest->attributes->all() as $key => $value) {
Chris@0 79 $request = $request->withAttribute($key, $value);
Chris@0 80 }
Chris@0 81
Chris@0 82 return $request;
Chris@0 83 }
Chris@0 84
Chris@0 85 /**
Chris@0 86 * Converts Symfony uploaded files array to the PSR one.
Chris@0 87 *
Chris@0 88 * @param array $uploadedFiles
Chris@0 89 *
Chris@0 90 * @return array
Chris@0 91 */
Chris@0 92 private function getFiles(array $uploadedFiles)
Chris@0 93 {
Chris@0 94 $files = array();
Chris@0 95
Chris@0 96 foreach ($uploadedFiles as $key => $value) {
Chris@0 97 if (null === $value) {
Chris@0 98 $files[$key] = new DiactorosUploadedFile(null, 0, UPLOAD_ERR_NO_FILE, null, null);
Chris@0 99 continue;
Chris@0 100 }
Chris@0 101 if ($value instanceof UploadedFile) {
Chris@0 102 $files[$key] = $this->createUploadedFile($value);
Chris@0 103 } else {
Chris@0 104 $files[$key] = $this->getFiles($value);
Chris@0 105 }
Chris@0 106 }
Chris@0 107
Chris@0 108 return $files;
Chris@0 109 }
Chris@0 110
Chris@0 111 /**
Chris@0 112 * Creates a PSR-7 UploadedFile instance from a Symfony one.
Chris@0 113 *
Chris@0 114 * @param UploadedFile $symfonyUploadedFile
Chris@0 115 *
Chris@0 116 * @return UploadedFileInterface
Chris@0 117 */
Chris@0 118 private function createUploadedFile(UploadedFile $symfonyUploadedFile)
Chris@0 119 {
Chris@0 120 return new DiactorosUploadedFile(
Chris@0 121 $symfonyUploadedFile->getRealPath(),
Chris@17 122 (int) $symfonyUploadedFile->getSize(),
Chris@0 123 $symfonyUploadedFile->getError(),
Chris@0 124 $symfonyUploadedFile->getClientOriginalName(),
Chris@0 125 $symfonyUploadedFile->getClientMimeType()
Chris@0 126 );
Chris@0 127 }
Chris@0 128
Chris@0 129 /**
Chris@0 130 * {@inheritdoc}
Chris@0 131 */
Chris@0 132 public function createResponse(Response $symfonyResponse)
Chris@0 133 {
Chris@0 134 if ($symfonyResponse instanceof BinaryFileResponse) {
Chris@0 135 $stream = new DiactorosStream($symfonyResponse->getFile()->getPathname(), 'r');
Chris@0 136 } else {
Chris@0 137 $stream = new DiactorosStream('php://temp', 'wb+');
Chris@0 138 if ($symfonyResponse instanceof StreamedResponse) {
Chris@0 139 ob_start(function ($buffer) use ($stream) {
Chris@0 140 $stream->write($buffer);
Chris@0 141
Chris@17 142 return '';
Chris@0 143 });
Chris@0 144
Chris@0 145 $symfonyResponse->sendContent();
Chris@0 146 ob_end_clean();
Chris@0 147 } else {
Chris@0 148 $stream->write($symfonyResponse->getContent());
Chris@0 149 }
Chris@0 150 }
Chris@0 151
Chris@0 152 $headers = $symfonyResponse->headers->all();
Chris@18 153 if (!isset($headers['Set-Cookie']) && !isset($headers['set-cookie'])) {
Chris@17 154 $cookies = $symfonyResponse->headers->getCookies();
Chris@17 155 if (!empty($cookies)) {
Chris@17 156 $headers['Set-Cookie'] = array();
Chris@17 157 foreach ($cookies as $cookie) {
Chris@17 158 $headers['Set-Cookie'][] = $cookie->__toString();
Chris@17 159 }
Chris@0 160 }
Chris@0 161 }
Chris@0 162
Chris@0 163 $response = new DiactorosResponse(
Chris@0 164 $stream,
Chris@0 165 $symfonyResponse->getStatusCode(),
Chris@0 166 $headers
Chris@0 167 );
Chris@0 168
Chris@0 169 $protocolVersion = $symfonyResponse->getProtocolVersion();
Chris@0 170 if ('1.1' !== $protocolVersion) {
Chris@0 171 $response = $response->withProtocolVersion($protocolVersion);
Chris@0 172 }
Chris@0 173
Chris@0 174 return $response;
Chris@0 175 }
Chris@0 176 }