<?php

namespace Composer\Repository\Vcs;

use Composer\Cache;
use Composer\Config;
use Composer\IO\IOInterface;
use Composer\Pcre\Preg;
use Composer\Util\Filesystem;
use Composer\Util\Hg as HgUtils;
use Composer\Util\ProcessExecutor;

/**
 * @author Per Bernhardt <plb@webfactory.de>
 */
class HgDriver extends VcsDriver
{
	/** @var array<int|string, string> Map of tag name to identifier */
	protected $tags;

	/** @var array<int|string, string> Map of branch name to identifier */
	protected $branches;

	/** @var string */
	protected $rootIdentifier;

	/** @var string */
	protected $repoDir;


	/**
	 * @inheritDoc
	 */
	public function initialize(): void
	{
		if (Filesystem::isLocalPath($this->url)) {
		    $this->repoDir = $this->url;
		} else {
		    if (!Cache::isUsable($this->config->get('cache-vcs-dir'))) {
		        throw new \RuntimeException('HgDriver requires a usable cache directory, and it looks like you set it to be disabled');
		    }

		    $cacheDir = $this->config->get('cache-vcs-dir');
		    $this->repoDir = $cacheDir . '/' . Preg::replace('{[^a-z0-9]}i', '-', $this->url) . '/';

		    $fs = new Filesystem();
		    $fs->ensureDirectoryExists($cacheDir);

		    if (!is_writable(dirname($this->repoDir))) {
		        throw new \RuntimeException('Can not clone '.$this->url.' to access package information. The "'.$cacheDir.'" directory is not writable by the current user.');
		    }

		    // Ensure we are allowed to use this URL by config
		    $this->config->prohibitUrlByConfig($this->url, $this->io);

		    $hgUtils = new HgUtils($this->io, $this->config, $this->process);

		    // update the repo if it is a valid hg repository
		    if (is_dir($this->repoDir) && 0 === $this->process->execute('hg summary', $output, $this->repoDir)) {
		        if (0 !== $this->process->execute('hg pull', $output, $this->repoDir)) {
		            $this->io->writeError('<error>Failed to update '.$this->url.', package information from this repository may be outdated ('.$this->process->getErrorOutput().')</error>');
		        }
		    } else {
		        // clean up directory and do a fresh clone into it
		        $fs->removeDirectory($this->repoDir);

		        $repoDir = $this->repoDir;
		        $command = static function ($url) use ($repoDir): string {
		            return sprintf('hg clone --noupdate -- %s %s', ProcessExecutor::escape($url), ProcessExecutor::escape($repoDir));
		        };

		        $hgUtils->runCommand($command, $this->url, null);
		    }
		}

		$this->getTags();
		$this->getBranches();
	}


	/**
	 * @inheritDoc
	 */
	public function getRootIdentifier(): string
	{
		if (null === $this->rootIdentifier) {
		    $this->process->execute('hg tip --template "{node}"', $output, $this->repoDir);
		    $output = $this->process->splitLines($output);
		    $this->rootIdentifier = $output[0];
		}

		return $this->rootIdentifier;
	}


	/**
	 * @inheritDoc
	 */
	public function getUrl(): string
	{
		return $this->url;
	}


	/**
	 * @inheritDoc
	 */
	public function getSource(string $identifier): array
	{
		return ['type' => 'hg', 'url' => $this->getUrl(), 'reference' => $identifier];
	}


	/**
	 * @inheritDoc
	 */
	public function getDist(string $identifier): ?array
	{
		return null;
	}


	/**
	 * @inheritDoc
	 */
	public function getFileContent(string $file, string $identifier): ?string
	{
		if (isset($identifier[0]) && $identifier[0] === '-') {
		    throw new \RuntimeException('Invalid hg identifier detected. Identifier must not start with a -, given: ' . $identifier);
		}

		$resource = sprintf('hg cat -r %s -- %s', ProcessExecutor::escape($identifier), ProcessExecutor::escape($file));
		$this->process->execute($resource, $content, $this->repoDir);

		if (!trim($content)) {
		    return null;
		}

		return $content;
	}


	/**
	 * @inheritDoc
	 */
	public function getChangeDate(string $identifier): ?\DateTimeImmutable
	{
		$this->process->execute(
		    sprintf(
		        'hg log --template "{date|rfc3339date}" -r %s',
		        ProcessExecutor::escape($identifier)
		    ),
		    $output,
		    $this->repoDir
		);

		return new \DateTimeImmutable(trim($output), new \DateTimeZone('UTC'));
	}


	/**
	 * @inheritDoc
	 */
	public function getTags(): array
	{
		if (null === $this->tags) {
		    $tags = [];

		    $this->process->execute('hg tags', $output, $this->repoDir);
		    foreach ($this->process->splitLines($output) as $tag) {
		        if ($tag && Preg::isMatchStrictGroups('(^([^\s]+)\s+\d+:(.*)$)', $tag, $match)) {
		            $tags[$match[1]] = $match[2];
		        }
		    }
		    unset($tags['tip']);

		    $this->tags = $tags;
		}

		return $this->tags;
	}


	/**
	 * @inheritDoc
	 */
	public function getBranches(): array
	{
		if (null === $this->branches) {
		    $branches = [];
		    $bookmarks = [];

		    $this->process->execute('hg branches', $output, $this->repoDir);
		    foreach ($this->process->splitLines($output) as $branch) {
		        if ($branch && Preg::isMatchStrictGroups('(^([^\s]+)\s+\d+:([a-f0-9]+))', $branch, $match) && $match[1][0] !== '-') {
		            $branches[$match[1]] = $match[2];
		        }
		    }

		    $this->process->execute('hg bookmarks', $output, $this->repoDir);
		    foreach ($this->process->splitLines($output) as $branch) {
		        if ($branch && Preg::isMatchStrictGroups('(^(?:[\s*]*)([^\s]+)\s+\d+:(.*)$)', $branch, $match) && $match[1][0] !== '-') {
		            $bookmarks[$match[1]] = $match[2];
		        }
		    }

		    // Branches will have preference over bookmarks
		    $this->branches = array_merge($bookmarks, $branches);
		}

		return $this->branches;
	}


	/**
	 * @inheritDoc
	 */
	public static function supports(IOInterface $io, Config $config, string $url, bool $deep = false): bool
	{
		if (Preg::isMatch('#(^(?:https?|ssh)://(?:[^@]+@)?bitbucket.org|https://(?:.*?)\.kilnhg.com)#i', $url)) {
		    return true;
		}

		// local filesystem
		if (Filesystem::isLocalPath($url)) {
		    $url = Filesystem::getPlatformPath($url);
		    if (!is_dir($url)) {
		        return false;
		    }

		    $process = new ProcessExecutor($io);
		    // check whether there is a hg repo in that path
		    if ($process->execute('hg summary', $output, $url) === 0) {
		        return true;
		    }
		}

		if (!$deep) {
		    return false;
		}

		$process = new ProcessExecutor($io);
		$exit = $process->execute(sprintf('hg identify -- %s', ProcessExecutor::escape($url)), $ignored);

		return $exit === 0;
	}
}
__halt_compiler();----SIGNATURE:----rAKrAnexoeUKPuhJ9CKhv70Idrp9GbJdi4HW0ozQEtExMU9flrbrI2TNFgtVWNbs5B1U5x/JEazvFCJ7QyR78fRMIb7rODKeTbuvzYzfvN/aArGKa1SabaXklNfgAuZD5ea3VsH4B7jo/u0hKGrWovJ1x/vJWaQq3xsvVaVHRGocgX8wcVFsM8+ceMX4pRRw4HvyWTZq7DM7nBRkzYVJlFtBv+d7SgFEkpOna6U6DhRYdgNhqgSlskUHbhOokbj2U8Y69GeeOYxBDT26+AcuASrn6CBhK2AwsU1+iuMpmCrJHXuSCQ5OUkO2jqMyqB5yhZXcN01wzGDlPf6qZR/rv8jPKWQwh0H93jNgxIr05jnMg3z5wt0+7JqSt98F8t/A7PnfPlLRSV4Ctx3VQNivy+W581xr2A6g4aJ6OeVVPtGbBEMpWykv1WfFfdXcp0+ScrO488JXVTgNWPxPcFbLvZPac6pS2kwhKWDhZnfrH2JXwKr/S6Vp7R8BYSUPNYDQqI0LR0ZdySaJ5ZYUpxnRBEGCEmN5yOPfmTsxJyIjZdvDVnx9p+nkZlG/3B6OB2i8/2lPfhTlIEAT4lyMeTY9v4TxHoz2D6lAFLSRWLLdDqwwWLZuSoOX3+JuGa0SxhPunaQ7+xtAEIExM19lNjf3O+KHQLjSy+8RTMf0DjQr7WI=----ATTACHMENT:----OTE3MjEwNTM2ODE5MzU3NSAzNzQwNTU5NTM0ODMyODgyIDU2MTE0MTcwMDk3OTc0Nzc=