o Rh-@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__rr`/var/www/html/HyperOracle/crypto_trader/venv/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 _compress _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)r2r3)r r')r+r2r3rrrenable_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+r5sizer.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 memoryviewnbytesr6castr'compressr"r#encoder<r$r=)r+r5r=r> chunk_len chunk_len_prerrrr:Ns8        zStreamWriter.write status_lineheadersrcs4|jdur||IdHt||}||dS)z*Write request/response status and headers.N)r*_serialize_headersr<)r+rJrKbufrrr 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@rAs 0 s0 T) r&r)r'rFflushr#r6rGr<r=)r+r5rHrrr 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)rO)rrrr asyncioAbstractEventLoop_T_OnChunkSent_T_OnHeadersSentr,propertyr Transportr.rr0zlibZ_DEFAULT_STRATEGYstrrr4bytesr<boolr:rNrQr=rrrrrs^     +  rstringr cCsd|vsd|vr td|S)N  zRNewline or carriage return detected in headers. Potential header injection attack.) ValueError)r^rrr _safe_headers rbrJrKcCs2dd|D}|dd|d}|dS)Ncss(|]\}}t|dt|VqdS)z: N)rb).0kvrrr s&z(_py_serialize_headers..z z zutf-8)itemsjoinrG)rJrK headers_genlinerrr_py_serialize_headerss rk)$__doc__rSrYtypingrrrrrr multidictrabcr base_protocolr compression_utilsr helpersr __all__rrrr\rUrVrr[rbrkrLaiohttp._http_writer _http_writer_c_serialize_headers ImportErrorrrrrs: