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