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
8 USER_AGENT = 'Python/Twisted XMLRPC 0.1'
9 class XMLRPCClient(HTTPClient):
10 def connectionMade(self):
11 payload = dumps(self.args, self.method)
12 self.sendCommand('POST', '/RPC2')
13 self.sendHeader('User-Agent', USER_AGENT)
14 self.sendHeader('Content-Type', 'text/xml')
15 self.sendHeader('Content-Length', len(payload))
17 self.transport.write(payload)
18 self.transport.write('\r\n')
20 def handleResponse(self, buf):
22 args, name = loads(buf)
24 print "response decode error: " + `e`
27 apply(self.d.callback, args)
29 class XMLRPCClientFactory(ClientFactory):
30 def __init__(self, method, args, callback=None, errback=None):
35 self.d.addCallback(callback)
37 self.d.addErrback(errback)
40 def buildProtocol(self, addr):
42 prot.method = self.method
47 def clientConnectionFailed(self, connector, reason):