src/applications/repository/daemon/PhabricatorRepositoryPullLocalDaemonModule.php

   1 <?php
   2
   3 final class PhabricatorRepositoryPullLocalDaemonModule
   4   extends PhutilDaemonOverseerModule {
   5
   6   private $cursor = 0;
   7
   8   public function shouldWakePool(PhutilDaemonPool $pool) {
   9     $class = $pool->getPoolDaemonClass();
  10     if ($class != 'PhabricatorRepositoryPullLocalDaemon') {
  11       return false;
  12     }
  13
  14     if ($this->shouldThrottle($class, 1)) {
  15       return false;
  16     }
  17
  18     $table = new PhabricatorRepositoryStatusMessage();
  19     $table_name = $table->getTableName();
  20     $conn = $table->establishConnection('r');
  21
  22     $row = queryfx_one(
  23       $conn,
  24       'SELECT id FROM %T WHERE statusType = %s
  25         AND id > %d ORDER BY id DESC LIMIT 1',
  26       $table_name,
  27       PhabricatorRepositoryStatusMessage::TYPE_NEEDS_UPDATE,
  28       $this->cursor);
  29
  30     if (!$row) {
  31       return false;
  32     }
  33
  34     $this->cursor = (int)$row['id'];
  35     return true;
  36   }
  37
  38 }