gddlmZddlmZddlmZddlmZddlmZddl m Z m Z m Z m Z mZddlmZmZmZddlmZd d lmZmZmZmZmZmZd d lmZmZmZm Z m!Z!d d l"m#Z#m$Z$m%Z%m&Z&m'Z'm(Z(m)Z)m*Z*m+Z+m,Z,m-Z-d d l.m/Z/d dl0m1Z1d dl2m3Z3m4Z4m5Z5m6Z6m7Z7m8Z8m9Z9m:Z:m;Z;mZ>m?Z?m@Z@mAZAmBZBmCZCmDZDmEZEmFZFmGZGmHZHmIZImJZJmKZKmLZLmMZMmNZNmOZOmPZPmQZQmRZRmSZSmTZTmUZUmVZVmWZWddlXmYZYddlZm[Z[ddl\m]Z]ddl^m_Z_m`Z`Gdde[Zay)) annotations)suppress)partial)loads)time)CallableDictListOptionalTuple)parse_qs urlencodeurlparse)uuid4)DEFAULT_HEADERS EXPIRY_MARGIN GOTRUE_URL MAX_RETRIESRETRY_INTERVAL STORAGE_KEY) AuthApiErrorAuthImplicitGrantRedirectErrorAuthInvalidCredentialsErrorAuthRetryableErrorAuthSessionMissingError) decode_jwt_payloadgenerate_pkce_challengegenerate_pkce_verifier model_dumpmodel_dump_jsonmodel_validateparse_auth_otp_responseparse_auth_responseparse_link_identity_responseparse_sso_responseparse_user_response) AsyncClient)Timer)%AuthChangeEventAuthenticatorAssuranceLevels AuthFlowTypeAuthMFAChallengeResponseAuthMFAEnrollResponse-AuthMFAGetAuthenticatorAssuranceLevelResponseAuthMFAListFactorsResponseAuthMFAUnenrollResponseAuthMFAVerifyResponseAuthOtpResponse AuthResponseCodeExchangeParamsDecodedJWTDictIdentitiesResponseMFAChallengeAndVerifyParamsMFAChallengeParamsMFAEnrollParamsMFAUnenrollParamsMFAVerifyParams OAuthResponseOptionsProviderResendCredentialsSessionSignInAnonymouslyCredentialsSignInWithIdTokenCredentialsSignInWithOAuthCredentialsSignInWithPasswordCredentials!SignInWithPasswordlessCredentialsSignInWithSSOCredentialsSignOutOptionsSignUpWithPasswordCredentials SubscriptionUserAttributes UserIdentity UserResponseVerifyOtpParams)AsyncGoTrueAdminAPI)AsyncGoTrueBaseAPI)AsyncGoTrueMFAAPI)AsyncMemoryStorageAsyncSupportedStoragec ~eZdZddddddddddd d7dZddd8dZd9dZd:d Z d; dd Z d?d Z d@dZ dAdZ dAdZ dZdBdZ dCdZ dDdZdEdZdFdZdGdZd;dHdZdIdZdJdZ d; dKdZddifdLdZ dMdZifdNd Zif dNd!ZdOd"ZdPd#Z dQd$ZdRd%Z dSd&Z!dTd'Z" dUd(Z#d9d)Z$ dVd*Z%d9d+Z&dWd,Z'dXd-Z(dYd.Z)dZd/Z* d[d0Z+ d\d1Z, d]d2Z-d^d3Z. d_d4Z/d`d5Z0dad6Z1y)bAsyncGoTrueClientNTimplicit) urlheaders storage_keyauto_refresh_tokenpersist_sessionstorage http_client flow_typeverifyproxyc tj||xst|xst|| | |xst|_||_||_|xs t|_ d|_ d|_ d|_ i|_ ||_t|j |j"|j$|_t)|_|j,|j*_|j0|j*_|j4|j*_|j8|j*_|j<|j*_|j@|j*_!|jD|j*_#y)N)rXrYr^r`rar)rXrYr^)$rQ__init__rrr _storage_key_auto_refresh_token_persist_sessionrS_storage_in_memory_session_refresh_token_timer_network_retries_state_change_emitters _flow_typerP_url_headers _http_clientadminrRmfa _challenge challenge_challenge_and_verifychallenge_and_verify_enrollenroll"_get_authenticator_assurance_level!get_authenticator_assurance_level _list_factors list_factors _unenrollunenroll_verifyr`) selfrXrYrZr[r\r]r^r_r`ras P/var/www/openai/venv/lib/python3.12/site-packages/gotrue/_async/gotrue_client.pyrczAsyncGoTrueClient.__init__Ws, ## !z.#  (6;#5 /7#5#7 5959! !?A##( MM))  %&!__(,(B(B%,,  3 3 2!% 2 2 NN,,)rXcK|r+|j|r|j|d{y|jd{y77wN)_is_implicit_grant_flowinitialize_from_urlinitialize_from_storage)rrXs r initializezAsyncGoTrueClient.initializesE 4//4**3/ / /..0 0 0 0 0s!(A A A A A  A c>K|jd{S7wr)_recover_and_refreshrs rrz)AsyncGoTrueClient.initialize_from_storages..0000s cPK |j|r`|j|d{\}}|j|d{|jd||dk(r|jd|yyy7L72#t$r }|j d{7|d}~wwxYww)N SIGNED_INrecoveryPASSWORD_RECOVERY)r_get_session_from_url _save_session_notify_all_subscribers Exception_remove_session)rrXsession redirect_typees rrz%AsyncGoTrueClient.initialize_from_urls ++C0/3/I/I#/N)N&((111,,['B J.001DgN/ 1)N1 &&( ( (G sVB&%A:A6A:A8-A:3B&6A:8A:: B#BBBB##B&cK|jd{|dii}|jdi}|jdxsi}|jd}|jdd|d|idtd{}|jr?|j |jd{|j d |j|S77S7&w) z/ Creates a new anonymous user. Noptionsdata captcha_tokenPOSTsignup)rgotrue_meta_securitybodyxformrrget_requestr$rrr)r credentialsrrrresponses rsign_in_anonymouslyz%AsyncGoTrueClient.sign_in_anonymouslys ""$$$  $b/K//)R0{{6"(b O4   #]) &'      $$X%5%56 6 6  ( (h6F6F G) %   7s4CC A#C:C;.C)C*#CCCc K|jd{|jd}|jd}|jd}|jdi}|jdxs|jd}|jdxsi}|jd d }|jd } |r*|jd d |||d | id|td{} n7|r*|jd d ||||d | idtd{} n t d| j r?|j | j d{|jd| j | S7V77b7)w)z% Creates a new user. Nemailphonepasswordr redirect_toemail_redirect_torchannelsmsrrrrrrrrrr)rrrrrr?You must provide either an email or phone number and a passwordrrrrr$rrrr) rrrrrrrrrrrs rsign_upzAsyncGoTrueClient.sign_ups""$$$((??:.//)R0kk-0TGKK@S4T {{6"(b++i/ O4 !]]" ( '- ()+  H!]]" ( &'- *+  H.Q    $$X%5%56 6 6  ( (h6F6F G] %  & 7sFE5E,C E5"E/#+E5E1:E5 E3 #E5/E51E53E5c K|jd{|jd}|jd}|jd}|jdi}|jdxsi}|jd}|r,|jdd |||d|id d dit d{}n9|r,|jdd |||d|id d dit d{}n t d|j r?|j |j d{|jd|j |S7$77b7)w)zN Log in an existing user with an email or phone and password. Nrrrrrrrtokenr grant_typerqueryr)rrrrrrr) rrrrrrrrrs rsign_in_with_passwordz'AsyncGoTrueClient.sign_in_with_passwordsu""$$$((??:.//)R0{{6"(b O4 !]]" ( '- !**+H !]]" ( '- !**+H".Q    $$X%5%56 6 6  ( (h6F6F Ga %"* 7sFED:BE.D=/-ED?:EE#E=E?EEc K|jd{|jd}|jd}|jd}|jd}|jdi}|jd}|jdd||||d|id d d it d{}|jr?|j |jd{|j d |j|S77S7&w)z} Allows signing in with an OIDC ID token. The authentication provider used should be enabled and configured. Nproviderr access_tokennoncerrr)rid_tokenrrrrrrrr) rrrrrrrrrs rsign_in_with_id_tokenz'AsyncGoTrueClient.sign_in_with_id_token,s ""$$$??:.("~6 (//)R0 O4   $! ,#]) j&'  $   $$X%5%56 6 6  ( (h6F6F G; % & 7s4DC;BD)C=*.DC?#D=D?DcK|j|jd}|jd}|jdi}|jd}|jd}|jdd}|r |jdd ||d|id |t S|r |jdd ||d|id |t St d w)a Attempts a single-sign on using an enterprise Identity Provider. A successful SSO attempt will redirect the current page to the identity provider authorization page. The redirect URL is implementation and SSO protocol specific. You can use it by providing a SSO domain. Typically you can extract this domain by asking users for their email address. If this domain is registered on the Auth instance the redirect will use that organization's currently active SSO Identity Provider for the login. If you have built an organization-specific login page, you can use the organization's SSO Identity Provider UUID directly instead. provider_iddomainrrrskip_http_redirectTrsso)rrrr)rrrz/You must provide either a domain or provider_id)rrrr&r)rrrrrrrrs rsign_in_with_ssoz"AsyncGoTrueClient.sign_in_with_ssoRs !oom4 *//)R0kk-0  O4 %[[)=tD ==$*<'-((!   ==#.*<'-((!  * =  sCC cvK|jd{|jd}|jdi}|jd}|jd}|jdi}|r||d<|r||d<|j|jd||d{}t ||S77w) zE Log in an existing user via a third-party provider. Nrrrscopes query_paramsz /authorizerrX)rr_get_url_for_providerrmr=)rrrrrrparamsrXs rsign_in_with_oauthz$AsyncGoTrueClient.sign_in_with_oauths""$$$??:.//)R0kk-0 X&^R0 $/F= ! %F8 ..yyk $h  hC88 % s"B9B5B B9#B7$B97B9cK|jd}|jdi}|jd}|jd}|jdi}|r||d<|r||d<d|d<|jd||d{}|jd{}|s t|j d ||j t d{} t|| j S7j7T7w) Nrrrrrtruerzuser/identities/authorizeGET)methodpathjwtrr) rr get_sessionrrrr%r=rX) rrrrrrrrXrrs r link_identityzAsyncGoTrueClient.link_identitys??:.//)R0kk-0 X&^R0 $/F= ! %F8 '-#$.. '6  ((**)+ +$$. '   hHLLAA + s6BC4C.C4C06C4C2C40C42C4cK|jd{}|jr t|jjSt S7:w)N) identities)get_useruserr7rr)rrs rget_user_identitiesz%AsyncGoTrueClient.get_user_identitiessH(}} (--*B*B C )* )sAA;AcK|jd{}|s t|jdd|j|jd{S7C7w)NDELETEzuser/identities/)r)rrr identity_idr)ridentityrs runlink_identityz!AsyncGoTrueClient.unlink_identitysf((**)+ +]] x334 5$$#   + s!AA>AAAAc K|jd{|jd}|jd}|jdi}|jd}|jdd}|jd}|jd d }|jd } |r)|jd d |||d | id|td{S|r)|jd d ||||d | idtd{St d77<7w)a Log in a user using magiclink or a one-time password (OTP). If the `{{ .ConfirmationURL }}` variable is specified in the email template, a magiclink will be sent. If the `{{ .Token }}` variable is specified in the email template, an OTP will be sent. If you're using phone sign-ins, only an OTP will be sent. You won't be able to send a magiclink for phone sign-ins. Nrrrrshould_create_userTrrrrrotp)rr create_userrr)rrrrrr0You must provide either an email or phone number)rrrr#r) rrrrrrrrrrs rsign_in_with_otpz"AsyncGoTrueClient.sign_in_with_otpsB ""$$$((//)R0#KK(;<$[[)=tD{{6"++i/ O4 " #5'- .-'    " #5&'- .'   * >  O %  s4D DB5D  D  *D 7D 8D  D  D cK|jd}|jd}|jd}|jdi}|jd}|jd}|d|id}| | td |j|rd|ind|i|jd d ||r|ndt d{S7w) zq Resends an existing signup confirmation email, email change email, SMS OTP or phone change OTP. rrtyperrr)rrNrrresendr)rrupdaterr#) rrrrrrrrrs rrzAsyncGoTrueClient.resend s((v&//)R0#KK(;< O4 %  =U]-B  We$GU3CD]]  -2)) #    sB8C:B?;Cc K|jd{|jdddd|jdijdii||jdijdtd{}|jr?|j |jd{|j d |j|S77S7&w) zN Log in a user given a User supplied OTP received via mobile. Nrr`rrrrrr)rrrr$rrrrrrs r verify_otpzAsyncGoTrueClient.verify_otp0s""$$$  &#VZZ 2%>%B%B?%S)   9b155mD%'      $$X%5%56 6 6  ( (h6F6F G! %   7s4CCA%C<C=.C+C,#CCCcK|jd{}|s t|jdd|jtd{S7;7w)Nrreauthenticaterr)rrrrr$)rrs rrz AsyncGoTrueClient.reauthenticateFs[((**)+ +]]  $$% #   + s!AA6A AAAcKd}|jrY|jj|jd{}|j |}|s%|j d{n |j }|sytt}|jr|j|tzknd}|r#|j|jd{S|S77t7 w)z Returns the session, refreshing it if necessary. The session returned can be null if the session is not detected which can happen in the event a user is not signed-in or has logged out. NF) rfrgget_itemrd_get_valid_sessionrrhroundr expires_atr_call_refresh_token refresh_token)rcurrent_session maybe_sessiontime_now has_expireds rrzAsyncGoTrueClient.get_sessionRs.2  "&--"8"89J9J"KKM"55mDO"**,,,"55O=))  & &(]*B B **?+H+HI I ! L- Js47CC*C$C%A+CCCCCcK|s(|jd{}|r |j}ny|jdd|td{S757w)z Gets the current user details if there is an existing session. Takes in an optional access token `jwt`. If no `jwt` is provided, `get_user()` will attempt to get the `jwt` from the current session. Nrrr)rrrr')rrrs rrzAsyncGoTrueClient.get_userosT ,,..G**]]5&cAT]UUU / Vs!AA0A A AAc2K|jd{}|s t|jdd||jtd{}|j |_|j |d{|jd||S7z7D7w)zB Updates user data, if there is a logged in user. NPUTrrrr USER_UPDATED)rrrrr'rrr)r attributesrrs r update_userzAsyncGoTrueClient.update_user~s((**)+ +  $$% '   }}   ))) $$^W=+  *s3BB7BB)B8B9BBBcbKtt}|}d}d}|rH|jddr4|j|}|j d}|rt |}||k}|rH|s t |j|d{} | js tS| j}n7|j|d{} t||| jd||z |}|j|d{|jd|t|| j S77f71w) a; Sets the session data from the current session. If the current session is expired, `set_session` will take care of refreshing it to obtain a new session. If the refresh token in the current session is invalid and the current session has expired, an error will be thrown. If the current session does not contain at `expires_at` field, `set_session` will use the exp claim defined in the access token. The current session that minimally contains an access token, refresh token and a user. TN.rOexpbearer)rrr token_type expires_inrTOKEN_REFRESHEDrr)rrsplit _decode_jwtrintr_refresh_access_tokenrr4rrArrr) rrrrrrrpayloadrrs r set_sessionzAsyncGoTrueClient.set_sessions)=  %) L..s3A6&&|4G++e$C X (H4  -//!77 FFH###~%&&G!]]<88H)+]]#%0% G  ))) $$%6@G(--@@!G 9 *s6BD/D) ;D/D+6D/;D-<.D/+D/-D/cK|s&|jd{}|r |j}|s t|j|d{}t ||j S7N7w)a' Returns a new session, regardless of expiry status. Takes in an optional current session. If not passed in, then refreshSession() will attempt to retrieve it from getSession(). If the current session's refresh token is invalid, an error will be thrown. Nr)rrrrr4r)rrrs rrefresh_sessionz!AsyncGoTrueClient.refresh_sessionsf ,,..G ' 5 5 )+ +00??G',,?? / @s!A+A'2A+ A) A+)A+scopeglobalcfKtt5|jd{}|r |jnd}|r'|jj ||dd{|ddk7r*|j d{|jdddddy7x7A7##1swYyxYww)a  Inside a browser context, `sign_out` will remove the logged in user from the browser session and log them out - removing all items from localstorage and then trigger a `"SIGNED_OUT"` event. For server-side management, you can revoke all refresh tokens for a user by passing a user's JWT through to `api.sign_out`. There is no way to revoke a user's access token jwt until it expires. It is recommended to set a shorter expiry on the jwt for this reason. Nrothers SIGNED_OUT)rrrrrpsign_outrr)rrrrs rrzAsyncGoTrueClient.sign_outsl # ,,..G3:7//Ljj)),8HIIIw8+**,,,,,\4@$ #.J-$ #sPB1B%B8B%B! B%?B#B% B1B%!B%#B%%B.*B1cxttdfd }t||}|j<|S)zJ Receive a notification every time an auth event happens. c<jjyr)rkpop)r unique_idsr _unsubscribez._unsubscribes  ' ' + +I 6r)idcallback unsubscribereturnNone)strrrJrk)rrr subscriptionrs` @ron_auth_state_changez&AsyncGoTrueClient.on_auth_state_changesBL  7$$ 2>##I.rc K|jdd|d|jdid|jdd{y7w)E Sends a password reset request to an email address. rrecoverr)rrr)rrN)rrrrrs rreset_password_for_emailz*AsyncGoTrueClient.reset_password_for_emailsRmm  #W[[%A)  M2  s|jjr(d |jj|j_|S77Nw) N friendly_name factor_type)r-r.rissuerrfactorsrtotpzdata:image/svg+xml;utf-8,) rrrrrr"r.r1qr_code)rrrrrs rrvzAsyncGoTrueClient._enrolls((**)+ +$O4!-0  - G +"7ODM#H-DN  $$.*?@ '   - F *x}}/D/D&? @U@U?V$WHMM !/+ s#CC A)CCA CCc K|jd{}|s t|jdd|jddd|jdi|jt t td{S7n7w)Nrfactors/ factor_idz /challengerr)rrrrrrr"r-rrrs rrrzAsyncGoTrueClient._challenge2s((**)+ +]] vzz+./z :VZZ 23$$.*BC #   + s"B BA)B BB B cK|jd|jdid{}|j|jd|j|jddd{S7I7w)Nr5code)r5 challenge_idr8)rrrr~rrs rrtz'AsyncGoTrueClient._challenge_and_verify>suVZZ 4    \\#ZZ 4 (  6*      s"&A6A2AA6-A4.A64A6c K|jd{}|s t|jdd|jdd||jt t td{}t tt|}|j|d{|jd||S77L7w)Nrr4r5z/verifyrMFA_CHALLENGE_VERIFIED) rrrrrrr"r2rAr rr)rrrrs rr~zAsyncGoTrueClient._verifyOs((**)+ + vzz+./w 7$$.*?@ '  !*X*>?  ))) $$%=wG+  *s4CB:AC/B<01C!B>"C<C>Cc K|jd{}|s t|jdd|jd|jt t td{S7[7w)Nrr4r5r)rrrrrrr1r"r6s rr|zAsyncGoTrueClient._unenroll_st((**)+ +]] vzz+./ 0$$1>B #   + s"A6A2AA6-A4.A64A6c^K|jd{}|jjxsg}|Dcgc]$}|jdk(s|jdk(s#|&}}|Dcgc]$}|jdk(s|jdk(s#|&}}t |||S7cc}wcc}ww)Nr1verifiedr)allr1r)rrr0r.statusr0)rrr?fr1rs rrzzAsyncGoTrueClient._list_factorsjs(mm##)rU3a!--6"9ahh*>T3UWCq1==G#;J@VCW)cEJJ )UWsDB-B!"B-B#B#B#"B-(B(=B( B(B-# B-cK|jd{}|stddgS|j|j}d}|j dr|j d}|j j xsgDcgc]}|jdk(s|}}|rdn|}|j dxsg}t|||S7cc}ww)N) current_level next_levelcurrent_authentication_methodsaalr>aal2amr)rr/r rrrr0r@)rrr rCrAverified_factorsrDrEs rrxz4AsyncGoTrueClient._get_authenticator_assurance_levelqs((**@"/1  ""7#7#78@D ;;u #KK.M||++1r1 1!QXX5KA1   0V] )0U);)Ar&<'!+I  !+ s(CC A/CC C ,C CcK|jr.|jj|jd{nd|_|j r"|j j d|_yy7;wr)rfrg remove_itemrdrhricancelrs rrz!AsyncGoTrueClient._remove_sessionsb  --++D,=,=> > >&*D #  $ $  % % , , .(,D % % ?s5A5A3JOOFG4E45NOO45IJJ0!#e4 1AB!%9Q!Rv~> 01LM M__V\: 01JK K@ 01MN N__V\: 01JK K=J/ ]]<00)#9%:!'!  7  %%1sE3F85F66AF8cK|jj|jd{}|j|}|s|r|j d{yt t }|j}|ru||tzkri|j}|jr8|r6|xjdz c_ |j|d{d|_ |j d{y|j.r|j1|d{|j3d|y777a#t$r}t|tr|jt krt|j"r|j"j%t't(|jdzz|j*|_|j"j-Yd}~yYd}~d}~wwxYw77ͭw)NrOrdr)rgrrdrrrrrrrrerjrr isinstancerrrirLr)rrstartrfrr)r raw_sessionrrrrrs rrz&AsyncGoTrueClient._recover_and_refreshs MM2243D3DEE 11+>**,,, =$// *x-'??+99M''M%%*%22=AAA,-D)&&( ( (   $$_5 5 5 $$[/BAF-B "1&89 11K?44 55<<>49+0E0E0KL 555111779  ) 6s})G$D,,G$D/A!G$;D3D1 D3G$.G /%G$G"G$/G$1D33 G.refresh_token_functions  ! !Q & !  $ 0 0 222273H3HIII,-D)3I q"45-- ;88&4+@+@3+FG<6 s]CA$A $A$A" A$C A$"A$$ C-A C 8B;9C >C CC)rirLrer)rX)rrbres` rr]z+AsyncGoTrueClient._start_auto_refresh_token se  $ $  % % , , .(,D % A:T55   %*%1G$H! !!'')sA1A4cf|jjD]}|j||yr)rkvaluesr)reventrr#s rrz)AsyncGoTrueClient._notify_all_subscribers&s. !77>>@L  ! !% 1Arc|syt|}|sy|jdsy|jdsy|jdsy t|d}||d< t t |S#t$rYywxYw#t $rYywxYw)Nrrr)rrr  ValueErrorr"rAr)rrYrrs rrz$AsyncGoTrueClient._get_valid_session.s[!xx'xx(xx % T,/0J!+D  !'40 0    s$ A-A<- A98A9< BBc||vr||dSdS)Nr)rrnames rrSzAsyncGoTrueClient._get_paramGs )- (<|D!!$F$FrcVt|}t|j}d|vxsd|vS)NrrN)rr r)rrXrTrs rrz)AsyncGoTrueClient._is_implicit_grant_flowNs/#&,,''H+>&+HHrc K|jdk(rYt}t|}|jj |j d|d{||k(rdnd}||d<||d<||d<t |}|d|S7.w) Npkce-code-verifierplains256code_challengecode_challenge_methodr?)rlrrrgr^rdr)rrXrr code_verifierrtrurs rrz'AsyncGoTrueClient._get_url_for_providerSs ??f $24M4]CN--(($$%^4m  )N: "(6F# $.CF* +%z&!aw sABB/Bct|S)zD Decodes a JWT (without performing any validation). )r)rrs rr zAsyncGoTrueClient._decode_jwtis"#&&rc K|jdxs0|jj|jdd{}|j dd|jd|d|jdt d{}|jj |jdd{|jr?|j|jd{|jd |j|S777U7(w) Nrwrqrztoken?grant_type=pkce auth_code)rzrwrrr) rrgrrdrr$rKrrr)rrrwrs rexchange_code_for_sessionz+AsyncGoTrueClient.exchange_code_for_sessionos ?3 T]]=S=S  ! 0> 8   ##ZZ 4!. =1%'   mm''4+<+<*=^(LMMM   $$X%5%56 6 6  ( (h6F6F G#8    N 6sH?DDADD/D4D 5.D#D $#DD D D)rX Optional[str]rYzOptional[Dict[str, str]]rZr|r[boolr\r}r]zOptional[AsyncSupportedStorage]r^zOptional[AsyncClient]r_r,r`r}rar|r r!)rXr|r r!r)rXr"r r!r)rz&Optional[SignInAnonymouslyCredentials]r r4)rrIr r4)rrEr r4)rrCr r4)rrG)rrDr r=)rrL)rrFr r3)rr@r r3)rrNr r4)r r4)r Optional[Session])rr|r zOptional[UserResponse])rrKr rM)rr"rr"r r4)rr|r r4)rrHr r!)rz4Callable[[AuthChangeEvent, Optional[Session]], None]r rJ)rr"rr>r r!)rr:r r.)rr9r r-)rr8r r2)rr<r r2)rr;r r1)r r0)r r/)rXr"r zTuple[Session, Optional[str]])rr"r rA)rr"r r4)rrAr r!)rbfloatr r!)rhr*rr~r r!)rYr|r r~)rzDict[str, List[str]]rmr"r r|)rXr"r r})rXr"rr?rzDict[str, str]r r")rr"r r6)rr5)2__name__ __module__ __qualname__rcrrrrrrrrrrrrrrrrrrrrrrr$r)r+rvrrrtr~r|rzrxrrrrr rr]rrrSrrr r{rlrrrVrVVs$",0%)#' $37-1",#.'.'* .' # .' ! .'.'1.'+.' .'.'.' .'d8<1 1 EIA 8525 5n727 7r$1$ $L7 r9/9 9.B5B B:   9 69  9 v! &!  ! F,   : V&,A^.2@*@ @&9@7JA,F (MO &<<<  <4   +   "  K 6 6-0& 0& '0&d!CF   V*422#2  2" 2G*GG  GI       ,' rrVN)b __future__r contextlibr functoolsrjsonrrtypingrr r r r urllib.parser rruuidr constantsrrrrrrerrorsrrrrrhelpersrrrr r!r"r#r$r%r&r' http_clientsr(timerr)typesr*r+r,r-r.r/r0r1r2r3r4r5r6r7r8r9r:r;r<r=r>r?r@rArBrCrDrErFrGrHrIrJrKrLrMrNgotrue_admin_apirPgotrue_base_apirQgotrue_mfa_apirRr]rSrTrVrlrrrs"8866    '&&&&&&&&&&N2/->k*kr