Changeset View
Changeset View
Standalone View
Standalone View
src/conduit/ArcanistConduitEngine.php
| <?php | <?php | ||||
| final class ArcanistConduitEngine | final class ArcanistConduitEngine | ||||
| extends Phobject { | extends Phobject { | ||||
| private $conduitURI; | private $conduitURI; | ||||
| private $conduitToken; | private $conduitToken; | ||||
| private $conduitTimeout; | |||||
| private $basicAuthUser; | |||||
| private $basicAuthPass; | |||||
| private $client; | private $client; | ||||
| private $callKey = 0; | private $callKey = 0; | ||||
| private $activeFutures = array(); | private $activeFutures = array(); | ||||
| private $resolvedFutures = array(); | private $resolvedFutures = array(); | ||||
| public function isCallable() { | public function isCallable() { | ||||
| return ($this->conduitURI !== null); | return ($this->conduitURI !== null); | ||||
| } | } | ||||
| Show All 11 Lines | public function setConduitToken($conduit_token) { | ||||
| $this->conduitToken = $conduit_token; | $this->conduitToken = $conduit_token; | ||||
| return $this; | return $this; | ||||
| } | } | ||||
| public function getConduitToken() { | public function getConduitToken() { | ||||
| return $this->conduitToken; | return $this->conduitToken; | ||||
| } | } | ||||
| public function setConduitTimeout($conduit_timeout) { | |||||
| $this->conduitTimeout = $conduit_timeout; | |||||
| return $this; | |||||
| } | |||||
| public function getConduitTimeout() { | |||||
| return $this->conduitTimeout; | |||||
| } | |||||
| public function setBasicAuthUser($basic_auth_user) { | |||||
| $this->basicAuthUser = $basic_auth_user; | |||||
| return $this; | |||||
| } | |||||
| public function getBasicAuthUser() { | |||||
| return $this->basicAuthUser; | |||||
| } | |||||
| public function setBasicAuthPass($basic_auth_pass) { | |||||
| $this->basicAuthPass = $basic_auth_pass; | |||||
| return $this; | |||||
| } | |||||
| public function getBasicAuthPass() { | |||||
| return $this->basicAuthPass; | |||||
| } | |||||
| public function newCall($method, array $parameters) { | public function newCall($method, array $parameters) { | ||||
| if ($this->conduitURI == null) { | if ($this->conduitURI == null) { | ||||
| $this->raiseURIException(); | $this->raiseURIException(); | ||||
| } | } | ||||
| $next_key = ++$this->callKey; | $next_key = ++$this->callKey; | ||||
| return id(new ArcanistConduitCall()) | return id(new ArcanistConduitCall()) | ||||
| Show All 17 Lines | final class ArcanistConduitEngine | ||||
| } | } | ||||
| private function getClient() { | private function getClient() { | ||||
| if (!$this->client) { | if (!$this->client) { | ||||
| $conduit_uri = $this->getConduitURI(); | $conduit_uri = $this->getConduitURI(); | ||||
| $client = new ConduitClient($conduit_uri); | $client = new ConduitClient($conduit_uri); | ||||
| $timeout = $this->getConduitTimeout(); | |||||
| if ($timeout) { | |||||
| $client->setTimeout($timeout); | |||||
| } | |||||
| $basic_user = $this->getBasicAuthUser(); | |||||
| $basic_pass = $this->getBasicAuthPass(); | |||||
| if ($basic_user !== null || $basic_pass !== null) { | |||||
| $client->setBasicAuthCredentials($basic_user, $basic_pass); | |||||
| } | |||||
| $token = $this->getConduitToken(); | $token = $this->getConduitToken(); | ||||
| if ($token) { | if ($token) { | ||||
| $client->setConduitToken($this->getConduitToken()); | $client->setConduitToken($this->getConduitToken()); | ||||
| } | } | ||||
| } | } | ||||
| return $client; | return $client; | ||||
| } | } | ||||
| ▲ Show 20 Lines • Show All 48 Lines • Show Last 20 Lines | |||||