mirror/AudioBookRequest
1
0
Fork 0
mirror of https://github.com/markbeep/AudioBookRequest.git synced 2025-12-21 04:50:17 -06:00
Code Issues Packages Projects Releases Wiki Activity

fix: correctly handle book metadata server being down

Browse Source
This commit is contained in:
Markbeep
2025-10-04 19:53:09 +02:00
parent 82f356f0cf
commit 399d82ed4e
1 changed files with 44 additions and 25 deletions
Download Patch File Download Diff File Expand all files Collapse all files

69
app/internal/book_search.py
View File

@@ -70,18 +70,23 @@ async def _get_audnexus_book(
https://audnex.us/#tag/Books/operation/getBookById
"""
logger.debug("Fetching book from Audnexus", asin=asin, region=region)
async with session.get(
f"https://api.audnex.us/books/{asin}?region={region}"
) as response:
if not response.ok:
logger.warning(
"Failed to fetch book from Audnexus",
asin=asin,
status=response.status,
reason=response.reason,
)
return None
book = await response.json()
try:
async with session.get(
f"https://api.audnex.us/books/{asin}?region={region}",
headers={"Client-Agent": "audiobookrequest"},
) as response:
if not response.ok:
logger.warning(
"Failed to fetch book from Audnexus",
asin=asin,
status=response.status,
reason=response.reason,
)
return None
book = await response.json()
except Exception as e:
logger.error("Exception while fetching book from Audnexus", asin=asin, error=e)
return None
return BookRequest(
asin=book["asin"],
title=book["title"],
@@ -103,18 +108,23 @@ async def _get_audimeta_book(
https://audimeta.de/api-docs/#/book/get_book__asin_
"""
logger.debug("Fetching book from Audimeta", asin=asin, region=region)
async with session.get(
f"https://audimeta.de/book/{asin}?region={region}"
) as response:
if not response.ok:
logger.warning(
"Failed to fetch book from Audimeta",
asin=asin,
status=response.status,
reason=response.reason,
)
return None
book = await response.json()
try:
async with session.get(
f"https://audimeta.de/book/{asin}?region={region}",
headers={"Client-Agent": "audiobookrequest"},
) as response:
if not response.ok:
logger.warning(
"Failed to fetch book from Audimeta",
asin=asin,
status=response.status,
reason=response.reason,
)
return None
book = await response.json()
except Exception as e:
logger.error("Exception while fetching book from Audimeta", asin=asin, error=e)
return None
return BookRequest(
asin=book["asin"],
title=book["title"],
@@ -135,10 +145,19 @@ async def get_book_by_asin(
book = await _get_audimeta_book(session, asin, audible_region)
if book:
return book
logger.debug(
"Audimeta did not have the book, trying Audnexus",
asin=asin,
region=audible_region,
)
book = await _get_audnexus_book(session, asin, audible_region)
if book:
return book
logger.warning("Failed to fetch book", asin=asin, region=audible_region)
logger.warning(
"Did not find the book on both Audnexus and Audimeta",
asin=asin,
region=audible_region,
)
class CacheQuery(pydantic.BaseModel, frozen=True):