1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
|
# $Id$
"""HTTPS utilities, both client and server.
At the moment this only knows how to use the PEM certs in my
subversion repository; generalizing it would not be hard, but the more
general version should use SQL anyway.
"""
import httplib, BaseHTTPServer, tlslite.api, glob, traceback, urlparse
import rpki.x509, rpki.exceptions
rpki_content_type = "application/x-rpki"
def client(msg, privateKey, certChain, x509TrustList, url):
"""Open client HTTPS connection, send a message, wait for response.
This function wraps most of what one needs to do to send a message
over HTTPS and get a response. The certificate checking isn't quite
up to snuff; it's better than with the other packages I've found,
but doesn't appear to handle subjectAltName extensions (sigh).
"""
u = urlparse.urlparse(url)
assert u.scheme in ("", "https") and \
u.username is None and \
u.password is None and \
u.params == "" and \
u.query == "" and \
u.fragment == ""
httpc = tlslite.api.HTTPTLSConnection(host = u.hostname or "localhost",
port = u.port or 443,
privateKey = privateKey.get_tlslite(),
certChain = certChain.tlslite_certChain(),
x509TrustList = x509TrustList.tlslite_trustList())
httpc.connect()
httpc.request("POST", u.path, msg, {"Content-Type" : rpki_content_type})
response = httpc.getresponse()
if response.status == httplib.OK:
return response.read()
else:
r = response.read()
raise rpki.exceptions.HTTPRequestFailed, \
"HTTP request failed with status %s, response %s" % (response.status, r)
class requestHandler(BaseHTTPServer.BaseHTTPRequestHandler):
"""Derived type to supply POST handler."""
rpki_handlers = None # Subclass must bind
def rpki_find_handler(self):
"""Helper method to search self.rpki_handlers."""
for s,h in self.rpki_handlers:
if self.path.startswith(s):
return h
return None
def do_POST(self):
"""POST handler."""
try:
handler = self.rpki_find_handler()
if self.headers["Content-Type"] != rpki_content_type:
rcode, rtext = 415, "Received Content-Type %s, expected %s" \
% (self.headers["Content-Type"], rpki_content_type)
elif handler is None:
rcode, rtext = 404, "No handler found for URL " + self.path
else:
rcode, rtext = handler(query = self.rfile.read(int(self.headers["Content-Length"])),
path = self.path)
except Exception, edata:
traceback.print_exc()
rcode, rtext = 500, "Unhandled exception %s" % edata
self.send_response(rcode)
self.send_header("Content-Type", rpki_content_type)
self.end_headers()
self.wfile.write(rtext)
class httpServer(tlslite.api.TLSSocketServerMixIn, BaseHTTPServer.HTTPServer):
"""Derived type to handle TLS aspects of HTTPS."""
rpki_certChain = None
rpki_privateKey = None
rpki_sessionCache = None
def handshake(self, tlsConnection):
"""TLS handshake handler."""
assert self.rpki_certChain is not None
assert self.rpki_privateKey is not None
assert self.rpki_sessionCache is not None
try:
tlsConnection.handshakeServer(certChain = self.rpki_certChain,
privateKey = self.rpki_privateKey,
sessionCache = self.rpki_sessionCache)
tlsConnection.ignoreAbruptClose = True
return True
except tlslite.api.TLSError, error:
print "TLS handshake failure:", str(error)
return False
def server(handlers, privateKey, certChain, port = 4433, host = ""):
"""Run an HTTPS server and wait (forever) for connections."""
if not isinstance(handlers, (tuple, list)):
handlers = (("/", handlers),)
class boundRequestHandler(requestHandler):
rpki_handlers = handlers
httpd = httpServer((host, port), boundRequestHandler)
httpd.rpki_privateKey = privateKey.get_tlslite()
httpd.rpki_certChain = certChain.tlslite_certChain()
httpd.rpki_sessionCache = tlslite.api.SessionCache()
httpd.serve_forever()
|
