PhabricatorConduitLogQuery.php
No OneTemporary
Actions

Subscribers

None

File Metadata

	<?php

	final class PhabricatorConduitLogQuery
	extends PhabricatorCursorPagedPolicyAwareQuery {

	private $callerPHIDs;
	private $methods;
	private $methodStatuses;

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

	public function withMethods(array $methods) {
	$this->methods = $methods;
	return $this;
	}

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

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

	protected function loadPage() {
	return $this->loadStandardPage($this->newResultObject());
	}

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

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

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

	if ($this->methodStatuses !== null) {
	$statuses = array_fuse($this->methodStatuses);

	$methods = id(new PhabricatorConduitMethodQuery())
	->setViewer($this->getViewer())
	->execute();

	$method_names = array();
	foreach ($methods as $method) {
	$status = $method->getMethodStatus();
	if (isset($statuses[$status])) {
	$method_names[] = $method->getAPIMethodName();
	}
	}

	if (!$method_names) {
	throw new PhabricatorEmptyQueryException();
	}

	$where[] = qsprintf(
	$conn,
	'method IN (%Ls)',
	$method_names);
	}

	return $where;
	}

	public function getQueryApplicationClass() {
	return 'PhabricatorConduitApplication';
	}

	}