U h @sDdZddlmZmZddlmZmZGdddZGdddZdS) zData Chunk Receiver ) CHUNK_EXT_REONLY_HEXDIG_RE) BadRequestfind_double_newlinec@s<eZdZdZdZddZddZddZd d Zd d Z dS) FixedStreamReceiverFNcCs||_||_dSN)remainbuf)selfclr r C/var/www/html/venv/lib/python3.8/site-packages/waitress/receiver.py__init__szFixedStreamReceiver.__init__cCs |jSrr __len__r r r r rszFixedStreamReceiver.__len__cCsn|j}|dkrd|_dSt|}||krL|j|d|d|_d|_|S|j||j|8_|SdS)zSee IStreamConsumerTrN)r completedlenr append)r datarmZdatalenr r r received!s zFixedStreamReceiver.receivedcCs |jSrr getfilerr r r r7szFixedStreamReceiver.getfilecCs|jSrr rr r r getbuf:szFixedStreamReceiver.getbuf) __name__ __module__ __qualname__rerrorrrrrrr r r r rsrc@sTeZdZdZdZdZdZdZdZdZ dZ ddZ ddZ d d Z d d Zd dZdS)ChunkedReceiverrFNcCs ||_dSrr)r r r r r rKszChunkedReceiver.__init__cCs |jSrrrr r r rNszChunkedReceiver.__len__c CsB|jr dSt|}|r>|j}|dkrr|d|}|j|t|}||d}|j|8_|jdkrpd|_q|jr|j|}|d}|dkrt|dkr||_d}n2d|_|dkr|dd}ntd|_ d|_ d|_q|j s|j |}|d}|dkr||_ d}n|d|}||dd}d|_ |r<|d}|dkr||d} t | } | s~td |_ d|_ q>|d|}t |std |_ d|_ q>t|d } | dkr| |_nd|_ q|j|} | drd|_|t| dSt| }|dkr| |_d}qd|_| d||_|t| |Sq|S) NrTs r"zChunk not properly terminatedF;zInvalid chunk extensionzInvalid chunk size)rrchunk_remainderr rvalidate_chunk_end chunk_endfindrr all_chunks_received control_linermatchrinttrailer startswithr) r sZ orig_sizerZto_writeZwrittenposlinesemiZextinfoZvalid_ext_infoszr.r r r rQs                        zChunkedReceiver.receivedcCs |jSrrrr r r rszChunkedReceiver.getfilecCs|jSrrrr r r rszChunkedReceiver.getbuf)rrrr&r'r+r(r*r.rr rrrrrr r r r r!>sqr!N) __doc__Zwaitress.rfc7230rrZwaitress.utilitiesrrrr!r r r r s)