o zsgY@sddlmZddlmZddlmZmZddlmZddl 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/m0Z0GdddZ1dS)) 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 @seZdZeiddeeeddddd dzddZd{ddZ d|ddZ d|ddZ d|d d!Z dddddd"d}d*d+Z ddddddddd,d~d3d4Zdd5dd7d8Zdd:d;Zdd=d>Zdd@dAZddEdFZddGdHZddJdKZddLddNdOZd|dPdQZddSdTZddXdYZddZd[Zdd\d]Zdd_d`ZddbdcZd|dddeZd|dfdgZddhddidjZ ddmdnZ!ddpdqZ"ddrdsZ#d|dtduZ$ddxdyZ%dS)SyncGoTrueClientTNF) urlheadersauto_refresh_tokenpersist_session local_storagecookie_optionsapireplace_default_headersverifyproxyr)strr*Dict[str, str]r+boolr,r-r'r.rr/Optional[SyncGoTrueAPI]r0r1r2 Optional[str]returnNonec Cst|std|drtdi|_d|_d|_d|_||_||_ ||_ |r*int } |i| ||| | d} |p@t di| |_ dS)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*r.r1r2)r ValueError startswithprintstate_change_emittersrefresh_token_timer current_usercurrent_sessionr+r,r-rr%r/) selfr)r*r+r,r-r.r/r0r1r2empty_or_default_headersargsr;r;O/var/www/html/minecraft/env/lib/python3.10/site-packages/gotrue/_sync/client.py__init__s*#   zSyncGoTrueClient.__init__cCs|SNr;rCr;r;rF __enter__XszSyncGoTrueClient.__enter__cCs |dSrH)close)rCexc_texc_vexc_tbr;r;rF__exit__[s zSyncGoTrueClient.__exit__cCs|jdSrH)r/rKrIr;r;rFrK^szSyncGoTrueClient.closecCs||dS)z/Recover the current session from local storage.N)_recover_session_recover_and_refreshrIr;r;rF init_recoveras zSyncGoTrueClient.init_recover)emailphonepassword redirect_todatarSrTrUrVrWOptional[Dict[str, Any]]Union[Session, User]cCs~||r|r|jj||||d}n|r!|r!|jj|||d}n |s'tdtdt|tr=|j|d|jt j d|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. )rSrUrVrW)rTrUrWz(Password must be defined, can't be None.z3Email or phone must be defined, both can't be None.sessionevent) _remove_sessionr/sign_up_with_emailsign_up_with_phoner< isinstancer _save_session_notify_all_subscribersr SIGNED_IN)rCrSrTrUrVrWresponser;r;rFsign_upfs&$  zSyncGoTrueClient.sign_up)rSrTrU refresh_tokenproviderrVscopes create_userrgrhOptional[Provider]rirjOptional[Union[Session, str]]c Cs||r|r|j|||d} | S|jj||d} | S|r3|r)|j||d} | S|jj||d} | S|r@|j|d|j} | S|rL|j|||d} | St d)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. rSrUrV)rSrjrTrU)rTrjrgrhrVrizLEmail, phone, refresh_token, or provider must be defined, all can't be None.) r^_handle_email_sign_inr/send_magic_link_email_handle_phone_sign_insend_mobile_otp_call_refresh_tokenrB_handle_provider_sign_inr<) rCrSrTrUrgrhrVrirjrer;r;rFsign_insF8    zSyncGoTrueClient.sign_in)rVtokencCsB||jj|||d}t|tr|j|d|jtjd|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. )rTrxrVrZr\) r^r/verify_mobile_otprarrbrcrrd)rCrTrxrVrer;r;rF verify_otps  zSyncGoTrueClient.verify_otpOptional[User]cC|jS)z4Returns the user data, if there is a logged in user.)rArIr;r;rFuser(zSyncGoTrueClient.userOptional[Session]cCr|)z8Returns the session data, if there is an active session.)rBrIr;r;rFr[,r~zSyncGoTrueClient.sessionrcCs|jstd|S)zForce refreshes the session. Force refreshes the session including the user data incase it was updated in a different session. Not logged in.)rBr<rurIr;r;rFrefresh_session0sz SyncGoTrueClient.refresh_session attributes)Union[UserAttributesDict, UserAttributes]r!cCsh|jstdt|trtdi|}n|}|jj|jj|d}||j_|j |jd|j t j d|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)jwtrrZr\Nr;) rBr<radictr"r/ update_user access_tokenr}rbrcr USER_UPDATED)rCrattributes_to_updaterer;r;rFupdate:s zSyncGoTrueClient.updatecCs<t|std|jj|d}|j|d|jtjd|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 tokenrorZr\)rr<r/refresh_access_tokenrbrcrrdrCrgrer;r;rF set_session]s  zSyncGoTrueClient.set_sessionrc Csdt|stdt|ddddddd}|jr*|jj|_|jj|_|jj|_|jj|_|j|d|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) rr<rrBrrrgrrb)rCrr[r;r;rFset_authxs$     zSyncGoTrueClient.set_auth) store_sessionrc Cst|stdt|}t|j}|d}|d}|d}|d}|d} |r3t|dd|r9|ds>td d|rD|dsItd d| rO| dsTtd d|rZ|ds_td dz ttt |d} Wn tyxtd dw|j j |dd} |d} t |d| d| t |d| |d| r| dndd} |r|j | d|d}|jtjd|r|ddkr|jtjd| S)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. r:error_descriptionrrrgrrizNo access_token detected.zNo refresh_token detected.zNo token_type detected.zNo expires_in detected.zInvalid expires_in.rrNrrZtyper\recovery)rr<rrquerygetrroundrintr/get_userrrbrcrrdPASSWORD_RECOVERY)rCr)rrWrrrrrgrrrerr[ recovery_moder;r;rFget_session_from_urlsT                    z%SyncGoTrueClient.get_session_from_urlcCsBd}|jr |jj}||jtjd|r|jj|ddSdS)zLog the user out.Nr\r)rBrr^rcr SIGNED_OUTr/sign_out)rCrr;r;rFrszSyncGoTrueClient.sign_outidcCs|j|dS)z Unsubscribe from a subscription.N)r?pop)rCrr;r;rF _unsubscribeszSyncGoTrueClient._unsubscribecallback4Callable[[AuthChangeEvent, Optional[Session]], None]r cCs0t}t||t|j|jdd}||j|j<|S)aReceive a notification every time an auth event happens. Parameters ---------- callback : Callable[[AuthChangeEvent, Optional[Session]], None] The callback to call when an auth event happens. Returns ------- subscription : Subscription A subscription object which can be used to unsubscribe itself. Raises ------ APIError If an error occurs. )r)rr unsubscribe)rr rrhexr?)rCr unique_id subscriptionr;r;rFon_auth_state_changes z%SyncGoTrueClient.on_auth_state_changecCs0|jj|||d}|j|d|jtjd|S)z Sign in with email and password.rmrZr\)r/sign_in_with_emailrbrcrrd)rCrSrUrVrer;r;rFrqs z&SyncGoTrueClient._handle_email_sign_incCs.|jj||d}|j|d|jtjd|S)z Sign in with phone and password.rnrZr\)r/sign_in_with_phonerbrcrrd)rCrTrUrer;r;rFrs!s z&SyncGoTrueClient._handle_phone_sign_inrcCs|jj|||dS)zSign in with provider.rp)r/get_url_for_provider)rCrhrVrir;r;rFrv(s z)SyncGoTrueClient._handle_provider_sign_in"Optional[Tuple[Session, int, int]]cCs|jt}|s dSt|}|d}|d}|r9t|tr;|r=t|tr?tt |}t|}t t }|||fSdSdSdSdS)zRecover common logicNr[r) r-get_itemrrrrarrrrrr)rCjsonrW session_rawexpires_at_rawr[rtime_nowr;r;rF_recover_common6s&      z SyncGoTrueClient._recover_commoncCsD|}|sdS|\}}}||kr |j|d|jtjddSdS)z-Attempts to get the session from LocalStorageNrZr\)rrbrcrrdrCresultr[rrr;r;rFrPIs  z!SyncGoTrueClient._recover_sessioncCs|}|sdS|\}}}||kr0|jr0|jr0z |j|jdWdSty/|YdSw||ks9|r9|js?|dS|j|d|jt j ddS)z4Recovers the session from LocalStorage and refreshesNrorZr\) rr+rgrurr^r}rbrcrrdrr;r;rFrQSs    z%SyncGoTrueClient._recover_and_refreshrocCs`|dur|jr |jj}ntd|jjtt|d}|j|d|jt j d|jt j d|S)Nz2No current session and refresh_token not supplied.rorZr\) rBrgr<r/rrr3rbrcrTOKEN_REFRESHEDrdrr;r;rFruds  z$SyncGoTrueClient._call_refresh_tokenr]rcCs"|jD] }|||jqdS)z0Notify all subscribers that auth event happened.N)r?valuesrrB)rCr]valuer;r;rFrcpsz(SyncGoTrueClient._notify_all_subscribersr[cCsl||_|j|_|jr$tt}|j|}|dkrdnd}|j||d|jr2|jr4|j|ddSdSdS)zSave session to client.<g?)rrZN) rBr}rArrr_start_auto_refresh_tokenr,_persist_session)rCr[r expire_inrefresh_duration_before_expiresr;r;rFrbus   zSyncGoTrueClient._save_sessioncCs*t||jd}|jtt|tddS)N)r[r)default)rrr-set_itemrrr3)rCr[rWr;r;rFrsz!SyncGoTrueClient._persist_sessioncCs,d|_d|_|jr|j|jtdS)zRemove the session.N)rBrAr@cancelr- remove_itemrrIr;r;rFr^s  z SyncGoTrueClient._remove_sessionrfloatcCs>|jr|j|dks|jsdSt||j|_|jdS)Nr)r@rr+rrustart)rCrr;r;rFrs  z*SyncGoTrueClient._start_auto_refresh_token)r)r3r*r4r+r5r,r5r-r'r.rr/r6r0r5r1r5r2r7r8r9)r8r()r8r9) rSr7rTr7rUr7rVr7rWrXr8rY)rSr7rTr7rUr7rgr7rhrkrVr7rir7rjr5r8rl)rTr3rxr3rVr7r8rY)r8r{)r8r)r8r)rrr8r!)rgr3r8r)rr3r8r)r)r3rr5r8r)rr3r8r9)rrr8r )rSr3rUr3rVr7r8r)rTr3rUr3r8r)rhrrVr7rir7r8r3)r8r)rgr7r8r)r]rr8r9)r[rr8r9)rrr8r9)&__name__ __module__ __qualname__rr&r parse_objrrGrJrOrKrRrfrwrzr}r[rrrrrrrrrqrsrvrrPrQrurcrbrr^rr;r;r;rFr(sp ;   @b (   # , C          r(N)2 __future__r functoolsrrrr threadingrrtypingrr r r r r r urllib.parserruuidr constantsrrrr exceptionsrhelpersrrrrtypesrrrrr r!r"r#r/r%storager&r'r(r;r;r;rFs   $  (