Update radio upload.

main.py

@@ -12,6 +12,7 @@ import pickle
 import re
 import sqlite3
 import time
+import traceback
 
 from google.auth.transport.requests import Request
 from google_auth_oauthlib.flow import InstalledAppFlow
@@ -355,8 +356,9 @@ async def message_callback(conn, cursor, youtube, client, room, event):
                         )
                     print(f"Added track to this week's playlist: {link}")
                     if recent:
-                        asyncio.create_task(process_radio_track(link, video_id, title))
+                        task = asyncio.create_task(process_radio_track(link, video_id, title))
-
+                        background_tasks.add(task)
+                        task.add_done_callback(background_tasks.discard)
 
 def in_playlist(cursor, video_id, playlist_id):
     """Checks if video is in playlist."""
@@ -444,89 +446,98 @@ async def backwards_sync(conn, cursor, youtube, client, room, start_token):
 
 async def process_radio_track(video_link, video_id, title):
     """Downloads native audio and pushes it to AzuraCast API in the background."""
-    if not AZURACAST_API_KEY:
-        return
-
-    # Sanitize title for the local filesystem
-    safe_title = "".join(c for c in title if c.isalnum() or c in " -_").strip()
-    base_filename = f"{safe_title}_{video_id}"
-    base_filepath = os.path.join(DATA_DIR, base_filename)
-
-    print(f"📻 Downloading audio for radio: {title}")
-
-    # 1. Download with yt-dlp (Keeping native AAC/Opus format)
-    dl_cmd = [
-        "yt-dlp",
-        "--extract-audio",
-        "--output",
-        f"{base_filepath}.%(ext)s",
-        video_link,
-    ]
-
-    process = await asyncio.create_subprocess_exec(
-        *dl_cmd, stdout=asyncio.subprocess.DEVNULL, stderr=asyncio.subprocess.DEVNULL
-    )
-    await process.communicate()
-
-    # Check for the file using glob since the extension (.m4a, .webm, .opus) is dynamic
-    downloaded_files = glob.glob(f"{base_filepath}.*")
-
-    if not downloaded_files:
-        print(f"❌ Failed to download audio for {title}")
-        return
-
-    filepath = downloaded_files[0]
-
-    print(f"📻 Uploading to AzuraCast: {title}")
-
-    # 2. Upload to AzuraCast using curl
-    upload_cmd = [
-        "curl",
-        "-s",
-        "-X",
-        "POST",
-        f"{AZURACAST_URL}/api/station/{AZURACAST_STATION_ID}/files",
-        "-H",
-        f"X-API-Key: {AZURACAST_API_KEY}",
-        "-F",
-        f"file=@{filepath}",
-    ]
-
-    curl_proc = await asyncio.create_subprocess_exec(
-        *upload_cmd, stdout=asyncio.subprocess.PIPE, stderr=asyncio.subprocess.PIPE
-    )
-    stdout, _ = await curl_proc.communicate()
-
-    # 3. Extract unique_id and push to the live queue
     try:
-        response = json.loads(stdout.decode())
+        print(f"🚀 DEBUG: Background task started for {title}")
-        unique_id = response.get("unique_id")
 
-        if unique_id:
+        if not AZURACAST_API_KEY:
-            req_cmd = [
+            print("❌ Error: AZURACAST_API_KEY is empty or missing.")
-                "curl",
+            return
-                "-s",
-                "-X",
-                "POST",
-                f"{AZURACAST_URL}/api/station/{AZURACAST_STATION_ID}/request/{unique_id}",
-                "-H",
-                f"X-API-Key: {AZURACAST_API_KEY}",
-            ]
-            req_proc = await asyncio.create_subprocess_exec(
-                *req_cmd,
-                stdout=asyncio.subprocess.DEVNULL,
-                stderr=asyncio.subprocess.DEVNULL,
-            )
-            await req_proc.communicate()
-            print(f"✅ Queued on radio: {title}")
-        else:
-            print(f"⚠️ Uploaded, but no unique_id returned. Response: {stdout.decode()}")
-    except json.JSONDecodeError:
-        print(f"❌ Failed to parse AzuraCast response: {stdout.decode()}")
 
-    # Cleanup the local file so your container doesn't bloat
+        # Sanitize title for the local filesystem
-    if os.path.exists(filepath):
+        safe_title = "".join(c for c in title if c.isalnum() or c in " -_").strip()
-        os.remove(filepath)
+        base_filename = f"{safe_title}_{video_id}"
+        base_filepath = os.path.join(DATA_DIR, base_filename)
+
+        print(f"📻 Downloading audio for radio: {title}")
+
+        # 1. Download with yt-dlp
+        dl_cmd = [
+            "yt-dlp",
+            "--extract-audio",
+            "--output",
+            f"{base_filepath}.%(ext)s",
+            video_link,
+        ]
+
+        process = await asyncio.create_subprocess_exec(
+            *dl_cmd,
+            stdout=asyncio.subprocess.DEVNULL,
+            stderr=asyncio.subprocess.DEVNULL,
+        )
+        await process.communicate()
+
+        # Check for the file using glob
+        downloaded_files = glob.glob(f"{base_filepath}.*")
+
+        if not downloaded_files:
+            print(f"❌ Failed to download audio for {title}")
+            return
+
+        filepath = downloaded_files[0]
+
+        print(f"📻 Uploading to AzuraCast: {title}")
+
+        # 2. Upload to AzuraCast using curl
+        upload_cmd = [
+            "curl",
+            "-s",
+            "-X",
+            "POST",
+            f"{AZURACAST_URL}/api/station/{AZURACAST_STATION_ID}/files",
+            "-H",
+            f"X-API-Key: {AZURACAST_API_KEY}",
+            "-F",
+            f"file=@{filepath}",
+        ]
+
+        curl_proc = await asyncio.create_subprocess_exec(
+            *upload_cmd, stdout=asyncio.subprocess.PIPE, stderr=asyncio.subprocess.PIPE
+        )
+        stdout, _ = await curl_proc.communicate()
+
+        # 3. Extract unique_id and queue
+        try:
+            response = json.loads(stdout.decode())
+            unique_id = response.get("unique_id")
+
+            if unique_id:
+                req_cmd = [
+                    "curl",
+                    "-s",
+                    "-X",
+                    "POST",
+                    f"{AZURACAST_URL}/api/station/{AZURACAST_STATION_ID}/request/{unique_id}",
+                    "-H",
+                    f"X-API-Key: {AZURACAST_API_KEY}",
+                ]
+                req_proc = await asyncio.create_subprocess_exec(
+                    *req_cmd,
+                    stdout=asyncio.subprocess.DEVNULL,
+                    stderr=asyncio.subprocess.DEVNULL,
+                )
+                await req_proc.communicate()
+                print(f"✅ Queued on radio: {title}")
+            else:
+                print(f"⚠️ Uploaded, but no unique_id returned: {stdout.decode()}")
+        except json.JSONDecodeError:
+            print(f"❌ Failed to parse AzuraCast response: {stdout.decode()}")
+
+        if os.path.exists(filepath):
+            os.remove(filepath)
+
+    except Exception as e:
+        print(f"💥 CRITICAL ERROR in background task: {e}")
+        traceback.print_exc()
 
 
 async def main():
@@ -537,6 +548,7 @@ async def main():
     youtube = get_authenticated_service()
     client = await get_client(conn, cursor, youtube)
     sync_token = load_sync_token()
+    background_tasks = set()
 
     # This is incredibly dumb and most probably will exceed your YouTube API quota.
     if args.backwards_sync: