1
0
Fork 0

Properly handle installed repos as additionalFixedRepository, fixes #9574

pull/9651/head
Jordi Boggiano 2021-01-26 09:41:02 +01:00
parent f2cdec0f0f
commit 5c35f37f92
No known key found for this signature in database
GPG Key ID: 7BBD42C429EC80BC
2 changed files with 27 additions and 23 deletions

View File

@ -43,6 +43,7 @@ use Composer\Package\Version\VersionParser;
use Composer\Package\Package; use Composer\Package\Package;
use Composer\Repository\ArrayRepository; use Composer\Repository\ArrayRepository;
use Composer\Repository\RepositorySet; use Composer\Repository\RepositorySet;
use Composer\Repository\CompositeRepository;
use Composer\Semver\Constraint\Constraint; use Composer\Semver\Constraint\Constraint;
use Composer\Package\Locker; use Composer\Package\Locker;
use Composer\Package\RootPackageInterface; use Composer\Package\RootPackageInterface;
@ -767,14 +768,22 @@ class Installer
$repositorySet->addRepository(new RootPackageRepository($this->fixedRootPackage)); $repositorySet->addRepository(new RootPackageRepository($this->fixedRootPackage));
$repositorySet->addRepository($platformRepo); $repositorySet->addRepository($platformRepo);
if ($this->additionalFixedRepository) { if ($this->additionalFixedRepository) {
$additionalFixedRepository = $this->additionalFixedRepository; // allow using installed repos if needed to avoid warnings about installed repositories being used in the RepositorySet
// wrap the repository in a FilterRepository if needed to avoid warnings about installed repositories being used in the RepositorySet
// see https://github.com/composer/composer/pull/9574 // see https://github.com/composer/composer/pull/9574
if ($additionalFixedRepository instanceof InstalledRepository || $additionalFixedRepository instanceof InstalledRepositoryInterface) { $additionalFixedRepositories = $this->additionalFixedRepository;
$additionalFixedRepository = new FilterRepository($additionalFixedRepository, array()); if ($additionalFixedRepositories instanceof CompositeRepository) {
$additionalFixedRepositories = $additionalFixedRepositories->getRepositories();
} else {
$additionalFixedRepositories = array($additionalFixedRepositories);
}
foreach ($additionalFixedRepositories as $additionalFixedRepository) {
if ($additionalFixedRepository instanceof InstalledRepository || $additionalFixedRepository instanceof InstalledRepositoryInterface) {
$repositorySet->allowInstalledRepositories();
break;
}
} }
$repositorySet->addRepository($additionalFixedRepository); $repositorySet->addRepository($this->additionalFixedRepository);
} }
return $repositorySet; return $repositorySet;

View File

@ -303,9 +303,7 @@ class CurlDownloader
if (!$error && function_exists('curl_strerror')) { if (!$error && function_exists('curl_strerror')) {
$error = curl_strerror($errno); $error = curl_strerror($errno);
} }
$exception = new TransportException('curl error '.$errno.' while downloading '.Url::sanitize($progress['url']).': '.$error); throw new TransportException('curl error '.$errno.' while downloading '.Url::sanitize($progress['url']).': '.$error);
$exception->setResponseInfo($progress);
throw $exception;
} }
$statusCode = $progress['http_code']; $statusCode = $progress['http_code'];
rewind($job['headerHandle']); rewind($job['headerHandle']);
@ -337,7 +335,7 @@ class CurlDownloader
HttpDownloader::outputWarnings($this->io, $job['origin'], json_decode($response->getBody(), true)); HttpDownloader::outputWarnings($this->io, $job['origin'], json_decode($response->getBody(), true));
} }
$result = $this->isAuthenticatedRetryNeeded($job, $response, $progress); $result = $this->isAuthenticatedRetryNeeded($job, $response);
if ($result['retry']) { if ($result['retry']) {
$this->restartJob($job, $job['url'], array('storeAuth' => $result['storeAuth'])); $this->restartJob($job, $job['url'], array('storeAuth' => $result['storeAuth']));
continue; continue;
@ -345,7 +343,7 @@ class CurlDownloader
// handle 3xx redirects, 304 Not Modified is excluded // handle 3xx redirects, 304 Not Modified is excluded
if ($statusCode >= 300 && $statusCode <= 399 && $statusCode !== 304 && $job['attributes']['redirects'] < $this->maxRedirects) { if ($statusCode >= 300 && $statusCode <= 399 && $statusCode !== 304 && $job['attributes']['redirects'] < $this->maxRedirects) {
$location = $this->handleRedirect($job, $response, $progress); $location = $this->handleRedirect($job, $response);
if ($location) { if ($location) {
$this->restartJob($job, $location, array('redirects' => $job['attributes']['redirects'] + 1)); $this->restartJob($job, $location, array('redirects' => $job['attributes']['redirects'] + 1));
continue; continue;
@ -354,7 +352,7 @@ class CurlDownloader
// fail 4xx and 5xx responses and capture the response // fail 4xx and 5xx responses and capture the response
if ($statusCode >= 400 && $statusCode <= 599) { if ($statusCode >= 400 && $statusCode <= 599) {
throw $this->failResponse($job, $response, $response->getStatusMessage(), $progress); throw $this->failResponse($job, $response, $response->getStatusMessage());
} }
if ($job['attributes']['storeAuth']) { if ($job['attributes']['storeAuth']) {
@ -376,6 +374,9 @@ class CurlDownloader
if ($e instanceof TransportException && $response) { if ($e instanceof TransportException && $response) {
$e->setResponse($response->getBody()); $e->setResponse($response->getBody());
} }
if ($e instanceof TransportException && $progress) {
$e->setResponseInfo($progress);
}
if (is_resource($job['headerHandle'])) { if (is_resource($job['headerHandle'])) {
fclose($job['headerHandle']); fclose($job['headerHandle']);
@ -417,7 +418,7 @@ class CurlDownloader
} }
} }
private function handleRedirect(array $job, Response $response, array $responseInfo) private function handleRedirect(array $job, Response $response)
{ {
if ($locationHeader = $response->getHeader('location')) { if ($locationHeader = $response->getHeader('location')) {
if (parse_url($locationHeader, PHP_URL_SCHEME)) { if (parse_url($locationHeader, PHP_URL_SCHEME)) {
@ -445,12 +446,10 @@ class CurlDownloader
return $targetUrl; return $targetUrl;
} }
$exception = new TransportException('The "'.$job['url'].'" file could not be downloaded, got redirect without Location ('.$response->getStatusMessage().')'); throw new TransportException('The "'.$job['url'].'" file could not be downloaded, got redirect without Location ('.$response->getStatusMessage().')');
$exception->setResponseInfo($responseInfo);
throw $exception;
} }
private function isAuthenticatedRetryNeeded(array $job, Response $response, array $responseInfo) private function isAuthenticatedRetryNeeded(array $job, Response $response)
{ {
if (in_array($response->getStatusCode(), array(401, 403)) && $job['attributes']['retryAuthFailure']) { if (in_array($response->getStatusCode(), array(401, 403)) && $job['attributes']['retryAuthFailure']) {
$result = $this->authHelper->promptAuthIfNeeded($job['url'], $job['origin'], $response->getStatusCode(), $response->getStatusMessage(), $response->getHeaders()); $result = $this->authHelper->promptAuthIfNeeded($job['url'], $job['origin'], $response->getStatusCode(), $response->getStatusMessage(), $response->getHeaders());
@ -491,7 +490,7 @@ class CurlDownloader
} }
} }
throw $this->failResponse($job, $response, $needsAuthRetry, $responseInfo); throw $this->failResponse($job, $response, $needsAuthRetry);
} }
return array('retry' => false, 'storeAuth' => false); return array('retry' => false, 'storeAuth' => false);
@ -509,7 +508,7 @@ class CurlDownloader
$this->initDownload($job['resolve'], $job['reject'], $origin, $url, $job['options'], $job['filename'], $attributes); $this->initDownload($job['resolve'], $job['reject'], $origin, $url, $job['options'], $job['filename'], $attributes);
} }
private function failResponse(array $job, Response $response, $errorMessage, array $responseInfo) private function failResponse(array $job, Response $response, $errorMessage)
{ {
if ($job['filename']) { if ($job['filename']) {
@unlink($job['filename'].'~'); @unlink($job['filename'].'~');
@ -520,11 +519,7 @@ class CurlDownloader
$details = ':'.PHP_EOL.substr($response->getBody(), 0, 200).(strlen($response->getBody()) > 200 ? '...' : ''); $details = ':'.PHP_EOL.substr($response->getBody(), 0, 200).(strlen($response->getBody()) > 200 ? '...' : '');
} }
$exception = new TransportException('The "'.$job['url'].'" file could not be downloaded ('.$errorMessage.')' . $details, $response->getStatusCode()); return new TransportException('The "'.$job['url'].'" file could not be downloaded ('.$errorMessage.')' . $details, $response->getStatusCode());
$exception->setResponseInfo($responseInfo);
$exception->setHeaders($response->getHeaders());
$exception->setResponse($response->getBody());
return $exception;
} }
private function checkCurlResult($code) private function checkCurlResult($code)