U[iّ<UdZddlZddlZddlZddlZddlZddlZddlZddlZddl m Z ddl m Z ddl mZddlmZmZmZmZmZmZddlZddlmZdd lmZdd lmZmZmZmZm Z m!Z!m"Z"d d lm#Z#d d l$m%Z%d dl&m'Z'e#jPe)Z*e dGddZ+ejXdZ-ejXdZ.dee/e/fdee+fdZ0dZ1dZ2ejXdejfZ4dejjddfdZ6dejjddfdZ7dejpddfd Z9dejtfd!Z;dejxfd"Z=egejtfZ>egejxfZ?ejZAe;aBe>eCd#<e=aDe?eCd$<daEeejteCd%<d&e>ddfd'ZFd(e?ddfd)ZGdejtfd*ZHdejxfd+ZIdPd,ZJejeJeLed-rejeJ.ejejfZPeQeReSd/feCd0<d1ZTeQeUd/feCd2<d3d d4ePeTd5d6d7e'd8e/d9eUd:eVd;eVdeWdeejpddffd?ZXd3d d4ePeTd@d7e'd8e/d9eUd:eVd;eVdContains utilities to handle HTTP requests in huggingface_hub.N)contextmanager) dataclass)quote)AnyCallable GeneratorMappingOptionalUnion)OfflineModeIsEnabled) constants)BadRequestErrorDisabledRepoErrorGatedRepoErrorHfHubHTTPErrorRemoteEntryNotFoundErrorRepositoryNotFoundErrorRevisionNotFoundError)logging) SliceFileObj) HTTP_METHOD_TT)frozencXeZdZUdZeed<eed<eed<dZeeed<dZ eeed<y) RateLimitInfoa 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 remainingreset_in_secondsNlimitwindow_seconds) __name__ __module__ __qualname____doc__str__annotations__intr r r!i/var/www/html/chatbot/Makanify-Chatbot-3/venv/lib/python3.12/site-packages/huggingface_hub/utils/_http.pyrr4s6 NE8C=$(NHSM(r*rzL\"(?P\w+)\"\s*;\s*r\s*=\s*(?P\d+)\s*;\s*t\s*=\s*(?P\d+)z'q\s*=\s*(?P\d+).*?w\s*=\s*(?P\d+)headersreturncd}d}|D](}|j}|dk(r||}|dk(s$||}*|sytj|}|sy|jd}t |jd}t |jd}d} d} |rKt j|} | r4t | jd} t | jd} t |||| | S) 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 ratelimitzratelimit-policyrrtqw)rrrr r!)lower_RATELIMIT_REGEXsearchgroupr(_RATELIMIT_POLICY_REGEXr) r,r/policykey lower_keymatchrrrr r! policy_matchs r+parse_ratelimit_headersr>Ps* $I F"IIK  # I , ,S\F "   # #I .E KK0MEKK$%I5;;s+,E$(N .55f=  **3/0E !3!3C!89N #)%  r*zX-Amzn-Trace-Idz x-request-ida  # staging or production endpoint ^https://[^/]+ ( # on /api/repo_type/repo_id /api/(models|datasets|spaces)/(.+) | # or /repo_id/resolve/revision/... /(.+)/resolve/(.+) ) )flagsrequestc Ntjrtd|jdt|j vrO|j j txsttj|j t<|j j t}tjd||j|j|j j ddutjrtjdt||S)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) authorizationNzSend: %s)ris_offline_moder urlX_AMZN_TRACE_IDr,get X_REQUEST_IDr&uuiduuid4loggerdebugmethodHF_DEBUG_curlify)r@ request_ids r+hf_request_event_hookrPs  ""GKK=)J K  goo-+2??+>+>|+L+aPSTXT^T^T`Pa($$_5J LL/ O,D8  Z'!23 r*c Kt|Sw)z3 Async version of `hf_request_event_hook`. )rP)r@s r+async_hf_request_event_hookrRs ! ))s responsecK|jdk\rGd|jvr8 t|jd}|dkr|j d{yyyy#t$rYywxYw7w)NzContent-lengthi@B) status_coder,r( ValueErroraread)rSlengths r+async_hf_response_event_hookrZss" x// / X--.>?@ !nn&&&" 0#   's3A+AA+A)A+ A&#A+%A&&A+ctjdtgidtjtj dS)zQ Factory function to create a `httpx.Client` with the default transport. r@TN@write event_hooksfollow_redirectstimeout)httpxClientrPTimeoutrDEFAULT_REQUEST_TIMEOUTr)r*r+default_client_factoryrgs8 <<!6 78 i??tL r*ctjtgtgddtjt j dS)zV Factory function to create a `httpx.AsyncClient` with the default transport. )r@rSTr\r]r_)rc AsyncClientrRrZrerrfr)r*r+default_async_client_factoryrjs=   !< =LhKij i??tL r*_GLOBAL_CLIENT_FACTORY_GLOBAL_ASYNC_CLIENT_FACTORY_GLOBAL_CLIENTclient_factorycRt5t|adddy#1swYyxYw)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_client`] 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_client`] to get a correctly configured `httpx.Client`. N) _CLIENT_LOCK close_sessionrk)rns r+set_client_factoryrrs' 0!/000s &async_client_factoryc|ay)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`. 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. Nrl)rss r+set_async_client_factoryrvs $8 r*cztt5tadddtStS#1swYtSxYw)a 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)rmrprkr)r*r+ get_sessionrxs6  635N 6 > 6 s ,:ctS)a Return a `httpx.AsyncClient` object, using the transport factory from the user. Use [`set_async_client_factory`] to customize the `httpx.AsyncClient`. 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. rur)r*r+get_async_sessionrz)s  ( ))r*ct}da| |jyy#t$r"}tj d|Yd}~yd}~wwxYw)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. NzError closing client: )rmclose ExceptionrJwarning)clientes r+rqrq9sTFN 9 LLN 9 NN3A37 8 8 9s A AA register_at_fork)after_in_child._DEFAULT_RETRY_ON_EXCEPTIONS)iiii_DEFAULT_RETRY_ON_STATUS_CODESF) max_retriesbase_wait_time max_wait_timeretry_on_exceptionsretry_on_status_codesstreamrLrDrrrrrrc +Kt|tr|f}ttrfd|} dd} d|vr6t|dtjt fr|dj } t} dz d | |dj| dtjdtffd } |r6| jdd|5} | | s|  dddy dddn"| jdd|} | | s| y.t%dz}tjd |d ddn!| }tjd|dddt'j(|t+|| dz} #1swYxYw#|$rS}tjd |d d t|tj r t#kDr|Yd}~d}~wwxYww)zfInternal implementation of HTTP backoff logic shared between `http_backoff` and `http_stream_backoff`.rNdatarrSr-c|jvrytjd|jddkDr t|y|jdk(r#t |j }| |j y)zNHandle response and return True if should retry, False if should return/yield.Fz HTTP Error z thrown while requesting  rT)rVrJr~hf_raise_for_statusr>r,r)rSratelimit_inforrLnb_triesratelimit_resetrrDs r+ _should_retryz)_http_backoff_base.._should_retrys''/DD X-A-A,BB[\b[ccdehdijkk)'1!''3.%>KSKFK$X."N  & 1A5L NN3L>AWX`Waabcnbooqr s%L NN\,y !K=XZ[ \ <  Q7  D#  NNQse#=fXQseL M#u112+% &  sWA;G3AFF  F(G3**FA8G3 FFG0A G+&G3+G00G3)rrrrrc <ttd|||||||dd|S)a0 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). FrLrDrrrrrrr))nextrrLrDrrrrrrs r+ http_backoffrsAB  #)' 3"7    r*c +HKtd|||||||dd|Ed{y7w)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() ``` 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). TrNr))rrs r+http_stream_backoffr sBL"  %#/3     s " "endpointc|r|jdntj}|tjtjfvr@|j tj|}|j tj|}|S)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. r)rstriprENDPOINT_HF_DEFAULT_ENDPOINT_HF_DEFAULT_STAGING_ENDPOINTreplace)rDrs r+fix_hf_endpoint_in_urlr\sf (0xs#Y5G5GH 66 8^8^__kk)88(Ckk)@@(K Jr* endpoint_namec  t| |j y#t$rtjddY4wxYw#t j $r}|jdzdk(rYd}~y|jjd}|jjd}|d k(r5|jd d zd |jd z}tt||||dk(r5|jd d zd|jd z}tt||||dk(r5|jd d zd|jd z}tt||||dk(r;|jd d zd|jd zdzdz}tt||||dk(sh|jdk(r|dk7r|j |j jjt"j%t'|j j8|jd d zd|jd zdz}tt(||||jdk(r|d|dnd}tt*||||jdk(r9d |jd|d d |jd zd!z}tt,||||jd"k(rt/|j}|d#|j0d$}|d%|j2d&z }|j4:|j6.|d'|j8d(|j4d)|j6d*z }n|d z }|d+|jd z }nd,|jd }tt,||||jd-k(r[|j jjd.}|d/|d0|jjd1d }tt,|||tt,t'|||d}~wwxYw)2a 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. zFailed to parse warning headersT)exc_infodNz X-Error-CodeX-Error-MessageRevisionNotFoundz Client Error. zRevision Not Found for url: . EntryNotFoundzEntry Not Found for url: GatedRepoz!Cannot access gated repo for url z$Access to this resource is disabled.z!Cannot access repository for url  RepoNotFoundiz+Invalid credentials in Authorization headerzRepository 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. For more details, see https://huggingface.co/docs/huggingface_hub/authenticationrUz Bad request for z endpoint:z Bad request:iz Forbidden: z Cannot access content at: z2 Make sure your token has the correct permissions.rz0 429 Too Many Requests: you have reached your 'z ' rate limit.z Retry after z secondsz (rz requests remaining in current z s window).z Url: z! 429 Too Many Requests for url: iRangez. Requested range: z. Content-Range: z Content-Range)_warn_on_warning_headersr}rJrKraise_for_statusrcHTTPStatusErrorrVr,rFrD_formatrrrrr@REPO_API_REGEXr6r&rrrr>rrr r!r)rSrr error_code error_messagemessager range_headers r+rrisBG * `?!!# G 6 FG  ^?   3 &! + %%)).9  ((,,->? + +!--.n=FKghphthtguuvIwwG/(C J ? *!--.n=FKdemeqeqdrrsIttG2GXFA M ; &''(7&@EfgogsgsfttuCvv .'8 )  C '!NN  ,  $$0%%c(*:*:*>*>&?@L''(728<<.BCNN 17HE1 L  ! !S (DQD]&}oZ@cu /7H=1 D  ! !S (x++,LqI0a@AGH  .'8}^?s- A AAPO;0N O;;Pc.|jjd}|D]u}d|vr|jddnd|f\}}|j}|tvs9|j}|sLtj |t j|wy)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;rN)r,get_listsplitstrip_WARNED_TOPICSaddrJr~)rSserver_warningsserver_warningtopicrs r+rrs&&//?O)(9<9N--c15UWYgThw   &mmoG""5)w'(r* error_typecustom_messagecg}|jjd}||j| |j}|jd}|3t|tr|j|n|j||jd}| |D]}d|vs|j|d|D cgc]5} t| jst| j7}} tt j#|}dj%|} |} | r5| j|jvrd |vr | d| zz } n| d | zz } t|jjt&d} | rd | d } n1t|jjt(d} | rd | d } | rI| j| jvr)d| vr | j+d}| d| z| |dz} n|  z } || j|| xsd S#tj $r7 |j |j}n#t$ri}YnwxYwY5wxYw#tj$rY|jjdd}|jr-d|jvr|j|jY+wxYwcc} w)Nrerrorerrorsrz Content-Typerhtmlrrz (Request ID: )z (Amzn Trace ID: )rSserver_message)r,rFappendjsonrcResponseNotReadread RuntimeErrorrlistextendJSONDecodeErrortextr4r&rdictfromkeysjoinrGrEindex)rrrS server_errors from_headersrrr content_typelinerfinal_error_messagerOrequest_id_message newline_indexs r+rrsM##''(9:L\*$0 ==?D!  %&$$U+$$U+(#   ;%!((y)9: ;4AV4CIOODUSY__&VMV}56MYY}-N)...08L8L8NN ^ # 4.#8 8  6N#: : X%%)),;z-Hz: Nzutf-8ignore)riz ... [truncated]zz-drrr)rLsortedr,itemsr4contentdecodelenrrrDrrr&r)r@partskvbody flat_partss r+rNrNds\  w~~$E w,,./'1 779 'A 4A3b%&&' D"%%gh%? t9t 5Dk]"23D  #!  4dB/011 tW[[! ""EJ-1   eCFm ,   eCFm , - 88J r*z%^\s*bytes\s*=\s*(\d*)\s*-\s*(\d*)\s*$original_range resume_sizec|sd|dSd|vrtd|dtj|}|std|d|j \}}|s:|std|dt ||z }d|}|d krtd |d|St |}||z}|r)t |}d|d|}||kDrtd |d|Sd|dS) zB Adjust HTTP Range header to account for resume position. zbytes=-,zMultiple ranges detected - z, not supported yet.zInvalid range format - rzbytes=-rzEmpty new range - )rW RANGE_REGEXr<rgroupsr()rrr<startend new_suffix new_range new_starts r+_adjust_range_headerrs'  }A&& n6~6HH\]^^   n -E 4^4FaHIIJE3 !88J!LM MX + j\* ?!3I=BC C JE #I #hYKq. s?!3I=BC C I;a  r*)r-N)N)er%atexitrrosre threadingrrH contextlibr dataclassesrshlexrtypingrrrr r r rchuggingface_hub.errorsr rrrrrrrrrrr_lfsr_typingr get_loggerr"rJrcompiler5r8r&r>rErGVERBOSErRequestrPrRrrZrdrgrirjCLIENT_FACTORY_TASYNC_CLIENT_FACTORY_TLockrprkr'rlrmrrrvrxrzrqregisterhasattrrTimeoutException NetworkErrorrtuplerr}rr(rrrrrrrsetrrrrN IGNORECASEr rr)r*r+r,sE  %!EE 7"   H % $))),2::mn$"**%OP8WS#X%688M;R8|$   **  5==TB*u}}** ' 'D ' e&7&7B ,-!"e&7&7"78y~~ +A(A7S4S)-&-0'70D0"83I8d8& U\\  *5,, * 9,  2!"B}5>C=S=SUZUgUg