www.aleph1.co.uk Git - yaffs-website/blob - vendor/symfony/psr-http-message-bridge/Factory/DiactorosFactory.php

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