55import jwt
66from datetime import datetime
77from httpx import InvalidURL as HttpInvalidURL , HTTPError
8- from pydantic import (
9- HttpUrl ,
10- ValidationError as PydanticValidationError ,
11- validate_call
12- )
8+ from pydantic import HttpUrl , ValidationError as PydanticValidationError , validate_call
139
1410from . import base
1511from .models import Client as ClientModel
@@ -115,15 +111,10 @@ def _access_token_is_expired(self):
115111 return True
116112 if not self .access_token_expires_at :
117113 try :
118- self ._set_access_token_expires_at (
119- Token (access_token = self .access_token )
120- )
114+ self ._set_access_token_expires_at (Token (access_token = self .access_token ))
121115 except (PydanticValidationError , TypeError , HTTPError ):
122116 return True
123- if (
124- datetime .fromtimestamp (self .access_token_expires_at )
125- > datetime .now ()
126- ):
117+ if datetime .fromtimestamp (self .access_token_expires_at ) > datetime .now ():
127118 return False
128119 return True
129120
@@ -149,15 +140,10 @@ def _refresh_token_is_expired(self):
149140 return True
150141 if not self .refresh_token_expires_at :
151142 try :
152- self ._set_refresh_token_expires_at (
153- Token (refresh_token = self .refresh_token )
154- )
143+ self ._set_refresh_token_expires_at (Token (refresh_token = self .refresh_token ))
155144 except (PydanticValidationError , TypeError , HTTPError ):
156145 return True
157- if (
158- datetime .fromtimestamp (self .refresh_token_expires_at )
159- > datetime .now ()
160- ):
146+ if datetime .fromtimestamp (self .refresh_token_expires_at ) > datetime .now ():
161147 return False
162148 return True
163149
@@ -182,8 +168,7 @@ def _refresh_access_token(self):
182168
183169 def _get_headers (self ):
184170 _headers = self .headers .copy ()
185- if (self .username and self .password ) or \
186- self .access_token or self .refresh_token or self .auth0_token :
171+ if (self .username and self .password ) or self .access_token or self .refresh_token or self .auth0_token :
187172 if (
188173 self .refresh_token
189174 and self ._refresh_token_is_expired () is False
@@ -226,21 +211,15 @@ def login(self):
226211 elif self .username and self .password :
227212 self ._basic_login ()
228213 return self .token ()
229- elif (
230- self .access_token
231- and not self .refresh_token
232- and not (self .username and self .password )
233- ):
214+ elif self .access_token and not self .refresh_token and not (self .username and self .password ):
234215 try :
235216 response = Token (access_token = self .access_token )
236217 self ._set_access_token_expires_at (response )
237218 return response
238219 except (PydanticValidationError , TypeError ):
239220 return Token ()
240221 elif (
241- not self .access_token
242- and not self .refresh_token
243- and not (self .username and self .password )
222+ not self .access_token and not self .refresh_token and not (self .username and self .password )
244223 ):
245224 return Token ()
246225 else :
@@ -295,12 +274,10 @@ async def proxy_method(self, *args, **kwargs):
295274 for submodule_info in pkgutil .walk_packages (path = module .__path__ , prefix = sub_prefix ):
296275 submodule = importlib .import_module (submodule_info .name )
297276 if hasattr (submodule , "asyncio" ):
298- method_name = submodule_info .name .split ('.' )[- 1 ]
299- AsyncClient ._add_proxy_method (
300- method_name , submodule .asyncio
301- )
277+ method_name = submodule_info .name .split ("." )[- 1 ]
278+ AsyncClient ._add_proxy_method (method_name , submodule .asyncio )
302279 if hasattr (submodule , "sync" ):
303- method_name = submodule_info .name .split ('.' )[- 1 ]
280+ method_name = submodule_info .name .split ("." )[- 1 ]
304281 Client ._add_proxy_method (method_name , submodule .sync )
305282
306283 except Exception as e :
0 commit comments