src/applications/diffusion/query/pathchange/DiffusionPathChangeQuery.php

   1 <?php
   2
   3 final class DiffusionPathChangeQuery extends Phobject {
   4
   5   private $request;
   6   private $limit;
   7
   8   public function setLimit($limit) {
   9     $this->limit = $limit;
  10     return $this;
  11   }
  12
  13   public function getLimit() {
  14     return $this->limit;
  15   }
  16
  17   private function __construct() {
  18     // <private>
  19   }
  20
  21   public static function newFromDiffusionRequest(
  22     DiffusionRequest $request) {
  23     $query = new DiffusionPathChangeQuery();
  24     $query->request = $request;
  25
  26     return $query;
  27   }
  28
  29   protected function getRequest() {
  30     return $this->request;
  31   }
  32
  33   public function loadChanges() {
  34     return $this->executeQuery();
  35   }
  36
  37   protected function executeQuery() {
  38
  39     $drequest = $this->getRequest();
  40     $repository = $drequest->getRepository();
  41
  42     $commit = $drequest->loadCommit();
  43
  44     $conn_r = $repository->establishConnection('r');
  45
  46     if ($this->limit) {
  47       $limit = qsprintf(
  48         $conn_r,
  49         'LIMIT %d',
  50         $this->limit + 1);
  51     } else {
  52       $limit = qsprintf($conn_r, '');
  53     }
  54
  55     $raw_changes = queryfx_all(
  56       $conn_r,
  57       'SELECT c.*, p.path pathName, t.path targetPathName,
  58           i.commitIdentifier targetCommitIdentifier
  59         FROM %T c
  60           LEFT JOIN %T p ON c.pathID = p.id
  61           LEFT JOIN %T t ON c.targetPathID = t.id
  62           LEFT JOIN %T i ON c.targetCommitID = i.id
  63         WHERE c.commitID = %d AND isDirect = 1 %Q',
  64       PhabricatorRepository::TABLE_PATHCHANGE,
  65       PhabricatorRepository::TABLE_PATH,
  66       PhabricatorRepository::TABLE_PATH,
  67       $commit->getTableName(),
  68       $commit->getID(),
  69       $limit);
  70
  71     $limited = $this->limit && (count($raw_changes) > $this->limit);
  72     if ($limited) {
  73       $raw_changes = array_slice($raw_changes, 0, $this->limit);
  74     }
  75
  76     $changes = array();
  77
  78     $raw_changes = isort($raw_changes, 'pathName');
  79     foreach ($raw_changes as $raw_change) {
  80       $type = $raw_change['changeType'];
  81       if ($type == DifferentialChangeType::TYPE_CHILD) {
  82         continue;
  83       }
  84
  85       $change = new DiffusionPathChange();
  86       $change->setPath(ltrim($raw_change['pathName'], '/'));
  87       $change->setChangeType($raw_change['changeType']);
  88       $change->setFileType($raw_change['fileType']);
  89       $change->setCommitIdentifier($commit->getCommitIdentifier());
  90
  91       $change->setTargetPath(ltrim($raw_change['targetPathName'], '/'));
  92       $change->setTargetCommitIdentifier($raw_change['targetCommitIdentifier']);
  93
  94       $id = $raw_change['pathID'];
  95       $changes[$id] = $change;
  96     }
  97
  98     // Deduce the away paths by examining all the changes, if we loaded them
  99     // all.
 100
 101     if (!$limited) {
 102       $away = array();
 103       foreach ($changes as $change) {
 104         if ($change->getTargetPath()) {
 105           $away[$change->getTargetPath()][] = $change->getPath();
 106         }
 107       }
 108       foreach ($changes as $change) {
 109         if (isset($away[$change->getPath()])) {
 110           $change->setAwayPaths($away[$change->getPath()]);
 111         }
 112       }
 113     }
 114
 115     return $changes;
 116   }
 117 }