radio: refactor LRC fetching to directly use asyncio for backgrounding, and add null check for album art in RadioUtil

.gitignore

@@ -29,6 +29,7 @@ up.py
 job_review.py
 check_missing.py
 **/auth/*
+**/radio_api/*
 test/db_stats.py
 test/report/*
 .gitignore

endpoints/radio.py

@@ -434,7 +434,7 @@ class Radio(FastAPI):
         next["end"] = time_ends
 
         # Use BackgroundTasks for LRC fetch/cache
-        background_tasks.add_task(self._do_lrc_fetch, data.station, next.copy())
+        asyncio.create_task(self._do_lrc_fetch(data.station, next.copy()))
 
         try:
             background_tasks.add_task(self.radio_util.webhook_song_change, next, data.station)

utils/jwt_utils.py

@@ -0,0 +1,19 @@
+from jose import jwt, JWTError
+from ..auth.key_store import get_key_by_kid
+
+JWT_ALGORITHM = "HS256"
+
+
+def decode_jwt(token: str) -> dict | None:
+    """Decode a JWT token using the existing key management system."""
+    try:
+        headers = jwt.get_unverified_header(token)
+        kid = headers.get("kid")
+        if not kid:
+            return None
+        key = get_key_by_kid(kid)
+        if not key:
+            return None
+        return jwt.decode(token, key, algorithms=[JWT_ALGORITHM])
+    except JWTError:
+        return None

utils/radio_util.py

@@ -504,7 +504,7 @@ class RadioUtil:
                 track_id,
             )
             tagger = music_tag.load_file(file_path)
-            album_art = tagger["artwork"].first.data
+            album_art = tagger["artwork"].first.data if tagger else None
             with sqlite3.connect(self.album_art_db_path, timeout=2) as db_conn:
                 db_cursor = db_conn.execute(
                     "INSERT OR IGNORE INTO album_art (track_id, album_art) VALUES(?, ?)",