From c2d37fb40f7bdf24d8a072bc070ce88f462ffb65 Mon Sep 17 00:00:00 2001 From: leynier Date: Wed, 3 Nov 2021 22:48:52 -0400 Subject: [PATCH] fix: set prefix __ instead of _ for private methods --- gotrue/_async/api.py | 10 ++-- gotrue/_async/client.py | 108 ++++++++++++++++++++-------------------- gotrue/_sync/api.py | 10 ++-- gotrue/_sync/client.py | 108 ++++++++++++++++++++-------------------- 4 files changed, 118 insertions(+), 118 deletions(-) diff --git a/gotrue/_async/api.py b/gotrue/_async/api.py index 8ae3d9ed..6470f0e4 100644 --- a/gotrue/_async/api.py +++ b/gotrue/_async/api.py @@ -336,7 +336,7 @@ async def reset_password_for_email( response = await self.http_client.post(url, json=data, headers=headers) return parse_response(response, lambda _: None) - def _create_request_headers(self, *, jwt: str) -> dict[str, str]: + def __create_request_headers(self, *, jwt: str) -> dict[str, str]: """Create temporary object. Create a temporary object with all configured headers and adds the @@ -365,7 +365,7 @@ async def sign_out(self, *, jwt: str) -> None: jwt : str A valid, logged-in JWT. """ - headers = self._create_request_headers(jwt=jwt) + headers = self.__create_request_headers(jwt=jwt) url = f"{self.url}/logout" await self.http_client.post(url, headers=headers) @@ -423,7 +423,7 @@ async def get_user(self, *, jwt: str) -> User: error : APIError If an error occurs """ - headers = self._create_request_headers(jwt=jwt) + headers = self.__create_request_headers(jwt=jwt) url = f"{self.url}/user" response = await self.http_client.get(url, headers=headers) return parse_response(response, User.from_dict) @@ -454,7 +454,7 @@ async def update_user( error : APIError If an error occurs """ - headers = self._create_request_headers(jwt=jwt) + headers = self.__create_request_headers(jwt=jwt) data = attributes.to_dict() url = f"{self.url}/user" response = await self.http_client.put(url, json=data, headers=headers) @@ -483,7 +483,7 @@ async def delete_user(self, *, uid: str, jwt: str) -> User: error : APIError If an error occurs """ - headers = self._create_request_headers(jwt=jwt) + headers = self.__create_request_headers(jwt=jwt) url = f"{self.url}/admin/users/${uid}" response = await self.http_client.delete(url, headers=headers) return parse_response(response, User.from_dict) diff --git a/gotrue/_async/client.py b/gotrue/_async/client.py index 7506a7bc..40ac2c91 100644 --- a/gotrue/_async/client.py +++ b/gotrue/_async/client.py @@ -80,8 +80,8 @@ async def close(self) -> None: async def init_recover(self) -> None: """Recover the current session from local storage.""" - await self._recover_session() - await self._recover_and_refresh() + await self.__recover_session() + await self.__recover_and_refresh() async def sign_up( self, @@ -118,7 +118,7 @@ async def sign_up( error : APIError If an error occurs """ - await self._remove_session() + await self.__remove_session() if email and password: response = await self.api.sign_up_with_email( @@ -139,8 +139,8 @@ async def sign_up( if isinstance(response, Session): # The user has confirmed their email or the underlying DB doesn't # require email confirmation. - await self._save_session(session=response) - self._notify_all_subscribers(event=AuthChangeEvent.SIGNED_IN) + await self.__save_session(session=response) + self.__notify_all_subscribers(event=AuthChangeEvent.SIGNED_IN) return response async def sign_in( @@ -197,11 +197,11 @@ async def sign_in( error : APIError If an error occurs """ - await self._remove_session() + await self.__remove_session() if email and not password: response = await self.api.send_magic_link_email(email=email) elif email and password: - response = await self._handle_email_sign_in( + response = await self.__handle_email_sign_in( email=email, password=password, redirect_to=redirect_to, @@ -209,14 +209,14 @@ async def sign_in( elif phone and not password: response = await self.api.send_mobile_otp(phone=phone) elif phone and password: - response = await self._handle_phone_sign_in(phone=phone, password=password) + response = await self.__handle_phone_sign_in(phone=phone, password=password) elif refresh_token: # current_session and current_user will be updated to latest # on _call_refresh_token using the passed refresh_token - await self._call_refresh_token(refresh_token=refresh_token) + await self.__call_refresh_token(refresh_token=refresh_token) response = self.current_session elif provider: - response = await self._handle_provider_sign_in( + response = await self.__handle_provider_sign_in( provider=provider, redirect_to=redirect_to, scopes=scopes, @@ -257,15 +257,15 @@ async def verify_otp( error : APIError If an error occurs """ - await self._remove_session() + await self.__remove_session() response = await self.api.verify_mobile_otp( phone=phone, token=token, redirect_to=redirect_to, ) if isinstance(response, Session): - await self._save_session(session=response) - self._notify_all_subscribers(event=AuthChangeEvent.SIGNED_IN) + await self.__save_session(session=response) + self.__notify_all_subscribers(event=AuthChangeEvent.SIGNED_IN) return response def user(self) -> Optional[User]: @@ -284,7 +284,7 @@ async def refresh_session(self) -> Session: """ if not self.current_session: raise ValueError("Not logged in.") - response = await self._call_refresh_token() + response = await self.__call_refresh_token() return response async def update(self, *, attributes: UserAttributes) -> User: @@ -312,8 +312,8 @@ async def update(self, *, attributes: UserAttributes) -> User: attributes=attributes, ) self.current_session.user = response - await self._save_session(session=self.current_session) - self._notify_all_subscribers(event=AuthChangeEvent.USER_UPDATED) + await self.__save_session(session=self.current_session) + self.__notify_all_subscribers(event=AuthChangeEvent.USER_UPDATED) return response async def set_session(self, *, refresh_token: str) -> Session: @@ -335,8 +335,8 @@ async def set_session(self, *, refresh_token: str) -> Session: If an error occurs """ response = await self.api.refresh_access_token(refresh_token=refresh_token) - await self._save_session(session=response) - self._notify_all_subscribers(event=AuthChangeEvent.SIGNED_IN) + await self.__save_session(session=response) + self.__notify_all_subscribers(event=AuthChangeEvent.SIGNED_IN) return response async def set_auth(self, *, access_token: str) -> Session: @@ -372,7 +372,7 @@ async def set_auth(self, *, access_token: str) -> Session: session.expires_at = self.current_session.expires_at session.refresh_token = self.current_session.refresh_token session.provider_token = self.current_session.provider_token - await self._save_session(session=session) + await self.__save_session(session=session) return session async def get_session_from_url( @@ -430,10 +430,10 @@ async def get_session_from_url( provider_token=provider_token[0] if provider_token else None, ) if store_session: - await self._save_session(session=session) - self._notify_all_subscribers(event=AuthChangeEvent.SIGNED_IN) + await self.__save_session(session=session) + self.__notify_all_subscribers(event=AuthChangeEvent.SIGNED_IN) if query.get("type") == "recovery": - self._notify_all_subscribers(event=AuthChangeEvent.PASSWORD_RECOVERY) + self.__notify_all_subscribers(event=AuthChangeEvent.PASSWORD_RECOVERY) return session async def sign_out(self) -> None: @@ -441,12 +441,12 @@ async def sign_out(self) -> None: access_token: Optional[str] = None if self.current_session: access_token = self.current_session.access_token - await self._remove_session() - self._notify_all_subscribers(event=AuthChangeEvent.SIGNED_OUT) + await self.__remove_session() + self.__notify_all_subscribers(event=AuthChangeEvent.SIGNED_OUT) if access_token: await self.api.sign_out(jwt=access_token) - def _unsubscribe(self, *, id: str) -> None: + def __unsubscribe(self, *, id: str) -> None: """Unsubscribe from a subscription.""" self.state_change_emitters.pop(id) @@ -476,12 +476,12 @@ def on_auth_state_change( subscription = Subscription( id=unique_id, callback=callback, - unsubscribe=partial(self._unsubscribe, id=unique_id), + unsubscribe=partial(self.__unsubscribe, id=unique_id), ) self.state_change_emitters[unique_id] = subscription return subscription - async def _handle_email_sign_in( + async def __handle_email_sign_in( self, *, email: str, @@ -494,18 +494,18 @@ async def _handle_email_sign_in( password=password, redirect_to=redirect_to, ) - await self._save_session(session=response) - self._notify_all_subscribers(event=AuthChangeEvent.SIGNED_IN) + await self.__save_session(session=response) + self.__notify_all_subscribers(event=AuthChangeEvent.SIGNED_IN) return response - async def _handle_phone_sign_in(self, *, phone: str, password: str) -> Session: + async def __handle_phone_sign_in(self, *, phone: str, password: str) -> Session: """Sign in with phone and password.""" response = await self.api.sign_in_with_phone(phone=phone, password=password) - await self._save_session(session=response) - self._notify_all_subscribers(event=AuthChangeEvent.SIGNED_IN) + await self.__save_session(session=response) + self.__notify_all_subscribers(event=AuthChangeEvent.SIGNED_IN) return response - async def _handle_provider_sign_in( + async def __handle_provider_sign_in( self, *, provider: Provider, @@ -520,7 +520,7 @@ async def _handle_provider_sign_in( ) return response - async def _recover_session(self) -> None: + async def __recover_session(self) -> None: """Attempts to get the session from LocalStorage""" json = await self.local_storage.get_item(STORAGE_KEY) if not json: @@ -538,10 +538,10 @@ async def _recover_session(self) -> None: session = Session.from_dict(session_raw) time_now = round(time()) if expires_at >= time_now: - await self._save_session(session=session) - self._notify_all_subscribers(event=AuthChangeEvent.SIGNED_IN) + await self.__save_session(session=session) + self.__notify_all_subscribers(event=AuthChangeEvent.SIGNED_IN) - async def _recover_and_refresh(self) -> None: + async def __recover_and_refresh(self) -> None: """Recovers the session from LocalStorage and refreshes""" json = await self.local_storage.get_item(STORAGE_KEY) if not json: @@ -561,20 +561,20 @@ async def _recover_and_refresh(self) -> None: if expires_at < time_now: if self.auto_refresh_token and session.refresh_token: try: - await self._call_refresh_token( + await self.__call_refresh_token( refresh_token=session.refresh_token ) except APIError: - await self._remove_session() + await self.__remove_session() else: - await self._remove_session() + await self.__remove_session() elif not session or not session.user: - await self._remove_session() + await self.__remove_session() else: - await self._save_session(session=session) - self._notify_all_subscribers(event=AuthChangeEvent.SIGNED_IN) + await self.__save_session(session=session) + self.__notify_all_subscribers(event=AuthChangeEvent.SIGNED_IN) - async def _call_refresh_token( + async def __call_refresh_token( self, *, refresh_token: Optional[str] = None ) -> Session: if refresh_token is None: @@ -585,16 +585,16 @@ async def _call_refresh_token( response = await self.api.refresh_access_token( refresh_token=cast(str, refresh_token) ) - await self._save_session(session=response) - self._notify_all_subscribers(event=AuthChangeEvent.SIGNED_IN) + await self.__save_session(session=response) + self.__notify_all_subscribers(event=AuthChangeEvent.SIGNED_IN) return response - def _notify_all_subscribers(self, *, event: AuthChangeEvent) -> None: + def __notify_all_subscribers(self, *, event: AuthChangeEvent) -> None: """Notify all subscribers that auth event happened.""" for value in self.state_change_emitters.values(): value.callback(event, self.current_session) - async def _save_session(self, *, session: Session) -> None: + async def __save_session(self, *, session: Session) -> None: """Save session to client.""" self.current_session = session self.current_user = session.user @@ -602,17 +602,17 @@ async def _save_session(self, *, session: Session) -> None: time_now = round(time()) expire_in = session.expires_at - time_now refresh_duration_before_expires = 60 if expire_in > 60 else 0.5 - self._start_auto_refresh_token( + self.__start_auto_refresh_token( value=(expire_in - refresh_duration_before_expires) * 1000 ) if self.persist_session and session.expires_at: - await self._persist_session(session=session) + await self.__persist_session(session=session) - async def _persist_session(self, *, session: Session) -> None: + async def __persist_session(self, *, session: Session) -> None: data = {"session": session.to_dict(), "expires_at": session.expires_at} await self.local_storage.set_item(STORAGE_KEY, dumps(data)) - async def _remove_session(self) -> None: + async def __remove_session(self) -> None: """Remove the session.""" self.current_session = None self.current_user = None @@ -620,10 +620,10 @@ async def _remove_session(self) -> None: self.refresh_token_timer.cancel() await self.local_storage.remove_item(STORAGE_KEY) - def _start_auto_refresh_token(self, *, value: float) -> None: + def __start_auto_refresh_token(self, *, value: float) -> None: if self.refresh_token_timer: self.refresh_token_timer.cancel() if value <= 0 or not self.auto_refresh_token: return - self.refresh_token_timer = Timer(value, self._call_refresh_token) + self.refresh_token_timer = Timer(value, self.__call_refresh_token) self.refresh_token_timer.start() diff --git a/gotrue/_sync/api.py b/gotrue/_sync/api.py index 7444a2e7..df6d8398 100644 --- a/gotrue/_sync/api.py +++ b/gotrue/_sync/api.py @@ -336,7 +336,7 @@ def reset_password_for_email( response = self.http_client.post(url, json=data, headers=headers) return parse_response(response, lambda _: None) - def _create_request_headers(self, *, jwt: str) -> dict[str, str]: + def __create_request_headers(self, *, jwt: str) -> dict[str, str]: """Create temporary object. Create a temporary object with all configured headers and adds the @@ -365,7 +365,7 @@ def sign_out(self, *, jwt: str) -> None: jwt : str A valid, logged-in JWT. """ - headers = self._create_request_headers(jwt=jwt) + headers = self.__create_request_headers(jwt=jwt) url = f"{self.url}/logout" self.http_client.post(url, headers=headers) @@ -423,7 +423,7 @@ def get_user(self, *, jwt: str) -> User: error : APIError If an error occurs """ - headers = self._create_request_headers(jwt=jwt) + headers = self.__create_request_headers(jwt=jwt) url = f"{self.url}/user" response = self.http_client.get(url, headers=headers) return parse_response(response, User.from_dict) @@ -454,7 +454,7 @@ def update_user( error : APIError If an error occurs """ - headers = self._create_request_headers(jwt=jwt) + headers = self.__create_request_headers(jwt=jwt) data = attributes.to_dict() url = f"{self.url}/user" response = self.http_client.put(url, json=data, headers=headers) @@ -483,7 +483,7 @@ def delete_user(self, *, uid: str, jwt: str) -> User: error : APIError If an error occurs """ - headers = self._create_request_headers(jwt=jwt) + headers = self.__create_request_headers(jwt=jwt) url = f"{self.url}/admin/users/${uid}" response = self.http_client.delete(url, headers=headers) return parse_response(response, User.from_dict) diff --git a/gotrue/_sync/client.py b/gotrue/_sync/client.py index 37eb67b7..b19ee925 100644 --- a/gotrue/_sync/client.py +++ b/gotrue/_sync/client.py @@ -80,8 +80,8 @@ def close(self) -> None: def init_recover(self) -> None: """Recover the current session from local storage.""" - self._recover_session() - self._recover_and_refresh() + self.__recover_session() + self.__recover_and_refresh() def sign_up( self, @@ -118,7 +118,7 @@ def sign_up( error : APIError If an error occurs """ - self._remove_session() + self.__remove_session() if email and password: response = self.api.sign_up_with_email( @@ -139,8 +139,8 @@ def sign_up( if isinstance(response, Session): # The user has confirmed their email or the underlying DB doesn't # require email confirmation. - self._save_session(session=response) - self._notify_all_subscribers(event=AuthChangeEvent.SIGNED_IN) + self.__save_session(session=response) + self.__notify_all_subscribers(event=AuthChangeEvent.SIGNED_IN) return response def sign_in( @@ -197,11 +197,11 @@ def sign_in( error : APIError If an error occurs """ - self._remove_session() + self.__remove_session() if email and not password: response = self.api.send_magic_link_email(email=email) elif email and password: - response = self._handle_email_sign_in( + response = self.__handle_email_sign_in( email=email, password=password, redirect_to=redirect_to, @@ -209,14 +209,14 @@ def sign_in( elif phone and not password: response = self.api.send_mobile_otp(phone=phone) elif phone and password: - response = self._handle_phone_sign_in(phone=phone, password=password) + response = self.__handle_phone_sign_in(phone=phone, password=password) elif refresh_token: # current_session and current_user will be updated to latest # on _call_refresh_token using the passed refresh_token - self._call_refresh_token(refresh_token=refresh_token) + self.__call_refresh_token(refresh_token=refresh_token) response = self.current_session elif provider: - response = self._handle_provider_sign_in( + response = self.__handle_provider_sign_in( provider=provider, redirect_to=redirect_to, scopes=scopes, @@ -257,15 +257,15 @@ def verify_otp( error : APIError If an error occurs """ - self._remove_session() + self.__remove_session() response = self.api.verify_mobile_otp( phone=phone, token=token, redirect_to=redirect_to, ) if isinstance(response, Session): - self._save_session(session=response) - self._notify_all_subscribers(event=AuthChangeEvent.SIGNED_IN) + self.__save_session(session=response) + self.__notify_all_subscribers(event=AuthChangeEvent.SIGNED_IN) return response def user(self) -> Optional[User]: @@ -284,7 +284,7 @@ def refresh_session(self) -> Session: """ if not self.current_session: raise ValueError("Not logged in.") - response = self._call_refresh_token() + response = self.__call_refresh_token() return response def update(self, *, attributes: UserAttributes) -> User: @@ -312,8 +312,8 @@ def update(self, *, attributes: UserAttributes) -> User: attributes=attributes, ) self.current_session.user = response - self._save_session(session=self.current_session) - self._notify_all_subscribers(event=AuthChangeEvent.USER_UPDATED) + self.__save_session(session=self.current_session) + self.__notify_all_subscribers(event=AuthChangeEvent.USER_UPDATED) return response def set_session(self, *, refresh_token: str) -> Session: @@ -335,8 +335,8 @@ def set_session(self, *, refresh_token: str) -> Session: If an error occurs """ response = self.api.refresh_access_token(refresh_token=refresh_token) - self._save_session(session=response) - self._notify_all_subscribers(event=AuthChangeEvent.SIGNED_IN) + self.__save_session(session=response) + self.__notify_all_subscribers(event=AuthChangeEvent.SIGNED_IN) return response def set_auth(self, *, access_token: str) -> Session: @@ -372,7 +372,7 @@ def set_auth(self, *, access_token: str) -> Session: session.expires_at = self.current_session.expires_at session.refresh_token = self.current_session.refresh_token session.provider_token = self.current_session.provider_token - self._save_session(session=session) + self.__save_session(session=session) return session def get_session_from_url(self, *, url: str, store_session: bool = False) -> Session: @@ -428,10 +428,10 @@ def get_session_from_url(self, *, url: str, store_session: bool = False) -> Sess provider_token=provider_token[0] if provider_token else None, ) if store_session: - self._save_session(session=session) - self._notify_all_subscribers(event=AuthChangeEvent.SIGNED_IN) + self.__save_session(session=session) + self.__notify_all_subscribers(event=AuthChangeEvent.SIGNED_IN) if query.get("type") == "recovery": - self._notify_all_subscribers(event=AuthChangeEvent.PASSWORD_RECOVERY) + self.__notify_all_subscribers(event=AuthChangeEvent.PASSWORD_RECOVERY) return session def sign_out(self) -> None: @@ -439,12 +439,12 @@ def sign_out(self) -> None: access_token: Optional[str] = None if self.current_session: access_token = self.current_session.access_token - self._remove_session() - self._notify_all_subscribers(event=AuthChangeEvent.SIGNED_OUT) + self.__remove_session() + self.__notify_all_subscribers(event=AuthChangeEvent.SIGNED_OUT) if access_token: self.api.sign_out(jwt=access_token) - def _unsubscribe(self, *, id: str) -> None: + def __unsubscribe(self, *, id: str) -> None: """Unsubscribe from a subscription.""" self.state_change_emitters.pop(id) @@ -474,12 +474,12 @@ def on_auth_state_change( subscription = Subscription( id=unique_id, callback=callback, - unsubscribe=partial(self._unsubscribe, id=unique_id), + unsubscribe=partial(self.__unsubscribe, id=unique_id), ) self.state_change_emitters[unique_id] = subscription return subscription - def _handle_email_sign_in( + def __handle_email_sign_in( self, *, email: str, @@ -492,18 +492,18 @@ def _handle_email_sign_in( password=password, redirect_to=redirect_to, ) - self._save_session(session=response) - self._notify_all_subscribers(event=AuthChangeEvent.SIGNED_IN) + self.__save_session(session=response) + self.__notify_all_subscribers(event=AuthChangeEvent.SIGNED_IN) return response - def _handle_phone_sign_in(self, *, phone: str, password: str) -> Session: + def __handle_phone_sign_in(self, *, phone: str, password: str) -> Session: """Sign in with phone and password.""" response = self.api.sign_in_with_phone(phone=phone, password=password) - self._save_session(session=response) - self._notify_all_subscribers(event=AuthChangeEvent.SIGNED_IN) + self.__save_session(session=response) + self.__notify_all_subscribers(event=AuthChangeEvent.SIGNED_IN) return response - def _handle_provider_sign_in( + def __handle_provider_sign_in( self, *, provider: Provider, @@ -518,7 +518,7 @@ def _handle_provider_sign_in( ) return response - def _recover_session(self) -> None: + def __recover_session(self) -> None: """Attempts to get the session from LocalStorage""" json = self.local_storage.get_item(STORAGE_KEY) if not json: @@ -536,10 +536,10 @@ def _recover_session(self) -> None: session = Session.from_dict(session_raw) time_now = round(time()) if expires_at >= time_now: - self._save_session(session=session) - self._notify_all_subscribers(event=AuthChangeEvent.SIGNED_IN) + self.__save_session(session=session) + self.__notify_all_subscribers(event=AuthChangeEvent.SIGNED_IN) - def _recover_and_refresh(self) -> None: + def __recover_and_refresh(self) -> None: """Recovers the session from LocalStorage and refreshes""" json = self.local_storage.get_item(STORAGE_KEY) if not json: @@ -559,34 +559,34 @@ def _recover_and_refresh(self) -> None: if expires_at < time_now: if self.auto_refresh_token and session.refresh_token: try: - self._call_refresh_token(refresh_token=session.refresh_token) + self.__call_refresh_token(refresh_token=session.refresh_token) except APIError: - self._remove_session() + self.__remove_session() else: - self._remove_session() + self.__remove_session() elif not session or not session.user: - self._remove_session() + self.__remove_session() else: - self._save_session(session=session) - self._notify_all_subscribers(event=AuthChangeEvent.SIGNED_IN) + self.__save_session(session=session) + self.__notify_all_subscribers(event=AuthChangeEvent.SIGNED_IN) - def _call_refresh_token(self, *, refresh_token: Optional[str] = None) -> Session: + def __call_refresh_token(self, *, refresh_token: Optional[str] = None) -> Session: if refresh_token is None: if self.current_session: refresh_token = self.current_session.refresh_token else: raise ValueError("No current session and refresh_token not supplied.") response = self.api.refresh_access_token(refresh_token=cast(str, refresh_token)) - self._save_session(session=response) - self._notify_all_subscribers(event=AuthChangeEvent.SIGNED_IN) + self.__save_session(session=response) + self.__notify_all_subscribers(event=AuthChangeEvent.SIGNED_IN) return response - def _notify_all_subscribers(self, *, event: AuthChangeEvent) -> None: + def __notify_all_subscribers(self, *, event: AuthChangeEvent) -> None: """Notify all subscribers that auth event happened.""" for value in self.state_change_emitters.values(): value.callback(event, self.current_session) - def _save_session(self, *, session: Session) -> None: + def __save_session(self, *, session: Session) -> None: """Save session to client.""" self.current_session = session self.current_user = session.user @@ -594,17 +594,17 @@ def _save_session(self, *, session: Session) -> None: time_now = round(time()) expire_in = session.expires_at - time_now refresh_duration_before_expires = 60 if expire_in > 60 else 0.5 - self._start_auto_refresh_token( + self.__start_auto_refresh_token( value=(expire_in - refresh_duration_before_expires) * 1000 ) if self.persist_session and session.expires_at: - self._persist_session(session=session) + self.__persist_session(session=session) - def _persist_session(self, *, session: Session) -> None: + def __persist_session(self, *, session: Session) -> None: data = {"session": session.to_dict(), "expires_at": session.expires_at} self.local_storage.set_item(STORAGE_KEY, dumps(data)) - def _remove_session(self) -> None: + def __remove_session(self) -> None: """Remove the session.""" self.current_session = None self.current_user = None @@ -612,10 +612,10 @@ def _remove_session(self) -> None: self.refresh_token_timer.cancel() self.local_storage.remove_item(STORAGE_KEY) - def _start_auto_refresh_token(self, *, value: float) -> None: + def __start_auto_refresh_token(self, *, value: float) -> None: if self.refresh_token_timer: self.refresh_token_timer.cancel() if value <= 0 or not self.auto_refresh_token: return - self.refresh_token_timer = Timer(value, self._call_refresh_token) + self.refresh_token_timer = Timer(value, self.__call_refresh_token) self.refresh_token_timer.start()