1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
|
<?php
/**
* The Horde_RPC_xmlrpc class provides an XMLRPC implementation of the
* Horde RPC system.
*
* $Horde: framework/RPC/RPC/xmlrpc.php,v 1.9.10.8 2006/07/01 04:54:16 chuck Exp $
*
* Copyright 2002-2006 Jan Schneider <jan@horde.org>
*
* See the enclosed file COPYING for license information (LGPL). If you
* did not receive this file, see http://www.fsf.org/copyleft/lgpl.html.
*
* @author Jan Schneider <jan@horde.org>
* @since Horde 3.0
* @package Horde_RPC
*/
class Horde_RPC_xmlrpc extends Horde_RPC {
/**
* Resource handler for the XMLRPC server.
*
* @var resource
*/
var $_server;
/**
* XMLRPC server constructor
*
* @access private
*/
function Horde_RPC_xmlrpc()
{
parent::Horde_RPC();
$this->_server = xmlrpc_server_create();
foreach ($GLOBALS['registry']->listMethods() as $method) {
xmlrpc_server_register_method($this->_server, str_replace('/', '.', $method), array('Horde_RPC_xmlrpc', '_dispatcher'));
}
}
/**
* Cleans up the RPC server.
*/
function shutdown()
{
xmlrpc_server_destroy($this->_server);
}
/**
* Sends an RPC request to the server and returns the result.
*
* @param string The raw request string.
*
* @return string The XML encoded response from the server.
*/
function getResponse($request)
{
$response = null;
return xmlrpc_server_call_method($this->_server, $request, $response);
}
/**
* Will be registered as the handler for all available methods
* and will call the appropriate function through the registry.
*
* @access private
*
* @param string $method The name of the method called by the RPC request.
* @param array $params The passed parameters.
* @param mixed $data Unknown.
*
* @return mixed The result of the called registry method.
*/
function _dispatcher($method, $params, $data)
{
global $registry;
$method = str_replace('.', '/', $method);
if (!$registry->hasMethod($method)) {
return sprintf(_("Method \"%s\" is not defined"), $method);
}
$result = $registry->call($method, $params);
if (is_a($result, 'PEAR_Error')) {
$result = array('faultCode' => (int)$result->getCode(),
'faultString' => $result->getMessage());
}
return $result;
}
/**
* Builds an XMLRPC request and sends it to the XMLRPC server.
*
* This statically called method is actually the XMLRPC client.
*
* @param string $url The path to the XMLRPC server on the called host.
* @param string $method The method to call.
* @param array $params A hash containing any necessary parameters for
* the method call.
* @param $options Optional associative array of parameters which can be:
* user - Basic Auth username
* pass - Basic Auth password
* proxy_host - Proxy server host
* proxy_port - Proxy server port
* proxy_user - Proxy auth username
* proxy_pass - Proxy auth password
* timeout - Connection timeout in seconds.
* allowRedirects - Whether to follow redirects or not
* maxRedirects - Max number of redirects to follow
*
* @return mixed The returned result from the method or a PEAR
* error object on failure.
*/
function request($url, $method, $params = null, $options = array())
{
$options['method'] = 'POST';
$language = isset($GLOBALS['language']) ? $GLOBALS['language'] :
(isset($_SERVER['LANG']) ? $_SERVER['LANG'] : '');
if (!isset($options['timeout'])) {
$options['timeout'] = 5;
}
if (!isset($options['allowRedirects'])) {
$options['allowRedirects'] = true;
$options['maxRedirects'] = 3;
}
require_once 'HTTP/Request.php';
$http = &new HTTP_Request($url, $options);
if (!empty($language)) {
$http->addHeader('Accept-Language', $language);
}
$http->addHeader('User-Agent', 'Horde RPC client');
$http->addHeader('Content-Type', 'text/xml');
$http->addRawPostData(xmlrpc_encode_request($method, $params));
$result = $http->sendRequest();
if (is_a($result, 'PEAR_Error')) {
return $result;
} elseif ($http->getResponseCode() != 200) {
return PEAR::raiseError(_("Request couldn't be answered. Returned errorcode: ") . $http->getResponseCode(), 'horde.error');
} elseif (strpos($http->getResponseBody(), '<?xml') === false) {
return PEAR::raiseError(_("No valid XML data returned"), 'horde.error', null, null, $http->getResponseBody());
} else {
$response = @xmlrpc_decode(substr($http->getResponseBody(), strpos($http->getResponseBody(), '<?xml')));
if (is_array($response) && isset($response['faultString'])) {
return PEAR::raiseError($response['faultString'], 'horde.error');
} elseif (is_array($response) && isset($response[0]) &&
is_array($response[0]) && isset($response[0]['faultString'])) {
return PEAR::raiseError($response[0]['faultString'], 'horde.error');
}
return $response;
}
}
}
|
