Remove duplicate oauth2 token validity check (#128419)
* remove duplicate validity check * Apply suggestions from code review * add leftover --------- Co-authored-by: Martin Hjelmare <marhje52@gmail.com>
This commit is contained in:
parent
8ae8fa7ec9
commit
144454b8c3
12 changed files with 12 additions and 25 deletions
|
@ -27,7 +27,6 @@ class AsyncConfigEntryAuth(AbstractAuth):
|
|||
|
||||
async def async_get_access_token(self) -> str:
|
||||
"""Return a valid access token."""
|
||||
if not self._oauth_session.valid_token:
|
||||
await self._oauth_session.async_ensure_token_valid()
|
||||
await self._oauth_session.async_ensure_token_valid()
|
||||
|
||||
return cast(str, self._oauth_session.token["access_token"])
|
||||
|
|
|
@ -156,8 +156,7 @@ class OAuthFitbitApi(FitbitApi):
|
|||
|
||||
async def async_get_access_token(self) -> dict[str, Any]:
|
||||
"""Return a valid access token for the Fitbit API."""
|
||||
if not self._oauth_session.valid_token:
|
||||
await self._oauth_session.async_ensure_token_valid()
|
||||
await self._oauth_session.async_ensure_token_valid()
|
||||
return self._oauth_session.token
|
||||
|
||||
|
||||
|
|
|
@ -46,8 +46,7 @@ class AsyncConfigEntryAuth:
|
|||
|
||||
async def async_get_access_token(self) -> str:
|
||||
"""Return a valid access token."""
|
||||
if not self._oauth_session.valid_token:
|
||||
await self._oauth_session.async_ensure_token_valid()
|
||||
await self._oauth_session.async_ensure_token_valid()
|
||||
return self._oauth_session.token[CONF_ACCESS_TOKEN]
|
||||
|
||||
async def _get_service(self) -> Resource:
|
||||
|
|
|
@ -33,8 +33,6 @@ class IottyProxy(CloudApi):
|
|||
|
||||
async def async_get_access_token(self) -> Any:
|
||||
"""Return a valid access token."""
|
||||
|
||||
if not self._oauth_session.valid_token:
|
||||
await self._oauth_session.async_ensure_token_valid()
|
||||
await self._oauth_session.async_ensure_token_valid()
|
||||
|
||||
return self._oauth_session.token["access_token"]
|
||||
|
|
|
@ -36,8 +36,7 @@ class ConfigEntryLyricClient(LyricClient):
|
|||
|
||||
async def async_get_access_token(self):
|
||||
"""Return a valid access token."""
|
||||
if not self._oauth_session.valid_token:
|
||||
await self._oauth_session.async_ensure_token_valid()
|
||||
await self._oauth_session.async_ensure_token_valid()
|
||||
|
||||
return self._oauth_session.token["access_token"]
|
||||
|
||||
|
|
|
@ -20,7 +20,6 @@ class AuthenticatedMonzoAPI(AbstractMonzoApi):
|
|||
|
||||
async def async_get_access_token(self) -> str:
|
||||
"""Return a valid access token."""
|
||||
if not self._oauth_session.valid_token:
|
||||
await self._oauth_session.async_ensure_token_valid()
|
||||
await self._oauth_session.async_ensure_token_valid()
|
||||
|
||||
return str(self._oauth_session.token["access_token"])
|
||||
|
|
|
@ -26,7 +26,6 @@ class AsyncConfigEntryAuth(AbstractAuth):
|
|||
|
||||
async def async_get_access_token(self) -> str:
|
||||
"""Return a valid access token."""
|
||||
if not self._oauth_session.valid_token:
|
||||
await self._oauth_session.async_ensure_token_valid()
|
||||
await self._oauth_session.async_ensure_token_valid()
|
||||
|
||||
return cast(str, self._oauth_session.token["access_token"])
|
||||
|
|
|
@ -44,8 +44,7 @@ class AsyncConfigEntryAuth(AbstractAuth):
|
|||
|
||||
async def async_get_access_token(self) -> str:
|
||||
"""Return a valid access token for SDM API."""
|
||||
if not self._oauth_session.valid_token:
|
||||
await self._oauth_session.async_ensure_token_valid()
|
||||
await self._oauth_session.async_ensure_token_valid()
|
||||
return cast(str, self._oauth_session.token["access_token"])
|
||||
|
||||
async def async_get_creds(self) -> Credentials:
|
||||
|
|
|
@ -40,6 +40,5 @@ class AsyncConfigEntryNetatmoAuth(pyatmo.AbstractAsyncAuth):
|
|||
|
||||
async def async_get_access_token(self) -> str:
|
||||
"""Return a valid access token for Netatmo API."""
|
||||
if not self._oauth_session.valid_token:
|
||||
await self._oauth_session.async_ensure_token_valid()
|
||||
await self._oauth_session.async_ensure_token_valid()
|
||||
return cast(str, self._oauth_session.token["access_token"])
|
||||
|
|
|
@ -20,7 +20,6 @@ class AsyncConfigEntryAuth(pypoint.AbstractAuth):
|
|||
|
||||
async def async_get_access_token(self) -> str:
|
||||
"""Return a valid access token."""
|
||||
if not self._oauth_session.valid_token:
|
||||
await self._oauth_session.async_ensure_token_valid()
|
||||
await self._oauth_session.async_ensure_token_valid()
|
||||
|
||||
return self._oauth_session.token["access_token"]
|
||||
|
|
|
@ -23,7 +23,6 @@ class AsyncConfigEntryAuth(AbstractAuth):
|
|||
|
||||
async def async_get_access_token(self) -> str:
|
||||
"""Return a valid access token."""
|
||||
if not self._oauth_session.valid_token:
|
||||
await self._oauth_session.async_ensure_token_valid()
|
||||
await self._oauth_session.async_ensure_token_valid()
|
||||
|
||||
return self._oauth_session.token[CONF_ACCESS_TOKEN]
|
||||
|
|
|
@ -49,7 +49,6 @@ class AsyncConfigEntryAuth(my_pypi_package.AbstractAuth):
|
|||
|
||||
async def async_get_access_token(self) -> str:
|
||||
"""Return a valid access token."""
|
||||
if not self._oauth_session.valid_token:
|
||||
await self._oauth_session.async_ensure_token_valid()
|
||||
await self._oauth_session.async_ensure_token_valid()
|
||||
|
||||
return self._oauth_session.token["access_token"]
|
||||
|
|
Loading…
Add table
Reference in a new issue