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->getUri(),
  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         ;
  69
  70         foreach ($symfonyRequest->attributes->all() as $key => $value) {
  71             $request = $request->withAttribute($key, $value);
  72         }
  73
  74         return $request;
  75     }
  76
  77     /**
  78      * Converts Symfony uploaded files array to the PSR one.
  79      *
  80      * @param array $uploadedFiles
  81      *
  82      * @return array
  83      */
  84     private function getFiles(array $uploadedFiles)
  85     {
  86         $files = array();
  87
  88         foreach ($uploadedFiles as $key => $value) {
  89             if (null === $value) {
  90                 $files[$key] = new DiactorosUploadedFile(null, 0, UPLOAD_ERR_NO_FILE, null, null);
  91                 continue;
  92             }
  93             if ($value instanceof UploadedFile) {
  94                 $files[$key] = $this->createUploadedFile($value);
  95             } else {
  96                 $files[$key] = $this->getFiles($value);
  97             }
  98         }
  99
 100         return $files;
 101     }
 102
 103     /**
 104      * Creates a PSR-7 UploadedFile instance from a Symfony one.
 105      *
 106      * @param UploadedFile $symfonyUploadedFile
 107      *
 108      * @return UploadedFileInterface
 109      */
 110     private function createUploadedFile(UploadedFile $symfonyUploadedFile)
 111     {
 112         return new DiactorosUploadedFile(
 113             $symfonyUploadedFile->getRealPath(),
 114             $symfonyUploadedFile->getClientSize(),
 115             $symfonyUploadedFile->getError(),
 116             $symfonyUploadedFile->getClientOriginalName(),
 117             $symfonyUploadedFile->getClientMimeType()
 118         );
 119     }
 120
 121     /**
 122      * {@inheritdoc}
 123      */
 124     public function createResponse(Response $symfonyResponse)
 125     {
 126         if ($symfonyResponse instanceof BinaryFileResponse) {
 127             $stream = new DiactorosStream($symfonyResponse->getFile()->getPathname(), 'r');
 128         } else {
 129             $stream = new DiactorosStream('php://temp', 'wb+');
 130             if ($symfonyResponse instanceof StreamedResponse) {
 131                 ob_start(function ($buffer) use ($stream) {
 132                     $stream->write($buffer);
 133
 134                     return false;
 135                 });
 136
 137                 $symfonyResponse->sendContent();
 138                 ob_end_clean();
 139             } else {
 140                 $stream->write($symfonyResponse->getContent());
 141             }
 142         }
 143
 144         $headers = $symfonyResponse->headers->all();
 145
 146         $cookies = $symfonyResponse->headers->getCookies();
 147         if (!empty($cookies)) {
 148             $headers['Set-Cookie'] = array();
 149
 150             foreach ($cookies as $cookie) {
 151                 $headers['Set-Cookie'][] = $cookie->__toString();
 152             }
 153         }
 154
 155         $response = new DiactorosResponse(
 156             $stream,
 157             $symfonyResponse->getStatusCode(),
 158             $headers
 159         );
 160
 161         $protocolVersion = $symfonyResponse->getProtocolVersion();
 162         if ('1.1' !== $protocolVersion) {
 163             $response = $response->withProtocolVersion($protocolVersion);
 164         }
 165
 166         return $response;
 167     }
 168 }