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

Add support for provider listings

pull/1168/head
Jordi Boggiano 2012-10-14 16:33:53 +02:00
parent a3f9accd37
commit 07f72e9fb6
2 changed files with 53 additions and 17 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
src/Composer/Cache.php
View File

@ -65,4 +65,12 @@ class Cache
return sha1_file($this->root . $file); return sha1_file($this->root . $file);
} }
} }
public function sha256($file)
{
$file = preg_replace('{[^a-z0-9.]}i', '-', $file);
if ($this->enabled && file_exists($this->root . $file)) {
return hash_file('sha256', $this->root . $file);
}
}
} }

62
src/Composer/Repository/ComposerRepository.php
View File

@ -32,10 +32,12 @@ class ComposerRepository extends ArrayRepository implements NotifiableRepository
protected $config; protected $config;
protected $options; protected $options;
protected $url; protected $url;
protected $baseUrl;
protected $io; protected $io;
protected $cache; protected $cache;
protected $notifyUrl; protected $notifyUrl;
protected $providersUrl; protected $hasProviders = false;
protected $providerListing;
protected $providers = array(); protected $providers = array();
protected $providersByUid = array(); protected $providersByUid = array();
protected $loader; protected $loader;
@ -67,6 +69,7 @@ class ComposerRepository extends ArrayRepository implements NotifiableRepository
$this->config = $config; $this->config = $config;
$this->options = $repoConfig['options']; $this->options = $repoConfig['options'];
$this->url = $repoConfig['url']; $this->url = $repoConfig['url'];
$this->baseUrl = rtrim(preg_replace('{^(.*)(?:/packages.json)?(?:[?#].*)?$}', '$1', $this->url), '/');
$this->io = $io; $this->io = $io;
$this->cache = new Cache($io, $config->get('home').'/cache/'.preg_replace('{[^a-z0-9.]}i', '-', $this->url)); $this->cache = new Cache($io, $config->get('home').'/cache/'.preg_replace('{[^a-z0-9.]}i', '-', $this->url));
$this->loader = new ArrayLoader(); $this->loader = new ArrayLoader();
@ -193,11 +196,12 @@ class ComposerRepository extends ArrayRepository implements NotifiableRepository
{ {
$this->loadRootServerFile(); $this->loadRootServerFile();
return null !== $this->providersUrl; return $this->hasProviders;
} }
public function whatProvides(Pool $pool, $name) public function whatProvides(Pool $pool, $name)
{ {
// skip platform packages
if ($name === 'php' || in_array(substr($name, 0, 4), array('ext-', 'lib-'), true) || $name === '__root__') { if ($name === 'php' || in_array(substr($name, 0, 4), array('ext-', 'lib-'), true) || $name === '__root__') {
return array(); return array();
} }
@ -206,15 +210,21 @@ class ComposerRepository extends ArrayRepository implements NotifiableRepository
return $this->providers[$name]; return $this->providers[$name];
} }
$url = str_replace('%package%', strtolower($name), $this->providersUrl); if (null === $this->providerListing) {
$this->loadProviderListings($this->loadRootServerFile());
}
try { $url = 'p/'.$name.'.json';
$json = new JsonFile($url, new RemoteFilesystem($this->io));
$packages = $json->read(); // package does not exist in this repo
} catch (\RuntimeException $e) { if (!isset($this->providerListing[$url])) {
if (!$e->getPrevious() instanceof TransportException || $e->getPrevious()->getCode() !== 404) { return array();
throw $e; }
}
if ($this->cache->sha256($url) === $this->providerListing[$url]['sha256']) {
$packages = json_decode($this->cache->read($url), true);
} else {
$packages = $this->fetchFile($url);
} }
$this->providers[$name] = array(); $this->providers[$name] = array();
@ -301,12 +311,8 @@ class ComposerRepository extends ArrayRepository implements NotifiableRepository
} }
} }
if (!empty($data['providers'])) { if (!empty($data['providers']) || !empty($data['providers-includes'])) {
if ('/' === $data['providers'][0]) { $this->hasProviders = true;
$this->providersUrl = preg_replace('{(https?://[^/]+).*}i', '$1' . $data['providers'], $this->url);
} else {
$this->providersUrl = $data['providers'];
}
} }
return $this->rootData = $data; return $this->rootData = $data;
@ -319,6 +325,28 @@ class ComposerRepository extends ArrayRepository implements NotifiableRepository
return $this->loadIncludes($data); return $this->loadIncludes($data);
} }
protected function loadProviderListings($data)
{
if (isset($data['providers'])) {
if (!is_array($this->providerListing)) {
$this->providerListing = array();
}
$this->providerListing = array_merge($this->providerListing, $data['providers']);
}
if (isset($data['providers-includes'])) {
foreach ($data['providers-includes'] as $include => $metadata) {
if ($this->cache->sha256($include) === $metadata['sha256']) {
$includedData = json_decode($this->cache->read($include), true);
} else {
$includedData = $this->fetchFile($include);
}
$this->loadProviderListings($includedData);
}
}
}
protected function loadIncludes($data) protected function loadIncludes($data)
{ {
$packages = array(); $packages = array();
@ -369,7 +397,7 @@ class ComposerRepository extends ArrayRepository implements NotifiableRepository
{ {
if (!$cacheKey) { if (!$cacheKey) {
$cacheKey = $filename; $cacheKey = $filename;
$filename = $this->url.'/'.$filename; $filename = $this->baseUrl.'/'.$filename;
} }
$retries = 3; $retries = 3;