recaptime.dev
@recaptime-dev's working patches + fork for Phorge, a community fork of Phabricator. (Upstream dev and stable branches are at upstream/main and upstream/stable respectively.)
hq.recaptime.dev/wiki/Phorge
phorge
phabricator
1<?php
2
3final class DiffusionRenameHistoryQuery extends Phobject {
4
5 private $oldCommit;
6 private $wasCreated;
7 private $request;
8 private $viewer;
9
10 public function setViewer(PhabricatorUser $viewer) {
11 $this->viewer = $viewer;
12 return $this;
13 }
14
15 public function getWasCreated() {
16 return $this->wasCreated;
17 }
18
19 public function setRequest(DiffusionRequest $request) {
20 $this->request = $request;
21 return $this;
22 }
23
24 public function setOldCommit($old_commit) {
25 $this->oldCommit = $old_commit;
26 return $this;
27 }
28
29 public function getOldCommit() {
30 return $this->oldCommit;
31 }
32
33 public function loadOldFilename() {
34 $drequest = $this->request;
35 $repository_id = $drequest->getRepository()->getID();
36 $conn_r = id(new PhabricatorRepository())->establishConnection('r');
37
38 $commit_id = $this->loadCommitId($this->oldCommit);
39 $old_commit_sequence = $this->loadCommitSequence($commit_id);
40
41 $path = '/'.$drequest->getPath();
42 $commit_id = $this->loadCommitId($drequest->getCommit());
43
44 do {
45 $commit_sequence = $this->loadCommitSequence($commit_id);
46 $change = queryfx_one(
47 $conn_r,
48 'SELECT pc.changeType, pc.targetCommitID, tp.path
49 FROM %T p
50 JOIN %T pc ON p.id = pc.pathID
51 LEFT JOIN %T tp ON pc.targetPathID = tp.id
52 WHERE p.pathHash = %s
53 AND pc.repositoryID = %d
54 AND pc.changeType IN (%d, %d)
55 AND pc.commitSequence BETWEEN %d AND %d
56 ORDER BY pc.commitSequence DESC
57 LIMIT 1',
58 PhabricatorRepository::TABLE_PATH,
59 PhabricatorRepository::TABLE_PATHCHANGE,
60 PhabricatorRepository::TABLE_PATH,
61 md5($path),
62 $repository_id,
63 ArcanistDiffChangeType::TYPE_MOVE_HERE,
64 ArcanistDiffChangeType::TYPE_ADD,
65 $old_commit_sequence,
66 $commit_sequence);
67 if ($change) {
68 if ($change['changeType'] == ArcanistDiffChangeType::TYPE_ADD) {
69 $this->wasCreated = true;
70 return $path;
71 }
72 $commit_id = $change['targetCommitID'];
73 $path = $change['path'];
74 }
75 } while ($change && $path);
76
77 return $path;
78 }
79
80 private function loadCommitId($commit_identifier) {
81 $commit = id(new DiffusionCommitQuery())
82 ->setViewer($this->viewer)
83 ->withIdentifiers(array($commit_identifier))
84 ->withRepository($this->request->getRepository())
85 ->executeOne();
86 return $commit->getID();
87 }
88
89 private function loadCommitSequence($commit_id) {
90 $conn_r = id(new PhabricatorRepository())->establishConnection('r');
91 $path_change = queryfx_one(
92 $conn_r,
93 'SELECT commitSequence
94 FROM %T
95 WHERE repositoryID = %d AND commitID = %d
96 LIMIT 1',
97 PhabricatorRepository::TABLE_PATHCHANGE,
98 $this->request->getRepository()->getID(),
99 $commit_id);
100 return reset($path_change);
101 }
102
103}