DifferentialRevisionQuery.php
3ec4984f27cdstable

DifferentialRevisionQuery.php
View Options

			<?php

			/**
			* Flexible query API for Differential revisions. Example:
			*
			* // Load open revisions
			* $revisions = id(new DifferentialRevisionQuery())
			* ->withStatus(DifferentialRevisionQuery::STATUS_OPEN)
			* ->execute();
			*
			* @task config Query Configuration
			* @task exec Query Execution
			* @task internal Internals
			*/
			final class DifferentialRevisionQuery
			extends PhabricatorCursorPagedPolicyAwareQuery {

			private $pathIDs = array();

			private $status = 'status-any';
			const STATUS_ANY = 'status-any';
			const STATUS_OPEN = 'status-open';
			const STATUS_ACCEPTED = 'status-accepted';
			const STATUS_NEEDS_REVIEW = 'status-needs-review';
			const STATUS_CLOSED = 'status-closed'; // NOTE: Same as 'committed'.
			const STATUS_COMMITTED = 'status-committed'; // TODO: Remove.
			const STATUS_ABANDONED = 'status-abandoned';

			private $authors = array();
			private $draftAuthors = array();
			private $ccs = array();
			private $reviewers = array();
			private $revIDs = array();
			private $commitHashes = array();
			private $phids = array();
			private $subscribers = array();
			private $responsibles = array();
			private $branches = array();
			private $arcanistProjectPHIDs = array();
			private $draftRevisions = array();

			private $order = 'order-modified';
			const ORDER_MODIFIED = 'order-modified';
			const ORDER_CREATED = 'order-created';
			/**
			* This is essentially a denormalized copy of the revision modified time that
			* should perform better for path queries with a LIMIT. Critically, when you
			* browse "/", every revision in that repository for all time will match so
			* the query benefits from being able to stop before fully materializing the
			* result set.
			*/
			const ORDER_PATH_MODIFIED = 'order-path-modified';

			private $needRelationships = false;
			private $needActiveDiffs = false;
			private $needDiffIDs = false;
			private $needCommitPHIDs = false;
			private $needHashes = false;

			private $buildingGlobalOrder;


			/* -( Query Configuration )------------------------------------------------ */


			/**
			* Filter results to revisions which affect a Diffusion path ID in a given
			* repository. You can call this multiple times to select revisions for
			* several paths.
			*
			* @param int Diffusion repository ID.
			* @param int Diffusion path ID.
			* @return this
			* @task config
			*/
			public function withPath($repository_id, $path_id) {
			$this->pathIDs[] = array(
			'repositoryID' => $repository_id,
			'pathID' => $path_id,
			);
			return $this;
			}

			/**
			* Filter results to revisions authored by one of the given PHIDs. Calling
			* this function will clear anything set by previous calls to
			* @{method:withAuthors}.
			*
			* @param array List of PHIDs of authors
			* @return this
			* @task config
			*/
			public function withAuthors(array $author_phids) {
			$this->authors = $author_phids;
			return $this;
			}

			/**
			* Filter results to revisions with comments authored bythe given PHIDs
			*
			* @param array List of PHIDs of authors
			* @return this
			* @task config
			*/
			public function withDraftRepliesByAuthors(array $author_phids) {
			$this->draftAuthors = $author_phids;
			return $this;
			}

			/**
			* Filter results to revisions which CC one of the listed people. Calling this
			* function will clear anything set by previous calls to @{method:withCCs}.
			*
			* @param array List of PHIDs of subscribers
			* @return this
			* @task config
			*/
			public function withCCs(array $cc_phids) {
			$this->ccs = $cc_phids;
			return $this;
			}

			/**
			* Filter results to revisions that have one of the provided PHIDs as
			* reviewers. Calling this function will clear anything set by previous calls
			* to @{method:withReviewers}.
			*
			* @param array List of PHIDs of reviewers
			* @return this
			* @task config
			*/
			public function withReviewers(array $reviewer_phids) {
			$this->reviewers = $reviewer_phids;
			return $this;
			}

			/**
			* Filter results to revisions that have one of the provided commit hashes.
			* Calling this function will clear anything set by previous calls to
			* @{method:withCommitHashes}.
			*
			* @param array List of pairs <Class
			* ArcanistDifferentialRevisionHash::HASH_$type constant,
			* hash>
			* @return this
			* @task config
			*/
			public function withCommitHashes(array $commit_hashes) {
			$this->commitHashes = $commit_hashes;
			return $this;
			}

			/**
			* Filter results to revisions with a given status. Provide a class constant,
			* such as ##DifferentialRevisionQuery::STATUS_OPEN##.
			*
			* @param const Class STATUS constant, like STATUS_OPEN.
			* @return this
			* @task config
			*/
			public function withStatus($status_constant) {
			$this->status = $status_constant;
			return $this;
			}


			/**
			* Filter results to revisions on given branches.
			*
			* @param list List of branch names.
			* @return this
			* @task config
			*/
			public function withBranches(array $branches) {
			$this->branches = $branches;
			return $this;
			}


			/**
			* Filter results to only return revisions whose ids are in the given set.
			*
			* @param array List of revision ids
			* @return this
			* @task config
			*/
			public function withIDs(array $ids) {
			$this->revIDs = $ids;
			return $this;
			}


			/**
			* Filter results to only return revisions whose PHIDs are in the given set.
			*
			* @param array List of revision PHIDs
			* @return this
			* @task config
			*/
			public function withPHIDs(array $phids) {
			$this->phids = $phids;
			return $this;
			}


			/**
			* Given a set of users, filter results to return only revisions they are
			* responsible for (i.e., they are either authors or reviewers).
			*
			* @param array List of user PHIDs.
			* @return this
			* @task config
			*/
			public function withResponsibleUsers(array $responsible_phids) {
			$this->responsibles = $responsible_phids;
			return $this;
			}


			/**
			* Filter results to only return revisions with a given set of subscribers
			* (i.e., they are authors, reviewers or CC'd).
			*
			* @param array List of user PHIDs.
			* @return this
			* @task config
			*/
			public function withSubscribers(array $subscriber_phids) {
			$this->subscribers = $subscriber_phids;
			return $this;
			}


			/**
			* Filter results to only return revisions with a given set of arcanist
			* projects.
			*
			* @param array List of project PHIDs.
			* @return this
			* @task config
			*/
			public function withArcanistProjectPHIDs(array $arc_project_phids) {
			$this->arcanistProjectPHIDs = $arc_project_phids;
			return $this;
			}


			/**
			* Set result ordering. Provide a class constant, such as
			* ##DifferentialRevisionQuery::ORDER_CREATED##.
			*
			* @task config
			*/
			public function setOrder($order_constant) {
			$this->order = $order_constant;
			return $this;
			}


			/**
			* Set whether or not the query will load and attach relationships.
			*
			* @param bool True to load and attach relationships.
			* @return this
			* @task config
			*/
			public function needRelationships($need_relationships) {
			$this->needRelationships = $need_relationships;
			return $this;
			}


			/**
			* Set whether or not the query should load the active diff for each
			* revision.
			*
			* @param bool True to load and attach diffs.
			* @return this
			* @task config
			*/
			public function needActiveDiffs($need_active_diffs) {
			$this->needActiveDiffs = $need_active_diffs;
			return $this;
			}


			/**
			* Set whether or not the query should load the associated commit PHIDs for
			* each revision.
			*
			* @param bool True to load and attach diffs.
			* @return this
			* @task config
			*/
			public function needCommitPHIDs($need_commit_phids) {
			$this->needCommitPHIDs = $need_commit_phids;
			return $this;
			}


			/**
			* Set whether or not the query should load associated diff IDs for each
			* revision.
			*
			* @param bool True to load and attach diff IDs.
			* @return this
			* @task config
			*/
			public function needDiffIDs($need_diff_ids) {
			$this->needDiffIDs = $need_diff_ids;
			return $this;
			}


			/**
			* Set whether or not the query should load associated commit hashes for each
			* revision.
			*
			* @param bool True to load and attach commit hashes.
			* @return this
			* @task config
			*/
			public function needHashes($need_hashes) {
			$this->needHashes = $need_hashes;
			return $this;
			}


			/* -( Query Execution )---------------------------------------------------- */


			/**
			* Execute the query as configured, returning matching
			* @{class:DifferentialRevision} objects.
			*
			* @return list List of matching DifferentialRevision objects.
			* @task exec
			*/
			public function loadPage() {
			$table = new DifferentialRevision();
			$conn_r = $table->establishConnection('r');

			$data = $this->loadData();

			return $table->loadAllFromArray($data);
			}

			public function willFilterPage(array $revisions) {
			if (!$revisions) {
			return $revisions;
			}

			$table = new DifferentialRevision();
			$conn_r = $table->establishConnection('r');

			if ($this->needRelationships) {
			$this->loadRelationships($conn_r, $revisions);
			}

			if ($this->needCommitPHIDs) {
			$this->loadCommitPHIDs($conn_r, $revisions);
			}

			$need_active = $this->needActiveDiffs;
			$need_ids = $need_active \|\| $this->needDiffIDs;

			if ($need_ids) {
			$this->loadDiffIDs($conn_r, $revisions);
			}

			if ($need_active) {
			$this->loadActiveDiffs($conn_r, $revisions);
			}

			if ($this->needHashes) {
			$this->loadHashes($conn_r, $revisions);
			}

			return $revisions;
			}

			private function loadData() {
			$table = new DifferentialRevision();
			$conn_r = $table->establishConnection('r');

			if ($this->draftAuthors) {
			$this->draftRevisions = array();

			$draft_key = 'differential-comment-';
			$drafts = id(new PhabricatorDraft())->loadAllWhere(
			'authorPHID IN (%Ls) AND draftKey LIKE %> AND draft != %s',
			$this->draftAuthors,
			$draft_key,
			'');
			$len = strlen($draft_key);
			foreach ($drafts as $draft) {
			$this->draftRevisions[] = substr($draft->getDraftKey(), $len);
			}

			$inlines = id(new DifferentialInlineCommentQuery())
			->withDraftsByAuthors($this->draftAuthors)
			->execute();
			foreach ($inlines as $inline) {
			$this->draftRevisions[] = $inline->getRevisionID();
			}

			if (!$this->draftRevisions) {
			return array();
			}
			}

			$selects = array();

			// NOTE: If the query includes "responsiblePHIDs", we execute it as a
			// UNION of revisions they own and revisions they're reviewing. This has
			// much better performance than doing it with JOIN/WHERE.
			if ($this->responsibles) {
			$basic_authors = $this->authors;
			$basic_reviewers = $this->reviewers;
			try {
			// Build the query where the responsible users are authors.
			$this->authors = array_merge($basic_authors, $this->responsibles);
			$this->reviewers = $basic_reviewers;
			$selects[] = $this->buildSelectStatement($conn_r);

			// Build the query where the responsible users are reviewers.
			$this->authors = $basic_authors;
			$this->reviewers = array_merge($basic_reviewers, $this->responsibles);
			$selects[] = $this->buildSelectStatement($conn_r);

			// Put everything back like it was.
			$this->authors = $basic_authors;
			$this->reviewers = $basic_reviewers;
			} catch (Exception $ex) {
			$this->authors = $basic_authors;
			$this->reviewers = $basic_reviewers;
			throw $ex;
			}
			} else {
			$selects[] = $this->buildSelectStatement($conn_r);
			}

			if (count($selects) > 1) {
			$this->buildingGlobalOrder = true;
			$query = qsprintf(
			$conn_r,
			'%Q %Q %Q',
			implode(' UNION DISTINCT ', $selects),
			$this->buildOrderClause($conn_r),
			$this->buildLimitClause($conn_r));
			} else {
			$query = head($selects);
			}

			return queryfx_all($conn_r, '%Q', $query);
			}

			private function buildSelectStatement(AphrontDatabaseConnection $conn_r) {
			$table = new DifferentialRevision();

			$select = qsprintf(
			$conn_r,
			'SELECT r.* FROM %T r',
			$table->getTableName());

			$joins = $this->buildJoinsClause($conn_r);
			$where = $this->buildWhereClause($conn_r);
			$group_by = $this->buildGroupByClause($conn_r);

			$this->buildingGlobalOrder = false;
			$order_by = $this->buildOrderClause($conn_r);

			$limit = $this->buildLimitClause($conn_r);

			return qsprintf(
			$conn_r,
			'(%Q %Q %Q %Q %Q %Q)',
			$select,
			$joins,
			$where,
			$group_by,
			$order_by,
			$limit);
			}


			/* -( Internals )---------------------------------------------------------- */


			/**
			* @task internal
			*/
			private function buildJoinsClause($conn_r) {
			$joins = array();
			if ($this->pathIDs) {
			$path_table = new DifferentialAffectedPath();
			$joins[] = qsprintf(
			$conn_r,
			'JOIN %T p ON p.revisionID = r.id',
			$path_table->getTableName());
			}

			if ($this->commitHashes) {
			$joins[] = qsprintf(
			$conn_r,
			'JOIN %T hash_rel ON hash_rel.revisionID = r.id',
			ArcanistDifferentialRevisionHash::TABLE_NAME);
			}

			if ($this->ccs) {
			$joins[] = qsprintf(
			$conn_r,
			'JOIN %T cc_rel ON cc_rel.revisionID = r.id '.
			'AND cc_rel.relation = %s '.
			'AND cc_rel.objectPHID in (%Ls)',
			DifferentialRevision::RELATIONSHIP_TABLE,
			DifferentialRevision::RELATION_SUBSCRIBED,
			$this->ccs);
			}

			if ($this->reviewers) {
			$joins[] = qsprintf(
			$conn_r,
			'JOIN %T reviewer_rel ON reviewer_rel.revisionID = r.id '.
			'AND reviewer_rel.relation = %s '.
			'AND reviewer_rel.objectPHID in (%Ls)',
			DifferentialRevision::RELATIONSHIP_TABLE,
			DifferentialRevision::RELATION_REVIEWER,
			$this->reviewers);
			}

			if ($this->subscribers) {
			$joins[] = qsprintf(
			$conn_r,
			'JOIN %T sub_rel ON sub_rel.revisionID = r.id '.
			'AND sub_rel.relation IN (%Ls) '.
			'AND sub_rel.objectPHID in (%Ls)',
			DifferentialRevision::RELATIONSHIP_TABLE,
			array(
			DifferentialRevision::RELATION_SUBSCRIBED,
			DifferentialRevision::RELATION_REVIEWER,
			),
			$this->subscribers);
			}

			$joins = implode(' ', $joins);

			return $joins;
			}


			/**
			* @task internal
			*/
			private function buildWhereClause($conn_r) {
			$where = array();

			if ($this->pathIDs) {
			$path_clauses = array();
			$repo_info = igroup($this->pathIDs, 'repositoryID');
			foreach ($repo_info as $repository_id => $paths) {
			$path_clauses[] = qsprintf(
			$conn_r,
			'(p.repositoryID = %d AND p.pathID IN (%Ld))',
			$repository_id,
			ipull($paths, 'pathID'));
			}
			$path_clauses = '('.implode(' OR ', $path_clauses).')';
			$where[] = $path_clauses;
			}

			if ($this->authors) {
			$where[] = qsprintf(
			$conn_r,
			'r.authorPHID IN (%Ls)',
			$this->authors);
			}

			if ($this->draftRevisions) {
			$where[] = qsprintf(
			$conn_r,
			'r.id IN (%Ld)',
			$this->draftRevisions);
			}

			if ($this->revIDs) {
			$where[] = qsprintf(
			$conn_r,
			'r.id IN (%Ld)',
			$this->revIDs);
			}

			if ($this->commitHashes) {
			$hash_clauses = array();
			foreach ($this->commitHashes as $info) {
			list($type, $hash) = $info;
			$hash_clauses[] = qsprintf(
			$conn_r,
			'(hash_rel.type = %s AND hash_rel.hash = %s)',
			$type,
			$hash);
			}
			$hash_clauses = '('.implode(' OR ', $hash_clauses).')';
			$where[] = $hash_clauses;
			}

			if ($this->phids) {
			$where[] = qsprintf(
			$conn_r,
			'r.phid IN (%Ls)',
			$this->phids);
			}

			if ($this->branches) {
			$where[] = qsprintf(
			$conn_r,
			'r.branchName in (%Ls)',
			$this->branches);
			}

			if ($this->arcanistProjectPHIDs) {
			$where[] = qsprintf(
			$conn_r,
			'r.arcanistProjectPHID in (%Ls)',
			$this->arcanistProjectPHIDs);
			}

			switch ($this->status) {
			case self::STATUS_ANY:
			break;
			case self::STATUS_OPEN:
			$where[] = qsprintf(
			$conn_r,
			'r.status IN (%Ld)',
			array(
			ArcanistDifferentialRevisionStatus::NEEDS_REVIEW,
			ArcanistDifferentialRevisionStatus::NEEDS_REVISION,
			ArcanistDifferentialRevisionStatus::ACCEPTED,
			));
			break;
			case self::STATUS_NEEDS_REVIEW:
			$where[] = qsprintf(
			$conn_r,
			'r.status IN (%Ld)',
			array(
			ArcanistDifferentialRevisionStatus::NEEDS_REVIEW,
			));
			break;
			case self::STATUS_ACCEPTED:
			$where[] = qsprintf(
			$conn_r,
			'r.status IN (%Ld)',
			array(
			ArcanistDifferentialRevisionStatus::ACCEPTED,
			));
			break;
			case self::STATUS_COMMITTED:
			phlog(
			"WARNING: DifferentialRevisionQuery using deprecated ".
			"STATUS_COMMITTED constant. This will be removed soon. ".
			"Use STATUS_CLOSED.");
			// fallthrough
			case self::STATUS_CLOSED:
			$where[] = qsprintf(
			$conn_r,
			'r.status IN (%Ld)',
			array(
			ArcanistDifferentialRevisionStatus::CLOSED,
			));
			break;
			case self::STATUS_ABANDONED:
			$where[] = qsprintf(
			$conn_r,
			'r.status IN (%Ld)',
			array(
			ArcanistDifferentialRevisionStatus::ABANDONED,
			));
			break;
			default:
			throw new Exception(
			"Unknown revision status filter constant '{$this->status}'!");
			}

			$where[] = $this->buildPagingClause($conn_r);
			return $this->formatWhereClause($where);
			}


			/**
			* @task internal
			*/
			private function buildGroupByClause($conn_r) {
			$join_triggers = array_merge(
			$this->pathIDs,
			$this->ccs,
			$this->reviewers,
			$this->subscribers);

			$needs_distinct = (count($join_triggers) > 1);

			if ($needs_distinct) {
			return 'GROUP BY r.id';
			} else {
			return '';
			}
			}

			private function loadCursorObject($id) {
			$results = id(new DifferentialRevisionQuery())
			->setViewer($this->getViewer())
			->withIDs(array($id))
			->execute();
			return head($results);
			}

			protected function buildPagingClause(AphrontDatabaseConnection $conn_r) {
			$default = parent::buildPagingClause($conn_r);

			$before_id = $this->getBeforeID();
			$after_id = $this->getAfterID();

			if (!$before_id && !$after_id) {
			return $default;
			}

			if ($before_id) {
			$cursor = $this->loadCursorObject($before_id);
			} else {
			$cursor = $this->loadCursorObject($after_id);
			}

			if (!$cursor) {
			return null;
			}

			switch ($this->order) {
			case self::ORDER_CREATED:
			return $default;
			case self::ORDER_MODIFIED:
			if ($before_id) {
			return qsprintf(
			$conn_r,
			'(r.dateModified %Q %d OR (r.dateModified = %d AND r.id %Q %d))',
			$this->getReversePaging() ? '<' : '>',
			$cursor->getDateModified(),
			$cursor->getDateModified(),
			$this->getReversePaging() ? '<' : '>',
			$cursor->getID());
			} else {
			return qsprintf(
			$conn_r,
			'(r.dateModified %Q %d OR (r.dateModified = %d AND r.id %Q %d))',
			$this->getReversePaging() ? '>' : '<',
			$cursor->getDateModified(),
			$cursor->getDateModified(),
			$this->getReversePaging() ? '>' : '<',
			$cursor->getID());
			}
			case self::ORDER_PATH_MODIFIED:
			if ($before_id) {
			return qsprintf(
			$conn_r,
			'(p.epoch %Q %d OR (p.epoch = %d AND r.id %Q %d))',
			$this->getReversePaging() ? '<' : '>',
			$cursor->getDateCreated(),
			$cursor->getDateCreated(),
			$this->getReversePaging() ? '<' : '>',
			$cursor->getID());
			} else {
			return qsprintf(
			$conn_r,
			'(p.epoch %Q %d OR (p.epoch = %d AND r.id %Q %d))',
			$this->getReversePaging() ? '>' : '<',
			$cursor->getDateCreated(),
			$cursor->getDateCreated(),
			$this->getReversePaging() ? '>' : '<',
			$cursor->getID());
			}
			}
			}

			protected function getPagingColumn() {
			$is_global = $this->buildingGlobalOrder;
			switch ($this->order) {
			case self::ORDER_MODIFIED:
			if ($is_global) {
			return 'dateModified';
			}
			return 'r.dateModified';
			case self::ORDER_CREATED:
			if ($is_global) {
			return 'id';
			}
			return 'r.id';
			case self::ORDER_PATH_MODIFIED:
			if (!$this->pathIDs) {
			throw new Exception(
			"To use ORDER_PATH_MODIFIED, you must specify withPath().");
			}
			return 'p.epoch';
			default:
			throw new Exception("Unknown query order constant '{$this->order}'.");
			}
			}

			private function loadRelationships($conn_r, array $revisions) {
			assert_instances_of($revisions, 'DifferentialRevision');
			$relationships = queryfx_all(
			$conn_r,
			'SELECT * FROM %T WHERE revisionID in (%Ld) ORDER BY sequence',
			DifferentialRevision::RELATIONSHIP_TABLE,
			mpull($revisions, 'getID'));
			$relationships = igroup($relationships, 'revisionID');
			foreach ($revisions as $revision) {
			$revision->attachRelationships(
			idx(
			$relationships,
			$revision->getID(),
			array()));
			}
			}

			private function loadCommitPHIDs($conn_r, array $revisions) {
			assert_instances_of($revisions, 'DifferentialRevision');
			$commit_phids = queryfx_all(
			$conn_r,
			'SELECT * FROM %T WHERE revisionID IN (%Ld)',
			DifferentialRevision::TABLE_COMMIT,
			mpull($revisions, 'getID'));
			$commit_phids = igroup($commit_phids, 'revisionID');
			foreach ($revisions as $revision) {
			$phids = idx($commit_phids, $revision->getID(), array());
			$phids = ipull($phids, 'commitPHID');
			$revision->attachCommitPHIDs($phids);
			}
			}

			private function loadDiffIDs($conn_r, array $revisions) {
			assert_instances_of($revisions, 'DifferentialRevision');

			$diff_table = new DifferentialDiff();

			$diff_ids = queryfx_all(
			$conn_r,
			'SELECT revisionID, id FROM %T WHERE revisionID IN (%Ld)
			ORDER BY id DESC',
			$diff_table->getTableName(),
			mpull($revisions, 'getID'));
			$diff_ids = igroup($diff_ids, 'revisionID');

			foreach ($revisions as $revision) {
			$ids = idx($diff_ids, $revision->getID(), array());
			$ids = ipull($ids, 'id');
			$revision->attachDiffIDs($ids);
			}
			}

			private function loadActiveDiffs($conn_r, array $revisions) {
			assert_instances_of($revisions, 'DifferentialRevision');

			$diff_table = new DifferentialDiff();

			$load_ids = array();
			foreach ($revisions as $revision) {
			$diffs = $revision->getDiffIDs();
			if ($diffs) {
			$load_ids[] = max($diffs);
			}
			}

			$active_diffs = array();
			if ($load_ids) {
			$active_diffs = $diff_table->loadAllWhere(
			'id IN (%Ld)',
			$load_ids);
			}

			$active_diffs = mpull($active_diffs, null, 'getRevisionID');
			foreach ($revisions as $revision) {
			$revision->attachActiveDiff(idx($active_diffs, $revision->getID()));
			}
			}

			private function loadHashes(
			AphrontDatabaseConnection $conn_r,
			array $revisions) {
			assert_instances_of($revisions, 'DifferentialRevision');

			$data = queryfx_all(
			$conn_r,
			'SELECT * FROM %T WHERE revisionID IN (%Ld)',
			'differential_revisionhash',
			mpull($revisions, 'getID'));

			$data = igroup($data, 'revisionID');
			foreach ($revisions as $revision) {
			$hashes = idx($data, $revision->getID(), array());
			$list = array();
			foreach ($hashes as $hash) {
			$list[] = array($hash['type'], $hash['hash']);
			}
			$revision->attachHashes($list);
			}
			}

			public static function splitResponsible(array $revisions, array $user_phids) {
			$blocking = array();
			$active = array();
			$waiting = array();
			$status_review = ArcanistDifferentialRevisionStatus::NEEDS_REVIEW;

			// Bucket revisions into $blocking (revisions where you are blocking
			// others), $active (revisions you need to do something about) and $waiting
			// (revisions you're waiting on someone else to do something about).
			foreach ($revisions as $revision) {
			$needs_review = ($revision->getStatus() == $status_review);
			$filter_is_author = in_array($revision->getAuthorPHID(), $user_phids);
			if (!$revision->getReviewers()) {
			$needs_review = false;
			}

			// If exactly one of "needs review" and "the user is the author" is
			// true, the user needs to act on it. Otherwise, they're waiting on
			// it.
			if ($needs_review ^ $filter_is_author) {
			if ($needs_review) {
			array_unshift($blocking, $revision);
			} else {
			$active[] = $revision;
			}
			} else {
			$waiting[] = $revision;
			}
			}

			return array($blocking, $active, $waiting);
			}


			}

phab/src/applications/differential/query/DifferentialRevisionQuery.php3ec4984f27cdstable

DifferentialRevisionQuery.phpView Options

phab/src/applications/differential/query/DifferentialRevisionQuery.php
3ec4984f27cdstable

DifferentialRevisionQuery.php
View Options