blob: 273202f2df3ff552d1023e0d241d0ce3f6c729ce [file] [log] [blame]
Georg Brandl38eceaa2008-05-26 11:14:17 +00001"""XML-RPC Servers.
Fredrik Lundhb329b712001-09-17 17:35:21 +00002
3This module can be used to create simple XML-RPC servers
4by creating a server and either installing functions, a
Martin v. Löwisd69663d2003-01-15 11:37:23 +00005class instance, or by extending the SimpleXMLRPCServer
Fredrik Lundhb329b712001-09-17 17:35:21 +00006class.
7
Martin v. Löwisd69663d2003-01-15 11:37:23 +00008It can also be used to handle XML-RPC requests in a CGI
9environment using CGIXMLRPCRequestHandler.
10
Georg Brandl38eceaa2008-05-26 11:14:17 +000011The Doc* classes can be used to create XML-RPC servers that
12serve pydoc-style documentation in response to HTTP
13GET requests. This documentation is dynamically generated
14based on the functions and methods registered with the
15server.
16
Fredrik Lundhb329b712001-09-17 17:35:21 +000017A list of possible usage patterns follows:
18
191. Install functions:
20
21server = SimpleXMLRPCServer(("localhost", 8000))
22server.register_function(pow)
23server.register_function(lambda x,y: x+y, 'add')
24server.serve_forever()
25
262. Install an instance:
27
28class MyFuncs:
29 def __init__(self):
Neal Norwitz9d72bb42007-04-17 08:48:32 +000030 # make all of the sys functions available through sys.func_name
31 import sys
32 self.sys = sys
Martin v. Löwisd69663d2003-01-15 11:37:23 +000033 def _listMethods(self):
34 # implement this method so that system.listMethods
Neal Norwitz9d72bb42007-04-17 08:48:32 +000035 # knows to advertise the sys methods
Martin v. Löwisd69663d2003-01-15 11:37:23 +000036 return list_public_methods(self) + \
Neal Norwitz9d72bb42007-04-17 08:48:32 +000037 ['sys.' + method for method in list_public_methods(self.sys)]
Fredrik Lundhb329b712001-09-17 17:35:21 +000038 def pow(self, x, y): return pow(x, y)
39 def add(self, x, y) : return x + y
Tim Peters2c60f7a2003-01-29 03:49:43 +000040
Fredrik Lundhb329b712001-09-17 17:35:21 +000041server = SimpleXMLRPCServer(("localhost", 8000))
Martin v. Löwisd69663d2003-01-15 11:37:23 +000042server.register_introspection_functions()
Fredrik Lundhb329b712001-09-17 17:35:21 +000043server.register_instance(MyFuncs())
44server.serve_forever()
45
463. Install an instance with custom dispatch method:
47
48class Math:
Martin v. Löwisd69663d2003-01-15 11:37:23 +000049 def _listMethods(self):
50 # this method must be present for system.listMethods
51 # to work
52 return ['add', 'pow']
53 def _methodHelp(self, method):
54 # this method must be present for system.methodHelp
55 # to work
56 if method == 'add':
57 return "add(2,3) => 5"
58 elif method == 'pow':
59 return "pow(x, y[, z]) => number"
60 else:
61 # By convention, return empty
62 # string if no help is available
63 return ""
Fredrik Lundhb329b712001-09-17 17:35:21 +000064 def _dispatch(self, method, params):
65 if method == 'pow':
Martin v. Löwisd69663d2003-01-15 11:37:23 +000066 return pow(*params)
Fredrik Lundhb329b712001-09-17 17:35:21 +000067 elif method == 'add':
68 return params[0] + params[1]
69 else:
70 raise 'bad method'
Martin v. Löwisd69663d2003-01-15 11:37:23 +000071
Fredrik Lundhb329b712001-09-17 17:35:21 +000072server = SimpleXMLRPCServer(("localhost", 8000))
Martin v. Löwisd69663d2003-01-15 11:37:23 +000073server.register_introspection_functions()
Fredrik Lundhb329b712001-09-17 17:35:21 +000074server.register_instance(Math())
75server.serve_forever()
76
Martin v. Löwisd69663d2003-01-15 11:37:23 +0000774. Subclass SimpleXMLRPCServer:
Fredrik Lundhb329b712001-09-17 17:35:21 +000078
Martin v. Löwisd69663d2003-01-15 11:37:23 +000079class MathServer(SimpleXMLRPCServer):
Fredrik Lundhb329b712001-09-17 17:35:21 +000080 def _dispatch(self, method, params):
81 try:
82 # We are forcing the 'export_' prefix on methods that are
83 # callable through XML-RPC to prevent potential security
84 # problems
85 func = getattr(self, 'export_' + method)
86 except AttributeError:
87 raise Exception('method "%s" is not supported' % method)
88 else:
Martin v. Löwisd69663d2003-01-15 11:37:23 +000089 return func(*params)
Fredrik Lundhb329b712001-09-17 17:35:21 +000090
91 def export_add(self, x, y):
92 return x + y
93
Martin v. Löwisd69663d2003-01-15 11:37:23 +000094server = MathServer(("localhost", 8000))
Fredrik Lundhb329b712001-09-17 17:35:21 +000095server.serve_forever()
Martin v. Löwisd69663d2003-01-15 11:37:23 +000096
975. CGI script:
98
99server = CGIXMLRPCRequestHandler()
100server.register_function(pow)
101server.handle_request()
Fredrik Lundhb329b712001-09-17 17:35:21 +0000102"""
103
104# Written by Brian Quinlan (brian@sweetapp.com).
105# Based on code written by Fredrik Lundh.
106
Kristján Valur Jónsson985fc6a2009-07-01 10:01:31 +0000107from xmlrpc.client import Fault, dumps, loads, gzip_encode, gzip_decode
Georg Brandl24420152008-05-26 16:32:26 +0000108from http.server import BaseHTTPRequestHandler
109import http.server
Alexandre Vassalottice261952008-05-12 02:31:37 +0000110import socketserver
Fredrik Lundhb329b712001-09-17 17:35:21 +0000111import sys
Thomas Wouters49fd7fa2006-04-21 10:40:58 +0000112import os
Georg Brandl38eceaa2008-05-26 11:14:17 +0000113import re
114import pydoc
115import inspect
Guido van Rossum61e21b52007-08-20 19:06:03 +0000116import traceback
Thomas Wouters49fd7fa2006-04-21 10:40:58 +0000117try:
118 import fcntl
119except ImportError:
120 fcntl = None
Fredrik Lundhb329b712001-09-17 17:35:21 +0000121
Guido van Rossumd0641422005-02-03 15:01:24 +0000122def resolve_dotted_attribute(obj, attr, allow_dotted_names=True):
Martin v. Löwisd69663d2003-01-15 11:37:23 +0000123 """resolve_dotted_attribute(a, 'b.c.d') => a.b.c.d
Fredrik Lundhb329b712001-09-17 17:35:21 +0000124
Martin v. Löwisd69663d2003-01-15 11:37:23 +0000125 Resolves a dotted attribute name to an object. Raises
126 an AttributeError if any attribute in the chain starts with a '_'.
Guido van Rossumd0641422005-02-03 15:01:24 +0000127
128 If the optional allow_dotted_names argument is false, dots are not
129 supported and this function operates similar to getattr(obj, attr).
Fredrik Lundhb329b712001-09-17 17:35:21 +0000130 """
131
Guido van Rossumd0641422005-02-03 15:01:24 +0000132 if allow_dotted_names:
133 attrs = attr.split('.')
134 else:
135 attrs = [attr]
136
137 for i in attrs:
Martin v. Löwisd69663d2003-01-15 11:37:23 +0000138 if i.startswith('_'):
139 raise AttributeError(
140 'attempt to access private attribute "%s"' % i
141 )
142 else:
143 obj = getattr(obj,i)
144 return obj
Fredrik Lundhb329b712001-09-17 17:35:21 +0000145
Martin v. Löwisd69663d2003-01-15 11:37:23 +0000146def list_public_methods(obj):
147 """Returns a list of attribute strings, found in the specified
148 object, which represent callable attributes"""
149
150 return [member for member in dir(obj)
151 if not member.startswith('_') and
Guido van Rossumd59da4b2007-05-22 18:11:13 +0000152 hasattr(getattr(obj, member), '__call__')]
Martin v. Löwisd69663d2003-01-15 11:37:23 +0000153
Martin v. Löwisd69663d2003-01-15 11:37:23 +0000154class SimpleXMLRPCDispatcher:
155 """Mix-in class that dispatches XML-RPC requests.
156
157 This class is used to register XML-RPC method handlers
158 and then to dispatch them. There should never be any
159 reason to instantiate this class directly.
160 """
Tim Peters2c60f7a2003-01-29 03:49:43 +0000161
Matthias Klosea3d29e82009-04-07 13:13:10 +0000162 def __init__(self, allow_none=False, encoding=None):
Martin v. Löwisd69663d2003-01-15 11:37:23 +0000163 self.funcs = {}
164 self.instance = None
Andrew M. Kuchling10a16de2005-12-04 16:34:40 +0000165 self.allow_none = allow_none
Senthil Kumaranb3af08f2009-04-01 20:20:43 +0000166 self.encoding = encoding or 'utf-8'
Martin v. Löwisd69663d2003-01-15 11:37:23 +0000167
Guido van Rossumd0641422005-02-03 15:01:24 +0000168 def register_instance(self, instance, allow_dotted_names=False):
Martin v. Löwisd69663d2003-01-15 11:37:23 +0000169 """Registers an instance to respond to XML-RPC requests.
170
171 Only one instance can be installed at a time.
172
173 If the registered instance has a _dispatch method then that
174 method will be called with the name of the XML-RPC method and
Georg Brandl7eb4b7d2005-07-22 21:49:32 +0000175 its parameters as a tuple
Martin v. Löwisd69663d2003-01-15 11:37:23 +0000176 e.g. instance._dispatch('add',(2,3))
177
178 If the registered instance does not have a _dispatch method
179 then the instance will be searched to find a matching method
180 and, if found, will be called. Methods beginning with an '_'
181 are considered private and will not be called by
182 SimpleXMLRPCServer.
183
184 If a registered function matches a XML-RPC request, then it
185 will be called instead of the registered instance.
Guido van Rossumd0641422005-02-03 15:01:24 +0000186
187 If the optional allow_dotted_names argument is true and the
188 instance does not have a _dispatch method, method names
189 containing dots are supported and resolved, as long as none of
190 the name segments start with an '_'.
191
192 *** SECURITY WARNING: ***
193
194 Enabling the allow_dotted_names options allows intruders
195 to access your module's global variables and may allow
196 intruders to execute arbitrary code on your machine. Only
197 use this option on a secure, closed network.
198
Fredrik Lundhb329b712001-09-17 17:35:21 +0000199 """
200
Martin v. Löwisd69663d2003-01-15 11:37:23 +0000201 self.instance = instance
Guido van Rossumd0641422005-02-03 15:01:24 +0000202 self.allow_dotted_names = allow_dotted_names
Martin v. Löwisd69663d2003-01-15 11:37:23 +0000203
204 def register_function(self, function, name = None):
205 """Registers a function to respond to XML-RPC requests.
206
207 The optional name argument can be used to set a Unicode name
208 for the function.
209 """
210
211 if name is None:
212 name = function.__name__
213 self.funcs[name] = function
214
215 def register_introspection_functions(self):
216 """Registers the XML-RPC introspection methods in the system
217 namespace.
218
219 see http://xmlrpc.usefulinc.com/doc/reserved.html
220 """
Tim Peters2c60f7a2003-01-29 03:49:43 +0000221
Martin v. Löwisd69663d2003-01-15 11:37:23 +0000222 self.funcs.update({'system.listMethods' : self.system_listMethods,
223 'system.methodSignature' : self.system_methodSignature,
224 'system.methodHelp' : self.system_methodHelp})
225
226 def register_multicall_functions(self):
227 """Registers the XML-RPC multicall method in the system
228 namespace.
229
230 see http://www.xmlrpc.com/discuss/msgReader$1208"""
Tim Peters2c60f7a2003-01-29 03:49:43 +0000231
Martin v. Löwisd69663d2003-01-15 11:37:23 +0000232 self.funcs.update({'system.multicall' : self.system_multicall})
Tim Peters2c60f7a2003-01-29 03:49:43 +0000233
Martin v. Löwisd69663d2003-01-15 11:37:23 +0000234 def _marshaled_dispatch(self, data, dispatch_method = None):
235 """Dispatches an XML-RPC method from marshalled (XML) data.
Tim Peters2c60f7a2003-01-29 03:49:43 +0000236
Martin v. Löwisd69663d2003-01-15 11:37:23 +0000237 XML-RPC methods are dispatched from the marshalled (XML) data
238 using the _dispatch method and the result is returned as
239 marshalled data. For backwards compatibility, a dispatch
Tim Peters2c60f7a2003-01-29 03:49:43 +0000240 function can be provided as an argument (see comment in
Martin v. Löwisd69663d2003-01-15 11:37:23 +0000241 SimpleXMLRPCRequestHandler.do_POST) but overriding the
242 existing method through subclassing is the prefered means
243 of changing method dispatch behavior.
244 """
Tim Peters2c60f7a2003-01-29 03:49:43 +0000245
Fredrik Lundhb329b712001-09-17 17:35:21 +0000246 try:
Georg Brandl38eceaa2008-05-26 11:14:17 +0000247 params, method = loads(data)
Thomas Wouters4d70c3d2006-06-08 14:42:34 +0000248
249 # generate response
Martin v. Löwisd69663d2003-01-15 11:37:23 +0000250 if dispatch_method is not None:
251 response = dispatch_method(method, params)
Tim Peters2c60f7a2003-01-29 03:49:43 +0000252 else:
Fredrik Lundhb329b712001-09-17 17:35:21 +0000253 response = self._dispatch(method, params)
Martin v. Löwisd69663d2003-01-15 11:37:23 +0000254 # wrap response in a singleton tuple
255 response = (response,)
Georg Brandl38eceaa2008-05-26 11:14:17 +0000256 response = dumps(response, methodresponse=1,
257 allow_none=self.allow_none, encoding=self.encoding)
Guido van Rossumb940e112007-01-10 16:19:56 +0000258 except Fault as fault:
Georg Brandl38eceaa2008-05-26 11:14:17 +0000259 response = dumps(fault, allow_none=self.allow_none,
260 encoding=self.encoding)
Fredrik Lundhb329b712001-09-17 17:35:21 +0000261 except:
Martin v. Löwisd69663d2003-01-15 11:37:23 +0000262 # report exception back to server
Thomas Wouters89f507f2006-12-13 04:49:30 +0000263 exc_type, exc_value, exc_tb = sys.exc_info()
Georg Brandl38eceaa2008-05-26 11:14:17 +0000264 response = dumps(
265 Fault(1, "%s:%s" % (exc_type, exc_value)),
Andrew M. Kuchling427aedb2005-12-04 17:13:12 +0000266 encoding=self.encoding, allow_none=self.allow_none,
Martin v. Löwisd69663d2003-01-15 11:37:23 +0000267 )
268
Senthil Kumaranb3af08f2009-04-01 20:20:43 +0000269 return response.encode(self.encoding)
Martin v. Löwisd69663d2003-01-15 11:37:23 +0000270
271 def system_listMethods(self):
272 """system.listMethods() => ['add', 'subtract', 'multiple']
273
274 Returns a list of the methods supported by the server."""
Tim Peters2c60f7a2003-01-29 03:49:43 +0000275
Hye-Shik Chang96042862007-08-19 10:49:11 +0000276 methods = set(self.funcs.keys())
Martin v. Löwisd69663d2003-01-15 11:37:23 +0000277 if self.instance is not None:
278 # Instance can implement _listMethod to return a list of
279 # methods
280 if hasattr(self.instance, '_listMethods'):
Hye-Shik Chang96042862007-08-19 10:49:11 +0000281 methods |= set(self.instance._listMethods())
Martin v. Löwisd69663d2003-01-15 11:37:23 +0000282 # if the instance has a _dispatch method then we
283 # don't have enough information to provide a list
284 # of methods
285 elif not hasattr(self.instance, '_dispatch'):
Hye-Shik Chang96042862007-08-19 10:49:11 +0000286 methods |= set(list_public_methods(self.instance))
287 return sorted(methods)
Tim Peters2c60f7a2003-01-29 03:49:43 +0000288
Martin v. Löwisd69663d2003-01-15 11:37:23 +0000289 def system_methodSignature(self, method_name):
290 """system.methodSignature('add') => [double, int, int]
291
Brett Cannonb9b5f162004-10-03 23:21:44 +0000292 Returns a list describing the signature of the method. In the
Martin v. Löwisd69663d2003-01-15 11:37:23 +0000293 above example, the add method takes two integers as arguments
294 and returns a double result.
295
296 This server does NOT support system.methodSignature."""
297
298 # See http://xmlrpc.usefulinc.com/doc/sysmethodsig.html
Tim Peters2c60f7a2003-01-29 03:49:43 +0000299
Martin v. Löwisd69663d2003-01-15 11:37:23 +0000300 return 'signatures not supported'
301
302 def system_methodHelp(self, method_name):
303 """system.methodHelp('add') => "Adds two integers together"
304
305 Returns a string containing documentation for the specified method."""
Tim Peters2c60f7a2003-01-29 03:49:43 +0000306
Martin v. Löwisd69663d2003-01-15 11:37:23 +0000307 method = None
Guido van Rossume2b70bc2006-08-18 22:13:04 +0000308 if method_name in self.funcs:
Martin v. Löwisd69663d2003-01-15 11:37:23 +0000309 method = self.funcs[method_name]
310 elif self.instance is not None:
311 # Instance can implement _methodHelp to return help for a method
312 if hasattr(self.instance, '_methodHelp'):
313 return self.instance._methodHelp(method_name)
314 # if the instance has a _dispatch method then we
315 # don't have enough information to provide help
316 elif not hasattr(self.instance, '_dispatch'):
317 try:
318 method = resolve_dotted_attribute(
319 self.instance,
Guido van Rossumd0641422005-02-03 15:01:24 +0000320 method_name,
321 self.allow_dotted_names
Martin v. Löwisd69663d2003-01-15 11:37:23 +0000322 )
323 except AttributeError:
324 pass
325
326 # Note that we aren't checking that the method actually
327 # be a callable object of some kind
328 if method is None:
329 return ""
Fredrik Lundhb329b712001-09-17 17:35:21 +0000330 else:
Neal Norwitz732911f2003-06-29 04:16:28 +0000331 import pydoc
Neal Norwitz3f401f02003-06-29 04:19:37 +0000332 return pydoc.getdoc(method)
Fredrik Lundhb329b712001-09-17 17:35:21 +0000333
Martin v. Löwisd69663d2003-01-15 11:37:23 +0000334 def system_multicall(self, call_list):
335 """system.multicall([{'methodName': 'add', 'params': [2, 2]}, ...]) => \
336[[4], ...]
Fredrik Lundhb329b712001-09-17 17:35:21 +0000337
Martin v. Löwisd69663d2003-01-15 11:37:23 +0000338 Allows the caller to package multiple XML-RPC calls into a single
339 request.
340
Tim Peters2c60f7a2003-01-29 03:49:43 +0000341 See http://www.xmlrpc.com/discuss/msgReader$1208
Martin v. Löwisd69663d2003-01-15 11:37:23 +0000342 """
Tim Peters2c60f7a2003-01-29 03:49:43 +0000343
Martin v. Löwisd69663d2003-01-15 11:37:23 +0000344 results = []
345 for call in call_list:
346 method_name = call['methodName']
347 params = call['params']
348
349 try:
350 # XXX A marshalling error in any response will fail the entire
351 # multicall. If someone cares they should fix this.
352 results.append([self._dispatch(method_name, params)])
Guido van Rossumb940e112007-01-10 16:19:56 +0000353 except Fault as fault:
Martin v. Löwisd69663d2003-01-15 11:37:23 +0000354 results.append(
355 {'faultCode' : fault.faultCode,
356 'faultString' : fault.faultString}
357 )
358 except:
Thomas Wouters89f507f2006-12-13 04:49:30 +0000359 exc_type, exc_value, exc_tb = sys.exc_info()
Martin v. Löwisd69663d2003-01-15 11:37:23 +0000360 results.append(
361 {'faultCode' : 1,
Thomas Wouters89f507f2006-12-13 04:49:30 +0000362 'faultString' : "%s:%s" % (exc_type, exc_value)}
Martin v. Löwisd69663d2003-01-15 11:37:23 +0000363 )
364 return results
Tim Peters2c60f7a2003-01-29 03:49:43 +0000365
Fredrik Lundhb329b712001-09-17 17:35:21 +0000366 def _dispatch(self, method, params):
367 """Dispatches the XML-RPC method.
368
369 XML-RPC calls are forwarded to a registered function that
370 matches the called XML-RPC method name. If no such function
371 exists then the call is forwarded to the registered instance,
372 if available.
373
374 If the registered instance has a _dispatch method then that
375 method will be called with the name of the XML-RPC method and
Georg Brandl7eb4b7d2005-07-22 21:49:32 +0000376 its parameters as a tuple
Fredrik Lundhb329b712001-09-17 17:35:21 +0000377 e.g. instance._dispatch('add',(2,3))
378
379 If the registered instance does not have a _dispatch method
380 then the instance will be searched to find a matching method
381 and, if found, will be called.
382
383 Methods beginning with an '_' are considered private and will
Martin v. Löwisd69663d2003-01-15 11:37:23 +0000384 not be called.
Fredrik Lundhb329b712001-09-17 17:35:21 +0000385 """
386
Fredrik Lundhb329b712001-09-17 17:35:21 +0000387 func = None
388 try:
389 # check to see if a matching function has been registered
Martin v. Löwisd69663d2003-01-15 11:37:23 +0000390 func = self.funcs[method]
Fredrik Lundhb329b712001-09-17 17:35:21 +0000391 except KeyError:
Martin v. Löwisd69663d2003-01-15 11:37:23 +0000392 if self.instance is not None:
Fredrik Lundhb329b712001-09-17 17:35:21 +0000393 # check for a _dispatch method
Martin v. Löwisd69663d2003-01-15 11:37:23 +0000394 if hasattr(self.instance, '_dispatch'):
395 return self.instance._dispatch(method, params)
Fredrik Lundhb329b712001-09-17 17:35:21 +0000396 else:
397 # call instance method directly
398 try:
Martin v. Löwisd69663d2003-01-15 11:37:23 +0000399 func = resolve_dotted_attribute(
400 self.instance,
Guido van Rossumd0641422005-02-03 15:01:24 +0000401 method,
402 self.allow_dotted_names
Fredrik Lundhb329b712001-09-17 17:35:21 +0000403 )
404 except AttributeError:
405 pass
406
407 if func is not None:
Martin v. Löwisd69663d2003-01-15 11:37:23 +0000408 return func(*params)
Fredrik Lundhb329b712001-09-17 17:35:21 +0000409 else:
410 raise Exception('method "%s" is not supported' % method)
Tim Peters2c60f7a2003-01-29 03:49:43 +0000411
Georg Brandl24420152008-05-26 16:32:26 +0000412class SimpleXMLRPCRequestHandler(BaseHTTPRequestHandler):
Martin v. Löwisd69663d2003-01-15 11:37:23 +0000413 """Simple XML-RPC request handler class.
Fredrik Lundhb329b712001-09-17 17:35:21 +0000414
Martin v. Löwisd69663d2003-01-15 11:37:23 +0000415 Handles all HTTP POST requests and attempts to decode them as
416 XML-RPC requests.
417 """
418
Thomas Wouters4d70c3d2006-06-08 14:42:34 +0000419 # Class attribute listing the accessible path components;
420 # paths not on this list will result in a 404 error.
421 rpc_paths = ('/', '/RPC2')
422
Kristján Valur Jónsson985fc6a2009-07-01 10:01:31 +0000423 #if not None, encode responses larger than this, if possible
424 encode_threshold = 1400 #a common MTU
425
426 #Override form StreamRequestHandler: full buffering of output
427 #and no Nagle.
428 wbufsize = -1
429 disable_nagle_algorithm = True
430
431 # a re to match a gzip Accept-Encoding
432 aepattern = re.compile(r"""
433 \s* ([^\s;]+) \s* #content-coding
434 (;\s* q \s*=\s* ([0-9\.]+))? #q
435 """, re.VERBOSE | re.IGNORECASE)
436
437 def accept_encodings(self):
438 r = {}
439 ae = self.headers.get("Accept-Encoding", "")
440 for e in ae.split(","):
441 match = self.aepattern.match(e)
442 if match:
443 v = match.group(3)
444 v = float(v) if v else 1.0
445 r[match.group(1)] = v
446 return r
447
Thomas Wouters4d70c3d2006-06-08 14:42:34 +0000448 def is_rpc_path_valid(self):
449 if self.rpc_paths:
450 return self.path in self.rpc_paths
451 else:
452 # If .rpc_paths is empty, just assume all paths are legal
453 return True
454
Martin v. Löwisd69663d2003-01-15 11:37:23 +0000455 def do_POST(self):
456 """Handles the HTTP POST request.
457
458 Attempts to interpret all HTTP POST requests as XML-RPC calls,
459 which are forwarded to the server's _dispatch method for handling.
460 """
Tim Peters2c60f7a2003-01-29 03:49:43 +0000461
Thomas Wouters4d70c3d2006-06-08 14:42:34 +0000462 # Check that the path is legal
463 if not self.is_rpc_path_valid():
464 self.report_404()
465 return
466
Martin v. Löwisd69663d2003-01-15 11:37:23 +0000467 try:
Tim Peters536cf992005-12-25 23:18:31 +0000468 # Get arguments by reading body of request.
469 # We read this in chunks to avoid straining
Andrew M. Kuchlinge63fde72005-12-04 15:36:57 +0000470 # socket.read(); around the 10 or 15Mb mark, some platforms
471 # begin to have problems (bug #792570).
472 max_chunk_size = 10*1024*1024
473 size_remaining = int(self.headers["content-length"])
474 L = []
475 while size_remaining:
476 chunk_size = min(size_remaining, max_chunk_size)
477 L.append(self.rfile.read(chunk_size))
478 size_remaining -= len(L[-1])
Hye-Shik Chang96042862007-08-19 10:49:11 +0000479 data = b''.join(L)
Andrew M. Kuchlinge63fde72005-12-04 15:36:57 +0000480
Kristján Valur Jónsson985fc6a2009-07-01 10:01:31 +0000481 data = self.decode_request_content(data)
482 if data is None:
483 return #response has been sent
484
Martin v. Löwisd69663d2003-01-15 11:37:23 +0000485 # In previous versions of SimpleXMLRPCServer, _dispatch
486 # could be overridden in this class, instead of in
487 # SimpleXMLRPCDispatcher. To maintain backwards compatibility,
488 # check to see if a subclass implements _dispatch and dispatch
489 # using that method if present.
490 response = self.server._marshaled_dispatch(
491 data, getattr(self, '_dispatch', None)
492 )
Guido van Rossum61e21b52007-08-20 19:06:03 +0000493 except Exception as e: # This should only happen if the module is buggy
Martin v. Löwisd69663d2003-01-15 11:37:23 +0000494 # internal error, report as HTTP server error
495 self.send_response(500)
Guido van Rossum61e21b52007-08-20 19:06:03 +0000496
497 # Send information about the exception if requested
498 if hasattr(self.server, '_send_traceback_header') and \
499 self.server._send_traceback_header:
500 self.send_header("X-exception", str(e))
501 self.send_header("X-traceback", traceback.format_exc())
502
Kristján Valur Jónsson985fc6a2009-07-01 10:01:31 +0000503 self.send_header("Content-length", "0")
Martin v. Löwisd69663d2003-01-15 11:37:23 +0000504 self.end_headers()
505 else:
Martin v. Löwisd69663d2003-01-15 11:37:23 +0000506 self.send_response(200)
507 self.send_header("Content-type", "text/xml")
Kristján Valur Jónsson985fc6a2009-07-01 10:01:31 +0000508 if self.encode_threshold is not None:
509 if len(response) > self.encode_threshold:
510 q = self.accept_encodings().get("gzip", 0)
511 if q:
512 response = gzip_encode(response)
513 self.send_header("Content-Encoding", "gzip")
Martin v. Löwisd69663d2003-01-15 11:37:23 +0000514 self.send_header("Content-length", str(len(response)))
515 self.end_headers()
516 self.wfile.write(response)
517
Kristján Valur Jónsson985fc6a2009-07-01 10:01:31 +0000518 def decode_request_content(self, data):
519 #support gzip encoding of request
520 encoding = self.headers.get("content-encoding", "identity").lower()
521 if encoding == "identity":
522 return data
523 if encoding == "gzip":
524 try:
525 return gzip_decode(data)
526 except ValueError:
527 self.send_response(400, "error decoding gzip content")
528 else:
529 self.send_response(501, "encoding %r not supported" % encoding)
530 self.send_header("Content-length", "0")
531 self.end_headers()
Tim Peters2c60f7a2003-01-29 03:49:43 +0000532
Thomas Wouters4d70c3d2006-06-08 14:42:34 +0000533 def report_404 (self):
534 # Report a 404 error
535 self.send_response(404)
Christian Heimes0aa93cd2007-12-08 18:38:20 +0000536 response = b'No such page'
Thomas Wouters4d70c3d2006-06-08 14:42:34 +0000537 self.send_header("Content-type", "text/plain")
538 self.send_header("Content-length", str(len(response)))
539 self.end_headers()
540 self.wfile.write(response)
Thomas Wouters4d70c3d2006-06-08 14:42:34 +0000541
Fredrik Lundhb329b712001-09-17 17:35:21 +0000542 def log_request(self, code='-', size='-'):
543 """Selectively log an accepted request."""
544
545 if self.server.logRequests:
Georg Brandl24420152008-05-26 16:32:26 +0000546 BaseHTTPRequestHandler.log_request(self, code, size)
Fredrik Lundhb329b712001-09-17 17:35:21 +0000547
Alexandre Vassalottice261952008-05-12 02:31:37 +0000548class SimpleXMLRPCServer(socketserver.TCPServer,
Martin v. Löwisd69663d2003-01-15 11:37:23 +0000549 SimpleXMLRPCDispatcher):
Fredrik Lundhb329b712001-09-17 17:35:21 +0000550 """Simple XML-RPC server.
551
552 Simple XML-RPC server that allows functions and a single instance
Martin v. Löwisd69663d2003-01-15 11:37:23 +0000553 to be installed to handle requests. The default implementation
554 attempts to dispatch XML-RPC calls to the functions or instance
555 installed in the server. Override the _dispatch method inhereted
556 from SimpleXMLRPCDispatcher to change this behavior.
Fredrik Lundhb329b712001-09-17 17:35:21 +0000557 """
558
Andrew M. Kuchling3a976052005-12-04 15:07:41 +0000559 allow_reuse_address = True
560
Guido van Rossum61e21b52007-08-20 19:06:03 +0000561 # Warning: this is for debugging purposes only! Never set this to True in
562 # production code, as will be sending out sensitive information (exception
563 # and stack trace details) when exceptions are raised inside
564 # SimpleXMLRPCRequestHandler.do_POST
565 _send_traceback_header = False
566
Fredrik Lundhb329b712001-09-17 17:35:21 +0000567 def __init__(self, addr, requestHandler=SimpleXMLRPCRequestHandler,
Guido van Rossumd8faa362007-04-27 19:54:29 +0000568 logRequests=True, allow_none=False, encoding=None, bind_and_activate=True):
Fredrik Lundhb329b712001-09-17 17:35:21 +0000569 self.logRequests = logRequests
Tim Peters2c60f7a2003-01-29 03:49:43 +0000570
Andrew M. Kuchling427aedb2005-12-04 17:13:12 +0000571 SimpleXMLRPCDispatcher.__init__(self, allow_none, encoding)
Alexandre Vassalottice261952008-05-12 02:31:37 +0000572 socketserver.TCPServer.__init__(self, addr, requestHandler, bind_and_activate)
Tim Peters2c60f7a2003-01-29 03:49:43 +0000573
Tim Peters536cf992005-12-25 23:18:31 +0000574 # [Bug #1222790] If possible, set close-on-exec flag; if a
575 # method spawns a subprocess, the subprocess shouldn't have
Andrew M. Kuchling3a976052005-12-04 15:07:41 +0000576 # the listening socket open.
Thomas Wouters49fd7fa2006-04-21 10:40:58 +0000577 if fcntl is not None and hasattr(fcntl, 'FD_CLOEXEC'):
Andrew M. Kuchling3a976052005-12-04 15:07:41 +0000578 flags = fcntl.fcntl(self.fileno(), fcntl.F_GETFD)
579 flags |= fcntl.FD_CLOEXEC
580 fcntl.fcntl(self.fileno(), fcntl.F_SETFD, flags)
581
Martin v. Löwisd69663d2003-01-15 11:37:23 +0000582class CGIXMLRPCRequestHandler(SimpleXMLRPCDispatcher):
583 """Simple handler for XML-RPC data passed through CGI."""
Tim Peters2c60f7a2003-01-29 03:49:43 +0000584
Andrew M. Kuchling427aedb2005-12-04 17:13:12 +0000585 def __init__(self, allow_none=False, encoding=None):
586 SimpleXMLRPCDispatcher.__init__(self, allow_none, encoding)
Fredrik Lundhb329b712001-09-17 17:35:21 +0000587
Martin v. Löwisd69663d2003-01-15 11:37:23 +0000588 def handle_xmlrpc(self, request_text):
589 """Handle a single XML-RPC request"""
Tim Peters2c60f7a2003-01-29 03:49:43 +0000590
Martin v. Löwisd69663d2003-01-15 11:37:23 +0000591 response = self._marshaled_dispatch(request_text)
Tim Peters2c60f7a2003-01-29 03:49:43 +0000592
Guido van Rossumbe19ed72007-02-09 05:37:30 +0000593 print('Content-Type: text/xml')
594 print('Content-Length: %d' % len(response))
595 print()
Senthil Kumaranb3af08f2009-04-01 20:20:43 +0000596 sys.stdout.flush()
597 sys.stdout.buffer.write(response)
598 sys.stdout.buffer.flush()
Fredrik Lundhb329b712001-09-17 17:35:21 +0000599
Martin v. Löwisd69663d2003-01-15 11:37:23 +0000600 def handle_get(self):
601 """Handle a single HTTP GET request.
Fredrik Lundhb329b712001-09-17 17:35:21 +0000602
Martin v. Löwisd69663d2003-01-15 11:37:23 +0000603 Default implementation indicates an error because
604 XML-RPC uses the POST method.
Fredrik Lundhb329b712001-09-17 17:35:21 +0000605 """
606
Martin v. Löwisd69663d2003-01-15 11:37:23 +0000607 code = 400
Georg Brandl24420152008-05-26 16:32:26 +0000608 message, explain = BaseHTTPRequestHandler.responses[code]
Tim Peters2c60f7a2003-01-29 03:49:43 +0000609
Georg Brandl24420152008-05-26 16:32:26 +0000610 response = http.server.DEFAULT_ERROR_MESSAGE % \
Martin v. Löwisd69663d2003-01-15 11:37:23 +0000611 {
Tim Peters2c60f7a2003-01-29 03:49:43 +0000612 'code' : code,
613 'message' : message,
Martin v. Löwisd69663d2003-01-15 11:37:23 +0000614 'explain' : explain
615 }
Senthil Kumaranb3af08f2009-04-01 20:20:43 +0000616 response = response.encode('utf-8')
Guido van Rossumbe19ed72007-02-09 05:37:30 +0000617 print('Status: %d %s' % (code, message))
Senthil Kumaranb3af08f2009-04-01 20:20:43 +0000618 print('Content-Type: %s' % http.server.DEFAULT_ERROR_CONTENT_TYPE)
Guido van Rossumbe19ed72007-02-09 05:37:30 +0000619 print('Content-Length: %d' % len(response))
620 print()
Senthil Kumaranb3af08f2009-04-01 20:20:43 +0000621 sys.stdout.flush()
622 sys.stdout.buffer.write(response)
623 sys.stdout.buffer.flush()
Tim Peters2c60f7a2003-01-29 03:49:43 +0000624
Martin v. Löwisd69663d2003-01-15 11:37:23 +0000625 def handle_request(self, request_text = None):
626 """Handle a single XML-RPC request passed through a CGI post method.
Tim Peters2c60f7a2003-01-29 03:49:43 +0000627
Martin v. Löwisd69663d2003-01-15 11:37:23 +0000628 If no XML data is given then it is read from stdin. The resulting
629 XML-RPC response is printed to stdout along with the correct HTTP
630 headers.
Fredrik Lundhb329b712001-09-17 17:35:21 +0000631 """
Tim Peters2c60f7a2003-01-29 03:49:43 +0000632
Martin v. Löwisd69663d2003-01-15 11:37:23 +0000633 if request_text is None and \
634 os.environ.get('REQUEST_METHOD', None) == 'GET':
635 self.handle_get()
636 else:
637 # POST data is normally available through stdin
Georg Brandl99412e52009-04-01 04:27:47 +0000638 try:
639 length = int(os.environ.get('CONTENT_LENGTH', None))
Georg Brandlc7485062009-04-01 15:53:15 +0000640 except (ValueError, TypeError):
Georg Brandl99412e52009-04-01 04:27:47 +0000641 length = -1
Martin v. Löwisd69663d2003-01-15 11:37:23 +0000642 if request_text is None:
Georg Brandl99412e52009-04-01 04:27:47 +0000643 request_text = sys.stdin.read(length)
Fredrik Lundhb329b712001-09-17 17:35:21 +0000644
Martin v. Löwisd69663d2003-01-15 11:37:23 +0000645 self.handle_xmlrpc(request_text)
Tim Peters2c60f7a2003-01-29 03:49:43 +0000646
Georg Brandl38eceaa2008-05-26 11:14:17 +0000647
648# -----------------------------------------------------------------------------
649# Self documenting XML-RPC Server.
650
651class ServerHTMLDoc(pydoc.HTMLDoc):
652 """Class used to generate pydoc HTML document for a server"""
653
654 def markup(self, text, escape=None, funcs={}, classes={}, methods={}):
655 """Mark up some plain text, given a context of symbols to look for.
656 Each context dictionary maps object names to anchor names."""
657 escape = escape or self.escape
658 results = []
659 here = 0
660
661 # XXX Note that this regular expression does not allow for the
662 # hyperlinking of arbitrary strings being used as method
663 # names. Only methods with names consisting of word characters
664 # and '.'s are hyperlinked.
665 pattern = re.compile(r'\b((http|ftp)://\S+[\w/]|'
666 r'RFC[- ]?(\d+)|'
667 r'PEP[- ]?(\d+)|'
668 r'(self\.)?((?:\w|\.)+))\b')
669 while 1:
670 match = pattern.search(text, here)
671 if not match: break
672 start, end = match.span()
673 results.append(escape(text[here:start]))
674
675 all, scheme, rfc, pep, selfdot, name = match.groups()
676 if scheme:
677 url = escape(all).replace('"', '"')
678 results.append('<a href="%s">%s</a>' % (url, url))
679 elif rfc:
680 url = 'http://www.rfc-editor.org/rfc/rfc%d.txt' % int(rfc)
681 results.append('<a href="%s">%s</a>' % (url, escape(all)))
682 elif pep:
683 url = 'http://www.python.org/dev/peps/pep-%04d/' % int(pep)
684 results.append('<a href="%s">%s</a>' % (url, escape(all)))
685 elif text[end:end+1] == '(':
686 results.append(self.namelink(name, methods, funcs, classes))
687 elif selfdot:
688 results.append('self.<strong>%s</strong>' % name)
689 else:
690 results.append(self.namelink(name, classes))
691 here = end
692 results.append(escape(text[here:]))
693 return ''.join(results)
694
695 def docroutine(self, object, name, mod=None,
696 funcs={}, classes={}, methods={}, cl=None):
697 """Produce HTML documentation for a function or method object."""
698
699 anchor = (cl and cl.__name__ or '') + '-' + name
700 note = ''
701
702 title = '<a name="%s"><strong>%s</strong></a>' % (
703 self.escape(anchor), self.escape(name))
704
705 if inspect.ismethod(object):
706 args, varargs, varkw, defaults = inspect.getargspec(object)
707 # exclude the argument bound to the instance, it will be
708 # confusing to the non-Python user
709 argspec = inspect.formatargspec (
710 args[1:],
711 varargs,
712 varkw,
713 defaults,
714 formatvalue=self.formatvalue
715 )
716 elif inspect.isfunction(object):
717 args, varargs, varkw, defaults = inspect.getargspec(object)
718 argspec = inspect.formatargspec(
719 args, varargs, varkw, defaults, formatvalue=self.formatvalue)
720 else:
721 argspec = '(...)'
722
723 if isinstance(object, tuple):
724 argspec = object[0] or argspec
725 docstring = object[1] or ""
726 else:
727 docstring = pydoc.getdoc(object)
728
729 decl = title + argspec + (note and self.grey(
730 '<font face="helvetica, arial">%s</font>' % note))
731
732 doc = self.markup(
733 docstring, self.preformat, funcs, classes, methods)
734 doc = doc and '<dd><tt>%s</tt></dd>' % doc
735 return '<dl><dt>%s</dt>%s</dl>\n' % (decl, doc)
736
737 def docserver(self, server_name, package_documentation, methods):
738 """Produce HTML documentation for an XML-RPC server."""
739
740 fdict = {}
741 for key, value in methods.items():
742 fdict[key] = '#-' + key
743 fdict[value] = fdict[key]
744
745 server_name = self.escape(server_name)
746 head = '<big><big><strong>%s</strong></big></big>' % server_name
747 result = self.heading(head, '#ffffff', '#7799ee')
748
749 doc = self.markup(package_documentation, self.preformat, fdict)
750 doc = doc and '<tt>%s</tt>' % doc
751 result = result + '<p>%s</p>\n' % doc
752
753 contents = []
754 method_items = sorted(methods.items())
755 for key, value in method_items:
756 contents.append(self.docroutine(value, key, funcs=fdict))
757 result = result + self.bigsection(
758 'Methods', '#ffffff', '#eeaa77', ''.join(contents))
759
760 return result
761
762class XMLRPCDocGenerator:
763 """Generates documentation for an XML-RPC server.
764
765 This class is designed as mix-in and should not
766 be constructed directly.
767 """
768
769 def __init__(self):
770 # setup variables used for HTML documentation
771 self.server_name = 'XML-RPC Server Documentation'
772 self.server_documentation = \
773 "This server exports the following methods through the XML-RPC "\
774 "protocol."
775 self.server_title = 'XML-RPC Server Documentation'
776
777 def set_server_title(self, server_title):
778 """Set the HTML title of the generated server documentation"""
779
780 self.server_title = server_title
781
782 def set_server_name(self, server_name):
783 """Set the name of the generated HTML server documentation"""
784
785 self.server_name = server_name
786
787 def set_server_documentation(self, server_documentation):
788 """Set the documentation string for the entire server."""
789
790 self.server_documentation = server_documentation
791
792 def generate_html_documentation(self):
793 """generate_html_documentation() => html documentation for the server
794
795 Generates HTML documentation for the server using introspection for
796 installed functions and instances that do not implement the
797 _dispatch method. Alternatively, instances can choose to implement
798 the _get_method_argstring(method_name) method to provide the
799 argument string used in the documentation and the
800 _methodHelp(method_name) method to provide the help text used
801 in the documentation."""
802
803 methods = {}
804
805 for method_name in self.system_listMethods():
806 if method_name in self.funcs:
807 method = self.funcs[method_name]
808 elif self.instance is not None:
809 method_info = [None, None] # argspec, documentation
810 if hasattr(self.instance, '_get_method_argstring'):
811 method_info[0] = self.instance._get_method_argstring(method_name)
812 if hasattr(self.instance, '_methodHelp'):
813 method_info[1] = self.instance._methodHelp(method_name)
814
815 method_info = tuple(method_info)
816 if method_info != (None, None):
817 method = method_info
818 elif not hasattr(self.instance, '_dispatch'):
819 try:
820 method = resolve_dotted_attribute(
821 self.instance,
822 method_name
823 )
824 except AttributeError:
825 method = method_info
826 else:
827 method = method_info
828 else:
829 assert 0, "Could not find method in self.functions and no "\
830 "instance installed"
831
832 methods[method_name] = method
833
834 documenter = ServerHTMLDoc()
835 documentation = documenter.docserver(
836 self.server_name,
837 self.server_documentation,
838 methods
839 )
840
841 return documenter.page(self.server_title, documentation)
842
843class DocXMLRPCRequestHandler(SimpleXMLRPCRequestHandler):
844 """XML-RPC and documentation request handler class.
845
846 Handles all HTTP POST requests and attempts to decode them as
847 XML-RPC requests.
848
849 Handles all HTTP GET requests and interprets them as requests
850 for documentation.
851 """
852
853 def do_GET(self):
854 """Handles the HTTP GET request.
855
856 Interpret all HTTP GET requests as requests for server
857 documentation.
858 """
859 # Check that the path is legal
860 if not self.is_rpc_path_valid():
861 self.report_404()
862 return
863
Senthil Kumaranb3af08f2009-04-01 20:20:43 +0000864 response = self.server.generate_html_documentation().encode('utf-8')
Georg Brandl38eceaa2008-05-26 11:14:17 +0000865 self.send_response(200)
866 self.send_header("Content-type", "text/html")
867 self.send_header("Content-length", str(len(response)))
868 self.end_headers()
Senthil Kumaranb3af08f2009-04-01 20:20:43 +0000869 self.wfile.write(response)
Georg Brandl38eceaa2008-05-26 11:14:17 +0000870
Georg Brandl38eceaa2008-05-26 11:14:17 +0000871class DocXMLRPCServer( SimpleXMLRPCServer,
872 XMLRPCDocGenerator):
873 """XML-RPC and HTML documentation server.
874
875 Adds the ability to serve server documentation to the capabilities
876 of SimpleXMLRPCServer.
877 """
878
879 def __init__(self, addr, requestHandler=DocXMLRPCRequestHandler,
880 logRequests=1, allow_none=False, encoding=None,
881 bind_and_activate=True):
882 SimpleXMLRPCServer.__init__(self, addr, requestHandler, logRequests,
883 allow_none, encoding, bind_and_activate)
884 XMLRPCDocGenerator.__init__(self)
885
886class DocCGIXMLRPCRequestHandler( CGIXMLRPCRequestHandler,
887 XMLRPCDocGenerator):
888 """Handler for XML-RPC data and documentation requests passed through
889 CGI"""
890
891 def handle_get(self):
892 """Handles the HTTP GET request.
893
894 Interpret all HTTP GET requests as requests for server
895 documentation.
896 """
897
Senthil Kumaranb3af08f2009-04-01 20:20:43 +0000898 response = self.generate_html_documentation().encode('utf-8')
Georg Brandl38eceaa2008-05-26 11:14:17 +0000899
900 print('Content-Type: text/html')
901 print('Content-Length: %d' % len(response))
902 print()
Senthil Kumaranb3af08f2009-04-01 20:20:43 +0000903 sys.stdout.flush()
904 sys.stdout.buffer.write(response)
905 sys.stdout.buffer.flush()
Georg Brandl38eceaa2008-05-26 11:14:17 +0000906
907 def __init__(self):
908 CGIXMLRPCRequestHandler.__init__(self)
909 XMLRPCDocGenerator.__init__(self)
910
911
Fredrik Lundhb329b712001-09-17 17:35:21 +0000912if __name__ == '__main__':
Guido van Rossumbe19ed72007-02-09 05:37:30 +0000913 print('Running XML-RPC server on port 8000')
Fredrik Lundhb329b712001-09-17 17:35:21 +0000914 server = SimpleXMLRPCServer(("localhost", 8000))
915 server.register_function(pow)
916 server.register_function(lambda x,y: x+y, 'add')
917 server.serve_forever()