130 lines
3.9 KiB
PHP
130 lines
3.9 KiB
PHP
<?php
|
|
/*
|
|
COPYRIGHT
|
|
|
|
Copyright 2007 Sergio Vaccaro <sergio@inservibile.org>
|
|
|
|
This file is part of JSON-RPC PHP.
|
|
|
|
JSON-RPC PHP is free software; you can redistribute it and/or modify
|
|
it under the terms of the GNU General Public License as published by
|
|
the Free Software Foundation; either version 2 of the License, or
|
|
(at your option) any later version.
|
|
|
|
JSON-RPC PHP is distributed in the hope that it will be useful,
|
|
but WITHOUT ANY WARRANTY; without even the implied warranty of
|
|
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
|
GNU General Public License for more details.
|
|
|
|
You should have received a copy of the GNU General Public License
|
|
along with JSON-RPC PHP; if not, write to the Free Software
|
|
Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA
|
|
*/
|
|
|
|
/**
|
|
* The object of this class are generic jsonRPC 1.0 clients
|
|
* http://json-rpc.org/wiki/specification
|
|
*
|
|
* @author sergio <jsonrpcphp@inservibile.org>
|
|
*/
|
|
class jsonRPCClient {
|
|
|
|
/**
|
|
* Debug state
|
|
*
|
|
* @var boolean
|
|
*/
|
|
private $debug;
|
|
private $debug_output = NULL;
|
|
|
|
/**
|
|
* The server URL
|
|
*
|
|
* @var string
|
|
*/
|
|
private $url;
|
|
/**
|
|
* The request id
|
|
*
|
|
* @var integer
|
|
*/
|
|
private $id;
|
|
|
|
/**
|
|
* Takes the connection parameters
|
|
*
|
|
* @param string $url
|
|
* @param boolean $debug
|
|
*/
|
|
public function __construct($url, $debug = false) {
|
|
$this->url = $url;
|
|
$this->debug = $debug;
|
|
$this->debug_output = '';
|
|
$this->id = rand(1, 100);
|
|
}
|
|
|
|
/**
|
|
* Fetch debug information
|
|
* @param none
|
|
* @return array Debug data
|
|
**/
|
|
public function getDebugData() {
|
|
if ($this->debug) return $this->debug_output;
|
|
return false;
|
|
}
|
|
|
|
/**
|
|
* Performs a jsonRCP request and gets the results as an array
|
|
*
|
|
* @param string $method
|
|
* @param array $params
|
|
* @return array
|
|
*/
|
|
public function __call($method, $params) {
|
|
if (!is_scalar($method)) throw new Exception('Method name has no scalar value');
|
|
|
|
if (is_array($params)) {
|
|
// no keys
|
|
$params = array_values($params);
|
|
} else {
|
|
throw new Exception('Params must be given as array');
|
|
}
|
|
|
|
// prepares the request
|
|
$request = array(
|
|
'method' => $method,
|
|
'params' => $params,
|
|
'id' => $this->id
|
|
);
|
|
$request = json_encode($request);
|
|
if ($this->debug) $this->debug_output[] = 'Request: '.$request;
|
|
|
|
// performs the HTTP POST
|
|
// extract information from URL for proper authentication
|
|
$url = parse_url($this->url);
|
|
$ch = curl_init($url['scheme'].'://'.$url['host'].':'.$url['port'].$url['path']);
|
|
curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
|
|
curl_setopt($ch, CURLOPT_HTTPHEADER, array('Content-type: application/json'));
|
|
curl_setopt($ch, CURLOPT_USERPWD, $url['user'] . ":" . $url['pass']);
|
|
curl_setopt($ch, CURLOPT_POST, true);
|
|
curl_setopt($ch, CURLOPT_POSTFIELDS, $request);
|
|
curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, 0);
|
|
// curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, 0);
|
|
$response = curl_exec($ch);
|
|
if (curl_errno($ch)) throw new Exception('RPC call failed: ' . curl_error($ch));
|
|
if ($this->debug) $this->debug_output[] = 'Response: ' . $response;
|
|
$response = json_decode($response, true);
|
|
$resultStatus = curl_getinfo($ch);
|
|
if ($resultStatus['http_code'] != '200') {
|
|
if ($resultStatus['http_code'] == '401') throw new Exception('RPC call did not return 200: Authentication failed');
|
|
throw new Exception('RPC call did not return 200: HTTP error: ' . $resultStatus['http_code'] . ' - JSON Response: [' . @$response['error']['code'] . '] ' . @$response['error']['message']);
|
|
}
|
|
curl_close($ch);
|
|
|
|
// final checks and return
|
|
if (!is_null($response['error']) || is_null($response)) throw new Exception('Response error or empty: ' . @$response['error']);
|
|
if ($response['id'] != $this->id) throw new Exception('Incorrect response id (request id: ' . $this->id . ', response id: ' . $response['id'] . ')');
|
|
return $response['result'];
|
|
}
|
|
}
|