o Zh-@s<dZddlZddlZddlmZmZmZmZmZm Z ddl m Z ddl m Z ddlmZddlmZdd lmZd ZGd d d eZeddZeddZeeegedfZeed gedfZGddde ZdedefddZdedd defddZeZzddl m!Z!e!jZ"ese"ZWdSWdSe#yYdSw)z"Http related parsers and protocol.N)Any AwaitableCallable NamedTupleOptionalUnion) CIMultiDict)AbstractStreamWriter) BaseProtocol)ZLibCompressor) NO_EXTENSIONS) StreamWriter HttpVersion HttpVersion10 HttpVersion11c@seZdZUeed<eed<dS)rmajorminorN)__name__ __module__ __qualname__int__annotations__rrJ/var/www/html/lang_env/lib/python3.10/site-packages/aiohttp/http_writer.pyrs  rCIMultiDict[str]c @seZdZ  d(dedejdededdf ddZe de ej fd d Z e defd d Z d)d dZdejfdededdfddZdeddfddZddddedededdfddZdedd ddfd!d"Zd*deddfd$d%Zd)d&d'ZdS)+rNprotocolloop on_chunk_senton_headers_sentreturncCsF||_||_d|_d|_d|_d|_d|_d|_d|_||_ ||_ dS)NFr) _protocolrlengthchunked buffer_size output_size_eof _compressZ _drain_waiter_on_chunk_sent_on_headers_sent)selfrrrrrrr__init__s zStreamWriter.__init__cCs|jjSN)r! transportr*rrrr-5szStreamWriter.transportcCs|jSr,)r!r.rrrr9szStreamWriter.protocolcCs d|_dS)NT)r#r.rrrenable_chunking=s zStreamWriter.enable_chunkingdeflateencodingstrategycCst||d|_dS)N)r1r2)r r')r*r1r2rrrenable_compression@szStreamWriter.enable_compressionchunkcCsXt|}|j|7_|j|7_|j}|jjr!|dus!|r%td||dS)Nz!Cannot write to closing transport) lenr$r%r-r! connected is_closingConnectionResetErrorwrite)r*r4sizer-rrr_writeEszStreamWriter._writeTi)drainLIMITr<r=cs |jdur||IdHt|tr|jt|kr|d}|jdur1|j|IdH}|s1dS|jdurTt|}|j|krF|j||_n|d|j}d|_|sTdS|r|j rhdt| d}||d}| ||j |kr|rd|_ | IdHdSdSdSdS)zWrites chunk of data to a stream. write_eof() indicates end of stream. writer can't be used after write_eof() method being called. write() return drain future. Ncr%x asciis )r( isinstance memoryviewnbytesr5castr'compressr"r#encoder;r$r<)r*r4r<r= chunk_lenZ chunk_len_prerrrr9Ns8        zStreamWriter.write status_lineheadersrcs4|jdur||IdHt||}||dS)z*Write request/response status and headers.N)r)_serialize_headersr;)r*rHrIbufrrr write_headersys   zStreamWriter.write_headerscs|jrdS|r|jdur||IdH|jr?|r#|j|IdH}||j7}|r>|jr>dt|d}||d}n|jrV|rTdt|d}||d}nd}|r]||| IdHd|_dS)Nr?r@s 0 s0 T) r&r(r'rEflushr#r5rFr;r<)r*r4rGrrr write_eofs,    zStreamWriter.write_eofcs&|jjdur|jIdHdSdS)zFlush the write buffer. The intended use is to write await w.write(data) await w.drain() N)r!r- _drain_helperr.rrrr<s zStreamWriter.drain)NN)r N)rM)rrrr asyncioAbstractEventLoop_T_OnChunkSent_T_OnHeadersSentr+propertyr Transportr-rr/zlibZ_DEFAULT_STRATEGYstrrr3bytesr;boolr9rLrOr<rrrrrs^     +  rstringr cCsd|vsd|vr td|S)N  zRNewline or carriage return detected in headers. Potential header injection attack.) ValueError)r\rrr _safe_headers r`rHrIcCs2dd|D}|dd|d}|dS)Ncss(|]\}}t|dt|VqdS)z: N)r`).0kvrrr s&z(_py_serialize_headers..z z zutf-8)itemsjoinrF)rHrIZ headers_genlinerrr_py_serialize_headerss rh)$__doc__rQrWtypingrrrrrrZ multidictrabcr Z base_protocolr Zcompression_utilsr helpersr __all__rrrrZrSrTrrYr`rhrJZaiohttp._http_writerZ _http_writerZ_c_serialize_headers ImportErrorrrrrs: