1 from twisted.internet.protocol import ClientFactory
2 from twisted.protocols.http import HTTPClient
3 from twisted.internet.defer import Deferred
5 from xmlrpclib import loads, dumps
7 USER_AGENT = 'Python/Twisted XMLRPC 0.1'
8 class XMLRPCClient(HTTPClient):
9 def connectionMade(self):
10 payload = dumps(self.args, self.method)
11 self.sendCommand('POST', '/RPC2')
12 self.sendHeader('User-Agent', USER_AGENT)
13 self.sendHeader('Content-Type', 'text/xml')
14 self.sendHeader('Content-Length', len(payload))
16 self.transport.write(payload)
17 self.transport.write('\r\n')
19 def handleResponse(self, buf):
20 args, name = loads(buf)
21 apply(self.d.callback, args)
24 class XMLRPCClientFactory(ClientFactory):
25 def __init__(self, method, args, callback=None, errback=None):
30 self.d.addCallback(callback)
32 self.d.addErrback(errback)
34 def buildProtocol(self, addr):
36 prot.method = self.method