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