gYddlmZddlmZddlmZmZddlmZddl m Z ddl m Z m Z m Z mZmZmZmZddlmZmZddlmZd d lmZmZmZmZd d lmZd d lmZm Z m!Z!m"Z"d d l#m$Z$m%Z%m&Z&m'Z'm(Z(m)Z)m*Z*m+Z+ddl,m-Z-ddl.m/Z/m0Z0GddZ1y)) annotations)partial)dumpsloads)Timer)time)AnyCallableDictOptionalTupleUnioncast)parse_qsurlparse)uuid4)COOKIE_OPTIONSDEFAULT_HEADERS GOTRUE_URL STORAGE_KEY)APIError) is_http_url is_valid_jwt model_dumpmodel_validate)AuthChangeEvent CookieOptionsProviderSession SubscriptionUserUserAttributesUserAttributesDict) SyncGoTrueAPI)SyncMemoryStorageSyncSupportedStoragec eZdZeiddeej eddddd d(dZd)dZ d*dZ d*dZ d*d Z dddddd  d+d Z ddddddddd  d,d Zdd d-dZd.dZd/dZd0dZd1dZd2dZd3dZdd d4dZd*dZd5dZ d6dZ d7dZd8dZ d9dZd:dZd*dZd*d Zdd!d;d"Z dd'Z%y)?SyncGoTrueClientTNF) urlheadersauto_refresh_tokenpersist_session local_storagecookie_optionsapireplace_default_headersverifyproxyc t|s td|jdr tdi|_d|_d|_d|_||_||_ ||_ |rint} |i| ||| | d} |xs tdi| |_ y)aDCreate a new client url : str The URL of the GoTrue server. headers : Dict[str, str] Any additional headers to send to the GoTrue server. auto_refresh_token : bool Set to "true" if you want to automatically refresh the token before expiring. persist_session : bool Set to "true" if you want to automatically save the user session into local storage. local_storage : SupportedStorage The storage engine to use for persisting the session. cookie_options : CookieOptions The options for the cookie. verify: bool Verify SSL, True by default, False disables verification. proxy: str HTTP Proxy string or None, None by default, None disables proxy. #url must be a valid HTTP URL stringzhttp://z`Warning: DO NOT USE HTTP IN PRODUCTION FOR GOTRUE EVER! GoTrue REQUIRES HTTPS to work securely.N)r+r,r0r3r4)r ValueError startswithprintstate_change_emittersrefresh_token_timer current_usercurrent_sessionr-r.r/rr&r1) selfr+r,r-r.r/r0r1r2r3r4empty_or_default_headersargss H/var/www/openai/venv/lib/python3.12/site-packages/gotrue/_sync/client.py__init__zSyncGoTrueClient.__init__sF3 < = >>) $ : ?A"48 ,026"4.*)@2o >2>g>,  /-/$/c|SNr7r?s rB __enter__zSyncGoTrueClient.__enter__Xs rDc$|jyrF)close)r?exc_texc_vexc_tbs rB__exit__zSyncGoTrueClient.__exit__[s  rDc8|jjyrF)r1rJrGs rBrJzSyncGoTrueClient.close^s rDcD|j|jy)z/Recover the current session from local storage.N)_recover_session_recover_and_refreshrGs rB init_recoverzSyncGoTrueClient.init_recoveras  !!#rD)emailphonepassword redirect_todatach|j|r"|r |jj||||}n;|r!|r|jj|||}n|s t dt dt |t r2|j||jtj|S)a7Creates a new user. If email and phone are provided, email will be used and phone will be ignored. Parameters --------- email : Optional[str] The user's email address. phone : Optional[str] The user's phone number. password : Optional[str] The user's password. redirect_to : Optional[str] A URL or mobile address to send the user to after they are confirmed. data : Optional[Dict[str, Any]] Optional user metadata. Returns ------- response : Union[Session, User] A logged-in session if the server has "autoconfirm" ON A user if the server has "autoconfirm" OFF Raises ------ APIError If an error occurs. )rTrVrWrX)rUrVrXz(Password must be defined, can't be None.z3Email or phone must be defined, both can't be None.sessionevent) _remove_sessionr1sign_up_with_emailsign_up_with_phoner8 isinstancer _save_session_notify_all_subscribersr SIGNED_IN)r?rTrUrVrWrXresponses rBsign_upzSyncGoTrueClient.sign_upfsH  Xxx22!' 3H xxx22hT3HGH HRS S h (   x  0  ( (/H/H ( IrD)rTrUrV refresh_tokenproviderrWscopes create_userc|j|r7|r|j|||} | S|jj||} | S|r6|r|j ||} | S|jj ||} | S|r |j ||j} | S|r|j|||} | Std)a.Log in an existing user, or login via a third-party provider. If email and phone are provided, email will be used and phone will be ignored. Parameters --------- email : Optional[str] The user's email address. phone : Optional[str] The user's phone number. password : Optional[str] The user's password. refresh_token : Optional[str] A valid refresh token that was returned on login. provider : Optional[Provider] One of the providers supported by GoTrue. redirect_to : Optional[str] A URL or mobile address to send the user to after they are confirmed. scopes : Optional[str] A space-separated list of scopes granted to the OAuth application. Returns ------- response : Optional[Union[Session, str]] If only email are provided between the email and password, None is returned and send magic link to email If email and password are provided, a logged-in session is returned. If only phone are provided between the phone and password, None is returned and send message to phone If phone and password are provided, a logged-in session is returned. If refresh_token is provided, a logged-in session is returned. If provider is provided, an redirect URL is returned. Otherwise, error is raised. Raises ------ APIError If an error occurs. rTrVrW)rTrjrUrV)rUrjrgrhrWrizLEmail, phone, refresh_token, or provider must be defined, all can't be None.) r^_handle_email_sign_inr1send_magic_link_email_handle_phone_sign_insend_mobile_otp_call_refresh_tokenr>_handle_provider_sign_inr8) r?rTrUrVrgrhrWrirjres rBsign_inzSyncGoTrueClient.sign_insp  55% +6@5 8899[:4/55EH5U*' 8833[4&!  $ $= $ A++H44!'5H % rD)rWc|j|jj|||}t|tr2|j ||j tj|S)a^Log in a user given a User supplied OTP received via mobile. Parameters ---------- phone : str The user's phone number. token : str The user's OTP. redirect_to : Optional[str] A URL or mobile address to send the user to after they are confirmed. Returns ------- response : Union[Session, User] A logged-in session if the server has "autoconfirm" ON A user if the server has "autoconfirm" OFF Raises ------ APIError If an error occurs. )rUtokenrWrZr\) r^r1verify_mobile_otprar rbrcrrd)r?rUrxrWres rB verify_otpzSyncGoTrueClient.verify_otpsk: 88--#.  h (   x  0  ( (/H/H ( IrDc|jS)z4Returns the user data, if there is a logged in user.)r=rGs rBuserzSyncGoTrueClient.user(s   rDc|jS)z8Returns the session data, if there is an active session.)r>rGs rBr[zSyncGoTrueClient.session,s###rDcP|js td|jS)zForce refreshes the session. Force refreshes the session including the user data incase it was updated in a different session. Not logged in.)r>r8rtrGs rBrefresh_sessionz SyncGoTrueClient.refresh_session0s( ##-. .''))rDcl|js tdt|tr t di|}n|}|j j |jj|}||j_|j|j|jtj|S)aUpdates user data, if there is a logged in user. Parameters ---------- attributes : UserAttributesDict | UserAttributes Attributes to update, could be: email, password, email_change_token, data Returns ------- response : User The updated user data. Raises ------ APIError If an error occurs. r)jwt attributesrZr\r7) r>r8radictr#r1 update_user access_tokenr|rbrcr USER_UPDATED)r?rattributes_to_updateres rBupdatezSyncGoTrueClient.update:s$##-. . j$ '#1#?J#? #- 88''$$11+( %-! 4#7#78 $$?+G+G$HrDct|s td|jj|}|j ||j t j|S)aTSets the session data from refresh_token and returns current Session Parameters ---------- refresh_token : str A JWT token Returns ------- response : Session A logged-in session Raises ------ APIError If an error occurs. z5refresh_token must be a valid JWT authorization tokenrnrZr\)rr8r1refresh_access_tokenrbrcrrdr?rgres rB set_sessionzSyncGoTrueClient.set_session]sY&M* N O8800}0M 8, $$?+D+D$ErDc jt|s tdt|dddddd}|jrl|jj|_|jj |_|jj |_|jj|_|j||S)a}Overrides the JWT on the current client. The JWT will then be sent in all subsequent network requests. Parameters ---------- access_token : str A JWT token Returns ------- response : Session A logged-in session Raises ------ APIError If an error occurs. z4access_token must be a valid JWT authorization tokenbearerNr token_typer| expires_in expires_atrgprovider_tokenrZ) rr8r r>rrrgrrb)r?rr[s rBset_authzSyncGoTrueClient.set_authxs(L) M N%    !%!5!5!@!@G !%!5!5!@!@G $($8$8$F$FG !%)%9%9%H%HG " 7+rD) store_sessionc t|s tdt|}t|j}|j d}|j d}|j d}|j d}|j d} |rt |dd|r|ds t d d|r|ds t d d| r| ds t d d|r|ds t d d ttt|dz} |jj|d} |j d} t|d| d| t|d| |d| r| dnd} |rm|j| |j d}|jtj |r(|ddk(r |jtj"| S#t$r t d dwxYw)aGets the session data from a URL string. Parameters ---------- url : str The URL string. store_session : bool Optionally store the session in the browser Returns ------- response : Session A logged-in session Raises ------ APIError If an error occurs. r6error_descriptionrrrgrrizNo access_token detected.zNo refresh_token detected.zNo token_type detected.zNo expires_in detected.zInvalid expires_in.rrNrrZtyper\recovery)rr8rrquerygetrroundrintr1get_userr rbrcrrdPASSWORD_RECOVERY)r?r+rrXrrrrrgrrrerr[ recovery_modes rBget_session_from_urlz%SyncGoTrueClient.get_session_from_urls23 < =}$!II&9:yy0 YY|,  /2 YY|, ,Q/5 5<?6< <M!$47= =A4c: :A4c: : 7tvZ]);;J88$$a$9#34%a!!}:a=)!'*0>>!,D     w  /!IIf-M  ( (/H/H ( Iq!1Z!?,,?3T3T,U' 70#6 6 7s *"GG1cd}|jr|jj}|j|jtj |r|j j|yy)zLog the user out.Nr\r)r>rr^rcr SIGNED_OUTr1sign_out)r?rs rBrzSyncGoTrueClient.sign_outsa&*   //<|jj|||S)zSign in with provider.ro)r1get_url_for_provider)r?rhrWris rBruz)SyncGoTrueClient._handle_provider_sign_in(s)xx,,#-  rDcV|jjt}|syt|}|j d}|j d}|rXt |t rG|rDt |tr3tt|}t |}tt}|||fSyyyy)zRecover common logicNr[r) r/get_itemrrrrarrrr rr)r?jsonrX session_rawexpires_at_rawr[rtime_nows rB_recover_commonz SyncGoTrueClient._recover_common6s!!**;7 T{hhy) ,/ >3/;-$Wk:G^,JTV}HJ0 0 .0 rDc|j}|sy|\}}}||k\r3|j||jtjyy)z-Attempts to get the session from LocalStorageNrZr\)rrbrcrrdr?resultr[rrs rBrQz!SyncGoTrueClient._recover_sessionIsW%%' (.%X  !   w  /  ( (/H/H ( I "rDc|j}|sy|\}}}||kr6|jr*|jr |j|jy||ks|r |j s|j y|j||jtjy#t$r|j YywxYw)z4Recovers the session from LocalStorage and refreshesNrnrZr\) rr-rgrtrr^r|rbrcrrdrs rBrRz%SyncGoTrueClient._recover_and_refreshSs%%' (.%X  T%<%<AVAV '((w7L7L(M( "'  "   w  /  ( (/H/H ( I  '$$& 'sB,,CCrnc^|.|jr|jj}n td|jj t t |}|j||jtj|jtj|S)Nz2No current session and refresh_token not supplied.rnrZr\) r>rgr8r1rrstrrbrcrTOKEN_REFRESHEDrdrs rBrtz$SyncGoTrueClient._call_refresh_tokends  ## $ 4 4 B B  !UVV8800tC?W0X 8, $$?+J+J$K $$?+D+D$ErDcz|jjD]}|j||j y)z0Notify all subscribers that auth event happened.N)r;valuesrr>)r?r]values rBrcz(SyncGoTrueClient._notify_all_subscribersps///668E NN5$"6"6 79rDc$||_|j|_|jr@t t }|j|z }|dkDrdnd}|j ||z |jr |jr|j|yyy)zSave session to client.<g?)rrZN) r>r|r=rrr_start_auto_refresh_tokenr._persist_session)r?r[r expire_inrefresh_duration_before_expiress rBrbzSyncGoTrueClient._save_sessionus&#LL   TV}H**X5I4=Nb +  * * #BB +    G$6$6  ! !' ! 2%7 rDct||jd}|jjtt |t y)N)r[r)default)rrr/set_itemrrr)r?r[rXs rBrz!SyncGoTrueClient._persist_sessions4%g.g>P>PQ ##KtS1IJrDcd|_d|_|jr|jj|jj t y)zRemove the session.N)r>r=r<cancelr/ remove_itemrrGs rBr^z SyncGoTrueClient._remove_sessionsA#   # #  $ $ + + - &&{3rDc|jr|jj|dks |jsyt||j|_|jj y)Nr)r<rr-rrtstart)r?rs rBrz*SyncGoTrueClient._start_auto_refresh_tokensV  # #  $ $ + + - A:T44 #(0H0H#I    &&(rD)r+rr,zDict[str, str]r-boolr.rr/r(r0rr1zOptional[SyncGoTrueAPI]r2rr3rr4 Optional[str]returnNone)rr*)rr) rTrrUrrVrrWrrXzOptional[Dict[str, Any]]rUnion[Session, User])rTrrUrrVrrgrrhzOptional[Provider]rWrrirrjrrzOptional[Union[Session, str]])rUrrxrrWrrr)rzOptional[User])rzOptional[Session])rr )rz)Union[UserAttributesDict, UserAttributes]rr")rgrrr )rrrr )r+rrrrr )rrrr)rz4Callable[[AuthChangeEvent, Optional[Session]], None]rr!)rTrrVrrWrrr )rUrrVrrr )rhrrWrrirrr)rz"Optional[Tuple[Session, int, int]])rgrrr )r]rrr)r[r rr)rfloatrr)&__name__ __module__ __qualname__rr'r parse_objrrCrHrNrJrSrfrvrzr|r[rrrrrrrrrprrrurrQrRrtrcrbrr^rr7rDrBr*r*s"$#' $.?.A(? (?(?(O'+(-#9090 90 ! 90  90,90&90%90"&909090 90v$ $#"&%))-;; ;  ; # ;'; ;@ $#"&'+'+%) $![[ [  [ % [%[#[[[ '[D&* && & # &  &P!$*!F6&X$ AA A  AF0+G  >  #   "    #     1&JJ"EI 8 3K4)rDr*N)2 __future__r functoolsrrrr threadingrrtypingr r r r r rr urllib.parserruuidr constantsrrrr exceptionsrhelpersrrrrtypesrrrr r!r"r#r$r1r&storager'r(r*r7rDrBrsU"DDD+PP!KK   <y )y )rD