5pjSSKrSSKrSSKrSSKJr SSKJr SSKrSSKJ r SSKJ r \R"S5r S \ S \4S jr"S S \ \5r\"SS9"SS55rS!S\R$S\ S-S \S-4Sjjr\ SSS.S\S\ S\ S\ S-S\ S-S \ 4 Sjj5r"SS5r\"5rSrS\\ \ 4S \\ \ 44SjrS rg)"N) dataclass)Enum) constants)validate_hf_hub_argsz^[0-9a-fA-F]{64}$xet_hashreturnc>[[RU55$)zLReturn whether `xet_hash` looks like a real Xet content hash (64 hex chars).)bool_REGEX_XET_HASH fullmatch)r s V/var/www/html/pdf-tiff/venv/lib/python3.13/site-packages/huggingface_hub/utils/_xet.pyis_valid_xet_hashrs ))(3 44c\rSrSrSrSrSrg) XetTokenTypereadwriteN)__name__ __module__ __qualname____firstlineno__READWRITE__static_attributes__rrrrrs D ErrT)frozenc*\rSrSr%\\S'\\S'Srg) XetFileData file_hash refresh_routerN)rrrrstr__annotations__rrrrr!r!s Nrr!responseendpointc"UcgUR[Rn[RUR;a!UR[RSnOUR[R nUbUO[RnUR[R5(a>UR[RRS5URS55n[UUS9$![ a gf=f)a2 Parse XET file metadata from an HTTP response. This function extracts XET file metadata from the HTTP headers or HTTP links of a given response object. If the required metadata is not found, it returns `None`. Args: response (`httpx.Response`): The HTTP response object containing headers dict and links dict to extract the XET metadata from. Returns: `Optional[XetFileData]`: An instance of `XetFileData` containing the file hash and refresh route if the metadata is found. Returns `None` if the required metadata is missing. Nurl/)r#r$) headersrHUGGINGFACE_HEADER_X_XET_HASH$HUGGINGFACE_HEADER_LINK_XET_AUTH_KEYlinks&HUGGINGFACE_HEADER_X_XET_REFRESH_ROUTEKeyErrorENDPOINT startswithHUGGINGFACE_CO_URL_HOMEreplacerstripr!)r'r(r#r$s r!parse_xet_file_data_from_responser7 s$$Y%L%LM  9 9X^^ K$NN9+Y+YZ[`aM$,,Y-]-]^M$/xY5G5GH A ABB%--i.O.O.V.VWZ.[]e]l]lmp]qr #  sAD"D D D)revisionr( token_typerepo_id repo_typer8cUbUO[RnUSUSUSURS3nUS:wdUbUSU3- nU$)a Build the URL used to fetch or refresh a Xet access token for a given repo. Args: token_type (`XetTokenType`): Type of the token to request: `"read"` or `"write"`. repo_id (`str`): A namespace (user or an organization) and a repo name separated by a `/`. repo_type (`str`): Type of the repo (e.g. `"model"`, `"dataset"`, `"space"`, `"bucket"`). revision (`str`, `optional`): The revision of the repo to get the token for. endpoint (`str`, `optional`): The endpoint to use for the request. Defaults to the Hub endpoint. Returns: `str`: The fully-qualified URL of the token refresh endpoint. z/api/zs/z/xet-z-tokenbucketr+)rr2value)r9r:r;r8r(r*s rxet_connection_info_refresh_urlr?Cs_4$/xY5G5GH JeI;b z7G7G6H OCH 4 8*~ Jrc*\rSrSrSrSrSrSrSrg)XetSessionHolderha'Holds an optional XetSession; supports safe re-creation after sigint_abort or fork. Thread-safe: a ``threading.Lock`` guards all state mutations, which matters for free-threaded Python (3.14t) where multiple threads can race on ``get()`` or ``sigint_abort()`` without the GIL serialising them. cT[R"5UlSUlSUlgN) threadingLock_lock_session _session_pidselfs r__init__XetSessionHolder.__init__ps^^%  (,rc$UR [R"5nURbURU:waSUlURcSSKJn U"5UlXlURsSSS5 $!,(df  g=f)zReturn the current session, creating one if needed. Fork-safe: if the current process PID differs from the PID that created the session (i.e. we are in a forked child), the old session is discarded and a fresh session is created for this process. Nr) XetSession)rGosgetpidrHrIhf_xetrO)rK current_pidrOs rgetXetSessionHolder.getuscZZ))+K}}(T->->+-M!% }}$- *  $/!==ZZs A*B BcUR URb)URR5 SUlSUlSSS5 g![a N#f=f!,(df  g=f)zMAbort the current session and clear it so the next get() creates a fresh one.N)rGrH sigint_abort ExceptionrIrJs rrWXetSessionHolder.sigint_aborts\ ZZ}}(MM..0!% $(!Z! Zs-AA A AAAA A+)rGrHrIN) rrrr__doc__rLrTrWrrrrrArAhs- !0 )rrAc*[R5$)aReturn the global :class:`hf_xet.XetSession`, creating it on first call. The session is shared across all calls within a process, just as the HTTP client returned by :func:`~huggingface_hub.utils._http.get_session` is shared. It is created lazily and is fork-safe and thread-safe. )_GLOBAL_XET_HOLDERrTrrrget_xet_sessionr]s  ! ! ##rr,cUR5VVs0sHupUR5S:wdMX_M snn$s snnf)zReturn a copy of headers with the authorization header removed. Xet storage requests use a short-lived xet access token for auth, so the Hub authorization header must not be forwarded to xet storage endpoints. authorization)itemslower)r,keyr>s rxet_headers_without_authrcs5 *1 [:3CIIK?rns= ! "**12555 3  $  #PT* `knr`r F   !!! ! Dj ! Dj ! !!H.).)b&'$\d38n\c3h\&r