U
9ܟj(@ @ s d dl Z d dlZd dlZd dlmZ d dlmZmZ d dlm Z d dl
m Z d dl m
Z
d dlmZ dd lmZmZ e eZG d
d d e
jZee G d d
d
e
jZdS ) N)unquote)inlineCallbacks
maybeDeferred)IProtocolNegotiationFactory)ProtocolWrapper)http) implementer )HEADER_NAME_REparse_x_forwarded_forc @ s e Zd ZdZdddddddddZd d
Zed d Zd
d Z dd Z
dd Z dd Z dd Z
dd Zdd Zdd Zd d Zd d Zd!S )"
WebRequestz
Request that either hands off information to channels, or offloads
to a WebSocket class.
Does some extra processing over the normal Twisted Web request to separate
GET and POST out.
a
%(title)s
%(title)s
%(body)s
z z z c O sr d | _ d | _z| j>d ks| j.j?rW d S | jj@}
| j./|
} tA| |
k } d | | d }
| j>B|
| sqqW n2 tCk
r. t#DtEF | dd!d" Y nX d S )#Ni s Bad RequestzInvalid header names Upgrader hostporthttpsr ascii /zInvalid characters in path ?r zInvalid query strings websocket z!Could not make WebSocket protocol s HTTP/1.1
s : ,s
z#Upgraded connection %s to WebSocket _s daphne-root-pathzHTTP %s request for %s) type http_versionmethodpathraw_path root_pathscheme query_stringheadersclientr z http.request)r/ body more_body Internal Server Errorz Daphne HTTP processing error)Gtime
request_startZrequestHeadersZgetAllRawHeadersr
fullmatch basic_error hasHeaderZ
getRawHeadershasattrr8 strr# r$ r r ZisSecureZ
client_schemer Z proxy_forwarded_address_headerr Zproxy_forwarded_port_headerZ proxy_forwarded_proto_headerr2 decodeUnicodeDecodeErrorr6 urisplitlowerZ
ws_factory
buildProtocol transportZgetPeersetResponseCoder warnfinishZ_raw_query_string
isinstancer ZwrappedProtocolprotocolZmakeConnectionr1 joincontentreadZ dataReceiveddebugprotocol_disconnectedr Z_networkProducerZresumeProducingZ
clean_headersr4 r appendseekr Zcreate_applicationZ clientprotor closedZrequest_buffer_sizelen
put_nowaitr r r r )r name_Zupgrade_headerrN rI datahvaluesvalue buffer_sizechunkr: payloadr! r! r" processD s
&
zWebRequest.processc C s: | j r| td| j tj| | | j | dS )3
Cleans up reply channel on close.
zHTTP disconnect for %sN)
r send_disconnectr rR r r r connectionLostr rS )r reasonr! r! r" re s
zWebRequest.connectionLostc C s8 | j r| td| j tj| | j | dS )rc zHTTP close for %sN)
r rd r rR r r r rL r rS r r! r! r" rL s
zWebRequest.finishc C s | j s| jdkrdS d|kr$td|d dkr| jr>tdd| _d|krTtd| |d |d i D ]\}}| j|| qn| jj r| j
d
s| d | jj t
d |d | j n"|d d
kr| jstd|d tj| |dd |dds| t
d| j z| jd}W n tk
rT t| j}Y nX zJ| jdd|| j| jdd| jrdt| j nd| | j d W n$ t k
r t
t ! Y nX nt
d| j ntd|d dS ) z1
Handles a reply from the client
Nr/ zMessage has no type definedhttp.response.startz&HTTP response has already been startedTstatusz s
j