gP8dZddlZddlZddlmZddlmZejdejZ ejjejjfZ dZdZGd d eZGd d eZGd deZdZej*fdZdZy)z=Virtual bases classes for downloading media from Google APIs.N)_helpers)commonz@bytes (?P\d+)-(?P\d+)/(?P\d+))flagsGETz bytes */0cXeZdZdZddZedZedZedZ edZ y) DownloadBasea:Base class for download helpers. Defines core shared behavior across different download types. 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. end (int): The last byte in a range to be downloaded. headers (Optional[Mapping[str, str]]): Extra headers that should be sent with the request, e.g. headers for encrypted data. 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. Nc||_||_||_||_|i}||_d|_t j|_y)NF) media_url_streamstartend_headers _finishedr RetryStrategy_retry_strategy)selfr streamr r headerss }/var/www/html/FastMealFinder_FlaskServer-InitialRelease/venv/lib/python3.12/site-packages/google/resumable_media/_download.py__init__zDownloadBase.__init__6sG"   ?G %335c|jS)z4bool: Flag indicating if the download has completed.)rrs rfinishedzDownloadBase.finishedAs~~rctd)zAccess the status code from an HTTP response. Args: response (object): The HTTP response object. Raises: NotImplementedError: Always, since virtual. This implementation is virtual.NotImplementedErrorresponses r_get_status_codezDownloadBase._get_status_codeF""CDDrctd)zAccess the headers from an HTTP response. Args: response (object): The HTTP response object. Raises: NotImplementedError: Always, since virtual. rrrs r _get_headerszDownloadBase._get_headersRr"rctd)zAccess the response body from an HTTP response. Args: response (object): The HTTP response object. Raises: NotImplementedError: Always, since virtual. rrrs r _get_bodyzDownloadBase._get_body^r"r)NNNN) __name__ __module__ __qualname____doc__rpropertyr staticmethodr!r$r&rrrr"sb& 6 E E E E E Errc:eZdZdZ dfd ZdZdZddZxZS)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. c|tt| |||||||_d|_d|_d|_d|_y)Nrr r rr)superr/rchecksum_bytes_downloaded_expected_checksum_checksum_object_object_generation)rr rr r rr3 __class__s rrzDownload.__init__sM h& fEsG ' ! !""& $"&rc|jr tdt|j|j|j t |jd|j fS)aPrepare the contents of an HTTP request. This is everything that must be done before a request that doesn't require network I/O (or other I/O). This is based on the `sans-I/O`_ philosophy. Returns: Tuple[str, str, NoneType, Mapping[str, str]]: The quadruple * HTTP verb for the request (always GET) * the URL for the request * the body of the request (always :data:`None`) * headers for the request Raises: ValueError: If the current :class:`Download` has already finished. .. _sans-I/O: https://sans-io.readthedocs.io/ z!A download can only be used once.N)r ValueErroradd_bytes_ranger r r_GETr rs r_prepare_requestzDownload._prepare_requestsF* ==@A A DHHdmm<T^^T4==88rc\d|_tj|t|jy)a^Process the response from an HTTP request. This is everything that must be done after a request that doesn't require network I/O (or other I/O). This is based on the `sans-I/O`_ philosophy. Args: response (object): The HTTP response object. .. _sans-I/O: https://sans-io.readthedocs.io/ TN)rrrequire_status_code_ACCEPTABLE_STATUS_CODESr!)rr s r_process_responsezDownload._process_responses'$$ .0E0E rctd)aConsume the resource to be downloaded. If a ``stream`` is attached to this download, then the downloaded resource will be written to the stream. Args: transport (object): An 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. Raises: NotImplementedError: Always, since virtual. rrr transporttimeouts rconsumezDownload.consumes(""CDDr)NNNNmd5N) r'r(r)r*rr=rArF __classcell__r8s@rr/r/ks$8TY '96 $Err/cteZdZdZd fd ZedZedZedZdZ dZ dZ d Z d d Z xZS) 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. c|dkr tdtt||||||||_d|_d|_d|_y)Nrz-> "DN $$  $  ! !''  ##H-x0 ,: d''$2D2D- ) Hk$KK(;<  $%55 !!++ N N+I=!Y.""$,,D & !:-1I )+ 88 H$8!DN q (!DN    # +D  =)rctd)aConsume the next chunk of the resource to be downloaded. Args: transport (object): An 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. Raises: NotImplementedError: Always, since virtual. rrrCs rconsume_next_chunkz"ChunkedDownload.consume_next_chunks"""CDDr)rNNrH)r'r(r)r*rr+rRrTrWr^r=rarArvrIrJs@rrLrLsf6 &&!!$""9HX*tErrLc||ydj|}n=|)|dkrdj|}n$dj|}ndj||}d|z|tj<y)aAdd a bytes range to a header dictionary. Some possible inputs and the corresponding bytes ranges:: >>> headers = {} >>> add_bytes_range(None, None, headers) >>> headers {} >>> add_bytes_range(500, 999, headers) >>> headers['range'] 'bytes=500-999' >>> add_bytes_range(None, 499, headers) >>> headers['range'] 'bytes=0-499' >>> add_bytes_range(-500, None, headers) >>> headers['range'] 'bytes=-500' >>> add_bytes_range(9500, None, headers) >>> headers['range'] 'bytes=9500-' Args: start (Optional[int]): The first byte in a range. Can be zero, positive, negative or :data:`None`. end (Optional[int]): The last byte in a range. Assumed to be positive. headers (Mapping[str, str]): A headers mapping which can have the bytes range added if at least one of ``start`` or ``end`` is not :data:`None`. Nz0-{:d}rz{:d}z{:d}-z {:d}-{:d}zbytes=)formatr RANGE_HEADER)r r r bytes_ranges rr;r;sr> } ; #//#.K ;qy$mmE2 %nnU3 &,,UC8K%- %;GH ! !"rcVtj|tj||}tj |}||t j |d|dt|jdt|jdt|jdfS)aGet the start, end and total bytes from a content range header. Args: response (object): An HTTP response object. get_headers (Callable[Any, Mapping[str, str]]): Helper to get headers from an HTTP response. callback (Optional[Callable]): A callback that takes no arguments, to be executed when an exception is being raised. Returns: Tuple[int, int, int]: The start byte, end byte and total bytes. Raises: ~google.resumable_media.common.InvalidResponse: If the ``Content-Range`` header is not of the form ``bytes {start}-{end}/{total}``. rczUnexpected content-range headerz8Expected to be of the form "bytes {start}-{end}/{total}"rprqrT) rrjCONTENT_RANGE_HEADER_CONTENT_RANGE_REmatchrrmrkgroup)r get_headersrd content_ranger~s rrhrhs$,,(//xM  # #M 2E } $$  -  F    EKK %& EKK #$ EKK &' rc||tjjk(r?tj|tj |tj }|tk(ryy)aValidate if response status code is 416 and content range is zero. This is the special case for handling zero bytes files. Args: response (object): An HTTP response object. get_status_code (Callable[Any, int]): Helper to get a status code from a response. get_headers (Callable[Any, Mapping[str, str]]): Helper to get headers from an HTTP response. Returns: bool: True if content range total bytes is zero, false otherwise. rcTF)httpclientREQUESTED_RANGE_NOT_SATISFIABLErrjr| do_nothing_ZERO_CONTENT_RANGE_HEADER)r get_status_coderrs rrgrgsTx DKK$O$OO 00   ) ) ((  6 6 r)r* http.clientrregoogle.resumable_mediarrcompile IGNORECASEr}rOKPARTIAL_CONTENTr@r<robjectrr/rLr;rrhrgr-rrrsD +)BJJG --!KKNNDKK,G,GH (FE6FERiE|iEXdEldEN0