Add project.query to Conduit

Summary: Add a conduit method to query project information.

Test Plan: Ran method from API test console.

Reviewers: bill, btrahan, jungejason

Reviewed By: btrahan

CC: aran

Maniphest Tasks: T681

Differential Revision: https://secure.phabricator.com/D1444
This commit is contained in:
epriestley
2012-01-17 16:29:35 -08:00
parent 6472dbe168
commit 42ddad1bc8
7 changed files with 242 additions and 5 deletions

View File

@@ -1,7 +1,7 @@
<?php
/*
* Copyright 2011 Facebook, Inc.
* Copyright 2012 Facebook, Inc.
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
@@ -18,12 +18,26 @@
final class PhabricatorProjectQuery {
private $ids;
private $phids;
private $owners;
private $members;
private $limit;
private $offset;
private $needMembers;
public function withIDs(array $ids) {
$this->ids = $ids;
return $this;
}
public function withPHIDs(array $phids) {
$this->phids = $phids;
return $this;
}
public function setLimit($limit) {
$this->limit = $limit;
return $this;
@@ -44,13 +58,19 @@ final class PhabricatorProjectQuery {
return $this;
}
public function needMembers($need_members) {
$this->needMembers = $need_members;
return $this;
}
public function execute() {
$table = id(new PhabricatorProject());
$conn_r = $table->establishConnection('r');
$where = $this->buildWhereClause($conn_r);
$joins = $this->buildJoinsClause($conn_r);
$limit = null;
$limit = '';
if ($this->limit) {
$limit = qsprintf(
$conn_r,
@@ -69,13 +89,51 @@ final class PhabricatorProjectQuery {
$data = queryfx_all(
$conn_r,
'SELECT p.* FROM %T p %Q %Q %Q',
'SELECT p.* FROM %T p %Q %Q %Q %Q',
$table->getTableName(),
$joins,
$where,
$order,
$limit);
return $table->loadAllFromArray($data);
$projects = $table->loadAllFromArray($data);
if ($projects && $this->needMembers) {
$members = PhabricatorProjectAffiliation::loadAllForProjectPHIDs(
mpull($projects, 'getPHID'));
foreach ($projects as $project) {
$project->attachAffiliations(
array_values(idx($members, $project->getPHID(), array())));
}
}
return $projects;
}
private function buildWhereClause($conn_r) {
$where = array();
if ($this->ids) {
$where[] = qsprintf(
$conn_r,
'id IN (%Ld)',
$this->ids);
}
if ($this->phids) {
$where[] = qsprintf(
$conn_r,
'phid IN (%Ls)',
$this->phids);
}
if ($where) {
$where = 'WHERE ('.implode(') AND (', $where).')';
} else {
$where = '';
}
return $where;
}
private function buildJoinsClause($conn_r) {

View File

@@ -1,7 +1,7 @@
<?php
/*
* Copyright 2011 Facebook, Inc.
* Copyright 2012 Facebook, Inc.
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
@@ -26,6 +26,7 @@ class PhabricatorProject extends PhabricatorProjectDAO {
protected $phrictionSlug;
private $subprojectsNeedUpdate;
private $affiliations;
public function getConfiguration() {
return array(
@@ -54,6 +55,18 @@ class PhabricatorProject extends PhabricatorProjectDAO {
return $profile;
}
public function getAffiliations() {
if ($this->affiliations === null) {
throw new Exception('Attach affiliations first!');
}
return $this->affiliations;
}
public function attachAffiliations(array $affiliations) {
$this->affiliations = $affiliations;
return $this;
}
public function loadAffiliations() {
$affils = PhabricatorProjectAffiliation::loadAllForProjectPHIDs(
array($this->getPHID()));