Hg.php

<?php

declare (strict_types=1);

/*
 * This file is part of Composer.
 *
 * (c) Nils Adermann <naderman@naderman.de>
 *     Jordi Boggiano <j.boggiano@seld.be>
 *
 * For the full copyright and license information, please view the LICENSE
 * file that was distributed with this source code.
 */
namespace Composer\Util;

use Composer\Config;
use Composer\IO\IOInterface;
use Composer\Pcre\Preg;

/**
 * @author Jonas Renaudot <jonas.renaudot@gmail.com>
 */
class Hg {
    
    /** @var string|false|null */
    private static $version = false;
    
    /**
     * @var \Composer\IO\IOInterface
     */
    private $io;
    
    /**
     * @var \Composer\Config
     */
    private $config;
    
    /**
     * @var \Composer\Util\ProcessExecutor
     */
    private $process;
    public function __construct(IOInterface $io, Config $config, ProcessExecutor $process) {
        $this->io = $io;
        $this->config = $config;
        $this->process = $process;
    }
    public function runCommand(callable $commandCallable, string $url, ?string $cwd) : void {
        $this->config
            ->prohibitUrlByConfig($url, $this->io);
        // Try as is
        $command = $commandCallable($url);
        if (0 === $this->process
            ->execute($command, $ignoredOutput, $cwd)) {
            return;
        }
        // Try with the authentication information available
        if (Preg::isMatch('{^(?P<proto>ssh|https?)://(?:(?P<user>[^:@]+)(?::(?P<pass>[^:@]+))?@)?(?P<host>[^/]+)(?P<path>/.*)?}mi', $url, $matches) && $this->io
            ->hasAuthentication($matches['host'])) {
            if ($matches['proto'] === 'ssh') {
                $user = '';
                if ($matches['user'] !== null) {
                    $user = rawurlencode($matches['user']) . '@';
                }
                $authenticatedUrl = $matches['proto'] . '://' . $user . $matches['host'] . $matches['path'];
            }
            else {
                $auth = $this->io
                    ->getAuthentication($matches['host']);
                $authenticatedUrl = $matches['proto'] . '://' . rawurlencode((string) $auth['username']) . ':' . rawurlencode((string) $auth['password']) . '@' . $matches['host'] . $matches['path'];
            }
            $command = $commandCallable($authenticatedUrl);
            if (0 === $this->process
                ->execute($command, $ignoredOutput, $cwd)) {
                return;
            }
            $error = $this->process
                ->getErrorOutput();
        }
        else {
            $error = 'The given URL (' . $url . ') does not match the required format (ssh|http(s)://(username:password@)example.com/path-to-repository)';
        }
        $this->throwException("Failed to clone {$url}, \n\n" . $error, $url);
    }
    
    /**
     * @param non-empty-string $message
     *
     * @return never
     */
    private function throwException($message, string $url) : void {
        if (null === self::getVersion($this->process)) {
            throw new \RuntimeException(Url::sanitize('Failed to clone ' . $url . ', hg was not found, check that it is installed and in your PATH env.' . "\n\n" . $this->process
                ->getErrorOutput()));
        }
        throw new \RuntimeException(Url::sanitize($message));
    }
    
    /**
     * Retrieves the current hg version.
     *
     * @return string|null The hg version number, if present.
     */
    public static function getVersion(ProcessExecutor $process) : ?string {
        if (false === self::$version) {
            self::$version = null;
            if (0 === $process->execute([
                'hg',
                '--version',
            ], $output) && Preg::isMatch('/^.+? (\\d+(?:\\.\\d+)+)(?:\\+.*?)?\\)?\\r?\\n/', $output, $matches)) {
                self::$version = $matches[1];
            }
        }
        return self::$version;
    }

}