[Python-checkins] CVS: python/dist/src/Demo/xmlrpc xmlrpc_handler.py,NONE,1.1 xmlrpcserver.py,NONE,1.1

2001年7月11日 10:42:23 -0700

Update of /cvsroot/python/python/dist/src/Demo/xmlrpc
In directory usw-pr-cvs1:/tmp/cvs-serv11351/Demo/xmlrpc
Added Files:
	xmlrpc_handler.py xmlrpcserver.py 
Log Message:
xmlrpclib for python 2.2; initial checkin
--- NEW FILE: xmlrpc_handler.py ---
#
# XML-RPC SERVER
# $Id: xmlrpc_handler.py,v 1.1 2001年07月11日 17:42:21 effbot Exp $
#
# an asynchronous XML-RPC server for Medusa
#
# written by Sam Rushing
#
# Based on "xmlrpcserver.py" by Fredrik Lundh (fredrik@pythonware.com)
#
import http_server
import xmlrpclib
import regex
import string
import sys
class xmlrpc_handler:
 def match (self, request):
 # Note: /RPC2 is not required by the spec, so you may override this method.
 if request.uri[:5] == '/RPC2':
 return 1
 else:
 return 0
 def handle_request (self, request):
 [path, params, query, fragment] = request.split_uri()
 if request.command in ('post', 'put'):
 request.collector = collector (self, request)
 else:
 request.error (400)
 def continue_request (self, data, request):
 params, method = xmlrpclib.loads (data)
 try:
 # generate response
 try:
 response = self.call (method, params)
 response = (response,)
 except:
 # report exception back to server
 response = xmlrpclib.dumps (
 xmlrpclib.Fault (1, "%s:%s" % (sys.exc_type, sys.exc_value))
 )
 else:
 response = xmlrpclib.dumps (response, methodresponse=1)
 except:
 # internal error, report as HTTP server error
 request.error (500)
 else:
 # got a valid XML RPC response
 request['Content-Type'] = 'text/xml'
 request.push (response)
 request.done()
 def call (self, method, params):
 # override this method to implement RPC methods
 raise "NotYetImplemented"
class collector:
 "gathers input for POST and PUT requests"
 def __init__ (self, handler, request):
 self.handler = handler
 self.request = request
 self.data = ''
 # make sure there's a content-length header
 cl = request.get_header ('content-length')
 if not cl:
 request.error (411)
 else:
 cl = string.atoi (cl)
 # using a 'numeric' terminator
 self.request.channel.set_terminator (cl)
 def collect_incoming_data (self, data):
 self.data = self.data + data
 def found_terminator (self):
 # set the terminator back to the default
 self.request.channel.set_terminator ('\r\n\r\n')
 self.handler.continue_request (self.data, self.request)
if __name__ == '__main__':
 class rpc_demo (xmlrpc_handler):
 def call (self, method, params):
 print 'method="%s" params=%s' % (method, params)
 return "Sure, that works"
 import asyncore
 import http_server
 hs = http_server.http_server ('', 8000)
 rpc = rpc_demo()
 hs.install_handler (rpc)
 asyncore.loop()
--- NEW FILE: xmlrpcserver.py ---
#
# XML-RPC SERVER
# $Id: xmlrpcserver.py,v 1.1 2001年07月11日 17:42:21 effbot Exp $
#
# a simple XML-RPC server for Python
#
# History:
# 1999年02月01日 fl added to xmlrpclib distribution
#
# written by Fredrik Lundh, January 1999.
#
# Copyright (c) 1999 by Secret Labs AB.
# Copyright (c) 1999 by Fredrik Lundh.
#
# fredrik@pythonware.com
# http://www.pythonware.com
#
# --------------------------------------------------------------------
# Permission to use, copy, modify, and distribute this software and
# its associated documentation for any purpose and without fee is
# hereby granted. This software is provided as is.
# --------------------------------------------------------------------
#
import SocketServer, BaseHTTPServer
import xmlrpclib
import sys
class RequestHandler(BaseHTTPServer.BaseHTTPRequestHandler):
 def do_POST(self):
 try:
 # get arguments
 data = self.rfile.read(int(self.headers["content-length"]))
 params, method = xmlrpclib.loads(data)
 # generate response
 try:
 response = self.call(method, params)
 # wrap response in a singleton tuple
 response = (response,)
 except:
 # report exception back to server
 response = xmlrpclib.dumps(
 xmlrpclib.Fault(1, "%s:%s" % (sys.exc_type, sys.exc_value))
 )
 else:
 response = xmlrpclib.dumps(
 response,
 methodresponse=1
 )
 except:
 # internal error, report as HTTP server error
 self.send_response(500)
 self.end_headers()
 else:
 # got a valid XML RPC response
 self.send_response(200)
 self.send_header("Content-type", "text/xml")
 self.send_header("Content-length", str(len(response)))
 self.end_headers()
 self.wfile.write(response)
 # shut down the connection (from Skip Montanaro)
 self.wfile.flush()
 self.connection.shutdown(1)
 def call(self, method, params):
 # override this method to implement RPC methods
 print "CALL", method, params
 return params
if __name__ == '__main__':
 server = SocketServer.TCPServer(('', 8000), RequestHandler)
 server.serve_forever()