
    Y j                     r   % S r SSKrSSKrSSKrSSKrSSKrSSKrSSKrSSKrSSK	J
r
JrJr  SSKJr  SSKJr  SSKJr  SSKJrJr  SSKJr  SSKrSS	KJr  S
SKJr  S
SKJrJrJ r J!r!J"r"J#r#J$r$J%r%  SSKJ&r&  SSK'J(r(  SSK)J*r*  \&RV                  " \,5      r-\" SS9 " S S5      5       r.\R^                  " S5      r0\R^                  " S5      r1S\\2\24   S\.S-  4S jr3Sr4Sr5Sr6\R^                  " S\Rn                  S9r8\R^                  " S\Rn                  S9r9\R^                  " S 5      r:\R^                  " S!5      r;1 S"kr<S#\2S\=\2S-  \2S-  4   4S$ jr>S#\2S\2S-  4S% jr?S&\R                  SS4S' jrAS&\R                  SS4S( jrBS)\R                  SS4S* jrDS\R                  4S+ jrFS\R                  4S, jrH\
/ \R                  4   rI\
/ \R                  4   rJ\R                  " 5       rL\FqM\I\NS-'   \HqO\J\NS.'   SqP\R                  S-  \NS/'   S0\ISS4S1 jrQS2\JSS4S3 jrRS\R                  4S4 jrSS\R                  4S5 jrTS_S6 jrU\R                  " \U5        \W" \S75      (       a  \R                  " \US89  \R                  \R                  4r[\=\\\]   S94   \NS:'   S;r^\=\_S94   \NS<'   S=SS>\[\^S?S@.SA\*S#\2SB\_SC\`SD\`SE\\\]   \=\\\]   S94   -  SF\_\=\_S94   -  SG\aS\\R                  SS4   4SH jjrbS=SS>\[\^SI.SA\*S#\2SB\_SC\`SD\`SE\\\]   \=\\\]   S94   -  SF\_\=\_S94   -  S\R                  4SJ jjrc\S=SS>\[\^SI.SA\*S#\2SB\_SC\`SD\`SE\\\]   \=\\\]   S94   -  SF\_\=\_S94   -  S\\R                  SS4   4SK jj5       rdS?SL.SA\*S#\2SM\aS\R                  4SN jjreS#\2SO\2S-  S\24SP jrfS`S)\R                  SQ\2S-  SS4SR jjrg\h" 5       riS)\R                  SS4SS jrj\" ST\"SU9rkSV\\\k   SW\2S)\R                  SX\S\k4
SY jrlS&\R                  S\24SZ jrm\R^                  " S[\R                  5      roS\\2S-  S]\_S\2S-  4S^ jrpg)az>Contains utilities to handle HTTP requests in huggingface_hub.    N)Callable	GeneratorMapping)contextmanager)	dataclass)quote)AnyTypeVar)urlparse)OfflineModeIsEnabled   )	constants)BadRequestErrorBucketNotFoundErrorDisabledRepoErrorGatedRepoErrorHfHubHTTPErrorRemoteEntryNotFoundErrorRepositoryNotFoundErrorRevisionNotFoundError   )logging)SliceFileObj)HTTP_METHOD_TT)frozenc                   `    \ rS rSr% Sr\\S'   \\S'   \\S'   Sr\S-  \S'   Sr	\S-  \S'   S	r
g)
RateLimitInfo6   a  
Parsed rate limit information from HTTP response headers.

Attributes:
    resource_type (`str`): The type of resource being rate limited.
    remaining (`int`): The number of requests remaining in the current window.
    reset_in_seconds (`int`): The number of seconds until the rate limit resets.
    limit (`int`, *optional*): The maximum number of requests allowed in the current window.
    window_seconds (`int`, *optional*): The number of seconds in the current window.

resource_type	remainingreset_in_secondsNlimitwindow_seconds )__name__
__module____qualname____firstlineno____doc__str__annotations__intr"   r#   __static_attributes__r$       l/root/GenerationalWealth/GenerationalWealth/venv/lib/python3.13/site-packages/huggingface_hub/utils/_http.pyr   r   6   s6    
 NE3:!%NC$J%r.   r   zL\"(?P<resource_type>\w+)\"\s*;\s*r\s*=\s*(?P<r>\d+)\s*;\s*t\s*=\s*(?P<t>\d+)z'q\s*=\s*(?P<q>\d+).*?w\s*=\s*(?P<w>\d+)headersreturnc                    SnSnU  H+  nUR                  5       nUS:X  a  X   nM  US:X  d  M'  X   nM-     U(       d  g[        R                  U5      nU(       d  gUR                  S5      n[	        UR                  S5      5      n[	        UR                  S5      5      nSn	Sn
U(       aP  [
        R                  U5      nU(       a4  [	        UR                  S5      5      n	[	        UR                  S5      5      n
[        UUUU	U
S	9$ )
a  Parse rate limit information from HTTP response headers.

Follows IETF draft: https://www.ietf.org/archive/id/draft-ietf-httpapi-ratelimit-headers-09.html
Only a subset is implemented.

Example:
```python
>>> from huggingface_hub.utils import parse_ratelimit_headers
>>> headers = {
...     "ratelimit": '"api";r=0;t=55',
...     "ratelimit-policy": '"fixed window";"api";q=500;w=300',
... }
>>> info = parse_ratelimit_headers(headers)
>>> info.remaining
0
>>> info.reset_in_seconds
55
```
N	ratelimitzratelimit-policyr   rtqw)r   r    r!   r"   r#   )lower_RATELIMIT_REGEXsearchgroupr,   _RATELIMIT_POLICY_REGEXr   )r0   r3   policykey	lower_keymatchr   r    r!   r"   r#   policy_matchs               r/   parse_ratelimit_headersrB   R   s    * !IFIIK	#I,,\F  ##I.EKK0MEKK$%I5;;s+,E!%N.55f=**3/0E !3!3C!89N#)% r.   zx-request-idzX-Amzn-Trace-Idzx-amz-cf-ida  
        # staging or production endpoint
        ^https://[^/]+
        (
            # on /api/repo_type/repo_id
            /api/(models|datasets|spaces)/(.+)
            |
            # or /repo_id/resolve/revision/...
            /(.+)/resolve/(.+)
        )
    )flagszz
        # staging or production endpoint
        ^https?://[^/]+
        # on /api/buckets/...
        /api/buckets/
    zA^https?://[^/]+/api/(models|datasets|spaces)/([^/]+)(?:/([^/]+))?z)^https?://[^/]+/api/buckets/([^/]+/[^/]+)>	   rawblobrefstreecommitresolverevisionsettingsdiscussionsurlc                    [         R                  U 5      nU(       d  g[        R                  R	                  UR                  S5      5      nUR                  S5      UR                  S5      pCU(       a  U[        ;  a
  U SU 3nX%4$ UnX%4$ )a  Extract (repo_type, repo_id) from an API URL.

Returns canonical repo_type values: "model", "dataset", "space" (or None).

Examples:
    >>> _parse_repo_info_from_url("https://huggingface.co/api/models/user/repo")
    ("model", "user/repo")
    >>> _parse_repo_info_from_url("https://huggingface.co/api/datasets/user/repo/resolve/main/data.csv")
    ("dataset", "user/repo")
    >>> _parse_repo_info_from_url("https://huggingface.co/api/models/bert-base-cased/resolve/main/config.json")
    ("model", "bert-base-cased")
NNr   r      /)_REPO_ID_FROM_URL_REGEXr:   r   REPO_TYPES_MAPPINGgetr;   _REPO_URL_SUBPATHS)rM   r@   	repo_typefirstsecondrepo_ids         r/   _parse_repo_info_from_urlrZ      s     $**3/E,,00Q@IKKNEKKN6& 22G1VH%  r.   c                 `    [         R                  U 5      nU(       a  UR                  S5      $ S$ )z9Extract bucket_id (namespace/name) from a bucket API URL.r   N)_BUCKET_ID_FROM_URL_REGEXr:   r;   )rM   r@   s     r/   _parse_bucket_id_from_urlr]      s'    %,,S1E"5;;q>,,r.   requestc           	      t   [         R                  " 5       (       a  [        SU R                   S35      e[        U R
                  ;  aU  U R
                  R                  [        5      =(       d    [        [        R                  " 5       5      U R
                  [        '   U R
                  R                  [        5      n[        R                  SUU R                  U R                  U R
                  R                  S5      SL5        [         R                  (       a  [        R                  S[        U 5      5        U$ )z
Event hook that will be used to make HTTP requests to the Hugging Face Hub.

What it does:
- Block requests if offline mode is enabled
- Add a request ID to the request headers
- Log the request if debug mode is enabled
zCannot reach za: offline mode is enabled. To disable it, please unset the `HF_HUB_OFFLINE` environment variable.z%Request %s: %s %s (authenticated: %s)authorizationNzSend: %s)r   is_offline_moder   rM   X_AMZN_TRACE_IDr0   rT   X_REQUEST_IDr*   uuiduuid4loggerdebugmethodHF_DEBUG_curlify)r^   
request_ids     r/   hf_request_event_hookrl      s       """GKK=  )J  K
 	

 goo-+2??+>+>|+L+aPSTXT^T^T`Pa($$_5J LL/O,D8 Z'!23r.   c                     #    [        U 5      $ 7f)z+
Async version of `hf_request_event_hook`.
)rl   )r^   s    r/   async_hf_request_event_hookrn      s      !))s   responsec                    #    U R                   S:  aJ  SU R                  ;   a9   [        U R                  S   5      nUS:  a  U R	                  5       I S h  vN   g g g g ! [         a     g f = f N7f)N  zContent-lengthi@B )status_coder0   r,   
ValueErroraread)ro   lengths     r/   async_hf_response_event_hookrv      s     s" x///X--.>?@ 	!nn&&& " 0 #   's3   !A0A A0A.A0
A+(A0*A++A0c                  <    [         R                  " S[        /0SSS9$ )zI
Factory function to create a `httpx.Client` with the default transport.
r^   TNevent_hooksfollow_redirectstimeout)httpxClientrl   r$   r.   r/   default_client_factoryr~     s'     <<!6 78 r.   c                  H    [         R                  " [        /[        /S.SSS9$ )zN
Factory function to create a `httpx.AsyncClient` with the default transport.
)r^   ro   TNrx   )r|   AsyncClientrn   rv   r$   r.   r/   default_async_client_factoryr     s,     !< =LhKij r.   _GLOBAL_CLIENT_FACTORY_GLOBAL_ASYNC_CLIENT_FACTORY_GLOBAL_CLIENTclient_factoryc                 \    [            [        5         U qSSS5        g! , (       d  f       g= f)a  
Set the HTTP client factory to be used by `huggingface_hub`.

The client factory is a method that returns a `httpx.Client` object. On the first call to [`get_session`] the client factory
will be used to create a new `httpx.Client` object that will be shared between all calls made by `huggingface_hub`.

This can be useful if you are running your scripts in a specific environment requiring custom configuration (e.g. custom proxy or certifications).

Use [`get_session`] to get a correctly configured `httpx.Client`.
N)_CLIENT_LOCKclose_sessionr   )r   s    r/   set_client_factoryr   +  s     
!/ 
s   
+async_client_factoryc                     U q g)a  
Set the HTTP async client factory to be used by `huggingface_hub`.

The async client factory is a method that returns a `httpx.AsyncClient` object.
This can be useful if you are running your scripts in a specific environment requiring custom configuration (e.g. custom proxy or certifications).
Use [`get_async_client`] to get a correctly configured `httpx.AsyncClient`.

<Tip warning={true}>

Contrary to the `httpx.Client` that is shared between all calls made by `huggingface_hub`, the `httpx.AsyncClient` is not shared.
It is recommended to use an async context manager to ensure the client is properly closed when the context is exited.

</Tip>
Nr   )r   s    r/   set_async_client_factoryr   <  s
      $8 r.   c                      [         c  [           [        5       q SSS5        [         $ [         $ ! , (       d  f       [         $ = f)z
Get a `httpx.Client` object, using the transport factory from the user.

This client is shared between all calls made by `huggingface_hub`. Therefore you should not close it manually.

Use [`set_client_factory`] to customize the `httpx.Client`.
N)r   r   r   r$   r.   r/   get_sessionr   O  s3     35N > \s	   -
A c                      [        5       $ )a  
Return a `httpx.AsyncClient` object, using the transport factory from the user.

Use [`set_async_client_factory`] to customize the `httpx.AsyncClient`.

<Tip warning={true}>

Contrary to the `httpx.Client` that is shared between all calls made by `huggingface_hub`, the `httpx.AsyncClient` is not shared.
It is recommended to use an async context manager to ensure the client is properly closed when the context is exited.

</Tip>
r   r$   r.   r/   get_async_sessionr   ^  s     ())r.   c                      [         n Sq U b   U R                  5         gg! [         a"  n[        R	                  SU 35         SnAgSnAff = f)z
Close the global `httpx.Client` used by `huggingface_hub`.

If a Client is closed, it will be recreated on the next call to [`get_session`].

Can be useful if e.g. an SSL certificate has been updated.
NzError closing client: )r   close	Exceptionrf   warning)clientes     r/   r   r   n  sT     F N 	9LLN   	9NN3A3788	9s    
AAAregister_at_fork)after_in_child._DEFAULT_RETRY_ON_EXCEPTIONS)  i  i  i  i  _DEFAULT_RETRY_ON_STATUS_CODES      F)max_retriesbase_wait_timemax_wait_timeretry_on_exceptionsretry_on_status_codesstreamrh   r   r   r   r   r   r   c          	   +   N  ^ ^^^^^#    [        U[        5      (       a  U4n[        T[        5      (       a  T4mSmUn	SmSn
SU;   a;  [        US   [        R                  [
        45      (       a  US   R                  5       n
[        5       n TS-  mSm U
b  US   R                  U
5        S[        R                  S[        4UU UUUU4S jjnU(       a;  UR                  " ST TS.UD6 nU" U5      (       d  Uv    SSS5        g SSS5        O(UR                  " ST TS.UD6nU" U5      (       d  Uv   g Tb.  [%        T5      S-   n[        R                  SU ST ST S35        O!U	n[        R                  SU ST ST S35        [&        R(                  " U5        [+        XIS-  5      n	GM%  ! , (       d  f       N= f! U aY  n[        R                  S	U S
T  ST 35        [        U[        R                   5      (       a
  [#        5         TT:  a  Ue SnANSnAff = f7f)zfInternal implementation of HTTP backoff logic shared between `http_backoff` and `http_stream_backoff`.r   Ndatar   ro   r1   c                   > U R                   T;  a  g[        R                  SU R                    ST ST 35        TT:  a  [        U 5        gU R                   S:X  a$  [	        U R
                  5      nUb  UR                  mg)zNHandle response and return True if should retry, False if should return/yield.FzHTTP Error z thrown while requesting  r   T)rr   rf   r   hf_raise_for_statusrB   r0   r!   )ro   ratelimit_infor   rh   nb_triesratelimit_resetr   rM   s     r/   _should_retry)_http_backoff_base.<locals>._should_retry  s     ''/DD  X-A-A,BB[\b[ccdehdijkk)'1 ! ''3.%<X=M=M%NN%1*8*I*Ir.   rh   rM   'z' thrown while requesting r   zRate limited. Waiting zs before retry [Retry rQ   z].zRetrying in z	s [Retry r   r$   )
isinstancetyper,   ioIOBaser   tellr   seekr|   Responseboolr   r^   rf   r   ConnectErrorr   floattimesleepmin)rh   rM   r   r   r   r   r   r   kwargs
sleep_timeio_obj_initial_posr   r   ro   erractual_sleepr   r   s   ```   `         @@r/   _http_backoff_baser     s:     %t,,24'--!6 8HJ"&O
 Jvf~		<7PQQ#F^002]F
A0	 "-v##$67 4  . ]]D&cDVD(22& ED2 ED
 ">>KSKFK$X.."N / & 1A5LNN3L>AWX`Waabcnbooqrs%LNN\,y
!K=XZ[\

<  Q7
 D ED # 	NNQse#=fXQseLM#u1122+%	 &	so   BH%AG +F2>G H%G H%&G 7A;H%2
G <G ?H% G H"	AHH%H""H%)r   r   r   r   r   c                <    [        [        SU UUUUUUSS.UD65      $ )ax
  Wrapper around httpx to retry calls on an endpoint, with exponential backoff.

Endpoint call is retried on exceptions (ex: connection timeout, proxy error,...)
and/or on specific status codes (ex: service unavailable). If the call failed more
than `max_retries`, the exception is thrown or `raise_for_status` is called on the
response object.

Re-implement mechanisms from the `backoff` library to avoid adding an external
dependencies to `hugging_face_hub`. See https://github.com/litl/backoff.

Args:
    method (`Literal["GET", "OPTIONS", "HEAD", "POST", "PUT", "PATCH", "DELETE"]`):
        HTTP method to perform.
    url (`str`):
        The URL of the resource to fetch.
    max_retries (`int`, *optional*, defaults to `5`):
        Maximum number of retries, defaults to 5 (no retries).
    base_wait_time (`float`, *optional*, defaults to `1`):
        Duration (in seconds) to wait before retrying the first time.
        Wait time between retries then grows exponentially, capped by
        `max_wait_time`.
    max_wait_time (`float`, *optional*, defaults to `8`):
        Maximum duration (in seconds) to wait before retrying.
    retry_on_exceptions (`type[Exception]` or `tuple[type[Exception]]`, *optional*):
        Define which exceptions must be caught to retry the request. Can be a single type or a tuple of types.
        By default, retry on `httpx.TimeoutException` and `httpx.NetworkError`.
    retry_on_status_codes (`int` or `tuple[int]`, *optional*, defaults to `(429, 500, 502, 503, 504)`):
        Define on which status codes the request must be retried. By default, retries
        on rate limit (429) and server errors (5xx).
    **kwargs (`dict`, *optional*):
        kwargs to pass to `httpx.request`.

Example:
```
>>> from huggingface_hub.utils import http_backoff

# Same usage as "httpx.request".
>>> response = http_backoff("GET", "https://www.google.com")
>>> response.raise_for_status()

# If you expect a Gateway Timeout from time to time
>>> http_backoff("PUT", upload_url, data=data, retry_on_status_codes=504)
>>> response.raise_for_status()
```

> [!WARNING]
> When using `requests` it is possible to stream data by passing an iterator to the
> `data` argument. On http backoff this is a problem as the iterator is not reset
> after a failed call. This issue is mitigated for file objects or any IO streams
> by saving the initial position of the cursor (with `data.tell()`) and resetting the
> cursor between each call (with `data.seek()`). For arbitrary iterators, http backoff
> will fail. If this is a hard constraint for you, please let us know by opening an
> issue on [Github](https://github.com/huggingface/huggingface_hub).
Frh   rM   r   r   r   r   r   r   r$   )nextr   rh   rM   r   r   r   r   r   r   s           r/   http_backoffr     sA    B  
	
#)' 3"7
	
 
	
 r.   c             +   H   #    [        SU UUUUUUSS.UD6 Sh  vN   g N7f)a
  Wrapper around httpx to retry calls on an endpoint, with exponential backoff.

Endpoint call is retried on exceptions (ex: connection timeout, proxy error,...)
and/or on specific status codes (ex: service unavailable). If the call failed more
than `max_retries`, the exception is thrown or `raise_for_status` is called on the
response object.

Re-implement mechanisms from the `backoff` library to avoid adding an external
dependencies to `hugging_face_hub`. See https://github.com/litl/backoff.

Args:
    method (`Literal["GET", "OPTIONS", "HEAD", "POST", "PUT", "PATCH", "DELETE"]`):
        HTTP method to perform.
    url (`str`):
        The URL of the resource to fetch.
    max_retries (`int`, *optional*, defaults to `5`):
        Maximum number of retries, defaults to 5 (no retries).
    base_wait_time (`float`, *optional*, defaults to `1`):
        Duration (in seconds) to wait before retrying the first time.
        Wait time between retries then grows exponentially, capped by
        `max_wait_time`.
    max_wait_time (`float`, *optional*, defaults to `8`):
        Maximum duration (in seconds) to wait before retrying.
    retry_on_exceptions (`type[Exception]` or `tuple[type[Exception]]`, *optional*):
        Define which exceptions must be caught to retry the request. Can be a single type or a tuple of types.
        By default, retry on `httpx.TimeoutException` and `httpx.NetworkError`.
    retry_on_status_codes (`int` or `tuple[int]`, *optional*, defaults to `(429, 500, 502, 503, 504)`):
        Define on which status codes the request must be retried. By default, retries
        on rate limit (429) and server errors (5xx).
    **kwargs (`dict`, *optional*):
        kwargs to pass to `httpx.request`.

Example:
```
>>> from huggingface_hub.utils import http_stream_backoff

# Same usage as "httpx.stream".
>>> with http_stream_backoff("GET", "https://www.google.com") as response:
...     for chunk in response.iter_bytes():
...         print(chunk)

# If you expect a Gateway Timeout from time to time
>>> with http_stream_backoff("PUT", upload_url, data=data, retry_on_status_codes=504) as response:
...     response.raise_for_status()
```

<Tip warning={true}>

When using `httpx` it is possible to stream data by passing an iterator to the
`data` argument. On http backoff this is a problem as the iterator is not reset
after a failed call. This issue is mitigated for file objects or any IO streams
by saving the initial position of the cursor (with `data.tell()`) and resetting the
cursor between each call (with `data.seek()`). For arbitrary iterators, http backoff
will fail. If this is a hard constraint for you, please let us know by opening an
issue on [Github](https://github.com/huggingface/huggingface_hub).

</Tip>
Tr   Nr$   )r   r   s           r/   http_stream_backoffr   >  sA     L " 
%#/3
 
 
 
s   " ")retry_on_errorsr   c                P   U(       a  0 OSSS.n [        SU US.UDSS0DUD6n[        U5        SUR                  s=::  a  S::  a_  O   U$ [        UR                  S   5      nUR
                  S	:X  a2  [        U5      R                  UR                  S
9R                  5       nM   U$ )a  Perform an HTTP request with backoff and follow relative redirects only.

Used to fetch HEAD /resolve on repo or bucket files.

This is useful to follow a redirection to a renamed repository without following redirection to a CDN.

A backoff mechanism retries the HTTP call on errors (429, 5xx, timeout, network errors).

Args:
    method (`str`):
        HTTP method, such as 'GET' or 'HEAD'.
    url (`str`):
        The URL of the resource to fetch.
    retry_on_errors (`bool`, *optional*, defaults to `False`):
        Whether to retry on errors. If False, no retry is performed (fast fallback to local cache).
        If True, uses default retry behavior (429, 5xx, timeout, network errors).
    **httpx_kwargs (`dict`, *optional*):
        Params to pass to `httpx.request`.
r$   )r   r   r   rz   Fi,  i  Location )path)	r   r   rr   r   r0   netloc_replacer   geturl)rh   rM   r   httpx_kwargsno_retry_kwargsro   parsed_targets          r/   -_httpx_follow_relative_redirects_with_backoffr     s    0 2XZ#[   

 
 #	

 
 	H% (&&-#- 	O %X%5%5j%ABM##r)sm,,-2D2D,ELLN 	Or.   endpointc                    U(       a  UR                  S5      O[        R                  nU[        R                  [        R                  4;  a@  U R                  [        R                  U5      n U R                  [        R                  U5      n U $ )zReplace the default endpoint in a URL by a custom one.

This is useful when using a proxy and the Hugging Face Hub returns a URL with the default endpoint.
rQ   )rstripr   ENDPOINT_HF_DEFAULT_ENDPOINT_HF_DEFAULT_STAGING_ENDPOINTreplace)rM   r   s     r/   fix_hf_endpoint_in_urlr     sf    
 (0xs#Y5G5GH	66	8^8^__kk)88(Ckk)@@(KJr.   endpoint_namec           	      	    [        U 5         U R	                  5         g! [         a    [        R                  SSS9   N2f = f! [
        R                   Ga.  nU R                  S-  S:X  a   SnAgU R                  R                  S5      nU R                  R                  S5      nU R                  b6  U R                  R                  b  [        U R                  R                  5      OSnU(       a  [        U5      OS	u  pgUS
:X  a3  U R                   S3S-   SU R                   S3-   n[        [        XXgS9UeUS:X  a3  U R                   S3S-   SU R                   S3-   n[        [         XXgS9UeUS:X  a3  U R                   S3S-   SU R                   S3-   n[        ["        XXgS9UeUS:X  a:  U R                   S3S-   SU R                   S3-   S-   S-   n[        [$        X5      UeUS:X  a[  UbX  [&        R)                  U5      bB  U R                   S3S-   SU R                   S3-   S-   S-   n[        [*        X[-        U5      S9UeUS:X  d/  U R                  S:X  aX  US:w  aR  UbO  [.        R)                  U5      b9  U R                   S3S-   SU R                   S3-   S-   S -   n[        [0        XXgS9UeU R                  S!:X  a  Ub  S"U S#3OS$n[        [2        X5      UeU R                  S%:X  a8  SU R                   S&U S3S'U R                   S3-   S(-   n[        [4        X5      UeU R                  S):X  a  [7        U R                  5      n	U	b  S*U	R8                   S+3nUS,U	R:                   S-3-  nU	R<                  b;  U	R>                  b.  US.U	R@                   S/U	R<                   S0U	R>                   S13-  nOUS-  nUS2U R                   S3-  nOS3U R                   S3n[        [4        X5      UeU R                  S4:X  aZ  U R                  R                  R                  S55      n
U S6U
 S7U R                  R                  S85       S3n[        [4        X5      Ue[        [4        [        U5      U 5      UeSnAff = f)9ad  
Internal version of `response.raise_for_status()` that will refine a potential HTTPError.
Raised exception will be an instance of [`~errors.HfHubHTTPError`].

This helper is meant to be the unique method to raise_for_status when making a call to the Hugging Face Hub.

Args:
    response (`Response`):
        Response from the server.
    endpoint_name (`str`, *optional*):
        Name of the endpoint that has been called. If provided, the error message will be more complete.

> [!WARNING]
> Raises when the request has failed:
>
>     - [`~utils.RepositoryNotFoundError`]
>         If the repository to download from cannot be found. This may be because it
>         doesn't exist, because `repo_type` is not set correctly, or because the repo
>         is `private` and you do not have access.
>     - [`~utils.GatedRepoError`]
>         If the repository exists but is gated and the user is not on the authorized
>         list.
>     - [`~utils.RevisionNotFoundError`]
>         If the repository exists but the revision couldn't be found.
>     - [`~utils.EntryNotFoundError`]
>         If the repository exists but the entry (e.g. the requested file) couldn't be
>         find.
>     - [`~utils.BadRequestError`]
>         If request failed with a HTTP 400 BadRequest error.
>     - [`~utils.HfHubHTTPError`]
>         If request failed for a reason not listed above.
zFailed to parse warning headersT)exc_infod   rP   NzX-Error-CodeX-Error-MessagerO   RevisionNotFoundz Client Error.

zRevision Not Found for url: .)rV   rY   EntryNotFoundzEntry Not Found for url: 	GatedRepoz!Cannot access gated repo for url z$Access to this resource is disabled.z!Cannot access repository for url 
RepoNotFoundzBucket Not Found for url: zG
Please make sure you specified the correct bucket id (namespace/name).zg
If the bucket is private, make sure you are authenticated and your token has the required permissions.)	bucket_idi  z+Invalid credentials in Authorization headerzRepository Not Found for url: z
Please make sure you specified the correct `repo_id` and `repo_type`.
If you are trying to access a private or gated repo, make sure you are authenticated and your token has the required permissions.zQ
For more details, see https://huggingface.co/docs/huggingface_hub/authenticationrq   z

Bad request for z
 endpoint:z

Bad request:i  z Forbidden: z
Cannot access content at: z2
Make sure your token has the correct permissions.r   z0

429 Too Many Requests: you have reached your 'z' rate limit.z
Retry after z seconds (rQ   z requests remaining in current z
s window).z
Url: z!

429 Too Many Requests for url: i  Rangez. Requested range: z. Content-Range: zContent-Range)!_warn_on_warning_headersr   rf   rg   raise_for_statusr|   HTTPStatusErrorrr   r0   rT   r^   rM   r*   rZ   _formatr   r   r   r   BUCKET_API_REGEXr:   r   r]   REPO_API_REGEXr   r   r   rB   r   r!   r"   r#   r    )ro   r   r   
error_codeerror_messagerequest_urlrV   rY   messager   range_headers              r/   r   r     sn   BG *
u?!!#  G6FG    s?3&!+%%)).9
 ((,,->? *2)9)9)E(JZJZJ^J^JjC  $$%pt 	 HS6{CXd	++!--.n=FKghphthtguuvIwwG/iiopp?*!--.n=FKdemeqeqdrrsIttG2GQZlrss;&''(7&@EfgogsgsfttuCvv  .'ybhiiDD''(75hll^1EF  9	9  +W?QF .(' ''4@ ''(7.x||nA>? ]] }	}  #WB[\gBh >)  C'!NN'%%k2> ''(728<<.BC`` gg  17PYkqrr!!S(DQD]&}oZ@cu  /7=1D!!S(x++,LqI0a@AGH 
 .'<!C!!S(4X5E5EFN)HIeIeHffst  ^N,K,K+LHUU!''38U8U8a^556a8L8L7M N''5'D'D&EZQG
 sNGWX\\N!44?~QO.'<!C!!S(#++3377@L.|n<MhN^N^NbNbcrNsMttuvG.'<!C nc!fh7Q>gs?s,    A A A RR0PRRc                 F   U R                   R                  S5      nU H  nSU;   a  UR                  SS5      OSU4u  p4UR                  5       nU[        ;  d  M=  UR                  5       nU(       d  MV  [        R                  U5        [        R                  U5        M     g)a}  
Emit warnings if warning headers are present in the HTTP response.

Expected header format: 'X-HF-Warning: topic; message'

Only the first warning for each topic will be shown. Topic is optional and can be empty. Note that several warning
headers can be present in a single response.

Args:
    response (`httpx.Response`):
        The HTTP response to check for warning headers.
zX-HF-Warning;r   r   N)r0   get_listsplitstrip_WARNED_TOPICSaddrf   r   )ro   server_warningsserver_warningtopicr   s        r/   r   r   s  s     &&//?O)9<9N--c15UWYgTh&mmoGw""5)w' *r.   _HfHubHTTPErrorT)bound
error_typecustom_messageattrsc                    / nUR                   R                  S5      nUb  UR                  U5          UR                  5       nUR                  S5      nUb8  [        U[        5      (       a  UR                  U5        OUR                  U5        UR                  S5      nUb%  U H  nSU;   d  M  UR                  US   5        M!     U V
s/ s H<  n
[        U
5      R                  5       (       d  M#  [        U
5      R                  5       PM>     nn
[        [         R#                  U5      5      nSR%                  U5      nUnU(       a9  UR                  5       UR                  5       ;  a  S	U;   a	  USU-   -  nOUS	U-   -  nSnSn[&        S
4[(        S4[*        S44 H>  u  nnUR                   R                  U5      nU(       d  M*  [        U5      nSU SU S3n  O   U(       aL  UR                  5       UR                  5       ;  a*  SU;   a   UR-                  S5      nUS U U-   UUS  -   nOX-  nU " UR                  5       X+=(       d    S S9nUR/                  5        H  u  nn[1        UUU5        M     U$ ! [        R
                   a9     UR                  5         UR                  5       n GNn! [         a    0 n  GN~f = ff = f! [        R                   a`    UR                   R                  SS5      n	UR                  (       a/  SU	R                  5       ;  a  UR                  UR                  5         GNtf = fs  sn
f )Nr   errorerrorsr   zContent-Typer   htmlr   r   z
Request IDzAmzn Trace IDz	Amz CF IDr   : ))ro   server_message)r0   rT   appendjsonr|   ResponseNotReadreadRuntimeErrorr   listextendJSONDecodeErrortextr8   r*   r   dictfromkeysjoinrc   rb   X_AMZ_CF_IDindexitemssetattr)r  r  ro   r  server_errorsfrom_headersr   r	  r
  content_typeliner  final_error_messagerk   request_id_messageheaderlabelvaluenewline_indexr   kvs                         r/   r   r     s)    M ##''(9:L\*$0	==?D !%&&$$U+ $$U+(#%!((y)9:   4AV=4CIOODU&SY__&=MV }56M YY}-N )...08L8L8NN^#4.#886N#:: J	|$	/*	k"
   $$V,5UJ#%eWBugQ!7 j&&(0C0I0I0KK&&/55d;M#N]36HHK^_l_mKnn    5 (..08Tjfj
kC1Q Ja $$ 
		}}  	
	8  0''++NB?==V<+=+=+??  /	0 Wsa   I: A)K
 1K
 "M3M:K J2/K
 2K>K?K
 KKK
 
A0L>=L>c                    SSU R                   4/n[        U R                  R                  5       5       H(  u  p#UR	                  5       S:X  a  SnUSU SU 34/-  nM*     Sn U R
                  b1  U R
                  R                  SS	S
9n[        U5      S:  a  USS  S3nUb  USUR                  SS5      4/-  nUSU R                  4/-  n/ nU H[  u  p#U(       a#  UR                  [        [        U5      5      5        U(       d  M8  UR                  [        [        U5      5      5        M]     SR                  U5      $ ! [        R                   a    Sn Nf = f)zConvert a `httpx.Request` into a curl command (str).

Used for debug purposes only.

Implementation vendored from https://github.com/ofw/curlify/blob/master/curlify.py.
MIT License Copyright (c) 2016 Egor.
)curlNz-Xr`   z<TOKEN>z-Hr  Nzutf-8ignore)r
  i  z ... [truncated]z<streaming body>z-dr   r   r   )rh   sortedr0   r  r8   contentdecodelenr|   RequestNotReadr   rM   r  r   r*   r  )r^   partsr)  r*  body
flat_partss         r/   rj   rj     sd    		w~~$E
 w,,./779'A4A3b%&& 0
 D"??&??))'()CD4y4u+&67 4dB/011	tW[[!""EJeCFm,1eCFm,	  88J  "!"s   #>E EEz%^\s*bytes\s*=\s*(\d*)\s*-\s*(\d*)\s*$original_rangeresume_sizec                    U (       d  SU S3$ SU ;   a  [        SU < S35      e[        R                  U 5      nU(       d  [        SU < S35      eUR	                  5       u  p4U(       dB  U(       d  [        SU < S35      e[        U5      U-
  nSU 3nUS	::  a  [        S
U< S35      eU$ [        U5      nX1-   nU(       a*  [        U5      nSU SU 3nXt:  a  [        S
U< S35      eU$ SU S3$ )z:
Adjust HTTP Range header to account for resume position.
zbytes=-,zMultiple ranges detected - z, not supported yet.zInvalid range format - r   zbytes=-r   zEmpty new range - )rs   RANGE_REGEXr@   r  groupsr,   )r6  r7  r@   startend
new_suffix	new_range	new_starts           r/   _adjust_range_headerrB    s!    }A&&
n6~6HH\]^^n-E4^4FaHIIJE!88J!LMMX+
j\*	?!3I=BCCJE#I
#hYKq.	?!3I=BCCI;a  r.   )r1   N)N)qr)   atexitr   r  osre	threadingr   rd   collections.abcr   r   r   
contextlibr   dataclassesr   shlexr   typingr	   r
   urllib.parser   r|   huggingface_hub.errorsr   r   r   r
  r   r   r   r   r   r   r   r   r   _lfsr   _typingr   
get_loggerr%   rf   r   compiler9   r<   r*   rB   rc   rb   r  VERBOSEr   r   rR   r\   rU   tuplerZ   r]   Requestrl   rn   r   rv   r}   r~   r   r   CLIENT_FACTORY_TASYNC_CLIENT_FACTORY_TLockr   r   r+   r   r   r   r   r   r   r   registerhasattrr   TimeoutExceptionNetworkErrorr   r   r   r   r,   r   r   r   r   r   r   r   r   setr   r   r  r   rj   
IGNORECASEr;  rB  r$   r.   r/   <module>r^     s2   E  	  	 	    8 8 % !   !  7 	 	 	   " 
		H	% $& & &, ::mn **%OP 8WS#X%6 8=4;O 8z #
 ** :: **  **%ij  JJ'ST  q 3 5tS4Z1G+H 2-3 -3: -5== T B*u}} * *' 'D ' e&7&7  B,- !"e&7&7"78 ~~+A ( A7S 4 S&*t# *0'7 0D 0"83I 8d 8&U\\ *5,, * 9,  
2!""}5 >C=S=SUZUgUg<h eDOS$89 h2K c3h K Ie3Q^8^8	^8 	^8
 ^8 ^8 i5i#1E+FF^8 sCx0^8 ^8 u~~tT)*^8J Ie3QMM	M 	M
 M M i5i#1E+FFM sCx0M ^^M` 
 Ie3QOO	O 	O
 O O i5i#1E+FFO sCx0O u~~tT)*O Of AF00 #09=0
^^0f
 
sTz 
c 
\?%.. \?t \?W[ \?~ (u~~ ($ (0 -^D _%&_8;_GL~~_`c__D& emm &  & T jjA2==Q"!t "!# "!#PT* "!r.   