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):
21 args, name = loads(buf)
23 print "response decode error: " + `e`
29 l.append({'host' : self.transport.getHost()[1]})
30 apply(self.d.callback, (l,))
32 class XMLRPCClientFactory(ClientFactory):
33 def __init__(self, method, args, callback=None, errback=None):
38 self.d.addCallback(callback)
40 self.d.addErrback(errback)
42 def buildProtocol(self, addr):
44 prot.method = self.method
49 def clientConnectionFailed(self, connector, reason):