adjust retries
This commit is contained in:
parent
bd34f12a4e
commit
399ed4b4e4
@ -48,8 +48,8 @@ class Api:
|
|||||||
self.header = None
|
self.header = None
|
||||||
self._client = httpx.AsyncClient(timeout=httpx.Timeout(5.0, connect=5.0))
|
self._client = httpx.AsyncClient(timeout=httpx.Timeout(5.0, connect=5.0))
|
||||||
|
|
||||||
@retry_request(n_retries=10, timeout=5.0)
|
@retry_request(n_retries=5, timeout=15.0)
|
||||||
async def refreshAuth(self) -> None:
|
async def refreshAuth(self, timeout=None) -> None:
|
||||||
uri = "https://accounts.spotify.com/api/token"
|
uri = "https://accounts.spotify.com/api/token"
|
||||||
data = {
|
data = {
|
||||||
"grant_type": "refresh_token",
|
"grant_type": "refresh_token",
|
||||||
@ -59,6 +59,7 @@ class Api:
|
|||||||
uri,
|
uri,
|
||||||
data=data,
|
data=data,
|
||||||
headers={"Authorization": "Basic " + self.base_64},
|
headers={"Authorization": "Basic " + self.base_64},
|
||||||
|
timeout=timeout,
|
||||||
)
|
)
|
||||||
req = res.json()
|
req = res.json()
|
||||||
self.access_token = req["access_token"]
|
self.access_token = req["access_token"]
|
||||||
@ -66,9 +67,9 @@ class Api:
|
|||||||
return req["expires_in"]
|
return req["expires_in"]
|
||||||
|
|
||||||
@retry_request(n_retries=4, timeout=3.0)
|
@retry_request(n_retries=4, timeout=3.0)
|
||||||
async def getPlaying(self):
|
async def getPlaying(self, timeout=None):
|
||||||
url = "https://api.spotify.com/v1/me/player/currently-playing"
|
url = "https://api.spotify.com/v1/me/player/currently-playing"
|
||||||
req = await self._client.get(url, headers=self.header)
|
req = await self._client.get(url, headers=self.header, timeout=timeout)
|
||||||
if req.status_code == 204:
|
if req.status_code == 204:
|
||||||
return "not-playing"
|
return "not-playing"
|
||||||
if req.status_code == 401:
|
if req.status_code == 401:
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user