|
|
@@ -137,21 +137,23 @@ class File implements Response
|
|
|
curl_setopt($fp, $curl_param, $curl_value);
|
|
|
}
|
|
|
|
|
|
+ /** @var string|false $responseHeaders */
|
|
|
$responseHeaders = curl_exec($fp);
|
|
|
if (curl_errno($fp) === CURLE_WRITE_ERROR || curl_errno($fp) === CURLE_BAD_CONTENT_ENCODING) {
|
|
|
$this->error = 'cURL error ' . curl_errno($fp) . ': ' . curl_error($fp); // FreshRSS
|
|
|
- $this->on_http_response();
|
|
|
+ $this->on_http_response($responseHeaders);
|
|
|
$this->error = null; // FreshRSS
|
|
|
curl_setopt($fp, CURLOPT_ENCODING, 'none');
|
|
|
+ /** @var string|false $responseHeaders */
|
|
|
$responseHeaders = curl_exec($fp);
|
|
|
}
|
|
|
$this->status_code = curl_getinfo($fp, CURLINFO_HTTP_CODE);
|
|
|
if (curl_errno($fp)) {
|
|
|
$this->error = 'cURL error ' . curl_errno($fp) . ': ' . curl_error($fp);
|
|
|
$this->success = false;
|
|
|
- $this->on_http_response();
|
|
|
+ $this->on_http_response($responseHeaders);
|
|
|
} else {
|
|
|
- $this->on_http_response();
|
|
|
+ $this->on_http_response($responseHeaders);
|
|
|
// Use the updated url provided by curl_getinfo after any redirects.
|
|
|
if ($info = curl_getinfo($fp)) {
|
|
|
$this->url = $info['url'];
|
|
|
@@ -199,7 +201,7 @@ class File implements Response
|
|
|
if (!$fp) {
|
|
|
$this->error = 'fsockopen error: ' . $errstr;
|
|
|
$this->success = false;
|
|
|
- $this->on_http_response();
|
|
|
+ $this->on_http_response(false);
|
|
|
} else {
|
|
|
stream_set_timeout($fp, $timeout);
|
|
|
if (isset($url_parts['path'])) {
|
|
|
@@ -240,7 +242,7 @@ class File implements Response
|
|
|
$this->set_headers($parser->headers);
|
|
|
$this->body = $parser->body;
|
|
|
$this->status_code = $parser->status_code;
|
|
|
- $this->on_http_response();
|
|
|
+ $this->on_http_response($responseHeaders);
|
|
|
if ((in_array($this->status_code, [300, 301, 302, 303, 307]) || $this->status_code > 307 && $this->status_code < 400) && ($locationHeader = $this->get_header_line('location')) !== '' && $this->redirects < $redirects) {
|
|
|
$this->redirects++;
|
|
|
$location = \SimplePie\Misc::absolutize_url($locationHeader, $url);
|
|
|
@@ -288,18 +290,19 @@ class File implements Response
|
|
|
} else {
|
|
|
$this->error = 'Could not parse'; // FreshRSS
|
|
|
$this->success = false; // FreshRSS
|
|
|
- $this->on_http_response();
|
|
|
+ $this->on_http_response($responseHeaders);
|
|
|
}
|
|
|
} else {
|
|
|
$this->error = 'fsocket timed out';
|
|
|
$this->success = false;
|
|
|
- $this->on_http_response();
|
|
|
+ $this->on_http_response($responseHeaders);
|
|
|
}
|
|
|
fclose($fp);
|
|
|
}
|
|
|
}
|
|
|
} else {
|
|
|
$this->method = \SimplePie\SimplePie::FILE_SOURCE_LOCAL | \SimplePie\SimplePie::FILE_SOURCE_FILE_GET_CONTENTS;
|
|
|
+ $filebody = false;
|
|
|
if (empty($url) || !is_readable($url) || false === $filebody = file_get_contents($url)) {
|
|
|
$this->body = '';
|
|
|
$this->error = sprintf('file "%s" is not readable', $url);
|
|
|
@@ -308,7 +311,7 @@ class File implements Response
|
|
|
$this->body = $filebody;
|
|
|
$this->status_code = 200;
|
|
|
}
|
|
|
- $this->on_http_response();
|
|
|
+ $this->on_http_response($filebody);
|
|
|
}
|
|
|
if ($this->success) {
|
|
|
assert($this->body !== null); // For PHPStan
|
|
|
@@ -322,9 +325,10 @@ class File implements Response
|
|
|
/**
|
|
|
* Event to allow inheriting classes to e.g. log the HTTP responses.
|
|
|
* Triggered just after an HTTP response is received.
|
|
|
+ * @param string|false $response The raw HTTP response headers and body, or false in case of failure (as returned by curl_exec()).
|
|
|
* FreshRSS.
|
|
|
*/
|
|
|
- protected function on_http_response(): void
|
|
|
+ protected function on_http_response($response): void
|
|
|
{
|
|
|
}
|
|
|
|