Ë
|
|
çúhò. ã ó d dl Z d dlZd dlZd dlmZmZ d dlmZ d dlmZm Z m
|
Z
|
m Z d dl m Z mZ d dlmZ d dlmZ ej& e« Z G d d « Z G d
|
d « Z G d d « Z G d d« Zd Zde j6 fdZ y)é N)ÚdatetimeÚtimezone)Úsleep)ÚAnyÚ AwaitableÚCallableÚUnion)ÚRequestTokenErrÚTokenRenewalErr)ÚIdentityProviderInterface)Ú TokenResponsec óö e Zd ZdZd Zedeeegdf e f fd« Z
|
e
|
j deeegdf e f ddfd« Z
|
edeee gdf e f fd« Z e j deee gdf e f ddfd « Z y)
|
ÚCredentialsListenerzz
|
Listeners that will be notified on events related to credentials.
|
Accepts callbacks and awaitable callbacks.
|
c ó d | _ d | _ y ©N)Ú_on_nextÚ _on_error©Úselfs õk H:\项ç®\archive\æµè¯ç»\èæ¬\Change_password\venv_build\Lib\site-packages\redis/auth/token_manager.pyÚ__init__z CredentialsListener.__init__ s Ø Ø ó ÚreturnNc ó | j S r ©r r s r Úon_nextzCredentialsListener.on_next s à}}Ð r Úcallbackc ó || _ y r r ©r r s r r zCredentialsListener.on_next s à r c ó | j S r ©r r s r Úon_errorz CredentialsListener.on_error! s à~~Ð r c ó || _ y r r! r s r r" z CredentialsListener.on_error% s à!r )Ú__name__Ú
|
__module__Ú __qualname__Ú__doc__r Úpropertyr r r r r ÚsetterÚ Exceptionr" © r r r r så ñò
|
ð ð x¨¨¨t¨ Ñ 4°iÐ ?Ñ@ò ó ð ð ^^ð! h°¨u°d¨{Ñ&;¸YÐ&FÑ Gð !ÈDò !ó ð!ð ð % ¨)¨°dÐ):Ñ ;¸YÐ FÑGò ó ð ð __ð" x°° ¸TÐ0AÑ'BÀIÐ'MÑ!Nð "ÐSWò "ó ñ"r r c ó4 e Zd ZdedefdZdefdZdefdZy)Ú RetryPolicyÚ max_attemptsÚ delay_in_msc ó || _ || _ y r )r. r/ )r r. r/ s r r zRetryPolicy.__init__+ s Ø (ÔØ&Õr r c ó | j S )zW
|
Retry attempts before exception will be thrown.
|
|
:return: int
|
)r. r s r Úget_max_attemptsz RetryPolicy.get_max_attempts/ s ð × Ñ Ð r c ó | j S )zI
|
Delay between retries in seconds.
|
|
:return: int
|
)r/ r s r Úget_delay_in_mszRetryPolicy.get_delay_in_ms7 s ð × Ñ Ð r N)r$ r% r& ÚintÚfloatr r2 r4 r+ r r r- r- * s- ð' Sð '°uó 'ð! #ó !ð ô r r- c óT e Zd ZdedededefdZdefdZdefdZdefd Z defd
|
Z
|
y ) ÚTokenManagerConfigÚexpiration_refresh_ratioÚlower_refresh_bound_millisÚ%token_request_execution_timeout_in_msÚ retry_policyc ó< || _ || _ || _ || _ y r )Ú_expiration_refresh_ratioÚ_lower_refresh_bound_millisÚ&_token_request_execution_timeout_in_msÚ _retry_policy)r r9 r: r; r< s r r zTokenManagerConfig.__init__A s* ð *BÔ&Ø+EÔ(à 1ð Ô3ð *Õr r c ó | j S )a&
|
Represents the ratio of a token's lifetime at which a refresh should be triggered. # noqa: E501
|
For example, a value of 0.75 means the token should be refreshed
|
when 75% of its lifetime has elapsed (or when 25% of its lifetime remains).
|
|
:return: float
|
)r> r s r Ú get_expiration_refresh_ratioz/TokenManagerConfig.get_expiration_refresh_ratioO s ð ×-Ñ-Ð-r c ó | j S )a¤
|
Represents the minimum time in milliseconds before token expiration
|
to trigger a refresh, in milliseconds.
|
This value sets a fixed lower bound for when a token refresh should occur,
|
regardless of the token's total lifetime.
|
If set to 0 there will be no lower bound and the refresh will be triggered
|
based on the expirationRefreshRatio only.
|
|
:return: int
|
)r? r s r Ú get_lower_refresh_bound_millisz1TokenManagerConfig.get_lower_refresh_bound_millisZ s ð ×/Ñ/Ð/r c ó | j S )z
|
Represents the maximum time in milliseconds to wait
|
for a token request to complete.
|
|
:return: int
|
)r@ r s r Ú)get_token_request_execution_timeout_in_msz<TokenManagerConfig.get_token_request_execution_timeout_in_msg s ð ×:Ñ:Ð:r c ó | j S )z_
|
Represents the retry policy for token requests.
|
|
:return: RetryPolicy
|
)rA r s r Úget_retry_policyz#TokenManagerConfig.get_retry_policyp s ð ×!Ñ!Ð!r N) r$ r% r& r6 r5 r- r rC rE rG rI r+ r r r8 r8 @ s] ð *à"'ð *ð %(ð *ð 03ð *ð
|
"ó *ð .¨eó .ð 0°ó 0ð;¸3ó ;ð" +ô "r r8 c ó e Zd ZdedefdZd Z ddedede g df fd Z
|
dded
|
ed e dede g df f
|
d Z d Z ddefdZddefdZde de de fdZde fdZde de fdZ ddedej* fdZ ddedej* fdZy)Ú TokenManagerÚidentity_providerÚconfigc óX || _ || _ d | _ d | _ d | _ d| _ y )Nr )Ú_idpÚ_configÚ _next_timerÚ _listenerÚ _init_timerÚ_retries)r rL rM s r r zTokenManager.__init__z s0 ð & Ø Ø ÔØ Ø ÔØ r c óN t j d« | j « y )NzToken manager are disposed)ÚloggerÚinfoÚstopr s r Ú__del__zTokenManager.__del__ s Ü Ð0Ô1Ø r ÚlistenerÚ skip_initialr Nc óî || _ t j « }t j « }|j d| j ||« | _ t j d« t j |j! « |« j# « | j$ S # t $ rD t j « }t j t |fd¬« }|j « Y Öw xY w)NT)ÚtargetÚargsÚdaemonr úToken manager started)rR ÚasyncioÚget_running_loopÚ RuntimeErrorÚnew_event_loopÚ threadingÚThreadÚ_start_event_loop_in_threadÚstartÚEventÚ
|
call_laterÚ _renew_tokenrS rV rW Úrun_coroutine_threadsafeÚwaitÚresultrX )r rZ r[ ÚloopÚthreadÚ
|
init_events r rh zTokenManager.start sÉ ð
|
"ð Ü×+Ñ+Ó-Dô ]]_
|
Ø ??Ø t× Ñ ,°
|
ó
|
Ôô Ð+Ô,ô ×(Ñ(¨¯ © Ó):¸DÓA×HÑHÔJØyyÐøô# ò ä×)Ñ)Ó+DÜ ×%Ñ%Ü2¸$¸ÈôFð LLNð ús B' Â'A
|
C4Ã3C4Úblock_for_initialÚinitial_delay_in_msc óF K || _ t j « }t j « }t || j
|
||« }|j |dz |« | _ t j d« |r|j « d { | j S 7 w)Néè r` ) rR ra rb ri Ú_async_to_sync_wrapperÚ_renew_token_asyncrj rS rV rW rm rX )r rZ rr rs r[ ro rq Úwrappeds r Ú start_asynczTokenManager.start_async¤ s è ø ð "ä×'Ñ'Ó)Ü ]]_
|
ô )Ø $×)Ñ)¨<¸ó
|
ð ??Ð+>ÀÑ+EÀwÓOÔÜ Ð+Ô,á Ø //Ó#× #Ð #àyyÐð $ús B B!ÂB ÂB!c ó | j | j j « | j | j j « y y r )rS ÚcancelrQ r s r rX zTokenManager.stop¼ sC Ø × Ñ Ð 'Ø × Ñ × #Ñ #Ô %Ø × Ñ Ð 'Ø × Ñ × #Ñ #Õ %ð (r c ó¬ | j j |« }d| _ t |« S # t $ r}| j | j j « j « k r_| xj dz c_ t | j j « j « dz « | j |« cY d }~S |d }~ww xY w©Né ru r ) rO Ú request_tokenr
|
rT rP rI r2 r r4 Ú acquire_tokenr ©r Ú force_refreshÚtokenÚes r r zTokenManager.acquire_token sª ð ØII×+Ñ+¨MÓ:Eð Ü UÓ#Ð#øô ò Ø}}t||× <Ñ <Ó >× OÑ OÓ QÒQØ Ñ" Üdll×3Ñ3Ó5×EÑEÓGÈ$ÑNÔOØ×)Ñ)¨-Ó8Õ8àûð ús! / ¯ C¸BCÃCà CÃCc óì K | j j |« }d| _ t |« S # t $ r·}| j | j j « j « k r{| xj dz c_ t j | j j « j « dz « d { 7 | j |« d { 7 cY d }~S |d }~ww xY wwr} ) rO r r
|
rT rP rI r2 ra r r4 Úacquire_token_asyncr r s r r z TokenManager.acquire_token_asyncÐ sÆ è ø ð
|
ØII×+Ñ+¨MÓ:Eð Ü UÓ#Ð#øô ò Ø}}t||× <Ñ <Ó >× OÑ OÓ QÒQØ Ñ" Ü mmØLL×1Ñ1Ó3×CÑCÓEÈÑLó÷ ñ ð "× 5Ñ 5°mÓ D×DÐDÕDàûð üsO C41 C4± C1ºB C,ÃCÃC,Ã C"Ã C,Ã$C1Ã%C4Ã*C,Ã,C1Ã1C4Ú expire_dateÚ
|
issue_datec óx | j |« }| j ||« }t ||« }|dk rdS |dz S )Nr ru )Ú_delay_for_lower_refreshÚ_delay_for_ratio_refreshÚmin)r r r Údelay_for_lower_refreshÚdelay_for_ratio_refreshÚdelays r Ú_calculate_renewal_delayz%TokenManager._calculate_renewal_delayà sI Ø"&×"?Ñ"?À Ó"LÐ Ø"&×"?Ñ"?À ÈZÓ"XÐ ÜÐ+Ð-DÓEàAIqÐ/ 5¨4¡<Ð/r c ó¦ || j j « z
|
t j t j
|
« j « dz z
|
S ©Nru )rP rE r Únowr ÚutcÚ timestamp)r r s r r z%TokenManager._delay_for_lower_refreshç sB à Øll×9Ñ9Ó;ñ <ä||HLLÓ)×3Ñ3Ó5¸Ñ<ñ >ð
|
r c óÀ ||z
|
}||| j j « z z
|
}||z
|
t j t j
|
« j « dz z
|
S r )rP rC r r r r r )r r r Ú token_ttlÚrefresh_befores r r z%TokenManager._delay_for_ratio_refreshî s` Ø *Ñ, Ø"Ø ×AÑAÓCÑ Cñ
|
ð
|
Ø ñ ä||HLLÓ)×3Ñ3Ó5¸Ñ<ñ >ð
|
r rq c ó | j d¬« }| j |j « j « |j « j « « }|j « j « r t d« | j j *t j d« |r|j « yy|s* | j j |j « « |dk r |r|j « yyt j « }|j || j « | _ t j% d| d« ||r|j « S S # t $ r}t |« d}~ww xY w# t $ r=}| j j& || j j' |« Y d}~nd}~ww xY w |r|j « yy# |r|j « w w xY w) zq
|
Task to renew token from identity provider.
|
Schedules renewal tasks based on token TTL.
|
T©r úRequested token is expiredNú@No registered callback for token renewal task. Renewal cancelledr ú Next token renewal scheduled in ú seconds)r r Ú get_tokenÚget_expires_at_msÚget_received_at_msÚ
|
is_expiredr rR r rV ÚwarningÚsetr* ra rb rj rk rQ rW r" )r r[ rq Ú token_resr r ro s r rk zTokenManager._renew_tokenú sÌ ð$ !Ø ×*Ñ*¸Ð*Ó>IØ×1Ñ1Ø×#Ñ#Ó%×7Ñ7Ó9Ø×#Ñ#Ó%×8Ñ8Ó:óEð
|
×"Ñ"Ó$×/Ñ/Ô1Ü%Ð&BÓCÐCà~~×%Ñ%Ð-ÜØVôð ñ* ØÕ ð ñ' ð-ØNN×*Ñ*¨9×+>Ñ+>Ó+@ÔAð zØñ ØÕ ð ô ×+Ñ+Ó-DØ #¨u°d×6GÑ6GÓ HDÔ Ü KKÐ:¸5¸'ÀÐJÔ KØ ñ ØÕ ð øô! !ò -Ü)¨!Ó,Ð,ûð-ûô ò 'Ø~~×&Ñ&Ð.Øà NN× #Ñ # A× &Ñ &ûð 'úð 'áØÕ ð øzØÕ ð ús[ B0F ÃF Ã
|
)E0 Ã3F Ä AF Å0 F Å9 FÆF Æ F Æ GÆ3G ÇG* Ç GÇG* Ç*G?c ó* K | j d¬« d{ }| j |j « j « |j « j « « }|j « j « r t d« | j j *t j d« |r|j « yy|s2 | j j |j « « d{ |dk r |r|j « yyt j « }t || j « }t j# d| d« |j% ||« |r|j « yy7 o7 # t $ r}t |« d}~ww xY w# t $ rF}| j j& || j j' |« d{ 7 Y d}~d}~ww xY w# |r|j « w w xY ww) zx
|
Async task to renew tokens from identity provider.
|
Schedules renewal tasks based on token TTL.
|
Tr Nr r r r r )r r r r r¡ r¢ r rR r rV r£ r¤ r* ra rb rv rw rW rj r" )r r[ rq r¥ r r ro rx s r rw z TokenManager._renew_token_async( sÖ è ø ð$ !Ø "× 6Ñ 6ÀTÐ 6Ó J×JIØ×1Ñ1Ø×#Ñ#Ó%×7Ñ7Ó9Ø×#Ñ#Ó%×8Ñ8Ó:óEð
|
×"Ñ"Ó$×/Ñ/Ô1Ü%Ð&BÓCÐCà~~×%Ñ%Ð-ÜØVôð ñ* ØÕ ð ñ' ð-Ø ..×0Ñ0°×1DÑ1DÓ1FÓG×GÐGð zØñ ØÕ ð ô ×+Ñ+Ó-DÜ,¨T°4×3JÑ3JÓKGÜ KKÐ:¸5¸'ÀÐJÔ KØ OOE 7Ô +ñ ØÕ ð ðE Kùð" HùÜ ò -Ü)¨!Ó,Ð,ûð-ûô ò -Ø~~×&Ñ&Ð.Øà..×)Ñ)¨!Ó,× ,Ö ,ûð -ûñ ØÕ ð üs¦ HF) FB"F) Â=HÃF) Ã,F Ä F ÄF ÄF) Ä HÄ AF) Å4HÆF) Æ F Æ F&Æ F!Æ!F&Æ&F) Æ) G8Æ26G3Ç(G+Ç)G3Ç.G; Ç3G8Ç8G; Ç;HÈH)F)Fr F)FN)r$ r% r& r r8 r rY r Úboolr rh r6 ry rX r r r r r r ra ri rk rw r+ r r rK rK y s, ðØ!:ðØDVóòð #ñà%ðð ðð
|
"d(Ñ ó ð> #(Ø%&Ø "ñ à%ðð ðð #ð ð
|
ð ð
|
"d(Ñ ó ò0&ñ $°Mó $ñ $À ó $ð 0°Eð 0Àuð 0ÐQVó 0ð
|
°Eó
|
ð
|
|
°Eð
|
|
Àuó
|
|
ð GKñ,!Ø ð,!Ø6=·m±mó,!ð^ GKñ,!Ø ð,!Ø6=·m±mô,!r rK c ó fd}|S )a
|
Wraps an asynchronous function so it can be used with loop.call_later.
|
|
:param loop: The event loop in which the coroutine will be executed.
|
:param coro_func: The coroutine function to wrap.
|
:param args: Positional arguments to pass to the coroutine function.
|
:param kwargs: Keyword arguments to pass to the coroutine function.
|
:return: A regular function suitable for loop.call_later.
|
c ó@ t j i ¤¬« y )N)ro )ra Ú ensure_future)r^ Ú coro_funcÚkwargsro s r rx z'_async_to_sync_wrapper.<locals>.wrappedb s ø ä× Ñ i¨Ð 8°Ñ 8¸tÖDr r+ )ro r« r^ r¬ rx s ```` r rv rv W s û ÷Eð Nr Ú
|
event_loopc óN t j | « | j « y)z
|
Starts event loop in a thread.
|
Used to be able to schedule tasks using loop.call_later.
|
|
:param event_loop:
|
:return:
|
N)ra Úset_event_loopÚ run_forever)r s r rg rg i s ô ×Ñ:Ô&Ø×ÑÕ r ) ra Úloggingre r r Útimer Útypingr r r r Úredis.auth.errr
|
r Úredis.auth.idpr Úredis.auth.tokenr Ú getLoggerr$ rV r r- r8 rK rv ÚAbstractEventLooprg r+ r r ú<module>r¹ sx ðÛ Û Û ß 'Ý ß 2Ó 2ç ;Ý 4Ý *à × Ñ 8Ó $÷"ñ "÷6 ñ ÷,6"ñ 6"÷r[!ñ [!ò|ð$ ¨G×,EÑ,Eô r
|
