kQjGdZddlmZmZddlmZmZmZmZddl Z ddl Z GddeZ Gdde Z Gd d e Z y) aHeader providers for LanceDB remote connections. This module provides a flexible header management framework for LanceDB remote connections, allowing users to implement custom header strategies for authentication, request tracking, custom metadata, or any other header-based requirements. The module includes the HeaderProvider abstract base class and example implementations (StaticHeaderProvider and OAuthProvider) that demonstrate common patterns. The HeaderProvider interface is designed to be called before each request to the remote server, enabling dynamic header scenarios where values may need to be refreshed, rotated, or computed on-demand. )ABCabstractmethod)DictOptionalCallableAnyNc0eZdZdZedeeeffdZy)HeaderProvideraAbstract base class for providing custom headers for each request. Users can implement this interface to provide dynamic headers for various purposes such as authentication (OAuth tokens, API keys), request tracking (correlation IDs), custom metadata, or any other header-based requirements. The provider is called before each request to ensure fresh header values are always used. Error Handling -------------- If get_headers() raises an exception, the request will fail. Implementations should handle recoverable errors internally (e.g., retry token refresh) and only raise exceptions for unrecoverable errors. returncy)aGet the latest headers to be added to requests. This method is called before each request to the remote LanceDB server. Implementations should return headers that will be merged with existing headers. Returns ------- Dict[str, str] Dictionary of header names to values to add to the request. Raises ------ Exception If unable to fetch headers, the exception will be propagated and the request will fail. Nselfs Z/home/oem/CyberBrain26-unified/.venv/lib/python3.12/site-packages/lancedb/remote/header.py get_headerszHeaderProvider.get_headers(s$ N)__name__ __module__ __qualname____doc__rrstrrr rrr r s*  T#s(^  rr c<eZdZdZdeeeffdZdeeeffdZy)StaticHeaderProvideraExample implementation: A simple header provider that returns static headers. This is an example implementation showing how to create a HeaderProvider for cases where headers don't change during the session. Users can use this as a reference for implementing their own providers. Parameters ---------- headers : Dict[str, str] Static headers to return for every request. headersc.|j|_y)zInitialize with static headers. Parameters ---------- headers : Dict[str, str] Headers to return for every request. N)copy_headers)rrs r__init__zStaticHeaderProvider.__init__Js  rr c6|jjS)zReturn the static headers. Returns ------- Dict[str, str] Copy of the static headers. )rrrs rrz StaticHeaderProvider.get_headersTs}}!!##rN)rrrrrrrrr rrrr=s/ 'S#X'$T#s(^$rrcXeZdZdZ d degefdefdZd dZde fdZ de e e ffd Z y) OAuthProvideraExample implementation: OAuth token provider with automatic refresh. This is an example implementation showing how to manage OAuth tokens with automatic refresh when they expire. Users can use this as a reference for implementing their own OAuth or token-based authentication providers. Parameters ---------- token_fetcher : Callable[[], Dict[str, Any]] Function that fetches a new token. Should return a dict with 'access_token' and optionally 'expires_in' (seconds until expiration). refresh_buffer_seconds : int, optional Number of seconds before expiration to trigger refresh. Default is 300 (5 minutes). token_fetcherrefresh_buffer_secondscn||_||_d|_d|_t j |_y)abInitialize the OAuth provider. Parameters ---------- token_fetcher : Callable[[], Any] Function to fetch new tokens. Should return dict with 'access_token' and optionally 'expires_in'. refresh_buffer_seconds : int, optional Seconds before expiry to refresh token. Default 300. N)_token_fetcher_refresh_buffer_current_token_token_expires_at threadingLock _refresh_lock)rr"r#s rrzOAuthProvider.__init__ps3,5-126&^^-rr NcN|j5|jrt|j}|jd|_|js t d|jd}|t j |z|_nd|_dddy#1swYyxYw)z7Refresh the token if it's expired or close to expiring. access_tokenz+Token fetcher did not return 'access_token' expires_inN)r+_needs_refreshr%getr' ValueErrortimer()r token_datar.s r_refresh_token_if_neededz&OAuthProvider._refresh_token_if_neededs    2""$!002 &0nn^&D#**$%RSS(^^L9 )-1YY[:-ED*.2D* 2 2 2s BBB$c|jy|jytj|j|jz k\S)zCheck if token needs refresh.TF)r'r(r2r&rs rr/zOAuthProvider._needs_refreshsD    &  ! ! )yy{t558L8LLMMrct|j|js tdd|jddS)aGet OAuth headers, refreshing token if needed. Returns ------- Dict[str, str] Headers with Bearer token authorization. Raises ------ Exception If unable to fetch or refresh token. zFailed to obtain OAuth tokenzBearer oidc) Authorizationzx-lancedb-credential-type)r4r' RuntimeErrorrs rrzOAuthProvider.get_headerssE %%'""=> > 't':':&;<)/  r)i,)r N)rrrrrrintrr4boolr/rrrr rrr!r!_sS"OR.%b#g..HK.&2& N N T#s(^ rr!)rabcrrtypingrrrrr2r)r rr!r rrr>sC $00 ! S! H$>$DX NX r