url = $url;
$this->prefix = $prefix;
}
/**
* 设置调试模式
* @deprecated
*/
public function setDebug()
{
$this->debug = true;
}
/**
* 执行请求
*
* @param string $method
* @param array $args
* @return bool
*/
private function rpcCall(string $method, array $args): bool
{
$request = new Request($method, $args);
$xml = $request->getXml();
$client = HttpClient::get();
if (!$client) {
$this->error = new Error(-32300, 'transport error - could not open socket');
return false;
}
try {
$client->setHeader('Content-Type', 'text/xml')
->setHeader('User-Agent', self::DEFAULT_USERAGENT)
->setData($xml)
->send($this->url);
} catch (HttpClient\Exception $e) {
$this->error = new Error(-32700, $e->getMessage());
return false;
}
$contents = $client->getResponseBody();
if ($this->debug) {
echo '' . htmlspecialchars($contents) . "\n
\n\n";
}
// Now parse what we've got back
$this->message = new Message($contents);
if (!$this->message->parse()) {
// XML error
$this->error = new Error(-32700, 'parse error. not well formed');
return false;
}
// Is the message a fault?
if ($this->message->messageType == 'fault') {
$this->error = new Error($this->message->faultCode, $this->message->faultString);
return false;
}
// Message must be OK
return true;
}
/**
* 增加前缀
*
* $rpc->metaWeblog->newPost();
*
*
* @param string $prefix 前缀
* @return Client
*/
public function __get(string $prefix): Client
{
return new self($this->url, $this->prefix . $prefix . '.');
}
/**
* 增加魔术特性
* by 70
*
* @return mixed
* @throws Exception
*/
public function __call($method, $args)
{
$return = $this->rpcCall($this->prefix . $method, $args);
if ($return) {
return $this->getResponse();
} else {
throw new Exception($this->getErrorMessage(), $this->getErrorCode());
}
}
/**
* 获得返回值
*
* @return mixed
*/
public function getResponse()
{
// methodResponses can only have one param - return that
return $this->message->params[0];
}
/**
* 是否为错误
*
* @return bool
*/
public function isError(): bool
{
return isset($this->error);
}
/**
* 获取错误代码
*
* @return int
*/
private function getErrorCode(): int
{
return $this->error->code;
}
/**
* 获取错误消息
*
* @return string
*/
private function getErrorMessage(): string
{
return $this->error->message;
}
}