%(body)s
z z z c O sp d | _ d | _z"tjj| g|R i | | jjj| _d | _d| _ | j | W d S t y7 t t w )NF) client_addr server_addrr Request__init__channelfactoryserverapplication_queue_response_startedprotocol_connected Exceptionloggererror traceback format_exc)selfargskwargs r" t/var/www/vedio/testing/chatpythonscript.ninositsolution.com/env/lib/python3.10/site-packages/daphne/http_protocol.pyr 4 s zWebRequest.__init__c c s( zt | _| j D ]\}}t|s!| ddd W d S q d }| jdr2| jdd }t | j drTt | j drTt | j j | j j g| _t | j j | j j g| _| rZdnd | _| jjrwt| j| jj| jj| jj| j| j\| _| _z| jd W n ty d | _| ddd Y W d S w d | _d| jv r| j ddd | _z| jd W n ty | ddd Y W d S w |rL| dkrL| jj | j ! }|s| "d t#$d | % | j|_&| j d }| _ t'|t(r||_)n||_*|+| | j,d | j d }| j D ]}||d d d-|d d 7 }q|d7 }|| j./ 7 }|0| t#1d| j | j2| | j3j45 W d S g | _6| jj7| _7| j D ]-\}}d|v rdqY|D ] } | dkryt8| d | _7qf| j69| | f qfqYt#1d | j,| j | j.:dd t;| jj<| d | j= d d d | j,d t8| jd | j| j7| j| j| j6| j| jd V | _>| j>d u s| j.j?rW d S | jj@} | j./| } tA| | k } d | | d!} | j>B| | sW d S q tCy t#DtEF | dd"d# Y d S w )$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 Tz http.request)r0 body more_body Internal Server Errorz Daphne HTTP processing error)Gtime request_startrequestHeadersgetAllRawHeadersr fullmatch basic_error hasHeader getRawHeadershasattrr9 strr$ r% r r isSecure client_schemer proxy_forwarded_address_headerr proxy_forwarded_port_header proxy_forwarded_proto_headerr3 decodeUnicodeDecodeErrorr7 urisplitlower ws_factory buildProtocol transportgetPeersetResponseCoder warnfinish_raw_query_string isinstancer wrappedProtocolprotocolmakeConnectionr2 joincontentread dataReceiveddebugprotocol_disconnectedr _networkProducerresumeProducing clean_headersr5 r appendseekr create_application clientprotor closedrequest_buffer_sizelen put_nowaitr r r r )r name_upgrade_headerr[ rS 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 ra r r r connectionLostr rb )r reasonr" r" r# r{ s zWebRequest.connectionLostc C s8 | j r| td| j tj| | j | dS )ry zHTTP close for %sN) r rz r ra r r r rW r rb r r" r" r# rW s zWebRequest.finishc C s | j s| jdu r dS d|vrtd|d dkrc| jr tdd| _d|vr*td| |d |d i D ] \}}| j|| q7| jj rW| j d sW| d | jj t d |d | j dS |d d kr| jsttd|d tj| |dd |dds| t d| j z| jd}W n ty t| j}Y nw z%| jdd|| j| jdd| jrdt| j nd| | j d W dS t y t t ! Y dS w t d| j dS td|d ) z1 Handles a reply from the client Nr0 zMessage has no type definedhttp.response.startz&HTTP response has already been startedTstatusz