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