public-mirrors
/
composer
mirror of https://github.com/composer/composer
1
0
Fork 0
Code

RemoteFileSystem: response decode for TransportException

pull/9176/head
Stephan 2020-09-02 16:55:37 +01:00
parent 86ff43d8b9
commit 3b2d91975e
1 changed files with 42 additions and 32 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

74
src/Composer/Util/RemoteFilesystem.php
View File

@ -299,7 +299,7 @@ class RemoteFilesystem
$e = new TransportException('Content-Length mismatch, received '.Platform::strlen($result).' bytes out of the expected '.$contentLength); $e = new TransportException('Content-Length mismatch, received '.Platform::strlen($result).' bytes out of the expected '.$contentLength);
$e->setHeaders($http_response_header); $e->setHeaders($http_response_header);
$e->setStatusCode($this->findStatusCode($http_response_header)); $e->setStatusCode($this->findStatusCode($http_response_header));
$e->setResponse($result); $e->setResponse($this->decodeResult($result, $http_response_header));
$this->io->writeError('Content-Length mismatch, received '.Platform::strlen($result).' out of '.$contentLength.' bytes: (' . base64_encode($result).')', true, IOInterface::DEBUG); $this->io->writeError('Content-Length mismatch, received '.Platform::strlen($result).' out of '.$contentLength.' bytes: (' . base64_encode($result).')', true, IOInterface::DEBUG);
throw $e; throw $e;
@ -322,7 +322,7 @@ class RemoteFilesystem
$e->setStatusCode($this->findStatusCode($http_response_header)); $e->setStatusCode($this->findStatusCode($http_response_header));
} }
if ($e instanceof TransportException && $result !== false) { if ($e instanceof TransportException && $result !== false) {
$e->setResponse($result); $e->setResponse($this->decodeResult($result, $http_response_header));
} }
$result = false; $result = false;
} }
@ -394,7 +394,7 @@ class RemoteFilesystem
$e = new TransportException('The "'.$this->fileUrl.'" file could not be downloaded ('.$http_response_header[0].')', $statusCode); $e = new TransportException('The "'.$this->fileUrl.'" file could not be downloaded ('.$http_response_header[0].')', $statusCode);
$e->setHeaders($http_response_header); $e->setHeaders($http_response_header);
$e->setResponse($result); $e->setResponse($this->decodeResult($result, $http_response_header));
$e->setStatusCode($statusCode); $e->setStatusCode($statusCode);
throw $e; throw $e;
} }
@ -407,35 +407,21 @@ class RemoteFilesystem
// decode gzip // decode gzip
if ($result && extension_loaded('zlib') && substr($fileUrl, 0, 4) === 'http' && !$hasFollowedRedirect) { if ($result && extension_loaded('zlib') && substr($fileUrl, 0, 4) === 'http' && !$hasFollowedRedirect) {
$contentEncoding = Response::findHeaderValue($http_response_header, 'content-encoding'); try {
$decode = $contentEncoding && 'gzip' === strtolower($contentEncoding); $result = $this->decodeResult($result, $http_response_header);
} catch (\Exception $e) {
if ($decode) { if ($this->degradedMode) {
try { throw $e;
if (PHP_VERSION_ID >= 50400) {
$result = zlib_decode($result);
} else {
// work around issue with gzuncompress & co that do not work with all gzip checksums
$result = file_get_contents('compress.zlib://data:application/octet-stream;base64,'.base64_encode($result));
}
if (!$result) {
throw new TransportException('Failed to decode zlib stream');
}
} catch (\Exception $e) {
if ($this->degradedMode) {
throw $e;
}
$this->degradedMode = true;
$this->io->writeError(array(
'',
'<error>Failed to decode response: '.$e->getMessage().'</error>',
'<error>Retrying with degraded mode, check https://getcomposer.org/doc/articles/troubleshooting.md#degraded-mode for more info</error>',
));
return $this->get($this->originUrl, $this->fileUrl, $additionalOptions, $this->fileName, $this->progress);
} }
$this->degradedMode = true;
$this->io->writeError(array(
'',
'<error>Failed to decode response: '.$e->getMessage().'</error>',
'<error>Retrying with degraded mode, check https://getcomposer.org/doc/articles/troubleshooting.md#degraded-mode for more info</error>',
));
return $this->get($this->originUrl, $this->fileUrl, $additionalOptions, $this->fileName, $this->progress);
} }
} }
@ -737,7 +723,7 @@ class RemoteFilesystem
if (!$this->retry) { if (!$this->retry) {
$e = new TransportException('The "'.$this->fileUrl.'" file could not be downloaded, got redirect without Location ('.$http_response_header[0].')'); $e = new TransportException('The "'.$this->fileUrl.'" file could not be downloaded, got redirect without Location ('.$http_response_header[0].')');
$e->setHeaders($http_response_header); $e->setHeaders($http_response_header);
$e->setResponse($result); $e->setResponse($this->decodeResult($result, $http_response_header));
throw $e; throw $e;
} }
@ -814,4 +800,28 @@ class RemoteFilesystem
return parse_url($url, PHP_URL_HOST).':'.$port; return parse_url($url, PHP_URL_HOST).':'.$port;
} }
private function decodeResult($result, $http_response_header)
{
// decode gzip
if ($result && extension_loaded('zlib')) {
$contentEncoding = Response::findHeaderValue($http_response_header, 'content-encoding');
$decode = $contentEncoding && 'gzip' === strtolower($contentEncoding);
if ($decode) {
if (PHP_VERSION_ID >= 50400) {
$result = zlib_decode($result);
} else {
// work around issue with gzuncompress & co that do not work with all gzip checksums
$result = file_get_contents('compress.zlib://data:application/octet-stream;base64,'.base64_encode($result));
}
if (!$result) {
throw new TransportException('Failed to decode zlib stream');
}
}
}
return $result;
}
} }