src/applications/repository/query/PhabricatorRepositoryPushLogQuery.php

   1 <?php
   2
   3 final class PhabricatorRepositoryPushLogQuery
   4   extends PhabricatorCursorPagedPolicyAwareQuery {
   5
   6   private $ids;
   7   private $phids;
   8   private $repositoryPHIDs;
   9   private $pusherPHIDs;
  10   private $refTypes;
  11   private $newRefs;
  12   private $pushEventPHIDs;
  13   private $epochMin;
  14   private $epochMax;
  15   private $blockingHeraldRulePHIDs;
  16
  17   public function withIDs(array $ids) {
  18     $this->ids = $ids;
  19     return $this;
  20   }
  21
  22   public function withPHIDs(array $phids) {
  23     $this->phids = $phids;
  24     return $this;
  25   }
  26
  27   public function withRepositoryPHIDs(array $repository_phids) {
  28     $this->repositoryPHIDs = $repository_phids;
  29     return $this;
  30   }
  31
  32   public function withPusherPHIDs(array $pusher_phids) {
  33     $this->pusherPHIDs = $pusher_phids;
  34     return $this;
  35   }
  36
  37   public function withRefTypes(array $ref_types) {
  38     $this->refTypes = $ref_types;
  39     return $this;
  40   }
  41
  42   public function withNewRefs(array $new_refs) {
  43     $this->newRefs = $new_refs;
  44     return $this;
  45   }
  46
  47   public function withPushEventPHIDs(array $phids) {
  48     $this->pushEventPHIDs = $phids;
  49     return $this;
  50   }
  51
  52   public function withEpochBetween($min, $max) {
  53     $this->epochMin = $min;
  54     $this->epochMax = $max;
  55     return $this;
  56   }
  57
  58   public function withBlockingHeraldRulePHIDs(array $phids) {
  59     $this->blockingHeraldRulePHIDs = $phids;
  60     return $this;
  61   }
  62
  63   public function newResultObject() {
  64     return new PhabricatorRepositoryPushLog();
  65   }
  66
  67   protected function willFilterPage(array $logs) {
  68     $event_phids = mpull($logs, 'getPushEventPHID');
  69     $events = id(new PhabricatorObjectQuery())
  70       ->setParentQuery($this)
  71       ->setViewer($this->getViewer())
  72       ->withPHIDs($event_phids)
  73       ->execute();
  74     $events = mpull($events, null, 'getPHID');
  75
  76     foreach ($logs as $key => $log) {
  77       $event = idx($events, $log->getPushEventPHID());
  78       if (!$event) {
  79         unset($logs[$key]);
  80         continue;
  81       }
  82       $log->attachPushEvent($event);
  83     }
  84
  85     return $logs;
  86   }
  87
  88   protected function buildWhereClauseParts(AphrontDatabaseConnection $conn) {
  89     $where = parent::buildWhereClauseParts($conn);
  90
  91     if ($this->ids !== null) {
  92       $where[] = qsprintf(
  93         $conn,
  94         'log.id IN (%Ld)',
  95         $this->ids);
  96     }
  97
  98     if ($this->phids !== null) {
  99       $where[] = qsprintf(
 100         $conn,
 101         'log.phid IN (%Ls)',
 102         $this->phids);
 103     }
 104
 105     if ($this->repositoryPHIDs !== null) {
 106       $where[] = qsprintf(
 107         $conn,
 108         'log.repositoryPHID IN (%Ls)',
 109         $this->repositoryPHIDs);
 110     }
 111
 112     if ($this->pusherPHIDs !== null) {
 113       $where[] = qsprintf(
 114         $conn,
 115         'log.pusherPHID in (%Ls)',
 116         $this->pusherPHIDs);
 117     }
 118
 119     if ($this->pushEventPHIDs !== null) {
 120       $where[] = qsprintf(
 121         $conn,
 122         'log.pushEventPHID in (%Ls)',
 123         $this->pushEventPHIDs);
 124     }
 125
 126     if ($this->refTypes !== null) {
 127       $where[] = qsprintf(
 128         $conn,
 129         'log.refType IN (%Ls)',
 130         $this->refTypes);
 131     }
 132
 133     if ($this->newRefs !== null) {
 134       $where[] = qsprintf(
 135         $conn,
 136         'log.refNew IN (%Ls)',
 137         $this->newRefs);
 138     }
 139
 140     if ($this->epochMin !== null) {
 141       $where[] = qsprintf(
 142         $conn,
 143         'log.epoch >= %d',
 144         $this->epochMin);
 145     }
 146
 147     if ($this->epochMax !== null) {
 148       $where[] = qsprintf(
 149         $conn,
 150         'log.epoch <= %d',
 151         $this->epochMax);
 152     }
 153
 154     if ($this->blockingHeraldRulePHIDs !== null) {
 155       $where[] = qsprintf(
 156         $conn,
 157         '(event.rejectCode = %d AND event.rejectDetails IN (%Ls))',
 158         PhabricatorRepositoryPushLog::REJECT_HERALD,
 159         $this->blockingHeraldRulePHIDs);
 160     }
 161
 162     return $where;
 163   }
 164
 165   protected function buildJoinClauseParts(AphrontDatabaseConnection $conn) {
 166     $joins = parent::buildJoinClauseParts($conn);
 167
 168     if ($this->shouldJoinPushEventTable()) {
 169       $joins[] = qsprintf(
 170         $conn,
 171         'JOIN %T event ON event.phid = log.pushEventPHID',
 172         id(new PhabricatorRepositoryPushEvent())->getTableName());
 173     }
 174
 175     return $joins;
 176   }
 177
 178   private function shouldJoinPushEventTable() {
 179     if ($this->blockingHeraldRulePHIDs !== null) {
 180       return true;
 181     }
 182
 183     return false;
 184   }
 185
 186   public function getQueryApplicationClass() {
 187     return 'PhabricatorDiffusionApplication';
 188   }
 189
 190   protected function getPrimaryTableAlias() {
 191     return 'log';
 192   }
 193
 194
 195 }