@ -19,32 +19,19 @@ use Composer\Util\RemoteFilesystem;
use Composer\Downloader\FilesystemException;
use Composer\Downloader\FilesystemException;
use Symfony\Component\Console\Input\InputInterface;
use Symfony\Component\Console\Input\InputInterface;
use Symfony\Component\Console\Input\InputOption;
use Symfony\Component\Console\Input\InputOption;
use Symfony\Component\Console\Input\InputArgument;
use Symfony\Component\Console\Output\OutputInterface;
use Symfony\Component\Console\Output\OutputInterface;
/**
/**
* @author Igor Wiedler < igor @ wiedler . ch >
* @author Igor Wiedler < igor @ wiedler . ch >
* @author Kevin Ran < kran @ adobe . com >
* @author Jordi Boggiano < j.boggiano @ seld . be >
*/
*/
class SelfUpdateCommand extends Command
class SelfUpdateCommand extends Command
{
{
const ROLLBACK = 'rollback';
const CLEAN_ROLLBACKS = 'clean-rollbacks';
const HOMEPAGE = 'getcomposer.org';
const HOMEPAGE = 'getcomposer.org';
const OLD_INSTALL_EXT = '-old.phar';
const OLD_INSTALL_EXT = '-old.phar';
protected $remoteFS;
protected $latestVersion;
protected $homepageURL;
protected $localFilename;
public function __construct($name = null)
{
parent::__construct($name);
$protocol = (extension_loaded('openssl') ? 'https' : 'http') . '://';
$this->homepageURL = $protocol . self::HOMEPAGE;
$this->remoteFS = new RemoteFilesystem($this->getIO());
$this->localFilename = realpath($_SERVER['argv'][0]) ?: $_SERVER['argv'][0];
}
protected function configure()
protected function configure()
{
{
$this
$this
@ -52,8 +39,9 @@ class SelfUpdateCommand extends Command
->setAliases(array('selfupdate'))
->setAliases(array('selfupdate'))
->setDescription('Updates composer.phar to the latest version.')
->setDescription('Updates composer.phar to the latest version.')
->setDefinition(array(
->setDefinition(array(
new InputOption(self::ROLLBACK, 'r', InputOption::VALUE_NONE, 'Revert to an older installation of composer'),
new InputOption('rollback', 'r', InputOption::VALUE_NONE, 'Revert to an older installation of composer'),
new InputOption(self::CLEAN_ROLLBACKS, null, InputOption::VALUE_NONE, 'Delete old snapshots during an update. This makes the current version of composer the only rollback snapshot after the update')
new InputOption('clean-backups', null, InputOption::VALUE_NONE, 'Delete old backups during an update. This makes the current version of composer the only backup available after the update'),
new InputArgument('version', InputArgument::OPTIONAL, 'The version to update to'),
))
))
->setHelp(< < < EOT
->setHelp(< < < EOT
The < info > self-update< / info > command checks getcomposer.org for newer
The < info > self-update< / info > command checks getcomposer.org for newer
@ -68,71 +56,55 @@ EOT
protected function execute(InputInterface $input, OutputInterface $output)
protected function execute(InputInterface $input, OutputInterface $output)
{
{
$baseUrl = (extension_loaded('openssl') ? 'https' : 'http') . '://' . self::HOMEPAGE;
$remoteFilesystem = new RemoteFilesystem($this->getIO());
$config = Factory::createConfig();
$config = Factory::createConfig();
$cacheDir = rtrim($config->get('cache-dir'), '/');
$cacheDir = $config->get('cache-dir');
$rollbackDir = $config->get('home');
$localFilename = realpath($_SERVER['argv'][0]) ?: $_SERVER['argv'][0];
// Check if current dir is writable and if not try the cache dir from settings
// c heck if current dir is writable and if not try the cache dir from settings
$tmpDir = is_writable(dirname($this-> localFilename))? dirname($this-> localFilename) : $cacheDir;
$tmpDir = is_writable(dirname($localFilename)) ? dirname($localFilename) : $cacheDir;
// check for permissions in local filesystem before start connection process
// check for permissions in local filesystem before start connection process
if (!is_writable($tmpDir)) {
if (!is_writable($tmpDir)) {
throw new FilesystemException('Composer update failed: the "'.$tmpDir.'" directory used to download the temp file could not be written');
throw new FilesystemException('Composer update failed: the "'.$tmpDir.'" directory used to download the temp file could not be written');
}
}
if (!is_writable($localFilename)) {
if (!is_writable($this->localFilename)) {
throw new FilesystemException('Composer update failed: the "'.$localFilename.'" file could not be written');
throw new FilesystemException('Composer update failed: the "'.$this->localFilename.'" file could not be written');
}
}
$rollbackVersion = false;
if ($input->getOption('rollback')) {
$rollbackDir = rtrim($config->get('home'), '/');
return $this->rollback($output, $rollbackDir, $localFilename);
// rollback specified, get last phar
if ($input->getOption(self::ROLLBACK)) {
$rollbackVersion = $this->getLastVersion($rollbackDir);
if (!$rollbackVersion) {
throw new FilesystemException('Composer rollback failed: no installation to roll back to in "'.$rollbackDir.'"');
}
}
}
// if a rollback version is specified, check for permissions and rollback installation
$latestVersion = trim($remoteFilesystem->getContents(self::HOMEPAGE, $baseUrl. '/version', false));
if ($rollbackVersion) {
$updateVersion = $input->getArgument('version') ?: $latestVersion;
if (!is_writable($rollbackDir)) {
throw new FilesystemException('Composer rollback failed: the "'.$rollbackDir.'" dir could not be written to');
}
$old = $rollbackDir . '/' . $rollbackVersion . self::OLD_INSTALL_EXT;
if (preg_match('{^[0-9a-f]{40}$}', $updateVersion) & & $updateVersion !== $latestVersion) {
$output->writeln('< error > You can not update to a specific SHA-1 as those phars are not available for download< / error > ');
if (!is_file($old)) {
return 1;
throw new FilesystemException('Composer rollback failed: "'.$old.'" could not be found');
}
if (!is_readable($old)) {
throw new FilesystemException('Composer rollback failed: "'.$old.'" could not be read');
}
}
}
$updateVersion = ($rollbackVersion)? $rollbackVersion : $this->getLatestVersion();
if (Composer::VERSION === $updateVersion) {
if (Composer::VERSION === $updateVersion) {
$output->writeln('< info > You are already using composer version '.$updateVersion.'.< / info > ');
$output->writeln('< info > You are already using composer version '.$updateVersion.'.< / info > ');
return 0;
return 0;
}
}
$tempFilename = $tmpDir . '/' . basename($this->localFilename, '.phar').'-temp.phar';
$tempFilename = $tmpDir . '/' . basename($localFilename, '.phar').'-temp.phar';
$backupFile = ($rollbackVersion)? false : $rollbackDir . '/' . Composer::VERSION . self::OLD_INSTALL_EXT;
$backupFile = sprintf(
'%s/%s-%s%s',
if ($rollbackVersion) {
$rollbackDir,
rename($rollbackDir . "/{$rollbackVersion}" . self::OLD_INSTALL_EXT, $tempFilename);
strtr(Composer::RELEASE_DATE, ' :', '_-'),
$output->writeln(sprintf("Rolling back to cached version < info > %s< / info > .", $rollbackVersion));
preg_replace('{^([0-9a-f]{7})[0-9a-f]{33}$}', '$1', Composer::VERSION),
} else {
self::OLD_INSTALL_EXT
$endpoint = ($updateVersion === $this->getLatestVersion()) ? '/composer.phar' : "/download/{$updateVersion}/composer.phar";
);
$remoteFilename = $this->homepageURL . $endpoint;
$output->writeln(sprintf("Updating to version < info > %s< / info > .", $updateVersion));
$output->writeln(sprintf("Updating to version < info > %s< / info > .", $updateVersion));
$remoteFilename = $baseUrl . (preg_match('{^[0-9a-f]{40}$}', $updateVersion) ? '/composer.phar' : "/download/{$updateVersion}/composer.phar");
$this->remoteFS->copy(self::HOMEPAGE, $remoteFilename, $tempFilename);
$remoteFilesystem->copy(self::HOMEPAGE, $remoteFilename, $tempFilename);
// @todo: handle snapshot versions not being found!
if (!file_exists($tempFilename)) {
if (!file_exists($tempFilename)) {
$output->writeln('< error > The download of the new composer version failed for an unexpected reason');
$output->writeln('< error > The download of the new composer version failed for an unexpected reason');
@ -140,7 +112,7 @@ EOT
}
}
// remove saved installations of composer
// remove saved installations of composer
if ($input->getOption(self::CLEAN_ROLLBACKS )) {
if ($input->getOption('clean-backups' )) {
$files = $this->getOldInstallationFiles($rollbackDir);
$files = $this->getOldInstallationFiles($rollbackDir);
if (!empty($files)) {
if (!empty($files)) {
@ -152,38 +124,72 @@ EOT
}
}
}
}
}
}
}
if ($err = $this->setLocalPhar($tempFilename, $backupFile)) {
if ($err = $this->setLocalPhar($localFilename, $ tempFilename, $backupFile)) {
$output->writeln('< error > The file is corrupted ('.$err->getMessage().').< / error > ');
$output->writeln('< error > The file is corrupted ('.$err->getMessage().').< / error > ');
$output->writeln('< error > Please re-run the self-update command to try again.< / error > ');
$output->writeln('< error > Please re-run the self-update command to try again.< / error > ');
return 1;
return 1;
}
}
if ($backupFile) {
if (file_exists($backupFile)) {
$output->writeln('< info > Saved rollback snapshot '.$backupFile);
$output->writeln('Use < info > composer self-update --rollback< / info > to return to version '.Composer::VERSION);
} else {
$output->writeln('< warning > A backup of the current version could not be written to '.$backupFile.', no rollback possible< / warning > ');
}
}
protected function rollback(OutputInterface $output, $rollbackDir, $localFilename)
{
$rollbackVersion = $this->getLastBackupVersion($rollbackDir);
if (!$rollbackVersion) {
throw new \UnexpectedValueException('Composer rollback failed: no installation to roll back to in "'.$rollbackDir.'"');
}
}
if (!is_writable($rollbackDir)) {
throw new FilesystemException('Composer rollback failed: the "'.$rollbackDir.'" dir could not be written to');
}
}
protected function setLocalPhar($filename, $backupFile)
$old = $rollbackDir . '/' . $rollbackVersion . self::OLD_INSTALL_EXT;
if (!is_file($old)) {
throw new FilesystemException('Composer rollback failed: "'.$old.'" could not be found');
}
if (!is_readable($old)) {
throw new FilesystemException('Composer rollback failed: "'.$old.'" could not be read');
}
$oldFile = $rollbackDir . "/{$rollbackVersion}" . self::OLD_INSTALL_EXT;
$output->writeln(sprintf("Rolling back to version < info > %s< / info > .", $rollbackVersion));
if ($err = $this->setLocalPhar($localFilename, $oldFile)) {
$output->writeln('< error > The backup file was corrupted ('.$err->getMessage().') and has been removed.< / error > ');
return 1;
}
return 0;
}
protected function setLocalPhar($localFilename, $newFilename, $backupTarget = null)
{
{
try {
try {
@chmod($filename, 0777 & ~umask());
@chmod($newF ilename, 0777 & ~umask());
// test the phar validity
// test the phar validity
$phar = new \Phar($filename);
$phar = new \Phar($newF ilename);
// free the variable to unlock the file
// free the variable to unlock the file
unset($phar);
unset($phar);
// copy current file into installations dir
// copy current file into installations dir
if ($backupFile) {
if ($backupTarget & & file_exists($local Filename) ) {
copy($this->localFilename, $backupFile);
@copy($localFilename, $backupTarget );
}
}
unset($phar);
unset($phar);
rename($filename, $this->localFilename);
rename($newFilename, $ localFilename);
} catch (\Exception $e) {
} catch (\Exception $e) {
@unlink($filename);
if ($backupTarget) {
@unlink($newFilename);
}
if (!$e instanceof \UnexpectedValueException & & !$e instanceof \PharException) {
if (!$e instanceof \UnexpectedValueException & & !$e instanceof \PharException) {
throw $e;
throw $e;
}
}
@ -192,31 +198,20 @@ EOT
}
}
}
}
protected function getLastVersion($rollbackDir)
protected function getLastBackup Version($rollbackDir)
{
{
$files = $this->getOldInstallationFiles($rollbackDir);
$files = $this->getOldInstallationFiles($rollbackDir);
if (empty($files)) {
if (empty($files)) {
return false;
return false;
}
}
$fileTimes = array_map('filemtime', $files);
sort($files);
$map = array_combine($fileTimes, $files);
$latest = max($fileTimes);
return basename($map[$latest], self::OLD_INSTALL_EXT);
}
protected function getOldInstallationFiles($rollbackDir)
return basename(end($files), self::OLD_INSTALL_EXT);
{
return glob($rollbackDir . '/*' . self::OLD_INSTALL_EXT);
}
}
protected function getLatestVersion( )
protected function getOldInstallationFiles($rollbackDir )
{
{
if (!$this->latestVersion) {
return glob($rollbackDir . '/*' . self::OLD_INSTALL_EXT) ?: array();
$this->latestVersion = trim($this->remoteFS->getContents(self::HOMEPAGE, $this->homepageURL. '/version', false));
}
return $this->latestVersion;
}
}
}
}