Homec4science
Diffusion libphutil (stable) Browse

libphutil/src/conduit/client/ConduitClient.php
a1b1d2f697aastable

Last Change
Raw File

ConduitClient.php
View Options

<?php
/*
* Copyright 2011 Facebook, Inc.
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
class ConduitClient {
protected $host;
protected $path;
protected $traceMode;
protected $connectionID;
public function setConnectionID($connection_id) {
$this->connectionID = $connection_id;
return $this;
}
public function getConnectionID() {
return $this->connectionID;
}
public function __construct($uri) {
$this->host = parse_url($uri, PHP_URL_HOST);
$this->path = parse_url($uri, PHP_URL_PATH);
if (!$this->host) {
throw new Exception("Conduit URI '{$uri}' must include a valid host.");
}
$this->path = trim($this->path, '/').'/';
}
public function callMethodSynchronous($method, array $params) {
return $this->callMethod($method, $params)->resolve();
}
public function callMethod($method, array $params) {
$meta = array();
if ($this->getConnectionID()) {
$meta['connectionID'] = $this->getConnectionID();
}
if ($meta) {
$params['__conduit__'] = $meta;
}
$start_time = microtime(true);
$future = new ConduitFuture(
'http://'.$this->host.'/'.$this->path.$method,
array(
'params' => json_encode($params),
'output' => 'json',
));
$future->setMethod('POST');
$future->isReady();
if ($this->getTraceMode()) {
$future_name = $method;
$future->setTraceMode(true);
$future->setStartTime($start_time);
$future->setTraceName($future_name);
echo "[Conduit] >>> Send {$future_name}()...\n";
}
return $future;
}
public function setTraceMode($mode) {
$this->traceMode = $mode;
return $this;
}
protected function getTraceMode() {
if (!empty($this->traceMode)) {
return true;
}
return false;
}
}
c4science · Help