4 * This file is part of the Symfony package.
6 * (c) Fabien Potencier <fabien@symfony.com>
8 * For the full copyright and license information, please view the LICENSE
9 * file that was distributed with this source code.
12 namespace Symfony\Bridge\PsrHttpMessage\Factory;
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;
27 * Builds Psr\HttpMessage instances using the Zend Diactoros implementation.
29 * @author Kévin Dunglas <dunglas@gmail.com>
31 class DiactorosFactory implements HttpMessageFactoryInterface
33 public function __construct()
35 if (!class_exists('Zend\Diactoros\ServerRequestFactory')) {
36 throw new \RuntimeException('Zend Diactoros must be installed to use the DiactorosFactory.');
43 public function createRequest(Request $symfonyRequest)
45 $server = DiactorosRequestFactory::normalizeServer($symfonyRequest->server->all());
46 $headers = $symfonyRequest->headers->all();
48 if (PHP_VERSION_ID < 50600) {
49 $body = new DiactorosStream('php://temp', 'wb+');
50 $body->write($symfonyRequest->getContent());
52 $body = new DiactorosStream($symfonyRequest->getContent(true));
55 $request = new ServerRequest(
57 DiactorosRequestFactory::normalizeFiles($this->getFiles($symfonyRequest->files->all())),
58 $symfonyRequest->getUri(),
59 $symfonyRequest->getMethod(),
65 ->withCookieParams($symfonyRequest->cookies->all())
66 ->withQueryParams($symfonyRequest->query->all())
67 ->withParsedBody($symfonyRequest->request->all())
70 foreach ($symfonyRequest->attributes->all() as $key => $value) {
71 $request = $request->withAttribute($key, $value);
78 * Converts Symfony uploaded files array to the PSR one.
80 * @param array $uploadedFiles
84 private function getFiles(array $uploadedFiles)
88 foreach ($uploadedFiles as $key => $value) {
89 if (null === $value) {
90 $files[$key] = new DiactorosUploadedFile(null, 0, UPLOAD_ERR_NO_FILE, null, null);
93 if ($value instanceof UploadedFile) {
94 $files[$key] = $this->createUploadedFile($value);
96 $files[$key] = $this->getFiles($value);
104 * Creates a PSR-7 UploadedFile instance from a Symfony one.
106 * @param UploadedFile $symfonyUploadedFile
108 * @return UploadedFileInterface
110 private function createUploadedFile(UploadedFile $symfonyUploadedFile)
112 return new DiactorosUploadedFile(
113 $symfonyUploadedFile->getRealPath(),
114 $symfonyUploadedFile->getClientSize(),
115 $symfonyUploadedFile->getError(),
116 $symfonyUploadedFile->getClientOriginalName(),
117 $symfonyUploadedFile->getClientMimeType()
124 public function createResponse(Response $symfonyResponse)
126 if ($symfonyResponse instanceof BinaryFileResponse) {
127 $stream = new DiactorosStream($symfonyResponse->getFile()->getPathname(), 'r');
129 $stream = new DiactorosStream('php://temp', 'wb+');
130 if ($symfonyResponse instanceof StreamedResponse) {
131 ob_start(function ($buffer) use ($stream) {
132 $stream->write($buffer);
137 $symfonyResponse->sendContent();
140 $stream->write($symfonyResponse->getContent());
144 $headers = $symfonyResponse->headers->all();
146 $cookies = $symfonyResponse->headers->getCookies();
147 if (!empty($cookies)) {
148 $headers['Set-Cookie'] = array();
150 foreach ($cookies as $cookie) {
151 $headers['Set-Cookie'][] = $cookie->__toString();
155 $response = new DiactorosResponse(
157 $symfonyResponse->getStatusCode(),
161 $protocolVersion = $symfonyResponse->getProtocolVersion();
162 if ('1.1' !== $protocolVersion) {
163 $response = $response->withProtocolVersion($protocolVersion);