Roman/ohm_streaming
1
0
Fork 0
Code Issues Pull Requests 2 Actions Packages Projects Releases Wiki Activity

feat: add download-all endpoint for watchlist items

Browse Source
This commit is contained in:
root
2026-02-27 13:57:01 +00:00
parent 24567b58cf
commit 13b017a206
1 changed files with 1 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files
main.py
-6
View File
@@ -2086,8 +2086,6 @@ async def check_watchlist_item(
return result return result
except HTTPException: except HTTPException:
raise raise
except Exception as e:
logger.error(f"Error checking watchlist item: {e}", exc_info=True)
except Exception as e: except Exception as e:
logger.error(f"Error checking watchlist item: {e}", exc_info=True) logger.error(f"Error checking watchlist item: {e}", exc_info=True)
raise HTTPException(status_code=500, detail=str(e)) raise HTTPException(status_code=500, detail=str(e))
@@ -2104,7 +2102,6 @@ async def download_all_episodes(
if not item: if not item:
raise HTTPException(status_code=404, detail="Watchlist item not found") raise HTTPException(status_code=404, detail="Watchlist item not found")
# Check ownership
if item.user_id != current_user.id: if item.user_id != current_user.id:
raise HTTPException(status_code=403, detail="Access denied") raise HTTPException(status_code=403, detail="Access denied")
@@ -2121,7 +2118,6 @@ async def download_all_episodes(
"result": result "result": result
} }
finally: finally:
# Restore original value (the check will update it)
item.last_episode_downloaded = original_last_episode item.last_episode_downloaded = original_last_episode
watchlist_manager.db.commit() watchlist_manager.db.commit()
except HTTPException: except HTTPException:
@@ -2131,9 +2127,7 @@ async def download_all_episodes(
raise HTTPException(status_code=500, detail=str(e)) raise HTTPException(status_code=500, detail=str(e))
@app.post("/api/watchlist/{item_id}/pause", response_model=WatchlistItem, tags=["Watchlist"]) @app.post("/api/watchlist/{item_id}/pause", response_model=WatchlistItem, tags=["Watchlist"])
TB|@app.post("/api/watchlist/{item_id}/pause", response_model=WatchlistItem, tags=["Watchlist"])
@app.post("/api/watchlist/{item_id}/pause", response_model=WatchlistItem, tags=["Watchlist"]) @app.post("/api/watchlist/{item_id}/pause", response_model=WatchlistItem, tags=["Watchlist"])