%9jydZddlZddlZddlmZddlmZddlmZddlm Z dZ dZ d Z Gd d e jejZGd d e jejZGdde jej"ZGdde jej"ZdZGddej(j*Zeej(dr GddZydZy)z/Support for downloading media from Google APIs.N) _download)common)_helpers)_request_helperszChecksum mismatch while downloading: {} The X-Goog-Hash header indicated an {checksum_type} checksum of: {} but the actual {checksum_type} checksum of the downloaded contents was: {} zIncomplete download for: {} Error writing to stream while handling a gzip-compressed file download. Please restart the download. z The X-Goog-Stored-Content-Length is {}. The X-Goog-Stored-Content-Encoding is {}. The download request read {} bytes of data. If the download was incomplete, please check the network connection and restart the download. cLeZdZdZdZej ejffdZy)DownloadaHelper to manage downloading a resource from a Google API. "Slices" of the resource can be retrieved by specifying a range with ``start`` and / or ``end``. However, in typical usage, neither ``start`` nor ``end`` is expected to be provided. Args: media_url (str): The URL containing the media to be downloaded. stream (IO[bytes]): A write-able stream (i.e. file-like object) that the downloaded resource can be written to. start (int): The first byte in a range to be downloaded. If not provided, but ``end`` is provided, will download from the beginning to ``end`` of the media. end (int): The last byte in a range to be downloaded. If not provided, but ``start`` is provided, will download from the ``start`` to the end of the media. headers (Optional[Mapping[str, str]]): Extra headers that should be sent with the request, e.g. headers for encrypted data. checksum Optional([str]): The type of checksum to compute to verify the integrity of the object. The response headers must contain a checksum of the requested type. If the headers lack an appropriate checksum (for instance in the case of transcoded or ranged downloads where the remote service does not know the correct checksum) an INFO-level log will be emitted. Supported values are "md5", "crc32c" and None. The default is "md5". Attributes: media_url (str): The URL containing the media to be downloaded. start (Optional[int]): The first byte in a range to be downloaded. end (Optional[int]): The last byte in a range to be downloaded. c|jU|jItj||j|j |j \}}||_||_n|j}|j}|5t|j|}|jtjd}|D]L}|jj||xjt|z c_|j!|N ddd|%|j"t$j&j(k7rtj*|j-}||k7r|j |}|j/d} |j/d} t0j3| | |j} | r(|jt5| kr| dk7r t7| t8j3|j |||j j;} | | z } t=j>|| yyy#1swY3xYw)Write response body to a write-able stream. .. note: This method assumes that the ``_stream`` attribute is set on the current download. Args: response (~requests.Response): The HTTP response object. Raises: ~google.resumable_media.common.DataCorruption: If the download's checksum doesn't agree with server-computed checksum. N checksum_typeF) chunk_sizedecode_unicodex-goog-stored-content-encodingx-goog-stored-content-lengthgzip) _expected_checksum_checksum_objectr_get_expected_checksum _get_headers media_urlchecksum _add_decoderraw iter_contentr_SINGLE_GET_CHUNK_SIZE_streamwrite_bytes_downloadedlenupdate status_codehttpclientPARTIAL_CONTENTprepare_checksum_digestdigestget_RESPONSE_HEADERS_INFOformatintConnectionError_CHECKSUM_MISMATCHupperrDataCorruption) selfresponseexpected_checksumchecksum_objectlocal_checksum_object body_iterchunkactual_checksumheadersx_goog_encoding x_goog_lengthcontent_length_msgmsgs d/var/www/html/truck-me/venv/lib/python3.12/site-packages/google/resumable_media/requests/download.py_write_to_streamzDownload._write_to_streamYs#(  " " *t/D/D/L2:1P1P$++T^^4==2 . '8D #$3D ! $ 7 7 "33O  4 %1$O ! --+BBSX.I# 4 ""5)&&#e*4&%,,U3 4 4  )$$ (C(CC&>>?U?U?WXO"33++H5")++.N"O ' ,J K %;%B%B!?D4J4J&""..]1CC'61 **<==,33)'&*mm&9&9&; 4C --C //#>>14 D *! 4 4s .retriable_request~..C%%)))ZZ_1(>(>>$---1MMy)++7 99$..IQ#/1H1H"IK"77 TC&Y&&vsEnEF&&.*2*K*KD--+'  " "6 * ||'99&$BSBST6 ))!,./D*%%f-M%6077<'n#56F F2 !F--F2) _prepare_requestrrLrrMrrwait_and_retry_get_status_code_retry_strategy r/r]rB_payloadr7r^r[r\s `` @@r<consumezDownload.consumesB'+&;&;&=#7G  << #'+N8 $  " " *&.&G&G&WD #, \ .. t44d6J6J  N __name__ __module__ __qualname____doc__r=r_DEFAULT_CONNECT_TIMEOUT_DEFAULT_READ_TIMEOUTrhrir<rr8s.@N?h  5 5  2 2 ` rircLeZdZdZdZej ejffdZy) RawDownloadaHelper to manage downloading a raw resource from a Google API. "Slices" of the resource can be retrieved by specifying a range with ``start`` and / or ``end``. However, in typical usage, neither ``start`` nor ``end`` is expected to be provided. Args: media_url (str): The URL containing the media to be downloaded. stream (IO[bytes]): A write-able stream (i.e. file-like object) that the downloaded resource can be written to. start (int): The first byte in a range to be downloaded. If not provided, but ``end`` is provided, will download from the beginning to ``end`` of the media. end (int): The last byte in a range to be downloaded. If not provided, but ``start`` is provided, will download from the ``start`` to the end of the media. headers (Optional[Mapping[str, str]]): Extra headers that should be sent with the request, e.g. headers for encrypted data. checksum Optional([str]): The type of checksum to compute to verify the integrity of the object. The response headers must contain a checksum of the requested type. If the headers lack an appropriate checksum (for instance in the case of transcoded or ranged downloads where the remote service does not know the correct checksum) an INFO-level log will be emitted. Supported values are "md5", "crc32c" and None. The default is "md5". Attributes: media_url (str): The URL containing the media to be downloaded. start (Optional[int]): The first byte in a range to be downloaded. end (Optional[int]): The last byte in a range to be downloaded. c||jU|jItj||j|j |j \}}||_||_n|j}|j}|5|jjtjd}|D]L}|jj||xjt|z c_ |j|Nd|_ddd|%|j"t$j&j(k7rtj*|j-}||k7r|j |}|j/d}|j/d} t0j3| ||j} | r(|jt5| kr|dk7r t7| t8j3|j |||j j;} | | z } t=j>|| yyy#1swY3xYw) r Nr F)decode_contentTrrr) rrrrrrrrrCrrrrrrr _content_consumedr!r"r#r$r%r&r'r(r)r*r+r,r-rr.) r/r0r1r2r4r5r6r7r8r9r:r;s r<r=zRawDownload._write_to_stream,s&  " " *t/D/D/L2:1P1P$++T^^4==2 . '8D #$3D ! $ 7 7 "33O  . ++ 77,I# . ""5)&&#e*4&&&u- .*.H & .  )$$ (C(CC&>>?U?U?WXO"33++H5")++.N"O ' ,J K %;%B%B!?D4J4J&""..]1CC'61 **<==,33)'&*mm&9&9&; 4C --C //#>>14 D * . .s .retriable_requestr_r`) rarLrrMrrrbrcrdres `` @@r<rhzRawDownload.consumewsB'+&;&;&=#7G    " " *&.&G&G&WD #, \ .. t44d6J6J  riNrjrqrir<rsrs s->I?^  5 5  2 2 _ rirscFeZdZdZej ej ffdZy)ChunkedDownloadaDownload a resource in chunks from a Google API. Args: media_url (str): The URL containing the media to be downloaded. chunk_size (int): The number of bytes to be retrieved in each request. stream (IO[bytes]): A write-able stream (i.e. file-like object) that will be used to concatenate chunks of the resource as they are downloaded. start (int): The first byte in a range to be downloaded. If not provided, defaults to ``0``. end (int): The last byte in a range to be downloaded. If not provided, will download to the end of the media. headers (Optional[Mapping[str, str]]): Extra headers that should be sent with each request, e.g. headers for data encryption key headers. Attributes: media_url (str): The URL containing the media to be downloaded. start (Optional[int]): The first byte in a range to be downloaded. end (Optional[int]): The last byte in a range to be downloaded. chunk_size (int): The number of bytes to be retrieved in each request. Raises: ValueError: If ``start`` is negative. cj\fd}tj|jjS)+Consume the next chunk of the resource to be downloaded. Args: transport (~requests.Session): A ``requests`` object which can make authenticated requests. timeout (Optional[Union[float, Tuple[float, float]]]): The number of seconds to wait for the server response. Depending on the retry strategy, a request may be repeated several times using the same timeout each time. Can also be passed as a tuple (connect_timeout, read_timeout). See :meth:`requests.Session.request` documentation for details. Returns: ~requests.Response: The HTTP response returned by ``transport``. Raises: ValueError: If the current download has finished. cVj}j||S)Nr@rOrQrYr7r[rgr/rBr]rWs r<r^z=ChunkedDownload.consume_next_chunk..retriable_requests<&& 'F  " "6 *Mrirarrbrcrdr/r]rBr^r7r[rgrWs``` @@@@r<consume_next_chunkz"ChunkedDownload.consume_next_chunksN6)-(=(=(?%Wg   .. t44d6J6J  riNrkrlrmrnrrorprrqrir<rzrzs%>  5 5  2 2 , rirzcFeZdZdZej ej ffdZy)RawChunkedDownloadaDownload a raw resource in chunks from a Google API. Args: media_url (str): The URL containing the media to be downloaded. chunk_size (int): The number of bytes to be retrieved in each request. stream (IO[bytes]): A write-able stream (i.e. file-like object) that will be used to concatenate chunks of the resource as they are downloaded. start (int): The first byte in a range to be downloaded. If not provided, defaults to ``0``. end (int): The last byte in a range to be downloaded. If not provided, will download to the end of the media. headers (Optional[Mapping[str, str]]): Extra headers that should be sent with each request, e.g. headers for data encryption key headers. Attributes: media_url (str): The URL containing the media to be downloaded. start (Optional[int]): The first byte in a range to be downloaded. end (Optional[int]): The last byte in a range to be downloaded. chunk_size (int): The number of bytes to be retrieved in each request. Raises: ValueError: If ``start`` is negative. cj\fd}tj|jjS)r|cXjd}j||S)NT)rAr7rCrBr~rs r<r^z@RawChunkedDownload.consume_next_chunk..retriable_request^s?&& 'F  " "6 *Mrirrs``` @@@@r<rz%RawChunkedDownload.consume_next_chunk@sN6)-(=(=(?%Wg   .. t44d6J6J  riNrrqrir<rr$s%>  5 5  2 2 - rirc |jjddj}|dk(r$t||_t j S|dk(r*tr$t||_t j S|S)aPatch the ``_decoder`` on a ``urllib3`` response. This is so that we can intercept the compressed bytes before they are decoded. Only patches if the content encoding is ``gzip`` or ``br``. Args: response_raw (urllib3.response.HTTPResponse): The raw response for an HTTP request. checksum (object): A checksum which will be updated with compressed bytes. Returns: object: Either the original ``checksum`` if ``_decoder`` is not patched, or a ``_DoNothingHash`` if the decoder is patched, since the caller will no longer need to hash to decoded bytes. zcontent-encodingrbr)r7r'lower _GzipDecoder_decoderr_DoNothingHash_BrotliDecoder) response_rawrencodings r<rrpsu&##''(:B?EEGH6 ,X 6 &&(( T n .x 8 &&((ric.eZdZdZfdZdfd ZxZS)raDCustom subclass of ``urllib3`` decoder for ``gzip``-ed bytes. Allows a checksum function to see the compressed bytes before they are decoded. This way the checksum of the compressed value can be computed. Args: checksum (object): A checksum which will be updated with compressed bytes. c0t|||_yN)super__init__ _checksum)r/r __class__s r<rz_GzipDecoder.__init__s !ric|jj| t| ||S#t$rt| |cYSwxYw)aQDecompress the bytes. Args: data (bytes): The compressed bytes to be decompressed. max_length (int): Maximum number of bytes to return. -1 for no limit. Forwarded to the underlying decoder when supported. Returns: bytes: The decompressed bytes from ``data``.  max_length)rr r decompress TypeError)r/rArrs r<rz_GzipDecoder.decompresssP d# ,7%dz%B B ,7%d+ + ,s/A  A )rkrlrmrnrr __classcell__)rs@r<rrs",,rir BrotliDecoderc4eZdZdZdZddZedZdZy)ra*Handler for ``brotli`` encoded bytes. Allows a checksum function to see the compressed bytes before they are decoded. This way the checksum of the compressed value can be computed. Because BrotliDecoder's decompress method is dynamically created in urllib3, a subclass is not practical. Instead, this class creates a captive urllib3.requests.BrotliDecoder instance and acts as a proxy. Args: checksum (object): A checksum which will be updated with compressed bytes. cXtjj|_||_yr)urllib3r0rrr)r/rs r<rz_BrotliDecoder.__init__s#,,::rs6 ,)+< Q --y/A/AQ hJ "33Y5G5GJ ZH &44i6O6OH VI )::I,7##//,F 7  _-,),)^Nri