<?php

/**
 * @extends PhabricatorCursorPagedPolicyAwareQuery<HarbormasterBuildable>
 */
final class HarbormasterBuildableQuery
  extends PhabricatorCursorPagedPolicyAwareQuery {

  private $ids;
  private $phids;
  private $buildablePHIDs;
  private $containerPHIDs;
  private $statuses;
  private $manualBuildables;

  private $needContainerObjects;
  private $needBuilds;
  private $needTargets;

  public function withIDs(array $ids) {
    $this->ids = $ids;
    return $this;
  }

  public function withPHIDs(array $phids) {
    $this->phids = $phids;
    return $this;
  }

  public function withBuildablePHIDs(array $buildable_phids) {
    $this->buildablePHIDs = $buildable_phids;
    return $this;
  }

  public function withContainerPHIDs(array $container_phids) {
    $this->containerPHIDs = $container_phids;
    return $this;
  }

  public function withManualBuildables($manual) {
    $this->manualBuildables = $manual;
    return $this;
  }

  public function needContainerObjects($need) {
    $this->needContainerObjects = $need;
    return $this;
  }

  public function withStatuses(array $statuses) {
    $this->statuses = $statuses;
    return $this;
  }

  public function needBuilds($need) {
    $this->needBuilds = $need;
    return $this;
  }

  public function needTargets($need) {
    $this->needTargets = $need;
    return $this;
  }

  public function newResultObject() {
    return new HarbormasterBuildable();
  }

  protected function willFilterPage(array $page) {
    $buildables = array();

    $buildable_phids = array_filter(mpull($page, 'getBuildablePHID'));
    if ($buildable_phids) {
      $buildables = id(new PhabricatorObjectQuery())
        ->setViewer($this->getViewer())
        ->withPHIDs($buildable_phids)
        ->setParentQuery($this)
        ->execute();
      $buildables = mpull($buildables, null, 'getPHID');
    }

    foreach ($page as $key => $buildable) {
      $buildable_phid = $buildable->getBuildablePHID();
      if (empty($buildables[$buildable_phid])) {
        unset($page[$key]);
        continue;
      }
      $buildable->attachBuildableObject($buildables[$buildable_phid]);
    }

    return $page;
  }

  protected function didFilterPage(array $page) {
    if ($this->needContainerObjects) {
      $container_phids = array_filter(mpull($page, 'getContainerPHID'));

      if ($container_phids) {
        $containers = id(new PhabricatorObjectQuery())
          ->setViewer($this->getViewer())
          ->withPHIDs($container_phids)
          ->setParentQuery($this)
          ->execute();
        $containers = mpull($containers, null, 'getPHID');
      } else {
        $containers = array();
      }

      foreach ($page as $key => $buildable) {
        $container_phid = $buildable->getContainerPHID();
        $buildable->attachContainerObject(idx($containers, $container_phid));
      }
    }

    if ($this->needBuilds || $this->needTargets) {
      $builds = id(new HarbormasterBuildQuery())
        ->setViewer($this->getViewer())
        ->setParentQuery($this)
        ->withBuildablePHIDs(mpull($page, 'getPHID'))
        ->needBuildTargets($this->needTargets)
        ->execute();
      $builds = mgroup($builds, 'getBuildablePHID');
      foreach ($page as $key => $buildable) {
        $buildable->attachBuilds(idx($builds, $buildable->getPHID(), array()));
      }
    }

    return $page;
  }

  protected function buildWhereClauseParts(AphrontDatabaseConnection $conn) {
    $where = parent::buildWhereClauseParts($conn);

    if ($this->ids !== null) {
      $where[] = qsprintf(
        $conn,
        'id IN (%Ld)',
        $this->ids);
    }

    if ($this->phids !== null) {
      $where[] = qsprintf(
        $conn,
        'phid IN (%Ls)',
        $this->phids);
    }

    if ($this->buildablePHIDs !== null) {
      $where[] = qsprintf(
        $conn,
        'buildablePHID IN (%Ls)',
        $this->buildablePHIDs);
    }

    if ($this->containerPHIDs !== null) {
      $where[] = qsprintf(
        $conn,
        'containerPHID in (%Ls)',
        $this->containerPHIDs);
    }

    if ($this->statuses !== null) {
      $where[] = qsprintf(
        $conn,
        'buildableStatus in (%Ls)',
        $this->statuses);
    }

    if ($this->manualBuildables !== null) {
      $where[] = qsprintf(
        $conn,
        'isManualBuildable = %d',
        (int)$this->manualBuildables);
    }

    return $where;
  }

  public function getQueryApplicationClass() {
    return PhabricatorHarbormasterApplication::class;
  }

}