Differential D8471 Diff 20124 src/applications/repository/worker/commitmessageparser/PhabricatorRepositoryCommitMessageParserWorker.php

Changeset View

Standalone View

View Options

src/applications/repository/worker/commitmessageparser/PhabricatorRepositoryCommitMessageParserWorker.php

Show First 20 Lines • Show All 79 Lines • ▼ Show 20 Lines	final protected function updateCommitData(DiffusionCommitRef $ref) {
if ($revision_id) {		if ($revision_id) {
// TODO: Check if a more restrictive viewer could be set here		// TODO: Check if a more restrictive viewer could be set here
$revision_query = id(new DifferentialRevisionQuery())		$revision_query = id(new DifferentialRevisionQuery())
->withIDs(array($revision_id))		->withIDs(array($revision_id))
->setViewer(PhabricatorUser::getOmnipotentUser())		->setViewer(PhabricatorUser::getOmnipotentUser())
->needReviewerStatus(true)		->needReviewerStatus(true)
->needActiveDiffs(true);		->needActiveDiffs(true);

// TODO: Remove this once we swap to new CustomFields. This is only
// required by the old FieldSpecifications, lower on in this worker.
$revision_query->needRelationships(true);

$revision = $revision_query->executeOne();		$revision = $revision_query->executeOne();

if ($revision) {		if ($revision) {
$commit_drev = PhabricatorEdgeConfig::TYPE_COMMIT_HAS_DREV;		$commit_drev = PhabricatorEdgeConfig::TYPE_COMMIT_HAS_DREV;
id(new PhabricatorEdgeEditor())		id(new PhabricatorEdgeEditor())
->setActor($user)		->setActor($user)
->addEdge($commit->getPHID(), $commit_drev, $revision->getPHID())		->addEdge($commit->getPHID(), $commit_drev, $revision->getPHID())
->save();		->save();
▲ Show 20 Lines • Show All 95 Lines • ▼ Show 20 Lines	if ($revision_id) {
// lost a race to close the revision. That's perfectly fine, we can		// lost a race to close the revision. That's perfectly fine, we can
// just continue normally.		// just continue normally.
}		}
}		}
}		}
}		}

if ($should_autoclose) {		if ($should_autoclose) {
// TODO: When this is moved to CustomFields, remove the additional		// TODO: This isn't as general as it could be.
// call above in query construction.		if ($user->getPHID()) {
$fields = DifferentialFieldSelector::newSelector()		$this->closeTasks($user, $repository, $commit, $message);
->getFieldSpecifications();
foreach ($fields as $key => $field) {
if (!$field->shouldAppearOnCommitMessage()) {
continue;
}
$field->setUser($user);
$value = idx($field_values, $field->getCommitMessageKey());
$field->setValueFromParsedCommitMessage($value);
if ($revision) {
$field->setRevision($revision);
}
$field->didParseCommit($repository, $commit, $data);
}		}
}		}

$data->save();		$data->save();

$commit->writeImportStatusFlag(		$commit->writeImportStatusFlag(
PhabricatorRepositoryCommit::IMPORTED_MESSAGE);		PhabricatorRepositoryCommit::IMPORTED_MESSAGE);
}		}
▲ Show 20 Lines • Show All 187 Lines • ▼ Show 20 Lines	private function resolveUserPHID(
$user_name) {		$user_name) {

return id(new DiffusionResolveUserQuery())		return id(new DiffusionResolveUserQuery())
->withCommit($commit)		->withCommit($commit)
->withName($user_name)		->withName($user_name)
->execute();		->execute();
}		}

		private function closeTasks(
		PhabricatorUser $actor,
		PhabricatorRepository $repository,
		PhabricatorRepositoryCommit $commit,
		$message) {

		$maniphest = 'PhabricatorApplicationManiphest';
		if (!PhabricatorApplication::isClassInstalled($maniphest)) {
		return;
		}

		$prefixes = ManiphestTaskStatus::getStatusPrefixMap();
		$suffixes = ManiphestTaskStatus::getStatusSuffixMap();

		$matches = id(new ManiphestCustomFieldStatusParser())
		->parseCorpus($message);

		$task_statuses = array();
		foreach ($matches as $match) {
		$prefix = phutil_utf8_strtolower($match['prefix']);
		$suffix = phutil_utf8_strtolower($match['suffix']);

		$status = idx($suffixes, $suffix);
		if (!$status) {
		$status = idx($prefixes, $prefix);
		}

		foreach ($match['monograms'] as $task_monogram) {
		$task_id = (int)trim($task_monogram, 'tT');
		$task_statuses[$task_id] = $status;
		}
		}

		if (!$task_statuses) {
		return;
		}

		$tasks = id(new ManiphestTaskQuery())
		->setViewer($actor)
		->withIDs(array_keys($task_statuses))
		->execute();

		foreach ($tasks as $task_id => $task) {
		$xactions = array();

		// TODO: Swap this for a real edge transaction once the weirdness in
		// Maniphest edges is sorted out. Currently, Maniphest reacts to an edge
		// edit on this edge.
		id(new PhabricatorEdgeEditor())
		->setActor($actor)
		->addEdge(
		$task->getPHID(),
		PhabricatorEdgeConfig::TYPE_TASK_HAS_COMMIT,
		$commit->getPHID())
		->save();

		/* TODO: Do this instead of the above.

		$xactions[] = id(new ManiphestTransaction())
		->setTransactionType(PhabricatorTransactions::TYPE_EDGE)
		->setMetadataValue('edge:type', $edge_task_has_commit)
		->setNewValue(
		array(
		'+' => array(
		$commit->getPHID() => $commit->getPHID(),
		),
		));
		*/

		$status = $task_statuses[$task_id];
		if ($status) {
		if ($task->getStatus() != $status) {
		$xactions[] = id(new ManiphestTransaction())
		->setTransactionType(ManiphestTransaction::TYPE_STATUS)
		->setNewValue($status);

		$commit_name = $repository->formatCommitName(
		$commit->getCommitIdentifier());

		$status_message = pht(
		'Closed by commit %s.',
		$commit_name);

		$xactions[] = id(new ManiphestTransaction())
		->setTransactionType(PhabricatorTransactions::TYPE_COMMENT)
		->attachComment(
		id(new ManiphestTransactionComment())
		->setContent($status_message));
		}
		}

		$content_source = PhabricatorContentSource::newForSource(
		PhabricatorContentSource::SOURCE_DAEMON,
		array());

		$editor = id(new ManiphestTransactionEditor())
		->setActor($actor)
		->setContinueOnNoEffect(true)
		->setContinueOnMissingFields(true)
		->setContentSource($content_source);

		$editor->applyTransactions($task, $xactions);
		}
		}

}		}