<?php

final class PhabricatorTokenReceiverQuery
  extends PhabricatorCursorPagedPolicyAwareQuery {

  private $tokenCounts;

  protected function loadPage() {
    $table = new PhabricatorTokenCount();
    $conn_r = $table->establishConnection('r');

    $rows = queryfx_all(
      $conn_r,
      'SELECT objectPHID, tokenCount FROM %T ORDER BY tokenCount DESC',
      $table->getTableName());

    $this->tokenCounts = ipull($rows, 'tokenCount', 'objectPHID');
    return ipull($rows, 'objectPHID');
  }

  public function willFilterPage(array $phids) {
    if (!$phids) {
      return array();
    }
    $objects = id(new PhabricatorObjectHandleData($phids))
      ->setViewer($this->getViewer())
      ->loadObjects();
    return $objects;
  }

  public function getTokenCounts() {
    return $this->tokenCounts;
  }

}