[BUGFIX] Fix T3editor after PSR-7 change
[Packages/TYPO3.CMS.git] / typo3 / sysext / openid / lib / php-openid / Auth / Yadis / PlainHTTPFetcher.php
1 <?php
2
3 /**
4 * This module contains the plain non-curl HTTP fetcher
5 * implementation.
6 *
7 * PHP versions 4 and 5
8 *
9 * LICENSE: See the COPYING file included in this distribution.
10 *
11 * @package OpenID
12 * @author JanRain, Inc. <openid@janrain.com>
13 * @copyright 2005-2008 Janrain, Inc.
14 * @license http://www.apache.org/licenses/LICENSE-2.0 Apache
15 */
16
17 /**
18 * Interface import
19 */
20 require_once "Auth/Yadis/HTTPFetcher.php";
21
22 /**
23 * This class implements a plain, hand-built socket-based fetcher
24 * which will be used in the event that CURL is unavailable.
25 *
26 * @package OpenID
27 */
28 class Auth_Yadis_PlainHTTPFetcher extends Auth_Yadis_HTTPFetcher {
29 /**
30 * Does this fetcher support SSL URLs?
31 */
32 function supportsSSL()
33 {
34 return function_exists('openssl_open');
35 }
36
37 function get($url, $extra_headers = null)
38 {
39 if (!$this->canFetchURL($url)) {
40 return null;
41 }
42
43 $redir = true;
44
45 $stop = time() + $this->timeout;
46 $off = $this->timeout;
47
48 while ($redir && ($off > 0)) {
49
50 $parts = parse_url($url);
51
52 $specify_port = true;
53
54 // Set a default port.
55 if (!array_key_exists('port', $parts)) {
56 $specify_port = false;
57 if ($parts['scheme'] == 'http') {
58 $parts['port'] = 80;
59 } elseif ($parts['scheme'] == 'https') {
60 $parts['port'] = 443;
61 } else {
62 return null;
63 }
64 }
65
66 if (!array_key_exists('path', $parts)) {
67 $parts['path'] = '/';
68 }
69
70 $host = $parts['host'];
71
72 if ($parts['scheme'] == 'https') {
73 $host = 'ssl://' . $host;
74 }
75
76 $user_agent = Auth_OpenID_USER_AGENT;
77
78 $headers = array(
79 "GET ".$parts['path'].
80 (array_key_exists('query', $parts) ?
81 "?".$parts['query'] : "").
82 " HTTP/1.0",
83 "User-Agent: $user_agent",
84 "Host: ".$parts['host'].
85 ($specify_port ? ":".$parts['port'] : ""),
86 "Port: ".$parts['port']);
87
88 $errno = 0;
89 $errstr = '';
90
91 if ($extra_headers) {
92 foreach ($extra_headers as $h) {
93 $headers[] = $h;
94 }
95 }
96
97 @$sock = fsockopen($host, $parts['port'], $errno, $errstr,
98 $this->timeout);
99 if ($sock === false) {
100 return false;
101 }
102
103 stream_set_timeout($sock, $this->timeout);
104
105 fputs($sock, implode("\r\n", $headers) . "\r\n\r\n");
106
107 $data = "";
108 $kilobytes = 0;
109 while (!feof($sock) &&
110 $kilobytes < Auth_OpenID_FETCHER_MAX_RESPONSE_KB ) {
111 $data .= fgets($sock, 1024);
112 $kilobytes += 1;
113 }
114
115 fclose($sock);
116
117 // Split response into header and body sections
118 list($headers, $body) = explode("\r\n\r\n", $data, 2);
119 $headers = explode("\r\n", $headers);
120
121 $http_code = explode(" ", $headers[0]);
122 $code = $http_code[1];
123
124 if (in_array($code, array('301', '302'))) {
125 $url = $this->_findRedirect($headers, $url);
126 $redir = true;
127 } else {
128 $redir = false;
129 }
130
131 $off = $stop - time();
132 }
133
134 $new_headers = array();
135
136 foreach ($headers as $header) {
137 if (preg_match("/:/", $header)) {
138 $parts = explode(": ", $header, 2);
139
140 if (count($parts) == 2) {
141 list($name, $value) = $parts;
142 $new_headers[$name] = $value;
143 }
144 }
145
146 }
147
148 return new Auth_Yadis_HTTPResponse($url, $code, $new_headers, $body);
149 }
150
151 function post($url, $body, $extra_headers = null)
152 {
153 if (!$this->canFetchURL($url)) {
154 return null;
155 }
156
157 $parts = parse_url($url);
158
159 $headers = array();
160
161 $post_path = $parts['path'];
162 if (isset($parts['query'])) {
163 $post_path .= '?' . $parts['query'];
164 }
165
166 $headers[] = "POST ".$post_path." HTTP/1.0";
167 $headers[] = "Host: " . $parts['host'];
168 $headers[] = "Content-type: application/x-www-form-urlencoded";
169 $headers[] = "Content-length: " . strval(strlen($body));
170
171 if ($extra_headers &&
172 is_array($extra_headers)) {
173 $headers = array_merge($headers, $extra_headers);
174 }
175
176 // Join all headers together.
177 $all_headers = implode("\r\n", $headers);
178
179 // Add headers, two newlines, and request body.
180 $request = $all_headers . "\r\n\r\n" . $body;
181
182 // Set a default port.
183 if (!array_key_exists('port', $parts)) {
184 if ($parts['scheme'] == 'http') {
185 $parts['port'] = 80;
186 } elseif ($parts['scheme'] == 'https') {
187 $parts['port'] = 443;
188 } else {
189 return null;
190 }
191 }
192
193 if ($parts['scheme'] == 'https') {
194 $parts['host'] = sprintf("ssl://%s", $parts['host']);
195 }
196
197 // Connect to the remote server.
198 $errno = 0;
199 $errstr = '';
200
201 $sock = fsockopen($parts['host'], $parts['port'], $errno, $errstr,
202 $this->timeout);
203
204 if ($sock === false) {
205 return null;
206 }
207
208 stream_set_timeout($sock, $this->timeout);
209
210 // Write the POST request.
211 fputs($sock, $request);
212
213 // Get the response from the server.
214 $response = "";
215 while (!feof($sock)) {
216 if ($data = fgets($sock, 128)) {
217 $response .= $data;
218 } else {
219 break;
220 }
221 }
222
223 // Split the request into headers and body.
224 list($headers, $response_body) = explode("\r\n\r\n", $response, 2);
225
226 $headers = explode("\r\n", $headers);
227
228 // Expect the first line of the headers data to be something
229 // like HTTP/1.1 200 OK. Split the line on spaces and take
230 // the second token, which should be the return code.
231 $http_code = explode(" ", $headers[0]);
232 $code = $http_code[1];
233
234 $new_headers = array();
235
236 foreach ($headers as $header) {
237 if (preg_match("/:/", $header)) {
238 list($name, $value) = explode(": ", $header, 2);
239 $new_headers[$name] = $value;
240 }
241
242 }
243
244 return new Auth_Yadis_HTTPResponse($url, $code,
245 $new_headers, $response_body);
246 }
247 }
248