codey/api
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

add notifier to lyric_search for unknown request src, add timeout for widget/radio endpoint

Browse Source
This commit is contained in:
codey 2025-01-22 19:49:46 -05:00
parent 417d8b00f0
commit 2df8250ba2
2 changed files with 6 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
endpoints/lyric_search.py
View File

@ -13,6 +13,7 @@ import aiosqlite as sqlite3
from fastapi import FastAPI, HTTPException from fastapi import FastAPI, HTTPException
from pydantic import BaseModel from pydantic import BaseModel
from lyric_search_new.sources import aggregate from lyric_search_new.sources import aggregate
from lyric_search_new import notifier
class ValidLyricRequest(BaseModel): class ValidLyricRequest(BaseModel):
@ -92,6 +93,7 @@ class LyricSearch(FastAPI):
self.constants = constants self.constants = constants
self.glob_state = glob_state self.glob_state = glob_state
self.cache_utils = CacheUtils() self.cache_utils = CacheUtils()
self.notifier = notifier.DiscordNotifier()
self.lyrics_engine = importlib.import_module("lyrics_engine").LyricsEngine() self.lyrics_engine = importlib.import_module("lyrics_engine").LyricsEngine()
self.endpoint_name = "lyric_search" self.endpoint_name = "lyric_search"
@ -184,9 +186,11 @@ class LyricSearch(FastAPI):
raise HTTPException(detail="Invalid request", status_code=500) raise HTTPException(detail="Invalid request", status_code=500)
if data.src.upper() not in self.acceptable_request_sources: if data.src.upper() not in self.acceptable_request_sources:
await self.notifier.send(f"ERROR @ {__file__.rsplit("/", maxsplit=1)[-1]}",
f"Unknown request source: {data.src}")
return { return {
'err': True, 'err': True,
'errorText': f'Unknown request source: {data.src.upper()}', 'errorText': f'Unknown request source: {data.src}',
} }
search_artist: Optional[str] = data.a search_artist: Optional[str] = data.a

2
endpoints/misc.py
View File

@ -57,7 +57,7 @@ class Misc(FastAPI):
#TODO: change URL below to dynamically populate based on listener #TODO: change URL below to dynamically populate based on listener
async with ClientSession() as session: async with ClientSession() as session:
async with await session.post("http://127.0.0.1:52111/xc/", json=json_payload, async with await session.post("http://127.0.0.1:52111/xc/", json=json_payload,
headers=headers) as request: headers=headers, timeout=ClientTimeout(connect=3, sock_read=2)) as request:
request.raise_for_status() request.raise_for_status()
request_json = await request.json() request_json = await request.json()
request_json = request_json.get('response') request_json = request_json.get('response')