Diffusion Phabricator (feature/better-testing) Browse

better-testing

PhabricatorRepositoryURI.php
View Options

			<?php

			final class PhabricatorRepositoryURI
			extends PhabricatorRepositoryDAO
			implements
			PhabricatorApplicationTransactionInterface,
			PhabricatorPolicyInterface,
			PhabricatorExtendedPolicyInterface {

			protected $repositoryPHID;
			protected $uri;
			protected $builtinProtocol;
			protected $builtinIdentifier;
			protected $credentialPHID;
			protected $ioType;
			protected $displayType;
			protected $isDisabled;

			private $repository = self::ATTACHABLE;

			const BUILTIN_PROTOCOL_SSH = 'ssh';
			const BUILTIN_PROTOCOL_HTTP = 'http';
			const BUILTIN_PROTOCOL_HTTPS = 'https';

			const BUILTIN_IDENTIFIER_ID = 'id';
			const BUILTIN_IDENTIFIER_SHORTNAME = 'shortname';
			const BUILTIN_IDENTIFIER_CALLSIGN = 'callsign';

			const DISPLAY_DEFAULT = 'default';
			const DISPLAY_NEVER = 'never';
			const DISPLAY_ALWAYS = 'always';

			const IO_DEFAULT = 'default';
			const IO_OBSERVE = 'observe';
			const IO_MIRROR = 'mirror';
			const IO_NONE = 'none';
			const IO_READ = 'read';
			const IO_READWRITE = 'readwrite';

			protected function getConfiguration() {
			return array(
			self::CONFIG_AUX_PHID => true,
			self::CONFIG_COLUMN_SCHEMA => array(
			'uri' => 'text255',
			'builtinProtocol' => 'text32?',
			'builtinIdentifier' => 'text32?',
			'credentialPHID' => 'phid?',
			'ioType' => 'text32',
			'displayType' => 'text32',
			'isDisabled' => 'bool',
			),
			self::CONFIG_KEY_SCHEMA => array(
			'key_builtin' => array(
			'columns' => array(
			'repositoryPHID',
			'builtinProtocol',
			'builtinIdentifier',
			),
			'unique' => true,
			),
			),
			) + parent::getConfiguration();
			}

			public static function initializeNewURI(PhabricatorRepository $repository) {
			return id(new self())
			->attachRepository($repository)
			->setRepositoryPHID($repository->getPHID())
			->setIoType(self::IO_DEFAULT)
			->setDisplayType(self::DISPLAY_DEFAULT)
			->setIsDisabled(0);
			}

			public function generatePHID() {
			return PhabricatorPHID::generateNewPHID(
			PhabricatorRepositoryURIPHIDType::TYPECONST);
			}

			public function attachRepository(PhabricatorRepository $repository) {
			$this->repository = $repository;
			return $this;
			}

			public function getRepository() {
			return $this->assertAttached($this->repository);
			}

			public function getRepositoryURIBuiltinKey() {
			if (!$this->getBuiltinProtocol()) {
			return null;
			}

			$parts = array(
			$this->getBuiltinProtocol(),
			$this->getBuiltinIdentifier(),
			);

			return implode('.', $parts);
			}

			public function isBuiltin() {
			return (bool)$this->getBuiltinProtocol();
			}

			public function getEffectiveDisplayType() {
			$display = $this->getDisplayType();

			if ($display != self::DISPLAY_DEFAULT) {
			return $display;
			}

			return $this->getDefaultDisplayType();
			}

			public function getDefaultDisplayType() {
			switch ($this->getEffectiveIOType()) {
			case self::IO_MIRROR:
			case self::IO_OBSERVE:
			case self::IO_NONE:
			return self::DISPLAY_NEVER;
			case self::IO_READ:
			case self::IO_READWRITE:
			// By default, only show the "best" version of the builtin URI, not the
			// other redundant versions.
			$repository = $this->getRepository();
			$other_uris = $repository->getURIs();

			$identifier_value = array(
			self::BUILTIN_IDENTIFIER_CALLSIGN => 3,
			self::BUILTIN_IDENTIFIER_SHORTNAME => 2,
			self::BUILTIN_IDENTIFIER_ID => 1,
			);

			$have_identifiers = array();
			foreach ($other_uris as $other_uri) {
			if ($other_uri->getIsDisabled()) {
			continue;
			}

			$identifier = $other_uri->getBuiltinIdentifier();
			if (!$identifier) {
			continue;
			}

			$have_identifiers[$identifier] = $identifier_value[$identifier];
			}

			$best_identifier = max($have_identifiers);
			$this_identifier = $identifier_value[$this->getBuiltinIdentifier()];

			if ($this_identifier < $best_identifier) {
			return self::DISPLAY_NEVER;
			}

			return self::DISPLAY_ALWAYS;
			}

			return self::DISPLAY_NEVER;
			}


			public function getEffectiveIOType() {
			$io = $this->getIoType();

			if ($io != self::IO_DEFAULT) {
			return $io;
			}

			return $this->getDefaultIOType();
			}

			public function getDefaultIOType() {
			if ($this->isBuiltin()) {
			$repository = $this->getRepository();
			$other_uris = $repository->getURIs();

			$any_observe = false;
			foreach ($other_uris as $other_uri) {
			if ($other_uri->getIoType() == self::IO_OBSERVE) {
			$any_observe = true;
			break;
			}
			}

			if ($any_observe) {
			return self::IO_READ;
			} else {
			return self::IO_READWRITE;
			}
			}

			return self::IO_NONE;
			}


			public function getDisplayURI() {
			$uri = new PhutilURI($this->getURI());

			$protocol = $this->getForcedProtocol();
			if ($protocol) {
			$uri->setProtocol($protocol);
			}

			$user = $this->getForcedUser();
			if ($user) {
			$uri->setUser($user);
			}

			$host = $this->getForcedHost();
			if ($host) {
			$uri->setDomain($host);
			}

			$port = $this->getForcedPort();
			if ($port) {
			$uri->setPort($port);
			}

			$path = $this->getForcedPath();
			if ($path) {
			$uri->setPath($path);
			}

			return $uri;
			}

			private function getForcedProtocol() {
			switch ($this->getBuiltinProtocol()) {
			case self::BUILTIN_PROTOCOL_SSH:
			return 'ssh';
			case self::BUILTIN_PROTOCOL_HTTP:
			return 'http';
			case self::BUILTIN_PROTOCOL_HTTPS:
			return 'https';
			default:
			return null;
			}
			}

			private function getForcedUser() {
			switch ($this->getBuiltinProtocol()) {
			case self::BUILTIN_PROTOCOL_SSH:
			return AlmanacKeys::getClusterSSHUser();
			default:
			return null;
			}
			}

			private function getForcedHost() {
			$phabricator_uri = PhabricatorEnv::getURI('/');
			$phabricator_uri = new PhutilURI($phabricator_uri);

			$phabricator_host = $phabricator_uri->getDomain();

			switch ($this->getBuiltinProtocol()) {
			case self::BUILTIN_PROTOCOL_SSH:
			$ssh_host = PhabricatorEnv::getEnvConfig('diffusion.ssh-host');
			if ($ssh_host !== null) {
			return $ssh_host;
			}
			return $phabricator_host;
			case self::BUILTIN_PROTOCOL_HTTP:
			case self::BUILTIN_PROTOCOL_HTTPS:
			return $phabricator_host;
			default:
			return null;
			}
			}

			private function getForcedPort() {
			switch ($this->getBuiltinProtocol()) {
			case self::BUILTIN_PROTOCOL_SSH:
			return PhabricatorEnv::getEnvConfig('diffusion.ssh-port');
			case self::BUILTIN_PROTOCOL_HTTP:
			case self::BUILTIN_PROTOCOL_HTTPS:
			default:
			return null;
			}
			}

			private function getForcedPath() {
			if (!$this->isBuiltin()) {
			return null;
			}

			$repository = $this->getRepository();

			$id = $repository->getID();
			$callsign = $repository->getCallsign();
			$short_name = $repository->getRepositorySlug();

			$clone_name = $repository->getCloneName();

			if ($repository->isGit()) {
			$suffix = '.git';
			} else if ($repository->isHg()) {
			$suffix = '/';
			} else {
			$suffix = '';
			}

			switch ($this->getBuiltinIdentifier()) {
			case self::BUILTIN_IDENTIFIER_ID:
			return "/diffusion/{$id}/{$clone_name}{$suffix}";
			case self::BUILTIN_IDENTIFIER_SHORTNAME:
			return "/source/{$short_name}{$suffix}";
			case self::BUILTIN_IDENTIFIER_CALLSIGN:
			return "/diffusion/{$callsign}/{$clone_name}{$suffix}";
			default:
			return null;
			}
			}

			public function getViewURI() {
			$id = $this->getID();
			return $this->getRepository()->getPathURI("uri/view/{$id}/");
			}

			public function getEditURI() {
			$id = $this->getID();
			return $this->getRepository()->getPathURI("uri/edit/{$id}/");
			}

			public function getAvailableIOTypeOptions() {
			$options = array(
			self::IO_DEFAULT,
			self::IO_NONE,
			);

			if ($this->isBuiltin()) {
			$options[] = self::IO_READ;
			$options[] = self::IO_WRITE;
			} else {
			$options[] = self::IO_OBSERVE;
			$options[] = self::IO_MIRROR;
			}

			$map = array();
			$io_map = self::getIOTypeMap();
			foreach ($options as $option) {
			$spec = idx($io_map, $option, array());

			$label = idx($spec, 'label', $option);
			$short = idx($spec, 'short');

			$name = pht('%s: %s', $label, $short);
			$map[$option] = $name;
			}

			return $map;
			}

			public function getAvailableDisplayTypeOptions() {
			$options = array(
			self::DISPLAY_DEFAULT,
			self::DISPLAY_ALWAYS,
			self::DISPLAY_NEVER,
			);

			$map = array();
			$display_map = self::getDisplayTypeMap();
			foreach ($options as $option) {
			$spec = idx($display_map, $option, array());

			$label = idx($spec, 'label', $option);
			$short = idx($spec, 'short');

			$name = pht('%s: %s', $label, $short);
			$map[$option] = $name;
			}

			return $map;
			}

			public static function getIOTypeMap() {
			return array(
			self::IO_DEFAULT => array(
			'label' => pht('Default'),
			'short' => pht('Use default behavior.'),
			),
			self::IO_OBSERVE => array(
			'icon' => 'fa-download',
			'color' => 'green',
			'label' => pht('Observe'),
			'note' => pht(
			'Phabricator will observe changes to this URI and copy them.'),
			'short' => pht('Copy from a remote.'),
			),
			self::IO_MIRROR => array(
			'icon' => 'fa-upload',
			'color' => 'green',
			'label' => pht('Mirror'),
			'note' => pht(
			'Phabricator will push a copy of any changes to this URI.'),
			'short' => pht('Push a copy to a remote.'),
			),
			self::IO_NONE => array(
			'icon' => 'fa-times',
			'color' => 'grey',
			'label' => pht('No I/O'),
			'note' => pht(
			'Phabricator will not push or pull any changes to this URI.'),
			'short' => pht('Do not perform any I/O.'),
			),
			self::IO_READ => array(
			'icon' => 'fa-folder',
			'color' => 'blue',
			'label' => pht('Read Only'),
			'note' => pht(
			'Phabricator will serve a read-only copy of the repository from '.
			'this URI.'),
			'short' => pht('Serve repository in read-only mode.'),
			),
			self::IO_READWRITE => array(
			'icon' => 'fa-folder-open',
			'color' => 'blue',
			'label' => pht('Read/Write'),
			'note' => pht(
			'Phabricator will serve a read/write copy of the repository from '.
			'this URI.'),
			'short' => pht('Serve repository in read/write mode.'),
			),
			);
			}

			public static function getDisplayTypeMap() {
			return array(
			self::DISPLAY_DEFAULT => array(
			'label' => pht('Default'),
			'short' => pht('Use default behavior.'),
			),
			self::DISPLAY_ALWAYS => array(
			'icon' => 'fa-eye',
			'color' => 'green',
			'label' => pht('Visible'),
			'note' => pht('This URI will be shown to users as a clone URI.'),
			'short' => pht('Show as a clone URI.'),
			),
			self::DISPLAY_NEVER => array(
			'icon' => 'fa-eye-slash',
			'color' => 'grey',
			'label' => pht('Hidden'),
			'note' => pht(
			'This URI will be hidden from users.'),
			'short' => pht('Do not show as a clone URI.'),
			),
			);
			}


			/* -( PhabricatorApplicationTransactionInterface )------------------------- */


			public function getApplicationTransactionEditor() {
			return new DiffusionURIEditor();
			}

			public function getApplicationTransactionObject() {
			return $this;
			}

			public function getApplicationTransactionTemplate() {
			return new PhabricatorRepositoryURITransaction();
			}

			public function willRenderTimeline(
			PhabricatorApplicationTransactionView $timeline,
			AphrontRequest $request) {
			return $timeline;
			}


			/* -( PhabricatorPolicyInterface )----------------------------------------- */


			public function getCapabilities() {
			return array(
			PhabricatorPolicyCapability::CAN_VIEW,
			PhabricatorPolicyCapability::CAN_EDIT,
			);
			}

			public function getPolicy($capability) {
			switch ($capability) {
			case PhabricatorPolicyCapability::CAN_VIEW:
			case PhabricatorPolicyCapability::CAN_EDIT:
			return PhabricatorPolicies::getMostOpenPolicy();
			}
			}

			public function hasAutomaticCapability($capability, PhabricatorUser $viewer) {
			return false;
			}

			public function describeAutomaticCapability($capability) {
			return null;
			}


			/* -( PhabricatorExtendedPolicyInterface )--------------------------------- */


			public function getExtendedPolicy($capability, PhabricatorUser $viewer) {
			$extended = array();

			switch ($capability) {
			case PhabricatorPolicyCapability::CAN_EDIT:
			// To edit a repository URI, you must be able to edit the
			// corresponding repository.
			$extended[] = array($this->getRepository(), $capability);
			break;
			}

			return $extended;
			}

			}

phab/src/applications/repository/storage/PhabricatorRepositoryURI.php128995f1acd3feature/better-testing

PhabricatorRepositoryURI.phpView Options

phab/src/applications/repository/storage/PhabricatorRepositoryURI.php
128995f1acd3feature/better-testing

PhabricatorRepositoryURI.php
View Options