mbrucedogs/KaraokeVideoDownloader
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Signed-off-by: mbrucedogs <mbrucedogs@gmail.com>

Browse Source
This commit is contained in:
mbrucedogs 2025-07-29 08:49:43 -05:00
parent 42e7a6a09c
commit 409e66780c
1 changed files with 80 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

89
karaoke_downloader/downloader.py
View File

@ -384,6 +384,67 @@ class KaraokeDownloader:
print("🎵 No new videos to download.")
return True
# Create download plan for caching and resuming
download_plan = []
for video, artist, title, filename in videos_to_download:
download_plan.append({
"video_id": video["id"],
"artist": artist,
"title": title,
"filename": filename,
"channel_name": channel_name,
"video_title": video.get("title", ""),
"force_download": force_download
})
# Cache the download plan for resuming
import hashlib
from karaoke_downloader.cache_manager import get_download_plan_cache_file, save_plan_cache, load_cached_plan
plan_kwargs = {
"channel": channel_name,
"total_videos": len(available_videos),
"force_download": force_download,
}
if limit:
plan_kwargs["limit"] = limit
cache_file = get_download_plan_cache_file("all_videos", **plan_kwargs)
# Check for existing cache
cached_plan, _ = load_cached_plan(cache_file)
if cached_plan and not force_refresh:
print(f"\n📋 Found existing download plan cache: {cache_file.name}")
print(f" 🎬 Cached videos to download: {len(cached_plan)}")
download_plan = cached_plan
else:
# Create new download plan
download_plan = []
for video, artist, title, filename in videos_to_download:
download_plan.append({
"video_id": video["id"],
"artist": artist,
"title": title,
"filename": filename,
"channel_name": channel_name,
"video_title": video.get("title", ""),
"force_download": force_download
})
# Save the new plan to cache
save_plan_cache(cache_file, download_plan, []) # No unmatched for all-videos mode
# Show download plan summary
print(f"\n📋 Download Plan Summary:")
print(f" 📺 Channel: {channel_name}")
print(f" 🎬 Total videos to download: {len(videos_to_download)}")
print(f" ⏭️ Videos skipped: {skipped_count}")
if limit:
print(f" 🎯 Limit applied: {limit} videos")
print(f" 📁 Output directory: downloads/{channel_name}/")
print(f" 💾 Download plan cached to: {cache_file.name}")
print(f"\n🎬 Starting downloads...")
# Download videos using the download pipeline
pipeline = DownloadPipeline(
yt_dlp_path=str(self.yt_dlp_path),
@ -394,22 +455,30 @@ class KaraokeDownloader:
)
success_count = 0
for i, (video, artist, title, filename) in enumerate(videos_to_download, 1):
print(f"⬇️ Downloading {i}/{len(videos_to_download)}: {artist} - {title}")
total_to_download = len(download_plan)
for i, plan_item in enumerate(download_plan[:], 1): # Use slice to create a copy for iteration
print(f"⬇️ Downloading {i}/{total_to_download}: {plan_item['artist']} - {plan_item['title']}")
if pipeline.execute_pipeline(
video_id=video["id"],
artist=artist,
title=title,
channel_name=channel_name,
video_title=video.get("title", ""),
video_id=plan_item["video_id"],
artist=plan_item["artist"],
title=plan_item["title"],
channel_name=plan_item["channel_name"],
video_title=plan_item["video_title"],
):
print(f"✅ Successfully downloaded: {artist} - {title}")
success_count += 1
# Remove completed item from cache
download_plan.remove(plan_item) # Remove the current item
if download_plan: # If there are still items left
save_plan_cache(cache_file, download_plan, [])
print(f"🗑️ Removed completed item from download plan. {len(download_plan)} items remaining.")
else:
print(f"❌ Failed to download: {artist} - {title}")
# All downloads completed, delete the cache file
from karaoke_downloader.cache_manager import delete_plan_cache
delete_plan_cache(cache_file)
print("🗑️ All downloads completed, deleted download plan cache.")
print(f"\n🎉 Download complete! {success_count}/{len(videos_to_download)} videos downloaded successfully")
print(f"\n🎉 Download complete! {success_count}/{total_to_download} videos downloaded successfully")
return success_count > 0
def download_songlist_across_channels(