}DjddlmZddlmZddlmZmZddlmZm Z m Z ddl m Z ddl mZmZmZddlmZeeZerdd lmZed d d Gd d eeZde deefdZddedeefdZy))BytesIO) getLogger) TYPE_CHECKINGOptional)definefield fields_dict)Response)HTTPHeaderDict HTTPResponse is_fp_closed) RichMixin)CachedResponseF) auto_attribsreprslotscpeZdZUdZedZeed<eeZ eed<edZ e ed<edZ e ed<ed Z eed <ed Zeed <dd eeffd ZededdfdZeddZede fdZej2de fdZdZddZdd eefdZddZxZS)CachedHTTPResponsea%A wrapper class that emulates :py:class:`~urllib3.response.HTTPResponse`. This enables consistent behavior for streaming requests and generator usage in the following cases: * On an original response, after reading its content to write to the cache * On a cached response N)defaultdecode_content)factoryheadersreason request_urlrstatusversionbodyc |jDcic] \}}| || }}}t|dt|xsddd|||_d|_t |xsd|_|jdi|ycc}}w)zCFirst initialize via HTTPResponse.__init__, then via __attrs_init__NF)rpreload_contentr) itemssuper__init__r_body_fp_bytes_readlenlength_remaining__attrs_init__)selfrkwargskv __class__s n/var/www/html/Astrologybackend/backend/venv/lib/python3.12/site-packages/requests_cache/models/raw_response.pyr%zCachedHTTPResponse.__init__'s#)<<>C41aQ]!Q$CC Tgdkc2ETVT  #DKC 0%f% Ds A<A<responsereturnc &trt|jtsJt |j Dcic]}|t |j|d}}|jj|d<t||d<|di|Scc}w)z{Create a CachedHTTPResponse based on an original response, and restore the response to its previous state. Nrrr") r isinstancerawr r keysgetattr _request_url _copy_body)clsr1r-r,s r0 from_responsez CachedHTTPResponse.from_response0s hllL9 99=H=M=R=R=TU!WX\\1d33UU ( 9 9}#H-v}V} VsBc|t|j|j|j|jj }|j |j|S)z6Create a CachedHTTPResponse based on a cached response)rrrr)r rr status_coderequesturlreset_content)r:r1objs r0from_cached_responsez'CachedHTTPResponse.from_cached_response>sT"8#3#34??'' ((,,   (##$ r c|jS)zFor compatibility with urllib3rr+s r0r8zCachedHTTPResponse._request_urlJsr valuec||_yNrE)r+rGs r0r8zCachedHTTPResponse._request_urlOs  r cy)zNo-op for compatibilityNr"rFs r0 release_connzCachedHTTPResponse.release_connSsr c d|jvr|durtjdt|jry|jj |}|rJ|xj t|z c_|j|xjt|zc_|S|jj|S)zSimplified reader for cached content that emulates :py:meth:`urllib3.response.HTTPResponse.read()`, but does not need to read from a socket or decode content. zContent-EncodingFz@read(decode_content=False) is not supported for cached responsesr ) rloggerwarningr _fpreadr'r(r)close)r+amtrr,datas r0rPzCachedHTTPResponse.readVs  -.E2I NN] ^  !xx}}S!    3t9 , $$0%%T2%  HHNN  r c8t||xs |jy)z>Reset raw response file pointer, and optionally update contentN) _reset_fpr&)r+rs r0r@zCachedHTTPResponse.resetjs$* +r c+K|jjs.|jdd|i||jjs-yyw)zySimplified generator over cached content that emulates :py:meth:`urllib3.response.HTTPResponse.stream()` rRNr")rOclosedrP)r+rRr,s r0streamzCachedHTTPResponse.streamns9((//$))..v. .((//s AAArI)r1r)NN)__name__ __module__ __qualname____doc__rrbool__annotations__r rrstrrrintrrbytesr% classmethodr r;rCpropertyr8setterrKrPr@rX __classcell__)r/s@r0rrs!.ND.#N;G^;%FC%T*K*"FC"#GS#&Xe_& X 2F     c  !#!!&(,(5/,/r rr1r2ctrt|jtsJt |jddrt |jj ryt |jddr |j}n>|jjd}t|j||j}t|j||S)zRead and copy raw response data, and then restore response object to its previous state. This is necessary so streaming responses behave consistently with or without the cache. rON_has_decoded_contentF)r) rr4r5r r7r rOcontentrPrU)r1r_s r0r9r9vs(,, 555 8<< -hll>N>N1O 5u =||   6(,,%   hllD! Kr Nr5rcl|xsd}||_d|_t||_t ||_y)z/Set content and reset raw response file pointerr rN)r&r'rrOr(r))r5rs r0rUrUs1 ;3DCICdmCGt9Cr rI)iorloggingrtypingrrattrsrrr requestsr urllib3.responser r r rrYrMrrrar9rUr"r r0rrs*,,  8  Ue4\/L\/5\/~huo.%<%x%r