Rephl3x/Magent
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Route grabs through Sonarr/Radarr only

Browse Source
This commit is contained in:
Zak Bearman
2026-01-24 19:06:40 +13:00
parent 52e3d680f7
commit 5fa3aa6665
1 changed files with 2 additions and 46 deletions
Download Patch File Download Diff File Expand all files Collapse all files

48
backend/app/routers/requests.py
View File

@@ -1619,29 +1619,7 @@ async def action_grab(
try: try:
response = await client.grab_release(str(guid), int(indexer_id)) response = await client.grab_release(str(guid), int(indexer_id))
except httpx.HTTPStatusError as exc: except httpx.HTTPStatusError as exc:
status_code = exc.response.status_code if exc.response is not None else 502 raise HTTPException(status_code=502, detail=f"Sonarr grab failed: {exc}") from exc
if status_code == 404 and download_url:
qbit = QBittorrentClient(
runtime.qbittorrent_base_url,
runtime.qbittorrent_username,
runtime.qbittorrent_password,
)
if not qbit.configured():
raise HTTPException(status_code=400, detail="qBittorrent not configured")
try:
await qbit.add_torrent_url(str(download_url), category=f"magent-{request_id}")
except httpx.HTTPStatusError as qbit_exc:
raise HTTPException(status_code=502, detail=str(qbit_exc)) from qbit_exc
await asyncio.to_thread(
save_action,
request_id,
"grab",
"Grab release",
"ok",
"Sent to qBittorrent via Prowlarr.",
)
return {"status": "ok", "message": "Sent to qBittorrent.", "via": "qbittorrent"}
raise HTTPException(status_code=502, detail=str(exc)) from exc
await asyncio.to_thread( await asyncio.to_thread(
save_action, request_id, "grab", "Grab release", "ok", "Grab sent to Sonarr." save_action, request_id, "grab", "Grab release", "ok", "Grab sent to Sonarr."
) )
@@ -1653,29 +1631,7 @@ async def action_grab(
try: try:
response = await client.grab_release(str(guid), int(indexer_id)) response = await client.grab_release(str(guid), int(indexer_id))
except httpx.HTTPStatusError as exc: except httpx.HTTPStatusError as exc:
status_code = exc.response.status_code if exc.response is not None else 502 raise HTTPException(status_code=502, detail=f"Radarr grab failed: {exc}") from exc
if status_code == 404 and download_url:
qbit = QBittorrentClient(
runtime.qbittorrent_base_url,
runtime.qbittorrent_username,
runtime.qbittorrent_password,
)
if not qbit.configured():
raise HTTPException(status_code=400, detail="qBittorrent not configured")
try:
await qbit.add_torrent_url(str(download_url), category=f"magent-{request_id}")
except httpx.HTTPStatusError as qbit_exc:
raise HTTPException(status_code=502, detail=str(qbit_exc)) from qbit_exc
await asyncio.to_thread(
save_action,
request_id,
"grab",
"Grab release",
"ok",
"Sent to qBittorrent via Prowlarr.",
)
return {"status": "ok", "message": "Sent to qBittorrent.", "via": "qbittorrent"}
raise HTTPException(status_code=502, detail=str(exc)) from exc
await asyncio.to_thread( await asyncio.to_thread(
save_action, request_id, "grab", "Grab release", "ok", "Grab sent to Radarr." save_action, request_id, "grab", "Grab release", "ok", "Grab sent to Radarr."
) )