1
0
Fork 0
mirror of https://we.phorge.it/source/phorge.git synced 2024-11-29 10:12:41 +01:00

Add "requestedObjectPHID" to ReleephRequest

Summary:
Ref T3551. Currently, ReleephRequests don't have a direct concept of the //object// being requested. You can request `D123`, but that is just a convenient way to write `rXyyyy`.

When the UI wants to display information about a revision, it deduces it by examining the commit.

This is primarily an attack on T3551, so we don't need to load <commit -> edge -> revision> (in an ad-hoc way) to get revisions. Instead, when you request a revision we keep track of it and can load it directly later.

Later, this will let us do more things: for example, if you request a branch, we can automatically update the commits (as GitHub does), etc. (Repository branches will need PHIDs first, of course.)

This adds and populates the column but doesn't use it yet. The second part of the migration could safely be run while Phabricator is up, although even for Facebook this table is probably quite small.

Test Plan:
  - Ran migration.
  - Verified existing requests associated sensibly.
  - Created a new commit request.
  - Created a new revision request.

Reviewers: btrahan

Reviewed By: btrahan

Subscribers: epriestley

Maniphest Tasks: T3551

Differential Revision: https://secure.phabricator.com/D8822
This commit is contained in:
epriestley 2014-04-20 11:55:18 -07:00
parent a588955bf7
commit 1a3ac09975
6 changed files with 112 additions and 3 deletions

View file

@ -0,0 +1,5 @@
ALTER TABLE {$NAMESPACE}_releeph.releeph_request
ADD COLUMN requestedObjectPHID VARCHAR(64) COLLATE utf8_bin NOT NULL;
ALTER TABLE {$NAMESPACE}_releeph.releeph_request
ADD KEY `key_requestedObject` (requestedObjectPHID);

View file

@ -0,0 +1,45 @@
<?php
$pull_table = new ReleephRequest();
$table_name = $pull_table->getTableName();
$conn_w = $pull_table->establishConnection('w');
echo "Setting object PHIDs for requests...\n";
foreach (new LiskMigrationIterator($pull_table) as $pull) {
$id = $pull->getID();
echo "Migrating pull request {$id}...\n";
if ($pull->getRequestedObjectPHID()) {
// We already have a valid PHID, so skip this request.
continue;
}
$commit_phids = $pull->getCommitPHIDs();
if (count($commit_phids) != 1) {
// At the time this migration was written, all requests had exactly one
// commit. If a request has more than one, we don't have the information
// we need to process it.
continue;
}
$commit_phid = head($commit_phids);
$revision_phids = PhabricatorEdgeQuery::loadDestinationPHIDs(
$commit_phid,
PhabricatorEdgeConfig::TYPE_COMMIT_HAS_DREV);
if ($revision_phids) {
$object_phid = head($revision_phids);
} else {
$object_phid = $commit_phid;
}
queryfx(
$conn_w,
'UPDATE %T SET requestedObjectPHID = %s WHERE id = %d',
$table_name,
$object_phid,
$id);
}
echo "Done.\n";

View file

@ -4,6 +4,7 @@ final class ReleephCommitFinder {
private $releephProject; private $releephProject;
private $user; private $user;
private $objectPHID;
public function setUser(PhabricatorUser $user) { public function setUser(PhabricatorUser $user) {
$this->user = $user; $this->user = $user;
@ -18,7 +19,13 @@ final class ReleephCommitFinder {
return $this; return $this;
} }
public function getRequestedObjectPHID() {
return $this->objectPHID;
}
public function fromPartial($partial_string) { public function fromPartial($partial_string) {
$this->objectPHID = null;
// Look for diffs // Look for diffs
$matches = array(); $matches = array();
if (preg_match('/^D([1-9]\d*)$/', $partial_string, $matches)) { if (preg_match('/^D([1-9]\d*)$/', $partial_string, $matches)) {
@ -36,6 +43,8 @@ final class ReleephCommitFinder {
"{$partial_string} has no commits associated with it yet."); "{$partial_string} has no commits associated with it yet.");
} }
$this->objectPHID = $diff_rev->getPHID();
$commits = id(new PhabricatorRepositoryCommit())->loadAllWhere( $commits = id(new PhabricatorRepositoryCommit())->loadAllWhere(
'phid IN (%Ls) ORDER BY epoch ASC', 'phid IN (%Ls) ORDER BY epoch ASC',
$commit_phids); $commit_phids);
@ -43,7 +52,7 @@ final class ReleephCommitFinder {
} }
// Look for a raw commit number, or r<callsign><commit-number>. // Look for a raw commit number, or r<callsign><commit-number>.
$repository = $this->releephProject->loadPhabricatorRepository(); $repository = $this->releephProject->getRepository();
$dr_data = null; $dr_data = null;
$matches = array(); $matches = array();
if (preg_match('/^r(?P<callsign>[A-Z]+)(?P<commit>\w+)$/', if (preg_match('/^r(?P<callsign>[A-Z]+)(?P<commit>\w+)$/',
@ -79,6 +88,17 @@ final class ReleephCommitFinder {
"The commit {$partial_string} doesn't exist in this repository."); "The commit {$partial_string} doesn't exist in this repository.");
} }
// When requesting a single commit, if it has an associated review we
// imply the review was requested instead. This is always correct for now
// and consistent with the older behavior, although it might not be the
// right rule in the future.
$phids = PhabricatorEdgeQuery::loadDestinationPHIDs(
$phabricator_repository_commit->getPHID(),
PhabricatorEdgeConfig::TYPE_COMMIT_HAS_DREV);
if ($phids) {
$this->objectPHID = head($phids);
}
return $phabricator_repository_commit; return $phabricator_repository_commit;
} }

View file

@ -49,6 +49,7 @@ final class ConduitAPI_releeph_request_Method
// Find the requested commit identifiers // Find the requested commit identifiers
$requested_commits = array(); $requested_commits = array();
$requested_object_phids = array();
$things = $request->getValue('things'); $things = $request->getValue('things');
$finder = id(new ReleephCommitFinder()) $finder = id(new ReleephCommitFinder())
->setUser($user) ->setUser($user)
@ -56,6 +57,11 @@ final class ConduitAPI_releeph_request_Method
foreach ($things as $thing) { foreach ($things as $thing) {
try { try {
$requested_commits[$thing] = $finder->fromPartial($thing); $requested_commits[$thing] = $finder->fromPartial($thing);
$object_phid = $finder->getRequestedObjectPHID();
if (!$object_phid) {
$object_phid = $requested_commits[$thing]->getPHID();
}
$requested_object_phids[$thing] = $object_phid;
} catch (ReleephCommitFinderException $ex) { } catch (ReleephCommitFinderException $ex) {
throw id(new ConduitException('ERR_NO_MATCHES')) throw id(new ConduitException('ERR_NO_MATCHES'))
->setErrorDescription($ex->getMessage()); ->setErrorDescription($ex->getMessage());
@ -99,7 +105,8 @@ final class ConduitAPI_releeph_request_Method
$releeph_request = id(new ReleephRequest()) $releeph_request = id(new ReleephRequest())
->setRequestUserPHID($user->getPHID()) ->setRequestUserPHID($user->getPHID())
->setBranchID($releeph_branch->getID()) ->setBranchID($releeph_branch->getID())
->setInBranch(0); ->setInBranch(0)
->setRequestedObjectPHID($requested_object_phids[$thing]);
$xactions = array(); $xactions = array();

View file

@ -43,7 +43,8 @@ final class ReleephRequestEditController extends ReleephBranchController {
$pull = id(new ReleephRequest()) $pull = id(new ReleephRequest())
->setRequestUserPHID($viewer->getPHID()) ->setRequestUserPHID($viewer->getPHID())
->setBranchID($branch->getID()) ->setBranchID($branch->getID())
->setInBranch(0); ->setInBranch(0)
->attachBranch($branch);
$is_edit = false; $is_edit = false;
} }
@ -116,6 +117,15 @@ final class ReleephRequestEditController extends ReleephBranchController {
$errors[] = "The requested commit hasn't been parsed yet."; $errors[] = "The requested commit hasn't been parsed yet.";
} }
} }
if (!$errors) {
$object_phid = $finder->getRequestedObjectPHID();
if (!$object_phid) {
$object_phid = $pr_commit->getPHID();
}
$pull->setRequestedObjectPHID($object_phid);
}
} }
if (!$errors) { if (!$errors) {

View file

@ -13,6 +13,13 @@ final class ReleephRequest extends ReleephDAO
protected $pickStatus; protected $pickStatus;
protected $mailKey; protected $mailKey;
/**
* The object which is being requested. Normally this is a commit, but it
* might also be a revision. In the future, it could be a repository branch
* or an external object (like a GitHub pull request).
*/
protected $requestedObjectPHID;
// Information about the thing being requested // Information about the thing being requested
protected $requestCommitPHID; protected $requestCommitPHID;
@ -20,6 +27,7 @@ final class ReleephRequest extends ReleephDAO
protected $commitIdentifier; protected $commitIdentifier;
protected $commitPHID; protected $commitPHID;
private $customFields = self::ATTACHABLE; private $customFields = self::ATTACHABLE;
private $branch = self::ATTACHABLE; private $branch = self::ATTACHABLE;
@ -163,6 +171,20 @@ final class ReleephRequest extends ReleephDAO
return $this; return $this;
} }
/**
* Get the commit PHIDs this request is requesting.
*
* NOTE: For now, this always returns one PHID.
*
* @return list<phid> Commit PHIDs requested by this request.
*/
public function getCommitPHIDs() {
return array(
$this->requestCommitPHID,
);
}
public function getReason() { public function getReason() {
// Backward compatibility: reason used to be called comments // Backward compatibility: reason used to be called comments
$reason = $this->getDetail('reason'); $reason = $this->getDetail('reason');