DiffusionRepositoryController.php
5f26dd9b6660stable

DiffusionRepositoryController.php
View Options

			<?php

			final class DiffusionRepositoryController extends DiffusionController {

			private $historyFuture;
			private $browseFuture;
			private $tagFuture;
			private $branchFuture;

			public function shouldAllowPublic() {
			return true;
			}

			public function handleRequest(AphrontRequest $request) {
			$response = $this->loadDiffusionContext();
			if ($response) {
			return $response;
			}

			$viewer = $this->getViewer();
			$drequest = $this->getDiffusionRequest();
			$repository = $drequest->getRepository();

			$crumbs = $this->buildCrumbs();
			$crumbs->setBorder(true);

			$header = $this->buildHeaderView($repository);
			$curtain = $this->buildCurtain($repository);
			$property_table = $this->buildPropertiesTable($repository);
			$description = $this->buildDescriptionView($repository);
			$locate_file = $this->buildLocateFile();

			// Before we do any work, make sure we're looking at a some content: we're
			// on a valid branch, and the repository is not empty.
			$page_has_content = false;
			$empty_title = null;
			$empty_message = null;

			// If this VCS supports branches, check that the selected branch actually
			// exists.
			if ($drequest->supportsBranches()) {
			// NOTE: Mercurial may have multiple branch heads with the same name.
			$ref_cursors = id(new PhabricatorRepositoryRefCursorQuery())
			->setViewer($viewer)
			->withRepositoryPHIDs(array($repository->getPHID()))
			->withRefTypes(array(PhabricatorRepositoryRefCursor::TYPE_BRANCH))
			->withRefNames(array($drequest->getBranch()))
			->execute();
			if ($ref_cursors) {
			// This is a valid branch, so we necessarily have some content.
			$page_has_content = true;
			} else {
			$empty_title = pht('No Such Branch');
			$empty_message = pht(
			'There is no branch named "%s" in this repository.',
			$drequest->getBranch());
			}
			}

			// If we didn't find any branches, check if there are any commits at all.
			// This can tailor the message for empty repositories.
			if (!$page_has_content) {
			$any_commit = id(new DiffusionCommitQuery())
			->setViewer($viewer)
			->withRepository($repository)
			->setLimit(1)
			->execute();
			if ($any_commit) {
			if (!$drequest->supportsBranches()) {
			$page_has_content = true;
			}
			} else {
			$empty_title = pht('Empty Repository');
			$empty_message = pht('This repository does not have any commits yet.');
			}
			}

			if ($page_has_content) {
			$content = $this->buildNormalContent($drequest);
			} else {
			$content = id(new PHUIInfoView())
			->setTitle($empty_title)
			->setSeverity(PHUIInfoView::SEVERITY_WARNING)
			->setErrors(array($empty_message));
			}

			$view = id(new PHUITwoColumnView())
			->setHeader($header)
			->setCurtain($curtain)
			->setMainColumn(array(
			$property_table,
			$description,
			$locate_file,
			))
			->setFooter($content);

			return $this->newPage()
			->setTitle(
			array(
			$repository->getName(),
			$repository->getDisplayName(),
			))
			->setCrumbs($crumbs)
			->appendChild(array(
			$view,
			));
			}


			private function buildNormalContent(DiffusionRequest $drequest) {
			$request = $this->getRequest();
			$repository = $drequest->getRepository();

			$commit = $drequest->getCommit();
			$path = $drequest->getPath();

			$this->historyFuture = $this->callConduitMethod(
			'diffusion.historyquery',
			array(
			'commit' => $commit,
			'path' => $path,
			'offset' => 0,
			'limit' => 15,
			));

			$browse_pager = id(new PHUIPagerView())
			->readFromRequest($request);

			$this->browseFuture = $this->callConduitMethod(
			'diffusion.browsequery',
			array(
			'commit' => $commit,
			'path' => $path,
			'limit' => $browse_pager->getPageSize() + 1,
			));

			if ($this->needTagFuture()) {
			$tag_limit = $this->getTagLimit();
			$this->tagFuture = $this->callConduitMethod(
			'diffusion.tagsquery',
			array(
			// On the home page, we want to find tags on any branch.
			'commit' => null,
			'limit' => $tag_limit + 1,
			));
			}

			if ($this->needBranchFuture()) {
			$branch_limit = $this->getBranchLimit();
			$this->branchFuture = $this->callConduitMethod(
			'diffusion.branchquery',
			array(
			'closed' => false,
			'limit' => $branch_limit + 1,
			));
			}

			$futures = array(
			$this->historyFuture,
			$this->browseFuture,
			$this->tagFuture,
			$this->branchFuture,
			);
			$futures = array_filter($futures);
			$futures = new FutureIterator($futures);
			foreach ($futures as $future) {
			// Just resolve all the futures before continuing.
			}

			$phids = array();
			$content = array();

			try {
			$history_results = $this->historyFuture->resolve();
			$history = DiffusionPathChange::newFromConduit(
			$history_results['pathChanges']);

			foreach ($history as $item) {
			$data = $item->getCommitData();
			if ($data) {
			if ($data->getCommitDetail('authorPHID')) {
			$phids[$data->getCommitDetail('authorPHID')] = true;
			}
			if ($data->getCommitDetail('committerPHID')) {
			$phids[$data->getCommitDetail('committerPHID')] = true;
			}
			}
			}
			$history_exception = null;
			} catch (Exception $ex) {
			$history_results = null;
			$history = null;
			$history_exception = $ex;
			}

			try {
			$browse_results = $this->browseFuture->resolve();
			$browse_results = DiffusionBrowseResultSet::newFromConduit(
			$browse_results);

			$browse_paths = $browse_results->getPaths();
			$browse_paths = $browse_pager->sliceResults($browse_paths);

			foreach ($browse_paths as $item) {
			$data = $item->getLastCommitData();
			if ($data) {
			if ($data->getCommitDetail('authorPHID')) {
			$phids[$data->getCommitDetail('authorPHID')] = true;
			}
			if ($data->getCommitDetail('committerPHID')) {
			$phids[$data->getCommitDetail('committerPHID')] = true;
			}
			}
			}

			$browse_exception = null;
			} catch (Exception $ex) {
			$browse_results = null;
			$browse_paths = null;
			$browse_exception = $ex;
			}

			$phids = array_keys($phids);
			$handles = $this->loadViewerHandles($phids);

			if ($browse_results) {
			$readme = $this->renderDirectoryReadme($browse_results);
			} else {
			$readme = null;
			}

			$content[] = $this->buildBrowseTable(
			$browse_results,
			$browse_paths,
			$browse_exception,
			$handles,
			$browse_pager);

			$content[] = $this->buildHistoryTable(
			$history_results,
			$history,
			$history_exception);

			try {
			$content[] = $this->buildTagListTable($drequest);
			} catch (Exception $ex) {
			if (!$repository->isImporting()) {
			$content[] = $this->renderStatusMessage(
			pht('Unable to Load Tags'),
			$ex->getMessage());
			}
			}

			try {
			$content[] = $this->buildBranchListTable($drequest);
			} catch (Exception $ex) {
			if (!$repository->isImporting()) {
			$content[] = $this->renderStatusMessage(
			pht('Unable to Load Branches'),
			$ex->getMessage());
			}
			}

			if ($readme) {
			$content[] = $readme;
			}

			return $content;
			}

			private function buildHeaderView(PhabricatorRepository $repository) {
			$viewer = $this->getViewer();
			$header = id(new PHUIHeaderView())
			->setHeader($repository->getName())
			->setUser($viewer)
			->setPolicyObject($repository)
			->setHeaderIcon('fa-code');

			if (!$repository->isTracked()) {
			$header->setStatus('fa-ban', 'dark', pht('Inactive'));
			} else if ($repository->isImporting()) {
			$ratio = $repository->loadImportProgress();
			$percentage = sprintf('%.2f%%', 100 * $ratio);
			$header->setStatus(
			'fa-clock-o',
			'indigo',
			pht('Importing (%s)...', $percentage));
			} else {
			$header->setStatus('fa-check', 'bluegrey', pht('Active'));
			}

			return $header;
			}

			private function buildCurtain(PhabricatorRepository $repository) {
			$viewer = $this->getViewer();

			$edit_uri = $repository->getPathURI('manage/');
			$curtain = $this->newCurtainView($repository);

			$curtain->addAction(
			id(new PhabricatorActionView())
			->setName(pht('Manage Repository'))
			->setIcon('fa-cogs')
			->setHref($edit_uri));

			if ($repository->isHosted()) {
			$push_uri = $this->getApplicationURI(
			'pushlog/?repositories='.$repository->getMonogram());

			$curtain->addAction(
			id(new PhabricatorActionView())
			->setName(pht('View Push Logs'))
			->setIcon('fa-list-alt')
			->setHref($push_uri));
			}

			return $curtain;
			}

			private function buildDescriptionView(PhabricatorRepository $repository) {
			$viewer = $this->getViewer();
			$view = id(new PHUIPropertyListView())
			->setUser($viewer);

			$description = $repository->getDetail('description');
			if (strlen($description)) {
			$description = new PHUIRemarkupView($viewer, $description);
			$view->addTextContent($description);
			return id(new PHUIObjectBoxView())
			->setHeaderText(pht('Description'))
			->setBackground(PHUIObjectBoxView::BLUE_PROPERTY)
			->appendChild($view);
			}
			return null;
			}

			private function buildPropertiesTable(PhabricatorRepository $repository) {
			$viewer = $this->getViewer();

			$view = id(new PHUIPropertyListView())
			->setUser($viewer);

			$display_never = PhabricatorRepositoryURI::DISPLAY_NEVER;

			$uris = $repository->getURIs();
			foreach ($uris as $uri) {
			if ($uri->getIsDisabled()) {
			continue;
			}

			if ($uri->getEffectiveDisplayType() == $display_never) {
			continue;
			}

			if ($repository->isSVN()) {
			$label = pht('Checkout');
			} else {
			$label = pht('Clone');
			}

			$view->addProperty(
			$label,
			$this->renderCloneURI($repository, $uri));
			}

			$box = id(new PHUIObjectBoxView())
			->setHeaderText(pht('Details'))
			->setBackground(PHUIObjectBoxView::BLUE_PROPERTY)
			->appendChild($view);

			$info = null;
			$drequest = $this->getDiffusionRequest();

			// Try to load alternatives. This may fail for repositories which have not
			// cloned yet. If it does, just ignore it and continue.
			try {
			$alternatives = $drequest->getRefAlternatives();
			} catch (ConduitClientException $ex) {
			$alternatives = array();
			}

			if ($alternatives) {
			$message = array(
			pht(
			'The ref "%s" is ambiguous in this repository.',
			$drequest->getBranch()),
			' ',
			phutil_tag(
			'a',
			array(
			'href' => $drequest->generateURI(
			array(
			'action' => 'refs',
			)),
			),
			pht('View Alternatives')),
			);

			$messages = array($message);

			$info = id(new PHUIInfoView())
			->setSeverity(PHUIInfoView::SEVERITY_WARNING)
			->setErrors(array($message));

			$box->setInfoView($info);
			}


			return $box;
			}

			private function buildBranchListTable(DiffusionRequest $drequest) {
			$viewer = $this->getViewer();

			if (!$this->needBranchFuture()) {
			return null;
			}

			$branches = $this->branchFuture->resolve();
			if (!$branches) {
			return null;
			}

			$limit = $this->getBranchLimit();
			$more_branches = (count($branches) > $limit);
			$branches = array_slice($branches, 0, $limit);

			$branches = DiffusionRepositoryRef::loadAllFromDictionaries($branches);

			$commits = id(new DiffusionCommitQuery())
			->setViewer($viewer)
			->withIdentifiers(mpull($branches, 'getCommitIdentifier'))
			->withRepository($drequest->getRepository())
			->execute();

			$table = id(new DiffusionBranchTableView())
			->setUser($viewer)
			->setDiffusionRequest($drequest)
			->setBranches($branches)
			->setCommits($commits);

			$panel = id(new PHUIObjectBoxView())
			->setBackground(PHUIObjectBoxView::BLUE_PROPERTY);
			$header = new PHUIHeaderView();
			$header->setHeader(pht('Branches'));

			if ($more_branches) {
			$header->setSubHeader(pht('Showing %d branches.', $limit));
			}

			$button = new PHUIButtonView();
			$button->setText(pht('Show All'));
			$button->setTag('a');
			$button->setIcon('fa-code-fork');
			$button->setHref($drequest->generateURI(
			array(
			'action' => 'branches',
			)));

			$header->addActionLink($button);
			$panel->setHeader($header);
			$panel->setTable($table);

			return $panel;
			}

			private function buildTagListTable(DiffusionRequest $drequest) {
			$viewer = $this->getViewer();
			$repository = $drequest->getRepository();

			if (!$this->needTagFuture()) {
			return null;
			}

			$tags = $this->tagFuture->resolve();
			$tags = DiffusionRepositoryTag::newFromConduit($tags);
			if (!$tags) {
			return null;
			}

			$tag_limit = $this->getTagLimit();
			$more_tags = (count($tags) > $tag_limit);
			$tags = array_slice($tags, 0, $tag_limit);

			$commits = id(new DiffusionCommitQuery())
			->setViewer($viewer)
			->withIdentifiers(mpull($tags, 'getCommitIdentifier'))
			->withRepository($repository)
			->needCommitData(true)
			->execute();

			$view = id(new DiffusionTagListView())
			->setUser($viewer)
			->setDiffusionRequest($drequest)
			->setTags($tags)
			->setCommits($commits);

			$phids = $view->getRequiredHandlePHIDs();
			$handles = $this->loadViewerHandles($phids);
			$view->setHandles($handles);

			$panel = new PHUIObjectBoxView();
			$header = new PHUIHeaderView();
			$header->setHeader(pht('Tags'));

			if ($more_tags) {
			$header->setSubHeader(
			pht('Showing the %d most recent tags.', $tag_limit));
			}

			$button = new PHUIButtonView();
			$button->setText(pht('Show All Tags'));
			$button->setTag('a');
			$button->setIcon('fa-tag');
			$button->setHref($drequest->generateURI(
			array(
			'action' => 'tags',
			)));

			$header->addActionLink($button);

			$panel->setHeader($header);
			$panel->setTable($view);
			$panel->setBackground(PHUIObjectBoxView::BLUE_PROPERTY);

			return $panel;
			}

			private function buildHistoryTable(
			$history_results,
			$history,
			$history_exception) {

			$request = $this->getRequest();
			$viewer = $request->getUser();
			$drequest = $this->getDiffusionRequest();
			$repository = $drequest->getRepository();

			if ($history_exception) {
			if ($repository->isImporting()) {
			return $this->renderStatusMessage(
			pht('Still Importing...'),
			pht(
			'This repository is still importing. History is not yet '.
			'available.'));
			} else {
			return $this->renderStatusMessage(
			pht('Unable to Retrieve History'),
			$history_exception->getMessage());
			}
			}

			$history_table = id(new DiffusionHistoryTableView())
			->setUser($viewer)
			->setDiffusionRequest($drequest)
			->setHistory($history);

			// TODO: Super sketchy.
			$history_table->loadRevisions();

			if ($history_results) {
			$history_table->setParents($history_results['parents']);
			}

			$history_table->setIsHead(true);

			$icon = id(new PHUIIconView())
			->setIcon('fa-list-alt');

			$button = id(new PHUIButtonView())
			->setText(pht('View History'))
			->setHref($drequest->generateURI(
			array(
			'action' => 'history',
			)))
			->setTag('a')
			->setIcon($icon);

			$panel = id(new PHUIObjectBoxView())
			->setBackground(PHUIObjectBoxView::BLUE_PROPERTY);
			$header = id(new PHUIHeaderView())
			->setHeader(pht('Recent Commits'))
			->addActionLink($button);
			$panel->setHeader($header);
			$panel->setTable($history_table);

			return $panel;
			}

			private function buildLocateFile() {
			$request = $this->getRequest();
			$viewer = $request->getUser();
			$drequest = $this->getDiffusionRequest();
			$repository = $drequest->getRepository();

			$locate_panel = null;
			if ($repository->canUsePathTree()) {
			Javelin::initBehavior(
			'diffusion-locate-file',
			array(
			'controlID' => 'locate-control',
			'inputID' => 'locate-input',
			'browseBaseURI' => (string)$drequest->generateURI(
			array(
			'action' => 'browse',
			)),
			'uri' => (string)$drequest->generateURI(
			array(
			'action' => 'pathtree',
			)),
			));

			$form = id(new AphrontFormView())
			->setUser($viewer)
			->appendChild(
			id(new AphrontFormTypeaheadControl())
			->setHardpointID('locate-control')
			->setID('locate-input')
			->setLabel(pht('Locate File')));
			$form_box = id(new PHUIBoxView())
			->appendChild($form->buildLayoutView());
			$locate_panel = id(new PHUIObjectBoxView())
			->setHeaderText(pht('Locate File'))
			->setBackground(PHUIObjectBoxView::BLUE_PROPERTY)
			->appendChild($form_box);
			}
			return $locate_panel;
			}

			private function buildBrowseTable(
			$browse_results,
			$browse_paths,
			$browse_exception,
			array $handles,
			PHUIPagerView $pager) {

			require_celerity_resource('diffusion-icons-css');

			$request = $this->getRequest();
			$viewer = $request->getUser();
			$drequest = $this->getDiffusionRequest();
			$repository = $drequest->getRepository();

			if ($browse_exception) {
			if ($repository->isImporting()) {
			// The history table renders a useful message.
			return null;
			} else {
			return $this->renderStatusMessage(
			pht('Unable to Retrieve Paths'),
			$browse_exception->getMessage());
			}
			}

			$browse_table = id(new DiffusionBrowseTableView())
			->setUser($viewer)
			->setDiffusionRequest($drequest)
			->setHandles($handles);
			if ($browse_paths) {
			$browse_table->setPaths($browse_paths);
			} else {
			$browse_table->setPaths(array());
			}

			$browse_uri = $drequest->generateURI(array('action' => 'browse'));

			$browse_panel = id(new PHUIObjectBoxView())
			->setBackground(PHUIObjectBoxView::BLUE_PROPERTY);
			$header = id(new PHUIHeaderView())
			->setHeader($repository->getName());

			$icon = id(new PHUIIconView())
			->setIcon('fa-folder-open');

			$button = new PHUIButtonView();
			$button->setText(pht('Browse Repository'));
			$button->setTag('a');
			$button->setIcon($icon);
			$button->setHref($browse_uri);

			$header->addActionLink($button);
			$browse_panel->setHeader($header);
			$browse_panel->setTable($browse_table);

			$pager->setURI($browse_uri, 'offset');

			if ($pager->willShowPagingControls()) {
			$pager_box = $this->renderTablePagerBox($pager);
			} else {
			$pager_box = null;
			}

			return array(
			$browse_panel,
			$pager_box,
			);
			}

			private function renderCloneURI(
			PhabricatorRepository $repository,
			PhabricatorRepositoryURI $uri) {

			if ($repository->isSVN()) {
			$display = csprintf(
			'svn checkout %R %R',
			(string)$uri->getDisplayURI(),
			$repository->getCloneName());
			} else {
			$display = csprintf('%R', (string)$uri->getDisplayURI());
			}

			$display = (string)$display;
			$viewer = $this->getViewer();

			return id(new DiffusionCloneURIView())
			->setViewer($viewer)
			->setRepository($repository)
			->setRepositoryURI($uri)
			->setDisplayURI($display);
			}

			private function needTagFuture() {
			$drequest = $this->getDiffusionRequest();
			$repository = $drequest->getRepository();

			switch ($repository->getVersionControlSystem()) {
			case PhabricatorRepositoryType::REPOSITORY_TYPE_SVN:
			// No tags in SVN.
			return false;
			}

			return true;
			}

			private function getTagLimit() {
			return 15;
			}

			private function needBranchFuture() {
			$drequest = $this->getDiffusionRequest();

			if ($drequest->getBranch() === null) {
			return false;
			}

			return true;
			}

			private function getBranchLimit() {
			return 15;
			}

			}

phab/src/applications/diffusion/controller/DiffusionRepositoryController.php5f26dd9b6660stable

DiffusionRepositoryController.phpView Options

phab/src/applications/diffusion/controller/DiffusionRepositoryController.php
5f26dd9b6660stable

DiffusionRepositoryController.php
View Options