summaryrefslogtreecommitdiff
path: root/paste/webkit/FakeWebware/MiscUtils/M2PickleRPC.py
diff options
context:
space:
mode:
Diffstat (limited to 'paste/webkit/FakeWebware/MiscUtils/M2PickleRPC.py')
-rw-r--r--paste/webkit/FakeWebware/MiscUtils/M2PickleRPC.py67
1 files changed, 0 insertions, 67 deletions
diff --git a/paste/webkit/FakeWebware/MiscUtils/M2PickleRPC.py b/paste/webkit/FakeWebware/MiscUtils/M2PickleRPC.py
deleted file mode 100644
index 2976f7f..0000000
--- a/paste/webkit/FakeWebware/MiscUtils/M2PickleRPC.py
+++ /dev/null
@@ -1,67 +0,0 @@
-"""
-M2Crypto-enhanced transport for PickleRPC
-
-This lets you use M2Crypto for SSL encryption.
-
-Based on m2xmlrpclib.py which is
- Copyright (c) 1999-2002 Ng Pheng Siong. All rights reserved
-"""
-
-from PickleRPC import Transport
-import base64, string, sys
-from M2Crypto import SSL, httpslib, m2urllib
-try:
- from cStringIO import StringIO
-except ImportError:
- from StringIO import StringIO
-
-__version__ = 1 # version of M2PickleRPC
-
-class M2Transport(Transport):
- user_agent = "M2PickleRPC.py/%s - %s" % (__version__, Transport.user_agent)
-
- def __init__(self, ssl_context=None):
- if ssl_context is None:
- self.ssl_ctx=SSL.Context('sslv23')
- else:
- self.ssl_ctx=ssl_context
-
- def make_connection(self, host):
- _host, _port = m2urllib.splitport(host)
- if sys.version[0] == '2':
- return httpslib.HTTPS(_host, int(_port), ssl_context=self.ssl_ctx)
- elif sys.version[:3] == '1.5':
- return httpslib.HTTPS(self.ssl_ctx, _host, int(_port))
- else:
- raise RuntimeError, 'unsupported Python version'
-
- # @@ workarounds below are necessary because M2Crypto seems to
- # return from fileobject.read() early! So we have to call it
- # over and over to get the full data.
-
- def parse_response(self, f):
- """
- Workaround M2Crypto issue mentioned above
- """
- sio = StringIO()
- while 1:
- chunk = f.read()
- if not chunk:
- break
- sio.write(chunk)
- sio.seek(0)
- return Transport.parse_response(self, sio)
-
- def parse_response_gzip(self, f):
- """
- Workaround M2Crypto issue mentioned above
- """
- sio = StringIO()
- while 1:
- chunk = f.read()
- if not chunk:
- break
- sio.write(chunk)
- sio.seek(0)
- return Transport.parse_response_gzip(self, sio)
-