walkero
/
nghttp2
1
0
Fork 0
Code Issues Pull Requests Projects Releases 1 Wiki Activity

Merge branch 'fwiesel-client_certificate'

This commit is contained in:
Tatsuhiro Tsujikawa 2015-05-31 18:28:16 +09:00
parent 3d59c6c0b7 7eafebfeb9
commit ad150c3ab1
1 changed files with 17 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
python/nghttp2.pyx
View File

@ -698,6 +698,7 @@ cdef class _HTTP2SessionCoreBase:
handler.stream_id = stream_id handler.stream_id = stream_id
handler.http2 = self handler.http2 = self
handler.remote_address = self._get_remote_address() handler.remote_address = self._get_remote_address()
handler.client_certificate = self._get_client_certificate()
self.handlers.add(handler) self.handlers.add(handler)
def _rst_stream(self, stream_id, def _rst_stream(self, stream_id,
@ -713,6 +714,13 @@ cdef class _HTTP2SessionCoreBase:
def _get_remote_address(self): def _get_remote_address(self):
return self.transport.get_extra_info('peername') return self.transport.get_extra_info('peername')
def _get_client_certificate(self):
sock = self.transport.get_extra_info('socket')
try:
return sock.getpeercert()
except AttributeError:
return None
def _start_settings_timer(self): def _start_settings_timer(self):
loop = asyncio.get_event_loop() loop = asyncio.get_event_loop()
self.settings_timer = loop.call_later(self.SETTINGS_TIMEOUT, self.settings_timer = loop.call_later(self.SETTINGS_TIMEOUT,
@ -1030,6 +1038,9 @@ if asyncio:
Contains a tuple of the form (host, port) referring to the client's Contains a tuple of the form (host, port) referring to the client's
address. address.
client_certificate
May contain the client certifcate in its non-binary form
stream_id stream_id
Stream ID of this stream Stream ID of this stream
@ -1058,6 +1069,8 @@ if asyncio:
self.http2 = http2 self.http2 = http2
# address of the client # address of the client
self.remote_address = self.http2._get_remote_address() self.remote_address = self.http2._get_remote_address()
# certificate of the client
self._client_certificate = self.http2._get_client_certificate()
# :scheme header field in request # :scheme header field in request
self.scheme = None self.scheme = None
# :method header field in request # :method header field in request
@ -1075,6 +1088,10 @@ if asyncio:
def client_address(self): def client_address(self):
return self.remote_address return self.remote_address
@property
def client_certificate(self):
return self._client_certificate
def on_headers(self): def on_headers(self):
'''Called when request HEADERS is arrived. '''Called when request HEADERS is arrived.