Chris@17: <?php
Chris@17: 
Chris@17: /*
Chris@17:  * This file is part of the Symfony package.
Chris@17:  *
Chris@17:  * (c) Fabien Potencier <fabien@symfony.com>
Chris@17:  *
Chris@17:  * For the full copyright and license information, please view the LICENSE
Chris@17:  * file that was distributed with this source code.
Chris@17:  */
Chris@17: 
Chris@17: namespace Symfony\Bridge\PsrHttpMessage\Factory;
Chris@17: 
Chris@17: use Psr\Http\Message\ResponseFactoryInterface;
Chris@17: use Psr\Http\Message\ServerRequestFactoryInterface;
Chris@17: use Psr\Http\Message\StreamFactoryInterface;
Chris@17: use Psr\Http\Message\UploadedFileFactoryInterface;
Chris@17: use Psr\Http\Message\UploadedFileInterface;
Chris@17: use Symfony\Bridge\PsrHttpMessage\HttpMessageFactoryInterface;
Chris@17: use Symfony\Component\HttpFoundation\BinaryFileResponse;
Chris@17: use Symfony\Component\HttpFoundation\File\UploadedFile;
Chris@17: use Symfony\Component\HttpFoundation\Request;
Chris@17: use Symfony\Component\HttpFoundation\Response;
Chris@17: use Symfony\Component\HttpFoundation\StreamedResponse;
Chris@17: 
Chris@17: /**
Chris@17:  * Builds Psr\HttpMessage instances using a PSR-17 implementation.
Chris@17:  *
Chris@17:  * @author Antonio J. García Lagar <aj@garcialagar.es>
Chris@17:  */
Chris@17: class PsrHttpFactory implements HttpMessageFactoryInterface
Chris@17: {
Chris@17:     private $serverRequestFactory;
Chris@17:     private $streamFactory;
Chris@17:     private $uploadedFileFactory;
Chris@17:     private $responseFactory;
Chris@17: 
Chris@17:     public function __construct(ServerRequestFactoryInterface $serverRequestFactory, StreamFactoryInterface $streamFactory, UploadedFileFactoryInterface $uploadedFileFactory, ResponseFactoryInterface $responseFactory)
Chris@17:     {
Chris@17:         $this->serverRequestFactory = $serverRequestFactory;
Chris@17:         $this->streamFactory = $streamFactory;
Chris@17:         $this->uploadedFileFactory = $uploadedFileFactory;
Chris@17:         $this->responseFactory = $responseFactory;
Chris@17:     }
Chris@17: 
Chris@17:     /**
Chris@17:      * {@inheritdoc}
Chris@17:      */
Chris@17:     public function createRequest(Request $symfonyRequest)
Chris@17:     {
Chris@17:         $request = $this->serverRequestFactory->createServerRequest(
Chris@17:             $symfonyRequest->getMethod(),
Chris@17:             $symfonyRequest->getSchemeAndHttpHost().$symfonyRequest->getRequestUri(),
Chris@17:             $symfonyRequest->server->all()
Chris@17:         );
Chris@17: 
Chris@17:         foreach ($symfonyRequest->headers->all() as $name => $value) {
Chris@17:             $request = $request->withHeader($name, $value);
Chris@17:         }
Chris@17: 
Chris@17:         if (PHP_VERSION_ID < 50600) {
Chris@17:             $body = $this->streamFactory->createStreamFromFile('php://temp', 'wb+');
Chris@17:             $body->write($symfonyRequest->getContent());
Chris@17:         } else {
Chris@17:             $body = $this->streamFactory->createStreamFromResource($symfonyRequest->getContent(true));
Chris@17:         }
Chris@17: 
Chris@17:         $request = $request
Chris@17:             ->withBody($body)
Chris@17:             ->withUploadedFiles($this->getFiles($symfonyRequest->files->all()))
Chris@17:             ->withCookieParams($symfonyRequest->cookies->all())
Chris@17:             ->withQueryParams($symfonyRequest->query->all())
Chris@17:             ->withParsedBody($symfonyRequest->request->all())
Chris@17:         ;
Chris@17: 
Chris@17:         foreach ($symfonyRequest->attributes->all() as $key => $value) {
Chris@17:             $request = $request->withAttribute($key, $value);
Chris@17:         }
Chris@17: 
Chris@17:         return $request;
Chris@17:     }
Chris@17: 
Chris@17:     /**
Chris@17:      * Converts Symfony uploaded files array to the PSR one.
Chris@17:      *
Chris@17:      * @param array $uploadedFiles
Chris@17:      *
Chris@17:      * @return array
Chris@17:      */
Chris@17:     private function getFiles(array $uploadedFiles)
Chris@17:     {
Chris@17:         $files = array();
Chris@17: 
Chris@17:         foreach ($uploadedFiles as $key => $value) {
Chris@17:             if (null === $value) {
Chris@17:                 $files[$key] = $this->uploadedFileFactory->createUploadedFile($this->streamFactory->createStream(), 0, UPLOAD_ERR_NO_FILE);
Chris@17:                 continue;
Chris@17:             }
Chris@17:             if ($value instanceof UploadedFile) {
Chris@17:                 $files[$key] = $this->createUploadedFile($value);
Chris@17:             } else {
Chris@17:                 $files[$key] = $this->getFiles($value);
Chris@17:             }
Chris@17:         }
Chris@17: 
Chris@17:         return $files;
Chris@17:     }
Chris@17: 
Chris@17:     /**
Chris@17:      * Creates a PSR-7 UploadedFile instance from a Symfony one.
Chris@17:      *
Chris@17:      * @param UploadedFile $symfonyUploadedFile
Chris@17:      *
Chris@17:      * @return UploadedFileInterface
Chris@17:      */
Chris@17:     private function createUploadedFile(UploadedFile $symfonyUploadedFile)
Chris@17:     {
Chris@17:         return $this->uploadedFileFactory->createUploadedFile(
Chris@17:             $this->streamFactory->createStreamFromFile(
Chris@17:                 $symfonyUploadedFile->getRealPath()
Chris@17:             ),
Chris@17:             (int) $symfonyUploadedFile->getSize(),
Chris@17:             $symfonyUploadedFile->getError(),
Chris@17:             $symfonyUploadedFile->getClientOriginalName(),
Chris@17:             $symfonyUploadedFile->getClientMimeType()
Chris@17:         );
Chris@17:     }
Chris@17: 
Chris@17:     /**
Chris@17:      * {@inheritdoc}
Chris@17:      */
Chris@17:     public function createResponse(Response $symfonyResponse)
Chris@17:     {
Chris@17:         $response = $this->responseFactory->createResponse($symfonyResponse->getStatusCode());
Chris@17: 
Chris@17:         if ($symfonyResponse instanceof BinaryFileResponse) {
Chris@17:             $stream = $this->streamFactory->createStreamFromFile(
Chris@17:                 $symfonyResponse->getFile()->getPathname()
Chris@17:             );
Chris@17:         } else {
Chris@17:             $stream = $this->streamFactory->createStreamFromFile('php://temp', 'wb+');
Chris@17:             if ($symfonyResponse instanceof StreamedResponse) {
Chris@17:                 ob_start(function ($buffer) use ($stream) {
Chris@17:                     $stream->write($buffer);
Chris@17: 
Chris@17:                     return '';
Chris@17:                 });
Chris@17: 
Chris@17:                 $symfonyResponse->sendContent();
Chris@17:                 ob_end_clean();
Chris@17:             } else {
Chris@17:                 $stream->write($symfonyResponse->getContent());
Chris@17:             }
Chris@17:         }
Chris@17: 
Chris@17:         $response = $response->withBody($stream);
Chris@17: 
Chris@17:         $headers = $symfonyResponse->headers->all();
Chris@17:         $cookies = $symfonyResponse->headers->getCookies();
Chris@17:         if (!empty($cookies)) {
Chris@17:             $headers['Set-Cookie'] = array();
Chris@17: 
Chris@17:             foreach ($cookies as $cookie) {
Chris@17:                 $headers['Set-Cookie'][] = $cookie->__toString();
Chris@17:             }
Chris@17:         }
Chris@17: 
Chris@17:         foreach ($headers as $name => $value) {
Chris@17:             $response = $response->withHeader($name, $value);
Chris@17:         }
Chris@17: 
Chris@17:         $protocolVersion = $symfonyResponse->getProtocolVersion();
Chris@17:         $response = $response->withProtocolVersion($protocolVersion);
Chris@17: 
Chris@17:         return $response;
Chris@17:     }
Chris@17: }