Skip to content
Draft
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
23 changes: 15 additions & 8 deletions streamrip/client/qobuz.py
Original file line number Diff line number Diff line change
Expand Up @@ -409,14 +409,21 @@ async def _test_secret(self, secret: str) -> Optional[str]:
return None

async def _get_valid_secret(self, secrets: list[str]) -> str:
results = await asyncio.gather(
*[self._test_secret(secret) for secret in secrets],
)
working_secrets = [r for r in results if r is not None]
if len(working_secrets) == 0:
raise InvalidAppSecretError(secrets)

return working_secrets[0]
# ⚑ Bolt: Optimize secret validation by returning the first valid secret immediately
# and cancelling remaining background tasks. This prevents slow-tail latency
# where a fast valid response waits for slow or timed-out invalid responses.
tasks = [asyncio.create_task(self._test_secret(secret)) for secret in secrets]
try:
for coro in asyncio.as_completed(tasks):
result = await coro
if result is not None:
return result
finally:
for task in tasks:
if not task.done():
task.cancel()

raise InvalidAppSecretError(secrets)

async def _request_file_url(
self,
Expand Down