lukas.pupkalipinski/Aniworld
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix: download status

Browse Source
This commit is contained in:
Lukas
2025-11-20 19:02:04 +01:00
parent cf503c8d77
commit 57da1f1272
4 changed files with 23 additions and 30 deletions
Download Patch File Download Diff File Expand all files Collapse all files

17
src/server/services/anime_service.py
View File

@@ -65,36 +65,45 @@ class AnimeService:
)
return
# Use item_id if available, otherwise fallback to constructing ID
progress_id = (
args.item_id
if args.item_id
else f"download_{args.serie_folder}_{args.season}_{args.episode}"
)
# Map SeriesApp download events to progress service
if args.status == "started":
loop.create_task(
self._progress_service.start_progress(
progress_id=f"download_{args.serie_folder}_{args.season}_{args.episode}", # noqa: E501
progress_id=progress_id,
progress_type=ProgressType.DOWNLOAD,
title=f"Downloading {args.serie_folder}",
message=f"S{args.season:02d}E{args.episode:02d}",
metadata={"item_id": args.item_id} if args.item_id else None,
)
)
elif args.status == "progress":
loop.create_task(
self._progress_service.update_progress(
progress_id=f"download_{args.serie_folder}_{args.season}_{args.episode}", # noqa: E501
progress_id=progress_id,
current=int(args.progress),
total=100,
message=args.message or "Downloading...",
metadata={"item_id": args.item_id} if args.item_id else None,
)
)
elif args.status == "completed":
loop.create_task(
self._progress_service.complete_progress(
progress_id=f"download_{args.serie_folder}_{args.season}_{args.episode}", # noqa: E501
progress_id=progress_id,
message="Download completed",
)
)
elif args.status == "failed":
loop.create_task(
self._progress_service.fail_progress(
progress_id=f"download_{args.serie_folder}_{args.season}_{args.episode}", # noqa: E501
progress_id=progress_id,
error_message=args.message or str(args.error),
)
)